Documentation
¶
Index ¶
- func ConvertToWatchEvent(event zk.Event) (coordinating.WatchEvent, error)
- type ChildrenOperation
- type CoordClient
- func (c *CoordClient) Children(path string) coordinating.ChildrenOperation
- func (c *CoordClient) Close()
- func (c *CoordClient) Connect() error
- func (c *CoordClient) Create(path string, value []byte) coordinating.CreateOperation
- func (c *CoordClient) Delete(paths []string) coordinating.DeleteOperation
- func (c *CoordClient) Exists(path string) coordinating.ExistsOperation
- func (c *CoordClient) Get(path string) coordinating.GetOperation
- func (c *CoordClient) IsClosed() bool
- func (c *CoordClient) Lock(path string) coordinating.LockOperation
- func (c *CoordClient) OptimisticUpdate(path string, update func([]byte) []byte) coordinating.OptimisticUpdateOperation
- func (c *CoordClient) Set(path string, value []byte) coordinating.SetOperation
- type CreateOperation
- type DeleteOperation
- type ExistsOperation
- type GetOperation
- func (o GetOperation) OnEvent(ctx context.Context, fn func(coordinating.WatchEvent) coordinating.Recursive) coordinating.GetOperation
- func (o GetOperation) Run() ([]byte, error)
- func (o GetOperation) Watch(ctx context.Context) (<-chan coordinating.WatchEvent, error)
- func (o GetOperation) WithLock(lockPath string) coordinating.GetOperation
- type LockOperation
- type OptimisticUpdateOperation
- type SetOperation
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertToWatchEvent ¶
func ConvertToWatchEvent(event zk.Event) (coordinating.WatchEvent, error)
Types ¶
type ChildrenOperation ¶
type ChildrenOperation struct {
// contains filtered or unexported fields
}
func NewZKChildrenOperation ¶
func NewZKChildrenOperation(conn *zk.Conn, path string) ChildrenOperation
func (ChildrenOperation) Run ¶
func (o ChildrenOperation) Run() ([]string, error)
func (ChildrenOperation) Watch ¶
func (o ChildrenOperation) Watch(ctx context.Context) (<-chan coordinating.WatchEvent, error)
func (ChildrenOperation) WithLock ¶
func (o ChildrenOperation) WithLock(lockPath string) coordinating.ChildrenOperation
type CoordClient ¶
type CoordClient struct {
// contains filtered or unexported fields
}
func NewZKCoordClient ¶
func NewZKCoordClient(quorum []string, timeout uint) *CoordClient
func (*CoordClient) Children ¶
func (c *CoordClient) Children(path string) coordinating.ChildrenOperation
func (*CoordClient) Close ¶
func (c *CoordClient) Close()
func (*CoordClient) Connect ¶
func (c *CoordClient) Connect() error
func (*CoordClient) Create ¶
func (c *CoordClient) Create(path string, value []byte) coordinating.CreateOperation
func (*CoordClient) Delete ¶
func (c *CoordClient) Delete(paths []string) coordinating.DeleteOperation
func (*CoordClient) Exists ¶
func (c *CoordClient) Exists(path string) coordinating.ExistsOperation
func (*CoordClient) Get ¶
func (c *CoordClient) Get(path string) coordinating.GetOperation
func (*CoordClient) IsClosed ¶
func (c *CoordClient) IsClosed() bool
func (*CoordClient) Lock ¶
func (c *CoordClient) Lock(path string) coordinating.LockOperation
func (*CoordClient) OptimisticUpdate ¶
func (c *CoordClient) OptimisticUpdate(path string, update func([]byte) []byte) coordinating.OptimisticUpdateOperation
func (*CoordClient) Set ¶
func (c *CoordClient) Set(path string, value []byte) coordinating.SetOperation
type CreateOperation ¶
type CreateOperation struct {
// contains filtered or unexported fields
}
func NewZKCreateOperation ¶
func NewZKCreateOperation(conn *zk.Conn, path string, value []byte) CreateOperation
func (CreateOperation) AsEphemeral ¶
func (o CreateOperation) AsEphemeral() coordinating.CreateOperation
func (CreateOperation) AsSequential ¶
func (o CreateOperation) AsSequential() coordinating.CreateOperation
func (CreateOperation) Run ¶
func (o CreateOperation) Run() error
func (CreateOperation) WithLock ¶
func (o CreateOperation) WithLock(lockPath string) coordinating.CreateOperation
type DeleteOperation ¶
type DeleteOperation struct {
// contains filtered or unexported fields
}
func NewZKDeleteOperation ¶
func NewZKDeleteOperation(conn *zk.Conn, paths []string) DeleteOperation
func (DeleteOperation) IgnoreError ¶
func (o DeleteOperation) IgnoreError() coordinating.DeleteOperation
func (DeleteOperation) Run ¶
func (o DeleteOperation) Run() error
func (DeleteOperation) WithLock ¶
func (o DeleteOperation) WithLock(lockPath string) coordinating.DeleteOperation
type ExistsOperation ¶
type ExistsOperation struct {
// contains filtered or unexported fields
}
func NewZKExistsOperation ¶
func NewZKExistsOperation(conn *zk.Conn, path string) ExistsOperation
func (ExistsOperation) Run ¶
func (o ExistsOperation) Run() (bool, error)
func (ExistsOperation) Watch ¶
func (o ExistsOperation) Watch(ctx context.Context) (<-chan coordinating.WatchEvent, error)
func (ExistsOperation) WithLock ¶
func (o ExistsOperation) WithLock(lockPath string) coordinating.ExistsOperation
type GetOperation ¶
type GetOperation struct {
// contains filtered or unexported fields
}
func NewZKGetOperation ¶
func NewZKGetOperation(conn *zk.Conn, path string) GetOperation
func (GetOperation) OnEvent ¶
func (o GetOperation) OnEvent(ctx context.Context, fn func(coordinating.WatchEvent) coordinating.Recursive) coordinating.GetOperation
func (GetOperation) Run ¶
func (o GetOperation) Run() ([]byte, error)
func (GetOperation) Watch ¶
func (o GetOperation) Watch(ctx context.Context) (<-chan coordinating.WatchEvent, error)
func (GetOperation) WithLock ¶
func (o GetOperation) WithLock(lockPath string) coordinating.GetOperation
type LockOperation ¶
type LockOperation struct {
// contains filtered or unexported fields
}
func NewZKLockOperation ¶
func NewZKLockOperation(conn *zk.Conn, path string) LockOperation
func (LockOperation) Lock ¶
func (o LockOperation) Lock() error
func (LockOperation) Unlock ¶
func (o LockOperation) Unlock() error
type OptimisticUpdateOperation ¶
type OptimisticUpdateOperation struct {
// contains filtered or unexported fields
}
func (OptimisticUpdateOperation) Run ¶
func (o OptimisticUpdateOperation) Run() error
type SetOperation ¶
type SetOperation struct {
// contains filtered or unexported fields
}
func NewZKSetOperation ¶
func NewZKSetOperation(conn *zk.Conn, path string, value []byte) SetOperation
func (SetOperation) Run ¶
func (o SetOperation) Run() error
func (SetOperation) WithLock ¶
func (o SetOperation) WithLock(lockPath string) coordinating.SetOperation
Source Files
Click to show internal directories.
Click to hide internal directories.