storepb

package
v0.0.0-...-05cd9ca Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2024 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCache = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCache   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Chunk_Encoding_name = map[int32]string{
	0: "Chunk_XOR",
	1: "Chunk_Histogram",
	2: "Chunk_FloatHistogram",
}
View Source 
var Chunk_Encoding_value = map[string]int32{
	"Chunk_XOR":            0,
	"Chunk_Histogram":      1,
	"Chunk_FloatHistogram": 2,
}
View Source 
var LabelMatcher_Type_name = map[int32]string{
	0: "LabelMatcher_EQ",
	1: "LabelMatcher_NEQ",
	2: "LabelMatcher_RE",
	3: "LabelMatcher_NRE",
}
View Source 
var LabelMatcher_Type_value = map[string]int32{
	"LabelMatcher_EQ":  0,
	"LabelMatcher_NEQ": 1,
	"LabelMatcher_RE":  2,
	"LabelMatcher_NRE": 3,
}

Functions

func MatchersToPromMatchers 

func MatchersToPromMatchers(ms ...LabelMatcher) ([]*labels.Matcher, error)

MatchersToPromMatchers returns Prometheus matchers from proto matchers. NOTE: It allocates memory.

Types

type AggrChunk 

type AggrChunk struct {
	MinTime int64 `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime int64 `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	Raw     Chunk `protobuf:"bytes,3,opt,name=raw,proto3" json:"raw"`
}

func (*AggrChunk) Descriptor 

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

func (*AggrChunk) Equal 

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

func (AggrChunk) GetChunkEncoding 

func (c AggrChunk) GetChunkEncoding() (chunk.Encoding, bool)

func (*AggrChunk) GoString 

func (this *AggrChunk) GoString() string

func (*AggrChunk) Marshal 

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

func (*AggrChunk) MarshalTo 

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

func (*AggrChunk) MarshalToSizedBuffer 

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

func (*AggrChunk) ProtoMessage 

func (*AggrChunk) ProtoMessage()

func (*AggrChunk) Reset 

func (m *AggrChunk) Reset()

func (*AggrChunk) Size 

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

func (*AggrChunk) String 

func (this *AggrChunk) String() string

func (*AggrChunk) Unmarshal 

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

func (*AggrChunk) XXX_DiscardUnknown 

func (m *AggrChunk) XXX_DiscardUnknown()

func (*AggrChunk) XXX_Marshal 

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

func (*AggrChunk) XXX_Merge 

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

func (*AggrChunk) XXX_Size 

func (m *AggrChunk) XXX_Size() int

func (*AggrChunk) XXX_Unmarshal 

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

type CachedSeries 

type CachedSeries struct {
	Series              []github_com_grafana_mimir_pkg_mimirpb.PreallocatingMetric `protobuf:"bytes,1,rep,name=series,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.PreallocatingMetric" json:"series"`
	DiffEncodedPostings []byte                                                     `protobuf:"bytes,5,opt,name=diffEncodedPostings,proto3" json:"diffEncodedPostings,omitempty"`
}

func (*CachedSeries) Descriptor 

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

func (*CachedSeries) Equal 

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

func (*CachedSeries) GoString 

func (this *CachedSeries) GoString() string

func (*CachedSeries) Marshal 

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

func (*CachedSeries) MarshalTo 

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

func (*CachedSeries) MarshalToSizedBuffer 

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

func (*CachedSeries) ProtoMessage 

func (*CachedSeries) ProtoMessage()

func (*CachedSeries) Reset 

func (m *CachedSeries) Reset()

func (*CachedSeries) Size 

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

func (*CachedSeries) String 

func (this *CachedSeries) String() string

func (*CachedSeries) Unmarshal 

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

func (*CachedSeries) XXX_DiscardUnknown 

func (m *CachedSeries) XXX_DiscardUnknown()

func (*CachedSeries) XXX_Marshal 

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

func (*CachedSeries) XXX_Merge 

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

func (*CachedSeries) XXX_Size 

func (m *CachedSeries) XXX_Size() int

func (*CachedSeries) XXX_Unmarshal 

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

type Chunk 

