client

package
v3.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 21, 2022 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthIngester = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIngester   = fmt.Errorf("proto: integer overflow")
)
View Source 
var MatchType_name = map[int32]string{
	0: "EQUAL",
	1: "NOT_EQUAL",
	2: "REGEX_MATCH",
	3: "REGEX_NO_MATCH",
}
View Source 
var MatchType_value = map[string]int32{
	"EQUAL":          0,
	"NOT_EQUAL":      1,
	"REGEX_MATCH":    2,
	"REGEX_NO_MATCH": 3,
}

Functions

func FastFingerprint 

func FastFingerprint(ls []logproto.LabelAdapter) model.Fingerprint

FastFingerprint runs the same algorithm as Prometheus labelSetToFastFingerprint()

func Fingerprint 

func Fingerprint(labels labels.Labels) model.Fingerprint

Fingerprint runs the same algorithm as Prometheus labelSetToFingerprint()

func LabelsToKeyString 

func LabelsToKeyString(l labels.Labels) string

LabelsToKeyString is used to form a string to be used as the hashKey. Don't print, use l.String() for printing.

func RegisterIngesterServer 

func RegisterIngesterServer(s *grpc.Server, srv IngesterServer)

Types

type Chunk 

type Chunk struct {
	StartTimestampMs int64  `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64  `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Encoding         int32  `protobuf:"varint,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
	Data             []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Chunk) Descriptor 

func (*Chunk) Descriptor() ([]byte, []int)

func (*Chunk) Equal 

func (this *Chunk) Equal(that interface{}) bool

func (*Chunk) GetData 

func (m *Chunk) GetData() []byte

func (*Chunk) GetEncoding 

func (m *Chunk) GetEncoding() int32

func (*Chunk) GetEndTimestampMs 

func (m *Chunk) GetEndTimestampMs() int64

func (*Chunk) GetStartTimestampMs 

func (m *Chunk) GetStartTimestampMs() int64

func (*Chunk) GoString 

func (this *Chunk) GoString() string

func (*Chunk) Marshal 

func (m *Chunk) Marshal() (dAtA []byte, err error)

func (*Chunk) MarshalTo 

func (m *Chunk) MarshalTo(dAtA []byte) (int, error)

func (*Chunk) MarshalToSizedBuffer 

func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) Size 

func (m *Chunk) Size() (n int)

func (*Chunk) String 

func (this *Chunk) String() string

func (*Chunk) Unmarshal 

func (m *Chunk) Unmarshal(dAtA []byte) error

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

func (m *Chunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Chunk) XXX_Merge 

func (m *Chunk) XXX_Merge(src proto.Message)

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

func (m *Chunk) XXX_Unmarshal(b []byte) error

type ClosableHealthAndIngesterClient 

type ClosableHealthAndIngesterClient struct {
	logproto.PusherClient
	logproto.QuerierClient
	logproto.IngesterClient
	grpc_health_v1.HealthClient
	io.Closer
}

type Config 

type Config struct {
	PoolConfig                   clientpool.PoolConfig          `yaml:"pool_config,omitempty"`
	RemoteTimeout                time.Duration                  `yaml:"remote_timeout,omitempty"`
	GRPCClientConfig             grpcclient.Config              `yaml:"grpc_client_config"`
	GRPCUnaryClientInterceptors  []grpc.UnaryClientInterceptor  `yaml:"-"`
	GRCPStreamClientInterceptors []grpc.StreamClientInterceptor `yaml:"-"`
}

Config for an ingester client.

func (*Config) RegisterFlags 

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags registers flags.

type ExemplarQueryRequest 

type ExemplarQueryRequest struct {
	StartTimestampMs int64            `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64            `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         []*LabelMatchers `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*ExemplarQueryRequest) Descriptor 

func (*ExemplarQueryRequest) Descriptor() ([]byte, []int)

func (*ExemplarQueryRequest) Equal 

func (this *ExemplarQueryRequest) Equal(that interface{}) bool

func (*ExemplarQueryRequest) GetEndTimestampMs 

func (m *ExemplarQueryRequest) GetEndTimestampMs() int64

func (*ExemplarQueryRequest) GetMatchers 

func (m *ExemplarQueryRequest) GetMatchers() []*LabelMatchers

func (*ExemplarQueryRequest) GetStartTimestampMs 

func (m *ExemplarQueryRequest) GetStartTimestampMs() int64

func (*ExemplarQueryRequest) GoString 

func (this *ExemplarQueryRequest) GoString() string

func (*ExemplarQueryRequest) Marshal 

func (m *ExemplarQueryRequest) Marshal() (dAtA []byte, err error)

func (*ExemplarQueryRequest) MarshalTo 

func (m *ExemplarQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*ExemplarQueryRequest) MarshalToSizedBuffer 

func (m *ExemplarQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExemplarQueryRequest) ProtoMessage 

func (*ExemplarQueryRequest) ProtoMessage()

func (*ExemplarQueryRequest) Reset 

func (m *ExemplarQueryRequest) Reset()

func (*ExemplarQueryRequest) Size 

func (m *ExemplarQueryRequest) Size() (n int)

func (*ExemplarQueryRequest) String 

func (this *ExemplarQueryRequest) String() string

func (*ExemplarQueryRequest) Unmarshal 

func (m *ExemplarQueryRequest) Unmarshal(dAtA []byte) error

func (*ExemplarQueryRequest) XXX_DiscardUnknown 

func (m *ExemplarQueryRequest) XXX_DiscardUnknown()

func (*ExemplarQueryRequest) XXX_Marshal 

func (m *ExemplarQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExemplarQueryRequest) XXX_Merge 

func (m *ExemplarQueryRequest) XXX_Merge(src proto.Message)

func (*ExemplarQueryRequest) XXX_Size 

func (m *ExemplarQueryRequest) XXX_Size() int

func (*ExemplarQueryRequest) XXX_Unmarshal 

func (m *ExemplarQueryRequest) XXX_Unmarshal(b []byte) error

type ExemplarQueryResponse 

type ExemplarQueryResponse struct {
	Timeseries []logproto.TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
}

func (*ExemplarQueryResponse) Descriptor 

func (*ExemplarQueryResponse) Descriptor() ([]byte, []int)

func (*ExemplarQueryResponse) Equal 

func (this *ExemplarQueryResponse) Equal(that interface{}) bool

func (*ExemplarQueryResponse) GetTimeseries 

func (m *ExemplarQueryResponse) GetTimeseries() []logproto.TimeSeries

func (*ExemplarQueryResponse) GoString 

func (this *ExemplarQueryResponse) GoString() string

func (*ExemplarQueryResponse) Marshal 

func (m *ExemplarQueryResponse) Marshal() (dAtA []byte, err error)

func (*ExemplarQueryResponse) MarshalTo 

func (m *ExemplarQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*ExemplarQueryResponse) MarshalToSizedBuffer 

func (m *ExemplarQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExemplarQueryResponse) ProtoMessage 

func (*ExemplarQueryResponse) ProtoMessage()

func (*ExemplarQueryResponse) Reset 

func (m *ExemplarQueryResponse) Reset()

func (*ExemplarQueryResponse) Size 

func (m *ExemplarQueryResponse) Size() (n int)

func (*ExemplarQueryResponse) String 

func (this *ExemplarQueryResponse) String() string

func (*ExemplarQueryResponse) Unmarshal 

func (m *ExemplarQueryResponse) Unmarshal(dAtA []byte) error

func (*ExemplarQueryResponse) XXX_DiscardUnknown 

