Ydb_Coordination

package
v2.4.1 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2021 License: Apache-2.0 Imports: 7 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",
}
View Source 
var ConsistencyMode_value = map[string]int32{
	"CONSISTENCY_MODE_UNSET":   0,
	"CONSISTENCY_MODE_STRICT":  1,
	"CONSISTENCY_MODE_RELAXED": 2,
}
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",
}
View Source 
var RateLimiterCountersMode_value = map[string]int32{
	"RATE_LIMITER_COUNTERS_MODE_UNSET":      0,
	"RATE_LIMITER_COUNTERS_MODE_AGGREGATED": 1,
	"RATE_LIMITER_COUNTERS_MODE_DETAILED":   2,
}

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*AlterNodeRequest) Descriptor 

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

func (*AlterNodeRequest) GetConfig 

func (m *AlterNodeRequest) GetConfig() *Config

func (*AlterNodeRequest) GetOperationParams 

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

func (*AlterNodeRequest) GetPath 

func (m *AlterNodeRequest) GetPath() string

func (*AlterNodeRequest) ProtoMessage 

func (*AlterNodeRequest) ProtoMessage()

func (*AlterNodeRequest) Reset 

func (m *AlterNodeRequest) Reset()

func (*AlterNodeRequest) SetOperationParams 

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

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

func (*AlterNodeRequest) String 

func (m *AlterNodeRequest) String() string

func (*AlterNodeRequest) XXX_DiscardUnknown 

func (m *AlterNodeRequest) XXX_DiscardUnknown()

func (*AlterNodeRequest) XXX_Marshal 

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

func (*AlterNodeRequest) XXX_Merge 

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

func (*AlterNodeRequest) XXX_Size 

func (m *AlterNodeRequest) XXX_Size() int

func (*AlterNodeRequest) XXX_Unmarshal 

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

type AlterNodeResponse 

type AlterNodeResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*AlterNodeResponse) Descriptor 

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

func (*AlterNodeResponse) GetOperation 

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

func (*AlterNodeResponse) ProtoMessage 

func (*AlterNodeResponse) ProtoMessage()

func (*AlterNodeResponse) Reset 

func (m *AlterNodeResponse) Reset()

func (*AlterNodeResponse) String 

func (m *AlterNodeResponse) String() string

func (*AlterNodeResponse) XXX_DiscardUnknown 

func (m *AlterNodeResponse) XXX_DiscardUnknown()

func (*AlterNodeResponse) XXX_Marshal 

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

func (*AlterNodeResponse) XXX_Merge 

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

func (*AlterNodeResponse) XXX_Size 

func (m *AlterNodeResponse) XXX_Size() int

func (*AlterNodeResponse) XXX_Unmarshal 

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

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 master 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 */
	XXX_NoUnkeyedLiteral    struct{}                `json:"-"`
	XXX_unrecognized        []byte                  `json:"-"`
	XXX_sizecache           int32                   `json:"-"`
}

* Configuration settings for a coordination node

func (*Config) Descriptor 

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

func (*Config) GetAttachConsistencyMode 

func (m *Config) GetAttachConsistencyMode() ConsistencyMode

func (*Config) GetPath 

func (m *Config) GetPath() string

func (*Config) GetRateLimiterCountersMode 

func (m *Config) GetRateLimiterCountersMode() RateLimiterCountersMode

func (*Config) GetReadConsistencyMode 

func (m *Config) GetReadConsistencyMode() ConsistencyMode

func (*Config) GetSelfCheckPeriodMillis 

func (m *Config) GetSelfCheckPeriodMillis() uint32

func (*Config) GetSessionGracePeriodMillis 

func (m *Config) GetSessionGracePeriodMillis() uint32

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (m *Config) Reset()

func (*Config) String 

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal 

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

func (*Config) XXX_Merge 

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

func (*Config) XXX_Size 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal 

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

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 master
	ConsistencyMode_CONSISTENCY_MODE_STRICT ConsistencyMode = 1
	// Relaxed mode allows operations to complete on stale masters
	ConsistencyMode_CONSISTENCY_MODE_RELAXED ConsistencyMode = 2
)

func (ConsistencyMode) EnumDescriptor 

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

func (ConsistencyMode) String 

func (x ConsistencyMode) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*CreateNodeRequest) Descriptor 

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

func (*CreateNodeRequest) GetConfig 

func (m *CreateNodeRequest) GetConfig() *Config

func (*CreateNodeRequest) GetOperationParams 

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

func (*CreateNodeRequest) GetPath 

func (m *CreateNodeRequest) GetPath() string

func (*CreateNodeRequest) ProtoMessage 

func (*CreateNodeRequest) ProtoMessage()

func (*CreateNodeRequest) Reset 

func (m *CreateNodeRequest) Reset()

func (*CreateNodeRequest) SetOperationParams 

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

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

func (*CreateNodeRequest) String 

func (m *CreateNodeRequest) String() string

func (*CreateNodeRequest) XXX_DiscardUnknown 

func (m *CreateNodeRequest) XXX_DiscardUnknown()

func (*CreateNodeRequest) XXX_Marshal 

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

func (*CreateNodeRequest) XXX_Merge 

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

func (*CreateNodeRequest) XXX_Size 

func (m *CreateNodeRequest) XXX_Size() int

func (*CreateNodeRequest) XXX_Unmarshal 

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

type CreateNodeResponse 

type CreateNodeResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*CreateNodeResponse) Descriptor 

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

func (*CreateNodeResponse) GetOperation 

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

func (*CreateNodeResponse) ProtoMessage 

func (*CreateNodeResponse) ProtoMessage()

func (*CreateNodeResponse) Reset 

func (m *CreateNodeResponse) Reset()

func (*CreateNodeResponse) String 

func (m *CreateNodeResponse) String() string

func (*CreateNodeResponse) XXX_DiscardUnknown 

func (m *CreateNodeResponse) XXX_DiscardUnknown()

func (*CreateNodeResponse) XXX_Marshal 

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

func (*CreateNodeResponse) XXX_Merge 

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

func (*CreateNodeResponse) XXX_Size 

func (m *CreateNodeResponse) XXX_Size() int

func (*CreateNodeResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*DescribeNodeRequest) Descriptor 

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

func (*DescribeNodeRequest) GetOperationParams 

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

func (*DescribeNodeRequest) GetPath 

func (m *DescribeNodeRequest) GetPath() string