type Chunk struct {
	Type Chunk_Encoding                                       `protobuf:"varint,1,opt,name=type,proto3,enum=thanos.Chunk_Encoding" json:"type,omitempty"`
	Data github_com_grafana_mimir_pkg_mimirpb.UnsafeByteSlice `protobuf:"bytes,2,opt,name=data,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.UnsafeByteSlice" json:"data"`
}

func (*Chunk) Descriptor 

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

func (*Chunk) Equal 

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

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 Chunk_Encoding 

type Chunk_Encoding int32
const (
	Chunk_XOR            Chunk_Encoding = 0
	Chunk_Histogram      Chunk_Encoding = 1
	Chunk_FloatHistogram Chunk_Encoding = 2
)

func (Chunk_Encoding) EnumDescriptor 

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

func (Chunk_Encoding) String 

func (x Chunk_Encoding) String() string

type LabelMatcher 

type LabelMatcher struct {
	Type  LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=thanos.LabelMatcher_Type" 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"`
}

Matcher specifies a rule, which can match or set of labels or not.

func PromMatchersToMatchers 

func PromMatchersToMatchers(ms ...*labels.Matcher) ([]LabelMatcher, error)

PromMatchersToMatchers returns proto matchers from Prometheus matchers. NOTE: It allocates memory.

func (*LabelMatcher) Descriptor 

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

func (*LabelMatcher) Equal 

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

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 LabelMatcher_Type 

type LabelMatcher_Type int32
const (
	LabelMatcher_EQ  LabelMatcher_Type = 0
	LabelMatcher_NEQ LabelMatcher_Type = 1
	LabelMatcher_RE  LabelMatcher_Type = 2
	LabelMatcher_NRE LabelMatcher_Type = 3
)

func (LabelMatcher_Type) EnumDescriptor 

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

func (LabelMatcher_Type) String 

func (x LabelMatcher_Type) String() string

type LabelNamesRequest 

type LabelNamesRequest struct {
	Start int64 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	End   int64 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// hints is an opaque data structure that can be used to carry additional information.
	// The content of this field and whether it's supported depends on the
	// implementation of a specific store.
	Hints    *types.Any     `protobuf:"bytes,5,opt,name=hints,proto3" json:"hints,omitempty"`
	Matchers []LabelMatcher `protobuf:"bytes,6,rep,name=matchers,proto3" json:"matchers"`
}

func (*LabelNamesRequest) Descriptor 

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

func (*LabelNamesRequest) Equal 

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

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 {
	Names    []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	/// hints is an opaque data structure that can be used to carry additional information from
	/// the store. The content of this field and whether it's supported depends on the
	/// implementation of a specific store.
	Hints *types.Any `protobuf:"bytes,3,opt,name=hints,proto3" json:"hints,omitempty"`
}

func (*LabelNamesResponse) Descriptor 

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

func (*LabelNamesResponse) Equal 

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

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 {
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Start int64  `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty"`
	End   int64  `protobuf:"varint,5,opt,name=end,proto3" json:"end,omitempty"`
	// hints is an opaque data structure that can be used to carry additional information.
	// The content of this field and whether it's supported depends on the
	// implementation of a specific store.
	Hints    *types.Any     `protobuf:"bytes,6,opt,name=hints,proto3" json:"hints,omitempty"`
	Matchers []LabelMatcher `protobuf:"bytes,7,rep,name=matchers,proto3" json:"matchers"`
}

func (*LabelValuesRequest) Descriptor 

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

func (*LabelValuesRequest) Equal 

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

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 {
	Values   []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	/// hints is an opaque data structure that can be used to carry additional information from
	/// the store. The content of this field and whether it's supported depends on the
	/// implementation of a specific store.
	Hints *types.Any `protobuf:"bytes,3,opt,name=hints,proto3" json:"hints,omitempty"`
}

func (*LabelValuesResponse) Descriptor 

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

func (*LabelValuesResponse) Equal 

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

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 Series 