func (m *ExemplarQueryResponse) XXX_DiscardUnknown()

func (*ExemplarQueryResponse) XXX_Marshal 

func (m *ExemplarQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExemplarQueryResponse) XXX_Merge 

func (m *ExemplarQueryResponse) XXX_Merge(src proto.Message)

func (*ExemplarQueryResponse) XXX_Size 

func (m *ExemplarQueryResponse) XXX_Size() int

func (*ExemplarQueryResponse) XXX_Unmarshal 

func (m *ExemplarQueryResponse) XXX_Unmarshal(b []byte) error

type HealthAndIngesterClient 

type HealthAndIngesterClient interface {
	logproto.IngesterClient
	grpc_health_v1.HealthClient
	Close() error
}

func New 

func New(cfg Config, addr string) (HealthAndIngesterClient, error)

New returns a new ingester client.

type IngesterClient 

type IngesterClient interface {
	Push(ctx context.Context, in *logproto.WriteRequest, opts ...grpc.CallOption) (*logproto.WriteResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	QueryStream(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Ingester_QueryStreamClient, error)
	QueryExemplars(ctx context.Context, in *ExemplarQueryRequest, opts ...grpc.CallOption) (*ExemplarQueryResponse, error)
	LabelValues(ctx context.Context, in *LabelValuesRequest, opts ...grpc.CallOption) (*LabelValuesResponse, error)
	LabelNames(ctx context.Context, in *LabelNamesRequest, opts ...grpc.CallOption) (*LabelNamesResponse, error)
	UserStats(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UserStatsResponse, error)
	AllUserStats(ctx context.Context, in *UserStatsRequest, opts ...grpc.CallOption) (*UsersStatsResponse, error)
	MetricsForLabelMatchers(ctx context.Context, in *MetricsForLabelMatchersRequest, opts ...grpc.CallOption) (*MetricsForLabelMatchersResponse, error)
	MetricsMetadata(ctx context.Context, in *MetricsMetadataRequest, opts ...grpc.CallOption) (*MetricsMetadataResponse, error)
	// TransferChunks allows leaving ingester (client) to stream chunks directly to joining ingesters (server).
	TransferChunks(ctx context.Context, opts ...grpc.CallOption) (Ingester_TransferChunksClient, error)
}

IngesterClient is the client API for Ingester service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIngesterClient 

func NewIngesterClient(cc *grpc.ClientConn) IngesterClient

type IngesterServer 

type IngesterServer interface {
	Push(context.Context, *logproto.WriteRequest) (*logproto.WriteResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	QueryStream(*QueryRequest, Ingester_QueryStreamServer) error
	QueryExemplars(context.Context, *ExemplarQueryRequest) (*ExemplarQueryResponse, error)
	LabelValues(context.Context, *LabelValuesRequest) (*LabelValuesResponse, error)
	LabelNames(context.Context, *LabelNamesRequest) (*LabelNamesResponse, error)
	UserStats(context.Context, *UserStatsRequest) (*UserStatsResponse, error)
	AllUserStats(context.Context, *UserStatsRequest) (*UsersStatsResponse, error)
	MetricsForLabelMatchers(context.Context, *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)
	MetricsMetadata(context.Context, *MetricsMetadataRequest) (*MetricsMetadataResponse, error)
	// TransferChunks allows leaving ingester (client) to stream chunks directly to joining ingesters (server).
	TransferChunks(Ingester_TransferChunksServer) error
}

IngesterServer is the server API for Ingester service.

type Ingester_QueryStreamClient 

type Ingester_QueryStreamClient interface {
	Recv() (*QueryStreamResponse, error)
	grpc.ClientStream
}

type Ingester_QueryStreamServer 

type Ingester_QueryStreamServer interface {
	Send(*QueryStreamResponse) error
	grpc.ServerStream
}

type Ingester_TransferChunksClient 

type Ingester_TransferChunksClient interface {
	Send(*TimeSeriesChunk) error
	CloseAndRecv() (*TransferChunksResponse, error)
	grpc.ClientStream
}

type Ingester_TransferChunksServer 

type Ingester_TransferChunksServer interface {
	SendAndClose(*TransferChunksResponse) error
	Recv() (*TimeSeriesChunk, error)
	grpc.ServerStream
}

type LabelMatcher 

type LabelMatcher struct {
	Type  MatchType `protobuf:"varint,1,opt,name=type,proto3,enum=ingesterpb.MatchType" json:"type,omitempty"`
	Name  string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Value string    `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*LabelMatcher) Descriptor 

func (*LabelMatcher) Descriptor() ([]byte, []int)

func (*LabelMatcher) Equal 

func (this *LabelMatcher) Equal(that interface{}) bool

func (*LabelMatcher) GetName 

func (m *LabelMatcher) GetName() string

func (*LabelMatcher) GetType 

func (m *LabelMatcher) GetType() MatchType

func (*LabelMatcher) GetValue 

func (m *LabelMatcher) GetValue() string

func (*LabelMatcher) GoString 

func (this *LabelMatcher) GoString() string

func (*LabelMatcher) Marshal 

func (m *LabelMatcher) Marshal() (dAtA []byte, err error)

func (*LabelMatcher) MarshalTo 

func (m *LabelMatcher) MarshalTo(dAtA []byte) (int, error)

func (*LabelMatcher) MarshalToSizedBuffer 

func (m *LabelMatcher) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelMatcher) ProtoMessage 

func (*LabelMatcher) ProtoMessage()

func (*LabelMatcher) Reset 

func (m *LabelMatcher) Reset()

func (*LabelMatcher) Size 

func (m *LabelMatcher) Size() (n int)

func (*LabelMatcher) String 

func (this *LabelMatcher) String() string

func (*LabelMatcher) Unmarshal 

func (m *LabelMatcher) Unmarshal(dAtA []byte) error

func (*LabelMatcher) XXX_DiscardUnknown 

func (m *LabelMatcher) XXX_DiscardUnknown()

func (*LabelMatcher) XXX_Marshal 

func (m *LabelMatcher) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelMatcher) XXX_Merge 

func (m *LabelMatcher) XXX_Merge(src proto.Message)

func (*LabelMatcher) XXX_Size 

func (m *LabelMatcher) XXX_Size() int

func (*LabelMatcher) XXX_Unmarshal 

func (m *LabelMatcher) XXX_Unmarshal(b []byte) error

type LabelMatchers 

type LabelMatchers struct {
	Matchers []*LabelMatcher `protobuf:"bytes,1,rep,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*LabelMatchers) Descriptor 

func (*LabelMatchers) Descriptor() ([]byte, []int)

func (*LabelMatchers) Equal 

func (this *LabelMatchers) Equal(that interface{}) bool

func (*LabelMatchers) GetMatchers 

func (m *LabelMatchers) GetMatchers() []*LabelMatcher

func (*LabelMatchers) GoString 

func (this *LabelMatchers) GoString() string

func (*LabelMatchers) Marshal 

func (m *LabelMatchers) Marshal() (dAtA []byte, err error)

func (*LabelMatchers) MarshalTo 

func (m *LabelMatchers) MarshalTo(dAtA []byte) (int, error)

func (*LabelMatchers) MarshalToSizedBuffer 

func (m *LabelMatchers) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelMatchers) ProtoMessage 

func (*LabelMatchers) ProtoMessage()

func (*LabelMatchers) Reset 

func (m *LabelMatchers) Reset()

func (*LabelMatchers) Size 

func (m *LabelMatchers) Size() (n int)

func (*LabelMatchers) String 

func (this *LabelMatchers) String() string

func (*LabelMatchers) Unmarshal 

func (m *LabelMatchers) Unmarshal(dAtA []byte) error

func (*LabelMatchers) XXX_DiscardUnknown 

func (m *LabelMatchers) XXX_DiscardUnknown()

func (*LabelMatchers) XXX_Marshal 

func (m *LabelMatchers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelMatchers) XXX_Merge 

func (m *LabelMatchers) XXX_Merge(src proto.Message)

func (*LabelMatchers) XXX_Size 

func (m *LabelMatchers) XXX_Size() int

func (*LabelMatchers) XXX_Unmarshal 

func (m *LabelMatchers) XXX_Unmarshal(b []byte) error

type LabelNamesRequest 

type LabelNamesRequest struct {
	StartTimestampMs int64 `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64 `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
}

func (*LabelNamesRequest) Descriptor 

func (*LabelNamesRequest) Descriptor() ([]byte, []int)

func (*LabelNamesRequest) Equal 

func (this *LabelNamesRequest) Equal(that interface{}) bool

func (*LabelNamesRequest) GetEndTimestampMs 

func (m *LabelNamesRequest) GetEndTimestampMs() int64

func (*LabelNamesRequest) GetStartTimestampMs 

func (m *LabelNamesRequest) GetStartTimestampMs() int64

func (*LabelNamesRequest) GoString 

func (this *LabelNamesRequest) GoString() string

func (*LabelNamesRequest) Marshal 

func (m *LabelNamesRequest) Marshal() (dAtA []byte, err error)

func (*LabelNamesRequest) MarshalTo 

func (m *LabelNamesRequest) MarshalTo(dAtA []byte) (int, error)

func (*LabelNamesRequest) MarshalToSizedBuffer 

func (m *LabelNamesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelNamesRequest) ProtoMessage 

func (*LabelNamesRequest) ProtoMessage()

func (*LabelNamesRequest) Reset 

func (m *LabelNamesRequest) Reset()

func (*LabelNamesRequest) Size 

func (m *LabelNamesRequest) Size() (n int)

func (*LabelNamesRequest) String 

func (this *LabelNamesRequest) String() string

func (*LabelNamesRequest) Unmarshal 

func (m *LabelNamesRequest) Unmarshal(dAtA []byte) error

func (*LabelNamesRequest) XXX_DiscardUnknown 

func (m *LabelNamesRequest) XXX_DiscardUnknown()

func (*LabelNamesRequest) XXX_Marshal 

func (m *LabelNamesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelNamesRequest) XXX_Merge 

func (m *LabelNamesRequest) XXX_Merge(src proto.Message)

func (*LabelNamesRequest) XXX_Size 

func (m *LabelNamesRequest) XXX_Size() int

func (*LabelNamesRequest) XXX_Unmarshal 

func (m *LabelNamesRequest) XXX_Unmarshal(b []byte) error

type LabelNamesResponse 

type LabelNamesResponse struct {
	LabelNames []string `protobuf:"bytes,1,rep,name=label_names,json=labelNames,proto3" json:"label_names,omitempty"`
}

func (*LabelNamesResponse) Descriptor 

func (*LabelNamesResponse) Descriptor() ([]byte, []int)

func (*LabelNamesResponse) Equal 

func (this *LabelNamesResponse) Equal(that interface{}) bool

func (*LabelNamesResponse) GetLabelNames 

func (m *LabelNamesResponse) GetLabelNames() []string

func (*LabelNamesResponse) GoString 

func (this *LabelNamesResponse) GoString() string

func (*LabelNamesResponse) Marshal 

func (m *LabelNamesResponse) Marshal() (dAtA []byte, err error)

func (*LabelNamesResponse) MarshalTo 

func (m *LabelNamesResponse) MarshalTo(dAtA []byte) (int, error)

func (*LabelNamesResponse) MarshalToSizedBuffer 

func (m *LabelNamesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelNamesResponse) ProtoMessage 

func (*LabelNamesResponse) ProtoMessage()

func (*LabelNamesResponse) Reset 

func (m *LabelNamesResponse) Reset()

func (*LabelNamesResponse) Size 

func (m *LabelNamesResponse) Size() (n int)

func (*LabelNamesResponse) String 

func (this *LabelNamesResponse) String() string

func (*LabelNamesResponse) Unmarshal 

func (m *LabelNamesResponse) Unmarshal(dAtA []byte) error

func (*LabelNamesResponse) XXX_DiscardUnknown 

func (m *LabelNamesResponse) XXX_DiscardUnknown()

func (*LabelNamesResponse) XXX_Marshal 

func (m *LabelNamesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelNamesResponse) XXX_Merge 

func (m *LabelNamesResponse) XXX_Merge(src proto.Message)

func (*LabelNamesResponse) XXX_Size 

func (m *LabelNamesResponse) XXX_Size() int

func (*LabelNamesResponse) XXX_Unmarshal 

func (m *LabelNamesResponse) XXX_Unmarshal(b []byte) error

type LabelValuesRequest 

type LabelValuesRequest struct {
	LabelName        string         `protobuf:"bytes,1,opt,name=label_name,json=labelName,proto3" json:"label_name,omitempty"`
	StartTimestampMs int64          `protobuf:"varint,2,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64          `protobuf:"varint,3,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         *LabelMatchers `protobuf:"bytes,4,opt,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*LabelValuesRequest) Descriptor 

func (*LabelValuesRequest) Descriptor() ([]byte, []int)

func (*LabelValuesRequest) Equal 

func (this *LabelValuesRequest) Equal(that interface{}) bool

func (*LabelValuesRequest) GetEndTimestampMs 

func (m *LabelValuesRequest) GetEndTimestampMs() int64

func (*LabelValuesRequest) GetLabelName 

func (m *LabelValuesRequest) GetLabelName() string

func (*LabelValuesRequest) GetMatchers 

func (m *LabelValuesRequest) GetMatchers() *LabelMatchers

func (*LabelValuesRequest) GetStartTimestampMs 

func (m *LabelValuesRequest) GetStartTimestampMs() int64

func (*LabelValuesRequest) GoString 

func (this *LabelValuesRequest) GoString() string

func (*LabelValuesRequest) Marshal 

func (m *LabelValuesRequest) Marshal() (dAtA []byte, err error)

func (*LabelValuesRequest) MarshalTo 

func (m *LabelValuesRequest) MarshalTo(dAtA []byte) (int, error)

func (*LabelValuesRequest) MarshalToSizedBuffer 

func (m *LabelValuesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelValuesRequest) ProtoMessage 

func (*LabelValuesRequest) ProtoMessage()

func (*LabelValuesRequest) Reset 

func (m *LabelValuesRequest) Reset()

func (*LabelValuesRequest) Size 

func (m *LabelValuesRequest) Size() (n int)

func (*LabelValuesRequest) String 

func (this *LabelValuesRequest) String() string

func (*LabelValuesRequest) Unmarshal 

func (m *LabelValuesRequest) Unmarshal(dAtA []byte) error

func (*LabelValuesRequest) XXX_DiscardUnknown 

func (m *LabelValuesRequest) XXX_DiscardUnknown()

func (*LabelValuesRequest) XXX_Marshal 

func (m *LabelValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelValuesRequest) XXX_Merge 

func (m *LabelValuesRequest) XXX_Merge(src proto.Message)

func (*LabelValuesRequest) XXX_Size 

func (m *LabelValuesRequest) XXX_Size() int

func (*LabelValuesRequest) XXX_Unmarshal 

func (m *LabelValuesRequest) XXX_Unmarshal(b []byte) error

type LabelValuesResponse 

type LabelValuesResponse struct {
	LabelValues []string `protobuf:"bytes,1,rep,name=label_values,json=labelValues,proto3" json:"label_values,omitempty"`
}

func (*LabelValuesResponse) Descriptor 

func (*LabelValuesResponse) Descriptor() ([]byte, []int)

func (*LabelValuesResponse) Equal 

func (this *LabelValuesResponse) Equal(that interface{}) bool

func (*LabelValuesResponse) GetLabelValues 

func (m *LabelValuesResponse) GetLabelValues() []string

func (*LabelValuesResponse) GoString 

func (this *LabelValuesResponse) GoString() string

func (*LabelValuesResponse) Marshal 

func (m *LabelValuesResponse) Marshal() (dAtA []byte, err error)

func (*LabelValuesResponse) MarshalTo 

func (m *LabelValuesResponse) MarshalTo(dAtA []byte) (int, error)

func (*LabelValuesResponse) MarshalToSizedBuffer 

func (m *LabelValuesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LabelValuesResponse) ProtoMessage 

func (*LabelValuesResponse) ProtoMessage()

func (*LabelValuesResponse) Reset 

func (m *LabelValuesResponse) Reset()

func (*LabelValuesResponse) Size 

func (m *LabelValuesResponse) Size() (n int)

func (*LabelValuesResponse) String 

func (this *LabelValuesResponse) String() string

func (*LabelValuesResponse) Unmarshal 

func (m *LabelValuesResponse) Unmarshal(dAtA []byte) error

func (*LabelValuesResponse) XXX_DiscardUnknown 

func (m *LabelValuesResponse) XXX_DiscardUnknown()

func (*LabelValuesResponse) XXX_Marshal 

func (m *LabelValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LabelValuesResponse) XXX_Merge 

func (m *LabelValuesResponse) XXX_Merge(src proto.Message)

func (*LabelValuesResponse) XXX_Size 

func (m *LabelValuesResponse) XXX_Size() int

func (*LabelValuesResponse) XXX_Unmarshal 

func (m *LabelValuesResponse) XXX_Unmarshal(b []byte) error

type MatchType 

type MatchType int32
const (
	EQUAL          MatchType = 0
	NOT_EQUAL      MatchType = 1
	REGEX_MATCH    MatchType = 2
	REGEX_NO_MATCH MatchType = 3
)

func (MatchType) EnumDescriptor 

func (MatchType) EnumDescriptor() ([]byte, []int)

func (MatchType) String 

func (x MatchType) String() string

type MetricsForLabelMatchersRequest 

type MetricsForLabelMatchersRequest struct {
	StartTimestampMs int64            `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64            `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	MatchersSet      []*LabelMatchers `protobuf:"bytes,3,rep,name=matchers_set,json=matchersSet,proto3" json:"matchers_set,omitempty"`
}

func (*MetricsForLabelMatchersRequest) Descriptor 

func (*MetricsForLabelMatchersRequest) Descriptor() ([]byte, []int)

func (*MetricsForLabelMatchersRequest) Equal 

func (this *MetricsForLabelMatchersRequest) Equal(that interface{}) bool

func (*MetricsForLabelMatchersRequest) GetEndTimestampMs 

func (m *MetricsForLabelMatchersRequest) GetEndTimestampMs() int64

func (*MetricsForLabelMatchersRequest) GetMatchersSet 

func (m *MetricsForLabelMatchersRequest) GetMatchersSet() []*LabelMatchers

func (*MetricsForLabelMatchersRequest) GetStartTimestampMs 

func (m *MetricsForLabelMatchersRequest) GetStartTimestampMs() int64

func (*MetricsForLabelMatchersRequest) GoString 

func (this *MetricsForLabelMatchersRequest) GoString() string

func (*MetricsForLabelMatchersRequest) Marshal 

func (m *MetricsForLabelMatchersRequest) Marshal() (dAtA []byte, err error)

func (*MetricsForLabelMatchersRequest) MarshalTo 

func (m *MetricsForLabelMatchersRequest) MarshalTo(dAtA []byte) (int, error)

func (*MetricsForLabelMatchersRequest) MarshalToSizedBuffer 

func (m *MetricsForLabelMatchersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricsForLabelMatchersRequest) ProtoMessage 

func (*MetricsForLabelMatchersRequest) ProtoMessage()

func (*MetricsForLabelMatchersRequest) Reset 

func (m *MetricsForLabelMatchersRequest) Reset()

func (*MetricsForLabelMatchersRequest) Size 

func (m *MetricsForLabelMatchersRequest) Size() (n int)

func (*MetricsForLabelMatchersRequest) String 

func (this *MetricsForLabelMatchersRequest) String() string

func (*MetricsForLabelMatchersRequest) Unmarshal 

func (m *MetricsForLabelMatchersRequest) Unmarshal(dAtA []byte) error

func (*MetricsForLabelMatchersRequest) XXX_DiscardUnknown 

func (m *MetricsForLabelMatchersRequest) XXX_DiscardUnknown()

func (*MetricsForLabelMatchersRequest) XXX_Marshal 

func (m *MetricsForLabelMatchersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsForLabelMatchersRequest) XXX_Merge 

func (m *MetricsForLabelMatchersRequest) XXX_Merge(src proto.Message)

func (*MetricsForLabelMatchersRequest) XXX_Size 

func (m *MetricsForLabelMatchersRequest) XXX_Size() int

func (*MetricsForLabelMatchersRequest) XXX_Unmarshal 

func (m *MetricsForLabelMatchersRequest) XXX_Unmarshal(b []byte) error

type MetricsForLabelMatchersResponse 

type MetricsForLabelMatchersResponse struct {
	Metric []*logproto.Metric `protobuf:"bytes,1,rep,name=metric,proto3" json:"metric,omitempty"`
}

func (*MetricsForLabelMatchersResponse) Descriptor 

func (*MetricsForLabelMatchersResponse) Descriptor() ([]byte, []int)

func (*MetricsForLabelMatchersResponse) Equal 

func (this *MetricsForLabelMatchersResponse) Equal(that interface{}) bool

func (*MetricsForLabelMatchersResponse) GetMetric 

func (m *MetricsForLabelMatchersResponse) GetMetric() []*logproto.Metric

func (*MetricsForLabelMatchersResponse) GoString 

func (this *MetricsForLabelMatchersResponse) GoString() string

func (*MetricsForLabelMatchersResponse) Marshal 

func (m *MetricsForLabelMatchersResponse) Marshal() (dAtA []byte, err error)

func (*MetricsForLabelMatchersResponse) MarshalTo 

func (m *MetricsForLabelMatchersResponse) MarshalTo(dAtA []byte) (int, error)

func (*MetricsForLabelMatchersResponse) MarshalToSizedBuffer 

func (m *MetricsForLabelMatchersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricsForLabelMatchersResponse) ProtoMessage 

func (*MetricsForLabelMatchersResponse) ProtoMessage()

func (*MetricsForLabelMatchersResponse) Reset 

func (m *MetricsForLabelMatchersResponse) Reset()

func (*MetricsForLabelMatchersResponse) Size 

func (m *MetricsForLabelMatchersResponse) Size() (n int)

func (*MetricsForLabelMatchersResponse) String 

func (this *MetricsForLabelMatchersResponse) String() string

func (*MetricsForLabelMatchersResponse) Unmarshal 

func (m *MetricsForLabelMatchersResponse) Unmarshal(dAtA []byte) error

func (*MetricsForLabelMatchersResponse) XXX_DiscardUnknown 

func (m *MetricsForLabelMatchersResponse) XXX_DiscardUnknown()

func (*MetricsForLabelMatchersResponse) XXX_Marshal 

func (m *MetricsForLabelMatchersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsForLabelMatchersResponse) XXX_Merge 

func (m *MetricsForLabelMatchersResponse) XXX_Merge(src proto.Message)

func (*MetricsForLabelMatchersResponse) XXX_Size 

func (m *MetricsForLabelMatchersResponse) XXX_Size() int

func (*MetricsForLabelMatchersResponse) XXX_Unmarshal 

func (m *MetricsForLabelMatchersResponse) XXX_Unmarshal(b []byte) error

type MetricsMetadataRequest 

type MetricsMetadataRequest struct {
}

func (*MetricsMetadataRequest) Descriptor 

func (*MetricsMetadataRequest) Descriptor() ([]byte, []int)

func (*MetricsMetadataRequest) Equal 

func (this *MetricsMetadataRequest) Equal(that interface{}) bool

func (*MetricsMetadataRequest) GoString 

func (this *MetricsMetadataRequest) GoString() string

func (*MetricsMetadataRequest) Marshal 

func (m *MetricsMetadataRequest) Marshal() (dAtA []byte, err error)

func (*MetricsMetadataRequest) MarshalTo 

func (m *MetricsMetadataRequest) MarshalTo(dAtA []byte) (int, error)

func (*MetricsMetadataRequest) MarshalToSizedBuffer 

func (m *MetricsMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricsMetadataRequest) ProtoMessage 

func (*MetricsMetadataRequest) ProtoMessage()

func (*MetricsMetadataRequest) Reset 

func (m *MetricsMetadataRequest) Reset()

func (*MetricsMetadataRequest) Size 

func (m *MetricsMetadataRequest) Size() (n int)

func (*MetricsMetadataRequest) String 

func (this *MetricsMetadataRequest) String() string

func (*MetricsMetadataRequest) Unmarshal 

func (m *MetricsMetadataRequest) Unmarshal(dAtA []byte) error

func (*MetricsMetadataRequest) XXX_DiscardUnknown 

func (m *MetricsMetadataRequest) XXX_DiscardUnknown()

func (*MetricsMetadataRequest) XXX_Marshal 

func (m *MetricsMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsMetadataRequest) XXX_Merge 

func (m *MetricsMetadataRequest) XXX_Merge(src proto.Message)

func (*MetricsMetadataRequest) XXX_Size 

func (m *MetricsMetadataRequest) XXX_Size() int

func (*MetricsMetadataRequest) XXX_Unmarshal 

func (m *MetricsMetadataRequest) XXX_Unmarshal(b []byte) error

type MetricsMetadataResponse 

type MetricsMetadataResponse struct {
	Metadata []*logproto.MetricMetadata `protobuf:"bytes,1,rep,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*MetricsMetadataResponse) Descriptor 

func (*MetricsMetadataResponse) Descriptor() ([]byte, []int)

func (*MetricsMetadataResponse) Equal 

func (this *MetricsMetadataResponse) Equal(that interface{}) bool

func (*MetricsMetadataResponse) GetMetadata 

func (m *MetricsMetadataResponse) GetMetadata() []*logproto.MetricMetadata

func (*MetricsMetadataResponse) GoString 

func (this *MetricsMetadataResponse) GoString() string

func (*MetricsMetadataResponse) Marshal 

func (m *MetricsMetadataResponse) Marshal() (dAtA []byte, err error)

func (*MetricsMetadataResponse) MarshalTo 

func (m *MetricsMetadataResponse) MarshalTo(dAtA []byte) (int, error)

func (*MetricsMetadataResponse) MarshalToSizedBuffer 

func (m *MetricsMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricsMetadataResponse) ProtoMessage 

func (*MetricsMetadataResponse) ProtoMessage()

func (*MetricsMetadataResponse) Reset 

func (m *MetricsMetadataResponse) Reset()

func (*MetricsMetadataResponse) Size 

func (m *MetricsMetadataResponse) Size() (n int)

func (*MetricsMetadataResponse) String 

func (this *MetricsMetadataResponse) String() string

func (*MetricsMetadataResponse) Unmarshal 

func (m *MetricsMetadataResponse) Unmarshal(dAtA []byte) error

func (*MetricsMetadataResponse) XXX_DiscardUnknown 

func (m *MetricsMetadataResponse) XXX_DiscardUnknown()

func (*MetricsMetadataResponse) XXX_Marshal 

func (m *MetricsMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsMetadataResponse) XXX_Merge 

func (m *MetricsMetadataResponse) XXX_Merge(src proto.Message)

func (*MetricsMetadataResponse) XXX_Size 

func (m *MetricsMetadataResponse) XXX_Size() int

func (*MetricsMetadataResponse) XXX_Unmarshal 

func (m *MetricsMetadataResponse) XXX_Unmarshal(b []byte) error

type QueryRequest 

type QueryRequest struct {
	StartTimestampMs int64           `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs   int64           `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers         []*LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
}

func (*QueryRequest) Descriptor 

func (*QueryRequest) Descriptor() ([]byte, []int)

func (*QueryRequest) Equal 

func (this *QueryRequest) Equal(that interface{}) bool

func (*QueryRequest) GetEndTimestampMs 

func (m *QueryRequest) GetEndTimestampMs() int64

func (*QueryRequest) GetMatchers 

func (m *QueryRequest) GetMatchers() []*LabelMatcher

func (*QueryRequest) GetStartTimestampMs 

func (m *QueryRequest) GetStartTimestampMs() int64

func (*QueryRequest) GoString 

func (this *QueryRequest) GoString() string

func (*QueryRequest) Marshal 

func (m *QueryRequest) Marshal() (dAtA []byte, err error)

func (*QueryRequest) MarshalTo 

func (m *QueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryRequest) MarshalToSizedBuffer 

func (m *QueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) Size 

func (m *QueryRequest) Size() (n int)

func (*QueryRequest) String 

func (this *QueryRequest) String() string

func (*QueryRequest) Unmarshal 

func (m *QueryRequest) Unmarshal(dAtA []byte) error

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge 

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type QueryResponse 

type QueryResponse struct {
	Timeseries []logproto.TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
}

func (*QueryResponse) Descriptor 

func (*QueryResponse) Descriptor() ([]byte, []int)

func (*QueryResponse) Equal 

func (this *QueryResponse) Equal(that interface{}) bool

func (*QueryResponse) GetTimeseries 

func (m *QueryResponse) GetTimeseries() []logproto.TimeSeries

func (*QueryResponse) GoString 

func (this *QueryResponse) GoString() string

func (*QueryResponse) Marshal 

func (m *QueryResponse) Marshal() (dAtA []byte, err error)

func (*QueryResponse) MarshalTo 

func (m *QueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryResponse) MarshalToSizedBuffer 

func (m *QueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) Size 

func (m *QueryResponse) Size() (n int)

func (*QueryResponse) String 

func (this *QueryResponse) String() string

func (*QueryResponse) Unmarshal 

func (m *QueryResponse) Unmarshal(dAtA []byte) error

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponse) XXX_Merge 

func (m *QueryResponse) XXX_Merge(src proto.Message)

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

func (m *QueryResponse) XXX_Unmarshal(b []byte) error

type QueryStreamResponse 

type QueryStreamResponse struct {
	Chunkseries []TimeSeriesChunk     `protobuf:"bytes,1,rep,name=chunkseries,proto3" json:"chunkseries"`
	Timeseries  []logproto.TimeSeries `protobuf:"bytes,2,rep,name=timeseries,proto3" json:"timeseries"`
}

QueryStreamResponse contains a batch of timeseries chunks or timeseries. Only one of these series will be populated.

func (*QueryStreamResponse) Descriptor 

func (*QueryStreamResponse) Descriptor() ([]byte, []int)

func (*QueryStreamResponse) Equal 

func (this *QueryStreamResponse) Equal(that interface{}) bool

func (*QueryStreamResponse) GetChunkseries 

func (m *QueryStreamResponse) GetChunkseries() []TimeSeriesChunk

func (*QueryStreamResponse) GetTimeseries 

func (m *QueryStreamResponse) GetTimeseries() []logproto.TimeSeries

func (*QueryStreamResponse) GoString 

func (this *QueryStreamResponse) GoString() string

func (*QueryStreamResponse) Marshal 

func (m *QueryStreamResponse) Marshal() (dAtA []byte, err error)

func (*QueryStreamResponse) MarshalTo 

func (m *QueryStreamResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryStreamResponse) MarshalToSizedBuffer 

func (m *QueryStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryStreamResponse) ProtoMessage 

func (*QueryStreamResponse) ProtoMessage()

func (*QueryStreamResponse) Reset 

func (m *QueryStreamResponse) Reset()

func (*QueryStreamResponse) Size 

func (m *QueryStreamResponse) Size() (n int)

func (*QueryStreamResponse) String 

func (this *QueryStreamResponse) String() string

func (*QueryStreamResponse) Unmarshal 

func (m *QueryStreamResponse) Unmarshal(dAtA []byte) error

func (*QueryStreamResponse) XXX_DiscardUnknown 

func (m *QueryStreamResponse) XXX_DiscardUnknown()

func (*QueryStreamResponse) XXX_Marshal 

func (m *QueryStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryStreamResponse) XXX_Merge 

func (m *QueryStreamResponse) XXX_Merge(src proto.Message)

func (*QueryStreamResponse) XXX_Size 

func (m *QueryStreamResponse) XXX_Size() int

func (*QueryStreamResponse) XXX_Unmarshal 

func (m *QueryStreamResponse) XXX_Unmarshal(b []byte) error

type ReadRequest 

type ReadRequest struct {
	Queries []*QueryRequest `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
}

func (*ReadRequest) Descriptor 

func (*ReadRequest) Descriptor() ([]byte, []int)

func (*ReadRequest) Equal 

func (this *ReadRequest) Equal(that interface{}) bool

func (*ReadRequest) GetQueries 

func (m *ReadRequest) GetQueries() []*QueryRequest

func (*ReadRequest) GoString 

func (this *ReadRequest) GoString() string

func (*ReadRequest) Marshal 

func (m *ReadRequest) Marshal() (dAtA []byte, err error)

func (*ReadRequest) MarshalTo 

func (m *ReadRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadRequest) MarshalToSizedBuffer 

func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) Size 

func (m *ReadRequest) Size() (n int)

func (*ReadRequest) String 

func (this *ReadRequest) String() string

func (*ReadRequest) Unmarshal 

func (m *ReadRequest) Unmarshal(dAtA []byte) error

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadRequest) XXX_Merge 

