Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + const RingCheckPeriod + func IsInReplicationSet(r ring.ReadRing, ringKey uint32, address string) (bool, error) + func TokenFor(userID, labels string) uint32 + type ManagerMode int + const ClientMode + const ServerMode + type NoopStrategy struct + func (s *NoopStrategy) OwnsTenant(_ string) (ring.ReadRing, bool) + type RingConfig struct + EnableIPv6 bool + HeartbeatPeriod time.Duration + HeartbeatTimeout time.Duration + InstanceAddr string + InstanceID string + InstanceInterfaceNames []string + InstancePort int + InstanceZone string + KVStore kv.Config + ListenPort int + NumTokens int + ObservePeriod time.Duration + ReplicationFactor int + TokensFilePath string + ZoneAwarenessEnabled bool + func CortexLifecyclerConfigToRingConfig(cfg ring.LifecyclerConfig) RingConfig + func (cfg *RingConfig) RegisterFlagsWithPrefix(flagsPrefix, storePrefix string, fs *flag.FlagSet, skip ...string) + func (cfg *RingConfig) ToLifecyclerConfig(numTokens int, logger log.Logger) (ring.BasicLifecyclerConfig, error) + func (cfg *RingConfig) ToRingConfig(replicationFactor int) ring.Config + type RingManager struct + Mode ManagerMode + Ring *ring.Ring + RingLifecycler *ring.BasicLifecycler + func NewRingManager(name string, mode ManagerMode, cfg RingConfig, rf int, tokens int, ...) (*RingManager, error) + func (rm *RingManager) OnRingInstanceHeartbeat(_ *ring.BasicLifecycler, _ *ring.Desc, _ *ring.InstanceDesc) + func (rm *RingManager) OnRingInstanceRegister(_ *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, _ string, ...) (ring.InstanceState, ring.Tokens) + func (rm *RingManager) OnRingInstanceStopping(_ *ring.BasicLifecycler) + func (rm *RingManager) OnRingInstanceTokens(_ *ring.BasicLifecycler, _ ring.Tokens) + func (rm *RingManager) ServeHTTP(w http.ResponseWriter, req *http.Request) + type TenantSharding interface + OwnsTenant func(tenantID string) (tenantRing ring.ReadRing, owned bool) + type TenantShuffleSharding struct + func NewTenantShuffleSharding(r ring.ReadRing, ringLifeCycler *ring.BasicLifecycler, ...) *TenantShuffleSharding + func (s *TenantShuffleSharding) OwnsTenant(tenantID string) (ring.ReadRing, bool)