func (*DescribeNodeRequest) ProtoMessage 

func (*DescribeNodeRequest) ProtoMessage()

func (*DescribeNodeRequest) Reset 

func (m *DescribeNodeRequest) Reset()

func (*DescribeNodeRequest) SetOperationParams 

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

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

func (*DescribeNodeRequest) String 

func (m *DescribeNodeRequest) String() string

func (*DescribeNodeRequest) XXX_DiscardUnknown 

func (m *DescribeNodeRequest) XXX_DiscardUnknown()

func (*DescribeNodeRequest) XXX_Marshal 

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

func (*DescribeNodeRequest) XXX_Merge 

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

func (*DescribeNodeRequest) XXX_Size 

func (m *DescribeNodeRequest) XXX_Size() int

func (*DescribeNodeRequest) XXX_Unmarshal 

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

type DescribeNodeResponse 

type DescribeNodeResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DescribeNodeResponse) Descriptor 

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

func (*DescribeNodeResponse) GetOperation 

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

func (*DescribeNodeResponse) ProtoMessage 

func (*DescribeNodeResponse) ProtoMessage()

func (*DescribeNodeResponse) Reset 

func (m *DescribeNodeResponse) Reset()

func (*DescribeNodeResponse) String 

func (m *DescribeNodeResponse) String() string

func (*DescribeNodeResponse) XXX_DiscardUnknown 

func (m *DescribeNodeResponse) XXX_DiscardUnknown()

func (*DescribeNodeResponse) XXX_Marshal 

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

func (*DescribeNodeResponse) XXX_Merge 

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

func (*DescribeNodeResponse) XXX_Size 

func (m *DescribeNodeResponse) XXX_Size() int

func (*DescribeNodeResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DescribeNodeResult) Descriptor 

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

func (*DescribeNodeResult) GetConfig 

func (m *DescribeNodeResult) GetConfig() *Config

func (*DescribeNodeResult) GetSelf 

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

func (*DescribeNodeResult) ProtoMessage 

func (*DescribeNodeResult) ProtoMessage()

func (*DescribeNodeResult) Reset 

func (m *DescribeNodeResult) Reset()

func (*DescribeNodeResult) String 

func (m *DescribeNodeResult) String() string

func (*DescribeNodeResult) XXX_DiscardUnknown 

func (m *DescribeNodeResult) XXX_DiscardUnknown()

func (*DescribeNodeResult) XXX_Marshal 

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

func (*DescribeNodeResult) XXX_Merge 

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

func (*DescribeNodeResult) XXX_Size 

func (m *DescribeNodeResult) XXX_Size() int

func (*DescribeNodeResult) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*DropNodeRequest) Descriptor 

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

func (*DropNodeRequest) GetOperationParams 

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

func (*DropNodeRequest) GetPath 

func (m *DropNodeRequest) GetPath() string

func (*DropNodeRequest) ProtoMessage 

func (*DropNodeRequest) ProtoMessage()

func (*DropNodeRequest) Reset 

func (m *DropNodeRequest) Reset()

func (*DropNodeRequest) SetOperationParams 

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

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

func (*DropNodeRequest) String 

func (m *DropNodeRequest) String() string

func (*DropNodeRequest) XXX_DiscardUnknown 

func (m *DropNodeRequest) XXX_DiscardUnknown()

func (*DropNodeRequest) XXX_Marshal 

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

func (*DropNodeRequest) XXX_Merge 

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

func (*DropNodeRequest) XXX_Size 

func (m *DropNodeRequest) XXX_Size() int

func (*DropNodeRequest) XXX_Unmarshal 

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

type DropNodeResponse 

type DropNodeResponse struct {
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DropNodeResponse) Descriptor 

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

func (*DropNodeResponse) GetOperation 

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

func (*DropNodeResponse) ProtoMessage 

func (*DropNodeResponse) ProtoMessage()

func (*DropNodeResponse) Reset 

func (m *DropNodeResponse) Reset()

func (*DropNodeResponse) String 

func (m *DropNodeResponse) String() string

func (*DropNodeResponse) XXX_DiscardUnknown 

func (m *DropNodeResponse) XXX_DiscardUnknown()

func (*DropNodeResponse) XXX_Marshal 

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

func (*DropNodeResponse) XXX_Merge 

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

func (*DropNodeResponse) XXX_Size 

func (m *DropNodeResponse) XXX_Size() int

func (*DropNodeResponse) XXX_Unmarshal 

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

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) EnumDescriptor 

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

func (RateLimiterCountersMode) String 

func (x RateLimiterCountersMode) String() string

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

* Describes the state of a semaphore

func (*SemaphoreDescription) Descriptor 

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

func (*SemaphoreDescription) GetCount 

func (m *SemaphoreDescription) GetCount() uint64

func (*SemaphoreDescription) GetData 

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

func (*SemaphoreDescription) GetEphemeral 

func (m *SemaphoreDescription) GetEphemeral() bool

func (*SemaphoreDescription) GetLimit 

func (m *SemaphoreDescription) GetLimit() uint64

func (*SemaphoreDescription) GetName 

func (m *SemaphoreDescription) GetName() string

func (*SemaphoreDescription) GetOwners 

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

func (*SemaphoreDescription) GetWaiters 

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

func (*SemaphoreDescription) ProtoMessage 

func (*SemaphoreDescription) ProtoMessage()

func (*SemaphoreDescription) Reset 

func (m *SemaphoreDescription) Reset()

func (*SemaphoreDescription) String 

func (m *SemaphoreDescription) String() string

func (*SemaphoreDescription) XXX_DiscardUnknown 

func (m *SemaphoreDescription) XXX_DiscardUnknown()

func (*SemaphoreDescription) XXX_Marshal 

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

func (*SemaphoreDescription) XXX_Merge 

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

func (*SemaphoreDescription) XXX_Size 

func (m *SemaphoreDescription) XXX_Size() int

func (*SemaphoreDescription) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Describes an owner or a waiter of this semaphore

func (*SemaphoreSession) Descriptor 

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

func (*SemaphoreSession) GetCount 

func (m *SemaphoreSession) GetCount() uint64

func (*SemaphoreSession) GetData 

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

func (*SemaphoreSession) GetOrderId 

func (m *SemaphoreSession) GetOrderId() uint64

func (*SemaphoreSession) GetSessionId 

func (m *SemaphoreSession) GetSessionId() uint64