func (m *ReadRequest) XXX_Merge(src proto.Message)

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

func (m *ReadRequest) XXX_Unmarshal(b []byte) error

type ReadResponse 

type ReadResponse struct {
	Results []*QueryResponse `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

func (*ReadResponse) Descriptor 

func (*ReadResponse) Descriptor() ([]byte, []int)

func (*ReadResponse) Equal 

func (this *ReadResponse) Equal(that interface{}) bool

func (*ReadResponse) GetResults 

func (m *ReadResponse) GetResults() []*QueryResponse

func (*ReadResponse) GoString 

func (this *ReadResponse) GoString() string

func (*ReadResponse) Marshal 

func (m *ReadResponse) Marshal() (dAtA []byte, err error)

func (*ReadResponse) MarshalTo 

func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse) MarshalToSizedBuffer 

func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) Size 

func (m *ReadResponse) Size() (n int)

func (*ReadResponse) String 

func (this *ReadResponse) String() string

func (*ReadResponse) Unmarshal 

func (m *ReadResponse) Unmarshal(dAtA []byte) error

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadResponse) XXX_Merge 

func (m *ReadResponse) XXX_Merge(src proto.Message)

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

func (m *ReadResponse) XXX_Unmarshal(b []byte) error

type TimeSeriesChunk 

type TimeSeriesChunk struct {
	FromIngesterId string                                              `protobuf:"bytes,1,opt,name=from_ingester_id,json=fromIngesterId,proto3" json:"from_ingester_id,omitempty"`
	UserId         string                                              `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Labels         []github_com_grafana_loki_pkg_logproto.LabelAdapter `protobuf:"bytes,3,rep,name=labels,proto3,customtype=github.com/pao214/loki/v3/pkg/logproto.LabelAdapter" json:"labels"`
	Chunks         []Chunk                                             `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks"`
}

