Ydb_RateLimiter

package
v2.8.0 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AcquireResourceRequest 

type AcquireResourceRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Path of a coordination node.
	CoordinationNodePath string `protobuf:"bytes,2,opt,name=coordination_node_path,json=coordinationNodePath,proto3" json:"coordination_node_path,omitempty"`
	// Path of resource inside a coordination node.
	ResourcePath string `protobuf:"bytes,3,opt,name=resource_path,json=resourcePath,proto3" json:"resource_path,omitempty"`
	// Types that are valid to be assigned to Units:
	//	*AcquireResourceRequest_Required
	//	*AcquireResourceRequest_Used
	Units                isAcquireResourceRequest_Units `protobuf_oneof:"units"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*AcquireResourceRequest) Descriptor 

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

func (*AcquireResourceRequest) GetCoordinationNodePath 

func (m *AcquireResourceRequest) GetCoordinationNodePath() string

func (*AcquireResourceRequest) GetOperationParams 

func (m *AcquireResourceRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*AcquireResourceRequest) GetRequired 

func (m *AcquireResourceRequest) GetRequired() uint64

func (*AcquireResourceRequest) GetResourcePath 

func (m *AcquireResourceRequest) GetResourcePath() string

func (*AcquireResourceRequest) GetUnits 

func (m *AcquireResourceRequest) GetUnits() isAcquireResourceRequest_Units

func (*AcquireResourceRequest) GetUsed 

func (m *AcquireResourceRequest) GetUsed() uint64

func (*AcquireResourceRequest) ProtoMessage 

func (*AcquireResourceRequest) ProtoMessage()

func (*AcquireResourceRequest) Reset 

func (m *AcquireResourceRequest) Reset()

func (*AcquireResourceRequest) SetOperationParams 

func (m *AcquireResourceRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*AcquireResourceRequest) String 

func (m *AcquireResourceRequest) String() string

func (*AcquireResourceRequest) XXX_DiscardUnknown 

func (m *AcquireResourceRequest) XXX_DiscardUnknown()

func (*AcquireResourceRequest) XXX_Marshal 

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

func (*AcquireResourceRequest) XXX_Merge 

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

func (*AcquireResourceRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*AcquireResourceRequest) XXX_Size 

func (m *AcquireResourceRequest) XXX_Size() int

func (*AcquireResourceRequest) XXX_Unmarshal 

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

type AcquireResourceRequest_Required 

type AcquireResourceRequest_Required struct {
	Required uint64 `protobuf:"varint,4,opt,name=required,proto3,oneof"`
}

type AcquireResourceRequest_Used 

type AcquireResourceRequest_Used struct {
	Used uint64 `protobuf:"varint,5,opt,name=used,proto3,oneof"`
}

type AcquireResourceResponse 

type AcquireResourceResponse struct {
	// Holds AcquireResourceResult in case of successful call.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AcquireResourceResponse) Descriptor 

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

func (*AcquireResourceResponse) GetOperation 

func (m *AcquireResourceResponse) GetOperation() *Ydb_Operations.Operation

func (*AcquireResourceResponse) ProtoMessage 

func (*AcquireResourceResponse) ProtoMessage()

func (*AcquireResourceResponse) Reset 

func (m *AcquireResourceResponse) Reset()

func (*AcquireResourceResponse) String 

func (m *AcquireResourceResponse) String() string

func (*AcquireResourceResponse) XXX_DiscardUnknown 

func (m *AcquireResourceResponse) XXX_DiscardUnknown()

func (*AcquireResourceResponse) XXX_Marshal 

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

func (*AcquireResourceResponse) XXX_Merge 

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

func (*AcquireResourceResponse) XXX_Size 

func (m *AcquireResourceResponse) XXX_Size() int

func (*AcquireResourceResponse) XXX_Unmarshal 

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

type AcquireResourceResult 

type AcquireResourceResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AcquireResourceResult) Descriptor 

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

func (*AcquireResourceResult) ProtoMessage 

func (*AcquireResourceResult) ProtoMessage()

func (*AcquireResourceResult) Reset 

func (m *AcquireResourceResult) Reset()

func (*AcquireResourceResult) String 

func (m *AcquireResourceResult) String() string

func (*AcquireResourceResult) XXX_DiscardUnknown 

func (m *AcquireResourceResult) XXX_DiscardUnknown()

func (*AcquireResourceResult) XXX_Marshal 

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

func (*AcquireResourceResult) XXX_Merge 

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

func (*AcquireResourceResult) XXX_Size 

func (m *AcquireResourceResult) XXX_Size() int

func (*AcquireResourceResult) XXX_Unmarshal 

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

type AlterResourceRequest 

type AlterResourceRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Path of a coordination node.
	CoordinationNodePath string `protobuf:"bytes,2,opt,name=coordination_node_path,json=coordinationNodePath,proto3" json:"coordination_node_path,omitempty"`
	// New resource properties.
	Resource             *Resource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AlterResourceRequest) Descriptor 

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

func (*AlterResourceRequest) GetCoordinationNodePath 

func (m *AlterResourceRequest) GetCoordinationNodePath() string

func (*AlterResourceRequest) GetOperationParams 

func (m *AlterResourceRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*AlterResourceRequest) GetResource 

func (m *AlterResourceRequest) GetResource() *Resource

func (*AlterResourceRequest) ProtoMessage 

func (*AlterResourceRequest) ProtoMessage()

func (*AlterResourceRequest) Reset 

func (m *AlterResourceRequest) Reset()

func (*AlterResourceRequest) SetOperationParams 

func (m *AlterResourceRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*AlterResourceRequest) String 

func (m *AlterResourceRequest) String() string

func (*AlterResourceRequest) XXX_DiscardUnknown 

func (m *AlterResourceRequest) XXX_DiscardUnknown()

func (*AlterResourceRequest) XXX_Marshal 

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

func (*AlterResourceRequest) XXX_Merge 

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

func (*AlterResourceRequest) XXX_Size 

func (m *AlterResourceRequest) XXX_Size() int

func (*AlterResourceRequest) XXX_Unmarshal 

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

type AlterResourceResponse 

type AlterResourceResponse struct {
	// Holds AlterResourceResult in case of successful call.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AlterResourceResponse) Descriptor 

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

func (*AlterResourceResponse) GetOperation 

func (m *AlterResourceResponse) GetOperation() *Ydb_Operations.Operation

func (*AlterResourceResponse) ProtoMessage 

func (*AlterResourceResponse) ProtoMessage()

func (*AlterResourceResponse) Reset 

func (m *AlterResourceResponse) Reset()

func (*AlterResourceResponse) String 

func (m *AlterResourceResponse) String() string

func (*AlterResourceResponse) XXX_DiscardUnknown 

func (m *AlterResourceResponse) XXX_DiscardUnknown()

func (*AlterResourceResponse) XXX_Marshal 

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

func (*AlterResourceResponse) XXX_Merge 

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

func (*AlterResourceResponse) XXX_Size 

func (m *AlterResourceResponse) XXX_Size() int

func (*AlterResourceResponse) XXX_Unmarshal 

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

type AlterResourceResult 

type AlterResourceResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterResourceResult) Descriptor 

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

func (*AlterResourceResult) ProtoMessage 

func (*AlterResourceResult) ProtoMessage()

func (*AlterResourceResult) Reset 

func (m *AlterResourceResult) Reset()

func (*AlterResourceResult) String 

func (m *AlterResourceResult) String() string

func (*AlterResourceResult) XXX_DiscardUnknown 

func (m *AlterResourceResult) XXX_DiscardUnknown()

func (*AlterResourceResult) XXX_Marshal 

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

func (*AlterResourceResult) XXX_Merge 

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

func (*AlterResourceResult) XXX_Size 

func (m *AlterResourceResult) XXX_Size() int

func (*AlterResourceResult) XXX_Unmarshal 

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

type CreateResourceRequest 

type CreateResourceRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Path of a coordination node.
	CoordinationNodePath string `protobuf:"bytes,2,opt,name=coordination_node_path,json=coordinationNodePath,proto3" json:"coordination_node_path,omitempty"`
	// Resource properties.
	Resource             *Resource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateResourceRequest) Descriptor 

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

func (*CreateResourceRequest) GetCoordinationNodePath 

func (m *CreateResourceRequest) GetCoordinationNodePath() string

func (*CreateResourceRequest) GetOperationParams 

func (m *CreateResourceRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateResourceRequest) GetResource 

func (m *CreateResourceRequest) GetResource() *Resource

func (*CreateResourceRequest) ProtoMessage 

func (*CreateResourceRequest) ProtoMessage()

func (*CreateResourceRequest) Reset 

func (m *CreateResourceRequest) Reset()

func (*CreateResourceRequest) SetOperationParams 

func (m *CreateResourceRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*CreateResourceRequest) String 

func (m *CreateResourceRequest) String() string

func (*CreateResourceRequest) XXX_DiscardUnknown 

func (m *CreateResourceRequest) XXX_DiscardUnknown()

func (*CreateResourceRequest) XXX_Marshal 

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

func (*CreateResourceRequest) XXX_Merge 

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

func (*CreateResourceRequest) XXX_Size 

func (m *CreateResourceRequest) XXX_Size() int

func (*CreateResourceRequest) XXX_Unmarshal 

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

type CreateResourceResponse 

type CreateResourceResponse struct {
	// Holds CreateResourceResult in case of successful call.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CreateResourceResponse) Descriptor 

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

func (*CreateResourceResponse) GetOperation 

func (m *CreateResourceResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateResourceResponse) ProtoMessage 

func (*CreateResourceResponse) ProtoMessage()

func (*CreateResourceResponse) Reset 

func (m *CreateResourceResponse) Reset()

func (*CreateResourceResponse) String 

func (m *CreateResourceResponse) String() string

func (*CreateResourceResponse) XXX_DiscardUnknown 

func (m *CreateResourceResponse) XXX_DiscardUnknown()

func (*CreateResourceResponse) XXX_Marshal 

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

func (*CreateResourceResponse) XXX_Merge 

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

func (*CreateResourceResponse) XXX_Size 

func (m *CreateResourceResponse) XXX_Size() int

func (*CreateResourceResponse) XXX_Unmarshal 

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

type CreateResourceResult 

type CreateResourceResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateResourceResult) Descriptor 

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

func (*CreateResourceResult) ProtoMessage 

func (*CreateResourceResult) ProtoMessage()

func (*CreateResourceResult) Reset 

func (m *CreateResourceResult) Reset()

func (*CreateResourceResult) String 

func (m *CreateResourceResult) String() string

func (*CreateResourceResult) XXX_DiscardUnknown 

func (m *CreateResourceResult) XXX_DiscardUnknown()

func (*CreateResourceResult) XXX_Marshal 

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

func (*CreateResourceResult) XXX_Merge 

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

func (*CreateResourceResult) XXX_Size 

func (m *CreateResourceResult) XXX_Size() int

func (*CreateResourceResult) XXX_Unmarshal 

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

type DescribeResourceRequest 

type DescribeResourceRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Path of a coordination node.
	CoordinationNodePath string `protobuf:"bytes,2,opt,name=coordination_node_path,json=coordinationNodePath,proto3" json:"coordination_node_path,omitempty"`
	// Path of resource inside a coordination node.
	ResourcePath         string   `protobuf:"bytes,3,opt,name=resource_path,json=resourcePath,proto3" json:"resource_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DescribeResourceRequest) Descriptor 

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