func (*SemaphoreSession) GetTimeoutMillis 

func (m *SemaphoreSession) GetTimeoutMillis() uint64

func (*SemaphoreSession) ProtoMessage 

func (*SemaphoreSession) ProtoMessage()

func (*SemaphoreSession) Reset 

func (m *SemaphoreSession) Reset()

func (*SemaphoreSession) String 

func (m *SemaphoreSession) String() string

func (*SemaphoreSession) XXX_DiscardUnknown 

func (m *SemaphoreSession) XXX_DiscardUnknown()

func (*SemaphoreSession) XXX_Marshal 

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

func (*SemaphoreSession) XXX_Merge 

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

func (*SemaphoreSession) XXX_Size 

func (m *SemaphoreSession) XXX_Size() int

func (*SemaphoreSession) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Describes an active client session

func (*SessionDescription) Descriptor 

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

func (*SessionDescription) GetAttached 

func (m *SessionDescription) GetAttached() bool

func (*SessionDescription) GetDescription 

func (m *SessionDescription) GetDescription() string

func (*SessionDescription) GetSessionId 

func (m *SessionDescription) GetSessionId() uint64

func (*SessionDescription) GetTimeoutMillis 

func (m *SessionDescription) GetTimeoutMillis() uint64

func (*SessionDescription) ProtoMessage 

func (*SessionDescription) ProtoMessage()

func (*SessionDescription) Reset 

func (m *SessionDescription) Reset()

func (*SessionDescription) String 

func (m *SessionDescription) String() string

func (*SessionDescription) XXX_DiscardUnknown 

func (m *SessionDescription) XXX_DiscardUnknown()

func (*SessionDescription) XXX_Marshal 

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

func (*SessionDescription) XXX_Merge 

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

func (*SessionDescription) XXX_Size 

func (m *SessionDescription) XXX_Size() int

func (*SessionDescription) XXX_Unmarshal 

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

type SessionRequest 