func (*TimeSeriesChunk) Descriptor 

func (*TimeSeriesChunk) Descriptor() ([]byte, []int)

func (*TimeSeriesChunk) Equal 

func (this *TimeSeriesChunk) Equal(that interface{}) bool

func (*TimeSeriesChunk) GetChunks 

func (m *TimeSeriesChunk) GetChunks() []Chunk

func (*TimeSeriesChunk) GetFromIngesterId 

func (m *TimeSeriesChunk) GetFromIngesterId() string

func (*TimeSeriesChunk) GetUserId 

func (m *TimeSeriesChunk) GetUserId() string

func (*TimeSeriesChunk) GoString 

func (this *TimeSeriesChunk) GoString() string

func (*TimeSeriesChunk) Marshal 

func (m *TimeSeriesChunk) Marshal() (dAtA []byte, err error)

func (*TimeSeriesChunk) MarshalTo 

func (m *TimeSeriesChunk) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeriesChunk) MarshalToSizedBuffer 

func (m *TimeSeriesChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimeSeriesChunk) ProtoMessage 

func (*TimeSeriesChunk) ProtoMessage()

func (*TimeSeriesChunk) Reset 

func (m *TimeSeriesChunk) Reset()

func (*TimeSeriesChunk) Size 

func (m *TimeSeriesChunk) Size() (n int)

