Versions in this module Expand all Collapse all v3 v3.0.1 Aug 9, 2024 v3.0.0 Apr 8, 2024 Changes in this version + type GatewayClient struct + func NewGatewayClient(cfg IndexGatewayClientConfig, r prometheus.Registerer, ...) (*GatewayClient, error) + func (s *GatewayClient) BatchWrite(_ context.Context, _ index.WriteBatch) error + func (s *GatewayClient) GetChunkRef(ctx context.Context, in *logproto.GetChunkRefRequest) (*logproto.GetChunkRefResponse, error) + func (s *GatewayClient) GetSeries(ctx context.Context, in *logproto.GetSeriesRequest) (*logproto.GetSeriesResponse, error) + func (s *GatewayClient) GetShards(ctx context.Context, in *logproto.ShardsRequest) (res *logproto.ShardsResponse, err error) + func (s *GatewayClient) GetStats(ctx context.Context, in *logproto.IndexStatsRequest) (*logproto.IndexStatsResponse, error) + func (s *GatewayClient) GetVolume(ctx context.Context, in *logproto.VolumeRequest) (*logproto.VolumeResponse, error) + func (s *GatewayClient) LabelNamesForMetricName(ctx context.Context, in *logproto.LabelNamesForMetricNameRequest) (*logproto.LabelResponse, error) + func (s *GatewayClient) LabelValuesForMetricName(ctx context.Context, in *logproto.LabelValuesForMetricNameRequest) (*logproto.LabelResponse, error) + func (s *GatewayClient) NewWriteBatch() index.WriteBatch + func (s *GatewayClient) QueryIndex(_ context.Context, _ *logproto.QueryIndexRequest, _ ...grpc.CallOption) (logproto.IndexGateway_QueryIndexClient, error) + func (s *GatewayClient) QueryPages(ctx context.Context, queries []index.Query, callback index.QueryPagesCallback) error + func (s *GatewayClient) Stop() + type IndexGatewayClientConfig struct + Address string + Disabled bool + GRCPStreamClientInterceptors []grpc.StreamClientInterceptor + GRPCClientConfig grpcclient.Config + GRPCUnaryClientInterceptors []grpc.UnaryClientInterceptor + LogGatewayRequests bool + Mode indexgateway.Mode + PoolConfig clientpool.PoolConfig + Ring ring.ReadRing + func (i *IndexGatewayClientConfig) RegisterFlags(f *flag.FlagSet) + func (i *IndexGatewayClientConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + type IndexGatewayGRPCPool struct + func NewIndexGatewayGRPCPool(address string, opts []grpc.DialOption) (*IndexGatewayGRPCPool, error)
Go to main page