metadatapb

package
v0.19.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 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 {
	Metadata(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (Metadata_MetadataClient, 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 MetadataRequest 

type MetadataRequest 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 (*MetadataRequest) Descriptor 

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

func (*MetadataRequest) Marshal 

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

func (*MetadataRequest) MarshalTo 

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

func (*MetadataRequest) MarshalToSizedBuffer 

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

func (*MetadataRequest) ProtoMessage 

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) Reset 

func (m *MetadataRequest) Reset()

func (*MetadataRequest) Size 

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

func (*MetadataRequest) String 

func (m *MetadataRequest) String() string

func (*MetadataRequest) Unmarshal 

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

func (*MetadataRequest) XXX_DiscardUnknown 

func (m *MetadataRequest) XXX_DiscardUnknown()

func (*MetadataRequest) XXX_Marshal 

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

func (*MetadataRequest) XXX_Merge 

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

func (*MetadataRequest) XXX_Size 

func (m *MetadataRequest) XXX_Size() int

func (*MetadataRequest) XXX_Unmarshal 

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

type MetadataResponse 

type MetadataResponse struct {
	// Types that are valid to be assigned to Result:
	//	*MetadataResponse_Metadata
	//	*MetadataResponse_Warning
	Result isMetadataResponse_Result `protobuf_oneof:"result"`
}

func NewMetadataResponse 

func NewMetadataResponse(metadata *MetricMetadata) *MetadataResponse

func NewWarningMetadataResponse 

func NewWarningMetadataResponse(warning error) *MetadataResponse

func (*MetadataResponse) Descriptor 

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

func (*MetadataResponse) GetMetadata 

func (m *MetadataResponse) GetMetadata() *MetricMetadata

func (*MetadataResponse) GetResult 

func (m *MetadataResponse) GetResult() isMetadataResponse_Result

func (*MetadataResponse) GetWarning 

func (m *MetadataResponse) GetWarning() string

func (*MetadataResponse) Marshal 

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

func (*MetadataResponse) MarshalTo 

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

func (*MetadataResponse) MarshalToSizedBuffer 

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

func (*MetadataResponse) ProtoMessage 

func (*MetadataResponse) ProtoMessage()

func (*MetadataResponse) Reset 

func (m *MetadataResponse) Reset()

func (*MetadataResponse) Size 

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

func (*MetadataResponse) String 

func (m *MetadataResponse) String() string

func (*MetadataResponse) Unmarshal 

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

func (*MetadataResponse) XXX_DiscardUnknown 

func (m *MetadataResponse) XXX_DiscardUnknown()

func (*MetadataResponse) XXX_Marshal 

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

func (*MetadataResponse) XXX_Merge 

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

func (*MetadataResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MetadataResponse) XXX_Size 

func (m *MetadataResponse) XXX_Size() int

func (*MetadataResponse) XXX_Unmarshal 

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

type MetadataResponse_Metadata 

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

func (*MetadataResponse_Metadata) MarshalTo 

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

func (*MetadataResponse_Metadata) MarshalToSizedBuffer 

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

func (*MetadataResponse_Metadata) Size 

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

type MetadataResponse_Warning 

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

func (*MetadataResponse_Warning) MarshalTo 

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

func (*MetadataResponse_Warning) MarshalToSizedBuffer 

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

func (*MetadataResponse_Warning) Size 

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

type MetadataServer 

type MetadataServer interface {
	Metadata(*MetadataRequest, Metadata_MetadataServer) error
}

MetadataServer is the server API for Metadata service.

type Metadata_MetadataClient 

type Metadata_MetadataClient interface {
	Recv() (*MetadataResponse, error)
	grpc.ClientStream
}

type Metadata_MetadataServer 

type Metadata_MetadataServer interface {
	Send(*MetadataResponse) 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 UnimplementedMetadataServer 

type UnimplementedMetadataServer struct {
}

UnimplementedMetadataServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataServer) Metadata 

func (*UnimplementedMetadataServer) Metadata(req *MetadataRequest, srv Metadata_MetadataServer) 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.