func (*TimeSeriesChunk) String 

func (this *TimeSeriesChunk) String() string

func (*TimeSeriesChunk) Unmarshal 

func (m *TimeSeriesChunk) Unmarshal(dAtA []byte) error

func (*TimeSeriesChunk) XXX_DiscardUnknown 

func (m *TimeSeriesChunk) XXX_DiscardUnknown()

func (*TimeSeriesChunk) XXX_Marshal 

func (m *TimeSeriesChunk) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeSeriesChunk) XXX_Merge 

func (m *TimeSeriesChunk) XXX_Merge(src proto.Message)

func (*TimeSeriesChunk) XXX_Size 

func (m *TimeSeriesChunk) XXX_Size() int

func (*TimeSeriesChunk) XXX_Unmarshal 

func (m *TimeSeriesChunk) XXX_Unmarshal(b []byte) error

type TimeSeriesFile 

type TimeSeriesFile struct {
	FromIngesterId string `protobuf:"bytes,1,opt,name=from_ingester_id,json=fromIngesterId,proto3" json:"from_ingester_id,omitempty"`
	UserId         string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Filename       string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	Data           []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*TimeSeriesFile) Descriptor 

func (*TimeSeriesFile) Descriptor() ([]byte, []int)

func (*TimeSeriesFile) Equal 

