Documentation ¶
Index ¶
- Variables
- type Chunk
- type ChunkRef
- func (*ChunkRef) Descriptor() ([]byte, []int)deprecated
- func (x *ChunkRef) GetChecksum() uint32
- func (x *ChunkRef) GetFingerprint() uint64
- func (x *ChunkRef) GetFrom() int64
- func (x *ChunkRef) GetThrough() int64
- func (x *ChunkRef) GetUserId() string
- func (*ChunkRef) ProtoMessage()
- func (x *ChunkRef) ProtoReflect() protoreflect.Message
- func (x *ChunkRef) Reset()
- func (x *ChunkRef) String() string
- 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 Entry
- 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 LegacyLabelPair
- func (*LegacyLabelPair) Descriptor() ([]byte, []int)deprecated
- func (x *LegacyLabelPair) GetName() []byte
- func (x *LegacyLabelPair) GetValue() []byte
- func (*LegacyLabelPair) ProtoMessage()
- func (x *LegacyLabelPair) ProtoReflect() protoreflect.Message
- func (x *LegacyLabelPair) Reset()
- func (x *LegacyLabelPair) String() string
- type LegacySample
- func (*LegacySample) Descriptor() ([]byte, []int)deprecated
- func (x *LegacySample) GetTimestampMs() int64
- func (x *LegacySample) GetValue() float64
- func (*LegacySample) ProtoMessage()
- func (x *LegacySample) ProtoReflect() protoreflect.Message
- func (x *LegacySample) Reset()
- func (x *LegacySample) String() string
- type PushRequest
- type PushResponse
- 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 Series
- func (*Series) Descriptor() ([]byte, []int)deprecated
- func (x *Series) GetLabels() string
- func (x *Series) GetSamples() []*Sample
- func (x *Series) GetStreamHash() uint64
- func (*Series) ProtoMessage()
- func (x *Series) ProtoReflect() protoreflect.Message
- func (x *Series) Reset()
- func (x *Series) String() string
- 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 Stream
- func (*Stream) Descriptor() ([]byte, []int)deprecated
- func (x *Stream) GetEntries() []*Entry
- func (x *Stream) GetHash() uint64
- func (x *Stream) GetLabels() string
- func (*Stream) ProtoMessage()
- func (x *Stream) ProtoReflect() protoreflect.Message
- func (x *Stream) Reset()
- func (x *Stream) 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() *Stream
- 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 File_logproto_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 ChunkRef ¶
type ChunkRef struct { Fingerprint uint64 `protobuf:"varint,1,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"` UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` From int64 `protobuf:"varint,3,opt,name=from,proto3" json:"from,omitempty"` Through int64 `protobuf:"varint,4,opt,name=through,proto3" json:"through,omitempty"` // The checksum is not written to the external storage. We use crc32, // Castagnoli table. See http://www.evanjones.ca/crc32c.html. Checksum uint32 `protobuf:"varint,5,opt,name=checksum,proto3" json:"checksum,omitempty"` // contains filtered or unexported fields }
ChunkRef contains the metadata to reference a Chunk. It is embedded by the Chunk type itself and used to generate the Chunk checksum. So it is imported to take care of the JSON representation of the resulting Go struct.
func (*ChunkRef) Descriptor
deprecated
func (*ChunkRef) GetChecksum ¶
func (*ChunkRef) GetFingerprint ¶
func (*ChunkRef) GetThrough ¶
func (*ChunkRef) ProtoMessage ¶
func (*ChunkRef) ProtoMessage()
func (*ChunkRef) ProtoReflect ¶
func (x *ChunkRef) ProtoReflect() protoreflect.Message
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 Entry ¶
type Entry 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 (*Entry) Descriptor
deprecated
func (*Entry) GetTimestamp ¶
func (x *Entry) GetTimestamp() *timestamppb.Timestamp
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) ProtoReflect ¶
func (x *Entry) ProtoReflect() protoreflect.Message
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 LegacyLabelPair ¶
type LegacyLabelPair struct { Name []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
LegacyLabelPair exists for backwards compatibility reasons and is deprecated. Do not use.
func (*LegacyLabelPair) Descriptor
deprecated
func (*LegacyLabelPair) Descriptor() ([]byte, []int)
Deprecated: Use LegacyLabelPair.ProtoReflect.Descriptor instead.
func (*LegacyLabelPair) GetName ¶
func (x *LegacyLabelPair) GetName() []byte
func (*LegacyLabelPair) GetValue ¶
func (x *LegacyLabelPair) GetValue() []byte
func (*LegacyLabelPair) ProtoMessage ¶
func (*LegacyLabelPair) ProtoMessage()
func (*LegacyLabelPair) ProtoReflect ¶
func (x *LegacyLabelPair) ProtoReflect() protoreflect.Message
func (*LegacyLabelPair) Reset ¶
func (x *LegacyLabelPair) Reset()
func (*LegacyLabelPair) String ¶
func (x *LegacyLabelPair) String() string
type LegacySample ¶
type LegacySample struct { Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"` TimestampMs int64 `protobuf:"varint,2,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"` // contains filtered or unexported fields }
LegacySample exists for backwards compatibility reasons and is deprecated. Do not use.
func (*LegacySample) Descriptor
deprecated
func (*LegacySample) Descriptor() ([]byte, []int)
Deprecated: Use LegacySample.ProtoReflect.Descriptor instead.
func (*LegacySample) GetTimestampMs ¶
func (x *LegacySample) GetTimestampMs() int64
func (*LegacySample) GetValue ¶
func (x *LegacySample) GetValue() float64
func (*LegacySample) ProtoMessage ¶
func (*LegacySample) ProtoMessage()
func (*LegacySample) ProtoReflect ¶
func (x *LegacySample) ProtoReflect() protoreflect.Message
func (*LegacySample) Reset ¶
func (x *LegacySample) Reset()
func (*LegacySample) String ¶
func (x *LegacySample) String() string
type PushRequest ¶
type PushRequest struct { Streams []*Stream `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() []*Stream
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 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 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"` StreamHash uint64 `protobuf:"varint,3,opt,name=streamHash,proto3" json:"streamHash,omitempty"` // contains filtered or unexported fields }
func (*Series) Descriptor
deprecated
func (*Series) GetSamples ¶
func (*Series) GetStreamHash ¶
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 Stream ¶
type Stream struct { Labels string `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"` Entries []*Entry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"` // hash contains the original hash of the stream. Hash uint64 `protobuf:"varint,3,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*Stream) Descriptor
deprecated
func (*Stream) GetEntries ¶
func (*Stream) ProtoMessage ¶
func (*Stream) ProtoMessage()
func (*Stream) ProtoReflect ¶
func (x *Stream) ProtoReflect() protoreflect.Message
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 *Stream `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() *Stream
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