Documentation ¶
Index ¶
- Variables
- type Chunk
- type Direction
- type DroppedStream
- func (*DroppedStream) Descriptor() ([]byte, []int)deprecated
- func (x *DroppedStream) GetFrom() *timestamppb.Timestamp
- func (x *DroppedStream) GetLabels() string
- func (x *DroppedStream) GetTo() *timestamppb.Timestamp
- func (*DroppedStream) ProtoMessage()
- func (x *DroppedStream) ProtoReflect() protoreflect.Message
- func (x *DroppedStream) Reset()
- func (x *DroppedStream) String() string
- type EntryAdapter
- func (*EntryAdapter) Descriptor() ([]byte, []int)deprecated
- func (x *EntryAdapter) GetLine() string
- func (x *EntryAdapter) GetTimestamp() *timestamppb.Timestamp
- func (*EntryAdapter) ProtoMessage()
- func (x *EntryAdapter) ProtoReflect() protoreflect.Message
- func (x *EntryAdapter) Reset()
- func (x *EntryAdapter) String() string
- type GetChunkIDsRequest
- func (*GetChunkIDsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetChunkIDsRequest) GetEnd() *timestamppb.Timestamp
- func (x *GetChunkIDsRequest) GetMatchers() string
- func (x *GetChunkIDsRequest) GetStart() *timestamppb.Timestamp
- func (*GetChunkIDsRequest) ProtoMessage()
- func (x *GetChunkIDsRequest) ProtoReflect() protoreflect.Message
- func (x *GetChunkIDsRequest) Reset()
- func (x *GetChunkIDsRequest) String() string
- type GetChunkIDsResponse
- func (*GetChunkIDsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetChunkIDsResponse) GetChunkIDs() []string
- func (*GetChunkIDsResponse) ProtoMessage()
- func (x *GetChunkIDsResponse) ProtoReflect() protoreflect.Message
- func (x *GetChunkIDsResponse) Reset()
- func (x *GetChunkIDsResponse) String() string
- type LabelPair
- type LabelRequest
- func (*LabelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LabelRequest) GetEnd() *timestamppb.Timestamp
- func (x *LabelRequest) GetName() string
- func (x *LabelRequest) GetStart() *timestamppb.Timestamp
- func (x *LabelRequest) GetValues() bool
- func (*LabelRequest) ProtoMessage()
- func (x *LabelRequest) ProtoReflect() protoreflect.Message
- func (x *LabelRequest) Reset()
- func (x *LabelRequest) String() string
- type LabelResponse
- type PushRequest
- type PushResponse
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRequest) GetDirection() Direction
- func (x *QueryRequest) GetEnd() *timestamppb.Timestamp
- func (x *QueryRequest) GetLimit() uint32
- func (x *QueryRequest) GetSelector() string
- func (x *QueryRequest) GetShards() []string
- func (x *QueryRequest) GetStart() *timestamppb.Timestamp
- func (*QueryRequest) ProtoMessage()
- func (x *QueryRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRequest) Reset()
- func (x *QueryRequest) String() string
- type QueryResponse
- type Sample
- func (*Sample) Descriptor() ([]byte, []int)deprecated
- func (x *Sample) GetHash() uint64
- func (x *Sample) GetTimestamp() int64
- func (x *Sample) GetValue() float64
- func (*Sample) ProtoMessage()
- func (x *Sample) ProtoReflect() protoreflect.Message
- func (x *Sample) Reset()
- func (x *Sample) String() string
- type SampleQueryRequest
- func (*SampleQueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SampleQueryRequest) GetEnd() *timestamppb.Timestamp
- func (x *SampleQueryRequest) GetSelector() string
- func (x *SampleQueryRequest) GetShards() []string
- func (x *SampleQueryRequest) GetStart() *timestamppb.Timestamp
- func (*SampleQueryRequest) ProtoMessage()
- func (x *SampleQueryRequest) ProtoReflect() protoreflect.Message
- func (x *SampleQueryRequest) Reset()
- func (x *SampleQueryRequest) String() string
- type SampleQueryResponse
- func (*SampleQueryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SampleQueryResponse) GetSeries() []*Series
- func (*SampleQueryResponse) ProtoMessage()
- func (x *SampleQueryResponse) ProtoReflect() protoreflect.Message
- func (x *SampleQueryResponse) Reset()
- func (x *SampleQueryResponse) String() string
- type Series
- type SeriesIdentifier
- func (*SeriesIdentifier) Descriptor() ([]byte, []int)deprecated
- func (x *SeriesIdentifier) GetLabels() map[string]string
- func (*SeriesIdentifier) ProtoMessage()
- func (x *SeriesIdentifier) ProtoReflect() protoreflect.Message
- func (x *SeriesIdentifier) Reset()
- func (x *SeriesIdentifier) String() string
- type SeriesRequest
- func (*SeriesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SeriesRequest) GetEnd() *timestamppb.Timestamp
- func (x *SeriesRequest) GetGroups() []string
- func (x *SeriesRequest) GetShards() []string
- func (x *SeriesRequest) GetStart() *timestamppb.Timestamp
- func (*SeriesRequest) ProtoMessage()
- func (x *SeriesRequest) ProtoReflect() protoreflect.Message
- func (x *SeriesRequest) Reset()
- func (x *SeriesRequest) String() string
- type SeriesResponse
- type StreamAdapter
- func (*StreamAdapter) Descriptor() ([]byte, []int)deprecated
- func (x *StreamAdapter) GetEntries() []*EntryAdapter
- func (x *StreamAdapter) GetLabels() string
- func (*StreamAdapter) ProtoMessage()
- func (x *StreamAdapter) ProtoReflect() protoreflect.Message
- func (x *StreamAdapter) Reset()
- func (x *StreamAdapter) String() string
- type TailRequest
- func (*TailRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TailRequest) GetDelayFor() uint32
- func (x *TailRequest) GetLimit() uint32
- func (x *TailRequest) GetQuery() string
- func (x *TailRequest) GetStart() *timestamppb.Timestamp
- func (*TailRequest) ProtoMessage()
- func (x *TailRequest) ProtoReflect() protoreflect.Message
- func (x *TailRequest) Reset()
- func (x *TailRequest) String() string
- type TailResponse
- func (*TailResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TailResponse) GetDroppedStreams() []*DroppedStream
- func (x *TailResponse) GetStream() *StreamAdapter
- func (*TailResponse) ProtoMessage()
- func (x *TailResponse) ProtoReflect() protoreflect.Message
- func (x *TailResponse) Reset()
- func (x *TailResponse) String() string
- type TailersCountRequest
- type TailersCountResponse
- func (*TailersCountResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TailersCountResponse) GetCount() uint32
- func (*TailersCountResponse) ProtoMessage()
- func (x *TailersCountResponse) ProtoReflect() protoreflect.Message
- func (x *TailersCountResponse) Reset()
- func (x *TailersCountResponse) String() string
- type TimeSeriesChunk
- func (*TimeSeriesChunk) Descriptor() ([]byte, []int)deprecated
- func (x *TimeSeriesChunk) GetChunks() []*Chunk
- func (x *TimeSeriesChunk) GetFromIngesterId() string
- func (x *TimeSeriesChunk) GetLabels() []*LabelPair
- func (x *TimeSeriesChunk) GetUserId() string
- func (*TimeSeriesChunk) ProtoMessage()
- func (x *TimeSeriesChunk) ProtoReflect() protoreflect.Message
- func (x *TimeSeriesChunk) Reset()
- func (x *TimeSeriesChunk) String() string
- type TransferChunksResponse
Constants ¶
This section is empty.
Variables ¶
var ( Direction_name = map[int32]string{ 0: "FORWARD", 1: "BACKWARD", } Direction_value = map[string]int32{ "FORWARD": 0, "BACKWARD": 1, } )
Enum value maps for Direction.
var File_logproto_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Chunk ¶
type Chunk struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*Chunk) Descriptor
deprecated
func (*Chunk) ProtoMessage ¶
func (*Chunk) ProtoMessage()
func (*Chunk) ProtoReflect ¶
func (x *Chunk) ProtoReflect() protoreflect.Message
type Direction ¶
type Direction int32
func (Direction) Descriptor ¶
func (Direction) Descriptor() protoreflect.EnumDescriptor
func (Direction) EnumDescriptor
deprecated
func (Direction) Number ¶
func (x Direction) Number() protoreflect.EnumNumber
func (Direction) Type ¶
func (Direction) Type() protoreflect.EnumType
type DroppedStream ¶
type DroppedStream struct { From *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` To *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` Labels string `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"` // contains filtered or unexported fields }
func (*DroppedStream) Descriptor
deprecated
func (*DroppedStream) Descriptor() ([]byte, []int)
Deprecated: Use DroppedStream.ProtoReflect.Descriptor instead.
func (*DroppedStream) GetFrom ¶
func (x *DroppedStream) GetFrom() *timestamppb.Timestamp
func (*DroppedStream) GetLabels ¶
func (x *DroppedStream) GetLabels() string
func (*DroppedStream) GetTo ¶
func (x *DroppedStream) GetTo() *timestamppb.Timestamp
func (*DroppedStream) ProtoMessage ¶
func (*DroppedStream) ProtoMessage()
func (*DroppedStream) ProtoReflect ¶
func (x *DroppedStream) ProtoReflect() protoreflect.Message
func (*DroppedStream) Reset ¶
func (x *DroppedStream) Reset()
func (*DroppedStream) String ¶
func (x *DroppedStream) String() string
type EntryAdapter ¶
type EntryAdapter struct { Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"` // contains filtered or unexported fields }
func (*EntryAdapter) Descriptor
deprecated
func (*EntryAdapter) Descriptor() ([]byte, []int)
Deprecated: Use EntryAdapter.ProtoReflect.Descriptor instead.
func (*EntryAdapter) GetLine ¶
func (x *EntryAdapter) GetLine() string
func (*EntryAdapter) GetTimestamp ¶
func (x *EntryAdapter) GetTimestamp() *timestamppb.Timestamp
func (*EntryAdapter) ProtoMessage ¶
func (*EntryAdapter) ProtoMessage()
func (*EntryAdapter) ProtoReflect ¶
func (x *EntryAdapter) ProtoReflect() protoreflect.Message
func (*EntryAdapter) Reset ¶
func (x *EntryAdapter) Reset()
func (*EntryAdapter) String ¶
func (x *EntryAdapter) String() string
type GetChunkIDsRequest ¶
type GetChunkIDsRequest struct { Matchers string `protobuf:"bytes,1,opt,name=matchers,proto3" json:"matchers,omitempty"` Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*GetChunkIDsRequest) Descriptor
deprecated
func (*GetChunkIDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetChunkIDsRequest.ProtoReflect.Descriptor instead.
func (*GetChunkIDsRequest) GetEnd ¶
func (x *GetChunkIDsRequest) GetEnd() *timestamppb.Timestamp
func (*GetChunkIDsRequest) GetMatchers ¶
func (x *GetChunkIDsRequest) GetMatchers() string
func (*GetChunkIDsRequest) GetStart ¶
func (x *GetChunkIDsRequest) GetStart() *timestamppb.Timestamp
func (*GetChunkIDsRequest) ProtoMessage ¶
func (*GetChunkIDsRequest) ProtoMessage()
func (*GetChunkIDsRequest) ProtoReflect ¶
func (x *GetChunkIDsRequest) ProtoReflect() protoreflect.Message
func (*GetChunkIDsRequest) Reset ¶
func (x *GetChunkIDsRequest) Reset()
func (*GetChunkIDsRequest) String ¶
func (x *GetChunkIDsRequest) String() string
type GetChunkIDsResponse ¶
type GetChunkIDsResponse struct { ChunkIDs []string `protobuf:"bytes,1,rep,name=chunkIDs,proto3" json:"chunkIDs,omitempty"` // contains filtered or unexported fields }
func (*GetChunkIDsResponse) Descriptor
deprecated
func (*GetChunkIDsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetChunkIDsResponse.ProtoReflect.Descriptor instead.
func (*GetChunkIDsResponse) GetChunkIDs ¶
func (x *GetChunkIDsResponse) GetChunkIDs() []string
func (*GetChunkIDsResponse) ProtoMessage ¶
func (*GetChunkIDsResponse) ProtoMessage()
func (*GetChunkIDsResponse) ProtoReflect ¶
func (x *GetChunkIDsResponse) ProtoReflect() protoreflect.Message
func (*GetChunkIDsResponse) Reset ¶
func (x *GetChunkIDsResponse) Reset()
func (*GetChunkIDsResponse) String ¶
func (x *GetChunkIDsResponse) String() string
type LabelPair ¶
type LabelPair struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*LabelPair) Descriptor
deprecated
func (*LabelPair) ProtoMessage ¶
func (*LabelPair) ProtoMessage()
func (*LabelPair) ProtoReflect ¶
func (x *LabelPair) ProtoReflect() protoreflect.Message
type LabelRequest ¶
type LabelRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Values bool `protobuf:"varint,2,opt,name=values,proto3" json:"values,omitempty"` // True to fetch label values, false for fetch labels names. Start *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
func (*LabelRequest) Descriptor
deprecated
func (*LabelRequest) Descriptor() ([]byte, []int)
Deprecated: Use LabelRequest.ProtoReflect.Descriptor instead.
func (*LabelRequest) GetEnd ¶
func (x *LabelRequest) GetEnd() *timestamppb.Timestamp
func (*LabelRequest) GetName ¶
func (x *LabelRequest) GetName() string
func (*LabelRequest) GetStart ¶
func (x *LabelRequest) GetStart() *timestamppb.Timestamp
func (*LabelRequest) GetValues ¶
func (x *LabelRequest) GetValues() bool
func (*LabelRequest) ProtoMessage ¶
func (*LabelRequest) ProtoMessage()
func (*LabelRequest) ProtoReflect ¶
func (x *LabelRequest) ProtoReflect() protoreflect.Message
func (*LabelRequest) Reset ¶
func (x *LabelRequest) Reset()
func (*LabelRequest) String ¶
func (x *LabelRequest) String() string
type LabelResponse ¶
type LabelResponse struct { Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` // contains filtered or unexported fields }
func (*LabelResponse) Descriptor
deprecated
func (*LabelResponse) Descriptor() ([]byte, []int)
Deprecated: Use LabelResponse.ProtoReflect.Descriptor instead.
func (*LabelResponse) GetValues ¶
func (x *LabelResponse) GetValues() []string
func (*LabelResponse) ProtoMessage ¶
func (*LabelResponse) ProtoMessage()
func (*LabelResponse) ProtoReflect ¶
func (x *LabelResponse) ProtoReflect() protoreflect.Message
func (*LabelResponse) Reset ¶
func (x *LabelResponse) Reset()
func (*LabelResponse) String ¶
func (x *LabelResponse) String() string
type PushRequest ¶
type PushRequest struct { Streams []*StreamAdapter `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"` // contains filtered or unexported fields }
func (*PushRequest) Descriptor
deprecated
func (*PushRequest) Descriptor() ([]byte, []int)
Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.
func (*PushRequest) GetStreams ¶
func (x *PushRequest) GetStreams() []*StreamAdapter
func (*PushRequest) ProtoMessage ¶
func (*PushRequest) ProtoMessage()
func (*PushRequest) ProtoReflect ¶
func (x *PushRequest) ProtoReflect() protoreflect.Message
func (*PushRequest) Reset ¶
func (x *PushRequest) Reset()
func (*PushRequest) String ¶
func (x *PushRequest) String() string
type PushResponse ¶
type PushResponse struct {
// contains filtered or unexported fields
}
func (*PushResponse) Descriptor
deprecated
func (*PushResponse) Descriptor() ([]byte, []int)
Deprecated: Use PushResponse.ProtoReflect.Descriptor instead.
func (*PushResponse) ProtoMessage ¶
func (*PushResponse) ProtoMessage()
func (*PushResponse) ProtoReflect ¶
func (x *PushResponse) ProtoReflect() protoreflect.Message
func (*PushResponse) Reset ¶
func (x *PushResponse) Reset()
func (*PushResponse) String ¶
func (x *PushResponse) String() string
type QueryRequest ¶
type QueryRequest struct { Selector string `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"` Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Start *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"` Direction Direction `protobuf:"varint,5,opt,name=direction,proto3,enum=logproto.Direction" json:"direction,omitempty"` Shards []string `protobuf:"bytes,7,rep,name=shards,proto3" json:"shards,omitempty"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetDirection ¶
func (x *QueryRequest) GetDirection() Direction
func (*QueryRequest) GetEnd ¶
func (x *QueryRequest) GetEnd() *timestamppb.Timestamp
func (*QueryRequest) GetLimit ¶
func (x *QueryRequest) GetLimit() uint32
func (*QueryRequest) GetSelector ¶
func (x *QueryRequest) GetSelector() string
func (*QueryRequest) GetShards ¶
func (x *QueryRequest) GetShards() []string
func (*QueryRequest) GetStart ¶
func (x *QueryRequest) GetStart() *timestamppb.Timestamp
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type QueryResponse ¶
type QueryResponse struct { Streams []*StreamAdapter `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"` // contains filtered or unexported fields }
func (*QueryResponse) Descriptor
deprecated
func (*QueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.
func (*QueryResponse) GetStreams ¶
func (x *QueryResponse) GetStreams() []*StreamAdapter
func (*QueryResponse) ProtoMessage ¶
func (*QueryResponse) ProtoMessage()
func (*QueryResponse) ProtoReflect ¶
func (x *QueryResponse) ProtoReflect() protoreflect.Message
func (*QueryResponse) Reset ¶
func (x *QueryResponse) Reset()
func (*QueryResponse) String ¶
func (x *QueryResponse) String() string
type Sample ¶
type Sample struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` Hash uint64 `protobuf:"varint,3,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*Sample) Descriptor
deprecated
func (*Sample) GetTimestamp ¶
func (*Sample) ProtoMessage ¶
func (*Sample) ProtoMessage()
func (*Sample) ProtoReflect ¶
func (x *Sample) ProtoReflect() protoreflect.Message
type SampleQueryRequest ¶
type SampleQueryRequest struct { Selector string `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"` Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"` Shards []string `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"` // contains filtered or unexported fields }
func (*SampleQueryRequest) Descriptor
deprecated
func (*SampleQueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use SampleQueryRequest.ProtoReflect.Descriptor instead.
func (*SampleQueryRequest) GetEnd ¶
func (x *SampleQueryRequest) GetEnd() *timestamppb.Timestamp
func (*SampleQueryRequest) GetSelector ¶
func (x *SampleQueryRequest) GetSelector() string
func (*SampleQueryRequest) GetShards ¶
func (x *SampleQueryRequest) GetShards() []string
func (*SampleQueryRequest) GetStart ¶
func (x *SampleQueryRequest) GetStart() *timestamppb.Timestamp
func (*SampleQueryRequest) ProtoMessage ¶
func (*SampleQueryRequest) ProtoMessage()
func (*SampleQueryRequest) ProtoReflect ¶
func (x *SampleQueryRequest) ProtoReflect() protoreflect.Message
func (*SampleQueryRequest) Reset ¶
func (x *SampleQueryRequest) Reset()
func (*SampleQueryRequest) String ¶
func (x *SampleQueryRequest) String() string
type SampleQueryResponse ¶
type SampleQueryResponse struct { Series []*Series `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"` // contains filtered or unexported fields }
func (*SampleQueryResponse) Descriptor
deprecated
func (*SampleQueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use SampleQueryResponse.ProtoReflect.Descriptor instead.
func (*SampleQueryResponse) GetSeries ¶
func (x *SampleQueryResponse) GetSeries() []*Series
func (*SampleQueryResponse) ProtoMessage ¶
func (*SampleQueryResponse) ProtoMessage()
func (*SampleQueryResponse) ProtoReflect ¶
func (x *SampleQueryResponse) ProtoReflect() protoreflect.Message
func (*SampleQueryResponse) Reset ¶
func (x *SampleQueryResponse) Reset()
func (*SampleQueryResponse) String ¶
func (x *SampleQueryResponse) String() string
type Series ¶
type Series struct { Labels string `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"` Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"` // contains filtered or unexported fields }
func (*Series) Descriptor
deprecated
func (*Series) GetSamples ¶
func (*Series) ProtoMessage ¶
func (*Series) ProtoMessage()
func (*Series) ProtoReflect ¶
func (x *Series) ProtoReflect() protoreflect.Message
type SeriesIdentifier ¶
type SeriesIdentifier struct { Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SeriesIdentifier) Descriptor
deprecated
func (*SeriesIdentifier) Descriptor() ([]byte, []int)
Deprecated: Use SeriesIdentifier.ProtoReflect.Descriptor instead.
func (*SeriesIdentifier) GetLabels ¶
func (x *SeriesIdentifier) GetLabels() map[string]string
func (*SeriesIdentifier) ProtoMessage ¶
func (*SeriesIdentifier) ProtoMessage()
func (*SeriesIdentifier) ProtoReflect ¶
func (x *SeriesIdentifier) ProtoReflect() protoreflect.Message
func (*SeriesIdentifier) Reset ¶
func (x *SeriesIdentifier) Reset()
func (*SeriesIdentifier) String ¶
func (x *SeriesIdentifier) String() string
type SeriesRequest ¶
type SeriesRequest struct { Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"` Groups []string `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"` Shards []string `protobuf:"bytes,4,rep,name=shards,proto3" json:"shards,omitempty"` // contains filtered or unexported fields }
func (*SeriesRequest) Descriptor
deprecated
func (*SeriesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SeriesRequest.ProtoReflect.Descriptor instead.
func (*SeriesRequest) GetEnd ¶
func (x *SeriesRequest) GetEnd() *timestamppb.Timestamp
func (*SeriesRequest) GetGroups ¶
func (x *SeriesRequest) GetGroups() []string
func (*SeriesRequest) GetShards ¶
func (x *SeriesRequest) GetShards() []string
func (*SeriesRequest) GetStart ¶
func (x *SeriesRequest) GetStart() *timestamppb.Timestamp
func (*SeriesRequest) ProtoMessage ¶
func (*SeriesRequest) ProtoMessage()
func (*SeriesRequest) ProtoReflect ¶
func (x *SeriesRequest) ProtoReflect() protoreflect.Message
func (*SeriesRequest) Reset ¶
func (x *SeriesRequest) Reset()
func (*SeriesRequest) String ¶
func (x *SeriesRequest) String() string
type SeriesResponse ¶
type SeriesResponse struct { Series []*SeriesIdentifier `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"` // contains filtered or unexported fields }
func (*SeriesResponse) Descriptor
deprecated
func (*SeriesResponse) Descriptor() ([]byte, []int)
Deprecated: Use SeriesResponse.ProtoReflect.Descriptor instead.
func (*SeriesResponse) GetSeries ¶
func (x *SeriesResponse) GetSeries() []*SeriesIdentifier
func (*SeriesResponse) ProtoMessage ¶
func (*SeriesResponse) ProtoMessage()
func (*SeriesResponse) ProtoReflect ¶
func (x *SeriesResponse) ProtoReflect() protoreflect.Message
func (*SeriesResponse) Reset ¶
func (x *SeriesResponse) Reset()
func (*SeriesResponse) String ¶
func (x *SeriesResponse) String() string
type StreamAdapter ¶
type StreamAdapter struct { Labels string `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"` Entries []*EntryAdapter `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
func (*StreamAdapter) Descriptor
deprecated
func (*StreamAdapter) Descriptor() ([]byte, []int)
Deprecated: Use StreamAdapter.ProtoReflect.Descriptor instead.
func (*StreamAdapter) GetEntries ¶
func (x *StreamAdapter) GetEntries() []*EntryAdapter
func (*StreamAdapter) GetLabels ¶
func (x *StreamAdapter) GetLabels() string
func (*StreamAdapter) ProtoMessage ¶
func (*StreamAdapter) ProtoMessage()
func (*StreamAdapter) ProtoReflect ¶
func (x *StreamAdapter) ProtoReflect() protoreflect.Message
func (*StreamAdapter) Reset ¶
func (x *StreamAdapter) Reset()
func (*StreamAdapter) String ¶
func (x *StreamAdapter) String() string
type TailRequest ¶
type TailRequest struct { Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` DelayFor uint32 `protobuf:"varint,3,opt,name=delayFor,proto3" json:"delayFor,omitempty"` Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"` Start *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start,proto3" json:"start,omitempty"` // contains filtered or unexported fields }
func (*TailRequest) Descriptor
deprecated
func (*TailRequest) Descriptor() ([]byte, []int)
Deprecated: Use TailRequest.ProtoReflect.Descriptor instead.
func (*TailRequest) GetDelayFor ¶
func (x *TailRequest) GetDelayFor() uint32
func (*TailRequest) GetLimit ¶
func (x *TailRequest) GetLimit() uint32
func (*TailRequest) GetQuery ¶
func (x *TailRequest) GetQuery() string
func (*TailRequest) GetStart ¶
func (x *TailRequest) GetStart() *timestamppb.Timestamp
func (*TailRequest) ProtoMessage ¶
func (*TailRequest) ProtoMessage()
func (*TailRequest) ProtoReflect ¶
func (x *TailRequest) ProtoReflect() protoreflect.Message
func (*TailRequest) Reset ¶
func (x *TailRequest) Reset()
func (*TailRequest) String ¶
func (x *TailRequest) String() string
type TailResponse ¶
type TailResponse struct { Stream *StreamAdapter `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"` DroppedStreams []*DroppedStream `protobuf:"bytes,2,rep,name=droppedStreams,proto3" json:"droppedStreams,omitempty"` // contains filtered or unexported fields }
func (*TailResponse) Descriptor
deprecated
func (*TailResponse) Descriptor() ([]byte, []int)
Deprecated: Use TailResponse.ProtoReflect.Descriptor instead.
func (*TailResponse) GetDroppedStreams ¶
func (x *TailResponse) GetDroppedStreams() []*DroppedStream
func (*TailResponse) GetStream ¶
func (x *TailResponse) GetStream() *StreamAdapter
func (*TailResponse) ProtoMessage ¶
func (*TailResponse) ProtoMessage()
func (*TailResponse) ProtoReflect ¶
func (x *TailResponse) ProtoReflect() protoreflect.Message
func (*TailResponse) Reset ¶
func (x *TailResponse) Reset()
func (*TailResponse) String ¶
func (x *TailResponse) String() string
type TailersCountRequest ¶
type TailersCountRequest struct {
// contains filtered or unexported fields
}
func (*TailersCountRequest) Descriptor
deprecated
func (*TailersCountRequest) Descriptor() ([]byte, []int)
Deprecated: Use TailersCountRequest.ProtoReflect.Descriptor instead.
func (*TailersCountRequest) ProtoMessage ¶
func (*TailersCountRequest) ProtoMessage()
func (*TailersCountRequest) ProtoReflect ¶
func (x *TailersCountRequest) ProtoReflect() protoreflect.Message
func (*TailersCountRequest) Reset ¶
func (x *TailersCountRequest) Reset()
func (*TailersCountRequest) String ¶
func (x *TailersCountRequest) String() string
type TailersCountResponse ¶
type TailersCountResponse struct { Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*TailersCountResponse) Descriptor
deprecated
func (*TailersCountResponse) Descriptor() ([]byte, []int)
Deprecated: Use TailersCountResponse.ProtoReflect.Descriptor instead.
func (*TailersCountResponse) GetCount ¶
func (x *TailersCountResponse) GetCount() uint32
func (*TailersCountResponse) ProtoMessage ¶
func (*TailersCountResponse) ProtoMessage()
func (*TailersCountResponse) ProtoReflect ¶
func (x *TailersCountResponse) ProtoReflect() protoreflect.Message
func (*TailersCountResponse) Reset ¶
func (x *TailersCountResponse) Reset()
func (*TailersCountResponse) String ¶
func (x *TailersCountResponse) String() string
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 []*LabelPair `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"` Chunks []*Chunk `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks,omitempty"` // contains filtered or unexported fields }
func (*TimeSeriesChunk) Descriptor
deprecated
func (*TimeSeriesChunk) Descriptor() ([]byte, []int)
Deprecated: Use TimeSeriesChunk.ProtoReflect.Descriptor instead.
func (*TimeSeriesChunk) GetChunks ¶
func (x *TimeSeriesChunk) GetChunks() []*Chunk
func (*TimeSeriesChunk) GetFromIngesterId ¶
func (x *TimeSeriesChunk) GetFromIngesterId() string
func (*TimeSeriesChunk) GetLabels ¶
func (x *TimeSeriesChunk) GetLabels() []*LabelPair
func (*TimeSeriesChunk) GetUserId ¶
func (x *TimeSeriesChunk) GetUserId() string
func (*TimeSeriesChunk) ProtoMessage ¶
func (*TimeSeriesChunk) ProtoMessage()
func (*TimeSeriesChunk) ProtoReflect ¶
func (x *TimeSeriesChunk) ProtoReflect() protoreflect.Message
func (*TimeSeriesChunk) Reset ¶
func (x *TimeSeriesChunk) Reset()
func (*TimeSeriesChunk) String ¶
func (x *TimeSeriesChunk) String() string
type TransferChunksResponse ¶
type TransferChunksResponse struct {
// contains filtered or unexported fields
}
func (*TransferChunksResponse) Descriptor
deprecated
func (*TransferChunksResponse) Descriptor() ([]byte, []int)
Deprecated: Use TransferChunksResponse.ProtoReflect.Descriptor instead.
func (*TransferChunksResponse) ProtoMessage ¶
func (*TransferChunksResponse) ProtoMessage()
func (*TransferChunksResponse) ProtoReflect ¶
func (x *TransferChunksResponse) ProtoReflect() protoreflect.Message
func (*TransferChunksResponse) Reset ¶
func (x *TransferChunksResponse) Reset()
func (*TransferChunksResponse) String ¶
func (x *TransferChunksResponse) String() string