Versions in this module Expand all Collapse all v2 v2.6.2 Aug 12, 2022 Changes in this version + const RingIdentifier + const RingKey + type Config struct + Mode Mode + Ring RingCfg + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type Gateway struct + func NewIndexGateway(cfg Config, log log.Logger, registerer prometheus.Registerer, ...) (*Gateway, error) + func (g *Gateway) GetChunkRef(ctx context.Context, req *logproto.GetChunkRefRequest) (*logproto.GetChunkRefResponse, error) + func (g *Gateway) GetSeries(ctx context.Context, req *logproto.GetSeriesRequest) (*logproto.GetSeriesResponse, error) + func (g *Gateway) GetStats(ctx context.Context, req *logproto.IndexStatsRequest) (*logproto.IndexStatsResponse, error) + func (g *Gateway) LabelNamesForMetricName(ctx context.Context, req *logproto.LabelNamesForMetricNameRequest) (*logproto.LabelResponse, error) + func (g *Gateway) LabelValuesForMetricName(ctx context.Context, req *logproto.LabelValuesForMetricNameRequest) (*logproto.LabelResponse, error) + func (g *Gateway) QueryIndex(request *logproto.QueryIndexRequest, ...) error + type IndexClient interface + QueryPages func(ctx context.Context, queries []index.Query, callback index.QueryPagesCallback) error + Stop func() + type IndexQuerier interface + GetChunkRefs func(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*fetcher.Fetcher, error) + GetSeries func(ctx context.Context, userID string, from, through model.Time, ...) ([]labels.Labels, error) + LabelNamesForMetricName func(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + LabelValuesForMetricName func(ctx context.Context, userID string, from, through model.Time, ...) ([]string, error) + Stats func(ctx context.Context, userID string, from, through model.Time, ...) (*stats.Stats, error) + Stop func() + type ManagerMode int + const ClientMode + const ServerMode + type Mode string + const RingMode + const SimpleMode + func (i Mode) Set(v string) error + func (i Mode) String() string + type RingCfg struct + ReplicationFactor int + func (cfg *RingCfg) RegisterFlags(prefix, storePrefix string, f *flag.FlagSet) + type RingManager struct + Ring *ring.Ring + RingLifecycler *ring.BasicLifecycler + func NewRingManager(managerMode ManagerMode, cfg Config, log log.Logger, ...) (*RingManager, error) + func (rm *RingManager) IndexGatewayOwnsTenant(tenant string) bool + func (rm *RingManager) OnRingInstanceHeartbeat(_ *ring.BasicLifecycler, _ *ring.Desc, _ *ring.InstanceDesc) + func (rm *RingManager) OnRingInstanceRegister(_ *ring.BasicLifecycler, ringDesc ring.Desc, instanceExists bool, ...) (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)
Go to main page