resource_usage_agent

package
v0.0.0-...-ad14807 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2025 License: Apache-2.0 Imports: 10 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthResourceUsageAgent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourceUsageAgent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResourceUsageAgent = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterResourceMeteringPubSubServer 

func RegisterResourceMeteringPubSubServer(s *grpc.Server, srv ResourceMeteringPubSubServer)

func RegisterResourceUsageAgentServer 

func RegisterResourceUsageAgentServer(s *grpc.Server, srv ResourceUsageAgentServer)

Types

type EmptyResponse 

type EmptyResponse struct {
}

func (*EmptyResponse) Descriptor 

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

func (*EmptyResponse) Marshal 

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

func (*EmptyResponse) MarshalTo 

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

func (*EmptyResponse) MarshalToSizedBuffer 

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

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset 

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size 

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

func (*EmptyResponse) String 

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal 

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

func (*EmptyResponse) XXX_DiscardUnknown 

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal 

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

func (*EmptyResponse) XXX_Merge 

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

func (*EmptyResponse) XXX_Size 

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal 

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

type GroupTagRecord 

type GroupTagRecord struct {
	ResourceGroupTag []byte                `protobuf:"bytes,1,opt,name=resource_group_tag,json=resourceGroupTag,proto3" json:"resource_group_tag,omitempty"`
	Items            []*GroupTagRecordItem `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
}

GroupTagRecord is a set of resource usage data grouped by resource_group_tag.

func (*GroupTagRecord) Descriptor 

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

func (*GroupTagRecord) GetItems 

func (m *GroupTagRecord) GetItems() []*GroupTagRecordItem

func (*GroupTagRecord) GetResourceGroupTag 

func (m *GroupTagRecord) GetResourceGroupTag() []byte

func (*GroupTagRecord) Marshal 

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

func (*GroupTagRecord) MarshalTo 

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

func (*GroupTagRecord) MarshalToSizedBuffer 

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

func (*GroupTagRecord) ProtoMessage 

func (*GroupTagRecord) ProtoMessage()

func (*GroupTagRecord) Reset 

func (m *GroupTagRecord) Reset()

func (*GroupTagRecord) Size 

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

func (*GroupTagRecord) String 

func (m *GroupTagRecord) String() string

func (*GroupTagRecord) Unmarshal 

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

func (*GroupTagRecord) XXX_DiscardUnknown 

func (m *GroupTagRecord) XXX_DiscardUnknown()

func (*GroupTagRecord) XXX_Marshal 

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

func (*GroupTagRecord) XXX_Merge 

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

func (*GroupTagRecord) XXX_Size 

func (m *GroupTagRecord) XXX_Size() int

func (*GroupTagRecord) XXX_Unmarshal 

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

type GroupTagRecordItem 

type GroupTagRecordItem struct {
	TimestampSec uint64 `protobuf:"varint,1,opt,name=timestamp_sec,json=timestampSec,proto3" json:"timestamp_sec,omitempty"`
	CpuTimeMs    uint32 `protobuf:"varint,2,opt,name=cpu_time_ms,json=cpuTimeMs,proto3" json:"cpu_time_ms,omitempty"`
	ReadKeys     uint32 `protobuf:"varint,3,opt,name=read_keys,json=readKeys,proto3" json:"read_keys,omitempty"`
	WriteKeys    uint32 `protobuf:"varint,4,opt,name=write_keys,json=writeKeys,proto3" json:"write_keys,omitempty"`
}

func (*GroupTagRecordItem) Descriptor 

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

func (*GroupTagRecordItem) GetCpuTimeMs 

func (m *GroupTagRecordItem) GetCpuTimeMs() uint32

func (*GroupTagRecordItem) GetReadKeys 

func (m *GroupTagRecordItem) GetReadKeys() uint32

func (*GroupTagRecordItem) GetTimestampSec 

func (m *GroupTagRecordItem) GetTimestampSec() uint64

func (*GroupTagRecordItem) GetWriteKeys 

func (m *GroupTagRecordItem) GetWriteKeys() uint32

func (*GroupTagRecordItem) Marshal 

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

func (*GroupTagRecordItem) MarshalTo 

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

func (*GroupTagRecordItem) MarshalToSizedBuffer 

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

func (*GroupTagRecordItem) ProtoMessage 

func (*GroupTagRecordItem) ProtoMessage()

func (*GroupTagRecordItem) Reset 

func (m *GroupTagRecordItem) Reset()

func (*GroupTagRecordItem) Size 

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

func (*GroupTagRecordItem) String 

func (m *GroupTagRecordItem) String() string

func (*GroupTagRecordItem) Unmarshal 

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

func (*GroupTagRecordItem) XXX_DiscardUnknown 

func (m *GroupTagRecordItem) XXX_DiscardUnknown()

func (*GroupTagRecordItem) XXX_Marshal 

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

func (*GroupTagRecordItem) XXX_Merge 

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

func (*GroupTagRecordItem) XXX_Size 

func (m *GroupTagRecordItem) XXX_Size() int

func (*GroupTagRecordItem) XXX_Unmarshal 

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

type ResourceMeteringPubSubClient 

type ResourceMeteringPubSubClient interface {
	// Clients subscribe to resource metering records through this RPC, and TiKV periodically (e.g. per minute)
	// publishes resource metering records to clients via gRPC stream.
	Subscribe(ctx context.Context, in *ResourceMeteringRequest, opts ...grpc.CallOption) (ResourceMeteringPubSub_SubscribeClient, error)
}

ResourceMeteringPubSubClient is the client API for ResourceMeteringPubSub service.

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

func NewResourceMeteringPubSubClient 

func NewResourceMeteringPubSubClient(cc *grpc.ClientConn) ResourceMeteringPubSubClient

type ResourceMeteringPubSubServer 

type ResourceMeteringPubSubServer interface {
	// Clients subscribe to resource metering records through this RPC, and TiKV periodically (e.g. per minute)
	// publishes resource metering records to clients via gRPC stream.
	Subscribe(*ResourceMeteringRequest, ResourceMeteringPubSub_SubscribeServer) error
}

ResourceMeteringPubSubServer is the server API for ResourceMeteringPubSub service.

type ResourceMeteringPubSub_SubscribeClient 

type ResourceMeteringPubSub_SubscribeClient interface {
	Recv() (*ResourceUsageRecord, error)
	grpc.ClientStream
}

type ResourceMeteringPubSub_SubscribeServer 

type ResourceMeteringPubSub_SubscribeServer interface {
	Send(*ResourceUsageRecord) error
	grpc.ServerStream
}

type ResourceMeteringRequest 

type ResourceMeteringRequest struct {
}

func (*ResourceMeteringRequest) Descriptor 

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

func (*ResourceMeteringRequest) Marshal 

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

func (*ResourceMeteringRequest) MarshalTo 

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

func (*ResourceMeteringRequest) MarshalToSizedBuffer 

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

func (*ResourceMeteringRequest) ProtoMessage 

func (*ResourceMeteringRequest) ProtoMessage()

func (*ResourceMeteringRequest) Reset 

func (m *ResourceMeteringRequest) Reset()

func (*ResourceMeteringRequest) Size 

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

func (*ResourceMeteringRequest) String 

func (m *ResourceMeteringRequest) String() string

func (*ResourceMeteringRequest) Unmarshal 

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

func (*ResourceMeteringRequest) XXX_DiscardUnknown 

func (m *ResourceMeteringRequest) XXX_DiscardUnknown()

func (*ResourceMeteringRequest) XXX_Marshal 

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

func (*ResourceMeteringRequest) XXX_Merge 

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

func (*ResourceMeteringRequest) XXX_Size 

func (m *ResourceMeteringRequest) XXX_Size() int

func (*ResourceMeteringRequest) XXX_Unmarshal 

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

type ResourceUsageAgentClient 

type ResourceUsageAgentClient interface {
	// Report the resource usage records. By default, the records with the same
	// resource group tag will be batched by minute.
	Report(ctx context.Context, opts ...grpc.CallOption) (ResourceUsageAgent_ReportClient, error)
}

ResourceUsageAgentClient is the client API for ResourceUsageAgent service.

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

func NewResourceUsageAgentClient 

func NewResourceUsageAgentClient(cc *grpc.ClientConn) ResourceUsageAgentClient

type ResourceUsageAgentServer 

type ResourceUsageAgentServer interface {
	// Report the resource usage records. By default, the records with the same
	// resource group tag will be batched by minute.
	Report(ResourceUsageAgent_ReportServer) error
}

ResourceUsageAgentServer is the server API for ResourceUsageAgent service.

type ResourceUsageAgent_ReportClient 

type ResourceUsageAgent_ReportClient interface {
	Send(*ResourceUsageRecord) error
	CloseAndRecv() (*EmptyResponse, error)
	grpc.ClientStream
}

type ResourceUsageAgent_ReportServer 

type ResourceUsageAgent_ReportServer interface {
	SendAndClose(*EmptyResponse) error
	Recv() (*ResourceUsageRecord, error)
	grpc.ServerStream
}

type ResourceUsageRecord 

type ResourceUsageRecord struct {
	// Types that are valid to be assigned to RecordOneof:
	//	*ResourceUsageRecord_Record
	RecordOneof isResourceUsageRecord_RecordOneof `protobuf_oneof:"record_oneof"`
}

func (*ResourceUsageRecord) Descriptor 

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

func (*ResourceUsageRecord) GetRecord 

func (m *ResourceUsageRecord) GetRecord() *GroupTagRecord

func (*ResourceUsageRecord) GetRecordOneof 

func (m *ResourceUsageRecord) GetRecordOneof() isResourceUsageRecord_RecordOneof

func (*ResourceUsageRecord) Marshal 

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

func (*ResourceUsageRecord) MarshalTo 

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

func (*ResourceUsageRecord) MarshalToSizedBuffer 

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

func (*ResourceUsageRecord) ProtoMessage 

func (*ResourceUsageRecord) ProtoMessage()

func (*ResourceUsageRecord) Reset 

func (m *ResourceUsageRecord) Reset()

func (*ResourceUsageRecord) Size 

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

func (*ResourceUsageRecord) String 

func (m *ResourceUsageRecord) String() string

func (*ResourceUsageRecord) Unmarshal 

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

func (*ResourceUsageRecord) XXX_DiscardUnknown 

func (m *ResourceUsageRecord) XXX_DiscardUnknown()

func (*ResourceUsageRecord) XXX_Marshal 

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

func (*ResourceUsageRecord) XXX_Merge 

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

func (*ResourceUsageRecord) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ResourceUsageRecord) XXX_Size 

func (m *ResourceUsageRecord) XXX_Size() int

func (*ResourceUsageRecord) XXX_Unmarshal 

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

type ResourceUsageRecord_Record 

type ResourceUsageRecord_Record struct {
	Record *GroupTagRecord `protobuf:"bytes,1,opt,name=record,proto3,oneof" json:"record,omitempty"`
}

func (*ResourceUsageRecord_Record) MarshalTo 

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

func (*ResourceUsageRecord_Record) MarshalToSizedBuffer 

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

func (*ResourceUsageRecord_Record) Size 

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

type UnimplementedResourceMeteringPubSubServer 

type UnimplementedResourceMeteringPubSubServer struct {
}

UnimplementedResourceMeteringPubSubServer can be embedded to have forward compatible implementations.

func (*UnimplementedResourceMeteringPubSubServer) Subscribe 

func (*UnimplementedResourceMeteringPubSubServer) Subscribe(req *ResourceMeteringRequest, srv ResourceMeteringPubSub_SubscribeServer) error

type UnimplementedResourceUsageAgentServer 

type UnimplementedResourceUsageAgentServer struct {
}

UnimplementedResourceUsageAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedResourceUsageAgentServer) Report 

func (*UnimplementedResourceUsageAgentServer) Report(srv ResourceUsageAgent_ReportServer) 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.