resource_manager

package
v0.0.0-...-e8eeb94 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 11 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthResourceManager        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourceManager          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResourceManager = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var GroupMode_name = map[int32]string{
	0: "Unknown",
	1: "RUMode",
	2: "RawMode",
}
View Source 
var GroupMode_value = map[string]int32{
	"Unknown": 0,
	"RUMode":  1,
	"RawMode": 2,
}
View Source 
var RawResourceType_name = map[int32]string{
	0: "CPU",
	1: "IOReadFlow",
	2: "IOWriteFlow",
}
View Source 
var RawResourceType_value = map[string]int32{
	"CPU":         0,
	"IOReadFlow":  1,
	"IOWriteFlow": 2,
}
View Source 
var RequestUnitType_name = map[int32]string{
	0: "RU",
}
View Source 
var RequestUnitType_value = map[string]int32{
	"RU": 0,
}
View Source 
var RunawayAction_name = map[int32]string{
	0: "NoneAction",
	1: "DryRun",
	2: "CoolDown",
	3: "Kill",
	4: "SwitchGroup",
}
View Source 
var RunawayAction_value = map[string]int32{
	"NoneAction":  0,
	"DryRun":      1,
	"CoolDown":    2,
	"Kill":        3,
	"SwitchGroup": 4,
}
View Source 
var RunawayWatchType_name = map[int32]string{
	0: "NoneWatch",
	1: "Exact",
	2: "Similar",
	3: "Plan",
}
View Source 
var RunawayWatchType_value = map[string]int32{
	"NoneWatch": 0,
	"Exact":     1,
	"Similar":   2,
	"Plan":      3,
}

Functions

func RegisterResourceManagerServer 

func RegisterResourceManagerServer(s *grpc.Server, srv ResourceManagerServer)

Types

type BackgroundSettings 

type BackgroundSettings struct {
	// background task types.
	JobTypes []string `protobuf:"bytes,1,rep,name=job_types,json=jobTypes,proto3" json:"job_types,omitempty"`
	// the percentage limit of total resource(cpu/io) that background tasks can use.
	UtilizationLimit uint64 `protobuf:"varint,2,opt,name=utilization_limit,json=utilizationLimit,proto3" json:"utilization_limit,omitempty"`
}

func (*BackgroundSettings) Descriptor 

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

func (*BackgroundSettings) GetJobTypes 

func (m *BackgroundSettings) GetJobTypes() []string

func (*BackgroundSettings) GetUtilizationLimit 

func (m *BackgroundSettings) GetUtilizationLimit() uint64

func (*BackgroundSettings) Marshal 

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

func (*BackgroundSettings) MarshalTo 

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

func (*BackgroundSettings) MarshalToSizedBuffer 

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

func (*BackgroundSettings) ProtoMessage 

func (*BackgroundSettings) ProtoMessage()

func (*BackgroundSettings) Reset 

func (m *BackgroundSettings) Reset()

func (*BackgroundSettings) Size 

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

func (*BackgroundSettings) String 

func (m *BackgroundSettings) String() string

func (*BackgroundSettings) Unmarshal 

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

func (*BackgroundSettings) XXX_DiscardUnknown 

func (m *BackgroundSettings) XXX_DiscardUnknown()

func (*BackgroundSettings) XXX_Marshal 

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

func (*BackgroundSettings) XXX_Merge 

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

func (*BackgroundSettings) XXX_Size 

func (m *BackgroundSettings) XXX_Size() int

func (*BackgroundSettings) XXX_Unmarshal 

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

type Consumption 

type Consumption struct {
	RRU               float64 `protobuf:"fixed64,1,opt,name=r_r_u,json=rRU,proto3" json:"r_r_u,omitempty"`
	WRU               float64 `protobuf:"fixed64,2,opt,name=w_r_u,json=wRU,proto3" json:"w_r_u,omitempty"`
	ReadBytes         float64 `protobuf:"fixed64,3,opt,name=read_bytes,json=readBytes,proto3" json:"read_bytes,omitempty"`
	WriteBytes        float64 `protobuf:"fixed64,4,opt,name=write_bytes,json=writeBytes,proto3" json:"write_bytes,omitempty"`
	TotalCpuTimeMs    float64 `protobuf:"fixed64,5,opt,name=total_cpu_time_ms,json=totalCpuTimeMs,proto3" json:"total_cpu_time_ms,omitempty"`
	SqlLayerCpuTimeMs float64 `protobuf:"fixed64,6,opt,name=sql_layer_cpu_time_ms,json=sqlLayerCpuTimeMs,proto3" json:"sql_layer_cpu_time_ms,omitempty"`
	KvReadRpcCount    float64 `protobuf:"fixed64,7,opt,name=kv_read_rpc_count,json=kvReadRpcCount,proto3" json:"kv_read_rpc_count,omitempty"`
	KvWriteRpcCount   float64 `protobuf:"fixed64,8,opt,name=kv_write_rpc_count,json=kvWriteRpcCount,proto3" json:"kv_write_rpc_count,omitempty"`
}

func (*Consumption) Descriptor 

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

func (*Consumption) GetKvReadRpcCount 

func (m *Consumption) GetKvReadRpcCount() float64

func (*Consumption) GetKvWriteRpcCount 

func (m *Consumption) GetKvWriteRpcCount() float64

func (*Consumption) GetRRU 

func (m *Consumption) GetRRU() float64

func (*Consumption) GetReadBytes 

func (m *Consumption) GetReadBytes() float64

func (*Consumption) GetSqlLayerCpuTimeMs 

func (m *Consumption) GetSqlLayerCpuTimeMs() float64

func (*Consumption) GetTotalCpuTimeMs 

func (m *Consumption) GetTotalCpuTimeMs() float64

func (*Consumption) GetWRU 

func (m *Consumption) GetWRU() float64

func (*Consumption) GetWriteBytes 

func (m *Consumption) GetWriteBytes() float64

func (*Consumption) Marshal 

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

func (*Consumption) MarshalTo 

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

func (*Consumption) MarshalToSizedBuffer 

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

func (*Consumption) ProtoMessage 

func (*Consumption) ProtoMessage()

func (*Consumption) Reset 

func (m *Consumption) Reset()

func (*Consumption) Size 

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

func (*Consumption) String 

func (m *Consumption) String() string

func (*Consumption) Unmarshal 

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

func (*Consumption) XXX_DiscardUnknown 

func (m *Consumption) XXX_DiscardUnknown()

func (*Consumption) XXX_Marshal 

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

func (*Consumption) XXX_Merge 

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

func (*Consumption) XXX_Size 

func (m *Consumption) XXX_Size() int

func (*Consumption) XXX_Unmarshal 

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

type DeleteResourceGroupRequest 

type DeleteResourceGroupRequest struct {
	ResourceGroupName string `protobuf:"bytes,1,opt,name=resource_group_name,json=resourceGroupName,proto3" json:"resource_group_name,omitempty"`
}

func (*DeleteResourceGroupRequest) Descriptor 

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

func (*DeleteResourceGroupRequest) GetResourceGroupName 

func (m *DeleteResourceGroupRequest) GetResourceGroupName() string

func (*DeleteResourceGroupRequest) Marshal 

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

func (*DeleteResourceGroupRequest) MarshalTo 

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

func (*DeleteResourceGroupRequest) MarshalToSizedBuffer 

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

func (*DeleteResourceGroupRequest) ProtoMessage 

func (*DeleteResourceGroupRequest) ProtoMessage()

func (*DeleteResourceGroupRequest) Reset 

func (m *DeleteResourceGroupRequest) Reset()

func (*DeleteResourceGroupRequest) Size 

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

func (*DeleteResourceGroupRequest) String 

func (m *DeleteResourceGroupRequest) String() string

func (*DeleteResourceGroupRequest) Unmarshal 

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

func (*DeleteResourceGroupRequest) XXX_DiscardUnknown 

