metadatapb

package
v0.35.1 Latest Latest
Warning

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

Go to latest
Published: May 28, 2024 License: Apache-2.0 Imports: 12 Imported by: 5

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 RegisterMetadataServer

func RegisterMetadataServer(s *grpc.Server, srv MetadataServer)

Types

type Meta

type Meta struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type"`
	Help string `protobuf:"bytes,2,opt,name=help,proto3" json:"help"`
	Unit string `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit"`
}

func (*Meta) Descriptor

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

func (*Meta) Marshal

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

func (*Meta) MarshalTo

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

func (*Meta) MarshalToSizedBuffer

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

func (*Meta) ProtoMessage

func (*Meta) ProtoMessage()

func (*Meta) Reset

func (m *Meta) Reset()

func (*Meta) Size

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

func (*Meta) String

func (m *Meta) String() string

func (*Meta) Unmarshal

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

func (*Meta) XXX_DiscardUnknown

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal

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

func (*Meta) XXX_Merge

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

func (*Meta) XXX_Size

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal

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

type MetadataClient

type MetadataClient interface {
	MetricMetadata(ctx context.Context, in *MetricMetadataRequest, opts ...grpc.CallOption) (Metadata_MetricMetadataClient, error)
}

MetadataClient is the client API for Metadata service.

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

func NewMetadataClient

func NewMetadataClient(cc *grpc.ClientConn) MetadataClient

type MetadataServer

type MetadataServer interface {
	MetricMetadata(*MetricMetadataRequest, Metadata_MetricMetadataServer) error
}

MetadataServer is the server API for Metadata service.

type Metadata_MetricMetadataClient

type Metadata_MetricMetadataClient interface {
	Recv() (*MetricMetadataResponse, error)
	grpc.ClientStream
}

type Metadata_MetricMetadataServer

type Metadata_MetricMetadataServer interface {
	Send(*MetricMetadataResponse) error
	grpc.ServerStream
}

type MetricMetadata

type MetricMetadata struct {
	Metadata map[string]MetricMetadataEntry `` /* 147-byte string literal not displayed */
}

func FromMetadataMap

func FromMetadataMap(m map[string][]Meta) *MetricMetadata

func (*MetricMetadata) Descriptor

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

func (*MetricMetadata) Marshal

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

func (*MetricMetadata) MarshalTo

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

func (*MetricMetadata) MarshalToSizedBuffer

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

func (*MetricMetadata) ProtoMessage

func (*MetricMetadata) ProtoMessage()

func (*MetricMetadata) Reset

func (m *MetricMetadata) Reset()

func (*MetricMetadata) Size

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

func (*MetricMetadata) String

func (m *MetricMetadata) String() string

func (*MetricMetadata) Unmarshal

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

func (*MetricMetadata) XXX_DiscardUnknown

func (m *MetricMetadata) XXX_DiscardUnknown()

func (*MetricMetadata) XXX_Marshal

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

func (*MetricMetadata) XXX_Merge

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

func (*MetricMetadata) XXX_Size

func (m *MetricMetadata) XXX_Size() int

func (*MetricMetadata) XXX_Unmarshal

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

type MetricMetadataEntry

type MetricMetadataEntry struct {
	Metas []Meta `protobuf:"bytes,2,rep,name=metas,proto3" json:"metas"`
}

func (*MetricMetadataEntry) Descriptor

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

func (*MetricMetadataEntry) Marshal

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

func (*MetricMetadataEntry) MarshalTo

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

func (*MetricMetadataEntry) MarshalToSizedBuffer

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

func (*MetricMetadataEntry) ProtoMessage

func (*MetricMetadataEntry) ProtoMessage()

func (*MetricMetadataEntry) Reset

func (m *MetricMetadataEntry) Reset()

func (*MetricMetadataEntry) Size

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

func (*MetricMetadataEntry) String

func (m *MetricMetadataEntry) String() string

func (*MetricMetadataEntry) Unmarshal

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

func (*MetricMetadataEntry) XXX_DiscardUnknown

func (m *MetricMetadataEntry) XXX_DiscardUnknown()

func (*MetricMetadataEntry) XXX_Marshal

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

func (*MetricMetadataEntry) XXX_Merge

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

func (*MetricMetadataEntry) XXX_Size

