prompb

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2022 License: Apache-2.0 Imports: 21 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")
	ErrUnexpectedEndOfGroupRemote = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
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 RegisterAdminHandlerServer 

func RegisterAdminHandlerServer(ctx context.Context, mux *runtime.ServeMux, server AdminServer) error

RegisterAdminHandlerServer registers the http handlers for service Admin to "mux". UnaryRPC :call AdminServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterAdminHandlerFromEndpoint instead.

func RegisterAdminServer 

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

func RegisterClymeneServiceServer 

func RegisterClymeneServiceServer(s *grpc.Server, srv ClymeneServiceServer)

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. Series are returned sorted in the same way TSDB block are internally.

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 ClymeneServiceClient 

type ClymeneServiceClient interface {
	RequestMetrics(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
}

ClymeneServiceClient is the client API for ClymeneService service.

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

func NewClymeneServiceClient 

func NewClymeneServiceClient(cc *grpc.ClientConn) ClymeneServiceClient

type ClymeneServiceServer 

type ClymeneServiceServer interface {
	RequestMetrics(context.Context, *WriteRequest) (*MetricsResponse, error)
}

ClymeneServiceServer is the server API for ClymeneService service.

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 MetricsResponse 

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

func (*MetricsResponse) Descriptor 

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

func (*MetricsResponse) Marshal 

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

func (*MetricsResponse) MarshalTo 

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

func (*MetricsResponse) MarshalToSizedBuffer 

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

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) Reset 

func (m *MetricsResponse) Reset()

func (*MetricsResponse) Size 

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

func (*MetricsResponse) String 

func (m *MetricsResponse) String() string

func (*MetricsResponse) Unmarshal 

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

func (*MetricsResponse) XXX_DiscardUnknown 

func (m *MetricsResponse) XXX_DiscardUnknown()

func (*MetricsResponse) XXX_Marshal 

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

func (*MetricsResponse) XXX_Merge 

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

func (*MetricsResponse) XXX_Size 

func (m *MetricsResponse) XXX_Size() int

func (*MetricsResponse) XXX_Unmarshal 

func (m *MetricsResponse) 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"`
	Grouping             []string `protobuf:"bytes,5,rep,name=grouping,proto3" json:"grouping,omitempty"`
	By                   bool     `protobuf:"varint,6,opt,name=by,proto3" json:"by,omitempty"`
	RangeMs              int64    `protobuf:"varint,7,opt,name=range_ms,json=rangeMs,proto3" json:"range_ms,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadHints) Descriptor 

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

func (*ReadHints) GetBy 

func (m *ReadHints) GetBy() bool

func (*ReadHints) GetEndMs 

func (m *ReadHints) GetEndMs() int64

func (*ReadHints) GetFunc 

func (m *ReadHints) GetFunc() string

func (*ReadHints) GetGrouping 

func (m *ReadHints) GetGrouping() []string

func (*ReadHints) GetRangeMs 

func (m *ReadHints) GetRangeMs() int64

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 UnimplementedClymeneServiceServer 

type UnimplementedClymeneServiceServer struct {
}

UnimplementedClymeneServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClymeneServiceServer) RequestMetrics 

func (*UnimplementedClymeneServiceServer) RequestMetrics(ctx context.Context, req *WriteRequest) (*MetricsResponse, 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.