Ydb_RateLimiter

package
v2.0.3 Latest Latest
Warning

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

Go to latest
Published: Aug 11, 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 (*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 (*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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL