prompb

package
v2.13.1 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

README

The compiled protobufs are version controlled and you won't normally need to re-compile them when building Prometheus.

If however you have modified the defs and do need to re-compile, run make proto from the parent dir.

In order for the script to run, you'll need protoc (version 3.5.1) in your PATH.

Documentation

Overview

Package prompb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRemote = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRemote   = 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: "UNKNOWN",
	1: "XOR",
}
View Source 
var Chunk_Encoding_value = map[string]int32{
	"UNKNOWN": 0,
	"XOR":     1,
}
View Source 
var LabelMatcher_Type_name = map[int32]string{
	0: "EQ",
	1: "NEQ",
	2: "RE",
	3: "NRE",
}
View Source 
var LabelMatcher_Type_value = map[string]int32{
	"EQ":  0,
	"NEQ": 1,
	"RE":  2,
	"NRE": 3,
}
View Source 
var ReadRequest_ResponseType_name = map[int32]string{
	0: "SAMPLES",
	1: "STREAMED_XOR_CHUNKS",
}
View Source 
var ReadRequest_ResponseType_value = map[string]int32{
	"SAMPLES":             0,
	"STREAMED_XOR_CHUNKS": 1,
}

Functions

func RegisterAdminHandler 

func RegisterAdminHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAdminHandler registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAdminHandlerClient 

func RegisterAdminHandlerClient(ctx context.Context, mux *runtime.ServeMux, client AdminClient) error

RegisterAdminHandlerClient registers the http handlers for service Admin to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "AdminClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "AdminClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "AdminClient" to call the correct interceptors.

func RegisterAdminHandlerFromEndpoint 

func RegisterAdminHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAdminHandlerFromEndpoint is same as RegisterAdminHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAdminServer 

func RegisterAdminServer(s *grpc.Server, srv AdminServer)

Types

type AdminClient 

type AdminClient interface {
	// Snapshot creates a snapshot of all current data into 'snapshots/<datetime>-<rand>' under the TSDB's data directory.
	TSDBSnapshot(ctx context.Context, in *TSDBSnapshotRequest, opts ...grpc.CallOption) (*TSDBSnapshotResponse, error)
	// CleanTombstones removes the deleted data from disk and cleans up the existing tombstones.
	TSDBCleanTombstones(ctx context.Context, in *TSDBCleanTombstonesRequest, opts ...grpc.CallOption) (*TSDBCleanTombstonesResponse, error)
	// DeleteSeries deletes data for a selection of series in a time range.
	DeleteSeries(ctx context.Context, in *SeriesDeleteRequest, opts ...grpc.CallOption) (*SeriesDeleteResponse, error)
}

AdminClient is the client API for Admin service.

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

func NewAdminClient 

func NewAdminClient(cc *grpc.ClientConn) AdminClient

type AdminServer 

type AdminServer interface {
	// Snapshot creates a snapshot of all current data into 'snapshots/<datetime>-<rand>' under the TSDB's data directory.
	TSDBSnapshot(context.Context, *TSDBSnapshotRequest) (*TSDBSnapshotResponse, error)
	// CleanTombstones removes the deleted data from disk and cleans up the existing tombstones.
	TSDBCleanTombstones(context.Context, *TSDBCleanTombstonesRequest) (*TSDBCleanTombstonesResponse, error)
	// DeleteSeries deletes data for a selection of series in a time range.
	DeleteSeries(context.Context, *SeriesDeleteRequest) (*SeriesDeleteResponse, error)
}

AdminServer is the server API for Admin service.

type Chunk 

