Versions in this module Expand all Collapse all v3 v3.80.13 Sep 25, 2024 v3.80.12 Sep 24, 2024 Changes in this version + const Exclusive + const MaxSemaphoreLimit + const Shared + var ErrAcquireTimeout = errors.New("acquire semaphore timeout") + var ErrOperationStatusUnknown = errors.New("operation status is unknown") + var ErrSessionClosed = errors.New("session is closed") + type Client interface + AlterNode func(ctx context.Context, path string, config NodeConfig) (err error) + CreateNode func(ctx context.Context, path string, config NodeConfig) (err error) + DescribeNode func(ctx context.Context, path string) (_ *scheme.Entry, _ *NodeConfig, err error) + DropNode func(ctx context.Context, path string) (err error) + Session func(ctx context.Context, path string, opts ...options.SessionOption) (Session, error) + type ConsistencyMode uint + const ConsistencyModeRelaxed + const ConsistencyModeStrict + const ConsistencyModeUnset + func (t ConsistencyMode) String() string + func (t ConsistencyMode) To() Ydb_Coordination.ConsistencyMode + type Lease interface + Context func() context.Context + Release func() error + Session func() Session + type NodeConfig struct + AttachConsistencyMode ConsistencyMode + Path string + RatelimiterCountersMode RatelimiterCountersMode + ReadConsistencyMode ConsistencyMode + SelfCheckPeriodMillis uint32 + SessionGracePeriodMillis uint32 + type RatelimiterCountersMode uint + const RatelimiterCountersModeAggregated + const RatelimiterCountersModeDetailed + const RatelimiterCountersModeUnset + func (t RatelimiterCountersMode) String() string + func (t RatelimiterCountersMode) To() Ydb_Coordination.RateLimiterCountersMode + type SemaphoreDescription struct + Count uint64 + Data []byte + Ephemeral bool + Limit uint64 + Name string + Owners []*SemaphoreSession + Waiters []*SemaphoreSession + func (d *SemaphoreDescription) String() string + type SemaphoreSession struct + Count uint64 + Data []byte + OrderID uint64 + SessionID uint64 + Timeout time.Duration + func (s *SemaphoreSession) String() string + type Session interface + AcquireSemaphore func(ctx context.Context, name string, count uint64, ...) (Lease, error) + Close func(ctx context.Context) error + Context func() context.Context + CreateSemaphore func(ctx context.Context, name string, limit uint64, ...) error + DeleteSemaphore func(ctx context.Context, name string, opts ...options.DeleteSemaphoreOption) error + DescribeSemaphore func(ctx context.Context, name string, opts ...options.DescribeSemaphoreOption) (*SemaphoreDescription, error) + Reconnect func() + SessionID func() uint64 + UpdateSemaphore func(ctx context.Context, name string, opts ...options.UpdateSemaphoreOption) error
Go to main page