Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowResourceUsageAgent = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthResourceUsageAgent = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupResourceUsageAgent = fmt.Errorf("proto: unexpected end of group") + func RegisterResourceMeteringPubSubServer(s *grpc.Server, srv ResourceMeteringPubSubServer) + func RegisterResourceUsageAgentServer(s *grpc.Server, srv ResourceUsageAgentServer) + type EmptyResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EmptyResponse) Descriptor() ([]byte, []int) + func (*EmptyResponse) ProtoMessage() + func (m *EmptyResponse) Marshal() (dAtA []byte, err error) + func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error) + func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EmptyResponse) Reset() + func (m *EmptyResponse) Size() (n int) + func (m *EmptyResponse) String() string + func (m *EmptyResponse) Unmarshal(dAtA []byte) error + func (m *EmptyResponse) XXX_DiscardUnknown() + func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EmptyResponse) XXX_Merge(src proto.Message) + func (m *EmptyResponse) XXX_Size() int + func (m *EmptyResponse) XXX_Unmarshal(b []byte) error + type GroupTagRecord struct + Items []*GroupTagRecordItem + ResourceGroupTag []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GroupTagRecord) Descriptor() ([]byte, []int) + func (*GroupTagRecord) ProtoMessage() + func (m *GroupTagRecord) GetItems() []*GroupTagRecordItem + func (m *GroupTagRecord) GetResourceGroupTag() []byte + func (m *GroupTagRecord) Marshal() (dAtA []byte, err error) + func (m *GroupTagRecord) MarshalTo(dAtA []byte) (int, error) + func (m *GroupTagRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GroupTagRecord) Reset() + func (m *GroupTagRecord) Size() (n int) + func (m *GroupTagRecord) String() string + func (m *GroupTagRecord) Unmarshal(dAtA []byte) error + func (m *GroupTagRecord) XXX_DiscardUnknown() + func (m *GroupTagRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupTagRecord) XXX_Merge(src proto.Message) + func (m *GroupTagRecord) XXX_Size() int + func (m *GroupTagRecord) XXX_Unmarshal(b []byte) error + type GroupTagRecordItem struct + CpuTimeMs uint32 + ReadKeys uint32 + TimestampSec uint64 + WriteKeys uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GroupTagRecordItem) Descriptor() ([]byte, []int) + func (*GroupTagRecordItem) ProtoMessage() + func (m *GroupTagRecordItem) GetCpuTimeMs() uint32 + func (m *GroupTagRecordItem) GetReadKeys() uint32 + func (m *GroupTagRecordItem) GetTimestampSec() uint64 + func (m *GroupTagRecordItem) GetWriteKeys() uint32 + func (m *GroupTagRecordItem) Marshal() (dAtA []byte, err error) + func (m *GroupTagRecordItem) MarshalTo(dAtA []byte) (int, error) + func (m *GroupTagRecordItem) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GroupTagRecordItem) Reset() + func (m *GroupTagRecordItem) Size() (n int) + func (m *GroupTagRecordItem) String() string + func (m *GroupTagRecordItem) Unmarshal(dAtA []byte) error + func (m *GroupTagRecordItem) XXX_DiscardUnknown() + func (m *GroupTagRecordItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupTagRecordItem) XXX_Merge(src proto.Message) + func (m *GroupTagRecordItem) XXX_Size() int + func (m *GroupTagRecordItem) XXX_Unmarshal(b []byte) error + type ResourceMeteringPubSubClient interface + Subscribe func(ctx context.Context, in *ResourceMeteringRequest, opts ...grpc.CallOption) (ResourceMeteringPubSub_SubscribeClient, error) + func NewResourceMeteringPubSubClient(cc *grpc.ClientConn) ResourceMeteringPubSubClient + type ResourceMeteringPubSubServer interface + Subscribe func(*ResourceMeteringRequest, ResourceMeteringPubSub_SubscribeServer) error + type ResourceMeteringPubSub_SubscribeClient interface + Recv func() (*ResourceUsageRecord, error) + type ResourceMeteringPubSub_SubscribeServer interface + Send func(*ResourceUsageRecord) error + type ResourceMeteringRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResourceMeteringRequest) Descriptor() ([]byte, []int) + func (*ResourceMeteringRequest) ProtoMessage() + func (m *ResourceMeteringRequest) Marshal() (dAtA []byte, err error) + func (m *ResourceMeteringRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceMeteringRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceMeteringRequest) Reset() + func (m *ResourceMeteringRequest) Size() (n int) + func (m *ResourceMeteringRequest) String() string + func (m *ResourceMeteringRequest) Unmarshal(dAtA []byte) error + func (m *ResourceMeteringRequest) XXX_DiscardUnknown() + func (m *ResourceMeteringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceMeteringRequest) XXX_Merge(src proto.Message) + func (m *ResourceMeteringRequest) XXX_Size() int + func (m *ResourceMeteringRequest) XXX_Unmarshal(b []byte) error + type ResourceUsageAgentClient interface + Report func(ctx context.Context, opts ...grpc.CallOption) (ResourceUsageAgent_ReportClient, error) + func NewResourceUsageAgentClient(cc *grpc.ClientConn) ResourceUsageAgentClient + type ResourceUsageAgentServer interface + Report func(ResourceUsageAgent_ReportServer) error + type ResourceUsageAgent_ReportClient interface + CloseAndRecv func() (*EmptyResponse, error) + Send func(*ResourceUsageRecord) error + type ResourceUsageAgent_ReportServer interface + Recv func() (*ResourceUsageRecord, error) + SendAndClose func(*EmptyResponse) error + type ResourceUsageRecord struct + RecordOneof isResourceUsageRecord_RecordOneof + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResourceUsageRecord) Descriptor() ([]byte, []int) + func (*ResourceUsageRecord) ProtoMessage() + func (*ResourceUsageRecord) XXX_OneofWrappers() []interface{} + func (m *ResourceUsageRecord) GetRecord() *GroupTagRecord + func (m *ResourceUsageRecord) GetRecordOneof() isResourceUsageRecord_RecordOneof + func (m *ResourceUsageRecord) Marshal() (dAtA []byte, err error) + func (m *ResourceUsageRecord) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceUsageRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceUsageRecord) Reset() + func (m *ResourceUsageRecord) Size() (n int) + func (m *ResourceUsageRecord) String() string + func (m *ResourceUsageRecord) Unmarshal(dAtA []byte) error + func (m *ResourceUsageRecord) XXX_DiscardUnknown() + func (m *ResourceUsageRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceUsageRecord) XXX_Merge(src proto.Message) + func (m *ResourceUsageRecord) XXX_Size() int + func (m *ResourceUsageRecord) XXX_Unmarshal(b []byte) error + type ResourceUsageRecord_Record struct + Record *GroupTagRecord + func (m *ResourceUsageRecord_Record) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceUsageRecord_Record) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceUsageRecord_Record) Size() (n int) + type UnimplementedResourceMeteringPubSubServer struct + func (*UnimplementedResourceMeteringPubSubServer) Subscribe(req *ResourceMeteringRequest, srv ResourceMeteringPubSub_SubscribeServer) error + type UnimplementedResourceUsageAgentServer struct + func (*UnimplementedResourceUsageAgentServer) Report(srv ResourceUsageAgent_ReportServer) error