election

var Component = &component.Component{
	Name: "cluster.election",
	Dependencies: component.Components{
		runner.Component,
		election.Component,
	},
	Init: component.StepFunc(func(container container.Container) error {
		return container.Provide(NewElection)
	}),
	Execute: component.StepFunc(func(container container.Container) error {
		return container.Invoke(func(m cluster.Manager, e *Election) {
			m.OnAddPeer().Subscribe(e.onAddPeer)
			m.OnDeletingPeer().Subscribe(e.onDeletingPeer)
			m.OnMasterDisconnection().Subscribe(e.onMasterDisconnection)
			m.OnMasterCandidateConnect().Subscribe(e.onMasterCandidateConnect)
			m.OnChangeMaster().Subscribe(e.onChangeMaster)
		})
	}),
}