Function loadBackend

cmd/tempo-cli/main.go:110–178

(b *backendOptions, g *globalOptions)

}

func loadBackend(b *backendOptions, g *globalOptions) (backend.Reader, backend.Writer, backend.Compactor, error) {
	// Defaults
	cfg := app.Config{}
	cfg.RegisterFlagsAndApplyDefaults("", &flag.FlagSet{})

	// Existing config
	if g.ConfigFile != "" {
		buff, err := os.ReadFile(g.ConfigFile)
		if err != nil {
			return nil, nil, nil, fmt.Errorf("failed to read configFile %s: %w", g.ConfigFile, err)
		}

		err = yaml.UnmarshalStrict(buff, &cfg)
		if err != nil {
			return nil, nil, nil, fmt.Errorf("failed to parse configFile %s: %w", g.ConfigFile, err)
		}
	}

	// cli overrides
	if b.Backend != "" {
		cfg.StorageConfig.Trace.Backend = b.Backend
	}

	if b.Bucket != "" {
		cfg.StorageConfig.Trace.Local.Path = b.Bucket
		cfg.StorageConfig.Trace.GCS.BucketName = b.Bucket
		cfg.StorageConfig.Trace.S3.Bucket = b.Bucket
		cfg.StorageConfig.Trace.Azure.ContainerName = b.Bucket
	}

	cfg.StorageConfig.Trace.S3.InsecureSkipVerify = b.InsecureSkipVerify
	cfg.StorageConfig.Trace.GCS.Insecure = b.InsecureSkipVerify

	if b.S3User != "" {
		cfg.StorageConfig.Trace.S3.AccessKey = b.S3User
	}

	if b.S3Pass != "" {
		cfg.StorageConfig.Trace.S3.SecretKey = flagext.SecretWithValue(b.S3Pass)
	}

	if b.S3Endpoint != "" {
		cfg.StorageConfig.Trace.S3.Endpoint = b.S3Endpoint
	}

	var err error
	var r backend.RawReader
	var w backend.RawWriter
	var c backend.Compactor

	switch cfg.StorageConfig.Trace.Backend {
	case backend.Local:
		r, w, c, err = local.New(cfg.StorageConfig.Trace.Local)
	case backend.GCS:
		r, w, c, err = gcs.New(cfg.StorageConfig.Trace.GCS)
	case backend.S3:
		r, w, c, err = s3.New(cfg.StorageConfig.Trace.S3)
	case backend.Azure: