coordination

Documentation

Index

• type Client
  • func (c *Client) AlterNode(ctx context.Context, path string, config Config) (err error)
  • func (c *Client) CreateNode(ctx context.Context, path string, config Config) (err error)
  • func (c *Client) DescribeNode(ctx context.Context, path string) (*scheme.Entry, *Config, error)
  • func (c *Client) DropNode(ctx context.Context, path string) (err error)
• type Config
• type ConsistencyMode
  • func (t ConsistencyMode) String() string
• type RateLimiterCountersMode
  • func (t RateLimiterCountersMode) String() string

Types

type Client

type Client struct {
	Driver ydb.Driver
}

func (*Client) AlterNode

func (c *Client) AlterNode(ctx context.Context, path string, config Config) (err error)

func (*Client) CreateNode

func (c *Client) CreateNode(ctx context.Context, path string, config Config) (err error)

func (*Client) DescribeNode

func (c *Client) DescribeNode(ctx context.Context, path string) (*scheme.Entry, *Config, error)

Describes a coordination node

func (*Client) DropNode

func (c *Client) DropNode(ctx context.Context, path string) (err error)

type Config

type Config struct {
	Path                     string
	SelfCheckPeriodMillis    uint32
	SessionGracePeriodMillis uint32
	ReadConsistencyMode      ConsistencyMode
	AttachConsistencyMode    ConsistencyMode
	RateLimiterCountersMode  RateLimiterCountersMode
}

type ConsistencyMode

type ConsistencyMode uint

const (
	ConsistencyModeUnset ConsistencyMode = iota
	ConsistencyModeStrict
	ConsistencyModeRelaxed
)

func (ConsistencyMode) String

func (t ConsistencyMode) String() string

type RateLimiterCountersMode

type RateLimiterCountersMode uint

const (
	RateLimiterCountersModeUnset RateLimiterCountersMode = iota
	RateLimiterCountersModeAggregated
	RateLimiterCountersModeDetailed
)

func (RateLimiterCountersMode) String

func (t RateLimiterCountersMode) String() string