type Chunk struct {
	MinTimeMs            int64          `protobuf:"varint,1,opt,name=min_time_ms,json=minTimeMs,proto3" json:"min_time_ms,omitempty"`
	MaxTimeMs            int64          `protobuf:"varint,2,opt,name=max_time_ms,json=maxTimeMs,proto3" json:"max_time_ms,omitempty"`
	Type                 Chunk_Encoding `protobuf:"varint,3,opt,name=type,proto3,enum=prometheus.Chunk_Encoding" json:"type,omitempty"`
	Data                 []byte         `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Chunk represents a TSDB chunk. Time range [min, max] is inclusive.

func (*Chunk) Descriptor 

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

func (*Chunk) GetData 

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

func (*Chunk) GetMaxTimeMs 

func (m *Chunk) GetMaxTimeMs() int64

func (*Chunk) GetMinTimeMs 

func (m *Chunk) GetMinTimeMs() int64

func (*Chunk) GetType 

func (m *Chunk) GetType() Chunk_Encoding

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 (m *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

We require this to match chunkenc.Encoding. 

const (
	Chunk_UNKNOWN Chunk_Encoding = 0
	Chunk_XOR     Chunk_Encoding = 1
)

func (Chunk_Encoding) EnumDescriptor 

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

func (Chunk_Encoding) String 

func (x Chunk_Encoding) String() string

type ChunkedReadResponse 

type ChunkedReadResponse struct {
	ChunkedSeries []*ChunkedSeries `protobuf:"bytes,1,rep,name=chunked_series,json=chunkedSeries,proto3" json:"chunked_series,omitempty"`
	// query_index represents an index of the query from ReadRequest.queries these chunks relates to.
	QueryIndex           int64    `protobuf:"varint,2,opt,name=query_index,json=queryIndex,proto3" json:"query_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChunkedReadResponse is a response when response_type equals STREAMED_XOR_CHUNKS. We strictly stream full series after series, optionally split by time. This means that a single frame can contain partition of the single series, but once a new series is started to be streamed it means that no more chunks will be sent for previous one.

func (*ChunkedReadResponse) Descriptor 

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

func (*ChunkedReadResponse) GetChunkedSeries 

func (m *ChunkedReadResponse) GetChunkedSeries() []*ChunkedSeries

func (*ChunkedReadResponse) GetQueryIndex 

func (m *ChunkedReadResponse) GetQueryIndex() int64

func (*ChunkedReadResponse) Marshal 

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

func (*ChunkedReadResponse) MarshalTo 

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

func (*ChunkedReadResponse) MarshalToSizedBuffer 

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

func (*ChunkedReadResponse) ProtoMessage 

func (*ChunkedReadResponse) ProtoMessage()

func (*ChunkedReadResponse) Reset 

func (m *ChunkedReadResponse) Reset()

func (*ChunkedReadResponse) Size 

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

func (*ChunkedReadResponse) String 

func (m *ChunkedReadResponse) String() string

func (*ChunkedReadResponse) Unmarshal 

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

func (*ChunkedReadResponse) XXX_DiscardUnknown 

func (m *ChunkedReadResponse) XXX_DiscardUnknown()

func (*ChunkedReadResponse) XXX_Marshal 

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

func (*ChunkedReadResponse) XXX_Merge 

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

func (*ChunkedReadResponse) XXX_Size 

func (m *ChunkedReadResponse) XXX_Size() int

func (*ChunkedReadResponse) XXX_Unmarshal 

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

type ChunkedSeries 

type ChunkedSeries struct {
	// Labels should be sorted.
	Labels []Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	// Chunks will be in start time order and may overlap.
	Chunks               []Chunk  `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ChunkedSeries represents single, encoded time series.

func (*ChunkedSeries) Descriptor 

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

func (*ChunkedSeries) GetChunks 

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

func (*ChunkedSeries) GetLabels 

func (m *ChunkedSeries) GetLabels() []Label

func (*ChunkedSeries) Marshal 

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

func (*ChunkedSeries) MarshalTo 

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

func (*ChunkedSeries) MarshalToSizedBuffer 

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

func (*ChunkedSeries) ProtoMessage 

func (*ChunkedSeries) ProtoMessage()

func (*ChunkedSeries) Reset 

func (m *ChunkedSeries) Reset()

func (*ChunkedSeries) Size 

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

func (*ChunkedSeries) String 

func (m *ChunkedSeries) String() string

func (*ChunkedSeries) Unmarshal 

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

func (*ChunkedSeries) XXX_DiscardUnknown 

func (m *ChunkedSeries) XXX_DiscardUnknown()

func (*ChunkedSeries) XXX_Marshal 

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

func (*ChunkedSeries) XXX_Merge 

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

func (*ChunkedSeries) XXX_Size 

func (m *ChunkedSeries) XXX_Size() int

func (*ChunkedSeries) XXX_Unmarshal 

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

type Label 

type Label 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Label) Descriptor 

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

func (*Label) GetName 

func (m *Label) GetName() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) Marshal 

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

func (*Label) MarshalTo 

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

func (*Label) MarshalToSizedBuffer 

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

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

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

func (*Label) String 

func (m *Label) String() string

func (*Label) Unmarshal 

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

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

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

func (*Label) XXX_Merge 

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

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

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

type LabelMatcher 

type LabelMatcher struct {
	Type                 LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=prometheus.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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*LabelMatcher) Descriptor 

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

func (*LabelMatcher) GetName 

func (m *LabelMatcher) GetName() string

func (*LabelMatcher) GetType 

func (m *LabelMatcher) GetType() LabelMatcher_Type

func (*LabelMatcher) GetValue 

func (m *LabelMatcher) GetValue() 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 (m *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 Labels 

type Labels struct {
	Labels               []Label  `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Labels) Descriptor 

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

func (*Labels) GetLabels 

func (m *Labels) GetLabels() []Label

func (*Labels) Marshal 

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

func (*Labels) MarshalTo 

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

func (*Labels) MarshalToSizedBuffer 

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

func (*Labels) ProtoMessage 

func (*Labels) ProtoMessage()

func (*Labels) Reset 

func (m *Labels) Reset()

func (*Labels) Size 

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

func (*Labels) String 

func (m *Labels) String() string

func (*Labels) Unmarshal 

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

func (*Labels) XXX_DiscardUnknown 

func (m *Labels) XXX_DiscardUnknown()

func (*Labels) XXX_Marshal 

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

func (*Labels) XXX_Merge 

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

func (*Labels) XXX_Size 

func (m *Labels) XXX_Size() int

func (*Labels) XXX_Unmarshal 

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

type Query 

type Query struct {
	StartTimestampMs     int64           `protobuf:"varint,1,opt,name=start_timestamp_ms,json=startTimestampMs,proto3" json:"start_timestamp_ms,omitempty"`
	EndTimestampMs       int64           `protobuf:"varint,2,opt,name=end_timestamp_ms,json=endTimestampMs,proto3" json:"end_timestamp_ms,omitempty"`
	Matchers             []*LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
	Hints                *ReadHints      `protobuf:"bytes,4,opt,name=hints,proto3" json:"hints,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetEndTimestampMs 

func (m *Query) GetEndTimestampMs() int64

func (*Query) GetHints 

func (m *Query) GetHints() *ReadHints

func (*Query) GetMatchers 

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

func (*Query) GetStartTimestampMs 

func (m *Query) GetStartTimestampMs() int64

func (*Query) Marshal 

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

func (*Query) MarshalTo 

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

func (*Query) MarshalToSizedBuffer 

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

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) Size 

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

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal 

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

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

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

func (*Query) XXX_Merge 

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

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

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

type QueryResult 

type QueryResult struct {
	// Samples within a time series must be ordered by time.
	Timeseries           []*TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*QueryResult) Descriptor 

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

func (*QueryResult) GetTimeseries 

func (m *QueryResult) GetTimeseries() []*TimeSeries

func (*QueryResult) Marshal 

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

func (*QueryResult) MarshalTo 

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

func (*QueryResult) MarshalToSizedBuffer 

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

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset 

func (m *QueryResult) Reset()

func (*QueryResult) Size 

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

func (*QueryResult) String 

func (m *QueryResult) String() string

func (*QueryResult) Unmarshal 

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

func (*QueryResult) XXX_DiscardUnknown 

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal 

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

func (*QueryResult) XXX_Merge 

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

func (*QueryResult) XXX_Size 

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal 

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

type ReadHints 

type ReadHints struct {
	StepMs               int64    `protobuf:"varint,1,opt,name=step_ms,json=stepMs,proto3" json:"step_ms,omitempty"`
	Func                 string   `protobuf:"bytes,2,opt,name=func,proto3" json:"func,omitempty"`
	StartMs              int64    `protobuf:"varint,3,opt,name=start_ms,json=startMs,proto3" json:"start_ms,omitempty"`
	EndMs                int64    `protobuf:"varint,4,opt,name=end_ms,json=endMs,proto3" json:"end_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadHints) Descriptor 

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

func (*ReadHints) GetEndMs 

func (m *ReadHints) GetEndMs() int64

func (*ReadHints) GetFunc 

func (m *ReadHints) GetFunc() string

func (*ReadHints) GetStartMs 

func (m *ReadHints) GetStartMs() int64

func (*ReadHints) GetStepMs 

func (m *ReadHints) GetStepMs() int64

func (*ReadHints) Marshal 

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

func (*ReadHints) MarshalTo 

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

func (*ReadHints) MarshalToSizedBuffer 

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

func (*ReadHints) ProtoMessage 

func (*ReadHints) ProtoMessage()

func (*ReadHints) Reset 

func (m *ReadHints) Reset()

func (*ReadHints) Size 

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

func (*ReadHints) String 

func (m *ReadHints) String() string

func (*ReadHints) Unmarshal 

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

func (*ReadHints) XXX_DiscardUnknown 

func (m *ReadHints) XXX_DiscardUnknown()

func (*ReadHints) XXX_Marshal 

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

func (*ReadHints) XXX_Merge 

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

func (*ReadHints) XXX_Size 

func (m *ReadHints) XXX_Size() int

func (*ReadHints) XXX_Unmarshal 

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

type ReadRequest 

type ReadRequest struct {
	Queries []*Query `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
	// accepted_response_types allows negotiating the content type of the response.
	//
	// Response types are taken from the list in the FIFO order. If no response type in `accepted_response_types` is
	// implemented by server, error is returned.
	// For request that do not contain `accepted_response_types` field the SAMPLES response type will be used.
	AcceptedResponseTypes []ReadRequest_ResponseType `` /* 175-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{}                   `json:"-"`
	XXX_unrecognized      []byte                     `json:"-"`
	XXX_sizecache         int32                      `json:"-"`
}

ReadRequest represents a remote read request.

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetAcceptedResponseTypes 

func (m *ReadRequest) GetAcceptedResponseTypes() []ReadRequest_ResponseType

func (*ReadRequest) GetQueries 

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

func (*ReadRequest) Marshal 

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

func (*ReadRequest) MarshalTo 

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

func (*ReadRequest) MarshalToSizedBuffer 

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

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) Size 

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

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) Unmarshal 

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

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

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

func (*ReadRequest) XXX_Merge 

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

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

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

type ReadRequest_ResponseType 

type ReadRequest_ResponseType int32
const (
	// Server will return a single ReadResponse message with matched series that includes list of raw samples.
	// It's recommended to use streamed response types instead.
	//
	// Response headers:
	// Content-Type: "application/x-protobuf"
	// Content-Encoding: "snappy"
	ReadRequest_SAMPLES ReadRequest_ResponseType = 0
	// Server will stream a delimited ChunkedReadResponse message that contains XOR encoded chunks for a single series.
	// Each message is following varint size and fixed size bigendian uint32 for CRC32 Castagnoli checksum.
	//
	// Response headers:
	// Content-Type: "application/x-streamed-protobuf; proto=prometheus.ChunkedReadResponse"
	// Content-Encoding: ""
	ReadRequest_STREAMED_XOR_CHUNKS ReadRequest_ResponseType = 1
)

func (ReadRequest_ResponseType) EnumDescriptor 

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

func (ReadRequest_ResponseType) String 

func (x ReadRequest_ResponseType) String() string

type ReadResponse 

type ReadResponse struct {
	// In same order as the request's queries.
	Results              []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

ReadResponse is a response when response_type equals SAMPLES.

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetResults 

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

func (*ReadResponse) Marshal 

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

func (*ReadResponse) MarshalTo 

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

func (*ReadResponse) MarshalToSizedBuffer 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) Size 

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

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal 

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

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

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

func (*ReadResponse) XXX_Merge 

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

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

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

type Sample 

type Sample struct {
	Value                float64  `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Sample) Descriptor 

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

func (*Sample) GetTimestamp 

func (m *Sample) GetTimestamp() int64

func (*Sample) GetValue 

func (m *Sample) GetValue() float64

func (*Sample) Marshal 

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

func (*Sample) MarshalTo 

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

func (*Sample) MarshalToSizedBuffer 

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

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) Reset 

func (m *Sample) Reset()

func (*Sample) Size 

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

func (*Sample) String 

func (m *Sample) String() string

func (*Sample) Unmarshal 

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

func (*Sample) XXX_DiscardUnknown 

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal 

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

func (*Sample) XXX_Merge 

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

func (*Sample) XXX_Size 

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal 

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

type SeriesDeleteRequest 

type SeriesDeleteRequest struct {
	MinTime              *time.Time     `protobuf:"bytes,1,opt,name=min_time,json=minTime,proto3,stdtime" json:"min_time,omitempty"`
	MaxTime              *time.Time     `protobuf:"bytes,2,opt,name=max_time,json=maxTime,proto3,stdtime" json:"max_time,omitempty"`
	Matchers             []LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SeriesDeleteRequest) Descriptor 

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

func (*SeriesDeleteRequest) Marshal 

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

func (*SeriesDeleteRequest) MarshalTo 

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

func (*SeriesDeleteRequest) MarshalToSizedBuffer 

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

func (*SeriesDeleteRequest) ProtoMessage 

func (*SeriesDeleteRequest) ProtoMessage()

func (*SeriesDeleteRequest) Reset 

func (m *SeriesDeleteRequest) Reset()

func (*SeriesDeleteRequest) Size 

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

func (*SeriesDeleteRequest) String 

func (m *SeriesDeleteRequest) String() string

func (*SeriesDeleteRequest) Unmarshal 

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

func (*SeriesDeleteRequest) XXX_DiscardUnknown 

func (m *SeriesDeleteRequest) XXX_DiscardUnknown()

func (*SeriesDeleteRequest) XXX_Marshal 

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

func (*SeriesDeleteRequest) XXX_Merge 

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

func (*SeriesDeleteRequest) XXX_Size 

func (m *SeriesDeleteRequest) XXX_Size() int

func (*SeriesDeleteRequest) XXX_Unmarshal 

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

type SeriesDeleteResponse 

type SeriesDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SeriesDeleteResponse) Descriptor 

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

