Function internalNew

tempodb/backend/s3/s3.go:117–169

(cfg *Config, confirm bool)

}

func internalNew(cfg *Config, confirm bool) (*readerWriter, error) {
	if cfg == nil {
		return nil, fmt.Errorf("config is nil")
	}

	l := log.Logger

	// Global minio settings that affect all minio clients in the process
	if cfg.RetryMaxAttempts > 0 {
		minio.MaxRetry = cfg.RetryMaxAttempts
	}

	if cfg.RetryBackoffInitial > 0 {
		minio.DefaultRetryUnit = cfg.RetryBackoffInitial
	}

	if cfg.RetryBackoffMax > 0 {
		minio.DefaultRetryCap = cfg.RetryBackoffMax
	}

	core, err := createCore(cfg, false)
	if err != nil {
		return nil, fmt.Errorf("unexpected error creating core: %w", err)
	}

	hedgedCore, err := createCore(cfg, true)
	if err != nil {
		return nil, fmt.Errorf("unexpected error creating hedgedCore: %w", err)
	}

	// try listing objects
	if confirm {
		_, err = core.ListObjects(cfg.Bucket, cfg.Prefix, "", "/", 1)
		if err != nil {
			return nil, fmt.Errorf("unexpected error from ListObjects on %s: %w", cfg.Bucket, err)
		}
	}

	encryption, err := buildSSEConfig(cfg)
	if err != nil {
		return nil, fmt.Errorf("returned Error when trying to configure Server Side Encryption: %w", err)
	}

	rw := &readerWriter{
		logger:     l,
		cfg:        cfg,
		core:       core,
		hedgedCore: hedgedCore,
		sse:        encryption,
	}

	return rw, nil
}

func getPutObjectOptions(rw *readerWriter) minio.PutObjectOptions {
	return minio.PutObjectOptions{