func (m *DeleteResourceGroupRequest) XXX_DiscardUnknown()

func (*DeleteResourceGroupRequest) XXX_Marshal 

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

func (*DeleteResourceGroupRequest) XXX_Merge 

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

func (*DeleteResourceGroupRequest) XXX_Size 

func (m *DeleteResourceGroupRequest) XXX_Size() int

func (*DeleteResourceGroupRequest) XXX_Unmarshal 

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

type DeleteResourceGroupResponse 

type DeleteResourceGroupResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Body  string `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}

func (*DeleteResourceGroupResponse) Descriptor 

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

func (*DeleteResourceGroupResponse) GetBody 

func (m *DeleteResourceGroupResponse) GetBody() string

func (*DeleteResourceGroupResponse) GetError 

func (m *DeleteResourceGroupResponse) GetError() *Error

func (*DeleteResourceGroupResponse) Marshal 

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

func (*DeleteResourceGroupResponse) MarshalTo 

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

func (*DeleteResourceGroupResponse) MarshalToSizedBuffer 

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

func (*DeleteResourceGroupResponse) ProtoMessage 

func (*DeleteResourceGroupResponse) ProtoMessage()

func (*DeleteResourceGroupResponse) Reset 

func (m *DeleteResourceGroupResponse) Reset()

func (*DeleteResourceGroupResponse) Size 

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

func (*DeleteResourceGroupResponse) String 

func (m *DeleteResourceGroupResponse) String() string

func (*DeleteResourceGroupResponse) Unmarshal 

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

func (*DeleteResourceGroupResponse) XXX_DiscardUnknown 

func (m *DeleteResourceGroupResponse) XXX_DiscardUnknown()

func (*DeleteResourceGroupResponse) XXX_Marshal 

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

func (*DeleteResourceGroupResponse) XXX_Merge 

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

func (*DeleteResourceGroupResponse) XXX_Size 

func (m *DeleteResourceGroupResponse) XXX_Size() int

func (*DeleteResourceGroupResponse) XXX_Unmarshal 

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

type Error 

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*Error) Descriptor 

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

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type GetResourceGroupRequest 

type GetResourceGroupRequest struct {
	ResourceGroupName string `protobuf:"bytes,1,opt,name=resource_group_name,json=resourceGroupName,proto3" json:"resource_group_name,omitempty"`
	WithRuStats       bool   `protobuf:"varint,2,opt,name=with_ru_stats,json=withRuStats,proto3" json:"with_ru_stats,omitempty"`
}

func (*GetResourceGroupRequest) Descriptor 

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

func (*GetResourceGroupRequest) GetResourceGroupName 

func (m *GetResourceGroupRequest) GetResourceGroupName() string

func (*GetResourceGroupRequest) GetWithRuStats 

func (m *GetResourceGroupRequest) GetWithRuStats() bool

func (*GetResourceGroupRequest) Marshal 

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

func (*GetResourceGroupRequest) MarshalTo 

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

func (*GetResourceGroupRequest) MarshalToSizedBuffer 

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

func (*GetResourceGroupRequest) ProtoMessage 

func (*GetResourceGroupRequest) ProtoMessage()

func (*GetResourceGroupRequest) Reset 

func (m *GetResourceGroupRequest) Reset()

func (*GetResourceGroupRequest) Size 

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

func (*GetResourceGroupRequest) String 

func (m *GetResourceGroupRequest) String() string

func (*GetResourceGroupRequest) Unmarshal 

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

func (*GetResourceGroupRequest) XXX_DiscardUnknown 

func (m *GetResourceGroupRequest) XXX_DiscardUnknown()

func (*GetResourceGroupRequest) XXX_Marshal 

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

func (*GetResourceGroupRequest) XXX_Merge 

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

func (*GetResourceGroupRequest) XXX_Size 

func (m *GetResourceGroupRequest) XXX_Size() int

func (*GetResourceGroupRequest) XXX_Unmarshal 

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

type GetResourceGroupResponse 

type GetResourceGroupResponse struct {
	Error *Error         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Group *ResourceGroup `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
}

func (*GetResourceGroupResponse) Descriptor 

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

func (*GetResourceGroupResponse) GetError 

func (m *GetResourceGroupResponse) GetError() *Error

func (*GetResourceGroupResponse) GetGroup 

func (m *GetResourceGroupResponse) GetGroup() *ResourceGroup

func (*GetResourceGroupResponse) Marshal 

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

func (*GetResourceGroupResponse) MarshalTo 

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

func (*GetResourceGroupResponse) MarshalToSizedBuffer 

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

func (*GetResourceGroupResponse) ProtoMessage 

func (*GetResourceGroupResponse) ProtoMessage()

func (*GetResourceGroupResponse) Reset 

func (m *GetResourceGroupResponse) Reset()

func (*GetResourceGroupResponse) Size 

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

func (*GetResourceGroupResponse) String 

func (m *GetResourceGroupResponse) String() string

func (*GetResourceGroupResponse) Unmarshal 

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

func (*GetResourceGroupResponse) XXX_DiscardUnknown 

func (m *GetResourceGroupResponse) XXX_DiscardUnknown()

func (*GetResourceGroupResponse) XXX_Marshal 

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

func (*GetResourceGroupResponse) XXX_Merge 

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

func (*GetResourceGroupResponse) XXX_Size 

func (m *GetResourceGroupResponse) XXX_Size() int

func (*GetResourceGroupResponse) XXX_Unmarshal 

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

type GrantedRUTokenBucket 

type GrantedRUTokenBucket struct {
	Type          RequestUnitType `protobuf:"varint,1,opt,name=type,proto3,enum=resource_manager.RequestUnitType" json:"type,omitempty"`
	GrantedTokens *TokenBucket    `protobuf:"bytes,2,opt,name=granted_tokens,json=grantedTokens,proto3" json:"granted_tokens,omitempty"`
	TrickleTimeMs int64           `protobuf:"varint,3,opt,name=trickle_time_ms,json=trickleTimeMs,proto3" json:"trickle_time_ms,omitempty"`
}

func (*GrantedRUTokenBucket) Descriptor 

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

func (*GrantedRUTokenBucket) GetGrantedTokens 

func (m *GrantedRUTokenBucket) GetGrantedTokens() *TokenBucket

func (*GrantedRUTokenBucket) GetTrickleTimeMs 

func (m *GrantedRUTokenBucket) GetTrickleTimeMs() int64

func (*GrantedRUTokenBucket) GetType 

func (m *GrantedRUTokenBucket) GetType() RequestUnitType

func (*GrantedRUTokenBucket) Marshal 

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

func (*GrantedRUTokenBucket) MarshalTo 

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

func (*GrantedRUTokenBucket) MarshalToSizedBuffer 

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

func (*GrantedRUTokenBucket) ProtoMessage 

func (*GrantedRUTokenBucket) ProtoMessage()

func (*GrantedRUTokenBucket) Reset 

func (m *GrantedRUTokenBucket) Reset()

func (*GrantedRUTokenBucket) Size 

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

func (*GrantedRUTokenBucket) String 

func (m *GrantedRUTokenBucket) String() string

func (*GrantedRUTokenBucket) Unmarshal 

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

func (*GrantedRUTokenBucket) XXX_DiscardUnknown 

func (m *GrantedRUTokenBucket) XXX_DiscardUnknown()

func (*GrantedRUTokenBucket) XXX_Marshal 

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

func (*GrantedRUTokenBucket) XXX_Merge 

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

func (*GrantedRUTokenBucket) XXX_Size 

func (m *GrantedRUTokenBucket) XXX_Size() int

func (*GrantedRUTokenBucket) XXX_Unmarshal 

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

type GrantedRawResourceTokenBucket 

type GrantedRawResourceTokenBucket struct {
	Type          RawResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=resource_manager.RawResourceType" json:"type,omitempty"`
	GrantedTokens *TokenBucket    `protobuf:"bytes,2,opt,name=granted_tokens,json=grantedTokens,proto3" json:"granted_tokens,omitempty"`
	TrickleTimeMs int64           `protobuf:"varint,3,opt,name=trickle_time_ms,json=trickleTimeMs,proto3" json:"trickle_time_ms,omitempty"`
}