func (*SeriesDeleteResponse) Marshal 

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

func (*SeriesDeleteResponse) MarshalTo 

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

func (*SeriesDeleteResponse) MarshalToSizedBuffer 

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

func (*SeriesDeleteResponse) ProtoMessage 

func (*SeriesDeleteResponse) ProtoMessage()

func (*SeriesDeleteResponse) Reset 

func (m *SeriesDeleteResponse) Reset()

func (*SeriesDeleteResponse) Size 

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

func (*SeriesDeleteResponse) String 

func (m *SeriesDeleteResponse) String() string

func (*SeriesDeleteResponse) Unmarshal 

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

func (*SeriesDeleteResponse) XXX_DiscardUnknown 

func (m *SeriesDeleteResponse) XXX_DiscardUnknown()

func (*SeriesDeleteResponse) XXX_Marshal 

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

func (*SeriesDeleteResponse) XXX_Merge 

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

func (*SeriesDeleteResponse) XXX_Size 

func (m *SeriesDeleteResponse) XXX_Size() int

func (*SeriesDeleteResponse) XXX_Unmarshal 

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

type TSDBCleanTombstonesRequest 

type TSDBCleanTombstonesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TSDBCleanTombstonesRequest) Descriptor 

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

func (*TSDBCleanTombstonesRequest) Marshal 

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