type Series struct {
	Labels []github_com_grafana_mimir_pkg_mimirpb.LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.LabelAdapter" json:"labels"`
	Chunks []AggrChunk                                         `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
}

func (*Series) Descriptor 

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

func (*Series) Equal 

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

func (*Series) GoString 

func (this *Series) GoString() string

func (*Series) Marshal 

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

func (*Series) MarshalTo 

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

func (*Series) MarshalToSizedBuffer 

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

func (*Series) ProtoMessage 

func (*Series) ProtoMessage()

func (*Series) Reset 

func (m *Series) Reset()

func (*Series) Size 

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

func (*Series) String 

func (this *Series) String() string

func (*Series) Unmarshal 

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

func (*Series) XXX_DiscardUnknown 

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal 

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

func (*Series) XXX_Merge 

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

func (*Series) XXX_Size 

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal 

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

type SeriesRequest 

type SeriesRequest struct {
	MinTime  int64          `protobuf:"varint,1,opt,name=min_time,json=minTime,proto3" json:"min_time,omitempty"`
	MaxTime  int64          `protobuf:"varint,2,opt,name=max_time,json=maxTime,proto3" json:"max_time,omitempty"`
	Matchers []LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers"`
	// skip_chunks controls whether sending chunks or not in series responses.
	SkipChunks bool `protobuf:"varint,8,opt,name=skip_chunks,json=skipChunks,proto3" json:"skip_chunks,omitempty"`
	// hints is an opaque data structure that can be used to carry additional information.
	// The content of this field and whether it's supported depends on the
	// implementation of a specific store.
	Hints *types.Any `protobuf:"bytes,9,opt,name=hints,proto3" json:"hints,omitempty"`
	// If streaming_chunks_batch_size=0, the response must only contain one 'series' at a time
	// with the series labels and chunks data sent together.
	// If streaming_chunks_batch_size > 0
	// - The store may choose to send the streaming_series/streaming_chunks OR behave as
	//   if streaming_chunks_batch_size=0 if it does not support streaming series.
	// - The store must not send a mix of 'series' and streaming_series/streaming_chunks for a single request.
	// - If the store chooses to send streaming series, all the streaming_series must be sent before
	//   sending any streaming_chunks, with the last streaming_series response containing is_end_of_series_stream=true.
	//   The order of series in both streaming_series/streaming_chunks must match and the size of the batch must not
	//   cross streaming_chunks_batch_size, although it can be lower than that.
	// The proto field ID is 100 so that we have an option to bring back compatibility with Thanos' storage API.
	StreamingChunksBatchSize uint64 `` /* 140-byte string literal not displayed */
}

func (*SeriesRequest) Descriptor 

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

func (*SeriesRequest) Equal 

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

func (*SeriesRequest) GoString 

func (this *SeriesRequest) GoString() string

func (*SeriesRequest) Marshal 

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

func (*SeriesRequest) MarshalTo 

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

func (*SeriesRequest) MarshalToSizedBuffer 

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

func (*SeriesRequest) ProtoMessage 

func (*SeriesRequest) ProtoMessage()

func (*SeriesRequest) Reset 

func (m *SeriesRequest) Reset()

func (*SeriesRequest) Size 

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

func (*SeriesRequest) String 

func (this *SeriesRequest) String() string

func (*SeriesRequest) Unmarshal 

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

func (*SeriesRequest) XXX_DiscardUnknown 

func (m *SeriesRequest) XXX_DiscardUnknown()

func (*SeriesRequest) XXX_Marshal 

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

func (*SeriesRequest) XXX_Merge 

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

func (*SeriesRequest) XXX_Size 

func (m *SeriesRequest) XXX_Size() int

func (*SeriesRequest) XXX_Unmarshal 

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

type SeriesResponse 

type SeriesResponse struct {
	// Types that are valid to be assigned to Result:
	//	*SeriesResponse_Series
	//	*SeriesResponse_Warning
	//	*SeriesResponse_Hints
	//	*SeriesResponse_Stats
	//	*SeriesResponse_StreamingSeries
	//	*SeriesResponse_StreamingChunks
	//	*SeriesResponse_StreamingChunksEstimate
	Result isSeriesResponse_Result `protobuf_oneof:"result"`
}

func NewHintsSeriesResponse 

func NewHintsSeriesResponse(hints *types.Any) *SeriesResponse

func NewSeriesResponse 

func NewSeriesResponse(series *Series) *SeriesResponse

