Versions in this module Expand all Collapse all v2 v2.5.2 Apr 27, 2022 Changes in this version + var ErrIntOverflowIngester = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthIngester = fmt.Errorf("proto: negative length found during unmarshaling") + var MatchType_name = map[int32]string + var MatchType_value = map[string]int32 + func FastFingerprint(ls []logproto.LabelAdapter) model.Fingerprint + func Fingerprint(labels labels.Labels) model.Fingerprint + func LabelsToKeyString(l labels.Labels) string + func RegisterIngesterServer(s *grpc.Server, srv IngesterServer) + type Chunk struct + Data []byte + Encoding int32 + EndTimestampMs int64 + StartTimestampMs int64 + func (*Chunk) Descriptor() ([]byte, []int) + func (*Chunk) ProtoMessage() + func (m *Chunk) GetData() []byte + func (m *Chunk) GetEncoding() int32 + func (m *Chunk) GetEndTimestampMs() int64 + func (m *Chunk) GetStartTimestampMs() int64 + func (m *Chunk) Marshal() (dAtA []byte, err error) + func (m *Chunk) MarshalTo(dAtA []byte) (int, error) + func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Chunk) Reset() + func (m *Chunk) Size() (n int) + func (m *Chunk) Unmarshal(dAtA []byte) error + func (m *Chunk) XXX_DiscardUnknown() + func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Chunk) XXX_Merge(src proto.Message) + func (m *Chunk) XXX_Size() int + func (m *Chunk) XXX_Unmarshal(b []byte) error + func (this *Chunk) Equal(that interface{}) bool + func (this *Chunk) GoString() string + func (this *Chunk) String() string + type ClosableHealthAndIngesterClient struct + type Config struct + GRCPStreamClientInterceptors []grpc.StreamClientInterceptor + GRPCClientConfig grpcclient.Config + GRPCUnaryClientInterceptors []grpc.UnaryClientInterceptor + PoolConfig clientpool.PoolConfig + RemoteTimeout time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type ExemplarQueryRequest struct + EndTimestampMs int64 + Matchers []*LabelMatchers + StartTimestampMs int64 + func (*ExemplarQueryRequest) Descriptor() ([]byte, []int) + func (*ExemplarQueryRequest) ProtoMessage() + func (m *ExemplarQueryRequest) GetEndTimestampMs() int64 + func (m *ExemplarQueryRequest) GetMatchers() []*LabelMatchers + func (m *ExemplarQueryRequest) GetStartTimestampMs() int64 + func (m *ExemplarQueryRequest) Marshal() (dAtA []byte, err error) + func (m *ExemplarQueryRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ExemplarQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExemplarQueryRequest) Reset() + func (m *ExemplarQueryRequest) Size() (n int) + func (m *ExemplarQueryRequest) Unmarshal(dAtA []byte) error + func (m *ExemplarQueryRequest) XXX_DiscardUnknown() + func (m *ExemplarQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExemplarQueryRequest) XXX_Merge(src proto.Message) + func (m *ExemplarQueryRequest) XXX_Size() int + func (m *ExemplarQueryRequest) XXX_Unmarshal(b []byte) error + func (this *ExemplarQueryRequest) Equal(that interface{}) bool + func (this *ExemplarQueryRequest) GoString() string + func (this *ExemplarQueryRequest) String() string + type ExemplarQueryResponse struct + Timeseries []logproto.TimeSeries + func (*ExemplarQueryResponse) Descriptor() ([]byte, []int) + func (*ExemplarQueryResponse) ProtoMessage() + func (m *ExemplarQueryResponse) GetTimeseries() []logproto.TimeSeries + func (m *ExemplarQueryResponse) Marshal() (dAtA []byte, err error) + func (m *ExemplarQueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ExemplarQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExemplarQueryResponse) Reset() + func (m *ExemplarQueryResponse) Size() (n int) + func (m *ExemplarQueryResponse) Unmarshal(dAtA []byte) error + func (m *ExemplarQueryResponse) XXX_DiscardUnknown() + func (m *ExemplarQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExemplarQueryResponse) XXX_Merge(src proto.Message) + func (m *ExemplarQueryResponse) XXX_Size() int + func (m *ExemplarQueryResponse) XXX_Unmarshal(b []byte) error + func (this *ExemplarQueryResponse) Equal(that interface{}) bool + func (this *ExemplarQueryResponse) GoString() string + func (this *ExemplarQueryResponse) String() string + type HealthAndIngesterClient interface + Close func() error + func New(cfg Config, addr string) (HealthAndIngesterClient, error) + type IngesterClient interface + AllUserStats func(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UsersStatsResponse, error) + LabelNames func(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error) + LabelValues func(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error) + MetricsForLabelMatchers func(ctx context.Context, in *MetricsForLabelMatchersRequest, ...) (*MetricsForLabelMatchersResponse, error) + MetricsMetadata func(ctx context.Context, in *MetricsMetadataRequest, opts ...grpc.CallOption) (*MetricsMetadataResponse, error) + Push func(ctx context.Context, in *logproto.WriteRequest, opts ...grpc.CallOption) (*logproto.WriteResponse, error) + Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error) + QueryExemplars func(ctx context.Context, in *ExemplarQueryRequest, opts ...grpc.CallOption) (*ExemplarQueryResponse, error) + QueryStream func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Ingester_QueryStreamClient, error) + TransferChunks func(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, error) + UserStats func(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UserStatsResponse, error) + func NewIngesterClient(cc *grpc.ClientConn) IngesterClient + type IngesterServer interface + AllUserStats func(context.Context, *UserStatsRequest) (*UsersStatsResponse, error) + LabelNames func(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error) + LabelValues func(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error) + MetricsForLabelMatchers func(context.Context, *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error) + MetricsMetadata func(context.Context, *MetricsMetadataRequest) (*MetricsMetadataResponse, error) + Push func(context.Context, *logproto.WriteRequest) (*logproto.WriteResponse, error) + Query func(context.Context, *QueryRequest) (*QueryResponse, error) + QueryExemplars func(context.Context, *ExemplarQueryRequest) (*ExemplarQueryResponse, error) + QueryStream func(*QueryRequest, Ingester_QueryStreamServer) error + TransferChunks func(Ingester_TransferChunksServer) error + UserStats func(context.Context, *UserStatsRequest) (*UserStatsResponse, error) + type Ingester_QueryStreamClient interface + Recv func() (*QueryStreamResponse, error) + type Ingester_QueryStreamServer interface + Send func(*QueryStreamResponse) error + type Ingester_TransferChunksClient interface + CloseAndRecv func() (*TransferChunksResponse, error) + Send func(*TimeSeriesChunk) error + type Ingester_TransferChunksServer interface + Recv func() (*TimeSeriesChunk, error) + SendAndClose func(*TransferChunksResponse) error + type LabelMatcher struct + Name string + Type MatchType + Value string + func (*LabelMatcher) Descriptor() ([]byte, []int) + func (*LabelMatcher) ProtoMessage() + func (m *LabelMatcher) GetName() string + func (m *LabelMatcher) GetType() MatchType + func (m *LabelMatcher) GetValue() string + func (m *LabelMatcher) Marshal() (dAtA []byte, err error) + func (m *LabelMatcher) MarshalTo(dAtA []byte) (int, error) + func (m *LabelMatcher) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelMatcher) Reset() + func (m *LabelMatcher) Size() (n int) + func (m *LabelMatcher) Unmarshal(dAtA []byte) error + func (m *LabelMatcher) XXX_DiscardUnknown() + func (m *LabelMatcher) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelMatcher) XXX_Merge(src proto.Message) + func (m *LabelMatcher) XXX_Size() int + func (m *LabelMatcher) XXX_Unmarshal(b []byte) error + func (this *LabelMatcher) Equal(that interface{}) bool + func (this *LabelMatcher) GoString() string + func (this *LabelMatcher) String() string + type LabelMatchers struct + Matchers []*LabelMatcher + func (*LabelMatchers) Descriptor() ([]byte, []int) + func (*LabelMatchers) ProtoMessage() + func (m *LabelMatchers) GetMatchers() []*LabelMatcher + func (m *LabelMatchers) Marshal() (dAtA []byte, err error) + func (m *LabelMatchers) MarshalTo(dAtA []byte) (int, error) + func (m *LabelMatchers) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelMatchers) Reset() + func (m *LabelMatchers) Size() (n int) + func (m *LabelMatchers) Unmarshal(dAtA []byte) error + func (m *LabelMatchers) XXX_DiscardUnknown() + func (m *LabelMatchers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelMatchers) XXX_Merge(src proto.Message) + func (m *LabelMatchers) XXX_Size() int + func (m *LabelMatchers) XXX_Unmarshal(b []byte) error + func (this *LabelMatchers) Equal(that interface{}) bool + func (this *LabelMatchers) GoString() string + func (this *LabelMatchers) String() string + type LabelNamesRequest struct + EndTimestampMs int64 + StartTimestampMs int64 + func (*LabelNamesRequest) Descriptor() ([]byte, []int) + func (*LabelNamesRequest) ProtoMessage() + func (m *LabelNamesRequest) GetEndTimestampMs() int64 + func (m *LabelNamesRequest) GetStartTimestampMs() int64 + func (m *LabelNamesRequest) Marshal() (dAtA []byte, err error) + func (m *LabelNamesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LabelNamesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelNamesRequest) Reset() + func (m *LabelNamesRequest) Size() (n int) + func (m *LabelNamesRequest) Unmarshal(dAtA []byte) error + func (m *LabelNamesRequest) XXX_DiscardUnknown() + func (m *LabelNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelNamesRequest) XXX_Merge(src proto.Message) + func (m *LabelNamesRequest) XXX_Size() int + func (m *LabelNamesRequest) XXX_Unmarshal(b []byte) error + func (this *LabelNamesRequest) Equal(that interface{}) bool + func (this *LabelNamesRequest) GoString() string + func (this *LabelNamesRequest) String() string + type LabelNamesResponse struct + LabelNames []string + func (*LabelNamesResponse) Descriptor() ([]byte, []int) + func (*LabelNamesResponse) ProtoMessage() + func (m *LabelNamesResponse) GetLabelNames() []string + func (m *LabelNamesResponse) Marshal() (dAtA []byte, err error) + func (m *LabelNamesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LabelNamesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelNamesResponse) Reset() + func (m *LabelNamesResponse) Size() (n int) + func (m *LabelNamesResponse) Unmarshal(dAtA []byte) error + func (m *LabelNamesResponse) XXX_DiscardUnknown() + func (m *LabelNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelNamesResponse) XXX_Merge(src proto.Message) + func (m *LabelNamesResponse) XXX_Size() int + func (m *LabelNamesResponse) XXX_Unmarshal(b []byte) error + func (this *LabelNamesResponse) Equal(that interface{}) bool + func (this *LabelNamesResponse) GoString() string + func (this *LabelNamesResponse) String() string + type LabelValuesRequest struct + EndTimestampMs int64 + LabelName string + Matchers *LabelMatchers + StartTimestampMs int64 + func (*LabelValuesRequest) Descriptor() ([]byte, []int) + func (*LabelValuesRequest) ProtoMessage() + func (m *LabelValuesRequest) GetEndTimestampMs() int64 + func (m *LabelValuesRequest) GetLabelName() string + func (m *LabelValuesRequest) GetMatchers() *LabelMatchers + func (m *LabelValuesRequest) GetStartTimestampMs() int64 + func (m *LabelValuesRequest) Marshal() (dAtA []byte, err error) + func (m *LabelValuesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *LabelValuesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelValuesRequest) Reset() + func (m *LabelValuesRequest) Size() (n int) + func (m *LabelValuesRequest) Unmarshal(dAtA []byte) error + func (m *LabelValuesRequest) XXX_DiscardUnknown() + func (m *LabelValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelValuesRequest) XXX_Merge(src proto.Message) + func (m *LabelValuesRequest) XXX_Size() int + func (m *LabelValuesRequest) XXX_Unmarshal(b []byte) error + func (this *LabelValuesRequest) Equal(that interface{}) bool + func (this *LabelValuesRequest) GoString() string + func (this *LabelValuesRequest) String() string + type LabelValuesResponse struct + LabelValues []string + func (*LabelValuesResponse) Descriptor() ([]byte, []int) + func (*LabelValuesResponse) ProtoMessage() + func (m *LabelValuesResponse) GetLabelValues() []string + func (m *LabelValuesResponse) Marshal() (dAtA []byte, err error) + func (m *LabelValuesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *LabelValuesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LabelValuesResponse) Reset() + func (m *LabelValuesResponse) Size() (n int) + func (m *LabelValuesResponse) Unmarshal(dAtA []byte) error + func (m *LabelValuesResponse) XXX_DiscardUnknown() + func (m *LabelValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LabelValuesResponse) XXX_Merge(src proto.Message) + func (m *LabelValuesResponse) XXX_Size() int + func (m *LabelValuesResponse) XXX_Unmarshal(b []byte) error + func (this *LabelValuesResponse) Equal(that interface{}) bool + func (this *LabelValuesResponse) GoString() string + func (this *LabelValuesResponse) String() string + type MatchType int32 + const EQUAL + const NOT_EQUAL + const REGEX_MATCH + const REGEX_NO_MATCH + func (MatchType) EnumDescriptor() ([]byte, []int) + func (x MatchType) String() string + type MetricsForLabelMatchersRequest struct + EndTimestampMs int64 + MatchersSet []*LabelMatchers + StartTimestampMs int64 + func (*MetricsForLabelMatchersRequest) Descriptor() ([]byte, []int) + func (*MetricsForLabelMatchersRequest) ProtoMessage() + func (m *MetricsForLabelMatchersRequest) GetEndTimestampMs() int64 + func (m *MetricsForLabelMatchersRequest) GetMatchersSet() []*LabelMatchers + func (m *MetricsForLabelMatchersRequest) GetStartTimestampMs() int64 + func (m *MetricsForLabelMatchersRequest) Marshal() (dAtA []byte, err error) + func (m *MetricsForLabelMatchersRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsForLabelMatchersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MetricsForLabelMatchersRequest) Reset() + func (m *MetricsForLabelMatchersRequest) Size() (n int) + func (m *MetricsForLabelMatchersRequest) Unmarshal(dAtA []byte) error + func (m *MetricsForLabelMatchersRequest) XXX_DiscardUnknown() + func (m *MetricsForLabelMatchersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MetricsForLabelMatchersRequest) XXX_Merge(src proto.Message) + func (m *MetricsForLabelMatchersRequest) XXX_Size() int + func (m *MetricsForLabelMatchersRequest) XXX_Unmarshal(b []byte) error + func (this *MetricsForLabelMatchersRequest) Equal(that interface{}) bool + func (this *MetricsForLabelMatchersRequest) GoString() string + func (this *MetricsForLabelMatchersRequest) String() string + type MetricsForLabelMatchersResponse struct + Metric []*logproto.Metric + func (*MetricsForLabelMatchersResponse) Descriptor() ([]byte, []int) + func (*MetricsForLabelMatchersResponse) ProtoMessage() + func (m *MetricsForLabelMatchersResponse) GetMetric() []*logproto.Metric + func (m *MetricsForLabelMatchersResponse) Marshal() (dAtA []byte, err error) + func (m *MetricsForLabelMatchersResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsForLabelMatchersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MetricsForLabelMatchersResponse) Reset() + func (m *MetricsForLabelMatchersResponse) Size() (n int) + func (m *MetricsForLabelMatchersResponse) Unmarshal(dAtA []byte) error + func (m *MetricsForLabelMatchersResponse) XXX_DiscardUnknown() + func (m *MetricsForLabelMatchersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MetricsForLabelMatchersResponse) XXX_Merge(src proto.Message) + func (m *MetricsForLabelMatchersResponse) XXX_Size() int + func (m *MetricsForLabelMatchersResponse) XXX_Unmarshal(b []byte) error + func (this *MetricsForLabelMatchersResponse) Equal(that interface{}) bool + func (this *MetricsForLabelMatchersResponse) GoString() string + func (this *MetricsForLabelMatchersResponse) String() string + type MetricsMetadataRequest struct + func (*MetricsMetadataRequest) Descriptor() ([]byte, []int) + func (*MetricsMetadataRequest) ProtoMessage() + func (m *MetricsMetadataRequest) Marshal() (dAtA []byte, err error) + func (m *MetricsMetadataRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MetricsMetadataRequest) Reset() + func (m *MetricsMetadataRequest) Size() (n int) + func (m *MetricsMetadataRequest) Unmarshal(dAtA []byte) error + func (m *MetricsMetadataRequest) XXX_DiscardUnknown() + func (m *MetricsMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MetricsMetadataRequest) XXX_Merge(src proto.Message) + func (m *MetricsMetadataRequest) XXX_Size() int + func (m *MetricsMetadataRequest) XXX_Unmarshal(b []byte) error + func (this *MetricsMetadataRequest) Equal(that interface{}) bool + func (this *MetricsMetadataRequest) GoString() string + func (this *MetricsMetadataRequest) String() string + type MetricsMetadataResponse struct + Metadata []*logproto.MetricMetadata + func (*MetricsMetadataResponse) Descriptor() ([]byte, []int) + func (*MetricsMetadataResponse) ProtoMessage() + func (m *MetricsMetadataResponse) GetMetadata() []*logproto.MetricMetadata + func (m *MetricsMetadataResponse) Marshal() (dAtA []byte, err error) + func (m *MetricsMetadataResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MetricsMetadataResponse) Reset() + func (m *MetricsMetadataResponse) Size() (n int) + func (m *MetricsMetadataResponse) Unmarshal(dAtA []byte) error + func (m *MetricsMetadataResponse) XXX_DiscardUnknown() + func (m *MetricsMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MetricsMetadataResponse) XXX_Merge(src proto.Message) + func (m *MetricsMetadataResponse) XXX_Size() int + func (m *MetricsMetadataResponse) XXX_Unmarshal(b []byte) error + func (this *MetricsMetadataResponse) Equal(that interface{}) bool + func (this *MetricsMetadataResponse) GoString() string + func (this *MetricsMetadataResponse) String() string + type QueryRequest struct + EndTimestampMs int64 + Matchers []*LabelMatcher + StartTimestampMs int64 + func (*QueryRequest) Descriptor() ([]byte, []int) + func (*QueryRequest) ProtoMessage() + func (m *QueryRequest) GetEndTimestampMs() int64 + func (m *QueryRequest) GetMatchers() []*LabelMatcher + func (m *QueryRequest) GetStartTimestampMs() int64 + func (m *QueryRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequest) Reset() + func (m *QueryRequest) Size() (n int) + func (m *QueryRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequest) XXX_DiscardUnknown() + func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequest) XXX_Merge(src proto.Message) + func (m *QueryRequest) XXX_Size() int + func (m *QueryRequest) XXX_Unmarshal(b []byte) error + func (this *QueryRequest) Equal(that interface{}) bool + func (this *QueryRequest) GoString() string + func (this *QueryRequest) String() string + type QueryResponse struct + Timeseries []logproto.TimeSeries + func (*QueryResponse) Descriptor() ([]byte, []int) + func (*QueryResponse) ProtoMessage() + func (m *QueryResponse) GetTimeseries() []logproto.TimeSeries + func (m *QueryResponse) Marshal() (dAtA []byte, err error) + func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryResponse) Reset() + func (m *QueryResponse) Size() (n int) + func (m *QueryResponse) Unmarshal(dAtA []byte) error + func (m *QueryResponse) XXX_DiscardUnknown() + func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryResponse) XXX_Merge(src proto.Message) + func (m *QueryResponse) XXX_Size() int + func (m *QueryResponse) XXX_Unmarshal(b []byte) error + func (this *QueryResponse) Equal(that interface{}) bool + func (this *QueryResponse) GoString() string + func (this *QueryResponse) String() string + type QueryStreamResponse struct + Chunkseries []TimeSeriesChunk + Timeseries []logproto.TimeSeries + func (*QueryStreamResponse) Descriptor() ([]byte, []int) + func (*QueryStreamResponse) ProtoMessage() + func (m *QueryStreamResponse) GetChunkseries() []TimeSeriesChunk + func (m *QueryStreamResponse) GetTimeseries() []logproto.TimeSeries + func (m *QueryStreamResponse) Marshal() (dAtA []byte, err error) + func (m *QueryStreamResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryStreamResponse) Reset() + func (m *QueryStreamResponse) Size() (n int) + func (m *QueryStreamResponse) Unmarshal(dAtA []byte) error + func (m *QueryStreamResponse) XXX_DiscardUnknown() + func (m *QueryStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryStreamResponse) XXX_Merge(src proto.Message) + func (m *QueryStreamResponse) XXX_Size() int + func (m *QueryStreamResponse) XXX_Unmarshal(b []byte) error + func (this *QueryStreamResponse) Equal(that interface{}) bool + func (this *QueryStreamResponse) GoString() string + func (this *QueryStreamResponse) String() string + type ReadRequest struct + Queries []*QueryRequest + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetQueries() []*QueryRequest + func (m *ReadRequest) Marshal() (dAtA []byte, err error) + func (m *ReadRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReadRequest) Reset() + func (m *ReadRequest) Size() (n int) + func (m *ReadRequest) Unmarshal(dAtA []byte) error + func (m *ReadRequest) XXX_DiscardUnknown() + func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadRequest) XXX_Merge(src proto.Message) + func (m *ReadRequest) XXX_Size() int + func (m *ReadRequest) XXX_Unmarshal(b []byte) error + func (this *ReadRequest) Equal(that interface{}) bool + func (this *ReadRequest) GoString() string + func (this *ReadRequest) String() string + type ReadResponse struct + Results []*QueryResponse + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetResults() []*QueryResponse + func (m *ReadResponse) Marshal() (dAtA []byte, err error) + func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReadResponse) Reset() + func (m *ReadResponse) Size() (n int) + func (m *ReadResponse) Unmarshal(dAtA []byte) error + func (m *ReadResponse) XXX_DiscardUnknown() + func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadResponse) XXX_Merge(src proto.Message) + func (m *ReadResponse) XXX_Size() int + func (m *ReadResponse) XXX_Unmarshal(b []byte) error + func (this *ReadResponse) Equal(that interface{}) bool + func (this *ReadResponse) GoString() string + func (this *ReadResponse) String() string + type TimeSeriesChunk struct + Chunks []Chunk + FromIngesterId string + Labels []github_com_grafana_loki_pkg_logproto.LabelAdapter + UserId string + func (*TimeSeriesChunk) Descriptor() ([]byte, []int) + func (*TimeSeriesChunk) ProtoMessage() + func (m *TimeSeriesChunk) GetChunks() []Chunk + func (m *TimeSeriesChunk) GetFromIngesterId() string + func (m *TimeSeriesChunk) GetUserId() string + func (m *TimeSeriesChunk) Marshal() (dAtA []byte, err error) + func (m *TimeSeriesChunk) MarshalTo(dAtA []byte) (int, error) + func (m *TimeSeriesChunk) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TimeSeriesChunk) Reset() + func (m *TimeSeriesChunk) Size() (n int) + func (m *TimeSeriesChunk) Unmarshal(dAtA []byte) error + func (m *TimeSeriesChunk) XXX_DiscardUnknown() + func (m *TimeSeriesChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeSeriesChunk) XXX_Merge(src proto.Message) + func (m *TimeSeriesChunk) XXX_Size() int + func (m *TimeSeriesChunk) XXX_Unmarshal(b []byte) error + func (this *TimeSeriesChunk) Equal(that interface{}) bool + func (this *TimeSeriesChunk) GoString() string + func (this *TimeSeriesChunk) String() string + type TimeSeriesFile struct + Data []byte + Filename string + FromIngesterId string + UserId string + func (*TimeSeriesFile) Descriptor() ([]byte, []int) + func (*TimeSeriesFile) ProtoMessage() + func (m *TimeSeriesFile) GetData() []byte + func (m *TimeSeriesFile) GetFilename() string + func (m *TimeSeriesFile) GetFromIngesterId() string + func (m *TimeSeriesFile) GetUserId() string + func (m *TimeSeriesFile) Marshal() (dAtA []byte, err error) + func (m *TimeSeriesFile) MarshalTo(dAtA []byte) (int, error) + func (m *TimeSeriesFile) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TimeSeriesFile) Reset() + func (m *TimeSeriesFile) Size() (n int) + func (m *TimeSeriesFile) Unmarshal(dAtA []byte) error + func (m *TimeSeriesFile) XXX_DiscardUnknown() + func (m *TimeSeriesFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeSeriesFile) XXX_Merge(src proto.Message) + func (m *TimeSeriesFile) XXX_Size() int + func (m *TimeSeriesFile) XXX_Unmarshal(b []byte) error + func (this *TimeSeriesFile) Equal(that interface{}) bool + func (this *TimeSeriesFile) GoString() string + func (this *TimeSeriesFile) String() string + type TransferChunksResponse struct + func (*TransferChunksResponse) Descriptor() ([]byte, []int) + func (*TransferChunksResponse) ProtoMessage() + func (m *TransferChunksResponse) Marshal() (dAtA []byte, err error) + func (m *TransferChunksResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TransferChunksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransferChunksResponse) Reset() + func (m *TransferChunksResponse) Size() (n int) + func (m *TransferChunksResponse) Unmarshal(dAtA []byte) error + func (m *TransferChunksResponse) XXX_DiscardUnknown() + func (m *TransferChunksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransferChunksResponse) XXX_Merge(src proto.Message) + func (m *TransferChunksResponse) XXX_Size() int + func (m *TransferChunksResponse) XXX_Unmarshal(b []byte) error + func (this *TransferChunksResponse) Equal(that interface{}) bool + func (this *TransferChunksResponse) GoString() string + func (this *TransferChunksResponse) String() string + type UnimplementedIngesterServer struct + func (*UnimplementedIngesterServer) AllUserStats(ctx context.Context, req *UserStatsRequest) (*UsersStatsResponse, error) + func (*UnimplementedIngesterServer) LabelNames(ctx context.Context, req *LabelNamesRequest) (*LabelNamesResponse, error) + func (*UnimplementedIngesterServer) LabelValues(ctx context.Context, req *LabelValuesRequest) (*LabelValuesResponse, error) + func (*UnimplementedIngesterServer) MetricsForLabelMatchers(ctx context.Context, req *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error) + func (*UnimplementedIngesterServer) MetricsMetadata(ctx context.Context, req *MetricsMetadataRequest) (*MetricsMetadataResponse, error) + func (*UnimplementedIngesterServer) Push(ctx context.Context, req *logproto.WriteRequest) (*logproto.WriteResponse, error) + func (*UnimplementedIngesterServer) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, error) + func (*UnimplementedIngesterServer) QueryExemplars(ctx context.Context, req *ExemplarQueryRequest) (*ExemplarQueryResponse, error) + func (*UnimplementedIngesterServer) QueryStream(req *QueryRequest, srv Ingester_QueryStreamServer) error + func (*UnimplementedIngesterServer) TransferChunks(srv Ingester_TransferChunksServer) error + func (*UnimplementedIngesterServer) UserStats(ctx context.Context, req *UserStatsRequest) (*UserStatsResponse, error) + type UserIDStatsResponse struct + Data *UserStatsResponse + UserId string + func (*UserIDStatsResponse) Descriptor() ([]byte, []int) + func (*UserIDStatsResponse) ProtoMessage() + func (m *UserIDStatsResponse) GetData() *UserStatsResponse + func (m *UserIDStatsResponse) GetUserId() string + func (m *UserIDStatsResponse) Marshal() (dAtA []byte, err error) + func (m *UserIDStatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UserIDStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UserIDStatsResponse) Reset() + func (m *UserIDStatsResponse) Size() (n int) + func (m *UserIDStatsResponse) Unmarshal(dAtA []byte) error + func (m *UserIDStatsResponse) XXX_DiscardUnknown() + func (m *UserIDStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UserIDStatsResponse) XXX_Merge(src proto.Message) + func (m *UserIDStatsResponse) XXX_Size() int + func (m *UserIDStatsResponse) XXX_Unmarshal(b []byte) error + func (this *UserIDStatsResponse) Equal(that interface{}) bool + func (this *UserIDStatsResponse) GoString() string + func (this *UserIDStatsResponse) String() string + type UserStatsRequest struct + func (*UserStatsRequest) Descriptor() ([]byte, []int) + func (*UserStatsRequest) ProtoMessage() + func (m *UserStatsRequest) Marshal() (dAtA []byte, err error) + func (m *UserStatsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UserStatsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UserStatsRequest) Reset() + func (m *UserStatsRequest) Size() (n int) + func (m *UserStatsRequest) Unmarshal(dAtA []byte) error + func (m *UserStatsRequest) XXX_DiscardUnknown() + func (m *UserStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UserStatsRequest) XXX_Merge(src proto.Message) + func (m *UserStatsRequest) XXX_Size() int + func (m *UserStatsRequest) XXX_Unmarshal(b []byte) error + func (this *UserStatsRequest) Equal(that interface{}) bool + func (this *UserStatsRequest) GoString() string + func (this *UserStatsRequest) String() string + type UserStatsResponse struct + ApiIngestionRate float64 + IngestionRate float64 + NumSeries uint64 + RuleIngestionRate float64 + func (*UserStatsResponse) Descriptor() ([]byte, []int) + func (*UserStatsResponse) ProtoMessage() + func (m *UserStatsResponse) GetApiIngestionRate() float64 + func (m *UserStatsResponse) GetIngestionRate() float64 + func (m *UserStatsResponse) GetNumSeries() uint64 + func (m *UserStatsResponse) GetRuleIngestionRate() float64 + func (m *UserStatsResponse) Marshal() (dAtA []byte, err error) + func (m *UserStatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UserStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UserStatsResponse) Reset() + func (m *UserStatsResponse) Size() (n int) + func (m *UserStatsResponse) Unmarshal(dAtA []byte) error + func (m *UserStatsResponse) XXX_DiscardUnknown() + func (m *UserStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UserStatsResponse) XXX_Merge(src proto.Message) + func (m *UserStatsResponse) XXX_Size() int + func (m *UserStatsResponse) XXX_Unmarshal(b []byte) error + func (this *UserStatsResponse) Equal(that interface{}) bool + func (this *UserStatsResponse) GoString() string + func (this *UserStatsResponse) String() string + type UsersStatsResponse struct + Stats []*UserIDStatsResponse + func (*UsersStatsResponse) Descriptor() ([]byte, []int) + func (*UsersStatsResponse) ProtoMessage() + func (m *UsersStatsResponse) GetStats() []*UserIDStatsResponse + func (m *UsersStatsResponse) Marshal() (dAtA []byte, err error) + func (m *UsersStatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UsersStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UsersStatsResponse) Reset() + func (m *UsersStatsResponse) Size() (n int) + func (m *UsersStatsResponse) Unmarshal(dAtA []byte) error + func (m *UsersStatsResponse) XXX_DiscardUnknown() + func (m *UsersStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UsersStatsResponse) XXX_Merge(src proto.Message) + func (m *UsersStatsResponse) XXX_Size() int + func (m *UsersStatsResponse) XXX_Unmarshal(b []byte) error + func (this *UsersStatsResponse) Equal(that interface{}) bool + func (this *UsersStatsResponse) GoString() string + func (this *UsersStatsResponse) String() string Other modules containing this package github.com/fmoor/loki