func (this *TimeSeriesFile) Equal(that interface{}) bool

func (*TimeSeriesFile) GetData 

func (m *TimeSeriesFile) GetData() []byte

func (*TimeSeriesFile) GetFilename 

func (m *TimeSeriesFile) GetFilename() string

func (*TimeSeriesFile) GetFromIngesterId 

func (m *TimeSeriesFile) GetFromIngesterId() string

func (*TimeSeriesFile) GetUserId 

func (m *TimeSeriesFile) GetUserId() string

func (*TimeSeriesFile) GoString 

func (this *TimeSeriesFile) GoString() string

func (*TimeSeriesFile) Marshal 

func (m *TimeSeriesFile) Marshal() (dAtA []byte, err error)

func (*TimeSeriesFile) MarshalTo 

func (m *TimeSeriesFile) MarshalTo(dAtA []byte) (int, error)

func (*TimeSeriesFile) MarshalToSizedBuffer 

func (m *TimeSeriesFile) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimeSeriesFile) ProtoMessage 

func (*TimeSeriesFile) ProtoMessage()

func (*TimeSeriesFile) Reset 

func (m *TimeSeriesFile) Reset()

func (*TimeSeriesFile) Size 

func (m *TimeSeriesFile) Size() (n int)

func (*TimeSeriesFile) String 