func (*DescribeResourceRequest) GetCoordinationNodePath 

func (m *DescribeResourceRequest) GetCoordinationNodePath() string

func (*DescribeResourceRequest) GetOperationParams 

func (m *DescribeResourceRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeResourceRequest) GetResourcePath 

func (m *DescribeResourceRequest) GetResourcePath() string

func (*DescribeResourceRequest) ProtoMessage 

func (*DescribeResourceRequest) ProtoMessage()

func (*DescribeResourceRequest) Reset 

func (m *DescribeResourceRequest) Reset()

func (*DescribeResourceRequest) SetOperationParams 

func (m *DescribeResourceRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DescribeResourceRequest) String 

func (m *DescribeResourceRequest) String() string

func (*DescribeResourceRequest) XXX_DiscardUnknown 

func (m *DescribeResourceRequest) XXX_DiscardUnknown()

func (*DescribeResourceRequest) XXX_Marshal 

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

func (*DescribeResourceRequest) XXX_Merge 

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

func (*DescribeResourceRequest) XXX_Size 

func (m *DescribeResourceRequest) XXX_Size() int

func (*DescribeResourceRequest) XXX_Unmarshal 

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

type DescribeResourceResponse 

type DescribeResourceResponse struct {
	// Holds DescribeResourceResult in case of successful call.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DescribeResourceResponse) Descriptor 

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

func (*DescribeResourceResponse) GetOperation 

func (m *DescribeResourceResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeResourceResponse) ProtoMessage 

func (*DescribeResourceResponse) ProtoMessage()

func (*DescribeResourceResponse) Reset 

func (m *DescribeResourceResponse) Reset()

func (*DescribeResourceResponse) String 

func (m *DescribeResourceResponse) String() string

func (*DescribeResourceResponse) XXX_DiscardUnknown 

func (m *DescribeResourceResponse) XXX_DiscardUnknown()

func (*DescribeResourceResponse) XXX_Marshal 

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

func (*DescribeResourceResponse) XXX_Merge 

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

func (*DescribeResourceResponse) XXX_Size 

func (m *DescribeResourceResponse) XXX_Size() int

func (*DescribeResourceResponse) XXX_Unmarshal 

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

type DescribeResourceResult 

type DescribeResourceResult struct {
	Resource             *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DescribeResourceResult) Descriptor 

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

func (*DescribeResourceResult) GetResource 

func (m *DescribeResourceResult) GetResource() *Resource

func (*DescribeResourceResult) ProtoMessage 

func (*DescribeResourceResult) ProtoMessage()

func (*DescribeResourceResult) Reset 

func (m *DescribeResourceResult) Reset()

func (*DescribeResourceResult) String 

func (m *DescribeResourceResult) String() string

func (*DescribeResourceResult) XXX_DiscardUnknown 

func (m *DescribeResourceResult) XXX_DiscardUnknown()

func (*DescribeResourceResult) XXX_Marshal 

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

func (*DescribeResourceResult) XXX_Merge 

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

func (*DescribeResourceResult) XXX_Size 

func (m *DescribeResourceResult) XXX_Size() int

func (*DescribeResourceResult) XXX_Unmarshal 

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

type DropResourceRequest 

type DropResourceRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Path of a coordination node.
	CoordinationNodePath string `protobuf:"bytes,2,opt,name=coordination_node_path,json=coordinationNodePath,proto3" json:"coordination_node_path,omitempty"`
	// Path of resource inside a coordination node.
	ResourcePath         string   `protobuf:"bytes,3,opt,name=resource_path,json=resourcePath,proto3" json:"resource_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropResourceRequest) Descriptor 

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

func (*DropResourceRequest) GetCoordinationNodePath 

func (m *DropResourceRequest) GetCoordinationNodePath() string

func (*DropResourceRequest) GetOperationParams 

func (m *DropResourceRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DropResourceRequest) GetResourcePath 

func (m *DropResourceRequest) GetResourcePath() string

func (*DropResourceRequest) ProtoMessage 

func (*DropResourceRequest) ProtoMessage()

func (*DropResourceRequest) Reset 

func (m *DropResourceRequest) Reset()

func (*DropResourceRequest) SetOperationParams 

func (m *DropResourceRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DropResourceRequest) String 

func (m *DropResourceRequest) String() string

func (*DropResourceRequest) XXX_DiscardUnknown 

func (m *DropResourceRequest) XXX_DiscardUnknown()

func (*DropResourceRequest) XXX_Marshal 

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

func (*DropResourceRequest) XXX_Merge 

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

func (*DropResourceRequest) XXX_Size 

func (m *DropResourceRequest) XXX_Size() int

func (*DropResourceRequest) XXX_Unmarshal 

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

type DropResourceResponse 

type DropResourceResponse struct {
	// Holds DropResourceResult in case of successful call.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DropResourceResponse) Descriptor 

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

func (*DropResourceResponse) GetOperation 

func (m *DropResourceResponse) GetOperation() *Ydb_Operations.Operation

func (*DropResourceResponse) ProtoMessage 

func (*DropResourceResponse) ProtoMessage()

func (*DropResourceResponse) Reset 

func (m *DropResourceResponse) Reset()

func (*DropResourceResponse) String 

func (m *DropResourceResponse) String() string

func (*DropResourceResponse) XXX_DiscardUnknown 

func (m *DropResourceResponse) XXX_DiscardUnknown()

func (*DropResourceResponse) XXX_Marshal 

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

func (*DropResourceResponse) XXX_Merge 

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

func (*DropResourceResponse) XXX_Size 

func (m *DropResourceResponse) XXX_Size() int

func (*DropResourceResponse) XXX_Unmarshal 

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

type DropResourceResult 

type DropResourceResult struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropResourceResult) Descriptor 

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

func (*DropResourceResult) ProtoMessage 

func (*DropResourceResult) ProtoMessage()

func (*DropResourceResult) Reset 

func (m *DropResourceResult) Reset()

func (*DropResourceResult) String 

func (m *DropResourceResult) String() string

func (*DropResourceResult) XXX_DiscardUnknown 

func (m *DropResourceResult) XXX_DiscardUnknown()

func (*DropResourceResult) XXX_Marshal 

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

func (*DropResourceResult) XXX_Merge 

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

func (*DropResourceResult) XXX_Size 

func (m *DropResourceResult) XXX_Size() int

func (*DropResourceResult) XXX_Unmarshal 

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

type HierarchicalDrrSettings 

type HierarchicalDrrSettings struct {
	// Resource consumption speed limit.
	// Value is required for root resource.
	// 0 is equivalent to not set.
	// Must be nonnegative.
	MaxUnitsPerSecond float64 `protobuf:"fixed64,1,opt,name=max_units_per_second,json=maxUnitsPerSecond,proto3" json:"max_units_per_second,omitempty"`
	// Maximum burst size of resource consumption across the whole cluster
	// divided by max_units_per_second.
	// Default value is 1.
	// This means that maximum burst size might be equal to max_units_per_second.
	// 0 is equivalent to not set.
	// Must be nonnegative.
	MaxBurstSizeCoefficient float64 `` /* 136-byte string literal not displayed */
	// Prefetch in local bucket up to prefetch_coefficient*max_units_per_second units (full size).
	// Default value is inherited from parent or 0.2 for root.
	// Disables prefetching if any negative value is set
	// (It is useful to avoid bursts in case of large number of local buckets).
	PrefetchCoefficient float64 `protobuf:"fixed64,3,opt,name=prefetch_coefficient,json=prefetchCoefficient,proto3" json:"prefetch_coefficient,omitempty"`
	// Prefetching starts if there is less than prefetch_watermark fraction of full local bucket left.
	// Default value is inherited from parent or 0.75 for root.
	// Must be nonnegative and less than or equal to 1.
	PrefetchWatermark    float64  `protobuf:"fixed64,4,opt,name=prefetch_watermark,json=prefetchWatermark,proto3" json:"prefetch_watermark,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Settings for hierarchical deficit round robin (HDRR) algorithm.

func (*HierarchicalDrrSettings) Descriptor 

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

func (*HierarchicalDrrSettings) GetMaxBurstSizeCoefficient 

func (m *HierarchicalDrrSettings) GetMaxBurstSizeCoefficient() float64

func (*HierarchicalDrrSettings) GetMaxUnitsPerSecond 

func (m *HierarchicalDrrSettings) GetMaxUnitsPerSecond() float64

func (*HierarchicalDrrSettings) GetPrefetchCoefficient 

func (m *HierarchicalDrrSettings) GetPrefetchCoefficient() float64

func (*HierarchicalDrrSettings) GetPrefetchWatermark 

func (m *HierarchicalDrrSettings) GetPrefetchWatermark() float64

func (*HierarchicalDrrSettings) ProtoMessage 

func (*HierarchicalDrrSettings) ProtoMessage()

func (*HierarchicalDrrSettings) Reset 

func (m *HierarchicalDrrSettings) Reset()

func (*HierarchicalDrrSettings) String 

func (m *HierarchicalDrrSettings) String() string

func (*HierarchicalDrrSettings) XXX_DiscardUnknown 

func (m *HierarchicalDrrSettings) XXX_DiscardUnknown()

func (*HierarchicalDrrSettings) XXX_Marshal 

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

func (*HierarchicalDrrSettings) XXX_Merge 

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

func (*HierarchicalDrrSettings) XXX_Size 

func (m *HierarchicalDrrSettings) XXX_Size() int

func (*HierarchicalDrrSettings) XXX_Unmarshal 

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

type ListResourcesRequest 

type ListResourcesRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Path of a coordination node.
	CoordinationNodePath string `protobuf:"bytes,2,opt,name=coordination_node_path,json=coordinationNodePath,proto3" json:"coordination_node_path,omitempty"`
	// Path of resource inside a coordination node.
	// May be empty.
	// In that case all root resources will be listed.
	ResourcePath string `protobuf:"bytes,3,opt,name=resource_path,json=resourcePath,proto3" json:"resource_path,omitempty"`
	// List resources recursively.
	Recursive            bool     `protobuf:"varint,4,opt,name=recursive,proto3" json:"recursive,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListResourcesRequest) Descriptor 

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

func (*ListResourcesRequest) GetCoordinationNodePath 

func (m *ListResourcesRequest) GetCoordinationNodePath() string

func (*ListResourcesRequest) GetOperationParams 

func (m *ListResourcesRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*ListResourcesRequest) GetRecursive 

func (m *ListResourcesRequest) GetRecursive() bool

func (*ListResourcesRequest) GetResourcePath 

func (m *ListResourcesRequest) GetResourcePath() string

func (*ListResourcesRequest) ProtoMessage 

func (*ListResourcesRequest) ProtoMessage()

func (*ListResourcesRequest) Reset 

func (m *ListResourcesRequest) Reset()

func (*ListResourcesRequest) SetOperationParams 

func (m *ListResourcesRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*ListResourcesRequest) String 

func (m *ListResourcesRequest) String() string

func (*ListResourcesRequest) XXX_DiscardUnknown 

func (m *ListResourcesRequest) XXX_DiscardUnknown()

func (*ListResourcesRequest) XXX_Marshal 

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

func (*ListResourcesRequest) XXX_Merge 

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

func (*ListResourcesRequest) XXX_Size 

func (m *ListResourcesRequest) XXX_Size() int

func (*ListResourcesRequest) XXX_Unmarshal 

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

type ListResourcesResponse 

type ListResourcesResponse struct {
	// Holds ListResourcesResult in case of successful call.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ListResourcesResponse) Descriptor 

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

func (*ListResourcesResponse) GetOperation 

func (m *ListResourcesResponse) GetOperation() *Ydb_Operations.Operation

func (*ListResourcesResponse) ProtoMessage 

func (*ListResourcesResponse) ProtoMessage()

func (*ListResourcesResponse) Reset 

func (m *ListResourcesResponse) Reset()

func (*ListResourcesResponse) String 

func (m *ListResourcesResponse) String() string

func (*ListResourcesResponse) XXX_DiscardUnknown 

func (m *ListResourcesResponse) XXX_DiscardUnknown()

func (*ListResourcesResponse) XXX_Marshal 

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

func (*ListResourcesResponse) XXX_Merge 

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

func (*ListResourcesResponse) XXX_Size 

func (m *ListResourcesResponse) XXX_Size() int

func (*ListResourcesResponse) XXX_Unmarshal 

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

type ListResourcesResult 

type ListResourcesResult struct {
	ResourcePaths        []string `protobuf:"bytes,1,rep,name=resource_paths,json=resourcePaths,proto3" json:"resource_paths,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListResourcesResult) Descriptor 

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

func (*ListResourcesResult) GetResourcePaths 

func (m *ListResourcesResult) GetResourcePaths() []string

func (*ListResourcesResult) ProtoMessage 

func (*ListResourcesResult) ProtoMessage()

func (*ListResourcesResult) Reset 

func (m *ListResourcesResult) Reset()

func (*ListResourcesResult) String 

func (m *ListResourcesResult) String() string

func (*ListResourcesResult) XXX_DiscardUnknown 

func (m *ListResourcesResult) XXX_DiscardUnknown()

func (*ListResourcesResult) XXX_Marshal 

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

func (*ListResourcesResult) XXX_Merge 

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

func (*ListResourcesResult) XXX_Size 

func (m *ListResourcesResult) XXX_Size() int

func (*ListResourcesResult) XXX_Unmarshal 

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

type Resource 

type Resource struct {
	// Resource path. Elements are separated by slash.
	// The first symbol is not slash.
	// The first element is root resource name.
	// Resource path is the path of resource inside coordination node.
	ResourcePath string `protobuf:"bytes,1,opt,name=resource_path,json=resourcePath,proto3" json:"resource_path,omitempty"`
	// Types that are valid to be assigned to Type:
	//	*Resource_HierarchicalDrr
	Type                 isResource_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Rate limiter resource description.

func (*Resource) Descriptor 

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

func (*Resource) GetHierarchicalDrr 

func (m *Resource) GetHierarchicalDrr() *HierarchicalDrrSettings

func (*Resource) GetResourcePath 

func (m *Resource) GetResourcePath() string

func (*Resource) GetType 

func (m *Resource) GetType() isResource_Type

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) Reset 

func (m *Resource) Reset()

func (*Resource) String 

func (m *Resource) String() string

func (*Resource) XXX_DiscardUnknown 

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal 

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

func (*Resource) XXX_Merge 

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

func (*Resource) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Resource) XXX_Size 

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal 

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

type Resource_HierarchicalDrr 

type Resource_HierarchicalDrr struct {
	HierarchicalDrr *HierarchicalDrrSettings `protobuf:"bytes,2,opt,name=hierarchical_drr,json=hierarchicalDrr,proto3,oneof"`
}

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.