Ydb_Coordination

package
v0.0.0-...-8dd88c8 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

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) Descriptor() protoreflect.EnumDescriptor

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 (x ConsistencyMode) Number() protoreflect.EnumNumber

func (ConsistencyMode) String 

func (x ConsistencyMode) String() string

func (ConsistencyMode) Type 

func (ConsistencyMode) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (RateLimiterCountersMode) Enum 

func (x RateLimiterCountersMode) Enum() *RateLimiterCountersMode

func (RateLimiterCountersMode) EnumDescriptor deprecated 

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

Deprecated: Use RateLimiterCountersMode.Descriptor instead.

func (RateLimiterCountersMode) Number 

func (x RateLimiterCountersMode) Number() protoreflect.EnumNumber

func (RateLimiterCountersMode) String 

func (x RateLimiterCountersMode) String() string

func (RateLimiterCountersMode) Type 

func (RateLimiterCountersMode) Type() protoreflect.EnumType

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 (x *SessionRequest) GetPing() *SessionRequest_PingPong

func (*SessionRequest) GetPong 

func (x *SessionRequest) GetPong() *SessionRequest_PingPong

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 (x *SessionRequest_AcquireSemaphore) GetCount() uint64

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 (x *SessionRequest_AcquireSemaphore) GetName() string

func (*SessionRequest_AcquireSemaphore) GetReqId 

func (x *SessionRequest_AcquireSemaphore) GetReqId() uint64

func (*SessionRequest_AcquireSemaphore) GetTimeoutMillis 

func (x *SessionRequest_AcquireSemaphore) GetTimeoutMillis() uint64

func (*SessionRequest_AcquireSemaphore) ProtoMessage 

func (*SessionRequest_AcquireSemaphore) ProtoMessage()

func (*SessionRequest_AcquireSemaphore) ProtoReflect 

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

func (*SessionRequest_AcquireSemaphore) Reset 

func (x *SessionRequest_AcquireSemaphore) Reset()

func (*SessionRequest_AcquireSemaphore) String 

func (x *SessionRequest_AcquireSemaphore) String() 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 (x *SessionRequest_CreateSemaphore) GetName() string

func (*SessionRequest_CreateSemaphore) GetReqId 

func (x *SessionRequest_CreateSemaphore) GetReqId() uint64

func (*SessionRequest_CreateSemaphore) ProtoMessage 

func (*SessionRequest_CreateSemaphore) ProtoMessage()

func (*SessionRequest_CreateSemaphore) ProtoReflect 

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

func (*SessionRequest_CreateSemaphore) Reset 

func (x *SessionRequest_CreateSemaphore) Reset()

func (*SessionRequest_CreateSemaphore) String 

func (x *SessionRequest_CreateSemaphore) String() 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 (x *SessionRequest_DeleteSemaphore) GetName() string

func (*SessionRequest_DeleteSemaphore) GetReqId 

func (x *SessionRequest_DeleteSemaphore) GetReqId() uint64

func (*SessionRequest_DeleteSemaphore) ProtoMessage 

func (*SessionRequest_DeleteSemaphore) ProtoMessage()

func (*SessionRequest_DeleteSemaphore) ProtoReflect 

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

func (*SessionRequest_DeleteSemaphore) Reset 

func (x *SessionRequest_DeleteSemaphore) Reset()

func (*SessionRequest_DeleteSemaphore) String 

func (x *SessionRequest_DeleteSemaphore) String() 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 (x *SessionRequest_DescribeSemaphore) GetName() string

func (*SessionRequest_DescribeSemaphore) GetReqId 

func (x *SessionRequest_DescribeSemaphore) GetReqId() uint64

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 (x *SessionRequest_DescribeSemaphore) ProtoReflect() protoreflect.Message

func (*SessionRequest_DescribeSemaphore) Reset 

func (x *SessionRequest_DescribeSemaphore) Reset()

func (*SessionRequest_DescribeSemaphore) String 

func (x *SessionRequest_DescribeSemaphore) String() 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 (x *SessionRequest_ReleaseSemaphore) GetName() string

func (*SessionRequest_ReleaseSemaphore) GetReqId 

func (x *SessionRequest_ReleaseSemaphore) GetReqId() uint64

func (*SessionRequest_ReleaseSemaphore) ProtoMessage 

func (*SessionRequest_ReleaseSemaphore) ProtoMessage()

func (*SessionRequest_ReleaseSemaphore) ProtoReflect 

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

func (*SessionRequest_ReleaseSemaphore) Reset 

func (x *SessionRequest_ReleaseSemaphore) Reset()

func (*SessionRequest_ReleaseSemaphore) String 

