Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowResourceManager = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthResourceManager = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupResourceManager = fmt.Errorf("proto: unexpected end of group") + var GroupMode_name = map[int32]string + var GroupMode_value = map[string]int32 + var RawResourceType_name = map[int32]string + var RawResourceType_value = map[string]int32 + var RequestUnitType_name = map[int32]string + var RequestUnitType_value = map[string]int32 + var RunawayAction_name = map[int32]string + var RunawayAction_value = map[string]int32 + var RunawayWatchType_name = map[int32]string + var RunawayWatchType_value = map[string]int32 + func RegisterResourceManagerServer(s *grpc.Server, srv ResourceManagerServer) + type Consumption struct + KvReadRpcCount float64 + KvWriteRpcCount float64 + RRU float64 + ReadBytes float64 + SqlLayerCpuTimeMs float64 + TotalCpuTimeMs float64 + WRU float64 + WriteBytes float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Consumption) Descriptor() ([]byte, []int) + func (*Consumption) ProtoMessage() + func (m *Consumption) GetKvReadRpcCount() float64 + func (m *Consumption) GetKvWriteRpcCount() float64 + func (m *Consumption) GetRRU() float64 + func (m *Consumption) GetReadBytes() float64 + func (m *Consumption) GetSqlLayerCpuTimeMs() float64 + func (m *Consumption) GetTotalCpuTimeMs() float64 + func (m *Consumption) GetWRU() float64 + func (m *Consumption) GetWriteBytes() float64 + func (m *Consumption) Marshal() (dAtA []byte, err error) + func (m *Consumption) MarshalTo(dAtA []byte) (int, error) + func (m *Consumption) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Consumption) Reset() + func (m *Consumption) Size() (n int) + func (m *Consumption) String() string + func (m *Consumption) Unmarshal(dAtA []byte) error + func (m *Consumption) XXX_DiscardUnknown() + func (m *Consumption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Consumption) XXX_Merge(src proto.Message) + func (m *Consumption) XXX_Size() int + func (m *Consumption) XXX_Unmarshal(b []byte) error + type DeleteResourceGroupRequest struct + ResourceGroupName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResourceGroupRequest) Descriptor() ([]byte, []int) + func (*DeleteResourceGroupRequest) ProtoMessage() + func (m *DeleteResourceGroupRequest) GetResourceGroupName() string + func (m *DeleteResourceGroupRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteResourceGroupRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteResourceGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteResourceGroupRequest) Reset() + func (m *DeleteResourceGroupRequest) Size() (n int) + func (m *DeleteResourceGroupRequest) String() string + func (m *DeleteResourceGroupRequest) Unmarshal(dAtA []byte) error + func (m *DeleteResourceGroupRequest) XXX_DiscardUnknown() + func (m *DeleteResourceGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResourceGroupRequest) XXX_Merge(src proto.Message) + func (m *DeleteResourceGroupRequest) XXX_Size() int + func (m *DeleteResourceGroupRequest) XXX_Unmarshal(b []byte) error + type DeleteResourceGroupResponse struct + Body string + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResourceGroupResponse) Descriptor() ([]byte, []int) + func (*DeleteResourceGroupResponse) ProtoMessage() + func (m *DeleteResourceGroupResponse) GetBody() string + func (m *DeleteResourceGroupResponse) GetError() *Error + func (m *DeleteResourceGroupResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteResourceGroupResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteResourceGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteResourceGroupResponse) Reset() + func (m *DeleteResourceGroupResponse) Size() (n int) + func (m *DeleteResourceGroupResponse) String() string + func (m *DeleteResourceGroupResponse) Unmarshal(dAtA []byte) error + func (m *DeleteResourceGroupResponse) XXX_DiscardUnknown() + func (m *DeleteResourceGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResourceGroupResponse) XXX_Merge(src proto.Message) + func (m *DeleteResourceGroupResponse) XXX_Size() int + func (m *DeleteResourceGroupResponse) XXX_Unmarshal(b []byte) error + type Error struct + Message string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetMessage() string + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type GetResourceGroupRequest struct + ResourceGroupName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResourceGroupRequest) Descriptor() ([]byte, []int) + func (*GetResourceGroupRequest) ProtoMessage() + func (m *GetResourceGroupRequest) GetResourceGroupName() string + func (m *GetResourceGroupRequest) Marshal() (dAtA []byte, err error) + func (m *GetResourceGroupRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetResourceGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetResourceGroupRequest) Reset() + func (m *GetResourceGroupRequest) Size() (n int) + func (m *GetResourceGroupRequest) String() string + func (m *GetResourceGroupRequest) Unmarshal(dAtA []byte) error + func (m *GetResourceGroupRequest) XXX_DiscardUnknown() + func (m *GetResourceGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResourceGroupRequest) XXX_Merge(src proto.Message) + func (m *GetResourceGroupRequest) XXX_Size() int + func (m *GetResourceGroupRequest) XXX_Unmarshal(b []byte) error + type GetResourceGroupResponse struct + Error *Error + Group *ResourceGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetResourceGroupResponse) Descriptor() ([]byte, []int) + func (*GetResourceGroupResponse) ProtoMessage() + func (m *GetResourceGroupResponse) GetError() *Error + func (m *GetResourceGroupResponse) GetGroup() *ResourceGroup + func (m *GetResourceGroupResponse) Marshal() (dAtA []byte, err error) + func (m *GetResourceGroupResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResourceGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetResourceGroupResponse) Reset() + func (m *GetResourceGroupResponse) Size() (n int) + func (m *GetResourceGroupResponse) String() string + func (m *GetResourceGroupResponse) Unmarshal(dAtA []byte) error + func (m *GetResourceGroupResponse) XXX_DiscardUnknown() + func (m *GetResourceGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetResourceGroupResponse) XXX_Merge(src proto.Message) + func (m *GetResourceGroupResponse) XXX_Size() int + func (m *GetResourceGroupResponse) XXX_Unmarshal(b []byte) error + type GrantedRUTokenBucket struct + GrantedTokens *TokenBucket + TrickleTimeMs int64 + Type RequestUnitType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GrantedRUTokenBucket) Descriptor() ([]byte, []int) + func (*GrantedRUTokenBucket) ProtoMessage() + func (m *GrantedRUTokenBucket) GetGrantedTokens() *TokenBucket + func (m *GrantedRUTokenBucket) GetTrickleTimeMs() int64 + func (m *GrantedRUTokenBucket) GetType() RequestUnitType + func (m *GrantedRUTokenBucket) Marshal() (dAtA []byte, err error) + func (m *GrantedRUTokenBucket) MarshalTo(dAtA []byte) (int, error) + func (m *GrantedRUTokenBucket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GrantedRUTokenBucket) Reset() + func (m *GrantedRUTokenBucket) Size() (n int) + func (m *GrantedRUTokenBucket) String() string + func (m *GrantedRUTokenBucket) Unmarshal(dAtA []byte) error + func (m *GrantedRUTokenBucket) XXX_DiscardUnknown() + func (m *GrantedRUTokenBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GrantedRUTokenBucket) XXX_Merge(src proto.Message) + func (m *GrantedRUTokenBucket) XXX_Size() int + func (m *GrantedRUTokenBucket) XXX_Unmarshal(b []byte) error + type GrantedRawResourceTokenBucket struct + GrantedTokens *TokenBucket + TrickleTimeMs int64 + Type RawResourceType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GrantedRawResourceTokenBucket) Descriptor() ([]byte, []int) + func (*GrantedRawResourceTokenBucket) ProtoMessage() + func (m *GrantedRawResourceTokenBucket) GetGrantedTokens() *TokenBucket + func (m *GrantedRawResourceTokenBucket) GetTrickleTimeMs() int64 + func (m *GrantedRawResourceTokenBucket) GetType() RawResourceType + func (m *GrantedRawResourceTokenBucket) Marshal() (dAtA []byte, err error) + func (m *GrantedRawResourceTokenBucket) MarshalTo(dAtA []byte) (int, error) + func (m *GrantedRawResourceTokenBucket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GrantedRawResourceTokenBucket) Reset() + func (m *GrantedRawResourceTokenBucket) Size() (n int) + func (m *GrantedRawResourceTokenBucket) String() string + func (m *GrantedRawResourceTokenBucket) Unmarshal(dAtA []byte) error + func (m *GrantedRawResourceTokenBucket) XXX_DiscardUnknown() + func (m *GrantedRawResourceTokenBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GrantedRawResourceTokenBucket) XXX_Merge(src proto.Message) + func (m *GrantedRawResourceTokenBucket) XXX_Size() int + func (m *GrantedRawResourceTokenBucket) XXX_Unmarshal(b []byte) error + type GroupMode int32 + const GroupMode_RUMode + const GroupMode_RawMode + const GroupMode_Unknown + func (GroupMode) EnumDescriptor() ([]byte, []int) + func (x GroupMode) String() string + type GroupRawResourceSettings struct + Cpu *TokenBucket + IoRead *TokenBucket + IoWrite *TokenBucket + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GroupRawResourceSettings) Descriptor() ([]byte, []int) + func (*GroupRawResourceSettings) ProtoMessage() + func (m *GroupRawResourceSettings) GetCpu() *TokenBucket + func (m *GroupRawResourceSettings) GetIoRead() *TokenBucket + func (m *GroupRawResourceSettings) GetIoWrite() *TokenBucket + func (m *GroupRawResourceSettings) Marshal() (dAtA []byte, err error) + func (m *GroupRawResourceSettings) MarshalTo(dAtA []byte) (int, error) + func (m *GroupRawResourceSettings) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GroupRawResourceSettings) Reset() + func (m *GroupRawResourceSettings) Size() (n int) + func (m *GroupRawResourceSettings) String() string + func (m *GroupRawResourceSettings) Unmarshal(dAtA []byte) error + func (m *GroupRawResourceSettings) XXX_DiscardUnknown() + func (m *GroupRawResourceSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupRawResourceSettings) XXX_Merge(src proto.Message) + func (m *GroupRawResourceSettings) XXX_Size() int + func (m *GroupRawResourceSettings) XXX_Unmarshal(b []byte) error + type GroupRequestUnitSettings struct + RU *TokenBucket + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GroupRequestUnitSettings) Descriptor() ([]byte, []int) + func (*GroupRequestUnitSettings) ProtoMessage() + func (m *GroupRequestUnitSettings) GetRU() *TokenBucket + func (m *GroupRequestUnitSettings) Marshal() (dAtA []byte, err error) + func (m *GroupRequestUnitSettings) MarshalTo(dAtA []byte) (int, error) + func (m *GroupRequestUnitSettings) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GroupRequestUnitSettings) Reset() + func (m *GroupRequestUnitSettings) Size() (n int) + func (m *GroupRequestUnitSettings) String() string + func (m *GroupRequestUnitSettings) Unmarshal(dAtA []byte) error + func (m *GroupRequestUnitSettings) XXX_DiscardUnknown() + func (m *GroupRequestUnitSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GroupRequestUnitSettings) XXX_Merge(src proto.Message) + func (m *GroupRequestUnitSettings) XXX_Size() int + func (m *GroupRequestUnitSettings) XXX_Unmarshal(b []byte) error + type ListResourceGroupsRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListResourceGroupsRequest) Descriptor() ([]byte, []int) + func (*ListResourceGroupsRequest) ProtoMessage() + func (m *ListResourceGroupsRequest) Marshal() (dAtA []byte, err error) + func (m *ListResourceGroupsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListResourceGroupsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListResourceGroupsRequest) Reset() + func (m *ListResourceGroupsRequest) Size() (n int) + func (m *ListResourceGroupsRequest) String() string + func (m *ListResourceGroupsRequest) Unmarshal(dAtA []byte) error + func (m *ListResourceGroupsRequest) XXX_DiscardUnknown() + func (m *ListResourceGroupsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResourceGroupsRequest) XXX_Merge(src proto.Message) + func (m *ListResourceGroupsRequest) XXX_Size() int + func (m *ListResourceGroupsRequest) XXX_Unmarshal(b []byte) error + type ListResourceGroupsResponse struct + Error *Error + Groups []*ResourceGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListResourceGroupsResponse) Descriptor() ([]byte, []int) + func (*ListResourceGroupsResponse) ProtoMessage() + func (m *ListResourceGroupsResponse) GetError() *Error + func (m *ListResourceGroupsResponse) GetGroups() []*ResourceGroup + func (m *ListResourceGroupsResponse) Marshal() (dAtA []byte, err error) + func (m *ListResourceGroupsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListResourceGroupsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListResourceGroupsResponse) Reset() + func (m *ListResourceGroupsResponse) Size() (n int) + func (m *ListResourceGroupsResponse) String() string + func (m *ListResourceGroupsResponse) Unmarshal(dAtA []byte) error + func (m *ListResourceGroupsResponse) XXX_DiscardUnknown() + func (m *ListResourceGroupsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResourceGroupsResponse) XXX_Merge(src proto.Message) + func (m *ListResourceGroupsResponse) XXX_Size() int + func (m *ListResourceGroupsResponse) XXX_Unmarshal(b []byte) error + type PutResourceGroupRequest struct + Group *ResourceGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutResourceGroupRequest) Descriptor() ([]byte, []int) + func (*PutResourceGroupRequest) ProtoMessage() + func (m *PutResourceGroupRequest) GetGroup() *ResourceGroup + func (m *PutResourceGroupRequest) Marshal() (dAtA []byte, err error) + func (m *PutResourceGroupRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutResourceGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutResourceGroupRequest) Reset() + func (m *PutResourceGroupRequest) Size() (n int) + func (m *PutResourceGroupRequest) String() string + func (m *PutResourceGroupRequest) Unmarshal(dAtA []byte) error + func (m *PutResourceGroupRequest) XXX_DiscardUnknown() + func (m *PutResourceGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutResourceGroupRequest) XXX_Merge(src proto.Message) + func (m *PutResourceGroupRequest) XXX_Size() int + func (m *PutResourceGroupRequest) XXX_Unmarshal(b []byte) error + type PutResourceGroupResponse struct + Body string + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutResourceGroupResponse) Descriptor() ([]byte, []int) + func (*PutResourceGroupResponse) ProtoMessage() + func (m *PutResourceGroupResponse) GetBody() string + func (m *PutResourceGroupResponse) GetError() *Error + func (m *PutResourceGroupResponse) Marshal() (dAtA []byte, err error) + func (m *PutResourceGroupResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutResourceGroupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PutResourceGroupResponse) Reset() + func (m *PutResourceGroupResponse) Size() (n int) + func (m *PutResourceGroupResponse) String() string + func (m *PutResourceGroupResponse) Unmarshal(dAtA []byte) error + func (m *PutResourceGroupResponse) XXX_DiscardUnknown() + func (m *PutResourceGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PutResourceGroupResponse) XXX_Merge(src proto.Message) + func (m *PutResourceGroupResponse) XXX_Size() int + func (m *PutResourceGroupResponse) XXX_Unmarshal(b []byte) error + type RawResourceItem struct + Type RawResourceType + Value float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RawResourceItem) Descriptor() ([]byte, []int) + func (*RawResourceItem) ProtoMessage() + func (m *RawResourceItem) GetType() RawResourceType + func (m *RawResourceItem) GetValue() float64 + func (m *RawResourceItem) Marshal() (dAtA []byte, err error) + func (m *RawResourceItem) MarshalTo(dAtA []byte) (int, error) + func (m *RawResourceItem) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RawResourceItem) Reset() + func (m *RawResourceItem) Size() (n int) + func (m *RawResourceItem) String() string + func (m *RawResourceItem) Unmarshal(dAtA []byte) error + func (m *RawResourceItem) XXX_DiscardUnknown() + func (m *RawResourceItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RawResourceItem) XXX_Merge(src proto.Message) + func (m *RawResourceItem) XXX_Size() int + func (m *RawResourceItem) XXX_Unmarshal(b []byte) error + type RawResourceType int32 + const RawResourceType_CPU + const RawResourceType_IOReadFlow + const RawResourceType_IOWriteFlow + func (RawResourceType) EnumDescriptor() ([]byte, []int) + func (x RawResourceType) String() string + type RequestUnitItem struct + Type RequestUnitType + Value float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RequestUnitItem) Descriptor() ([]byte, []int) + func (*RequestUnitItem) ProtoMessage() + func (m *RequestUnitItem) GetType() RequestUnitType + func (m *RequestUnitItem) GetValue() float64 + func (m *RequestUnitItem) Marshal() (dAtA []byte, err error) + func (m *RequestUnitItem) MarshalTo(dAtA []byte) (int, error) + func (m *RequestUnitItem) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestUnitItem) Reset() + func (m *RequestUnitItem) Size() (n int) + func (m *RequestUnitItem) String() string + func (m *RequestUnitItem) Unmarshal(dAtA []byte) error + func (m *RequestUnitItem) XXX_DiscardUnknown() + func (m *RequestUnitItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestUnitItem) XXX_Merge(src proto.Message) + func (m *RequestUnitItem) XXX_Size() int + func (m *RequestUnitItem) XXX_Unmarshal(b []byte) error + type RequestUnitType int32 + const RequestUnitType_RU + func (RequestUnitType) EnumDescriptor() ([]byte, []int) + func (x RequestUnitType) String() string + type ResourceGroup struct + Mode GroupMode + Name string + Priority uint32 + RUSettings *GroupRequestUnitSettings + RawResourceSettings *GroupRawResourceSettings + RunawaySettings *RunawaySettings + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResourceGroup) Descriptor() ([]byte, []int) + func (*ResourceGroup) ProtoMessage() + func (m *ResourceGroup) GetMode() GroupMode + func (m *ResourceGroup) GetName() string + func (m *ResourceGroup) GetPriority() uint32 + func (m *ResourceGroup) GetRUSettings() *GroupRequestUnitSettings + func (m *ResourceGroup) GetRawResourceSettings() *GroupRawResourceSettings + func (m *ResourceGroup) GetRunawaySettings() *RunawaySettings + func (m *ResourceGroup) Marshal() (dAtA []byte, err error) + func (m *ResourceGroup) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceGroup) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceGroup) Reset() + func (m *ResourceGroup) Size() (n int) + func (m *ResourceGroup) String() string + func (m *ResourceGroup) Unmarshal(dAtA []byte) error + func (m *ResourceGroup) XXX_DiscardUnknown() + func (m *ResourceGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceGroup) XXX_Merge(src proto.Message) + func (m *ResourceGroup) XXX_Size() int + func (m *ResourceGroup) XXX_Unmarshal(b []byte) error + type ResourceManagerClient interface + AcquireTokenBuckets func(ctx context.Context, opts ...grpc.CallOption) (ResourceManager_AcquireTokenBucketsClient, error) + AddResourceGroup func(ctx context.Context, in *PutResourceGroupRequest, opts ...grpc.CallOption) (*PutResourceGroupResponse, error) + DeleteResourceGroup func(ctx context.Context, in *DeleteResourceGroupRequest, opts ...grpc.CallOption) (*DeleteResourceGroupResponse, error) + GetResourceGroup func(ctx context.Context, in *GetResourceGroupRequest, opts ...grpc.CallOption) (*GetResourceGroupResponse, error) + ListResourceGroups func(ctx context.Context, in *ListResourceGroupsRequest, opts ...grpc.CallOption) (*ListResourceGroupsResponse, error) + ModifyResourceGroup func(ctx context.Context, in *PutResourceGroupRequest, opts ...grpc.CallOption) (*PutResourceGroupResponse, error) + func NewResourceManagerClient(cc *grpc.ClientConn) ResourceManagerClient + type ResourceManagerServer interface + AcquireTokenBuckets func(ResourceManager_AcquireTokenBucketsServer) error + AddResourceGroup func(context.Context, *PutResourceGroupRequest) (*PutResourceGroupResponse, error) + DeleteResourceGroup func(context.Context, *DeleteResourceGroupRequest) (*DeleteResourceGroupResponse, error) + GetResourceGroup func(context.Context, *GetResourceGroupRequest) (*GetResourceGroupResponse, error) + ListResourceGroups func(context.Context, *ListResourceGroupsRequest) (*ListResourceGroupsResponse, error) + ModifyResourceGroup func(context.Context, *PutResourceGroupRequest) (*PutResourceGroupResponse, error) + type ResourceManager_AcquireTokenBucketsClient interface + Recv func() (*TokenBucketsResponse, error) + Send func(*TokenBucketsRequest) error + type ResourceManager_AcquireTokenBucketsServer interface + Recv func() (*TokenBucketsRequest, error) + Send func(*TokenBucketsResponse) error + type RunawayAction int32 + const RunawayAction_CoolDown + const RunawayAction_DryRun + const RunawayAction_Kill + func (RunawayAction) EnumDescriptor() ([]byte, []int) + func (x RunawayAction) String() string + type RunawayRule struct + ExecElapsedTimeMs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunawayRule) Descriptor() ([]byte, []int) + func (*RunawayRule) ProtoMessage() + func (m *RunawayRule) GetExecElapsedTimeMs() uint64 + func (m *RunawayRule) Marshal() (dAtA []byte, err error) + func (m *RunawayRule) MarshalTo(dAtA []byte) (int, error) + func (m *RunawayRule) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RunawayRule) Reset() + func (m *RunawayRule) Size() (n int) + func (m *RunawayRule) String() string + func (m *RunawayRule) Unmarshal(dAtA []byte) error + func (m *RunawayRule) XXX_DiscardUnknown() + func (m *RunawayRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunawayRule) XXX_Merge(src proto.Message) + func (m *RunawayRule) XXX_Size() int + func (m *RunawayRule) XXX_Unmarshal(b []byte) error + type RunawaySettings struct + Action RunawayAction + Rule *RunawayRule + Watch *RunawayWatch + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunawaySettings) Descriptor() ([]byte, []int) + func (*RunawaySettings) ProtoMessage() + func (m *RunawaySettings) GetAction() RunawayAction + func (m *RunawaySettings) GetRule() *RunawayRule + func (m *RunawaySettings) GetWatch() *RunawayWatch + func (m *RunawaySettings) Marshal() (dAtA []byte, err error) + func (m *RunawaySettings) MarshalTo(dAtA []byte) (int, error) + func (m *RunawaySettings) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RunawaySettings) Reset() + func (m *RunawaySettings) Size() (n int) + func (m *RunawaySettings) String() string + func (m *RunawaySettings) Unmarshal(dAtA []byte) error + func (m *RunawaySettings) XXX_DiscardUnknown() + func (m *RunawaySettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunawaySettings) XXX_Merge(src proto.Message) + func (m *RunawaySettings) XXX_Size() int + func (m *RunawaySettings) XXX_Unmarshal(b []byte) error + type RunawayWatch struct + LastingDurationMs uint64 + Type RunawayWatchType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunawayWatch) Descriptor() ([]byte, []int) + func (*RunawayWatch) ProtoMessage() + func (m *RunawayWatch) GetLastingDurationMs() uint64 + func (m *RunawayWatch) GetType() RunawayWatchType + func (m *RunawayWatch) Marshal() (dAtA []byte, err error) + func (m *RunawayWatch) MarshalTo(dAtA []byte) (int, error) + func (m *RunawayWatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RunawayWatch) Reset() + func (m *RunawayWatch) Size() (n int) + func (m *RunawayWatch) String() string + func (m *RunawayWatch) Unmarshal(dAtA []byte) error + func (m *RunawayWatch) XXX_DiscardUnknown() + func (m *RunawayWatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RunawayWatch) XXX_Merge(src proto.Message) + func (m *RunawayWatch) XXX_Size() int + func (m *RunawayWatch) XXX_Unmarshal(b []byte) error + type RunawayWatchType int32 + const RunawayWatchType_Exact + const RunawayWatchType_Similar + func (RunawayWatchType) EnumDescriptor() ([]byte, []int) + func (x RunawayWatchType) String() string + type TokenBucket struct + Settings *TokenLimitSettings + Tokens float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenBucket) Descriptor() ([]byte, []int) + func (*TokenBucket) ProtoMessage() + func (m *TokenBucket) GetSettings() *TokenLimitSettings + func (m *TokenBucket) GetTokens() float64 + func (m *TokenBucket) Marshal() (dAtA []byte, err error) + func (m *TokenBucket) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucket) Reset() + func (m *TokenBucket) Size() (n int) + func (m *TokenBucket) String() string + func (m *TokenBucket) Unmarshal(dAtA []byte) error + func (m *TokenBucket) XXX_DiscardUnknown() + func (m *TokenBucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenBucket) XXX_Merge(src proto.Message) + func (m *TokenBucket) XXX_Size() int + func (m *TokenBucket) XXX_Unmarshal(b []byte) error + type TokenBucketRequest struct + ConsumptionSinceLastRequest *Consumption + Request isTokenBucketRequest_Request + ResourceGroupName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenBucketRequest) Descriptor() ([]byte, []int) + func (*TokenBucketRequest) ProtoMessage() + func (*TokenBucketRequest) XXX_OneofWrappers() []interface{} + func (m *TokenBucketRequest) GetConsumptionSinceLastRequest() *Consumption + func (m *TokenBucketRequest) GetRawResourceItems() *TokenBucketRequest_RequestRawResource + func (m *TokenBucketRequest) GetRequest() isTokenBucketRequest_Request + func (m *TokenBucketRequest) GetResourceGroupName() string + func (m *TokenBucketRequest) GetRuItems() *TokenBucketRequest_RequestRU + func (m *TokenBucketRequest) Marshal() (dAtA []byte, err error) + func (m *TokenBucketRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketRequest) Reset() + func (m *TokenBucketRequest) Size() (n int) + func (m *TokenBucketRequest) String() string + func (m *TokenBucketRequest) Unmarshal(dAtA []byte) error + func (m *TokenBucketRequest) XXX_DiscardUnknown() + func (m *TokenBucketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenBucketRequest) XXX_Merge(src proto.Message) + func (m *TokenBucketRequest) XXX_Size() int + func (m *TokenBucketRequest) XXX_Unmarshal(b []byte) error + type TokenBucketRequest_RawResourceItems struct + RawResourceItems *TokenBucketRequest_RequestRawResource + func (m *TokenBucketRequest_RawResourceItems) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RawResourceItems) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RawResourceItems) Size() (n int) + type TokenBucketRequest_RequestRU struct + RequestRU []*RequestUnitItem + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenBucketRequest_RequestRU) Descriptor() ([]byte, []int) + func (*TokenBucketRequest_RequestRU) ProtoMessage() + func (m *TokenBucketRequest_RequestRU) GetRequestRU() []*RequestUnitItem + func (m *TokenBucketRequest_RequestRU) Marshal() (dAtA []byte, err error) + func (m *TokenBucketRequest_RequestRU) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RequestRU) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RequestRU) Reset() + func (m *TokenBucketRequest_RequestRU) Size() (n int) + func (m *TokenBucketRequest_RequestRU) String() string + func (m *TokenBucketRequest_RequestRU) Unmarshal(dAtA []byte) error + func (m *TokenBucketRequest_RequestRU) XXX_DiscardUnknown() + func (m *TokenBucketRequest_RequestRU) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenBucketRequest_RequestRU) XXX_Merge(src proto.Message) + func (m *TokenBucketRequest_RequestRU) XXX_Size() int + func (m *TokenBucketRequest_RequestRU) XXX_Unmarshal(b []byte) error + type TokenBucketRequest_RequestRawResource struct + RequestRawResource []*RawResourceItem + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenBucketRequest_RequestRawResource) Descriptor() ([]byte, []int) + func (*TokenBucketRequest_RequestRawResource) ProtoMessage() + func (m *TokenBucketRequest_RequestRawResource) GetRequestRawResource() []*RawResourceItem + func (m *TokenBucketRequest_RequestRawResource) Marshal() (dAtA []byte, err error) + func (m *TokenBucketRequest_RequestRawResource) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RequestRawResource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RequestRawResource) Reset() + func (m *TokenBucketRequest_RequestRawResource) Size() (n int) + func (m *TokenBucketRequest_RequestRawResource) String() string + func (m *TokenBucketRequest_RequestRawResource) Unmarshal(dAtA []byte) error + func (m *TokenBucketRequest_RequestRawResource) XXX_DiscardUnknown() + func (m *TokenBucketRequest_RequestRawResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenBucketRequest_RequestRawResource) XXX_Merge(src proto.Message) + func (m *TokenBucketRequest_RequestRawResource) XXX_Size() int + func (m *TokenBucketRequest_RequestRawResource) XXX_Unmarshal(b []byte) error + type TokenBucketRequest_RuItems struct + RuItems *TokenBucketRequest_RequestRU + func (m *TokenBucketRequest_RuItems) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RuItems) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketRequest_RuItems) Size() (n int) + type TokenBucketResponse struct + GrantedRUTokens []*GrantedRUTokenBucket + GrantedResourceTokens []*GrantedRawResourceTokenBucket + ResourceGroupName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenBucketResponse) Descriptor() ([]byte, []int) + func (*TokenBucketResponse) ProtoMessage() + func (m *TokenBucketResponse) GetGrantedRUTokens() []*GrantedRUTokenBucket + func (m *TokenBucketResponse) GetGrantedResourceTokens() []*GrantedRawResourceTokenBucket + func (m *TokenBucketResponse) GetResourceGroupName() string + func (m *TokenBucketResponse) Marshal() (dAtA []byte, err error) + func (m *TokenBucketResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketResponse) Reset() + func (m *TokenBucketResponse) Size() (n int) + func (m *TokenBucketResponse) String() string + func (m *TokenBucketResponse) Unmarshal(dAtA []byte) error + func (m *TokenBucketResponse) XXX_DiscardUnknown() + func (m *TokenBucketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenBucketResponse) XXX_Merge(src proto.Message) + func (m *TokenBucketResponse) XXX_Size() int + func (m *TokenBucketResponse) XXX_Unmarshal(b []byte) error + type TokenBucketsRequest struct + ClientUniqueId uint64 + Requests []*TokenBucketRequest + TargetRequestPeriodMs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenBucketsRequest) Descriptor() ([]byte, []int) + func (*TokenBucketsRequest) ProtoMessage() + func (m *TokenBucketsRequest) GetClientUniqueId() uint64 + func (m *TokenBucketsRequest) GetRequests() []*TokenBucketRequest + func (m *TokenBucketsRequest) GetTargetRequestPeriodMs() uint64 + func (m *TokenBucketsRequest) Marshal() (dAtA []byte, err error) + func (m *TokenBucketsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketsRequest) Reset() + func (m *TokenBucketsRequest) Size() (n int) + func (m *TokenBucketsRequest) String() string + func (m *TokenBucketsRequest) Unmarshal(dAtA []byte) error + func (m *TokenBucketsRequest) XXX_DiscardUnknown() + func (m *TokenBucketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenBucketsRequest) XXX_Merge(src proto.Message) + func (m *TokenBucketsRequest) XXX_Size() int + func (m *TokenBucketsRequest) XXX_Unmarshal(b []byte) error + type TokenBucketsResponse struct + Error *Error + Responses []*TokenBucketResponse + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenBucketsResponse) Descriptor() ([]byte, []int) + func (*TokenBucketsResponse) ProtoMessage() + func (m *TokenBucketsResponse) GetError() *Error + func (m *TokenBucketsResponse) GetResponses() []*TokenBucketResponse + func (m *TokenBucketsResponse) Marshal() (dAtA []byte, err error) + func (m *TokenBucketsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TokenBucketsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenBucketsResponse) Reset() + func (m *TokenBucketsResponse) Size() (n int) + func (m *TokenBucketsResponse) String() string + func (m *TokenBucketsResponse) Unmarshal(dAtA []byte) error + func (m *TokenBucketsResponse) XXX_DiscardUnknown() + func (m *TokenBucketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenBucketsResponse) XXX_Merge(src proto.Message) + func (m *TokenBucketsResponse) XXX_Size() int + func (m *TokenBucketsResponse) XXX_Unmarshal(b []byte) error + type TokenLimitSettings struct + BurstLimit int64 + FillRate uint64 + MaxTokens float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TokenLimitSettings) Descriptor() ([]byte, []int) + func (*TokenLimitSettings) ProtoMessage() + func (m *TokenLimitSettings) GetBurstLimit() int64 + func (m *TokenLimitSettings) GetFillRate() uint64 + func (m *TokenLimitSettings) GetMaxTokens() float64 + func (m *TokenLimitSettings) Marshal() (dAtA []byte, err error) + func (m *TokenLimitSettings) MarshalTo(dAtA []byte) (int, error) + func (m *TokenLimitSettings) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TokenLimitSettings) Reset() + func (m *TokenLimitSettings) Size() (n int) + func (m *TokenLimitSettings) String() string + func (m *TokenLimitSettings) Unmarshal(dAtA []byte) error + func (m *TokenLimitSettings) XXX_DiscardUnknown() + func (m *TokenLimitSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TokenLimitSettings) XXX_Merge(src proto.Message) + func (m *TokenLimitSettings) XXX_Size() int + func (m *TokenLimitSettings) XXX_Unmarshal(b []byte) error + type UnimplementedResourceManagerServer struct + func (*UnimplementedResourceManagerServer) AcquireTokenBuckets(srv ResourceManager_AcquireTokenBucketsServer) error + func (*UnimplementedResourceManagerServer) AddResourceGroup(ctx context.Context, req *PutResourceGroupRequest) (*PutResourceGroupResponse, error) + func (*UnimplementedResourceManagerServer) DeleteResourceGroup(ctx context.Context, req *DeleteResourceGroupRequest) (*DeleteResourceGroupResponse, error) + func (*UnimplementedResourceManagerServer) GetResourceGroup(ctx context.Context, req *GetResourceGroupRequest) (*GetResourceGroupResponse, error) + func (*UnimplementedResourceManagerServer) ListResourceGroups(ctx context.Context, req *ListResourceGroupsRequest) (*ListResourceGroupsResponse, error) + func (*UnimplementedResourceManagerServer) ModifyResourceGroup(ctx context.Context, req *PutResourceGroupRequest) (*PutResourceGroupResponse, error)