exemplarspb

package
v0.21.1 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2021 License: Apache-2.0 Imports: 17 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

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")
)

Functions

func RegisterExemplarsServer 

func RegisterExemplarsServer(s *grpc.Server, srv ExemplarsServer)

Types

type Exemplar 

type Exemplar struct {
	Labels labelpb.ZLabelSet `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"`
	Value  float64           `protobuf:"fixed64,2,opt,name=value,proto3" json:"value"`
	Ts     int64             `protobuf:"varint,3,opt,name=ts,proto3" json:"timestamp"`
}

func (*Exemplar) Compare 

func (e1 *Exemplar) Compare(e2 *Exemplar) int

Compare is used for sorting and comparing exemplars. Start from timestamp, then labels, finally values.

func (*Exemplar) Descriptor 

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

func (*Exemplar) Marshal 

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

func (*Exemplar) MarshalJSON 

func (m *Exemplar) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler.

func (*Exemplar) MarshalTo 

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

func (*Exemplar) MarshalToSizedBuffer 

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

func (*Exemplar) ProtoMessage 

func (*Exemplar) ProtoMessage()

func (*Exemplar) Reset 

func (m *Exemplar) Reset()

func (*Exemplar) Size 

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

func (*Exemplar) String 

func (m *Exemplar) String() string

func (*Exemplar) Unmarshal 

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

func (*Exemplar) UnmarshalJSON 

func (m *Exemplar) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler.

func (*Exemplar) XXX_DiscardUnknown 

func (m *Exemplar) XXX_DiscardUnknown()

func (*Exemplar) XXX_Marshal 

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

func (*Exemplar) XXX_Merge 

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

func (*Exemplar) XXX_Size 

func (m *Exemplar) XXX_Size() int

func (*Exemplar) XXX_Unmarshal 

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

type ExemplarData 

type ExemplarData struct {
	SeriesLabels labelpb.ZLabelSet `protobuf:"bytes,1,opt,name=seriesLabels,proto3" json:"seriesLabels"`
	Exemplars    []*Exemplar       `protobuf:"bytes,2,rep,name=exemplars,proto3" json:"exemplars"`
}

func (*ExemplarData) Compare 

func (s1 *ExemplarData) Compare(s2 *ExemplarData) int

Compare only compares the series labels of two exemplar data.

func (*ExemplarData) Descriptor 

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

func (*ExemplarData) Marshal 

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

func (*ExemplarData) MarshalTo 

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

func (*ExemplarData) MarshalToSizedBuffer 

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

func (*ExemplarData) ProtoMessage 

func (*ExemplarData) ProtoMessage()

func (*ExemplarData) Reset 

func (m *ExemplarData) Reset()

func (*ExemplarData) SetSeriesLabels 

func (s *ExemplarData) SetSeriesLabels(ls labels.Labels)

func (*ExemplarData) Size 

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

func (*ExemplarData) String 

func (m *ExemplarData) String() string

func (*ExemplarData) Unmarshal 

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

func (*ExemplarData) XXX_DiscardUnknown 

func (m *ExemplarData) XXX_DiscardUnknown()

func (*ExemplarData) XXX_Marshal 

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

func (*ExemplarData) XXX_Merge 

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

func (*ExemplarData) XXX_Size 

func (m *ExemplarData) XXX_Size() int

func (*ExemplarData) XXX_Unmarshal 

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

type ExemplarStore added in v0.20.1 

type ExemplarStore struct {
	ExemplarsClient
	LabelSets []labels.Labels
}

ExemplarStore wraps the ExemplarsClient and contains the info of external labels.

type ExemplarsClient 

type ExemplarsClient interface {
	/// Exemplars has info for all exemplars.
	/// Returned exemplars are expected to include external labels.
	Exemplars(ctx context.Context, in *ExemplarsRequest, opts ...grpc.CallOption) (Exemplars_ExemplarsClient, error)
}

ExemplarsClient is the client API for Exemplars service.

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

func NewExemplarsClient 

func NewExemplarsClient(cc *grpc.ClientConn) ExemplarsClient

type ExemplarsRequest 