func (x *SessionRequest_ReleaseSemaphore) String() 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 (x *SessionRequest_SessionStart) ProtoReflect() protoreflect.Message

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 (x *SessionRequest_SessionStop) ProtoReflect() protoreflect.Message

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 (x *SessionRequest_UpdateSemaphore) GetName() string

func (*SessionRequest_UpdateSemaphore) GetReqId 

func (x *SessionRequest_UpdateSemaphore) GetReqId() uint64

func (*SessionRequest_UpdateSemaphore) ProtoMessage 

func (*SessionRequest_UpdateSemaphore) ProtoMessage()

func (*SessionRequest_UpdateSemaphore) ProtoReflect 

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

func (*SessionRequest_UpdateSemaphore) Reset 

func (x *SessionRequest_UpdateSemaphore) Reset()

func (*SessionRequest_UpdateSemaphore) String 

func (x *SessionRequest_UpdateSemaphore) String() 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 (x *SessionResponse) GetPing() *SessionResponse_PingPong

func (*SessionResponse) GetPong 

func (x *SessionResponse) GetPong() *SessionResponse_PingPong

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 (x *SessionResponse_AcquireSemaphorePending) GetReqId() uint64

func (*SessionResponse_AcquireSemaphorePending) ProtoMessage 

func (*SessionResponse_AcquireSemaphorePending) ProtoMessage()

func (*SessionResponse_AcquireSemaphorePending) ProtoReflect 

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

func (*SessionResponse_AcquireSemaphorePending) Reset 

func (x *SessionResponse_AcquireSemaphorePending) Reset()

func (*SessionResponse_AcquireSemaphorePending) String 

func (x *SessionResponse_AcquireSemaphorePending) String() 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 (x *SessionResponse_AcquireSemaphoreResult) GetAcquired() bool

func (*SessionResponse_AcquireSemaphoreResult) GetIssues 

func (x *SessionResponse_AcquireSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_AcquireSemaphoreResult) GetReqId 

func (x *SessionResponse_AcquireSemaphoreResult) GetReqId() uint64

func (*SessionResponse_AcquireSemaphoreResult) GetStatus 

func (x *SessionResponse_AcquireSemaphoreResult) GetStatus() Ydb.StatusIds_StatusCode

func (*SessionResponse_AcquireSemaphoreResult) ProtoMessage 

func (*SessionResponse_AcquireSemaphoreResult) ProtoMessage()

func (*SessionResponse_AcquireSemaphoreResult) ProtoReflect 

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

func (*SessionResponse_AcquireSemaphoreResult) Reset 

func (x *SessionResponse_AcquireSemaphoreResult) Reset()

func (*SessionResponse_AcquireSemaphoreResult) String 

func (x *SessionResponse_AcquireSemaphoreResult) String() 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 (x *SessionResponse_CreateSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_CreateSemaphoreResult) GetReqId 

func (x *SessionResponse_CreateSemaphoreResult) GetReqId() uint64

func (*SessionResponse_CreateSemaphoreResult) GetStatus 

func (x *SessionResponse_CreateSemaphoreResult) GetStatus() Ydb.StatusIds_StatusCode

func (*SessionResponse_CreateSemaphoreResult) ProtoMessage 

func (*SessionResponse_CreateSemaphoreResult) ProtoMessage()

func (*SessionResponse_CreateSemaphoreResult) ProtoReflect 

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

func (*SessionResponse_CreateSemaphoreResult) Reset 

func (x *SessionResponse_CreateSemaphoreResult) Reset()

func (*SessionResponse_CreateSemaphoreResult) String 

func (x *SessionResponse_CreateSemaphoreResult) String() 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 (x *SessionResponse_DeleteSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_DeleteSemaphoreResult) GetReqId 

func (x *SessionResponse_DeleteSemaphoreResult) GetReqId() uint64

func (*SessionResponse_DeleteSemaphoreResult) GetStatus 

func (x *SessionResponse_DeleteSemaphoreResult) GetStatus() Ydb.StatusIds_StatusCode

func (*SessionResponse_DeleteSemaphoreResult) ProtoMessage 

func (*SessionResponse_DeleteSemaphoreResult) ProtoMessage()

func (*SessionResponse_DeleteSemaphoreResult) ProtoReflect 

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

func (*SessionResponse_DeleteSemaphoreResult) Reset 

func (x *SessionResponse_DeleteSemaphoreResult) Reset()

func (*SessionResponse_DeleteSemaphoreResult) String 

func (x *SessionResponse_DeleteSemaphoreResult) String() 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 (x *SessionResponse_DescribeSemaphoreChanged) GetReqId() uint64

