zzk

type GetConnection func(string) (client.Connection, error)

type HostLeader struct {
	HostID string
	Realm  string
	// contains filtered or unexported fields
}

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

type Listener interface {
	// SetConnection sets the connection object
	SetConnection(conn client.Connection)
	// GetPath concatenates the base path with whatever child nodes that are specified
	GetPath(nodes ...string) string
	// Ready verifies that the listener can start listening
	Ready() error
	// Done performs any cleanup when the listener exits
	Done()
	// Spawn is the action to be performed when a child node is found on the parent
	Spawn(<-chan interface{}, string)
	// PostProcess performs additional action based on the nodes that are in processing
	PostProcess(p map[string]struct{})
}

type Listener2 interface {

	// Listen is the method to call to start the listener
	Listen(cancel <-chan interface{}, conn client.Connection)

	// Exited does additional cleanup once shutdown is called
	Exited()
}

type NewListener func(string) Listener

type Node interface {
	client.Node
	// GetID relates to the child node mapping in zookeeper
	GetID() string
	// Create creates the object in zookeeper
	Create(conn client.Connection) error
	// Update updates the object in zookeeper
	Update(conn client.Connection) error
}

type Spawner interface {

	// SetConn sets the zookeeper connection
	SetConn(conn client.Connection)

	// Path returns the parent path of the zookeeper node whose children are
	// the target of spawn
	Path() string

	// Pre performs a synchronous action to occur before spawn
	Pre()

	// Spawn is intended to manage individual nodes that exist from Path()
	Spawn(cancel <-chan struct{}, n string)

	// Post presents the complete list of nodes that are children of Path() for
	// further processing and synchronization
	Post(p map[string]struct{})
}

type SyncHandler interface {
	// GetPath gets the path to the node
	GetPath(...string) string
	// Ready implements Listener
	Ready() error
	// Done implements Listener
	Done()
	// GetConnection acquires a path-based connection
	GetConnection(string) (client.Connection, error)
	// Allocate initialized a new Node object
	Allocate() Node
	// GetAll gets all local data
	GetAll() ([]Node, error)
	// AddUpdate performs a local update
	AddUpdate(string, Node) (string, error)
	// Delete deletes a Node locally
	Delete(string) error
}

type Synchronizer struct {
	SyncHandler
	// contains filtered or unexported fields
}