type SessionRequest struct {
	// Types that are valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

* Session request message sent from client to server

func (*SessionRequest) Descriptor 

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

func (*SessionRequest) GetAcquireSemaphore 

func (m *SessionRequest) GetAcquireSemaphore() *SessionRequest_AcquireSemaphore

func (*SessionRequest) GetCreateSemaphore 

func (m *SessionRequest) GetCreateSemaphore() *SessionRequest_CreateSemaphore

func (*SessionRequest) GetDeleteSemaphore 

func (m *SessionRequest) GetDeleteSemaphore() *SessionRequest_DeleteSemaphore

func (*SessionRequest) GetDescribeSemaphore 

func (m *SessionRequest) GetDescribeSemaphore() *SessionRequest_DescribeSemaphore

func (*SessionRequest) GetPing 

func (m *SessionRequest) GetPing() *SessionRequest_PingPong

func (*SessionRequest) GetPong 

func (m *SessionRequest) GetPong() *SessionRequest_PingPong

func (*SessionRequest) GetReleaseSemaphore 

func (m *SessionRequest) GetReleaseSemaphore() *SessionRequest_ReleaseSemaphore

func (*SessionRequest) GetRequest 

func (m *SessionRequest) GetRequest() isSessionRequest_Request

func (*SessionRequest) GetSessionStart 

func (m *SessionRequest) GetSessionStart() *SessionRequest_SessionStart

func (*SessionRequest) GetSessionStop 

func (m *SessionRequest) GetSessionStop() *SessionRequest_SessionStop

func (*SessionRequest) GetUnsupported_13 

func (m *SessionRequest) GetUnsupported_13() *Unsupported

func (*SessionRequest) GetUnsupported_14 

func (m *SessionRequest) GetUnsupported_14() *Unsupported

func (*SessionRequest) GetUnsupported_15 

func (m *SessionRequest) GetUnsupported_15() *Unsupported

func (*SessionRequest) GetUnsupported_5 

func (m *SessionRequest) GetUnsupported_5() *Unsupported

func (*SessionRequest) GetUnsupported_6 

func (m *SessionRequest) GetUnsupported_6() *Unsupported

func (*SessionRequest) GetUpdateSemaphore 

func (m *SessionRequest) GetUpdateSemaphore() *SessionRequest_UpdateSemaphore

func (*SessionRequest) ProtoMessage 

func (*SessionRequest) ProtoMessage()

func (*SessionRequest) Reset 

func (m *SessionRequest) Reset()

func (*SessionRequest) String 

func (m *SessionRequest) String() string

func (*SessionRequest) XXX_DiscardUnknown 

func (m *SessionRequest) XXX_DiscardUnknown()

func (*SessionRequest) XXX_Marshal 

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

func (*SessionRequest) XXX_Merge 

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

func (*SessionRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionRequest) XXX_Size 

func (m *SessionRequest) XXX_Size() int

func (*SessionRequest) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* 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 

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

func (*SessionRequest_AcquireSemaphore) GetCount 

func (m *SessionRequest_AcquireSemaphore) GetCount() uint64

func (*SessionRequest_AcquireSemaphore) GetData 

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

func (*SessionRequest_AcquireSemaphore) GetEphemeral 

func (m *SessionRequest_AcquireSemaphore) GetEphemeral() bool

func (*SessionRequest_AcquireSemaphore) GetName 

func (m *SessionRequest_AcquireSemaphore) GetName() string

func (*SessionRequest_AcquireSemaphore) GetReqId 

func (m *SessionRequest_AcquireSemaphore) GetReqId() uint64

func (*SessionRequest_AcquireSemaphore) GetTimeoutMillis 

func (m *SessionRequest_AcquireSemaphore) GetTimeoutMillis() uint64

func (*SessionRequest_AcquireSemaphore) ProtoMessage 

func (*SessionRequest_AcquireSemaphore) ProtoMessage()

func (*SessionRequest_AcquireSemaphore) Reset 

func (m *SessionRequest_AcquireSemaphore) Reset()

func (*SessionRequest_AcquireSemaphore) String 

func (m *SessionRequest_AcquireSemaphore) String() string

func (*SessionRequest_AcquireSemaphore) XXX_DiscardUnknown 

func (m *SessionRequest_AcquireSemaphore) XXX_DiscardUnknown()

func (*SessionRequest_AcquireSemaphore) XXX_Marshal 

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

func (*SessionRequest_AcquireSemaphore) XXX_Merge 

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

func (*SessionRequest_AcquireSemaphore) XXX_Size 

func (m *SessionRequest_AcquireSemaphore) XXX_Size() int

func (*SessionRequest_AcquireSemaphore) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used to create a new semaphore

func (*SessionRequest_CreateSemaphore) Descriptor 

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

func (*SessionRequest_CreateSemaphore) GetData 

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

func (*SessionRequest_CreateSemaphore) GetLimit 

func (m *SessionRequest_CreateSemaphore) GetLimit() uint64

func (*SessionRequest_CreateSemaphore) GetName 

func (m *SessionRequest_CreateSemaphore) GetName() string

func (*SessionRequest_CreateSemaphore) GetReqId 

func (m *SessionRequest_CreateSemaphore) GetReqId() uint64

func (*SessionRequest_CreateSemaphore) ProtoMessage 

func (*SessionRequest_CreateSemaphore) ProtoMessage()

func (*SessionRequest_CreateSemaphore) Reset 

func (m *SessionRequest_CreateSemaphore) Reset()

func (*SessionRequest_CreateSemaphore) String 

func (m *SessionRequest_CreateSemaphore) String() string

func (*SessionRequest_CreateSemaphore) XXX_DiscardUnknown 

func (m *SessionRequest_CreateSemaphore) XXX_DiscardUnknown()

func (*SessionRequest_CreateSemaphore) XXX_Marshal 

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

func (*SessionRequest_CreateSemaphore) XXX_Merge 

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

func (*SessionRequest_CreateSemaphore) XXX_Size 

func (m *SessionRequest_CreateSemaphore) XXX_Size() int

func (*SessionRequest_CreateSemaphore) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used to delete an existing semaphore

func (*SessionRequest_DeleteSemaphore) Descriptor 

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

func (*SessionRequest_DeleteSemaphore) GetForce 

func (m *SessionRequest_DeleteSemaphore) GetForce() bool

func (*SessionRequest_DeleteSemaphore) GetName 

func (m *SessionRequest_DeleteSemaphore) GetName() string

func (*SessionRequest_DeleteSemaphore) GetReqId 

func (m *SessionRequest_DeleteSemaphore) GetReqId() uint64

func (*SessionRequest_DeleteSemaphore) ProtoMessage 

func (*SessionRequest_DeleteSemaphore) ProtoMessage()

func (*SessionRequest_DeleteSemaphore) Reset 

func (m *SessionRequest_DeleteSemaphore) Reset()

func (*SessionRequest_DeleteSemaphore) String 

func (m *SessionRequest_DeleteSemaphore) String() string

func (*SessionRequest_DeleteSemaphore) XXX_DiscardUnknown 

func (m *SessionRequest_DeleteSemaphore) XXX_DiscardUnknown()

func (*SessionRequest_DeleteSemaphore) XXX_Marshal 

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

func (*SessionRequest_DeleteSemaphore) XXX_Merge 

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

func (*SessionRequest_DeleteSemaphore) XXX_Size 

func (m *SessionRequest_DeleteSemaphore) XXX_Size() int

func (*SessionRequest_DeleteSemaphore) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* 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 

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

func (*SessionRequest_DescribeSemaphore) GetIncludeOwners 

func (m *SessionRequest_DescribeSemaphore) GetIncludeOwners() bool

func (*SessionRequest_DescribeSemaphore) GetIncludeWaiters 

func (m *SessionRequest_DescribeSemaphore) GetIncludeWaiters() bool

func (*SessionRequest_DescribeSemaphore) GetName 

func (m *SessionRequest_DescribeSemaphore) GetName() string

func (*SessionRequest_DescribeSemaphore) GetReqId 

func (m *SessionRequest_DescribeSemaphore) GetReqId() uint64

func (*SessionRequest_DescribeSemaphore) GetWatchData 

func (m *SessionRequest_DescribeSemaphore) GetWatchData() bool

func (*SessionRequest_DescribeSemaphore) GetWatchOwners 

func (m *SessionRequest_DescribeSemaphore) GetWatchOwners() bool

func (*SessionRequest_DescribeSemaphore) ProtoMessage 

func (*SessionRequest_DescribeSemaphore) ProtoMessage()

func (*SessionRequest_DescribeSemaphore) Reset 

func (m *SessionRequest_DescribeSemaphore) Reset()

func (*SessionRequest_DescribeSemaphore) String 

func (m *SessionRequest_DescribeSemaphore) String() string

func (*SessionRequest_DescribeSemaphore) XXX_DiscardUnknown 

func (m *SessionRequest_DescribeSemaphore) XXX_DiscardUnknown()

func (*SessionRequest_DescribeSemaphore) XXX_Marshal 

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

func (*SessionRequest_DescribeSemaphore) XXX_Merge 

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

func (*SessionRequest_DescribeSemaphore) XXX_Size 

func (m *SessionRequest_DescribeSemaphore) XXX_Size() int

func (*SessionRequest_DescribeSemaphore) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used for checking liveness of the connection

func (*SessionRequest_PingPong) Descriptor 

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

func (*SessionRequest_PingPong) GetOpaque 

func (m *SessionRequest_PingPong) GetOpaque() uint64

func (*SessionRequest_PingPong) ProtoMessage 

func (*SessionRequest_PingPong) ProtoMessage()

func (*SessionRequest_PingPong) Reset 

func (m *SessionRequest_PingPong) Reset()

func (*SessionRequest_PingPong) String 

func (m *SessionRequest_PingPong) String() string

func (*SessionRequest_PingPong) XXX_DiscardUnknown 

func (m *SessionRequest_PingPong) XXX_DiscardUnknown()

func (*SessionRequest_PingPong) XXX_Marshal 

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

func (*SessionRequest_PingPong) XXX_Merge 

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

func (*SessionRequest_PingPong) XXX_Size 

func (m *SessionRequest_PingPong) XXX_Size() int

func (*SessionRequest_PingPong) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* 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 

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

func (*SessionRequest_ReleaseSemaphore) GetName 

func (m *SessionRequest_ReleaseSemaphore) GetName() string

func (*SessionRequest_ReleaseSemaphore) GetReqId 

func (m *SessionRequest_ReleaseSemaphore) GetReqId() uint64

func (*SessionRequest_ReleaseSemaphore) ProtoMessage 

func (*SessionRequest_ReleaseSemaphore) ProtoMessage()

func (*SessionRequest_ReleaseSemaphore) Reset 

func (m *SessionRequest_ReleaseSemaphore) Reset()

func (*SessionRequest_ReleaseSemaphore) String 

func (m *SessionRequest_ReleaseSemaphore) String() string

func (*SessionRequest_ReleaseSemaphore) XXX_DiscardUnknown 

func (m *SessionRequest_ReleaseSemaphore) XXX_DiscardUnknown()

func (*SessionRequest_ReleaseSemaphore) XXX_Marshal 

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

func (*SessionRequest_ReleaseSemaphore) XXX_Merge 

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

func (*SessionRequest_ReleaseSemaphore) XXX_Size 

func (m *SessionRequest_ReleaseSemaphore) XXX_Size() int

func (*SessionRequest_ReleaseSemaphore) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* First message used to start/restore a session

func (*SessionRequest_SessionStart) Descriptor 

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

func (*SessionRequest_SessionStart) GetDescription 

func (m *SessionRequest_SessionStart) GetDescription() string

func (*SessionRequest_SessionStart) GetPath 

func (m *SessionRequest_SessionStart) GetPath() string

func (*SessionRequest_SessionStart) GetProtectionKey 

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

func (*SessionRequest_SessionStart) GetSeqNo 

func (m *SessionRequest_SessionStart) GetSeqNo() uint64

func (*SessionRequest_SessionStart) GetSessionId 

func (m *SessionRequest_SessionStart) GetSessionId() uint64

func (*SessionRequest_SessionStart) GetTimeoutMillis 

func (m *SessionRequest_SessionStart) GetTimeoutMillis() uint64

func (*SessionRequest_SessionStart) ProtoMessage 

func (*SessionRequest_SessionStart) ProtoMessage()

func (*SessionRequest_SessionStart) Reset 

func (m *SessionRequest_SessionStart) Reset()

func (*SessionRequest_SessionStart) String 

func (m *SessionRequest_SessionStart) String() string

func (*SessionRequest_SessionStart) XXX_DiscardUnknown 

func (m *SessionRequest_SessionStart) XXX_DiscardUnknown()

func (*SessionRequest_SessionStart) XXX_Marshal 

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

func (*SessionRequest_SessionStart) XXX_Merge 

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

func (*SessionRequest_SessionStart) XXX_Size 

func (m *SessionRequest_SessionStart) XXX_Size() int

func (*SessionRequest_SessionStart) XXX_Unmarshal 

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

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SessionRequest_SessionStop) Descriptor 

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