func (this *TimeSeriesFile) String() string

func (*TimeSeriesFile) Unmarshal 

func (m *TimeSeriesFile) Unmarshal(dAtA []byte) error

func (*TimeSeriesFile) XXX_DiscardUnknown 

func (m *TimeSeriesFile) XXX_DiscardUnknown()

func (*TimeSeriesFile) XXX_Marshal 

func (m *TimeSeriesFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeSeriesFile) XXX_Merge 

func (m *TimeSeriesFile) XXX_Merge(src proto.Message)

func (*TimeSeriesFile) XXX_Size 

func (m *TimeSeriesFile) XXX_Size() int

func (*TimeSeriesFile) XXX_Unmarshal 

func (m *TimeSeriesFile) XXX_Unmarshal(b []byte) error

type TransferChunksResponse 

type TransferChunksResponse struct {
}

func (*TransferChunksResponse) Descriptor 

func (*TransferChunksResponse) Descriptor() ([]byte, []int)

func (*TransferChunksResponse) Equal 

func (this *TransferChunksResponse) Equal(that interface{}) bool

func (*TransferChunksResponse) GoString 

func (this *TransferChunksResponse) GoString() string

func (*TransferChunksResponse) Marshal 

func (m *TransferChunksResponse) Marshal() (dAtA []byte, err error)

func (*TransferChunksResponse) MarshalTo 

func (m *TransferChunksResponse) MarshalTo(dAtA []byte) (int, error)

func (*TransferChunksResponse) MarshalToSizedBuffer 

func (m *TransferChunksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransferChunksResponse) ProtoMessage 

func (*TransferChunksResponse) ProtoMessage()

func (*TransferChunksResponse) Reset 

func (m *TransferChunksResponse) Reset()

func (*TransferChunksResponse) Size 

func (m *TransferChunksResponse) Size() (n int)

func (*TransferChunksResponse) String 

func (this *TransferChunksResponse) String() string

func (*TransferChunksResponse) Unmarshal 

func (m *TransferChunksResponse) Unmarshal(dAtA []byte) error

func (*TransferChunksResponse) XXX_DiscardUnknown 

func (m *TransferChunksResponse) XXX_DiscardUnknown()

func (*TransferChunksResponse) XXX_Marshal 

func (m *TransferChunksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransferChunksResponse) XXX_Merge 

func (m *TransferChunksResponse) XXX_Merge(src proto.Message)

func (*TransferChunksResponse) XXX_Size 

func (m *TransferChunksResponse) XXX_Size() int

func (*TransferChunksResponse) XXX_Unmarshal 

func (m *TransferChunksResponse) XXX_Unmarshal(b []byte) error

type UnimplementedIngesterServer 

type UnimplementedIngesterServer struct {
}

UnimplementedIngesterServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngesterServer) AllUserStats 

func (*UnimplementedIngesterServer) AllUserStats(ctx context.Context, req *UserStatsRequest) (*UsersStatsResponse, error)

func (*UnimplementedIngesterServer) LabelNames 

func (*UnimplementedIngesterServer) LabelNames(ctx context.Context, req *LabelNamesRequest) (*LabelNamesResponse, error)

func (*UnimplementedIngesterServer) LabelValues 

func (*UnimplementedIngesterServer) LabelValues(ctx context.Context, req *LabelValuesRequest) (*LabelValuesResponse, error)

func (*UnimplementedIngesterServer) MetricsForLabelMatchers 

func (*UnimplementedIngesterServer) MetricsForLabelMatchers(ctx context.Context, req *MetricsForLabelMatchersRequest) (*MetricsForLabelMatchersResponse, error)

func (*UnimplementedIngesterServer) MetricsMetadata 

func (*UnimplementedIngesterServer) MetricsMetadata(ctx context.Context, req *MetricsMetadataRequest) (*MetricsMetadataResponse, error)

func (*UnimplementedIngesterServer) Push 

func (*UnimplementedIngesterServer) Push(ctx context.Context, req *logproto.WriteRequest) (*logproto.WriteResponse, error)

func (*UnimplementedIngesterServer) Query 

func (*UnimplementedIngesterServer) Query(ctx context.Context, req *QueryRequest) (*QueryResponse, error)

func (*UnimplementedIngesterServer) QueryExemplars 

func (*UnimplementedIngesterServer) QueryExemplars(ctx context.Context, req *ExemplarQueryRequest) (*ExemplarQueryResponse, error)

func (*UnimplementedIngesterServer) QueryStream 

func (*UnimplementedIngesterServer) QueryStream(req *QueryRequest, srv Ingester_QueryStreamServer) error

func (*UnimplementedIngesterServer) TransferChunks 

func (*UnimplementedIngesterServer) TransferChunks(srv Ingester_TransferChunksServer) error

func (*UnimplementedIngesterServer) UserStats 

func (*UnimplementedIngesterServer) UserStats(ctx context.Context, req *UserStatsRequest) (*UserStatsResponse, error)

type UserIDStatsResponse 

type UserIDStatsResponse struct {
	UserId string             `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Data   *UserStatsResponse `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*UserIDStatsResponse) Descriptor 

func (*UserIDStatsResponse) Descriptor() ([]byte, []int)

func (*UserIDStatsResponse) Equal 

func (this *UserIDStatsResponse) Equal(that interface{}) bool

func (*UserIDStatsResponse) GetData 

func (m *UserIDStatsResponse) GetData() *UserStatsResponse

func (*UserIDStatsResponse) GetUserId 

func (m *UserIDStatsResponse) GetUserId() string

func (*UserIDStatsResponse) GoString 

func (this *UserIDStatsResponse) GoString() string

func (*UserIDStatsResponse) Marshal 

func (m *UserIDStatsResponse) Marshal() (dAtA []byte, err error)

func (*UserIDStatsResponse) MarshalTo 

func (m *UserIDStatsResponse) MarshalTo(dAtA []byte) (int, error)

func (*UserIDStatsResponse) MarshalToSizedBuffer 

func (m *UserIDStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserIDStatsResponse) ProtoMessage 

func (*UserIDStatsResponse) ProtoMessage()

func (*UserIDStatsResponse) Reset 

func (m *UserIDStatsResponse) Reset()

func (*UserIDStatsResponse) Size 

func (m *UserIDStatsResponse) Size() (n int)

