manager

package

v0.1.11 Latest Latest Go to latest Published: May 3, 2017 License: Apache-2.0 Imports: 17 Imported by: 0

Details

View Source

const SWAN_ATOMIC_STORE_NODE_PATH = "%s/atomic-store"

View Source

const SWAN_LEADER_ELECTION_NODE_PATH = "%s/leader-election"

View Source

const ZK_FLAG_NONE = 0

View Source

var (
	ErrNormalExit = errors.New("normal exit 0")
)

View Source

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

This section is empty.

type Leadership uint8

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

func (l Leadership) String() string

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

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

func (manager *Manager) InitAndStart(ctx context.Context) error