func (*SessionRequest_SessionStop) ProtoMessage 

func (*SessionRequest_SessionStop) ProtoMessage()

func (*SessionRequest_SessionStop) Reset 

func (m *SessionRequest_SessionStop) Reset()

func (*SessionRequest_SessionStop) String 

func (m *SessionRequest_SessionStop) String() string

func (*SessionRequest_SessionStop) XXX_DiscardUnknown 

func (m *SessionRequest_SessionStop) XXX_DiscardUnknown()

func (*SessionRequest_SessionStop) XXX_Marshal 

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

func (*SessionRequest_SessionStop) XXX_Merge 

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

func (*SessionRequest_SessionStop) XXX_Size 

func (m *SessionRequest_SessionStop) XXX_Size() int

func (*SessionRequest_SessionStop) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used to change semaphore data

func (*SessionRequest_UpdateSemaphore) Descriptor 

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

func (*SessionRequest_UpdateSemaphore) GetData 

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

func (*SessionRequest_UpdateSemaphore) GetName 

func (m *SessionRequest_UpdateSemaphore) GetName() string

func (*SessionRequest_UpdateSemaphore) GetReqId 

func (m *SessionRequest_UpdateSemaphore) GetReqId() uint64

func (*SessionRequest_UpdateSemaphore) ProtoMessage 

func (*SessionRequest_UpdateSemaphore) ProtoMessage()

func (*SessionRequest_UpdateSemaphore) Reset 

func (m *SessionRequest_UpdateSemaphore) Reset()

func (*SessionRequest_UpdateSemaphore) String 

func (m *SessionRequest_UpdateSemaphore) String() string

func (*SessionRequest_UpdateSemaphore) XXX_DiscardUnknown 

func (m *SessionRequest_UpdateSemaphore) XXX_DiscardUnknown()

func (*SessionRequest_UpdateSemaphore) XXX_Marshal 

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

func (*SessionRequest_UpdateSemaphore) XXX_Merge 

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

func (*SessionRequest_UpdateSemaphore) XXX_Size 

func (m *SessionRequest_UpdateSemaphore) XXX_Size() int

func (*SessionRequest_UpdateSemaphore) XXX_Unmarshal 

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

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 valid to be assigned 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"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

* Session response message sent from server to client

func (*SessionResponse) Descriptor 

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

func (*SessionResponse) GetAcquireSemaphorePending 

func (m *SessionResponse) GetAcquireSemaphorePending() *SessionResponse_AcquireSemaphorePending

func (*SessionResponse) GetAcquireSemaphoreResult 

func (m *SessionResponse) GetAcquireSemaphoreResult() *SessionResponse_AcquireSemaphoreResult

func (*SessionResponse) GetCreateSemaphoreResult 

func (m *SessionResponse) GetCreateSemaphoreResult() *SessionResponse_CreateSemaphoreResult

func (*SessionResponse) GetDeleteSemaphoreResult 

func (m *SessionResponse) GetDeleteSemaphoreResult() *SessionResponse_DeleteSemaphoreResult

func (*SessionResponse) GetDescribeSemaphoreChanged 

func (m *SessionResponse) GetDescribeSemaphoreChanged() *SessionResponse_DescribeSemaphoreChanged

func (*SessionResponse) GetDescribeSemaphoreResult 

func (m *SessionResponse) GetDescribeSemaphoreResult() *SessionResponse_DescribeSemaphoreResult

func (*SessionResponse) GetFailure 

func (m *SessionResponse) GetFailure() *SessionResponse_Failure

func (*SessionResponse) GetPing 

func (m *SessionResponse) GetPing() *SessionResponse_PingPong

func (*SessionResponse) GetPong 

func (m *SessionResponse) GetPong() *SessionResponse_PingPong

func (*SessionResponse) GetReleaseSemaphoreResult 

func (m *SessionResponse) GetReleaseSemaphoreResult() *SessionResponse_ReleaseSemaphoreResult

func (*SessionResponse) GetResponse 

func (m *SessionResponse) GetResponse() isSessionResponse_Response