func NewStatsResponse 

func NewStatsResponse(indexBytesFetched int) *SeriesResponse

func NewStreamingChunksEstimate 

func NewStreamingChunksEstimate(estimatedChunks uint64) *SeriesResponse

func NewStreamingChunksResponse 

func NewStreamingChunksResponse(series *StreamingChunksBatch) *SeriesResponse

func NewStreamingSeriesResponse 

func NewStreamingSeriesResponse(series *StreamingSeriesBatch) *SeriesResponse

func (*SeriesResponse) Descriptor 

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

func (*SeriesResponse) Equal 

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

func (*SeriesResponse) GetHints 

func (m *SeriesResponse) GetHints() *types.Any

func (*SeriesResponse) GetResult 

func (m *SeriesResponse) GetResult() isSeriesResponse_Result

func (*SeriesResponse) GetSeries 

func (m *SeriesResponse) GetSeries() *Series

func (*SeriesResponse) GetStats 

func (m *SeriesResponse) GetStats() *Stats

func (*SeriesResponse) GetStreamingChunks 

func (m *SeriesResponse) GetStreamingChunks() *StreamingChunksBatch

func (*SeriesResponse) GetStreamingChunksEstimate 

func (m *SeriesResponse) GetStreamingChunksEstimate() *StreamingChunksEstimate

func (*SeriesResponse) GetStreamingSeries 

func (m *SeriesResponse) GetStreamingSeries() *StreamingSeriesBatch

func (*SeriesResponse) GetWarning 

func (m *SeriesResponse) GetWarning() string

func (*SeriesResponse) GoString 

func (this *SeriesResponse) GoString() string

func (*SeriesResponse) Marshal 

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

func (*SeriesResponse) MarshalTo 

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

func (*SeriesResponse) MarshalToSizedBuffer 

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

func (*SeriesResponse) ProtoMessage 

func (*SeriesResponse) ProtoMessage()

func (*SeriesResponse) Reset 

func (m *SeriesResponse) Reset()

func (*SeriesResponse) Size 

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

func (*SeriesResponse) String 

func (this *SeriesResponse) String() string

func (*SeriesResponse) Unmarshal 

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

func (*SeriesResponse) XXX_DiscardUnknown 

func (m *SeriesResponse) XXX_DiscardUnknown()

func (*SeriesResponse) XXX_Marshal 

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

func (*SeriesResponse) XXX_Merge 

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

func (*SeriesResponse) XXX_OneofWrappers 

func (*SeriesResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SeriesResponse) XXX_Size 

func (m *SeriesResponse) XXX_Size() int

func (*SeriesResponse) XXX_Unmarshal 

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

type SeriesResponse_Hints 

type SeriesResponse_Hints struct {
	Hints *types.Any `protobuf:"bytes,3,opt,name=hints,proto3,oneof"`
}

func (*SeriesResponse_Hints) Equal 

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

func (*SeriesResponse_Hints) GoString 

func (this *SeriesResponse_Hints) GoString() string

func (*SeriesResponse_Hints) MarshalTo 

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

func (*SeriesResponse_Hints) MarshalToSizedBuffer 

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

func (*SeriesResponse_Hints) Size 

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

func (*SeriesResponse_Hints) String 

func (this *SeriesResponse_Hints) String() string

type SeriesResponse_Series 

type SeriesResponse_Series struct {
	Series *Series `protobuf:"bytes,1,opt,name=series,proto3,oneof"`
}

func (*SeriesResponse_Series) Equal 

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

func (*SeriesResponse_Series) GoString 

func (this *SeriesResponse_Series) GoString() string

func (*SeriesResponse_Series) MarshalTo 

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

func (*SeriesResponse_Series) MarshalToSizedBuffer 

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

func (*SeriesResponse_Series) Size 

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

func (*SeriesResponse_Series) String 

func (this *SeriesResponse_Series) String() string

type SeriesResponse_Stats 

type SeriesResponse_Stats struct {
	Stats *Stats `protobuf:"bytes,4,opt,name=stats,proto3,oneof"`
}

func (*SeriesResponse_Stats) Equal 

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

func (*SeriesResponse_Stats) GoString 