func (*TSDBCleanTombstonesRequest) MarshalTo 

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

func (*TSDBCleanTombstonesRequest) MarshalToSizedBuffer 

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

func (*TSDBCleanTombstonesRequest) ProtoMessage 

func (*TSDBCleanTombstonesRequest) ProtoMessage()

func (*TSDBCleanTombstonesRequest) Reset 

func (m *TSDBCleanTombstonesRequest) Reset()

func (*TSDBCleanTombstonesRequest) Size 

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

func (*TSDBCleanTombstonesRequest) String 

func (m *TSDBCleanTombstonesRequest) String() string

func (*TSDBCleanTombstonesRequest) Unmarshal 

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

func (*TSDBCleanTombstonesRequest) XXX_DiscardUnknown 

func (m *TSDBCleanTombstonesRequest) XXX_DiscardUnknown()

func (*TSDBCleanTombstonesRequest) XXX_Marshal 

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

func (*TSDBCleanTombstonesRequest) XXX_Merge 

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

func (*TSDBCleanTombstonesRequest) XXX_Size 

func (m *TSDBCleanTombstonesRequest) XXX_Size() int

func (*TSDBCleanTombstonesRequest) XXX_Unmarshal 

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

type TSDBCleanTombstonesResponse 

type TSDBCleanTombstonesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TSDBCleanTombstonesResponse) Descriptor 

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

