manager

Documentation

Index

• Variables
• type Leadership
• type Manager
  • func New(cfg *config.ManagerConfig) (*Manager, error)
  • func (m *Manager) Start() error

Variables

var (
	ZKDefaultACL = zk.WorldACL(zk.PermAll)
)

Types

type Leadership

type Leadership uint8

const (
	ZKFlagNone         = 0
	LeaderElectionPath = "/leader-election"

	LeadershipUnknown  Leadership = 1
	LeadershipLeader   Leadership = 2
	LeadershipFollower Leadership = 3
)

type Manager

type Manager struct {
	ZKClient *zk.Conn
	// contains filtered or unexported fields
}

func New

func New(cfg *config.ManagerConfig) (*Manager, error)

func (*Manager) Start

func (m *Manager) Start() error