Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + type GatewayClient struct + func NewGatewayClient(cfg IndexGatewayClientConfig, r prometheus.Registerer, logger log.Logger) (*GatewayClient, error) + func (s *GatewayClient) BatchWrite(_ context.Context, _ index.WriteBatch) error + func (s *GatewayClient) GetChunkRef(ctx context.Context, in *logproto.GetChunkRefRequest, opts ...grpc.CallOption) (*logproto.GetChunkRefResponse, error) + func (s *GatewayClient) GetLabelVolume(ctx context.Context, in *logproto.LabelVolumeRequest, opts ...grpc.CallOption) (*logproto.LabelVolumeResponse, error) + func (s *GatewayClient) GetSeries(ctx context.Context, in *logproto.GetSeriesRequest, opts ...grpc.CallOption) (*logproto.GetSeriesResponse, error) + func (s *GatewayClient) GetStats(ctx context.Context, in *logproto.IndexStatsRequest, opts ...grpc.CallOption) (*logproto.IndexStatsResponse, 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 + GRPCClientConfig grpcclient.Config + 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