func (*SessionResponse) GetSessionStarted 

func (m *SessionResponse) GetSessionStarted() *SessionResponse_SessionStarted

func (*SessionResponse) GetSessionStopped 

func (m *SessionResponse) GetSessionStopped() *SessionResponse_SessionStopped

func (*SessionResponse) GetUnsupported_16 

func (m *SessionResponse) GetUnsupported_16() *Unsupported

func (*SessionResponse) GetUnsupported_17 

func (m *SessionResponse) GetUnsupported_17() *Unsupported

func (*SessionResponse) GetUnsupported_18 

func (m *SessionResponse) GetUnsupported_18() *Unsupported

func (*SessionResponse) GetUnsupported_6 

func (m *SessionResponse) GetUnsupported_6() *Unsupported

func (*SessionResponse) GetUnsupported_7 

func (m *SessionResponse) GetUnsupported_7() *Unsupported

func (*SessionResponse) GetUpdateSemaphoreResult 

func (m *SessionResponse) GetUpdateSemaphoreResult() *SessionResponse_UpdateSemaphoreResult

func (*SessionResponse) ProtoMessage 

func (*SessionResponse) ProtoMessage()

func (*SessionResponse) Reset 

func (m *SessionResponse) Reset()

func (*SessionResponse) String 

func (m *SessionResponse) String() string

func (*SessionResponse) XXX_DiscardUnknown 

func (m *SessionResponse) XXX_DiscardUnknown()

func (*SessionResponse) XXX_Marshal 

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

func (*SessionResponse) XXX_Merge 

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

func (*SessionResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*SessionResponse) XXX_Size 

func (m *SessionResponse) XXX_Size() int

func (*SessionResponse) XXX_Unmarshal 

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

type SessionResponse_AcquireSemaphorePending 