func (*TSDBCleanTombstonesResponse) Marshal 

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

func (*TSDBCleanTombstonesResponse) MarshalTo 

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

func (*TSDBCleanTombstonesResponse) MarshalToSizedBuffer 

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

func (*TSDBCleanTombstonesResponse) ProtoMessage 

func (*TSDBCleanTombstonesResponse) ProtoMessage()

func (*TSDBCleanTombstonesResponse) Reset 

func (m *TSDBCleanTombstonesResponse) Reset()

func (*TSDBCleanTombstonesResponse) Size 

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

func (*TSDBCleanTombstonesResponse) String 

func (m *TSDBCleanTombstonesResponse) String() string

func (*TSDBCleanTombstonesResponse) Unmarshal 

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

func (*TSDBCleanTombstonesResponse) XXX_DiscardUnknown 

func (m *TSDBCleanTombstonesResponse) XXX_DiscardUnknown()

func (*TSDBCleanTombstonesResponse) XXX_Marshal 

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

func (*TSDBCleanTombstonesResponse) XXX_Merge 

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

func (*TSDBCleanTombstonesResponse) XXX_Size 

func (m *TSDBCleanTombstonesResponse) XXX_Size() int

func (*TSDBCleanTombstonesResponse) XXX_Unmarshal 

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