func (*UserIDStatsResponse) String 

func (this *UserIDStatsResponse) String() string

func (*UserIDStatsResponse) Unmarshal 

func (m *UserIDStatsResponse) Unmarshal(dAtA []byte) error

func (*UserIDStatsResponse) XXX_DiscardUnknown 

func (m *UserIDStatsResponse) XXX_DiscardUnknown()

func (*UserIDStatsResponse) XXX_Marshal 

func (m *UserIDStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserIDStatsResponse) XXX_Merge 

func (m *UserIDStatsResponse) XXX_Merge(src proto.Message)

func (*UserIDStatsResponse) XXX_Size 

func (m *UserIDStatsResponse) XXX_Size() int

func (*UserIDStatsResponse) XXX_Unmarshal 

func (m *UserIDStatsResponse) XXX_Unmarshal(b []byte) error

type UserStatsRequest 

type UserStatsRequest struct {
}

func (*UserStatsRequest) Descriptor 

func (*UserStatsRequest) Descriptor() ([]byte, []int)

func (*UserStatsRequest) Equal 

func (this *UserStatsRequest) Equal(that interface{}) bool

func (*UserStatsRequest) GoString 

func (this *UserStatsRequest) GoString() string

func (*UserStatsRequest) Marshal 

func (m *UserStatsRequest) Marshal() (dAtA []byte, err error)

func (*UserStatsRequest) MarshalTo 

func (m *UserStatsRequest) MarshalTo(dAtA []byte) (int, error)

func (*UserStatsRequest) MarshalToSizedBuffer 

func (m *UserStatsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserStatsRequest) ProtoMessage 

func (*UserStatsRequest) ProtoMessage()

func (*UserStatsRequest) Reset 

func (m *UserStatsRequest) Reset()

func (*UserStatsRequest) Size 

func (m *UserStatsRequest) Size() (n int)

func (*UserStatsRequest) String 

func (this *UserStatsRequest) String() string

func (*UserStatsRequest) Unmarshal 

func (m *UserStatsRequest) Unmarshal(dAtA []byte) error

func (*UserStatsRequest) XXX_DiscardUnknown 

func (m *UserStatsRequest) XXX_DiscardUnknown()

func (*UserStatsRequest) XXX_Marshal 

func (m *UserStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserStatsRequest) XXX_Merge 

func (m *UserStatsRequest) XXX_Merge(src proto.Message)

func (*UserStatsRequest) XXX_Size 

func (m *UserStatsRequest) XXX_Size() int

func (*UserStatsRequest) XXX_Unmarshal 

func (m *UserStatsRequest) XXX_Unmarshal(b []byte) error

type UserStatsResponse 

type UserStatsResponse struct {
	IngestionRate     float64 `protobuf:"fixed64,1,opt,name=ingestion_rate,json=ingestionRate,proto3" json:"ingestion_rate,omitempty"`
	NumSeries         uint64  `protobuf:"varint,2,opt,name=num_series,json=numSeries,proto3" json:"num_series,omitempty"`
	ApiIngestionRate  float64 `protobuf:"fixed64,3,opt,name=api_ingestion_rate,json=apiIngestionRate,proto3" json:"api_ingestion_rate,omitempty"`
	RuleIngestionRate float64 `protobuf:"fixed64,4,opt,name=rule_ingestion_rate,json=ruleIngestionRate,proto3" json:"rule_ingestion_rate,omitempty"`
}

func (*UserStatsResponse) Descriptor 

func (*UserStatsResponse) Descriptor() ([]byte, []int)

func (*UserStatsResponse) Equal 

func (this *UserStatsResponse) Equal(that interface{}) bool

func (*UserStatsResponse) GetApiIngestionRate 

func (m *UserStatsResponse) GetApiIngestionRate() float64

func (*UserStatsResponse) GetIngestionRate 

func (m *UserStatsResponse) GetIngestionRate() float64

func (*UserStatsResponse) GetNumSeries 

func (m *UserStatsResponse) GetNumSeries() uint64

func (*UserStatsResponse) GetRuleIngestionRate 

func (m *UserStatsResponse) GetRuleIngestionRate() float64

func (*UserStatsResponse) GoString 

func (this *UserStatsResponse) GoString() string

func (*UserStatsResponse) Marshal 

func (m *UserStatsResponse) Marshal() (dAtA []byte, err error)

func (*UserStatsResponse) MarshalTo 

func (m *UserStatsResponse) MarshalTo(dAtA []byte) (int, error)

func (*UserStatsResponse) MarshalToSizedBuffer 

func (m *UserStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UserStatsResponse) ProtoMessage 

func (*UserStatsResponse) ProtoMessage()

func (*UserStatsResponse) Reset 

func (m *UserStatsResponse) Reset()

func (*UserStatsResponse) Size 

func (m *UserStatsResponse) Size() (n int)

func (*UserStatsResponse) String 

func (this *UserStatsResponse) String() string

func (*UserStatsResponse) Unmarshal 

func (m *UserStatsResponse) Unmarshal(dAtA []byte) error

func (*UserStatsResponse) XXX_DiscardUnknown 

func (m *UserStatsResponse) XXX_DiscardUnknown()

func (*UserStatsResponse) XXX_Marshal 

func (m *UserStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserStatsResponse) XXX_Merge 

func (m *UserStatsResponse) XXX_Merge(src proto.Message)

func (*UserStatsResponse) XXX_Size 

func (m *UserStatsResponse) XXX_Size() int

func (*UserStatsResponse) XXX_Unmarshal 

func (m *UserStatsResponse) XXX_Unmarshal(b []byte) error

type UsersStatsResponse 

type UsersStatsResponse struct {
	Stats []*UserIDStatsResponse `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
}

func (*UsersStatsResponse) Descriptor 

func (*UsersStatsResponse) Descriptor() ([]byte, []int)

func (*UsersStatsResponse) Equal 

func (this *UsersStatsResponse) Equal(that interface{}) bool

func (*UsersStatsResponse) GetStats 

func (m *UsersStatsResponse) GetStats() []*UserIDStatsResponse

func (*UsersStatsResponse) GoString 

func (this *UsersStatsResponse) GoString() string

func (*UsersStatsResponse) Marshal 

func (m *UsersStatsResponse) Marshal() (dAtA []byte, err error)

func (*UsersStatsResponse) MarshalTo 

func (m *UsersStatsResponse) MarshalTo(dAtA []byte) (int, error)

func (*UsersStatsResponse) MarshalToSizedBuffer 

func (m *UsersStatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UsersStatsResponse) ProtoMessage 

func (*UsersStatsResponse) ProtoMessage()

func (*UsersStatsResponse) Reset 

func (m *UsersStatsResponse) Reset()

func (*UsersStatsResponse) Size 

func (m *UsersStatsResponse) Size() (n int)

func (*UsersStatsResponse) String 

func (this *UsersStatsResponse) String() string

func (*UsersStatsResponse) Unmarshal 

func (m *UsersStatsResponse) Unmarshal(dAtA []byte) error

func (*UsersStatsResponse) XXX_DiscardUnknown 

func (m *UsersStatsResponse) XXX_DiscardUnknown()

func (*UsersStatsResponse) XXX_Marshal 

func (m *UsersStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UsersStatsResponse) XXX_Merge 

func (m *UsersStatsResponse) XXX_Merge(src proto.Message)

func (*UsersStatsResponse) XXX_Size 

func (m *UsersStatsResponse) XXX_Size() int

func (*UsersStatsResponse) XXX_Unmarshal 

func (m *UsersStatsResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.