func (this *SeriesResponse_Stats) GoString() string

func (*SeriesResponse_Stats) MarshalTo 

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

func (*SeriesResponse_Stats) MarshalToSizedBuffer 

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

func (*SeriesResponse_Stats) Size 

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

func (*SeriesResponse_Stats) String 

func (this *SeriesResponse_Stats) String() string

type SeriesResponse_StreamingChunks 

type SeriesResponse_StreamingChunks struct {
	StreamingChunks *StreamingChunksBatch `protobuf:"bytes,6,opt,name=streaming_chunks,json=streamingChunks,proto3,oneof"`
}

func (*SeriesResponse_StreamingChunks) Equal 

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

func (*SeriesResponse_StreamingChunks) GoString 

func (this *SeriesResponse_StreamingChunks) GoString() string

func (*SeriesResponse_StreamingChunks) MarshalTo 

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

func (*SeriesResponse_StreamingChunks) MarshalToSizedBuffer 

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

func (*SeriesResponse_StreamingChunks) Size 

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

func (*SeriesResponse_StreamingChunks) String 

func (this *SeriesResponse_StreamingChunks) String() string

type SeriesResponse_StreamingChunksEstimate 

type SeriesResponse_StreamingChunksEstimate struct {
	StreamingChunksEstimate *StreamingChunksEstimate `protobuf:"bytes,7,opt,name=streaming_chunks_estimate,json=streamingChunksEstimate,proto3,oneof"`
}

func (*SeriesResponse_StreamingChunksEstimate) Equal 

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

func (*SeriesResponse_StreamingChunksEstimate) GoString 

func (this *SeriesResponse_StreamingChunksEstimate) GoString() string

func (*SeriesResponse_StreamingChunksEstimate) MarshalTo 

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

func (*SeriesResponse_StreamingChunksEstimate) MarshalToSizedBuffer 

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

func (*SeriesResponse_StreamingChunksEstimate) Size 

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

func (*SeriesResponse_StreamingChunksEstimate) String 

func (this *SeriesResponse_StreamingChunksEstimate) String() string

type SeriesResponse_StreamingSeries 

type SeriesResponse_StreamingSeries struct {
	StreamingSeries *StreamingSeriesBatch `protobuf:"bytes,5,opt,name=streaming_series,json=streamingSeries,proto3,oneof"`
}

func (*SeriesResponse_StreamingSeries) Equal 

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

func (*SeriesResponse_StreamingSeries) GoString 

func (this *SeriesResponse_StreamingSeries) GoString() string

func (*SeriesResponse_StreamingSeries) MarshalTo 

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

func (*SeriesResponse_StreamingSeries) MarshalToSizedBuffer 

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

func (*SeriesResponse_StreamingSeries) Size 

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

func (*SeriesResponse_StreamingSeries) String 

func (this *SeriesResponse_StreamingSeries) String() string

type SeriesResponse_Warning 

type SeriesResponse_Warning struct {
	Warning string `protobuf:"bytes,2,opt,name=warning,proto3,oneof"`
}

func (*SeriesResponse_Warning) Equal 

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

func (*SeriesResponse_Warning) GoString 

func (this *SeriesResponse_Warning) GoString() string

func (*SeriesResponse_Warning) MarshalTo 

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

func (*SeriesResponse_Warning) MarshalToSizedBuffer 

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

func (*SeriesResponse_Warning) Size 

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

func (*SeriesResponse_Warning) String 

func (this *SeriesResponse_Warning) String() string

type SeriesSet 

type SeriesSet interface {
	Next() bool
	At() (labels.Labels, []AggrChunk)
	Err() error
}

SeriesSet is a set of series and their corresponding chunks. The set is sorted by the label sets. Chunks may be overlapping or expected of order.

func EmptySeriesSet 

func EmptySeriesSet() SeriesSet

EmptySeriesSet returns a new series set that contains no series.

type Stats 

type Stats struct {
	// This is the sum of all fetched index bytes (postings + series) for a series request.
	FetchedIndexBytes uint64 `protobuf:"varint,1,opt,name=fetched_index_bytes,json=fetchedIndexBytes,proto3" json:"fetched_index_bytes,omitempty"`
}