type TSDBSnapshotRequest 

type TSDBSnapshotRequest struct {
	SkipHead             bool     `protobuf:"varint,1,opt,name=skip_head,json=skipHead,proto3" json:"skip_head,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TSDBSnapshotRequest) Descriptor 

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

func (*TSDBSnapshotRequest) Marshal 

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

func (*TSDBSnapshotRequest) MarshalTo 

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

func (*TSDBSnapshotRequest) MarshalToSizedBuffer 

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

func (*TSDBSnapshotRequest) ProtoMessage 

func (*TSDBSnapshotRequest) ProtoMessage()

func (*TSDBSnapshotRequest) Reset 

func (m *TSDBSnapshotRequest) Reset()

func (*TSDBSnapshotRequest) Size 

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

func (*TSDBSnapshotRequest) String 

func (m *TSDBSnapshotRequest) String() string

func (*TSDBSnapshotRequest) Unmarshal 

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

func (*TSDBSnapshotRequest) XXX_DiscardUnknown 

func (m *TSDBSnapshotRequest) XXX_DiscardUnknown()

func (*TSDBSnapshotRequest) XXX_Marshal 

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

func (*TSDBSnapshotRequest) XXX_Merge 

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

func (*TSDBSnapshotRequest) XXX_Size 

func (m *TSDBSnapshotRequest) XXX_Size() int

func (*TSDBSnapshotRequest) XXX_Unmarshal 

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

type TSDBSnapshotResponse 

type TSDBSnapshotResponse struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TSDBSnapshotResponse) Descriptor 

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

func (*TSDBSnapshotResponse) Marshal 

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

func (*TSDBSnapshotResponse) MarshalTo 

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

func (*TSDBSnapshotResponse) MarshalToSizedBuffer 

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

func (*TSDBSnapshotResponse) ProtoMessage 

func (*TSDBSnapshotResponse) ProtoMessage()

func (*TSDBSnapshotResponse) Reset 

func (m *TSDBSnapshotResponse) Reset()

func (*TSDBSnapshotResponse) Size 

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

func (*TSDBSnapshotResponse) String 

func (m *TSDBSnapshotResponse) String() string

func (*TSDBSnapshotResponse) Unmarshal 

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

func (*TSDBSnapshotResponse) XXX_DiscardUnknown 

func (m *TSDBSnapshotResponse) XXX_DiscardUnknown()

func (*TSDBSnapshotResponse) XXX_Marshal 

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

func (*TSDBSnapshotResponse) XXX_Merge 

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

func (*TSDBSnapshotResponse) XXX_Size 

func (m *TSDBSnapshotResponse) XXX_Size() int

func (*TSDBSnapshotResponse) XXX_Unmarshal 

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

type TimeSeries 

type TimeSeries struct {
	Labels               []Label  `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	Samples              []Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TimeSeries represents samples and labels for a single time series.

func (*TimeSeries) Descriptor 

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

func (*TimeSeries) GetLabels 

func (m *TimeSeries) GetLabels() []Label

func (*TimeSeries) GetSamples 

func (m *TimeSeries) GetSamples() []Sample

func (*TimeSeries) Marshal 

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

func (*TimeSeries) MarshalTo 

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

func (*TimeSeries) MarshalToSizedBuffer 

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

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) Reset 