type ExemplarsRequest struct {
	Query                   string                          `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Start                   int64                           `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End                     int64                           `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	PartialResponseStrategy storepb.PartialResponseStrategy `` /* 169-byte string literal not displayed */
}

func (*ExemplarsRequest) Descriptor 

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

func (*ExemplarsRequest) Marshal 

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

func (*ExemplarsRequest) MarshalTo 

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

func (*ExemplarsRequest) MarshalToSizedBuffer 

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

func (*ExemplarsRequest) ProtoMessage 

func (*ExemplarsRequest) ProtoMessage()

func (*ExemplarsRequest) Reset 

func (m *ExemplarsRequest) Reset()

func (*ExemplarsRequest) Size 

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

func (*ExemplarsRequest) String 

func (m *ExemplarsRequest) String() string

func (*ExemplarsRequest) Unmarshal 

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

func (*ExemplarsRequest) XXX_DiscardUnknown 

func (m *ExemplarsRequest) XXX_DiscardUnknown()

func (*ExemplarsRequest) XXX_Marshal 

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

func (*ExemplarsRequest) XXX_Merge 

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

func (*ExemplarsRequest) XXX_Size 

func (m *ExemplarsRequest) XXX_Size() int

func (*ExemplarsRequest) XXX_Unmarshal 

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

type ExemplarsResponse 

type ExemplarsResponse struct {
	// Types that are valid to be assigned to Result:
	//	*ExemplarsResponse_Data
	//	*ExemplarsResponse_Warning
	Result isExemplarsResponse_Result `protobuf_oneof:"result"`
}

func NewExemplarsResponse 

func NewExemplarsResponse(e *ExemplarData) *ExemplarsResponse

func NewWarningExemplarsResponse 

func NewWarningExemplarsResponse(warning error) *ExemplarsResponse

func (*ExemplarsResponse) Descriptor 

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

func (*ExemplarsResponse) GetData 

func (m *ExemplarsResponse) GetData() *ExemplarData

func (*ExemplarsResponse) GetResult 

func (m *ExemplarsResponse) GetResult() isExemplarsResponse_Result

func (*ExemplarsResponse) GetWarning 

func (m *ExemplarsResponse) GetWarning() string

func (*ExemplarsResponse) Marshal 

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

func (*ExemplarsResponse) MarshalTo 

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

func (*ExemplarsResponse) MarshalToSizedBuffer 

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

func (*ExemplarsResponse) ProtoMessage 

func (*ExemplarsResponse) ProtoMessage()

func (*ExemplarsResponse) Reset 

func (m *ExemplarsResponse) Reset()

func (*ExemplarsResponse) Size 

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

func (*ExemplarsResponse) String 

func (m *ExemplarsResponse) String() string

func (*ExemplarsResponse) Unmarshal 

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

func (*ExemplarsResponse) XXX_DiscardUnknown 

func (m *ExemplarsResponse) XXX_DiscardUnknown()

func (*ExemplarsResponse) XXX_Marshal 

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

func (*ExemplarsResponse) XXX_Merge 

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

func (*ExemplarsResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExemplarsResponse) XXX_Size 

func (m *ExemplarsResponse) XXX_Size() int

func (*ExemplarsResponse) XXX_Unmarshal 

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

type ExemplarsResponse_Data 

type ExemplarsResponse_Data struct {
	Data *ExemplarData `protobuf:"bytes,1,opt,name=data,proto3,oneof" json:"data,omitempty"`
}

func (*ExemplarsResponse_Data) MarshalTo 

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

func (*ExemplarsResponse_Data) MarshalToSizedBuffer 

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

func (*ExemplarsResponse_Data) Size 

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

type ExemplarsResponse_Warning 

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

func (*ExemplarsResponse_Warning) MarshalTo 

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

func (*ExemplarsResponse_Warning) MarshalToSizedBuffer 

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

func (*ExemplarsResponse_Warning) Size 

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

type ExemplarsServer 

type ExemplarsServer interface {
	/// Exemplars has info for all exemplars.
	/// Returned exemplars are expected to include external labels.
	Exemplars(*ExemplarsRequest, Exemplars_ExemplarsServer) error
}

ExemplarsServer is the server API for Exemplars service.

type Exemplars_ExemplarsClient 

type Exemplars_ExemplarsClient interface {
	Recv() (*ExemplarsResponse, error)
	grpc.ClientStream
}

type Exemplars_ExemplarsServer 

type Exemplars_ExemplarsServer interface {
	Send(*ExemplarsResponse) error
	grpc.ServerStream
}

type UnimplementedExemplarsServer 

type UnimplementedExemplarsServer struct {
}

UnimplementedExemplarsServer can be embedded to have forward compatible implementations.

func (*UnimplementedExemplarsServer) Exemplars 

func (*UnimplementedExemplarsServer) Exemplars(req *ExemplarsRequest, srv Exemplars_ExemplarsServer) 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.