indexgateway

type Config struct {
	// Mode configures in which mode the client will be running when querying and communicating with an Index Gateway instance.
	Mode Mode `yaml:"mode"`

	// Ring configures the ring key-value store used to save and retrieve the different Index Gateway instances.
	//
	// In case it isn't explicitly set, it follows the same behavior of the other rings (ex: using the common configuration
	// section and the ingester configuration by default).
	Ring RingCfg `` /* 272-byte string literal not displayed */
}

type Gateway struct {
	services.Service
	// contains filtered or unexported fields
}

type IndexClient interface {
	seriesindex.ReadClient
	Stop()
}

type IndexClientWithRange struct {
	IndexClient
	TableRange config.TableRange
}

type IndexQuerier interface {
	stores.ChunkFetcher
	index.BaseReader
	Stop()
}

type Limits interface {
	IndexGatewayShardSize(tenantID string) int
}

type ManagerMode int

type Mode string

type NoopStrategy struct{}

type RingCfg struct {
	// InternalRingCfg configures the Index Gateway ring.
	loki_util.RingConfig `yaml:",inline"`

	// ReplicationFactor defines how many Index Gateway instances are assigned to each tenant.
	//
	// Whenever the store queries the ring key-value store for the Index Gateway instance responsible for tenant X,
	// multiple Index Gateway instances are expected to be returned as Index Gateway might be busy/locked for specific
	// reasons (this is assured by the spikey behavior of Index Gateway latencies).
	ReplicationFactor int `yaml:"replication_factor"`
}

type RingManager struct {
	services.Service

	RingLifecycler *ring.BasicLifecycler
	Ring           *ring.Ring
	Mode           ManagerMode
	// contains filtered or unexported fields
}

type ServerInterceptors struct {
	PerTenantRequestCount grpc.UnaryServerInterceptor
	// contains filtered or unexported fields
}

type ShardingStrategy interface {
	// FilterTenants whose indexes should be loaded by the index gateway.
	// Returns the list of user IDs that should be synced by the index gateway.
	FilterTenants(tenantID []string) ([]string, error)
}

type ShuffleShardingStrategy struct {
	// contains filtered or unexported fields
}