Documentation ¶
Index ¶
- func NewRegistry() mgr.Instance
- type Registry
- func (ec *Registry) Close()
- func (ec *Registry) Compact(ctx context.Context, reserve int64) error
- func (ec *Registry) Do(ctx context.Context, opts ...registry.PluginOpOption) (*registry.PluginResponse, error)
- func (ec *Registry) Err() (err <-chan error)
- func (ec *Registry) LeaseGrant(ctx context.Context, TTL int64) (leaseID int64, err error)
- func (ec *Registry) LeaseRenew(ctx context.Context, leaseID int64) (TTL int64, err error)
- func (ec *Registry) LeaseRevoke(ctx context.Context, leaseID int64) error
- func (ec *Registry) PutNoOverride(ctx context.Context, opts ...registry.PluginOpOption) (bool, error)
- func (ec *Registry) Ready() <-chan struct{}
- func (ec *Registry) Txn(ctx context.Context, ops []registry.PluginOp) (*registry.PluginResponse, error)
- func (ec *Registry) TxnWithCmp(ctx context.Context, success []registry.PluginOp, cmp []registry.CompareOp, ...) (*registry.PluginResponse, error)
- func (ec *Registry) Watch(ctx context.Context, opts ...registry.PluginOpOption) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRegistry ¶
Types ¶
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
func (*Registry) Do ¶
func (ec *Registry) Do(ctx context.Context, opts ...registry.PluginOpOption) (*registry.PluginResponse, error)
func (*Registry) LeaseGrant ¶
func (*Registry) LeaseRenew ¶
func (*Registry) LeaseRevoke ¶
func (*Registry) PutNoOverride ¶
func (*Registry) TxnWithCmp ¶
Click to show internal directories.
Click to hide internal directories.