func (*Stats) Descriptor 

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

func (*Stats) Equal 

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

func (*Stats) GoString 

func (this *Stats) GoString() string

func (*Stats) Marshal 

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

func (*Stats) MarshalTo 

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

func (*Stats) MarshalToSizedBuffer 

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

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) Reset 

func (m *Stats) Reset()

func (*Stats) Size 

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

func (*Stats) String 

func (this *Stats) String() string

func (*Stats) Unmarshal 

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

func (*Stats) XXX_DiscardUnknown 

func (m *Stats) XXX_DiscardUnknown()

func (*Stats) XXX_Marshal 

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

func (*Stats) XXX_Merge 

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

func (*Stats) XXX_Size 

func (m *Stats) XXX_Size() int

func (*Stats) XXX_Unmarshal 

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

type StreamingChunks 

type StreamingChunks struct {
	SeriesIndex uint64      `protobuf:"varint,1,opt,name=series_index,json=seriesIndex,proto3" json:"series_index,omitempty"`
	Chunks      []AggrChunk `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
}

func (*StreamingChunks) Descriptor 

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

func (*StreamingChunks) Equal 

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

func (*StreamingChunks) GoString 

func (this *StreamingChunks) GoString() string

func (*StreamingChunks) Marshal 

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

func (*StreamingChunks) MarshalTo 

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

func (*StreamingChunks) MarshalToSizedBuffer 

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

func (*StreamingChunks) ProtoMessage 

func (*StreamingChunks) ProtoMessage()

func (*StreamingChunks) Reset 

func (m *StreamingChunks) Reset()

func (*StreamingChunks) Size 

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

func (*StreamingChunks) String 

func (this *StreamingChunks) String() string

func (*StreamingChunks) Unmarshal 

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

func (*StreamingChunks) XXX_DiscardUnknown 

func (m *StreamingChunks) XXX_DiscardUnknown()

func (*StreamingChunks) XXX_Marshal 

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

func (*StreamingChunks) XXX_Merge 

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

func (*StreamingChunks) XXX_Size 

func (m *StreamingChunks) XXX_Size() int

func (*StreamingChunks) XXX_Unmarshal 

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

type StreamingChunksBatch 

type StreamingChunksBatch struct {
	Series []*StreamingChunks `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
}

func (*StreamingChunksBatch) Descriptor 

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

func (*StreamingChunksBatch) Equal 

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

func (*StreamingChunksBatch) GoString 

func (this *StreamingChunksBatch) GoString() string

func (*StreamingChunksBatch) Marshal 

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

func (*StreamingChunksBatch) MarshalTo 

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

func (*StreamingChunksBatch) MarshalToSizedBuffer 

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

func (*StreamingChunksBatch) ProtoMessage 

func (*StreamingChunksBatch) ProtoMessage()

func (*StreamingChunksBatch) Reset 

func (m *StreamingChunksBatch) Reset()

func (*StreamingChunksBatch) Size 

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

func (*StreamingChunksBatch) String 

func (this *StreamingChunksBatch) String() string

func (*StreamingChunksBatch) Unmarshal 

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

func (*StreamingChunksBatch) XXX_DiscardUnknown 

func (m *StreamingChunksBatch) XXX_DiscardUnknown()

func (*StreamingChunksBatch) XXX_Marshal 

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

func (*StreamingChunksBatch) XXX_Merge 

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

func (*StreamingChunksBatch) XXX_Size 

func (m *StreamingChunksBatch) XXX_Size() int

func (*StreamingChunksBatch) XXX_Unmarshal 

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

type StreamingChunksEstimate 

type StreamingChunksEstimate struct {
	EstimatedChunkCount uint64 `protobuf:"varint,1,opt,name=estimated_chunk_count,json=estimatedChunkCount,proto3" json:"estimated_chunk_count,omitempty"`
}

func (*StreamingChunksEstimate) Descriptor 

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

func (*StreamingChunksEstimate) Equal 

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

func (*StreamingChunksEstimate) GoString 

func (this *StreamingChunksEstimate) GoString() string

func (*StreamingChunksEstimate) Marshal 

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