type SessionResponse_AcquireSemaphorePending struct {
	ReqId                uint64   `protobuf:"varint,1,opt,name=req_id,json=reqId,proto3" json:"req_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SessionResponse_AcquireSemaphorePending) Descriptor 

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

func (*SessionResponse_AcquireSemaphorePending) GetReqId 

func (m *SessionResponse_AcquireSemaphorePending) GetReqId() uint64

func (*SessionResponse_AcquireSemaphorePending) ProtoMessage 

func (*SessionResponse_AcquireSemaphorePending) ProtoMessage()

func (*SessionResponse_AcquireSemaphorePending) Reset 

func (m *SessionResponse_AcquireSemaphorePending) Reset()

func (*SessionResponse_AcquireSemaphorePending) String 

func (m *SessionResponse_AcquireSemaphorePending) String() string

func (*SessionResponse_AcquireSemaphorePending) XXX_DiscardUnknown 

func (m *SessionResponse_AcquireSemaphorePending) XXX_DiscardUnknown()

func (*SessionResponse_AcquireSemaphorePending) XXX_Marshal 

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

func (*SessionResponse_AcquireSemaphorePending) XXX_Merge 

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

func (*SessionResponse_AcquireSemaphorePending) XXX_Size 

func (m *SessionResponse_AcquireSemaphorePending) XXX_Size() int

func (*SessionResponse_AcquireSemaphorePending) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SessionResponse_AcquireSemaphoreResult) Descriptor 

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

func (*SessionResponse_AcquireSemaphoreResult) GetAcquired 

func (m *SessionResponse_AcquireSemaphoreResult) GetAcquired() bool

func (*SessionResponse_AcquireSemaphoreResult) GetIssues 

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

func (*SessionResponse_AcquireSemaphoreResult) GetReqId 

func (m *SessionResponse_AcquireSemaphoreResult) GetReqId() uint64

func (*SessionResponse_AcquireSemaphoreResult) GetStatus 

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

func (*SessionResponse_AcquireSemaphoreResult) ProtoMessage 

func (*SessionResponse_AcquireSemaphoreResult) ProtoMessage()

func (*SessionResponse_AcquireSemaphoreResult) Reset 

func (m *SessionResponse_AcquireSemaphoreResult) Reset()

func (*SessionResponse_AcquireSemaphoreResult) String 

func (m *SessionResponse_AcquireSemaphoreResult) String() string

func (*SessionResponse_AcquireSemaphoreResult) XXX_DiscardUnknown 

func (m *SessionResponse_AcquireSemaphoreResult) XXX_DiscardUnknown()

func (*SessionResponse_AcquireSemaphoreResult) XXX_Marshal 

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

func (*SessionResponse_AcquireSemaphoreResult) XXX_Merge 

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

func (*SessionResponse_AcquireSemaphoreResult) XXX_Size 

func (m *SessionResponse_AcquireSemaphoreResult) XXX_Size() int

func (*SessionResponse_AcquireSemaphoreResult) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* The result of semaphore creation

func (*SessionResponse_CreateSemaphoreResult) Descriptor 

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

func (*SessionResponse_CreateSemaphoreResult) GetIssues 

func (m *SessionResponse_CreateSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_CreateSemaphoreResult) GetReqId 

func (m *SessionResponse_CreateSemaphoreResult) GetReqId() uint64

func (*SessionResponse_CreateSemaphoreResult) GetStatus 

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

func (*SessionResponse_CreateSemaphoreResult) ProtoMessage 

func (*SessionResponse_CreateSemaphoreResult) ProtoMessage()

func (*SessionResponse_CreateSemaphoreResult) Reset 

func (m *SessionResponse_CreateSemaphoreResult) Reset()

func (*SessionResponse_CreateSemaphoreResult) String 

func (m *SessionResponse_CreateSemaphoreResult) String() string

func (*SessionResponse_CreateSemaphoreResult) XXX_DiscardUnknown 

func (m *SessionResponse_CreateSemaphoreResult) XXX_DiscardUnknown()

func (*SessionResponse_CreateSemaphoreResult) XXX_Marshal 

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

func (*SessionResponse_CreateSemaphoreResult) XXX_Merge 

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

func (*SessionResponse_CreateSemaphoreResult) XXX_Size 

func (m *SessionResponse_CreateSemaphoreResult) XXX_Size() int

func (*SessionResponse_CreateSemaphoreResult) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* The result of semaphore deletion

func (*SessionResponse_DeleteSemaphoreResult) Descriptor 

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

func (*SessionResponse_DeleteSemaphoreResult) GetIssues 

func (m *SessionResponse_DeleteSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_DeleteSemaphoreResult) GetReqId 

func (m *SessionResponse_DeleteSemaphoreResult) GetReqId() uint64

func (*SessionResponse_DeleteSemaphoreResult) GetStatus 

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

func (*SessionResponse_DeleteSemaphoreResult) ProtoMessage 

func (*SessionResponse_DeleteSemaphoreResult) ProtoMessage()

func (*SessionResponse_DeleteSemaphoreResult) Reset 

func (m *SessionResponse_DeleteSemaphoreResult) Reset()

func (*SessionResponse_DeleteSemaphoreResult) String 

func (m *SessionResponse_DeleteSemaphoreResult) String() string

func (*SessionResponse_DeleteSemaphoreResult) XXX_DiscardUnknown 

func (m *SessionResponse_DeleteSemaphoreResult) XXX_DiscardUnknown()

func (*SessionResponse_DeleteSemaphoreResult) XXX_Marshal 

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

func (*SessionResponse_DeleteSemaphoreResult) XXX_Merge 

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

func (*SessionResponse_DeleteSemaphoreResult) XXX_Size 

func (m *SessionResponse_DeleteSemaphoreResult) XXX_Size() int

func (*SessionResponse_DeleteSemaphoreResult) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used to report a change in the watched semaphore

func (*SessionResponse_DescribeSemaphoreChanged) Descriptor 

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

func (*SessionResponse_DescribeSemaphoreChanged) GetDataChanged 

func (m *SessionResponse_DescribeSemaphoreChanged) GetDataChanged() bool

func (*SessionResponse_DescribeSemaphoreChanged) GetOwnersChanged 

func (m *SessionResponse_DescribeSemaphoreChanged) GetOwnersChanged() bool

func (*SessionResponse_DescribeSemaphoreChanged) GetReqId 

func (m *SessionResponse_DescribeSemaphoreChanged) GetReqId() uint64

func (*SessionResponse_DescribeSemaphoreChanged) ProtoMessage 

func (*SessionResponse_DescribeSemaphoreChanged) ProtoMessage()

func (*SessionResponse_DescribeSemaphoreChanged) Reset 

func (m *SessionResponse_DescribeSemaphoreChanged) Reset()

func (*SessionResponse_DescribeSemaphoreChanged) String 

func (m *SessionResponse_DescribeSemaphoreChanged) String() string

func (*SessionResponse_DescribeSemaphoreChanged) XXX_DiscardUnknown 

func (m *SessionResponse_DescribeSemaphoreChanged) XXX_DiscardUnknown()

func (*SessionResponse_DescribeSemaphoreChanged) XXX_Marshal 

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

func (*SessionResponse_DescribeSemaphoreChanged) XXX_Merge 

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

func (*SessionResponse_DescribeSemaphoreChanged) XXX_Size 

func (m *SessionResponse_DescribeSemaphoreChanged) XXX_Size() int

func (*SessionResponse_DescribeSemaphoreChanged) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* The result of the describe operation

func (*SessionResponse_DescribeSemaphoreResult) Descriptor 

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

func (*SessionResponse_DescribeSemaphoreResult) GetIssues 

func (m *SessionResponse_DescribeSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_DescribeSemaphoreResult) GetReqId 

func (m *SessionResponse_DescribeSemaphoreResult) GetReqId() uint64

func (*SessionResponse_DescribeSemaphoreResult) GetSemaphoreDescription 

func (m *SessionResponse_DescribeSemaphoreResult) GetSemaphoreDescription() *SemaphoreDescription

func (*SessionResponse_DescribeSemaphoreResult) GetStatus 

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

func (*SessionResponse_DescribeSemaphoreResult) GetWatchAdded 

func (m *SessionResponse_DescribeSemaphoreResult) GetWatchAdded() bool

func (*SessionResponse_DescribeSemaphoreResult) ProtoMessage 

func (*SessionResponse_DescribeSemaphoreResult) ProtoMessage()

func (*SessionResponse_DescribeSemaphoreResult) Reset 

func (m *SessionResponse_DescribeSemaphoreResult) Reset()

func (*SessionResponse_DescribeSemaphoreResult) String 

func (m *SessionResponse_DescribeSemaphoreResult) String() string

func (*SessionResponse_DescribeSemaphoreResult) XXX_DiscardUnknown 

func (m *SessionResponse_DescribeSemaphoreResult) XXX_DiscardUnknown()

func (*SessionResponse_DescribeSemaphoreResult) XXX_Marshal 

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

func (*SessionResponse_DescribeSemaphoreResult) XXX_Merge 

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

func (*SessionResponse_DescribeSemaphoreResult) XXX_Size 

func (m *SessionResponse_DescribeSemaphoreResult) XXX_Size() int

func (*SessionResponse_DescribeSemaphoreResult) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* Used to report connection and session level failures

func (*SessionResponse_Failure) Descriptor 

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

func (*SessionResponse_Failure) GetIssues 

func (m *SessionResponse_Failure) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_Failure) GetStatus 

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

func (*SessionResponse_Failure) ProtoMessage 

func (*SessionResponse_Failure) ProtoMessage()

func (*SessionResponse_Failure) Reset 

func (m *SessionResponse_Failure) Reset()

func (*SessionResponse_Failure) String 

func (m *SessionResponse_Failure) String() string

func (*SessionResponse_Failure) XXX_DiscardUnknown 

func (m *SessionResponse_Failure) XXX_DiscardUnknown()

func (*SessionResponse_Failure) XXX_Marshal 

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

func (*SessionResponse_Failure) XXX_Merge 

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

func (*SessionResponse_Failure) XXX_Size 

func (m *SessionResponse_Failure) XXX_Size() int

func (*SessionResponse_Failure) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used for checking liveness of the connection

func (*SessionResponse_PingPong) Descriptor 

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

func (*SessionResponse_PingPong) GetOpaque 

func (m *SessionResponse_PingPong) GetOpaque() uint64

func (*SessionResponse_PingPong) ProtoMessage 

func (*SessionResponse_PingPong) ProtoMessage()

func (*SessionResponse_PingPong) Reset 

func (m *SessionResponse_PingPong) Reset()

func (*SessionResponse_PingPong) String 

func (m *SessionResponse_PingPong) String() string

func (*SessionResponse_PingPong) XXX_DiscardUnknown 

func (m *SessionResponse_PingPong) XXX_DiscardUnknown()

func (*SessionResponse_PingPong) XXX_Marshal 

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

func (*SessionResponse_PingPong) XXX_Merge 

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

func (*SessionResponse_PingPong) XXX_Size 

func (m *SessionResponse_PingPong) XXX_Size() int

func (*SessionResponse_PingPong) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*SessionResponse_ReleaseSemaphoreResult) Descriptor 

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

func (*SessionResponse_ReleaseSemaphoreResult) GetIssues 

func (m *SessionResponse_ReleaseSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_ReleaseSemaphoreResult) GetReleased 

func (m *SessionResponse_ReleaseSemaphoreResult) GetReleased() bool

func (*SessionResponse_ReleaseSemaphoreResult) GetReqId 

func (m *SessionResponse_ReleaseSemaphoreResult) GetReqId() uint64

func (*SessionResponse_ReleaseSemaphoreResult) GetStatus 

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

func (*SessionResponse_ReleaseSemaphoreResult) ProtoMessage 

func (*SessionResponse_ReleaseSemaphoreResult) ProtoMessage()

func (*SessionResponse_ReleaseSemaphoreResult) Reset 

func (m *SessionResponse_ReleaseSemaphoreResult) Reset()

func (*SessionResponse_ReleaseSemaphoreResult) String 

func (m *SessionResponse_ReleaseSemaphoreResult) String() string

func (*SessionResponse_ReleaseSemaphoreResult) XXX_DiscardUnknown 

func (m *SessionResponse_ReleaseSemaphoreResult) XXX_DiscardUnknown()

func (*SessionResponse_ReleaseSemaphoreResult) XXX_Marshal 

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

func (*SessionResponse_ReleaseSemaphoreResult) XXX_Merge 

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

func (*SessionResponse_ReleaseSemaphoreResult) XXX_Size 

func (m *SessionResponse_ReleaseSemaphoreResult) XXX_Size() int

func (*SessionResponse_ReleaseSemaphoreResult) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used to report a successful session create/restore operation

func (*SessionResponse_SessionStarted) Descriptor 

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

func (*SessionResponse_SessionStarted) GetSessionId 

func (m *SessionResponse_SessionStarted) GetSessionId() uint64

func (*SessionResponse_SessionStarted) GetTimeoutMillis 

func (m *SessionResponse_SessionStarted) GetTimeoutMillis() uint64

func (*SessionResponse_SessionStarted) ProtoMessage 

func (*SessionResponse_SessionStarted) ProtoMessage()

func (*SessionResponse_SessionStarted) Reset 

func (m *SessionResponse_SessionStarted) Reset()

func (*SessionResponse_SessionStarted) String 

func (m *SessionResponse_SessionStarted) String() string

func (*SessionResponse_SessionStarted) XXX_DiscardUnknown 

func (m *SessionResponse_SessionStarted) XXX_DiscardUnknown()

func (*SessionResponse_SessionStarted) XXX_Marshal 

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

func (*SessionResponse_SessionStarted) XXX_Merge 

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

func (*SessionResponse_SessionStarted) XXX_Size 

func (m *SessionResponse_SessionStarted) XXX_Size() int

func (*SessionResponse_SessionStarted) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Used to report a successful graceful termination of the session

func (*SessionResponse_SessionStopped) Descriptor 

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

func (*SessionResponse_SessionStopped) GetSessionId 

func (m *SessionResponse_SessionStopped) GetSessionId() uint64

func (*SessionResponse_SessionStopped) ProtoMessage 

func (*SessionResponse_SessionStopped) ProtoMessage()

func (*SessionResponse_SessionStopped) Reset 

func (m *SessionResponse_SessionStopped) Reset()

func (*SessionResponse_SessionStopped) String 

func (m *SessionResponse_SessionStopped) String() string

func (*SessionResponse_SessionStopped) XXX_DiscardUnknown 

func (m *SessionResponse_SessionStopped) XXX_DiscardUnknown()

func (*SessionResponse_SessionStopped) XXX_Marshal 

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

func (*SessionResponse_SessionStopped) XXX_Merge 

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

func (*SessionResponse_SessionStopped) XXX_Size 

func (m *SessionResponse_SessionStopped) XXX_Size() int

func (*SessionResponse_SessionStopped) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

* The result of semaphore update

func (*SessionResponse_UpdateSemaphoreResult) Descriptor 

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

func (*SessionResponse_UpdateSemaphoreResult) GetIssues 

func (m *SessionResponse_UpdateSemaphoreResult) GetIssues() []*Ydb_Issue.IssueMessage

func (*SessionResponse_UpdateSemaphoreResult) GetReqId 

func (m *SessionResponse_UpdateSemaphoreResult) GetReqId() uint64

func (*SessionResponse_UpdateSemaphoreResult) GetStatus 

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

func (*SessionResponse_UpdateSemaphoreResult) ProtoMessage 

func (*SessionResponse_UpdateSemaphoreResult) ProtoMessage()

func (*SessionResponse_UpdateSemaphoreResult) Reset 

func (m *SessionResponse_UpdateSemaphoreResult) Reset()

func (*SessionResponse_UpdateSemaphoreResult) String 

func (m *SessionResponse_UpdateSemaphoreResult) String() string

func (*SessionResponse_UpdateSemaphoreResult) XXX_DiscardUnknown 

func (m *SessionResponse_UpdateSemaphoreResult) XXX_DiscardUnknown()

func (*SessionResponse_UpdateSemaphoreResult) XXX_Marshal 

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

func (*SessionResponse_UpdateSemaphoreResult) XXX_Merge 

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

func (*SessionResponse_UpdateSemaphoreResult) XXX_Size 

func (m *SessionResponse_UpdateSemaphoreResult) XXX_Size() int

func (*SessionResponse_UpdateSemaphoreResult) XXX_Unmarshal 

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

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

* Stub for unsupported messages

func (*Unsupported) Descriptor 

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

func (*Unsupported) ProtoMessage 

func (*Unsupported) ProtoMessage()

func (*Unsupported) Reset 

func (m *Unsupported) Reset()

func (*Unsupported) String 

func (m *Unsupported) String() string

func (*Unsupported) XXX_DiscardUnknown 

func (m *Unsupported) XXX_DiscardUnknown()

func (*Unsupported) XXX_Marshal 

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

func (*Unsupported) XXX_Merge 

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

func (*Unsupported) XXX_Size 

func (m *Unsupported) XXX_Size() int

func (*Unsupported) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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