Method initPartitionRing

cmd/tempo/app/modules.go:172–199

()

}

func (t *App) initPartitionRing() (services.Service, error) {
	var (
		heartbeatTimeout time.Duration
		readRing         ring.InstanceRingReader
		ringName         string
		ringKey          string
		kvConfig         kv.Config
	)

	heartbeatTimeout = t.cfg.LiveStore.Ring.HeartbeatTimeout
	readRing = t.readRings[ringLiveStore]
	ringName = livestore.PartitionRingName
	ringKey = livestore.PartitionRingKey
	kvConfig = t.cfg.LiveStore.PartitionRing.KVStore

	kvClient, err := kv.NewClient(kvConfig, ring.GetPartitionRingCodec(), kv.RegistererWithKVName(prometheus.DefaultRegisterer, ringName+"-watcher"), util_log.Logger)
	if err != nil {
		return nil, fmt.Errorf("creating KV store for %s partitions ring watcher: %w", ringName, err)
	}

	t.partitionRingWatcher = ring.NewPartitionRingWatcher(ringName, ringKey, kvClient, util_log.Logger, prometheus.WrapRegistererWithPrefix("tempo_", prometheus.DefaultRegisterer))
	t.partitionRing = ring.NewPartitionInstanceRing(t.partitionRingWatcher, readRing, heartbeatTimeout)

	// Expose a web page to view the partitions ring state.
	t.Server.HTTPRouter().Path("/partition-ring").Methods("GET", "POST").Handler(ring.NewPartitionRingPageHandler(t.partitionRingWatcher, ring.NewPartitionRingEditor(ringKey, kvClient)))

	return t.partitionRingWatcher, nil
}

func (t *App) initOverrides() (services.Service, error) {
	o, err := overrides.NewOverrides(t.cfg.Overrides, newRuntimeConfigValidator(&t.cfg), prometheus.DefaultRegisterer)