usertopology

Documentation

Index

• type TopologyManager
  • func NewTopologyManager(etcdClient *etcd.Client, nodeHandler *api.NodeRuleAPI, ...) *TopologyManager
  • func (tm *TopologyManager) OnNodeAdded(n *graph.Node)
  • func (tm *TopologyManager) OnNodeUpdated(n *graph.Node, ops []graph.PartiallyUpdatedOp)
  • func (tm *TopologyManager) OnStartAsMaster()
  • func (tm *TopologyManager) OnStartAsSlave()
  • func (tm *TopologyManager) OnSwitchToMaster()
  • func (tm *TopologyManager) OnSwitchToSlave()
  • func (tm *TopologyManager) Start()
  • func (tm *TopologyManager) Stop()

Types

type TopologyManager

type TopologyManager struct {
	etcd.MasterElection
	graph.DefaultGraphListener
	// contains filtered or unexported fields
}

TopologyManager describes topology manager

func NewTopologyManager

func NewTopologyManager(etcdClient *etcd.Client, nodeHandler *api.NodeRuleAPI, edgeHandler *api.EdgeRuleAPI, g *graph.Graph) *TopologyManager

NewTopologyManager returns new topology manager

func (*TopologyManager) OnNodeAdded

func (tm *TopologyManager) OnNodeAdded(n *graph.Node)

OnNodeAdded event

func (*TopologyManager) OnNodeUpdated

func (tm *TopologyManager) OnNodeUpdated(n *graph.Node, ops []graph.PartiallyUpdatedOp)

OnNodeUpdated event

func (*TopologyManager) OnStartAsMaster

func (tm *TopologyManager) OnStartAsMaster()

OnStartAsMaster event

func (*TopologyManager) OnStartAsSlave

func (tm *TopologyManager) OnStartAsSlave()

OnStartAsSlave event

func (*TopologyManager) OnSwitchToMaster

func (tm *TopologyManager) OnSwitchToMaster()

OnSwitchToMaster event

func (*TopologyManager) OnSwitchToSlave

func (tm *TopologyManager) OnSwitchToSlave()

OnSwitchToSlave event

func (*TopologyManager) Start

func (tm *TopologyManager) Start()

Start start the topology manager

func (*TopologyManager) Stop

func (tm *TopologyManager) Stop()

Stop stop the topology manager