func (*StreamingChunksEstimate) MarshalTo 

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

func (*StreamingChunksEstimate) MarshalToSizedBuffer 

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

func (*StreamingChunksEstimate) ProtoMessage 

func (*StreamingChunksEstimate) ProtoMessage()

func (*StreamingChunksEstimate) Reset 

func (m *StreamingChunksEstimate) Reset()

func (*StreamingChunksEstimate) Size 

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

func (*StreamingChunksEstimate) String 

func (this *StreamingChunksEstimate) String() string

func (*StreamingChunksEstimate) Unmarshal 

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

func (*StreamingChunksEstimate) XXX_DiscardUnknown 

func (m *StreamingChunksEstimate) XXX_DiscardUnknown()

func (*StreamingChunksEstimate) XXX_Marshal 

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

func (*StreamingChunksEstimate) XXX_Merge 

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

func (*StreamingChunksEstimate) XXX_Size 

func (m *StreamingChunksEstimate) XXX_Size() int

func (*StreamingChunksEstimate) XXX_Unmarshal 

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

type StreamingSeries 

type StreamingSeries struct {
	Labels []github_com_grafana_mimir_pkg_mimirpb.LabelAdapter `protobuf:"bytes,1,rep,name=labels,proto3,customtype=github.com/grafana/mimir/pkg/mimirpb.LabelAdapter" json:"labels"`
}

func (*StreamingSeries) Descriptor 

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

func (*StreamingSeries) Equal 

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

func (*StreamingSeries) GoString 

func (this *StreamingSeries) GoString() string

func (*StreamingSeries) Marshal 

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

func (*StreamingSeries) MarshalTo 

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

func (*StreamingSeries) MarshalToSizedBuffer 

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

func (*StreamingSeries) ProtoMessage 

func (*StreamingSeries) ProtoMessage()

func (*StreamingSeries) Reset 

func (m *StreamingSeries) Reset()

func (*StreamingSeries) Size 

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

func (*StreamingSeries) String 

func (this *StreamingSeries) String() string

func (*StreamingSeries) Unmarshal 

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

func (*StreamingSeries) XXX_DiscardUnknown 

func (m *StreamingSeries) XXX_DiscardUnknown()

func (*StreamingSeries) XXX_Marshal 

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

func (*StreamingSeries) XXX_Merge 

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

func (*StreamingSeries) XXX_Size 

func (m *StreamingSeries) XXX_Size() int

func (*StreamingSeries) XXX_Unmarshal 

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

type StreamingSeriesBatch 

type StreamingSeriesBatch struct {
	Series              []*StreamingSeries `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	IsEndOfSeriesStream bool               `protobuf:"varint,2,opt,name=is_end_of_series_stream,json=isEndOfSeriesStream,proto3" json:"is_end_of_series_stream,omitempty"`
}

func (*StreamingSeriesBatch) Descriptor 

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

func (*StreamingSeriesBatch) Equal 

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

func (*StreamingSeriesBatch) GoString 

func (this *StreamingSeriesBatch) GoString() string

func (*StreamingSeriesBatch) Marshal 

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

func (*StreamingSeriesBatch) MarshalTo 

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

func (*StreamingSeriesBatch) MarshalToSizedBuffer 

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

func (*StreamingSeriesBatch) ProtoMessage 

func (*StreamingSeriesBatch) ProtoMessage()

func (*StreamingSeriesBatch) Reset 

func (m *StreamingSeriesBatch) Reset()

func (*StreamingSeriesBatch) Size 

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

func (*StreamingSeriesBatch) String 

func (this *StreamingSeriesBatch) String() string

func (*StreamingSeriesBatch) Unmarshal 

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

func (*StreamingSeriesBatch) XXX_DiscardUnknown 

func (m *StreamingSeriesBatch) XXX_DiscardUnknown()

func (*StreamingSeriesBatch) XXX_Marshal 

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

func (*StreamingSeriesBatch) XXX_Merge 

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

func (*StreamingSeriesBatch) XXX_Size 

func (m *StreamingSeriesBatch) XXX_Size() int

func (*StreamingSeriesBatch) XXX_Unmarshal 

func (m *StreamingSeriesBatch) 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.