Function createCore

tempodb/backend/s3/s3.go:729–784

(cfg *Config, hedge bool)

}

func createCore(cfg *Config, hedge bool) (*minio.Core, error) {
	creds, err := fetchCreds(cfg)
	if err != nil {
		return nil, fmt.Errorf("failed to fetch credentials: %w", err)
	}

	customTransport, err := minio.DefaultTransport(!cfg.Insecure)
	if err != nil {
		return nil, fmt.Errorf("create minio.DefaultTransport: %w", err)
	}

	/* minio sets MaxIdleConns to 100 but we should also increase per host to 100 */
	customTransport.MaxIdleConnsPerHost = 100
	customTransport.MaxIdleConns = 100

	tlsConfig, err := cfg.GetTLSConfig()
	if err != nil {
		return nil, fmt.Errorf("failed to create TLS config: %w", err)
	}

	if tlsConfig != nil {
		customTransport.TLSClientConfig = tlsConfig
	}

	// add instrumentation
	transport := instrumentation.NewTransport(customTransport)
	var stats *hedgedhttp.Stats
	if hedge && cfg.HedgeRequestsAt != 0 {
		transport, stats, err = hedgedhttp.NewRoundTripperAndStats(cfg.HedgeRequestsAt, cfg.HedgeRequestsUpTo, transport)
		if err != nil {
			return nil, err
		}
		instrumentation.PublishHedgedMetrics(stats)
	}

	opts := &minio.Options{
		Region:    cfg.Region,
		Secure:    !cfg.Insecure,
		Creds:     creds,
		Transport: transport,
	}

	if cfg.ForcePathStyle {
		opts.BucketLookup = minio.BucketLookupPath
	} else {
		opts.BucketLookup = minio.BucketLookupType(cfg.BucketLookupType)
	}

	core, err := minio.NewCore(cfg.Endpoint, opts)
	if err != nil {
		return nil, fmt.Errorf("failed to create minio client: %w", err)
	}

	core.SetS3EnableDualstack(cfg.UseDualStack)
	return core, err
}

func readError(err error) error {