Documentation
¶
Index ¶
- 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
- func (o CreateOperation) AsEphemeral() coordinating.CreateOperation
- func (o CreateOperation) AsSequential() coordinating.CreateOperation
- func (o CreateOperation) OnEvent(func(event coordinating.WatchEvent) coordinating.Recursive) coordinating.CreateOperation
- func (o CreateOperation) Run() error
- func (o CreateOperation) WithLock(string) coordinating.CreateOperation
- type DeleteOperation
- type ExistsOperation
- type GetOperation
- type LockOperation
- type OptimisticUpdateOperation
- type SetOperation
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChildrenOperation ¶
type ChildrenOperation struct {
// contains filtered or unexported fields
}
func NewInMemChildrenOperation ¶
func NewInMemChildrenOperation(m *sync.Map, path string) ChildrenOperation
func (ChildrenOperation) Run ¶
func (o ChildrenOperation) Run() ([]string, error)
func (ChildrenOperation) Watch ¶
func (o ChildrenOperation) Watch(context.Context) (<-chan coordinating.WatchEvent, error)
func (ChildrenOperation) WithLock ¶
func (o ChildrenOperation) WithLock(string) coordinating.ChildrenOperation
type CoordClient ¶
type CoordClient struct {
// contains filtered or unexported fields
}
func NewInMemCoordClient ¶
func NewInMemCoordClient() *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 NewInMemCreateOperation ¶
func NewInMemCreateOperation(m *sync.Map, 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) OnEvent ¶
func (o CreateOperation) OnEvent(func(event coordinating.WatchEvent) coordinating.Recursive) coordinating.CreateOperation
func (CreateOperation) Run ¶
func (o CreateOperation) Run() error
func (CreateOperation) WithLock ¶
func (o CreateOperation) WithLock(string) coordinating.CreateOperation
type DeleteOperation ¶
type DeleteOperation struct {
// contains filtered or unexported fields
}
func NewInMemDeleteOperation ¶
func NewInMemDeleteOperation(m *sync.Map, 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(string) coordinating.DeleteOperation
type ExistsOperation ¶
type ExistsOperation struct {
// contains filtered or unexported fields
}
func NewInMemExistsOperation ¶
func NewInMemExistsOperation(m *sync.Map, path string) ExistsOperation
func (ExistsOperation) Run ¶
func (o ExistsOperation) Run() (bool, error)
func (ExistsOperation) Watch ¶
func (o ExistsOperation) Watch(context.Context) (<-chan coordinating.WatchEvent, error)
func (ExistsOperation) WithLock ¶
func (o ExistsOperation) WithLock(string) coordinating.ExistsOperation
type GetOperation ¶
type GetOperation struct {
// contains filtered or unexported fields
}
func NewInMemGetOperation ¶
func NewInMemGetOperation(m *sync.Map, path string) GetOperation
func (GetOperation) Run ¶
func (o GetOperation) Run() ([]byte, error)
func (GetOperation) Watch ¶
func (o GetOperation) Watch(context.Context) (<-chan coordinating.WatchEvent, error)
func (GetOperation) WithLock ¶
func (o GetOperation) WithLock(string) coordinating.GetOperation
type LockOperation ¶
type LockOperation struct {
}
func NewInMemLockOperation ¶
func NewInMemLockOperation() 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 NewInMemSetOperation ¶
func NewInMemSetOperation(m *sync.Map, path string, value []byte) SetOperation
func (SetOperation) Run ¶
func (o SetOperation) Run() error
func (SetOperation) WithLock ¶
func (o SetOperation) WithLock(string) coordinating.SetOperation
Source Files
Click to show internal directories.
Click to hide internal directories.