func (m *TimeSeries) Reset()

func (*TimeSeries) Size 

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

func (*TimeSeries) String 

func (m *TimeSeries) String() string

func (*TimeSeries) Unmarshal 

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

func (*TimeSeries) XXX_DiscardUnknown 

func (m *TimeSeries) XXX_DiscardUnknown()

func (*TimeSeries) XXX_Marshal 

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

func (*TimeSeries) XXX_Merge 

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

func (*TimeSeries) XXX_Size 

func (m *TimeSeries) XXX_Size() int

func (*TimeSeries) XXX_Unmarshal 

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

type UnimplementedAdminServer 

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServer) DeleteSeries 

func (*UnimplementedAdminServer) DeleteSeries(ctx context.Context, req *SeriesDeleteRequest) (*SeriesDeleteResponse, error)

func (*UnimplementedAdminServer) TSDBCleanTombstones 

func (*UnimplementedAdminServer) TSDBCleanTombstones(ctx context.Context, req *TSDBCleanTombstonesRequest) (*TSDBCleanTombstonesResponse, error)

func (*UnimplementedAdminServer) TSDBSnapshot 

func (*UnimplementedAdminServer) TSDBSnapshot(ctx context.Context, req *TSDBSnapshotRequest) (*TSDBSnapshotResponse, error)

type WriteRequest 

type WriteRequest struct {
	Timeseries           []TimeSeries `protobuf:"bytes,1,rep,name=timeseries,proto3" json:"timeseries"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetTimeseries 

func (m *WriteRequest) GetTimeseries() []TimeSeries

func (*WriteRequest) Marshal 

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

func (*WriteRequest) MarshalTo 

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

func (*WriteRequest) MarshalToSizedBuffer 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

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

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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