Ydb_Coordination

package
v0.0.0-...-5d5a685 Latest Latest
Warning

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

Go to latest
Published: May 28, 2024 License: Apache-2.0 Imports: 8 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ConsistencyMode_name = map[int32]string{
		0: "CONSISTENCY_MODE_UNSET",
		1: "CONSISTENCY_MODE_STRICT",
		2: "CONSISTENCY_MODE_RELAXED",
	}
	ConsistencyMode_value = map[string]int32{
		"CONSISTENCY_MODE_UNSET":   0,
		"CONSISTENCY_MODE_STRICT":  1,
		"CONSISTENCY_MODE_RELAXED": 2,
	}
)

Enum value maps for ConsistencyMode.

View Source
var (
	RateLimiterCountersMode_name = map[int32]string{
		0: "RATE_LIMITER_COUNTERS_MODE_UNSET",
		1: "RATE_LIMITER_COUNTERS_MODE_AGGREGATED",
		2: "RATE_LIMITER_COUNTERS_MODE_DETAILED",
	}
	RateLimiterCountersMode_value = map[string]int32{
		"RATE_LIMITER_COUNTERS_MODE_UNSET":      0,
		"RATE_LIMITER_COUNTERS_MODE_AGGREGATED": 1,
		"RATE_LIMITER_COUNTERS_MODE_DETAILED":   2,
	}
)

Enum value maps for RateLimiterCountersMode.

View Source
var File_protos_ydb_coordination_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AlterNodeRequest

type AlterNodeRequest struct {
	Path            string                          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Config          *Config                         `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterNodeRequest) Descriptor deprecated

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

Deprecated: Use AlterNodeRequest.ProtoReflect.Descriptor instead.

func (*AlterNodeRequest) GetConfig

func (x *AlterNodeRequest) GetConfig() *Config

func (*AlterNodeRequest) GetOperationParams

func (x *AlterNodeRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*AlterNodeRequest) GetPath

func (x *AlterNodeRequest) GetPath() string

func (*AlterNodeRequest) ProtoMessage

func (*AlterNodeRequest) ProtoMessage()

func (*AlterNodeRequest) ProtoReflect

func (x *AlterNodeRequest) ProtoReflect() protoreflect.Message

func (*AlterNodeRequest) Reset

func (x *AlterNodeRequest) Reset()

func (*AlterNodeRequest) String

func (x *AlterNodeRequest) String() string

type AlterNodeResponse

type AlterNodeResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterNodeResponse) Descriptor deprecated

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

Deprecated: Use AlterNodeResponse.ProtoReflect.Descriptor instead.

func (*AlterNodeResponse) GetOperation

func (x *AlterNodeResponse) GetOperation() *Ydb_Operations.Operation

func (*AlterNodeResponse) ProtoMessage

func (*AlterNodeResponse) ProtoMessage()

func (*AlterNodeResponse) ProtoReflect

func (x *AlterNodeResponse) ProtoReflect() protoreflect.Message

func (*AlterNodeResponse) Reset

func (x *AlterNodeResponse) Reset()

func (*AlterNodeResponse) String

func (x *AlterNodeResponse) String() string

type Config

type Config struct {

	// Initialized on creation, cannot be set
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Period in milliseconds for self-checks (default 1 second)
	SelfCheckPeriodMillis uint32 `` /* 129-byte string literal not displayed */
	// Grace period for sessions on leader change (default 10 seconds)
	SessionGracePeriodMillis uint32 `` /* 138-byte string literal not displayed */
	// Concistency mode for read operations
	ReadConsistencyMode ConsistencyMode `` /* 159-byte string literal not displayed */
	// Consistency mode for attach operations
	AttachConsistencyMode ConsistencyMode `` /* 165-byte string literal not displayed */
	// Rate limiter counters mode
	RateLimiterCountersMode RateLimiterCountersMode `` /* 181-byte string literal not displayed */
	// contains filtered or unexported fields
}

* Configuration settings for a coordination node

func (*Config) Descriptor deprecated

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetAttachConsistencyMode

func (x *Config) GetAttachConsistencyMode() ConsistencyMode

func (*Config) GetPath

func (x *Config) GetPath() string

func (*Config) GetRateLimiterCountersMode

func (x *Config) GetRateLimiterCountersMode() RateLimiterCountersMode

func (*Config) GetReadConsistencyMode

func (x *Config) GetReadConsistencyMode() ConsistencyMode

func (*Config) GetSelfCheckPeriodMillis

func (x *Config) GetSelfCheckPeriodMillis() uint32

func (*Config) GetSessionGracePeriodMillis

func (x *Config) GetSessionGracePeriodMillis() uint32

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type ConsistencyMode

type ConsistencyMode int32

* Consistency mode

const (
	// The default or current value
	ConsistencyMode_CONSISTENCY_MODE_UNSET ConsistencyMode = 0
	// Strict mode makes sure operations may only complete on current leader
	ConsistencyMode_CONSISTENCY_MODE_STRICT ConsistencyMode = 1
	// Relaxed mode allows operations to complete on stale masters
	ConsistencyMode_CONSISTENCY_MODE_RELAXED ConsistencyMode = 2
)

func (ConsistencyMode) Descriptor

func (ConsistencyMode) Enum

func (x ConsistencyMode) Enum() *ConsistencyMode

func (ConsistencyMode) EnumDescriptor deprecated

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

Deprecated: Use ConsistencyMode.Descriptor instead.

func (ConsistencyMode) Number

func (ConsistencyMode) String

func (x ConsistencyMode) String() string

func (ConsistencyMode) Type

type CreateNodeRequest

type CreateNodeRequest struct {
	Path            string                          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Config          *Config                         `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,3,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNodeRequest) Descriptor deprecated

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

Deprecated: Use CreateNodeRequest.ProtoReflect.Descriptor instead.

func (*CreateNodeRequest) GetConfig

func (x *CreateNodeRequest) GetConfig() *Config

func (*CreateNodeRequest) GetOperationParams

func (x *CreateNodeRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*CreateNodeRequest) GetPath

func (x *CreateNodeRequest) GetPath() string

func (*CreateNodeRequest) ProtoMessage

func (*CreateNodeRequest) ProtoMessage()

func (*CreateNodeRequest) ProtoReflect

func (x *CreateNodeRequest) ProtoReflect() protoreflect.Message

func (*CreateNodeRequest) Reset

func (x *CreateNodeRequest) Reset()

func (*CreateNodeRequest) String

func (x *CreateNodeRequest) String() string

type CreateNodeResponse

type CreateNodeResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNodeResponse) Descriptor deprecated

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

Deprecated: Use CreateNodeResponse.ProtoReflect.Descriptor instead.

func (*CreateNodeResponse) GetOperation

func (x *CreateNodeResponse) GetOperation() *Ydb_Operations.Operation

func (*CreateNodeResponse) ProtoMessage

func (*CreateNodeResponse) ProtoMessage()

func (*CreateNodeResponse) ProtoReflect

func (x *CreateNodeResponse) ProtoReflect() protoreflect.Message

func (*CreateNodeResponse) Reset

func (x *CreateNodeResponse) Reset()

func (*CreateNodeResponse) String

func (x *CreateNodeResponse) String() string

type DescribeNodeRequest

type DescribeNodeRequest struct {
	Path            string                          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,2,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeNodeRequest) Descriptor deprecated

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

Deprecated: Use DescribeNodeRequest.ProtoReflect.Descriptor instead.

func (*DescribeNodeRequest) GetOperationParams

func (x *DescribeNodeRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DescribeNodeRequest) GetPath

func (x *DescribeNodeRequest) GetPath() string

func (*DescribeNodeRequest) ProtoMessage

func (*DescribeNodeRequest) ProtoMessage()

func (*DescribeNodeRequest) ProtoReflect

func (x *DescribeNodeRequest) ProtoReflect() protoreflect.Message

func (*DescribeNodeRequest) Reset

func (x *DescribeNodeRequest) Reset()

func (*DescribeNodeRequest) String

func (x *DescribeNodeRequest) String() string

type DescribeNodeResponse

type DescribeNodeResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeNodeResponse) Descriptor deprecated

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

Deprecated: Use DescribeNodeResponse.ProtoReflect.Descriptor instead.

func (*DescribeNodeResponse) GetOperation

func (x *DescribeNodeResponse) GetOperation() *Ydb_Operations.Operation

func (*DescribeNodeResponse) ProtoMessage

func (*DescribeNodeResponse) ProtoMessage()

func (*DescribeNodeResponse) ProtoReflect

func (x *DescribeNodeResponse) ProtoReflect() protoreflect.Message

func (*DescribeNodeResponse) Reset

func (x *DescribeNodeResponse) Reset()

func (*DescribeNodeResponse) String

func (x *DescribeNodeResponse) String() string

type DescribeNodeResult

type DescribeNodeResult struct {
	Self   *Ydb_Scheme.Entry `protobuf:"bytes,1,opt,name=self,proto3" json:"self,omitempty"`
	Config *Config           `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeNodeResult) Descriptor deprecated

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

Deprecated: Use DescribeNodeResult.ProtoReflect.Descriptor instead.

func (*DescribeNodeResult) GetConfig

func (x *DescribeNodeResult) GetConfig() *Config

func (*DescribeNodeResult) GetSelf

func (x *DescribeNodeResult) GetSelf() *Ydb_Scheme.Entry

func (*DescribeNodeResult) ProtoMessage

func (*DescribeNodeResult) ProtoMessage()

func (*DescribeNodeResult) ProtoReflect

func (x *DescribeNodeResult) ProtoReflect() protoreflect.Message

func (*DescribeNodeResult) Reset

func (x *DescribeNodeResult) Reset()

func (*DescribeNodeResult) String

func (x *DescribeNodeResult) String() string

type DropNodeRequest

type DropNodeRequest struct {
	Path            string                          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,2,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// contains filtered or unexported fields
}

func (*DropNodeRequest) Descriptor deprecated

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

Deprecated: Use DropNodeRequest.ProtoReflect.Descriptor instead.

func (*DropNodeRequest) GetOperationParams

func (x *DropNodeRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DropNodeRequest) GetPath

func (x *DropNodeRequest) GetPath() string

func (*DropNodeRequest) ProtoMessage

func (*DropNodeRequest) ProtoMessage()

func (*DropNodeRequest) ProtoReflect

func (x *DropNodeRequest) ProtoReflect() protoreflect.Message

func (*DropNodeRequest) Reset

func (x *DropNodeRequest) Reset()

func (*DropNodeRequest) String

func (x *DropNodeRequest) String() string

type DropNodeResponse

type DropNodeResponse struct {
	Operation *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*DropNodeResponse) Descriptor deprecated

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

Deprecated: Use DropNodeResponse.ProtoReflect.Descriptor instead.

func (*DropNodeResponse) GetOperation

func (x *DropNodeResponse) GetOperation() *Ydb_Operations.Operation

func (*DropNodeResponse) ProtoMessage

func (*DropNodeResponse) ProtoMessage()

func (*DropNodeResponse) ProtoReflect

func (x *DropNodeResponse) ProtoReflect() protoreflect.Message

func (*DropNodeResponse) Reset

func (x *DropNodeResponse) Reset()

func (*DropNodeResponse) String

func (x *DropNodeResponse) String() string

type RateLimiterCountersMode

type RateLimiterCountersMode int32

* Counters mode

const (
	// The default or current value
	RateLimiterCountersMode_RATE_LIMITER_COUNTERS_MODE_UNSET RateLimiterCountersMode = 0
	// Aggregated counters for resource tree
	RateLimiterCountersMode_RATE_LIMITER_COUNTERS_MODE_AGGREGATED RateLimiterCountersMode = 1
	// Counters on every resource
	RateLimiterCountersMode_RATE_LIMITER_COUNTERS_MODE_DETAILED RateLimiterCountersMode = 2
)

func (RateLimiterCountersMode) Descriptor

func (RateLimiterCountersMode) Enum

func (RateLimiterCountersMode) EnumDescriptor deprecated

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

Deprecated: Use RateLimiterCountersMode.Descriptor instead.

func (RateLimiterCountersMode) Number

func (RateLimiterCountersMode) String

func (x RateLimiterCountersMode) String() string

func (RateLimiterCountersMode) Type

type SemaphoreDescription

type SemaphoreDescription struct {

	// Name of the semaphore
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// User-defined data attached to the semaphore
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Number of tokens currently acquired by owners
	Count uint64 `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"`
	// Maximum number of tokens that may acquired
	Limit uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// Ephemeral semaphores are deleted when released by all owners and waiters
	Ephemeral bool `protobuf:"varint,4,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
	// A list of current owners of the semaphore
	Owners []*SemaphoreSession `protobuf:"bytes,5,rep,name=owners,proto3" json:"owners,omitempty"`
	// A list of current waiters on the semaphore
	Waiters []*SemaphoreSession `protobuf:"bytes,6,rep,name=waiters,proto3" json:"waiters,omitempty"`
	// contains filtered or unexported fields
}

* Describes the state of a semaphore

func (*SemaphoreDescription) Descriptor deprecated

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

Deprecated: Use SemaphoreDescription.ProtoReflect.Descriptor instead.

func (*SemaphoreDescription) GetCount

func (x *SemaphoreDescription) GetCount() uint64

func (*SemaphoreDescription) GetData

func (x *SemaphoreDescription) GetData() []byte

func (*SemaphoreDescription) GetEphemeral

func (x *SemaphoreDescription) GetEphemeral() bool

func (*SemaphoreDescription) GetLimit

func (x *SemaphoreDescription) GetLimit() uint64

func (*SemaphoreDescription) GetName

func (x *SemaphoreDescription) GetName() string

func (*SemaphoreDescription) GetOwners

func (x *SemaphoreDescription) GetOwners() []*SemaphoreSession

func (*SemaphoreDescription) GetWaiters

func (x *SemaphoreDescription) GetWaiters() []*SemaphoreSession

func (*SemaphoreDescription) ProtoMessage

func (*SemaphoreDescription) ProtoMessage()

func (*SemaphoreDescription) ProtoReflect

func (x *SemaphoreDescription) ProtoReflect() protoreflect.Message

func (*SemaphoreDescription) Reset

func (x *SemaphoreDescription) Reset()

func (*SemaphoreDescription) String

func (x *SemaphoreDescription) String() string

type SemaphoreSession

type SemaphoreSession struct {

	// A monotonically increasing id which determines locking order
	OrderId uint64 `protobuf:"varint,5,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
	// An id of the session which tried to acquire the semaphore
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// A timeout in milliseconds for operation in waiters queue
	TimeoutMillis uint64 `protobuf:"varint,2,opt,name=timeout_millis,json=timeoutMillis,proto3" json:"timeout_millis,omitempty"`
	// Number of tokens for an acquire operation
	Count uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// User-defined data attached to the acquire operation
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

* Describes an owner or a waiter of this semaphore

func (*SemaphoreSession) Descriptor deprecated

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

Deprecated: Use SemaphoreSession.ProtoReflect.Descriptor instead.

func (*SemaphoreSession) GetCount

func (x *SemaphoreSession) GetCount() uint64

func (*SemaphoreSession) GetData

func (x *SemaphoreSession) GetData() []byte

func (*SemaphoreSession) GetOrderId

func (x *SemaphoreSession) GetOrderId() uint64

func (*SemaphoreSession) GetSessionId

func (x *SemaphoreSession) GetSessionId() uint64

func (*SemaphoreSession) GetTimeoutMillis

func (x *SemaphoreSession) GetTimeoutMillis() uint64

func (*SemaphoreSession) ProtoMessage

func (*SemaphoreSession) ProtoMessage()

func (*SemaphoreSession) ProtoReflect

func (x *SemaphoreSession) ProtoReflect() protoreflect.Message

func (*SemaphoreSession) Reset

func (x *SemaphoreSession) Reset()

func (*SemaphoreSession) String

func (x *SemaphoreSession) String() string

type SessionDescription

type SessionDescription struct {

	// Session id generated by the server
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Expiration timeout of the session
	TimeoutMillis uint64 `protobuf:"varint,2,opt,name=timeout_millis,json=timeoutMillis,proto3" json:"timeout_millis,omitempty"`
	// User-specified description of this session
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// True if this session is currently attached to a client
	Attached bool `protobuf:"varint,4,opt,name=attached,proto3" json:"attached,omitempty"`
	// contains filtered or unexported fields
}

* Describes an active client session

func (*SessionDescription) Descriptor deprecated

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

Deprecated: Use SessionDescription.ProtoReflect.Descriptor instead.

func (*SessionDescription) GetAttached

func (x *SessionDescription) GetAttached() bool

func (*SessionDescription) GetDescription

func (x *SessionDescription) GetDescription() string

func (*SessionDescription) GetSessionId

func (x *SessionDescription) GetSessionId() uint64

func (*SessionDescription) GetTimeoutMillis

func (x *SessionDescription) GetTimeoutMillis() uint64

func (*SessionDescription) ProtoMessage

func (*SessionDescription) ProtoMessage()

func (*SessionDescription) ProtoReflect

func (x *SessionDescription) ProtoReflect() protoreflect.Message

func (*SessionDescription) Reset

func (x *SessionDescription) Reset()

func (*SessionDescription) String

func (x *SessionDescription) String() string

type SessionRequest

type SessionRequest struct {

	// Types that are assignable to Request:
	//
	//	*SessionRequest_Ping
	//	*SessionRequest_Pong
	//	*SessionRequest_SessionStart_
	//	*SessionRequest_SessionStop_
	//	*SessionRequest_Unsupported_5
	//	*SessionRequest_Unsupported_6
	//	*SessionRequest_AcquireSemaphore_
	//	*SessionRequest_ReleaseSemaphore_
	//	*SessionRequest_DescribeSemaphore_
	//	*SessionRequest_CreateSemaphore_
	//	*SessionRequest_UpdateSemaphore_
	//	*SessionRequest_DeleteSemaphore_
	//	*SessionRequest_Unsupported_13
	//	*SessionRequest_Unsupported_14
	//	*SessionRequest_Unsupported_15
	Request isSessionRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

* Session request message sent from client to server

func (*SessionRequest) Descriptor deprecated

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

Deprecated: Use SessionRequest.ProtoReflect.Descriptor instead.

func (*SessionRequest) GetAcquireSemaphore

func (x *SessionRequest) GetAcquireSemaphore() *SessionRequest_AcquireSemaphore

func (*SessionRequest) GetCreateSemaphore

func (x *SessionRequest) GetCreateSemaphore() *SessionRequest_CreateSemaphore

func (*SessionRequest) GetDeleteSemaphore

func (x *SessionRequest) GetDeleteSemaphore() *SessionRequest_DeleteSemaphore

func (*SessionRequest) GetDescribeSemaphore

func (x *SessionRequest) GetDescribeSemaphore() *SessionRequest_DescribeSemaphore

func (*SessionRequest) GetPing

func (*SessionRequest) GetPong

func (*SessionRequest) GetReleaseSemaphore

func (x *SessionRequest) GetReleaseSemaphore() *SessionRequest_ReleaseSemaphore

func (*SessionRequest) GetRequest

func (m *SessionRequest) GetRequest() isSessionRequest_Request

func (*SessionRequest) GetSessionStart

func (x *SessionRequest) GetSessionStart() *SessionRequest_SessionStart

func (*SessionRequest) GetSessionStop

func (x *SessionRequest) GetSessionStop() *SessionRequest_SessionStop

func (*SessionRequest) GetUnsupported_13

func (x *SessionRequest) GetUnsupported_13() *Unsupported

func (*SessionRequest) GetUnsupported_14

func (x *SessionRequest) GetUnsupported_14() *Unsupported

func (*SessionRequest) GetUnsupported_15

func (x *SessionRequest) GetUnsupported_15() *Unsupported

func (*SessionRequest) GetUnsupported_5

func (x *SessionRequest) GetUnsupported_5() *Unsupported

func (*SessionRequest) GetUnsupported_6

func (x *SessionRequest) GetUnsupported_6() *Unsupported

func (*SessionRequest) GetUpdateSemaphore

func (x *SessionRequest) GetUpdateSemaphore() *SessionRequest_UpdateSemaphore

func (*SessionRequest) ProtoMessage

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) ProtoReflect

func (x *SessionRequest) ProtoReflect() protoreflect.Message

func (*SessionRequest) Reset

func (x *SessionRequest) Reset()

func (*SessionRequest) String

func (x *SessionRequest) String() string

type SessionRequest_AcquireSemaphore

type SessionRequest_AcquireSemaphore struct {

	// Client-defined request id, echoed in the response
	ReqId uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// Name of the semaphore to acquire
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Timeout in milliseconds after which operation will fail
	// if it's still waiting in the waiters queue
	TimeoutMillis uint64 `protobuf:"varint,3,opt,name=timeout_millis,json=timeoutMillis,proto3" json:"timeout_millis,omitempty"`
	// Number of tokens to acquire on the semaphore
	Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// User-defined binary data that may be attached to the operation
	Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// Ephemeral semaphores are created with the first acquire operation
	// and automatically deleted with the last release operation
	Ephemeral bool `protobuf:"varint,6,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
	// contains filtered or unexported fields
}

* Used to acquire a semaphore

WARNING: a single session cannot acquire the same semaphore multiple times

Later requests override previous operations with the same semaphore, e.g. to reduce acquired count, change timeout or attached data.

func (*SessionRequest_AcquireSemaphore) Descriptor deprecated

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

Deprecated: Use SessionRequest_AcquireSemaphore.ProtoReflect.Descriptor instead.

func (*SessionRequest_AcquireSemaphore) GetCount

func (*SessionRequest_AcquireSemaphore) GetData

func (x *SessionRequest_AcquireSemaphore) GetData() []byte

func (*SessionRequest_AcquireSemaphore) GetEphemeral

func (x *SessionRequest_AcquireSemaphore) GetEphemeral() bool

func (*SessionRequest_AcquireSemaphore) GetName

func (*SessionRequest_AcquireSemaphore) GetReqId

func (*SessionRequest_AcquireSemaphore) GetTimeoutMillis

func (x *SessionRequest_AcquireSemaphore) GetTimeoutMillis() uint64

func (*SessionRequest_AcquireSemaphore) ProtoMessage

func (*SessionRequest_AcquireSemaphore) ProtoMessage()

func (*SessionRequest_AcquireSemaphore) ProtoReflect

func (*SessionRequest_AcquireSemaphore) Reset

func (*SessionRequest_AcquireSemaphore) String

type SessionRequest_AcquireSemaphore_

type SessionRequest_AcquireSemaphore_ struct {
	AcquireSemaphore *SessionRequest_AcquireSemaphore `protobuf:"bytes,7,opt,name=acquire_semaphore,json=acquireSemaphore,proto3,oneof"`
}

type SessionRequest_CreateSemaphore

type SessionRequest_CreateSemaphore struct {

	// Client-defined request id, echoed in the response
	ReqId uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// Name of the semaphore to create
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Number of tokens that may be acquired by sessions
	Limit uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// User-defined data that is attached to the semaphore
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

* Used to create a new semaphore

func (*SessionRequest_CreateSemaphore) Descriptor deprecated

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

Deprecated: Use SessionRequest_CreateSemaphore.ProtoReflect.Descriptor instead.

func (*SessionRequest_CreateSemaphore) GetData

func (x *SessionRequest_CreateSemaphore) GetData() []byte

func (*SessionRequest_CreateSemaphore) GetLimit

func (x *SessionRequest_CreateSemaphore) GetLimit() uint64

func (*SessionRequest_CreateSemaphore) GetName

func (*SessionRequest_CreateSemaphore) GetReqId

func (x *SessionRequest_CreateSemaphore) GetReqId() uint64

func (*SessionRequest_CreateSemaphore) ProtoMessage

func (*SessionRequest_CreateSemaphore) ProtoMessage()

func (*SessionRequest_CreateSemaphore) ProtoReflect

func (*SessionRequest_CreateSemaphore) Reset

func (x *SessionRequest_CreateSemaphore) Reset()

func (*SessionRequest_CreateSemaphore) String

type SessionRequest_CreateSemaphore_

type SessionRequest_CreateSemaphore_ struct {
	CreateSemaphore *SessionRequest_CreateSemaphore `protobuf:"bytes,10,opt,name=create_semaphore,json=createSemaphore,proto3,oneof"`
}

type SessionRequest_DeleteSemaphore

type SessionRequest_DeleteSemaphore struct {

	// Client-defined request id, echoed in the response
	ReqId uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// Name of the semaphore to delete
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Will delete semaphore even if currently acquired by sessions
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

* Used to delete an existing semaphore

func (*SessionRequest_DeleteSemaphore) Descriptor deprecated

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

Deprecated: Use SessionRequest_DeleteSemaphore.ProtoReflect.Descriptor instead.

func (*SessionRequest_DeleteSemaphore) GetForce

func (x *SessionRequest_DeleteSemaphore) GetForce() bool

func (*SessionRequest_DeleteSemaphore) GetName

func (*SessionRequest_DeleteSemaphore) GetReqId

func (x *SessionRequest_DeleteSemaphore) GetReqId() uint64

func (*SessionRequest_DeleteSemaphore) ProtoMessage

func (*SessionRequest_DeleteSemaphore) ProtoMessage()

func (*SessionRequest_DeleteSemaphore) ProtoReflect

func (*SessionRequest_DeleteSemaphore) Reset

func (x *SessionRequest_DeleteSemaphore) Reset()

func (*SessionRequest_DeleteSemaphore) String

type SessionRequest_DeleteSemaphore_

type SessionRequest_DeleteSemaphore_ struct {
	DeleteSemaphore *SessionRequest_DeleteSemaphore `protobuf:"bytes,12,opt,name=delete_semaphore,json=deleteSemaphore,proto3,oneof"`
}

type SessionRequest_DescribeSemaphore

type SessionRequest_DescribeSemaphore struct {

	// Client-defined request id, echoed in the response
	ReqId uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// Name of the semaphore to describe
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Response will include owners list if true
	IncludeOwners bool `protobuf:"varint,3,opt,name=include_owners,json=includeOwners,proto3" json:"include_owners,omitempty"`
	// Response will include waiters list if true
	IncludeWaiters bool `protobuf:"varint,4,opt,name=include_waiters,json=includeWaiters,proto3" json:"include_waiters,omitempty"`
	// Watch for changes in semaphore data
	WatchData bool `protobuf:"varint,5,opt,name=watch_data,json=watchData,proto3" json:"watch_data,omitempty"`
	// Watch for changes in semaphore owners (including owners data)
	WatchOwners bool `protobuf:"varint,6,opt,name=watch_owners,json=watchOwners,proto3" json:"watch_owners,omitempty"`
	// contains filtered or unexported fields
}

* Used to describe semaphores and watch them for changes

WARNING: a describe operation will cancel previous watches on the same semaphore

func (*SessionRequest_DescribeSemaphore) Descriptor deprecated

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

Deprecated: Use SessionRequest_DescribeSemaphore.ProtoReflect.Descriptor instead.

func (*SessionRequest_DescribeSemaphore) GetIncludeOwners

func (x *SessionRequest_DescribeSemaphore) GetIncludeOwners() bool

func (*SessionRequest_DescribeSemaphore) GetIncludeWaiters

func (x *SessionRequest_DescribeSemaphore) GetIncludeWaiters() bool

func (*SessionRequest_DescribeSemaphore) GetName

func (*SessionRequest_DescribeSemaphore) GetReqId

func (*SessionRequest_DescribeSemaphore) GetWatchData

func (x *SessionRequest_DescribeSemaphore) GetWatchData() bool

func (*SessionRequest_DescribeSemaphore) GetWatchOwners

func (x *SessionRequest_DescribeSemaphore) GetWatchOwners() bool

func (*SessionRequest_DescribeSemaphore) ProtoMessage

func (*SessionRequest_DescribeSemaphore) ProtoMessage()

func (*SessionRequest_DescribeSemaphore) ProtoReflect

func (*SessionRequest_DescribeSemaphore) Reset

func (*SessionRequest_DescribeSemaphore) String

type SessionRequest_DescribeSemaphore_

type SessionRequest_DescribeSemaphore_ struct {
	DescribeSemaphore *SessionRequest_DescribeSemaphore `protobuf:"bytes,9,opt,name=describe_semaphore,json=describeSemaphore,proto3,oneof"`
}

type SessionRequest_Ping

type SessionRequest_Ping struct {
	Ping *SessionRequest_PingPong `protobuf:"bytes,1,opt,name=ping,proto3,oneof"`
}

type SessionRequest_PingPong

type SessionRequest_PingPong struct {

	// Opaque number specified in the ping message is echoed in the pong message
	Opaque uint64 `protobuf:"varint,1,opt,name=opaque,proto3" json:"opaque,omitempty"`
	// contains filtered or unexported fields
}

* Used for checking liveness of the connection

func (*SessionRequest_PingPong) Descriptor deprecated

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

Deprecated: Use SessionRequest_PingPong.ProtoReflect.Descriptor instead.

func (*SessionRequest_PingPong) GetOpaque

func (x *SessionRequest_PingPong) GetOpaque() uint64

func (*SessionRequest_PingPong) ProtoMessage

func (*SessionRequest_PingPong) ProtoMessage()

func (*SessionRequest_PingPong) ProtoReflect

func (x *SessionRequest_PingPong) ProtoReflect() protoreflect.Message

func (*SessionRequest_PingPong) Reset

func (x *SessionRequest_PingPong) Reset()

func (*SessionRequest_PingPong) String

func (x *SessionRequest_PingPong) String() string

type SessionRequest_Pong

type SessionRequest_Pong struct {
	Pong *SessionRequest_PingPong `protobuf:"bytes,2,opt,name=pong,proto3,oneof"`
}

type SessionRequest_ReleaseSemaphore

type SessionRequest_ReleaseSemaphore struct {

	// Client-defined request id, echoed in the response
	ReqId uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// Name of the semaphore to release
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

* Used to release a semaphore

WARNING: a single session cannot release the same semaphore multiple times

The release operation will either remove current session from waiters queue or release an already owned semaphore.

func (*SessionRequest_ReleaseSemaphore) Descriptor deprecated

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

Deprecated: Use SessionRequest_ReleaseSemaphore.ProtoReflect.Descriptor instead.

func (*SessionRequest_ReleaseSemaphore) GetName

func (*SessionRequest_ReleaseSemaphore) GetReqId

func (*SessionRequest_ReleaseSemaphore) ProtoMessage

func (*SessionRequest_ReleaseSemaphore) ProtoMessage()

func (*SessionRequest_ReleaseSemaphore) ProtoReflect

func (*SessionRequest_ReleaseSemaphore) Reset

func (*SessionRequest_ReleaseSemaphore) String

type SessionRequest_ReleaseSemaphore_

type SessionRequest_ReleaseSemaphore_ struct {
	ReleaseSemaphore *SessionRequest_ReleaseSemaphore `protobuf:"bytes,8,opt,name=release_semaphore,json=releaseSemaphore,proto3,oneof"`
}

type SessionRequest_SessionStart

type SessionRequest_SessionStart struct {

	// Path to a coordination node
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Non-zero when restoring a session, 0 when creating a new session
	SessionId uint64 `protobuf:"varint,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Timeout in milliseconds during which client may restore a detached session
	TimeoutMillis uint64 `protobuf:"varint,3,opt,name=timeout_millis,json=timeoutMillis,proto3" json:"timeout_millis,omitempty"`
	// User-defined description that may be used to describe the client
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Monotonically increasing sequence number generated by the client
	// When concurrent SessionStart requests are detected the one with
	// the biggest sequence number will succeed
	SeqNo uint64 `protobuf:"varint,5,opt,name=seq_no,json=seqNo,proto3" json:"seq_no,omitempty"`
	// Random bytes used to protect session from restore by other clients (max. 16 bytes)
	ProtectionKey []byte `protobuf:"bytes,6,opt,name=protection_key,json=protectionKey,proto3" json:"protection_key,omitempty"`
	// contains filtered or unexported fields
}

* First message used to start/restore a session

func (*SessionRequest_SessionStart) Descriptor deprecated

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

Deprecated: Use SessionRequest_SessionStart.ProtoReflect.Descriptor instead.

func (*SessionRequest_SessionStart) GetDescription

func (x *SessionRequest_SessionStart) GetDescription() string

func (*SessionRequest_SessionStart) GetPath

func (x *SessionRequest_SessionStart) GetPath() string

func (*SessionRequest_SessionStart) GetProtectionKey

func (x *SessionRequest_SessionStart) GetProtectionKey() []byte

func (*SessionRequest_SessionStart) GetSeqNo

func (x *SessionRequest_SessionStart) GetSeqNo() uint64

func (*SessionRequest_SessionStart) GetSessionId

func (x *SessionRequest_SessionStart) GetSessionId() uint64

func (*SessionRequest_SessionStart) GetTimeoutMillis

func (x *SessionRequest_SessionStart) GetTimeoutMillis() uint64

func (*SessionRequest_SessionStart) ProtoMessage

func (*SessionRequest_SessionStart) ProtoMessage()

func (*SessionRequest_SessionStart) ProtoReflect

func (*SessionRequest_SessionStart) Reset

func (x *SessionRequest_SessionStart) Reset()

func (*SessionRequest_SessionStart) String

func (x *SessionRequest_SessionStart) String() string

type SessionRequest_SessionStart_

type SessionRequest_SessionStart_ struct {
	SessionStart *SessionRequest_SessionStart `protobuf:"bytes,3,opt,name=session_start,json=sessionStart,proto3,oneof"`
}

type SessionRequest_SessionStop

type SessionRequest_SessionStop struct {
	// contains filtered or unexported fields
}

* Last message used to cleanly stop session before its timeout expires

func (*SessionRequest_SessionStop) Descriptor deprecated

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

Deprecated: Use SessionRequest_SessionStop.ProtoReflect.Descriptor instead.

func (*SessionRequest_SessionStop) ProtoMessage

func (*SessionRequest_SessionStop) ProtoMessage()

func (*SessionRequest_SessionStop) ProtoReflect

func (*SessionRequest_SessionStop) Reset

func (x *SessionRequest_SessionStop) Reset()

func (*SessionRequest_SessionStop) String

func (x *SessionRequest_SessionStop) String() string

type SessionRequest_SessionStop_

type SessionRequest_SessionStop_ struct {
	SessionStop *SessionRequest_SessionStop `protobuf:"bytes,4,opt,name=session_stop,json=sessionStop,proto3,oneof"`
}

type SessionRequest_Unsupported_13

type SessionRequest_Unsupported_13 struct {
	Unsupported_13 *Unsupported `protobuf:"bytes,13,opt,name=unsupported_13,json=unsupported13,proto3,oneof"`
}

type SessionRequest_Unsupported_14

type SessionRequest_Unsupported_14 struct {
	Unsupported_14 *Unsupported `protobuf:"bytes,14,opt,name=unsupported_14,json=unsupported14,proto3,oneof"`
}

type SessionRequest_Unsupported_15

type SessionRequest_Unsupported_15 struct {
	Unsupported_15 *Unsupported `protobuf:"bytes,15,opt,name=unsupported_15,json=unsupported15,proto3,oneof"`
}

type SessionRequest_Unsupported_5

type SessionRequest_Unsupported_5 struct {
	Unsupported_5 *Unsupported `protobuf:"bytes,5,opt,name=unsupported_5,json=unsupported5,proto3,oneof"`
}

type SessionRequest_Unsupported_6

type SessionRequest_Unsupported_6 struct {
	Unsupported_6 *Unsupported `protobuf:"bytes,6,opt,name=unsupported_6,json=unsupported6,proto3,oneof"`
}

type SessionRequest_UpdateSemaphore

type SessionRequest_UpdateSemaphore struct {

	// Client-defined request id, echoed in the response
	ReqId uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// Name of the semaphore to update
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// User-defined data that is attached to the semaphore
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

* Used to change semaphore data

func (*SessionRequest_UpdateSemaphore) Descriptor deprecated

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

Deprecated: Use SessionRequest_UpdateSemaphore.ProtoReflect.Descriptor instead.

func (*SessionRequest_UpdateSemaphore) GetData

func (x *SessionRequest_UpdateSemaphore) GetData() []byte

func (*SessionRequest_UpdateSemaphore) GetName

func (*SessionRequest_UpdateSemaphore) GetReqId

func (x *SessionRequest_UpdateSemaphore) GetReqId() uint64

func (*SessionRequest_UpdateSemaphore) ProtoMessage

func (*SessionRequest_UpdateSemaphore) ProtoMessage()

func (*SessionRequest_UpdateSemaphore) ProtoReflect

func (*SessionRequest_UpdateSemaphore) Reset

func (x *SessionRequest_UpdateSemaphore) Reset()

func (*SessionRequest_UpdateSemaphore) String

type SessionRequest_UpdateSemaphore_

type SessionRequest_UpdateSemaphore_ struct {
	UpdateSemaphore *SessionRequest_UpdateSemaphore `protobuf:"bytes,11,opt,name=update_semaphore,json=updateSemaphore,proto3,oneof"`
}

type SessionResponse

type SessionResponse struct {

	// Types that are assignable to Response:
	//
	//	*SessionResponse_Ping
	//	*SessionResponse_Pong
	//	*SessionResponse_Failure_
	//	*SessionResponse_SessionStarted_
	//	*SessionResponse_SessionStopped_
	//	*SessionResponse_Unsupported_6
	//	*SessionResponse_Unsupported_7
	//	*SessionResponse_AcquireSemaphorePending_
	//	*SessionResponse_AcquireSemaphoreResult_
	//	*SessionResponse_ReleaseSemaphoreResult_
	//	*SessionResponse_DescribeSemaphoreResult_
	//	*SessionResponse_DescribeSemaphoreChanged_
	//	*SessionResponse_CreateSemaphoreResult_
	//	*SessionResponse_UpdateSemaphoreResult_
	//	*SessionResponse_DeleteSemaphoreResult_
	//	*SessionResponse_Unsupported_16
	//	*SessionResponse_Unsupported_17
	//	*SessionResponse_Unsupported_18
	Response isSessionResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

* Session response message sent from server to client

func (*SessionResponse) Descriptor deprecated

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

Deprecated: Use SessionResponse.ProtoReflect.Descriptor instead.

func (*SessionResponse) GetAcquireSemaphorePending

func (x *SessionResponse) GetAcquireSemaphorePending() *SessionResponse_AcquireSemaphorePending

func (*SessionResponse) GetAcquireSemaphoreResult

func (x *SessionResponse) GetAcquireSemaphoreResult() *SessionResponse_AcquireSemaphoreResult

func (*SessionResponse) GetCreateSemaphoreResult

func (x *SessionResponse) GetCreateSemaphoreResult() *SessionResponse_CreateSemaphoreResult

func (*SessionResponse) GetDeleteSemaphoreResult

func (x *SessionResponse) GetDeleteSemaphoreResult() *SessionResponse_DeleteSemaphoreResult

func (*SessionResponse) GetDescribeSemaphoreChanged

func (x *SessionResponse) GetDescribeSemaphoreChanged() *SessionResponse_DescribeSemaphoreChanged

func (*SessionResponse) GetDescribeSemaphoreResult

func (x *SessionResponse) GetDescribeSemaphoreResult() *SessionResponse_DescribeSemaphoreResult

func (*SessionResponse) GetFailure

func (x *SessionResponse) GetFailure() *SessionResponse_Failure

func (*SessionResponse) GetPing

func (*SessionResponse) GetPong

func (*SessionResponse) GetReleaseSemaphoreResult

func (x *SessionResponse) GetReleaseSemaphoreResult() *SessionResponse_ReleaseSemaphoreResult

func (*SessionResponse) GetResponse

func (m *SessionResponse) GetResponse() isSessionResponse_Response

func (*SessionResponse) GetSessionStarted

func (x *SessionResponse) GetSessionStarted() *SessionResponse_SessionStarted

func (*SessionResponse) GetSessionStopped

func (x *SessionResponse) GetSessionStopped() *SessionResponse_SessionStopped

func (*SessionResponse) GetUnsupported_16

func (x *SessionResponse) GetUnsupported_16() *Unsupported

func (*SessionResponse) GetUnsupported_17

func (x *SessionResponse) GetUnsupported_17() *Unsupported

func (*SessionResponse) GetUnsupported_18

func (x *SessionResponse) GetUnsupported_18() *Unsupported

func (*SessionResponse) GetUnsupported_6

func (x *SessionResponse) GetUnsupported_6() *Unsupported

func (*SessionResponse) GetUnsupported_7

func (x *SessionResponse) GetUnsupported_7() *Unsupported

func (*SessionResponse) GetUpdateSemaphoreResult

func (x *SessionResponse) GetUpdateSemaphoreResult() *SessionResponse_UpdateSemaphoreResult

func (*SessionResponse) ProtoMessage

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) ProtoReflect

func (x *SessionResponse) ProtoReflect() protoreflect.Message

func (*SessionResponse) Reset

func (x *SessionResponse) Reset()

func (*SessionResponse) String

func (x *SessionResponse) String() string

type SessionResponse_AcquireSemaphorePending

type SessionResponse_AcquireSemaphorePending struct {
	ReqId uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	// contains filtered or unexported fields
}

* Used by the server to report when an acquire operation is added to the waiters queue

func (*SessionResponse_AcquireSemaphorePending) Descriptor deprecated

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

Deprecated: Use SessionResponse_AcquireSemaphorePending.ProtoReflect.Descriptor instead.

func (*SessionResponse_AcquireSemaphorePending) GetReqId

func (*SessionResponse_AcquireSemaphorePending) ProtoMessage

func (*SessionResponse_AcquireSemaphorePending) ProtoReflect

func (*SessionResponse_AcquireSemaphorePending) Reset

func (*SessionResponse_AcquireSemaphorePending) String

type SessionResponse_AcquireSemaphorePending_

type SessionResponse_AcquireSemaphorePending_ struct {
	AcquireSemaphorePending *SessionResponse_AcquireSemaphorePending `protobuf:"bytes,8,opt,name=acquire_semaphore_pending,json=acquireSemaphorePending,proto3,oneof"`
}

type SessionResponse_AcquireSemaphoreResult

type SessionResponse_AcquireSemaphoreResult struct {
	ReqId  uint64                    `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	Status Ydb.StatusIds_StatusCode  `protobuf:"varint,2,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	// True if semaphore was acquired, false if acquire timed out
	Acquired bool `protobuf:"varint,4,opt,name=acquired,proto3" json:"acquired,omitempty"`
	// contains filtered or unexported fields
}

* Used by the server to report the result of an acquire operation

func (*SessionResponse_AcquireSemaphoreResult) Descriptor deprecated

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

Deprecated: Use SessionResponse_AcquireSemaphoreResult.ProtoReflect.Descriptor instead.

func (*SessionResponse_AcquireSemaphoreResult) GetAcquired

func (*SessionResponse_AcquireSemaphoreResult) GetIssues

func (*SessionResponse_AcquireSemaphoreResult) GetReqId

func (*SessionResponse_AcquireSemaphoreResult) GetStatus

func (*SessionResponse_AcquireSemaphoreResult) ProtoMessage

func (*SessionResponse_AcquireSemaphoreResult) ProtoReflect

func (*SessionResponse_AcquireSemaphoreResult) Reset

func (*SessionResponse_AcquireSemaphoreResult) String

type SessionResponse_AcquireSemaphoreResult_

type SessionResponse_AcquireSemaphoreResult_ struct {
	AcquireSemaphoreResult *SessionResponse_AcquireSemaphoreResult `protobuf:"bytes,9,opt,name=acquire_semaphore_result,json=acquireSemaphoreResult,proto3,oneof"`
}

type SessionResponse_CreateSemaphoreResult

type SessionResponse_CreateSemaphoreResult struct {
	ReqId  uint64                    `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	Status Ydb.StatusIds_StatusCode  `protobuf:"varint,2,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

* The result of semaphore creation

func (*SessionResponse_CreateSemaphoreResult) Descriptor deprecated

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

Deprecated: Use SessionResponse_CreateSemaphoreResult.ProtoReflect.Descriptor instead.

func (*SessionResponse_CreateSemaphoreResult) GetIssues

func (*SessionResponse_CreateSemaphoreResult) GetReqId

func (*SessionResponse_CreateSemaphoreResult) GetStatus

func (*SessionResponse_CreateSemaphoreResult) ProtoMessage

func (*SessionResponse_CreateSemaphoreResult) ProtoMessage()

func (*SessionResponse_CreateSemaphoreResult) ProtoReflect

func (*SessionResponse_CreateSemaphoreResult) Reset

func (*SessionResponse_CreateSemaphoreResult) String

type SessionResponse_CreateSemaphoreResult_

type SessionResponse_CreateSemaphoreResult_ struct {
	CreateSemaphoreResult *SessionResponse_CreateSemaphoreResult `protobuf:"bytes,13,opt,name=create_semaphore_result,json=createSemaphoreResult,proto3,oneof"`
}

type SessionResponse_DeleteSemaphoreResult

type SessionResponse_DeleteSemaphoreResult struct {
	ReqId  uint64                    `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	Status Ydb.StatusIds_StatusCode  `protobuf:"varint,2,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

* The result of semaphore deletion

func (*SessionResponse_DeleteSemaphoreResult) Descriptor deprecated

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

Deprecated: Use SessionResponse_DeleteSemaphoreResult.ProtoReflect.Descriptor instead.

func (*SessionResponse_DeleteSemaphoreResult) GetIssues

func (*SessionResponse_DeleteSemaphoreResult) GetReqId

func (*SessionResponse_DeleteSemaphoreResult) GetStatus

func (*SessionResponse_DeleteSemaphoreResult) ProtoMessage

func (*SessionResponse_DeleteSemaphoreResult) ProtoMessage()

func (*SessionResponse_DeleteSemaphoreResult) ProtoReflect

func (*SessionResponse_DeleteSemaphoreResult) Reset

func (*SessionResponse_DeleteSemaphoreResult) String

type SessionResponse_DeleteSemaphoreResult_

type SessionResponse_DeleteSemaphoreResult_ struct {
	DeleteSemaphoreResult *SessionResponse_DeleteSemaphoreResult `protobuf:"bytes,15,opt,name=delete_semaphore_result,json=deleteSemaphoreResult,proto3,oneof"`
}

type SessionResponse_DescribeSemaphoreChanged

type SessionResponse_DescribeSemaphoreChanged struct {
	ReqId         uint64 `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	DataChanged   bool   `protobuf:"varint,2,opt,name=data_changed,json=dataChanged,proto3" json:"data_changed,omitempty"`
	OwnersChanged bool   `protobuf:"varint,3,opt,name=owners_changed,json=ownersChanged,proto3" json:"owners_changed,omitempty"`
	// contains filtered or unexported fields
}

* Used to report a change in the watched semaphore

func (*SessionResponse_DescribeSemaphoreChanged) Descriptor deprecated

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

Deprecated: Use SessionResponse_DescribeSemaphoreChanged.ProtoReflect.Descriptor instead.

func (*SessionResponse_DescribeSemaphoreChanged) GetDataChanged

func (x *SessionResponse_DescribeSemaphoreChanged) GetDataChanged() bool

func (*SessionResponse_DescribeSemaphoreChanged) GetOwnersChanged

func (x *SessionResponse_DescribeSemaphoreChanged) GetOwnersChanged() bool

func (*SessionResponse_DescribeSemaphoreChanged) GetReqId

func (*SessionResponse_DescribeSemaphoreChanged) ProtoMessage

func (*SessionResponse_DescribeSemaphoreChanged) ProtoReflect

func (*SessionResponse_DescribeSemaphoreChanged) Reset

func (*SessionResponse_DescribeSemaphoreChanged) String

type SessionResponse_DescribeSemaphoreChanged_

type SessionResponse_DescribeSemaphoreChanged_ struct {
	DescribeSemaphoreChanged *SessionResponse_DescribeSemaphoreChanged `protobuf:"bytes,12,opt,name=describe_semaphore_changed,json=describeSemaphoreChanged,proto3,oneof"`
}

type SessionResponse_DescribeSemaphoreResult

type SessionResponse_DescribeSemaphoreResult struct {
	ReqId                uint64                    `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	Status               Ydb.StatusIds_StatusCode  `protobuf:"varint,2,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues               []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	SemaphoreDescription *SemaphoreDescription     `protobuf:"bytes,4,opt,name=semaphore_description,json=semaphoreDescription,proto3" json:"semaphore_description,omitempty"`
	// True if a watch has been added for the semaphore
	WatchAdded bool `protobuf:"varint,5,opt,name=watch_added,json=watchAdded,proto3" json:"watch_added,omitempty"`
	// contains filtered or unexported fields
}

* The result of the describe operation

func (*SessionResponse_DescribeSemaphoreResult) Descriptor deprecated

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

Deprecated: Use SessionResponse_DescribeSemaphoreResult.ProtoReflect.Descriptor instead.

func (*SessionResponse_DescribeSemaphoreResult) GetIssues

func (*SessionResponse_DescribeSemaphoreResult) GetReqId

func (*SessionResponse_DescribeSemaphoreResult) GetSemaphoreDescription

func (x *SessionResponse_DescribeSemaphoreResult) GetSemaphoreDescription() *SemaphoreDescription

func (*SessionResponse_DescribeSemaphoreResult) GetStatus

func (*SessionResponse_DescribeSemaphoreResult) GetWatchAdded

func (x *SessionResponse_DescribeSemaphoreResult) GetWatchAdded() bool

func (*SessionResponse_DescribeSemaphoreResult) ProtoMessage

func (*SessionResponse_DescribeSemaphoreResult) ProtoReflect

func (*SessionResponse_DescribeSemaphoreResult) Reset

func (*SessionResponse_DescribeSemaphoreResult) String

type SessionResponse_DescribeSemaphoreResult_

type SessionResponse_DescribeSemaphoreResult_ struct {
	DescribeSemaphoreResult *SessionResponse_DescribeSemaphoreResult `protobuf:"bytes,11,opt,name=describe_semaphore_result,json=describeSemaphoreResult,proto3,oneof"`
}

type SessionResponse_Failure

type SessionResponse_Failure struct {
	Status Ydb.StatusIds_StatusCode  `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,2,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

* Used to report connection and session level failures

func (*SessionResponse_Failure) Descriptor deprecated

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

Deprecated: Use SessionResponse_Failure.ProtoReflect.Descriptor instead.

func (*SessionResponse_Failure) GetIssues

func (*SessionResponse_Failure) GetStatus

func (*SessionResponse_Failure) ProtoMessage

func (*SessionResponse_Failure) ProtoMessage()

func (*SessionResponse_Failure) ProtoReflect

func (x *SessionResponse_Failure) ProtoReflect() protoreflect.Message

func (*SessionResponse_Failure) Reset

func (x *SessionResponse_Failure) Reset()

func (*SessionResponse_Failure) String

func (x *SessionResponse_Failure) String() string

type SessionResponse_Failure_

type SessionResponse_Failure_ struct {
	Failure *SessionResponse_Failure `protobuf:"bytes,3,opt,name=failure,proto3,oneof"`
}

type SessionResponse_Ping

type SessionResponse_Ping struct {
	Ping *SessionResponse_PingPong `protobuf:"bytes,1,opt,name=ping,proto3,oneof"`
}

type SessionResponse_PingPong

type SessionResponse_PingPong struct {

	// Opaque number specified in the ping message is echoed in the pong message
	Opaque uint64 `protobuf:"varint,1,opt,name=opaque,proto3" json:"opaque,omitempty"`
	// contains filtered or unexported fields
}

* Used for checking liveness of the connection

func (*SessionResponse_PingPong) Descriptor deprecated

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

Deprecated: Use SessionResponse_PingPong.ProtoReflect.Descriptor instead.

func (*SessionResponse_PingPong) GetOpaque

func (x *SessionResponse_PingPong) GetOpaque() uint64

func (*SessionResponse_PingPong) ProtoMessage

func (*SessionResponse_PingPong) ProtoMessage()

func (*SessionResponse_PingPong) ProtoReflect

func (x *SessionResponse_PingPong) ProtoReflect() protoreflect.Message

func (*SessionResponse_PingPong) Reset

func (x *SessionResponse_PingPong) Reset()

func (*SessionResponse_PingPong) String

func (x *SessionResponse_PingPong) String() string

type SessionResponse_Pong

type SessionResponse_Pong struct {
	Pong *SessionResponse_PingPong `protobuf:"bytes,2,opt,name=pong,proto3,oneof"`
}

type SessionResponse_ReleaseSemaphoreResult

type SessionResponse_ReleaseSemaphoreResult struct {
	ReqId  uint64                    `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	Status Ydb.StatusIds_StatusCode  `protobuf:"varint,2,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	// True if semaphore was released, false if there was no active acquire operation
	Released bool `protobuf:"varint,4,opt,name=released,proto3" json:"released,omitempty"`
	// contains filtered or unexported fields
}

* Used by the server to report the result of a release operation

func (*SessionResponse_ReleaseSemaphoreResult) Descriptor deprecated

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

Deprecated: Use SessionResponse_ReleaseSemaphoreResult.ProtoReflect.Descriptor instead.

func (*SessionResponse_ReleaseSemaphoreResult) GetIssues

func (*SessionResponse_ReleaseSemaphoreResult) GetReleased

func (*SessionResponse_ReleaseSemaphoreResult) GetReqId

func (*SessionResponse_ReleaseSemaphoreResult) GetStatus

func (*SessionResponse_ReleaseSemaphoreResult) ProtoMessage

func (*SessionResponse_ReleaseSemaphoreResult) ProtoReflect

func (*SessionResponse_ReleaseSemaphoreResult) Reset

func (*SessionResponse_ReleaseSemaphoreResult) String

type SessionResponse_ReleaseSemaphoreResult_

type SessionResponse_ReleaseSemaphoreResult_ struct {
	ReleaseSemaphoreResult *SessionResponse_ReleaseSemaphoreResult `protobuf:"bytes,10,opt,name=release_semaphore_result,json=releaseSemaphoreResult,proto3,oneof"`
}

type SessionResponse_SessionStarted

type SessionResponse_SessionStarted struct {

	// A server generation id that may be used for restoring the session
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Timeout in milliseconds that will be used by the server
	TimeoutMillis uint64 `protobuf:"varint,2,opt,name=timeout_millis,json=timeoutMillis,proto3" json:"timeout_millis,omitempty"`
	// contains filtered or unexported fields
}

* Used to report a successful session create/restore operation

func (*SessionResponse_SessionStarted) Descriptor deprecated

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

Deprecated: Use SessionResponse_SessionStarted.ProtoReflect.Descriptor instead.

func (*SessionResponse_SessionStarted) GetSessionId

func (x *SessionResponse_SessionStarted) GetSessionId() uint64

func (*SessionResponse_SessionStarted) GetTimeoutMillis

func (x *SessionResponse_SessionStarted) GetTimeoutMillis() uint64

func (*SessionResponse_SessionStarted) ProtoMessage

func (*SessionResponse_SessionStarted) ProtoMessage()

func (*SessionResponse_SessionStarted) ProtoReflect

func (*SessionResponse_SessionStarted) Reset

func (x *SessionResponse_SessionStarted) Reset()

func (*SessionResponse_SessionStarted) String

type SessionResponse_SessionStarted_

type SessionResponse_SessionStarted_ struct {
	SessionStarted *SessionResponse_SessionStarted `protobuf:"bytes,4,opt,name=session_started,json=sessionStarted,proto3,oneof"`
}

type SessionResponse_SessionStopped

type SessionResponse_SessionStopped struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

* Used to report a successful graceful termination of the session

func (*SessionResponse_SessionStopped) Descriptor deprecated

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

Deprecated: Use SessionResponse_SessionStopped.ProtoReflect.Descriptor instead.

func (*SessionResponse_SessionStopped) GetSessionId

func (x *SessionResponse_SessionStopped) GetSessionId() uint64

func (*SessionResponse_SessionStopped) ProtoMessage

func (*SessionResponse_SessionStopped) ProtoMessage()

func (*SessionResponse_SessionStopped) ProtoReflect

func (*SessionResponse_SessionStopped) Reset

func (x *SessionResponse_SessionStopped) Reset()

func (*SessionResponse_SessionStopped) String

type SessionResponse_SessionStopped_

type SessionResponse_SessionStopped_ struct {
	SessionStopped *SessionResponse_SessionStopped `protobuf:"bytes,5,opt,name=session_stopped,json=sessionStopped,proto3,oneof"`
}

type SessionResponse_Unsupported_16

type SessionResponse_Unsupported_16 struct {
	Unsupported_16 *Unsupported `protobuf:"bytes,16,opt,name=unsupported_16,json=unsupported16,proto3,oneof"`
}

type SessionResponse_Unsupported_17

type SessionResponse_Unsupported_17 struct {
	Unsupported_17 *Unsupported `protobuf:"bytes,17,opt,name=unsupported_17,json=unsupported17,proto3,oneof"`
}

type SessionResponse_Unsupported_18

type SessionResponse_Unsupported_18 struct {
	Unsupported_18 *Unsupported `protobuf:"bytes,18,opt,name=unsupported_18,json=unsupported18,proto3,oneof"`
}

type SessionResponse_Unsupported_6

type SessionResponse_Unsupported_6 struct {
	Unsupported_6 *Unsupported `protobuf:"bytes,6,opt,name=unsupported_6,json=unsupported6,proto3,oneof"`
}

type SessionResponse_Unsupported_7

type SessionResponse_Unsupported_7 struct {
	Unsupported_7 *Unsupported `protobuf:"bytes,7,opt,name=unsupported_7,json=unsupported7,proto3,oneof"`
}

type SessionResponse_UpdateSemaphoreResult

type SessionResponse_UpdateSemaphoreResult struct {
	ReqId  uint64                    `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	Status Ydb.StatusIds_StatusCode  `protobuf:"varint,2,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

* The result of semaphore update

func (*SessionResponse_UpdateSemaphoreResult) Descriptor deprecated

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

Deprecated: Use SessionResponse_UpdateSemaphoreResult.ProtoReflect.Descriptor instead.

func (*SessionResponse_UpdateSemaphoreResult) GetIssues

func (*SessionResponse_UpdateSemaphoreResult) GetReqId

func (*SessionResponse_UpdateSemaphoreResult) GetStatus

func (*SessionResponse_UpdateSemaphoreResult) ProtoMessage

func (*SessionResponse_UpdateSemaphoreResult) ProtoMessage()

func (*SessionResponse_UpdateSemaphoreResult) ProtoReflect

func (*SessionResponse_UpdateSemaphoreResult) Reset

func (*SessionResponse_UpdateSemaphoreResult) String

type SessionResponse_UpdateSemaphoreResult_

type SessionResponse_UpdateSemaphoreResult_ struct {
	UpdateSemaphoreResult *SessionResponse_UpdateSemaphoreResult `protobuf:"bytes,14,opt,name=update_semaphore_result,json=updateSemaphoreResult,proto3,oneof"`
}

type Unsupported

type Unsupported struct {
	// contains filtered or unexported fields
}

* Stub for unsupported messages

func (*Unsupported) Descriptor deprecated

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

Deprecated: Use Unsupported.ProtoReflect.Descriptor instead.

func (*Unsupported) ProtoMessage

func (*Unsupported) ProtoMessage()

func (*Unsupported) ProtoReflect

func (x *Unsupported) ProtoReflect() protoreflect.Message

func (*Unsupported) Reset

func (x *Unsupported) Reset()

func (*Unsupported) String

func (x *Unsupported) String() string

Jump to

Keyboard shortcuts

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