func (*GrantedRawResourceTokenBucket) Descriptor 

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

func (*GrantedRawResourceTokenBucket) GetGrantedTokens 

func (m *GrantedRawResourceTokenBucket) GetGrantedTokens() *TokenBucket

func (*GrantedRawResourceTokenBucket) GetTrickleTimeMs 

func (m *GrantedRawResourceTokenBucket) GetTrickleTimeMs() int64

func (*GrantedRawResourceTokenBucket) GetType 

func (m *GrantedRawResourceTokenBucket) GetType() RawResourceType

func (*GrantedRawResourceTokenBucket) Marshal 

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

func (*GrantedRawResourceTokenBucket) MarshalTo 

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

func (*GrantedRawResourceTokenBucket) MarshalToSizedBuffer 

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

func (*GrantedRawResourceTokenBucket) ProtoMessage 

func (*GrantedRawResourceTokenBucket) ProtoMessage()

func (*GrantedRawResourceTokenBucket) Reset 

func (m *GrantedRawResourceTokenBucket) Reset()

func (*GrantedRawResourceTokenBucket) Size 

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

func (*GrantedRawResourceTokenBucket) String 

func (m *GrantedRawResourceTokenBucket) String() string

func (*GrantedRawResourceTokenBucket) Unmarshal 

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

func (*GrantedRawResourceTokenBucket) XXX_DiscardUnknown 

func (m *GrantedRawResourceTokenBucket) XXX_DiscardUnknown()

func (*GrantedRawResourceTokenBucket) XXX_Marshal 

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

func (*GrantedRawResourceTokenBucket) XXX_Merge 

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

func (*GrantedRawResourceTokenBucket) XXX_Size 

func (m *GrantedRawResourceTokenBucket) XXX_Size() int

func (*GrantedRawResourceTokenBucket) XXX_Unmarshal 

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

type GroupMode 

type GroupMode int32
const (
	GroupMode_Unknown GroupMode = 0
	GroupMode_RUMode  GroupMode = 1
	GroupMode_RawMode GroupMode = 2
)

func (GroupMode) EnumDescriptor 

func (GroupMode) EnumDescriptor() ([]byte, []int)

func (GroupMode) String 

func (x GroupMode) String() string

type GroupRawResourceSettings 

type GroupRawResourceSettings struct {
	Cpu     *TokenBucket `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	IoRead  *TokenBucket `protobuf:"bytes,2,opt,name=io_read,json=ioRead,proto3" json:"io_read,omitempty"`
	IoWrite *TokenBucket `protobuf:"bytes,3,opt,name=io_write,json=ioWrite,proto3" json:"io_write,omitempty"`
}

func (*GroupRawResourceSettings) Descriptor 

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

func (*GroupRawResourceSettings) GetCpu 

func (m *GroupRawResourceSettings) GetCpu() *TokenBucket

func (*GroupRawResourceSettings) GetIoRead 

func (m *GroupRawResourceSettings) GetIoRead() *TokenBucket

func (*GroupRawResourceSettings) GetIoWrite 

func (m *GroupRawResourceSettings) GetIoWrite() *TokenBucket

func (*GroupRawResourceSettings) Marshal 

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

func (*GroupRawResourceSettings) MarshalTo 

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

func (*GroupRawResourceSettings) MarshalToSizedBuffer 

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

func (*GroupRawResourceSettings) ProtoMessage 

func (*GroupRawResourceSettings) ProtoMessage()

func (*GroupRawResourceSettings) Reset 

func (m *GroupRawResourceSettings) Reset()

func (*GroupRawResourceSettings) Size 

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

func (*GroupRawResourceSettings) String 

func (m *GroupRawResourceSettings) String() string

func (*GroupRawResourceSettings) Unmarshal 

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

func (*GroupRawResourceSettings) XXX_DiscardUnknown 

func (m *GroupRawResourceSettings) XXX_DiscardUnknown()

func (*GroupRawResourceSettings) XXX_Marshal 

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

func (*GroupRawResourceSettings) XXX_Merge 

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

func (*GroupRawResourceSettings) XXX_Size 

func (m *GroupRawResourceSettings) XXX_Size() int

func (*GroupRawResourceSettings) XXX_Unmarshal 

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

type GroupRequestUnitSettings 

type GroupRequestUnitSettings struct {
	RU *TokenBucket `protobuf:"bytes,1,opt,name=r_u,json=rU,proto3" json:"r_u,omitempty"`
}

func (*GroupRequestUnitSettings) Descriptor 

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

func (*GroupRequestUnitSettings) GetRU 

func (m *GroupRequestUnitSettings) GetRU() *TokenBucket

func (*GroupRequestUnitSettings) Marshal 

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

func (*GroupRequestUnitSettings) MarshalTo 

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

func (*GroupRequestUnitSettings) MarshalToSizedBuffer 

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

func (*GroupRequestUnitSettings) ProtoMessage 

func (*GroupRequestUnitSettings) ProtoMessage()

func (*GroupRequestUnitSettings) Reset 

func (m *GroupRequestUnitSettings) Reset()

func (*GroupRequestUnitSettings) Size 

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

func (*GroupRequestUnitSettings) String 

func (m *GroupRequestUnitSettings) String() string

func (*GroupRequestUnitSettings) Unmarshal 

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

func (*GroupRequestUnitSettings) XXX_DiscardUnknown 

func (m *GroupRequestUnitSettings) XXX_DiscardUnknown()

func (*GroupRequestUnitSettings) XXX_Marshal 

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

func (*GroupRequestUnitSettings) XXX_Merge 

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

func (*GroupRequestUnitSettings) XXX_Size 

func (m *GroupRequestUnitSettings) XXX_Size() int

func (*GroupRequestUnitSettings) XXX_Unmarshal 

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

type ListResourceGroupsRequest 

type ListResourceGroupsRequest struct {
	WithRuStats bool `protobuf:"varint,1,opt,name=with_ru_stats,json=withRuStats,proto3" json:"with_ru_stats,omitempty"`
}

func (*ListResourceGroupsRequest) Descriptor 

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

func (*ListResourceGroupsRequest) GetWithRuStats 

func (m *ListResourceGroupsRequest) GetWithRuStats() bool

func (*ListResourceGroupsRequest) Marshal 

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

func (*ListResourceGroupsRequest) MarshalTo 

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

func (*ListResourceGroupsRequest) MarshalToSizedBuffer 

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

func (*ListResourceGroupsRequest) ProtoMessage 

func (*ListResourceGroupsRequest) ProtoMessage()

func (*ListResourceGroupsRequest) Reset 

func (m *ListResourceGroupsRequest) Reset()

func (*ListResourceGroupsRequest) Size 

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

func (*ListResourceGroupsRequest) String 

func (m *ListResourceGroupsRequest) String() string

func (*ListResourceGroupsRequest) Unmarshal 

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

func (*ListResourceGroupsRequest) XXX_DiscardUnknown 

func (m *ListResourceGroupsRequest) XXX_DiscardUnknown()

func (*ListResourceGroupsRequest) XXX_Marshal 

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

func (*ListResourceGroupsRequest) XXX_Merge 

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

func (*ListResourceGroupsRequest) XXX_Size 

func (m *ListResourceGroupsRequest) XXX_Size() int

func (*ListResourceGroupsRequest) XXX_Unmarshal 

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

type ListResourceGroupsResponse 

type ListResourceGroupsResponse struct {
	Error  *Error           `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Groups []*ResourceGroup `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
}

func (*ListResourceGroupsResponse) Descriptor 

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

func (*ListResourceGroupsResponse) GetError 

func (m *ListResourceGroupsResponse) GetError() *Error

func (*ListResourceGroupsResponse) GetGroups 

func (m *ListResourceGroupsResponse) GetGroups() []*ResourceGroup

func (*ListResourceGroupsResponse) Marshal 

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

func (*ListResourceGroupsResponse) MarshalTo 

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

func (*ListResourceGroupsResponse) MarshalToSizedBuffer 

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

func (*ListResourceGroupsResponse) ProtoMessage 

func (*ListResourceGroupsResponse) ProtoMessage()

func (*ListResourceGroupsResponse) Reset 

func (m *ListResourceGroupsResponse) Reset()

func (*ListResourceGroupsResponse) Size 

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

func (*ListResourceGroupsResponse) String 

func (m *ListResourceGroupsResponse) String() string

func (*ListResourceGroupsResponse) Unmarshal 

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

func (*ListResourceGroupsResponse) XXX_DiscardUnknown 

func (m *ListResourceGroupsResponse) XXX_DiscardUnknown()

func (*ListResourceGroupsResponse) XXX_Marshal 

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

func (*ListResourceGroupsResponse) XXX_Merge 

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

func (*ListResourceGroupsResponse) XXX_Size 

func (m *ListResourceGroupsResponse) XXX_Size() int

func (*ListResourceGroupsResponse) XXX_Unmarshal 

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

type Participant 

type Participant struct {
	// name is the unique name of the resource manager participant.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// id is the unique id of the resource manager participant.
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// listen_urls is the serivce endpoint list in the url format.
	// listen_urls[0] is primary service endpoint.
	ListenUrls []string `protobuf:"bytes,3,rep,name=listen_urls,json=listenUrls,proto3" json:"listen_urls,omitempty"`
}

func (*Participant) Descriptor 

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

func (*Participant) GetId 

func (m *Participant) GetId() uint64

func (*Participant) GetListenUrls 

func (m *Participant) GetListenUrls() []string

func (*Participant) GetName 

func (m *Participant) GetName() string

func (*Participant) Marshal 

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

func (*Participant) MarshalTo 

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

func (*Participant) MarshalToSizedBuffer 

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

func (*Participant) ProtoMessage 

func (*Participant) ProtoMessage()

func (*Participant) Reset 

func (m *Participant) Reset()

func (*Participant) Size 

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

func (*Participant) String 

func (m *Participant) String() string

func (*Participant) Unmarshal 

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

func (*Participant) XXX_DiscardUnknown 

func (m *Participant) XXX_DiscardUnknown()

func (*Participant) XXX_Marshal 

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

func (*Participant) XXX_Merge 

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

func (*Participant) XXX_Size 

func (m *Participant) XXX_Size() int

func (*Participant) XXX_Unmarshal 

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

type PutResourceGroupRequest 

type PutResourceGroupRequest struct {
	Group *ResourceGroup `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
}

func (*PutResourceGroupRequest) Descriptor 

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

func (*PutResourceGroupRequest) GetGroup 

func (m *PutResourceGroupRequest) GetGroup() *ResourceGroup

func (*PutResourceGroupRequest) Marshal 

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

func (*PutResourceGroupRequest) MarshalTo 

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

func (*PutResourceGroupRequest) MarshalToSizedBuffer 

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

func (*PutResourceGroupRequest) ProtoMessage 

func (*PutResourceGroupRequest) ProtoMessage()

func (*PutResourceGroupRequest) Reset 

func (m *PutResourceGroupRequest) Reset()

func (*PutResourceGroupRequest) Size 

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

func (*PutResourceGroupRequest) String 

func (m *PutResourceGroupRequest) String() string

func (*PutResourceGroupRequest) Unmarshal 

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

func (*PutResourceGroupRequest) XXX_DiscardUnknown 

func (m *PutResourceGroupRequest) XXX_DiscardUnknown()

func (*PutResourceGroupRequest) XXX_Marshal 

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

func (*PutResourceGroupRequest) XXX_Merge 

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

func (*PutResourceGroupRequest) XXX_Size 

func (m *PutResourceGroupRequest) XXX_Size() int

func (*PutResourceGroupRequest) XXX_Unmarshal 

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

type PutResourceGroupResponse 

type PutResourceGroupResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Body  string `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
}

func (*PutResourceGroupResponse) Descriptor 

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

func (*PutResourceGroupResponse) GetBody 

func (m *PutResourceGroupResponse) GetBody() string

func (*PutResourceGroupResponse) GetError 

func (m *PutResourceGroupResponse) GetError() *Error

func (*PutResourceGroupResponse) Marshal 

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

func (*PutResourceGroupResponse) MarshalTo 

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

func (*PutResourceGroupResponse) MarshalToSizedBuffer 

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

func (*PutResourceGroupResponse) ProtoMessage 

func (*PutResourceGroupResponse) ProtoMessage()

func (*PutResourceGroupResponse) Reset 

func (m *PutResourceGroupResponse) Reset()

func (*PutResourceGroupResponse) Size 

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

func (*PutResourceGroupResponse) String 

func (m *PutResourceGroupResponse) String() string

func (*PutResourceGroupResponse) Unmarshal 

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

func (*PutResourceGroupResponse) XXX_DiscardUnknown 

func (m *PutResourceGroupResponse) XXX_DiscardUnknown()

func (*PutResourceGroupResponse) XXX_Marshal 

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

func (*PutResourceGroupResponse) XXX_Merge 

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

func (*PutResourceGroupResponse) XXX_Size 

func (m *PutResourceGroupResponse) XXX_Size() int

func (*PutResourceGroupResponse) XXX_Unmarshal 

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

type RawResourceItem 

type RawResourceItem struct {
	Type  RawResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=resource_manager.RawResourceType" json:"type,omitempty"`
	Value float64         `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RawResourceItem) Descriptor 

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

func (*RawResourceItem) GetType 

func (m *RawResourceItem) GetType() RawResourceType

func (*RawResourceItem) GetValue 

func (m *RawResourceItem) GetValue() float64

func (*RawResourceItem) Marshal 

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

func (*RawResourceItem) MarshalTo 

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

func (*RawResourceItem) MarshalToSizedBuffer 

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

func (*RawResourceItem) ProtoMessage 

func (*RawResourceItem) ProtoMessage()

func (*RawResourceItem) Reset 

func (m *RawResourceItem) Reset()

func (*RawResourceItem) Size 

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

func (*RawResourceItem) String 

func (m *RawResourceItem) String() string

func (*RawResourceItem) Unmarshal 

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

func (*RawResourceItem) XXX_DiscardUnknown 

func (m *RawResourceItem) XXX_DiscardUnknown()

func (*RawResourceItem) XXX_Marshal 

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

func (*RawResourceItem) XXX_Merge 

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

func (*RawResourceItem) XXX_Size 

func (m *RawResourceItem) XXX_Size() int

func (*RawResourceItem) XXX_Unmarshal 

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

type RawResourceType 

type RawResourceType int32
const (
	RawResourceType_CPU         RawResourceType = 0
	RawResourceType_IOReadFlow  RawResourceType = 1
	RawResourceType_IOWriteFlow RawResourceType = 2
)

func (RawResourceType) EnumDescriptor 

func (RawResourceType) EnumDescriptor() ([]byte, []int)

func (RawResourceType) String 

func (x RawResourceType) String() string

type RequestUnitItem 

type RequestUnitItem struct {
	Type  RequestUnitType `protobuf:"varint,1,opt,name=type,proto3,enum=resource_manager.RequestUnitType" json:"type,omitempty"`
	Value float64         `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*RequestUnitItem) Descriptor 

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

func (*RequestUnitItem) GetType 

func (m *RequestUnitItem) GetType() RequestUnitType

func (*RequestUnitItem) GetValue 

func (m *RequestUnitItem) GetValue() float64

func (*RequestUnitItem) Marshal 

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

func (*RequestUnitItem) MarshalTo 

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

func (*RequestUnitItem) MarshalToSizedBuffer 

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

func (*RequestUnitItem) ProtoMessage 