func (m *MetricMetadataEntry) XXX_Size() int

func (*MetricMetadataEntry) XXX_Unmarshal

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

type MetricMetadataRequest

type MetricMetadataRequest struct {
	Metric                  string                          `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	Limit                   int32                           `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	PartialResponseStrategy storepb.PartialResponseStrategy `` /* 169-byte string literal not displayed */
}

func (*MetricMetadataRequest) Descriptor

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

func (*MetricMetadataRequest) Marshal

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

func (*MetricMetadataRequest) MarshalTo

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

func (*MetricMetadataRequest) MarshalToSizedBuffer

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

func (*MetricMetadataRequest) ProtoMessage

func (*MetricMetadataRequest) ProtoMessage()

func (*MetricMetadataRequest) Reset

func (m *MetricMetadataRequest) Reset()

func (*MetricMetadataRequest) Size

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

func (*MetricMetadataRequest) String

func (m *MetricMetadataRequest) String() string

func (*MetricMetadataRequest) Unmarshal

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

func (*MetricMetadataRequest) XXX_DiscardUnknown

func (m *MetricMetadataRequest) XXX_DiscardUnknown()

func (*MetricMetadataRequest) XXX_Marshal

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

func (*MetricMetadataRequest) XXX_Merge

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

func (*MetricMetadataRequest) XXX_Size

func (m *MetricMetadataRequest) XXX_Size() int

func (*MetricMetadataRequest) XXX_Unmarshal

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

type MetricMetadataResponse

type MetricMetadataResponse struct {
	// Types that are valid to be assigned to Result:
	//	*MetricMetadataResponse_Metadata
	//	*MetricMetadataResponse_Warning
	Result isMetricMetadataResponse_Result `protobuf_oneof:"result"`
}

func NewMetricMetadataResponse

func NewMetricMetadataResponse(metadata *MetricMetadata) *MetricMetadataResponse

func NewWarningMetadataResponse

func NewWarningMetadataResponse(warning error) *MetricMetadataResponse

func (*MetricMetadataResponse) Descriptor

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

func (*MetricMetadataResponse) GetMetadata

func (m *MetricMetadataResponse) GetMetadata() *MetricMetadata

func (*MetricMetadataResponse) GetResult

func (m *MetricMetadataResponse) GetResult() isMetricMetadataResponse_Result

func (*MetricMetadataResponse) GetWarning

func (m *MetricMetadataResponse) GetWarning() string

func (*MetricMetadataResponse) Marshal

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

func (*MetricMetadataResponse) MarshalTo

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

func (*MetricMetadataResponse) MarshalToSizedBuffer

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

func (*MetricMetadataResponse) ProtoMessage

func (*MetricMetadataResponse) ProtoMessage()

func (*MetricMetadataResponse) Reset

func (m *MetricMetadataResponse) Reset()

func (*MetricMetadataResponse) Size

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

func (*MetricMetadataResponse) String

func (m *MetricMetadataResponse) String() string

func (*MetricMetadataResponse) Unmarshal

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

func (*MetricMetadataResponse) XXX_DiscardUnknown

func (m *MetricMetadataResponse) XXX_DiscardUnknown()

func (*MetricMetadataResponse) XXX_Marshal

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

func (*MetricMetadataResponse) XXX_Merge

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

func (*MetricMetadataResponse) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MetricMetadataResponse) XXX_Size

func (m *MetricMetadataResponse) XXX_Size() int

func (*MetricMetadataResponse) XXX_Unmarshal

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

type MetricMetadataResponse_Metadata

type MetricMetadataResponse_Metadata struct {
	Metadata *MetricMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof" json:"metadata,omitempty"`
}

func (*MetricMetadataResponse_Metadata) MarshalTo

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

func (*MetricMetadataResponse_Metadata) MarshalToSizedBuffer

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

func (*MetricMetadataResponse_Metadata) Size

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

type MetricMetadataResponse_Warning

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

func (*MetricMetadataResponse_Warning) MarshalTo

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

func (*MetricMetadataResponse_Warning) MarshalToSizedBuffer

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

func (*MetricMetadataResponse_Warning) Size

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

type UnimplementedMetadataServer

type UnimplementedMetadataServer struct {
}

UnimplementedMetadataServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataServer) MetricMetadata

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL