elector

type Conn interface {
	Get(path string) ([]byte, *zk.Stat, error)
	Exists(path string) (bool, *zk.Stat, error)
	Create(path string, data []byte, flags int32, acl []zk.ACL) (string, error)
	CreateProtectedEphemeralSequential(path string, data []byte, acl []zk.ACL) (string, error)
	ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error)
}

type ConnAdapter struct {
	GetF                                func(path string) ([]byte, *zk.Stat, error)
	ExistsF                             func(path string) (bool, *zk.Stat, error)
	CreateF                             func(path string, data []byte, flags int32, acl []zk.ACL) (string, error)
	CreateProtectedEphemeralSequentialF func(path string, data []byte, acl []zk.ACL) (string, error)
	ChildrenWF                          func(path string) ([]string, *zk.Stat, <-chan zk.Event, error)
}

type ConnectionOpts struct {
	// ConnectTimeout is the timeout to make the initial connection to ZK.
	ConnectTimeout time.Duration

	// InitialSessionTimeout is how long to wait for a valid session to
	// be established once the connection happens.
	InitialSessionTimeout time.Duration

	// Auth represents authentication details. If left alone, no auth will
	// be performed
	Auth struct {
		Schema string
		Secret []byte
	}
}

type Connector interface {
	// Connect returns a ZK connection and events channel
	Connect() (Conn, <-chan zk.Event, error)

	// Close should ensure the ZK connection is closed.
	Close() error
}

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

type Event struct {
	// Leader is true if the elector that produced it is the leader
	Leader bool

	// Err represents an error event. If this is non-nil, the other fields
	// in the event must be ignored, and most clients will want to
	// shut down if Err is non-nil, since leadership cannot be guaranteed
	// in that case.
	//
	// When an err is sent, the Elector should no longer be considered
	// usable.
	Err error
}

type IElector interface {
	// LeaderIdent returns the current leader of the cluster, or "" if
	// the current leader is not known.
	LeaderIdent() string

	// Events returns a channel from which the client should consume events
	// from the elector.  The channel will be closed after an error event
	// is sent, as the elector is no longer usable from that point on.
	Events() <-chan Event

	// Close tidies up any applicable connection details to ZK. Clients
	// should call then when the elector is no longer needed
	Close() error
}