curator

type ChildrenCache struct {
	// contains filtered or unexported fields
}

type ChildrenCacheEvent struct {
	ChildNode string
	Data      []byte
	Stat      *zk.Stat
	Type      ChildrenCacheEventType
}

type ChildrenCacheEventType int

type Conn interface {
	Close()

	Get(path string) (data []byte, stat *zk.Stat, err error)
	GetW(path string) (data []byte, stat *zk.Stat, watch <-chan zk.Event, err error)

	Children(path string) (children []string, stat *zk.Stat, err error)
	ChildrenW(path string) (children []string, stat *zk.Stat, watch <-chan zk.Event, err error)

	Exists(path string) (exist bool, stat *zk.Stat, err error)
	ExistsW(path string) (exist bool, stat *zk.Stat, watch <-chan zk.Event, err error)

	Create(path string, value []byte, flags int32, acl []zk.ACL) (pathCreated string, err error)
	CreateProtectedEphemeralSequential(path string, value []byte, aclv []zk.ACL) (pathCreated string, err error)

	Set(path string, value []byte, version int32) (stat *zk.Stat, err error)

	Delete(path string, version int32) (err error)

	GetACL(path string) ([]zk.ACL, *zk.Stat, error)
	SetACL(path string, acl []zk.ACL, version int32) (*zk.Stat, error)
}

type EnsembleProvider interface {
	Start() error
	Close() error
	GetConnectionString() string
}

type ExponentialBackoffRetry struct {
	N            int
	BaseDuration time.Duration
	MaxDuration  time.Duration
}

type FixedEnsembleProvider string

type LeaderSelector struct {
	// contains filtered or unexported fields
}

type LeaderSelectorListener interface {
	TakeLeaderShip(client *ZookeeperClient, cancel <-chan struct{}) error
}

type Locker interface {
	Acquire() error
	Release() error
}

type Logger interface {
	Infof(format string, v ...interface{})
	Infoln(v ...interface{})
	Errorf(format string, v ...interface{})
	Errorln(v ...interface{})
	Debugf(format string, v ...interface{})
	Debugln(v ...interface{})
	Warnf(format string, v ...interface{})
	Warnln(v ...interface{})
}

type Mutex struct {
	// contains filtered or unexported fields
}

type OnChildrenCacheChange func(event ChildrenCacheEvent)

type RetryForever struct {
	Duration time.Duration
}

type RetryNTimes struct {
	N        int
	Duration time.Duration
}

type RetryPolicy interface {
	AllowRetry(count int, elapsed time.Duration, sleeper RetrySleeper) bool
}

type RetryPolicyFunc func(count int, elapsed time.Duration, sleeper RetrySleeper) bool

type RetrySleeper interface {
	Sleep(duration time.Duration) error
}

type RetrySleeperFunc func(duration time.Duration) error

type Watcher struct {
	// contains filtered or unexported fields
}

type ZookeeperClient struct {
	// contains filtered or unexported fields
}

type ZookeeperClientBuilder struct {
	// contains filtered or unexported fields
}

type ZookeeperFactory interface {
	Create(connectString string, sessionTimeout, connectTimeout time.Duration, readOnly bool) (*zk.Conn, <-chan zk.Event, error)
}