func (*RequestUnitItem) ProtoMessage()

func (*RequestUnitItem) Reset 

func (m *RequestUnitItem) Reset()

func (*RequestUnitItem) Size 

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

func (*RequestUnitItem) String 

func (m *RequestUnitItem) String() string

func (*RequestUnitItem) Unmarshal 

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

func (*RequestUnitItem) XXX_DiscardUnknown 

func (m *RequestUnitItem) XXX_DiscardUnknown()

func (*RequestUnitItem) XXX_Marshal 

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

func (*RequestUnitItem) XXX_Merge 

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

func (*RequestUnitItem) XXX_Size 

func (m *RequestUnitItem) XXX_Size() int

func (*RequestUnitItem) XXX_Unmarshal 

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

type RequestUnitType 

type RequestUnitType int32
const (
	RequestUnitType_RU RequestUnitType = 0
)

func (RequestUnitType) EnumDescriptor 

func (RequestUnitType) EnumDescriptor() ([]byte, []int)

func (RequestUnitType) String 

func (x RequestUnitType) String() string

type ResourceGroup 

type ResourceGroup struct {
	Name string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mode GroupMode `protobuf:"varint,2,opt,name=mode,proto3,enum=resource_manager.GroupMode" json:"mode,omitempty"`
	// Used in RU mode, group settings with WRU/RRU etc resource abstract unit.
	RUSettings *GroupRequestUnitSettings `protobuf:"bytes,3,opt,name=r_u_settings,json=rUSettings,proto3" json:"r_u_settings,omitempty"`
	// Used in Raw mode, group settings with CPU/IO etc resource unit.
	RawResourceSettings *GroupRawResourceSettings `protobuf:"bytes,4,opt,name=raw_resource_settings,json=rawResourceSettings,proto3" json:"raw_resource_settings,omitempty"`
	// The task scheduling priority
	Priority uint32 `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	// Runaway queries settings
	RunawaySettings *RunawaySettings `protobuf:"bytes,6,opt,name=runaway_settings,json=runawaySettings,proto3" json:"runaway_settings,omitempty"`
	// Background task control settings.
	BackgroundSettings *BackgroundSettings `protobuf:"bytes,7,opt,name=background_settings,json=backgroundSettings,proto3" json:"background_settings,omitempty"`
	// RU consumption statistics.
	RUStats *Consumption `protobuf:"bytes,8,opt,name=RUStats,proto3" json:"RUStats,omitempty"`
}

ResourceGroup the settings definitions.

func (*ResourceGroup) Descriptor 

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

func (*ResourceGroup) GetBackgroundSettings 

func (m *ResourceGroup) GetBackgroundSettings() *BackgroundSettings

func (*ResourceGroup) GetMode 

func (m *ResourceGroup) GetMode() GroupMode

func (*ResourceGroup) GetName 

func (m *ResourceGroup) GetName() string

func (*ResourceGroup) GetPriority 

func (m *ResourceGroup) GetPriority() uint32

func (*ResourceGroup) GetRUSettings 

func (m *ResourceGroup) GetRUSettings() *GroupRequestUnitSettings

func (*ResourceGroup) GetRUStats 

func (m *ResourceGroup) GetRUStats() *Consumption

func (*ResourceGroup) GetRawResourceSettings 

func (m *ResourceGroup) GetRawResourceSettings() *GroupRawResourceSettings

func (*ResourceGroup) GetRunawaySettings 

func (m *ResourceGroup) GetRunawaySettings() *RunawaySettings

func (*ResourceGroup) Marshal 

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

func (*ResourceGroup) MarshalTo 

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

func (*ResourceGroup) MarshalToSizedBuffer 

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

func (*ResourceGroup) ProtoMessage 

func (*ResourceGroup) ProtoMessage()

func (*ResourceGroup) Reset 

func (m *ResourceGroup) Reset()

func (*ResourceGroup) Size 

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

func (*ResourceGroup) String 

func (m *ResourceGroup) String() string

func (*ResourceGroup) Unmarshal 

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

func (*ResourceGroup) XXX_DiscardUnknown 

func (m *ResourceGroup) XXX_DiscardUnknown()

func (*ResourceGroup) XXX_Marshal 

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

func (*ResourceGroup) XXX_Merge 

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

func (*ResourceGroup) XXX_Size 

func (m *ResourceGroup) XXX_Size() int

func (*ResourceGroup) XXX_Unmarshal 

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

type ResourceManagerClient 

type ResourceManagerClient interface {
	ListResourceGroups(ctx context.Context, in *ListResourceGroupsRequest, opts ...grpc.CallOption) (*ListResourceGroupsResponse, error)
	GetResourceGroup(ctx context.Context, in *GetResourceGroupRequest, opts ...grpc.CallOption) (*GetResourceGroupResponse, error)
	AddResourceGroup(ctx context.Context, in *PutResourceGroupRequest, opts ...grpc.CallOption) (*PutResourceGroupResponse, error)
	ModifyResourceGroup(ctx context.Context, in *PutResourceGroupRequest, opts ...grpc.CallOption) (*PutResourceGroupResponse, error)
	DeleteResourceGroup(ctx context.Context, in *DeleteResourceGroupRequest, opts ...grpc.CallOption) (*DeleteResourceGroupResponse, error)
	AcquireTokenBuckets(ctx context.Context, opts ...grpc.CallOption) (ResourceManager_AcquireTokenBucketsClient, error)
}

ResourceManagerClient is the client API for ResourceManager service.

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

func NewResourceManagerClient 

func NewResourceManagerClient(cc *grpc.ClientConn) ResourceManagerClient

type ResourceManagerServer 

type ResourceManagerServer interface {
	ListResourceGroups(context.Context, *ListResourceGroupsRequest) (*ListResourceGroupsResponse, error)
	GetResourceGroup(context.Context, *GetResourceGroupRequest) (*GetResourceGroupResponse, error)
	AddResourceGroup(context.Context, *PutResourceGroupRequest) (*PutResourceGroupResponse, error)
	ModifyResourceGroup(context.Context, *PutResourceGroupRequest) (*PutResourceGroupResponse, error)
	DeleteResourceGroup(context.Context, *DeleteResourceGroupRequest) (*DeleteResourceGroupResponse, error)
	AcquireTokenBuckets(ResourceManager_AcquireTokenBucketsServer) error
}

ResourceManagerServer is the server API for ResourceManager service.

type ResourceManager_AcquireTokenBucketsClient 

type ResourceManager_AcquireTokenBucketsClient interface {
	Send(*TokenBucketsRequest) error
	Recv() (*TokenBucketsResponse, error)
	grpc.ClientStream
}

type ResourceManager_AcquireTokenBucketsServer 

type ResourceManager_AcquireTokenBucketsServer interface {
	Send(*TokenBucketsResponse) error
	Recv() (*TokenBucketsRequest, error)
	grpc.ServerStream
}

type RunawayAction 

type RunawayAction int32
const (
	RunawayAction_NoneAction  RunawayAction = 0
	RunawayAction_DryRun      RunawayAction = 1
	RunawayAction_CoolDown    RunawayAction = 2
	RunawayAction_Kill        RunawayAction = 3
	RunawayAction_SwitchGroup RunawayAction = 4
)

func (RunawayAction) EnumDescriptor 

func (RunawayAction) EnumDescriptor() ([]byte, []int)

func (RunawayAction) String 

func (x RunawayAction) String() string

type RunawayRule 

type RunawayRule struct {
	ExecElapsedTimeMs uint64 `protobuf:"varint,1,opt,name=exec_elapsed_time_ms,json=execElapsedTimeMs,proto3" json:"exec_elapsed_time_ms,omitempty"`
	ProcessedKeys     int64  `protobuf:"varint,2,opt,name=processed_keys,json=processedKeys,proto3" json:"processed_keys,omitempty"`
	RequestUnit       int64  `protobuf:"varint,3,opt,name=request_unit,json=requestUnit,proto3" json:"request_unit,omitempty"`
}

func (*RunawayRule) Descriptor 

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

func (*RunawayRule) GetExecElapsedTimeMs 

func (m *RunawayRule) GetExecElapsedTimeMs() uint64

func (*RunawayRule) GetProcessedKeys 

func (m *RunawayRule) GetProcessedKeys() int64

func (*RunawayRule) GetRequestUnit 

func (m *RunawayRule) GetRequestUnit() int64

func (*RunawayRule) Marshal 

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

func (*RunawayRule) MarshalTo 

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

func (*RunawayRule) MarshalToSizedBuffer 

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

func (*RunawayRule) ProtoMessage 

func (*RunawayRule) ProtoMessage()

func (*RunawayRule) Reset 

func (m *RunawayRule) Reset()

func (*RunawayRule) Size 

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

func (*RunawayRule) String 

func (m *RunawayRule) String() string

func (*RunawayRule) Unmarshal 

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

func (*RunawayRule) XXX_DiscardUnknown 

func (m *RunawayRule) XXX_DiscardUnknown()

func (*RunawayRule) XXX_Marshal 

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

func (*RunawayRule) XXX_Merge 

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

func (*RunawayRule) XXX_Size 

func (m *RunawayRule) XXX_Size() int

func (*RunawayRule) XXX_Unmarshal 

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

type RunawaySettings 

type RunawaySettings struct {
	Rule   *RunawayRule  `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"`
	Action RunawayAction `protobuf:"varint,2,opt,name=action,proto3,enum=resource_manager.RunawayAction" json:"action,omitempty"`
	Watch  *RunawayWatch `protobuf:"bytes,3,opt,name=watch,proto3" json:"watch,omitempty"`
	// When the runaway action is `SwitchGroup`,
	// this field will be used to indicate which group to switch.
	SwitchGroupName string `protobuf:"bytes,4,opt,name=switch_group_name,json=switchGroupName,proto3" json:"switch_group_name,omitempty"`
}