func (*SessionResponse_DescribeSemaphoreChanged) ProtoMessage 

func (*SessionResponse_DescribeSemaphoreChanged) ProtoMessage()

func (*SessionResponse_DescribeSemaphoreChanged) ProtoReflect 

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

func (*SessionResponse_DescribeSemaphoreChanged) Reset 

func (x *SessionResponse_DescribeSemaphoreChanged) Reset()

func (*SessionResponse_DescribeSemaphoreChanged) String 

func (x *SessionResponse_DescribeSemaphoreChanged) String() 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 (x *SessionResponse_DescribeSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_DescribeSemaphoreResult) GetReqId 

func (x *SessionResponse_DescribeSemaphoreResult) GetReqId() uint64

func (*SessionResponse_DescribeSemaphoreResult) GetSemaphoreDescription 

func (x *SessionResponse_DescribeSemaphoreResult) GetSemaphoreDescription() *SemaphoreDescription

func (*SessionResponse_DescribeSemaphoreResult) GetStatus 

func (x *SessionResponse_DescribeSemaphoreResult) GetStatus() Ydb.StatusIds_StatusCode

func (*SessionResponse_DescribeSemaphoreResult) GetWatchAdded 

func (x *SessionResponse_DescribeSemaphoreResult) GetWatchAdded() bool

func (*SessionResponse_DescribeSemaphoreResult) ProtoMessage 

func (*SessionResponse_DescribeSemaphoreResult) ProtoMessage()

func (*SessionResponse_DescribeSemaphoreResult) ProtoReflect 

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

func (*SessionResponse_DescribeSemaphoreResult) Reset 

func (x *SessionResponse_DescribeSemaphoreResult) Reset()

func (*SessionResponse_DescribeSemaphoreResult) String 

func (x *SessionResponse_DescribeSemaphoreResult) String() 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 (x *SessionResponse_Failure) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_Failure) GetStatus 

func (x *SessionResponse_Failure) GetStatus() Ydb.StatusIds_StatusCode

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 (x *SessionResponse_ReleaseSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_ReleaseSemaphoreResult) GetReleased 

func (x *SessionResponse_ReleaseSemaphoreResult) GetReleased() bool

func (*SessionResponse_ReleaseSemaphoreResult) GetReqId 

func (x *SessionResponse_ReleaseSemaphoreResult) GetReqId() uint64

func (*SessionResponse_ReleaseSemaphoreResult) GetStatus 

func (x *SessionResponse_ReleaseSemaphoreResult) GetStatus() Ydb.StatusIds_StatusCode

func (*SessionResponse_ReleaseSemaphoreResult) ProtoMessage 

func (*SessionResponse_ReleaseSemaphoreResult) ProtoMessage()

func (*SessionResponse_ReleaseSemaphoreResult) ProtoReflect 

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

func (*SessionResponse_ReleaseSemaphoreResult) Reset 

func (x *SessionResponse_ReleaseSemaphoreResult) Reset()

func (*SessionResponse_ReleaseSemaphoreResult) String 

func (x *SessionResponse_ReleaseSemaphoreResult) String() 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 (x *SessionResponse_SessionStarted) ProtoReflect() protoreflect.Message

func (*SessionResponse_SessionStarted) Reset 

func (x *SessionResponse_SessionStarted) Reset()

func (*SessionResponse_SessionStarted) String 

func (x *SessionResponse_SessionStarted) String() 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 (x *SessionResponse_SessionStopped) ProtoReflect() protoreflect.Message

func (*SessionResponse_SessionStopped) Reset 

func (x *SessionResponse_SessionStopped) Reset()

func (*SessionResponse_SessionStopped) String 

func (x *SessionResponse_SessionStopped) String() 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 (x *SessionResponse_UpdateSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_UpdateSemaphoreResult) GetReqId 

func (x *SessionResponse_UpdateSemaphoreResult) GetReqId() uint64

func (*SessionResponse_UpdateSemaphoreResult) GetStatus 

func (x *SessionResponse_UpdateSemaphoreResult) GetStatus() Ydb.StatusIds_StatusCode

func (*SessionResponse_UpdateSemaphoreResult) ProtoMessage 

func (*SessionResponse_UpdateSemaphoreResult) ProtoMessage()

func (*SessionResponse_UpdateSemaphoreResult) ProtoReflect 

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

func (*SessionResponse_UpdateSemaphoreResult) Reset 

func (x *SessionResponse_UpdateSemaphoreResult) Reset()

func (*SessionResponse_UpdateSemaphoreResult) String 

func (x *SessionResponse_UpdateSemaphoreResult) String() 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.