election

Documentation

Index

• Constants
• type Cluster
• type Config
• type Manager
  • func New(config *Config, logger *zap.Logger) (*Manager, error)
  • func (m *Manager) Disconnect()
  • func (m *Manager) GetClusterInfo() (*Cluster, error)
  • func (m *Manager) GetHostname() (string, error)
  • func (m *Manager) IsMaster() bool
  • func (m *Manager) Start() (*chan int, error)

Constants

const ClusterChanged = 3

ClusterChanged - signals for cluster change

const Disconnected = 4

Disconnected - int signal for disconnection

const (
	// EventDisconnected - specifies a custom event for disconnection
	EventDisconnected zk.EventType = 99
)

const Master = 1

Master - signals for master role acquisition

const Slave = 2

Slave - signals for slave role acquisition

Types

type Cluster

type Cluster struct {
	IsMaster bool
	Master   string
	Slaves   []string
	Nodes    []string
	NumNodes int
}

Cluster - has cluster info

type Config

type Config struct {
	ZKURL                  []string
	ZKElectionNodeURI      string
	ZKSlaveNodesURI        string
	ReconnectionTimeout    string
	SessionTimeout         string
	ClusterChangeCheckTime string
	ClusterChangeWaitTime  string
}

Config - configures the election

type Manager

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

Manager - handles the zookeeper election

func New

func New(config *Config, logger *zap.Logger) (*Manager, error)

New - creates a new instance

func (*Manager) Disconnect

func (m *Manager) Disconnect()

Disconnect - disconnects from the zookeeper

func (*Manager) GetClusterInfo

func (m *Manager) GetClusterInfo() (*Cluster, error)

GetClusterInfo - return cluster info

func (*Manager) GetHostname

func (m *Manager) GetHostname() (string, error)

GetHostname - retrieves this node hostname from the OS

func (*Manager) IsMaster

func (m *Manager) IsMaster() bool

IsMaster - check if the cluster is the master

func (*Manager) Start

func (m *Manager) Start() (*chan int, error)

Start - starts to listen zk events