usertopology

Documentation

Index

• func DefToMetadata(def string, metadata graph.Metadata) (graph.Metadata, error)
• type TopologyManager
  • func NewTopologyManager(etcdClient *etcd.Client, nodeHandler *apiServer.NodeRuleAPI, ...) *TopologyManager
  • func (tm *TopologyManager) OnNodeAdded(n *graph.Node)
  • func (tm *TopologyManager) OnNodeUpdated(n *graph.Node)
  • func (tm *TopologyManager) OnStartAsMaster()
  • func (tm *TopologyManager) OnStartAsSlave()
  • func (tm *TopologyManager) OnSwitchToMaster()
  • func (tm *TopologyManager) OnSwitchToSlave()
  • func (tm *TopologyManager) Start()
  • func (tm *TopologyManager) Stop()

Functions

func DefToMetadata

func DefToMetadata(def string, metadata graph.Metadata) (graph.Metadata, error)

DefToMetadata converts a string in k1=v1,k2=v2,... format to a metadata object

Types

type TopologyManager

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

TopologyManager describes topology manager

func NewTopologyManager

func NewTopologyManager(etcdClient *etcd.Client, nodeHandler *apiServer.NodeRuleAPI, edgeHandler *apiServer.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)

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