metadatapb

package
v0.24.0-rc.2 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2021 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 

func (*UnimplementedMetadataServer) MetricMetadata(req *MetricMetadataRequest, srv Metadata_MetricMetadataServer) 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.