sync

type ElectWatcher interface {
	// Next is a blocking call
	Next() (*Member, error)
	Close()
}

type Leader interface {
	// Id leader node
	Id() string
	// Resign resigns leadership
	Resign() error
	// Observe watch leadership event
	Observe() chan ObserveResult
	// Primary get the info of primary role
	Primary() (*Member, error)
	// Status returns when leadership is lost
	Status() chan bool
}

type LeaderOption func(o *LeaderOptions)

type LeaderOptions struct {
	TTL       int64
	Namespace string
	Id        string
}

type ListMembersOption func(o *ListMembersOptions)

type ListMembersOptions struct {
	Namespace string
}

type LockOption func(o *LockOptions)

type LockOptions struct {
	TTL  time.Duration
	Wait time.Duration
}

type Member struct {
	Leader    string `json:"leader"`
	Id        string `json:"id"`
	Namespace string `json:"namespace"`
	Role      Role   `json:"role"`
}

type ObserveResult struct {
	Namespace string `json:"namespace"`
	Id        string `json:"id"`
}

type Option func(o *Options)

type Options struct {
	Nodes  []string
	Prefix string
}

type Role string

type Sync interface {
	// Init Initialise options
	Init(...Option) error
	// Options Return the options
	Options() Options
	// Leader Elect a leader
	Leader(ctx context.Context, name string, opts ...LeaderOption) (Leader, error)
	// ListMembers get all election member
	ListMembers(ctx context.Context, opts ...ListMembersOption) ([]*Member, error)
	// WatchElect watch leader event
	WatchElect(ctx context.Context, opts ...WatchElectOption) (ElectWatcher, error)
	// Lock acquires a lock
	Lock(ctx context.Context, id string, opts ...LockOption) error
	// Unlock releases a lock
	Unlock(ctx context.Context, id string) error
	// String Sync implementation
	String() string
}

type WatchElectOption func(o *WatchElectOptions)

type WatchElectOptions struct {
	Namespace string
	Id        string
}