func (*RunawaySettings) Descriptor 

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

func (*RunawaySettings) GetAction 

func (m *RunawaySettings) GetAction() RunawayAction

func (*RunawaySettings) GetRule 

func (m *RunawaySettings) GetRule() *RunawayRule

func (*RunawaySettings) GetSwitchGroupName 

func (m *RunawaySettings) GetSwitchGroupName() string

func (*RunawaySettings) GetWatch 

func (m *RunawaySettings) GetWatch() *RunawayWatch

func (*RunawaySettings) Marshal 

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

func (*RunawaySettings) MarshalTo 

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

func (*RunawaySettings) MarshalToSizedBuffer 

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

func (*RunawaySettings) ProtoMessage 

func (*RunawaySettings) ProtoMessage()

func (*RunawaySettings) Reset 

func (m *RunawaySettings) Reset()

func (*RunawaySettings) Size 

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

func (*RunawaySettings) String 

func (m *RunawaySettings) String() string

func (*RunawaySettings) Unmarshal 

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

func (*RunawaySettings) XXX_DiscardUnknown 

func (m *RunawaySettings) XXX_DiscardUnknown()

func (*RunawaySettings) XXX_Marshal 

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

func (*RunawaySettings) XXX_Merge 

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

func (*RunawaySettings) XXX_Size 

func (m *RunawaySettings) XXX_Size() int

func (*RunawaySettings) XXX_Unmarshal 

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

type RunawayWatch 

type RunawayWatch struct {
	// how long would the watch last
	LastingDurationMs int64            `protobuf:"varint,1,opt,name=lasting_duration_ms,json=lastingDurationMs,proto3" json:"lasting_duration_ms,omitempty"`
	Type              RunawayWatchType `protobuf:"varint,2,opt,name=type,proto3,enum=resource_manager.RunawayWatchType" json:"type,omitempty"`
}

func (*RunawayWatch) Descriptor 

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

func (*RunawayWatch) GetLastingDurationMs 

func (m *RunawayWatch) GetLastingDurationMs() int64

func (*RunawayWatch) GetType 

func (m *RunawayWatch) GetType() RunawayWatchType

func (*RunawayWatch) Marshal 

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

func (*RunawayWatch) MarshalTo 

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

func (*RunawayWatch) MarshalToSizedBuffer 

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

func (*RunawayWatch) ProtoMessage 

func (*RunawayWatch) ProtoMessage()

func (*RunawayWatch) Reset 

func (m *RunawayWatch) Reset()

func (*RunawayWatch) Size 

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

func (*RunawayWatch) String 

func (m *RunawayWatch) String() string

func (*RunawayWatch) Unmarshal 

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

func (*RunawayWatch) XXX_DiscardUnknown 

func (m *RunawayWatch) XXX_DiscardUnknown()

func (*RunawayWatch) XXX_Marshal 

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

func (*RunawayWatch) XXX_Merge 

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

func (*RunawayWatch) XXX_Size 

func (m *RunawayWatch) XXX_Size() int

func (*RunawayWatch) XXX_Unmarshal 

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

type RunawayWatchType 

type RunawayWatchType int32
const (
	RunawayWatchType_NoneWatch RunawayWatchType = 0
	RunawayWatchType_Exact     RunawayWatchType = 1
	RunawayWatchType_Similar   RunawayWatchType = 2
	RunawayWatchType_Plan      RunawayWatchType = 3
)

func (RunawayWatchType) EnumDescriptor 

func (RunawayWatchType) EnumDescriptor() ([]byte, []int)

func (RunawayWatchType) String 

func (x RunawayWatchType) String() string

type TokenBucket 

type TokenBucket struct {
	Settings *TokenLimitSettings `protobuf:"bytes,1,opt,name=settings,proto3" json:"settings,omitempty"`
	// Once used to reconfigure, the tokens is delta tokens.
	Tokens float64 `protobuf:"fixed64,2,opt,name=tokens,proto3" json:"tokens,omitempty"`
}

func (*TokenBucket) Descriptor 

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

func (*TokenBucket) GetSettings 

func (m *TokenBucket) GetSettings() *TokenLimitSettings

func (*TokenBucket) GetTokens 

func (m *TokenBucket) GetTokens() float64

func (*TokenBucket) Marshal 

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

func (*TokenBucket) MarshalTo 

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

func (*TokenBucket) MarshalToSizedBuffer 

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

func (*TokenBucket) ProtoMessage 

func (*TokenBucket) ProtoMessage()

func (*TokenBucket) Reset 

func (m *TokenBucket) Reset()

func (*TokenBucket) Size 

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

func (*TokenBucket) String 

func (m *TokenBucket) String() string

func (*TokenBucket) Unmarshal 

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

func (*TokenBucket) XXX_DiscardUnknown 

func (m *TokenBucket) XXX_DiscardUnknown()

func (*TokenBucket) XXX_Marshal 

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

func (*TokenBucket) XXX_Merge 

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

func (*TokenBucket) XXX_Size 

func (m *TokenBucket) XXX_Size() int

func (*TokenBucket) XXX_Unmarshal 

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

type TokenBucketRequest 

