client

Nov 10, 2021

Changes in this version

type Client

+ func (c *Client) Describe(ctx context.Context) (*NodeMetadata, error)

+ func (c *Client) Weight(ctx context.Context, weight uint64) error

+ type NodeMetadata struct

+ FailureDomain uint64

+ Weight uint64

Jun 1, 2020

Changes in this version

+ const LogNone

Apr 15, 2020

Changes in this version

type DialFunc

+ func DialFuncWithTLS(dial DialFunc, config *tls.Config) DialFunc

+ type YamlNodeStore struct

+ func NewYamlNodeStore(path string) (*YamlNodeStore, error)

+ func (s *YamlNodeStore) Get(ctx context.Context) ([]NodeInfo, error)

+ func (s *YamlNodeStore) Set(ctx context.Context, servers []NodeInfo) error

Jan 9, 2020

Changes in this version

+ const Spare

+ const StandBy

+ const Voter

type Client

+ func (c *Client) Assign(ctx context.Context, id uint64, role NodeRole) error

+ func (c *Client) Transfer(ctx context.Context, id uint64) error

+ type NodeRole = protocol.NodeRole

+ type NodeStoreOption func(*nodeStoreOptions)

+ func WithNodeStoreWhereClause(where string) NodeStoreOption

Aug 29, 2019

Changes in this version

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogWarn

+ var NewInmemNodeStore = protocol.NewInmemNodeStore

+ func DefaultDialFunc(ctx context.Context, address string) (net.Conn, error)

+ func DefaultLogFunc(l LogLevel, format string, a ...interface{})

+ type Client struct

+ func FindLeader(ctx context.Context, store NodeStore, options ...Option) (*Client, error)

+ func New(ctx context.Context, address string, options ...Option) (*Client, error)

+ func (c *Client) Add(ctx context.Context, node NodeInfo) error

+ func (c *Client) Close() error

+ func (c *Client) Cluster(ctx context.Context) ([]NodeInfo, error)

+ func (c *Client) Dump(ctx context.Context, dbname string) ([]File, error)

+ func (c *Client) Leader(ctx context.Context) (*NodeInfo, error)

+ func (c *Client) Remove(ctx context.Context, id uint64) error

+ type DatabaseNodeStore struct

+ func DefaultNodeStore(filename string) (*DatabaseNodeStore, error)

+ func NewNodeStore(db *sql.DB, schema, table, column string) *DatabaseNodeStore

+ func (d *DatabaseNodeStore) Get(ctx context.Context) ([]NodeInfo, error)

+ func (d *DatabaseNodeStore) Set(ctx context.Context, servers []NodeInfo) error

+ type DialFunc = protocol.DialFunc

+ type File struct

+ Data []byte

+ Name string

+ type InmemNodeStore = protocol.InmemNodeStore

+ type LogFunc = logging.Func

+ type LogLevel = logging.Level

+ type NodeInfo = protocol.NodeInfo

+ type NodeStore = protocol.NodeStore

+ type Option func(*options)

+ func WithDialFunc(dial DialFunc) Option

+ func WithLogFunc(log LogFunc) Option