type TokenBucketRequest struct {
	ResourceGroupName string `protobuf:"bytes,1,opt,name=resource_group_name,json=resourceGroupName,proto3" json:"resource_group_name,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*TokenBucketRequest_RuItems
	//	*TokenBucketRequest_RawResourceItems
	Request isTokenBucketRequest_Request `protobuf_oneof:"request"`
	// Aggregate statistics in group level.
	ConsumptionSinceLastRequest *Consumption `` /* 146-byte string literal not displayed */
	// label background request.
	IsBackground bool `protobuf:"varint,5,opt,name=is_background,json=isBackground,proto3" json:"is_background,omitempty"`
	IsTiflash    bool `protobuf:"varint,6,opt,name=is_tiflash,json=isTiflash,proto3" json:"is_tiflash,omitempty"`
}

func (*TokenBucketRequest) Descriptor 

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

func (*TokenBucketRequest) GetConsumptionSinceLastRequest 

func (m *TokenBucketRequest) GetConsumptionSinceLastRequest() *Consumption

func (*TokenBucketRequest) GetIsBackground 

func (m *TokenBucketRequest) GetIsBackground() bool

func (*TokenBucketRequest) GetIsTiflash 

func (m *TokenBucketRequest) GetIsTiflash() bool

func (*TokenBucketRequest) GetRawResourceItems 

func (m *TokenBucketRequest) GetRawResourceItems() *TokenBucketRequest_RequestRawResource

func (*TokenBucketRequest) GetRequest 

func (m *TokenBucketRequest) GetRequest() isTokenBucketRequest_Request

func (*TokenBucketRequest) GetResourceGroupName 

func (m *TokenBucketRequest) GetResourceGroupName() string

func (*TokenBucketRequest) GetRuItems 

func (m *TokenBucketRequest) GetRuItems() *TokenBucketRequest_RequestRU

func (*TokenBucketRequest) Marshal 

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

func (*TokenBucketRequest) MarshalTo 

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

func (*TokenBucketRequest) MarshalToSizedBuffer 

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

func (*TokenBucketRequest) ProtoMessage 

func (*TokenBucketRequest) ProtoMessage()

func (*TokenBucketRequest) Reset 

func (m *TokenBucketRequest) Reset()

func (*TokenBucketRequest) Size 

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

func (*TokenBucketRequest) String 

func (m *TokenBucketRequest) String() string

func (*TokenBucketRequest) Unmarshal 

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

func (*TokenBucketRequest) XXX_DiscardUnknown 

func (m *TokenBucketRequest) XXX_DiscardUnknown()

func (*TokenBucketRequest) XXX_Marshal 

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

func (*TokenBucketRequest) XXX_Merge 

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

func (*TokenBucketRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TokenBucketRequest) XXX_Size 

func (m *TokenBucketRequest) XXX_Size() int

func (*TokenBucketRequest) XXX_Unmarshal 

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

type TokenBucketRequest_RawResourceItems 

type TokenBucketRequest_RawResourceItems struct {
	RawResourceItems *TokenBucketRequest_RequestRawResource `protobuf:"bytes,3,opt,name=raw_resource_items,json=rawResourceItems,proto3,oneof" json:"raw_resource_items,omitempty"`
}

func (*TokenBucketRequest_RawResourceItems) MarshalTo 

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

func (*TokenBucketRequest_RawResourceItems) MarshalToSizedBuffer 

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

func (*TokenBucketRequest_RawResourceItems) Size 

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

type TokenBucketRequest_RequestRU 

type TokenBucketRequest_RequestRU struct {
	RequestRU []*RequestUnitItem `protobuf:"bytes,1,rep,name=request_r_u,json=requestRU,proto3" json:"request_r_u,omitempty"`
}

func (*TokenBucketRequest_RequestRU) Descriptor 

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

func (*TokenBucketRequest_RequestRU) GetRequestRU 

func (m *TokenBucketRequest_RequestRU) GetRequestRU() []*RequestUnitItem

func (*TokenBucketRequest_RequestRU) Marshal 

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

func (*TokenBucketRequest_RequestRU) MarshalTo 

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

func (*TokenBucketRequest_RequestRU) MarshalToSizedBuffer 

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

func (*TokenBucketRequest_RequestRU) ProtoMessage 

func (*TokenBucketRequest_RequestRU) ProtoMessage()

func (*TokenBucketRequest_RequestRU) Reset 

func (m *TokenBucketRequest_RequestRU) Reset()

func (*TokenBucketRequest_RequestRU) Size 

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

func (*TokenBucketRequest_RequestRU) String 

func (m *TokenBucketRequest_RequestRU) String() string

func (*TokenBucketRequest_RequestRU) Unmarshal 

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

func (*TokenBucketRequest_RequestRU) XXX_DiscardUnknown 

func (m *TokenBucketRequest_RequestRU) XXX_DiscardUnknown()

func (*TokenBucketRequest_RequestRU) XXX_Marshal 

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

func (*TokenBucketRequest_RequestRU) XXX_Merge 

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

func (*TokenBucketRequest_RequestRU) XXX_Size 

func (m *TokenBucketRequest_RequestRU) XXX_Size() int

func (*TokenBucketRequest_RequestRU) XXX_Unmarshal 

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

type TokenBucketRequest_RequestRawResource 

type TokenBucketRequest_RequestRawResource struct {
	RequestRawResource []*RawResourceItem `protobuf:"bytes,1,rep,name=request_raw_resource,json=requestRawResource,proto3" json:"request_raw_resource,omitempty"`
}

func (*TokenBucketRequest_RequestRawResource) Descriptor 

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

func (*TokenBucketRequest_RequestRawResource) GetRequestRawResource 

func (m *TokenBucketRequest_RequestRawResource) GetRequestRawResource() []*RawResourceItem

func (*TokenBucketRequest_RequestRawResource) Marshal 

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

func (*TokenBucketRequest_RequestRawResource) MarshalTo 

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

func (*TokenBucketRequest_RequestRawResource) MarshalToSizedBuffer 

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

func (*TokenBucketRequest_RequestRawResource) ProtoMessage 

func (*TokenBucketRequest_RequestRawResource) ProtoMessage()

func (*TokenBucketRequest_RequestRawResource) Reset 

func (m *TokenBucketRequest_RequestRawResource) Reset()

func (*TokenBucketRequest_RequestRawResource) Size 

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

func (*TokenBucketRequest_RequestRawResource) String 

func (m *TokenBucketRequest_RequestRawResource) String() string

func (*TokenBucketRequest_RequestRawResource) Unmarshal 

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

func (*TokenBucketRequest_RequestRawResource) XXX_DiscardUnknown 

func (m *TokenBucketRequest_RequestRawResource) XXX_DiscardUnknown()

func (*TokenBucketRequest_RequestRawResource) XXX_Marshal 

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

func (*TokenBucketRequest_RequestRawResource) XXX_Merge 

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

func (*TokenBucketRequest_RequestRawResource) XXX_Size 

func (m *TokenBucketRequest_RequestRawResource) XXX_Size() int

func (*TokenBucketRequest_RequestRawResource) XXX_Unmarshal 

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

type TokenBucketRequest_RuItems 

type TokenBucketRequest_RuItems struct {
	RuItems *TokenBucketRequest_RequestRU `protobuf:"bytes,2,opt,name=ru_items,json=ruItems,proto3,oneof" json:"ru_items,omitempty"`
}

func (*TokenBucketRequest_RuItems) MarshalTo 

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

func (*TokenBucketRequest_RuItems) MarshalToSizedBuffer 

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

func (*TokenBucketRequest_RuItems) Size 

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

type TokenBucketResponse 

type TokenBucketResponse struct {
	ResourceGroupName string `protobuf:"bytes,1,opt,name=resource_group_name,json=resourceGroupName,proto3" json:"resource_group_name,omitempty"`
	// RU mode
	GrantedRUTokens []*GrantedRUTokenBucket `protobuf:"bytes,2,rep,name=granted_r_u_tokens,json=grantedRUTokens,proto3" json:"granted_r_u_tokens,omitempty"`
	// Raw mode
	GrantedResourceTokens []*GrantedRawResourceTokenBucket `` /* 126-byte string literal not displayed */
}

func (*TokenBucketResponse) Descriptor 

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

func (*TokenBucketResponse) GetGrantedRUTokens 

func (m *TokenBucketResponse) GetGrantedRUTokens() []*GrantedRUTokenBucket

func (*TokenBucketResponse) GetGrantedResourceTokens 

func (m *TokenBucketResponse) GetGrantedResourceTokens() []*GrantedRawResourceTokenBucket

func (*TokenBucketResponse) GetResourceGroupName 

func (m *TokenBucketResponse) GetResourceGroupName() string

func (*TokenBucketResponse) Marshal 

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

func (*TokenBucketResponse) MarshalTo 

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

func (*TokenBucketResponse) MarshalToSizedBuffer 

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

func (*TokenBucketResponse) ProtoMessage 

func (*TokenBucketResponse) ProtoMessage()

func (*TokenBucketResponse) Reset 

func (m *TokenBucketResponse) Reset()

func (*TokenBucketResponse) Size 

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

func (*TokenBucketResponse) String 

func (m *TokenBucketResponse) String() string

func (*TokenBucketResponse) Unmarshal 

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

func (*TokenBucketResponse) XXX_DiscardUnknown 

func (m *TokenBucketResponse) XXX_DiscardUnknown()

func (*TokenBucketResponse) XXX_Marshal 

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

func (*TokenBucketResponse) XXX_Merge 

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

func (*TokenBucketResponse) XXX_Size 

func (m *TokenBucketResponse) XXX_Size() int

func (*TokenBucketResponse) XXX_Unmarshal 

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

type TokenBucketsRequest 

type TokenBucketsRequest struct {
	Requests              []*TokenBucketRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	TargetRequestPeriodMs uint64                `` /* 129-byte string literal not displayed */
	ClientUniqueId        uint64                `protobuf:"varint,3,opt,name=client_unique_id,json=clientUniqueId,proto3" json:"client_unique_id,omitempty"`
}

func (*TokenBucketsRequest) Descriptor 

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

func (*TokenBucketsRequest) GetClientUniqueId 

func (m *TokenBucketsRequest) GetClientUniqueId() uint64

func (*TokenBucketsRequest) GetRequests 

func (m *TokenBucketsRequest) GetRequests() []*TokenBucketRequest

func (*TokenBucketsRequest) GetTargetRequestPeriodMs 

func (m *TokenBucketsRequest) GetTargetRequestPeriodMs() uint64

func (*TokenBucketsRequest) Marshal 

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

func (*TokenBucketsRequest) MarshalTo 

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

func (*TokenBucketsRequest) MarshalToSizedBuffer 

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

func (*TokenBucketsRequest) ProtoMessage 

func (*TokenBucketsRequest) ProtoMessage()

func (*TokenBucketsRequest) Reset 

func (m *TokenBucketsRequest) Reset()

func (*TokenBucketsRequest) Size 

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

func (*TokenBucketsRequest) String 

func (m *TokenBucketsRequest) String() string

func (*TokenBucketsRequest) Unmarshal 

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

func (*TokenBucketsRequest) XXX_DiscardUnknown 

func (m *TokenBucketsRequest) XXX_DiscardUnknown()

func (*TokenBucketsRequest) XXX_Marshal 

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

func (*TokenBucketsRequest) XXX_Merge 

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

func (*TokenBucketsRequest) XXX_Size 

func (m *TokenBucketsRequest) XXX_Size() int

func (*TokenBucketsRequest) XXX_Unmarshal 

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

type TokenBucketsResponse 

type TokenBucketsResponse struct {
	Error     *Error                 `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Responses []*TokenBucketResponse `protobuf:"bytes,2,rep,name=responses,proto3" json:"responses,omitempty"`
}

func (*TokenBucketsResponse) Descriptor 

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

func (*TokenBucketsResponse) GetError 

func (m *TokenBucketsResponse) GetError() *Error

func (*TokenBucketsResponse) GetResponses 

func (m *TokenBucketsResponse) GetResponses() []*TokenBucketResponse

func (*TokenBucketsResponse) Marshal 

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

func (*TokenBucketsResponse) MarshalTo 

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

func (*TokenBucketsResponse) MarshalToSizedBuffer 

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

func (*TokenBucketsResponse) ProtoMessage 

func (*TokenBucketsResponse) ProtoMessage()

func (*TokenBucketsResponse) Reset 

func (m *TokenBucketsResponse) Reset()

func (*TokenBucketsResponse) Size 

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

func (*TokenBucketsResponse) String 

func (m *TokenBucketsResponse) String() string

func (*TokenBucketsResponse) Unmarshal 

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

func (*TokenBucketsResponse) XXX_DiscardUnknown 

func (m *TokenBucketsResponse) XXX_DiscardUnknown()

func (*TokenBucketsResponse) XXX_Marshal 

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

func (*TokenBucketsResponse) XXX_Merge 

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

func (*TokenBucketsResponse) XXX_Size 

func (m *TokenBucketsResponse) XXX_Size() int

func (*TokenBucketsResponse) XXX_Unmarshal 

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

type TokenLimitSettings 

type TokenLimitSettings struct {
	FillRate   uint64  `protobuf:"varint,1,opt,name=fill_rate,json=fillRate,proto3" json:"fill_rate,omitempty"`
	BurstLimit int64   `protobuf:"varint,2,opt,name=burst_limit,json=burstLimit,proto3" json:"burst_limit,omitempty"`
	MaxTokens  float64 `protobuf:"fixed64,3,opt,name=max_tokens,json=maxTokens,proto3" json:"max_tokens,omitempty"`
}

func (*TokenLimitSettings) Descriptor 

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

func (*TokenLimitSettings) GetBurstLimit 

func (m *TokenLimitSettings) GetBurstLimit() int64

func (*TokenLimitSettings) GetFillRate 

func (m *TokenLimitSettings) GetFillRate() uint64

func (*TokenLimitSettings) GetMaxTokens 

func (m *TokenLimitSettings) GetMaxTokens() float64

func (*TokenLimitSettings) Marshal 

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

func (*TokenLimitSettings) MarshalTo 

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

func (*TokenLimitSettings) MarshalToSizedBuffer 

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

func (*TokenLimitSettings) ProtoMessage 

func (*TokenLimitSettings) ProtoMessage()

func (*TokenLimitSettings) Reset 

func (m *TokenLimitSettings) Reset()

func (*TokenLimitSettings) Size 

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

func (*TokenLimitSettings) String 

func (m *TokenLimitSettings) String() string

func (*TokenLimitSettings) Unmarshal 

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

func (*TokenLimitSettings) XXX_DiscardUnknown 

func (m *TokenLimitSettings) XXX_DiscardUnknown()

func (*TokenLimitSettings) XXX_Marshal 

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

func (*TokenLimitSettings) XXX_Merge 

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

func (*TokenLimitSettings) XXX_Size 

func (m *TokenLimitSettings) XXX_Size() int

func (*TokenLimitSettings) XXX_Unmarshal 

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

type UnimplementedResourceManagerServer 

type UnimplementedResourceManagerServer struct {
}

UnimplementedResourceManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedResourceManagerServer) AcquireTokenBuckets 

func (*UnimplementedResourceManagerServer) AcquireTokenBuckets(srv ResourceManager_AcquireTokenBucketsServer) error

func (*UnimplementedResourceManagerServer) AddResourceGroup 

func (*UnimplementedResourceManagerServer) AddResourceGroup(ctx context.Context, req *PutResourceGroupRequest) (*PutResourceGroupResponse, error)

func (*UnimplementedResourceManagerServer) DeleteResourceGroup 

func (*UnimplementedResourceManagerServer) DeleteResourceGroup(ctx context.Context, req *DeleteResourceGroupRequest) (*DeleteResourceGroupResponse, error)

func (*UnimplementedResourceManagerServer) GetResourceGroup 

func (*UnimplementedResourceManagerServer) GetResourceGroup(ctx context.Context, req *GetResourceGroupRequest) (*GetResourceGroupResponse, error)

func (*UnimplementedResourceManagerServer) ListResourceGroups 

func (*UnimplementedResourceManagerServer) ListResourceGroups(ctx context.Context, req *ListResourceGroupsRequest) (*ListResourceGroupsResponse, error)

func (*UnimplementedResourceManagerServer) ModifyResourceGroup 

func (*UnimplementedResourceManagerServer) ModifyResourceGroup(ctx context.Context, req *PutResourceGroupRequest) (*PutResourceGroupResponse, 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.