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()
• type UserMetadataManager
  • func NewUserMetadataManager(g *graph.Graph, u *server.UserMetadataAPIHandler) *UserMetadataManager
  • func (u *UserMetadataManager) OnNodeAdded(n *graph.Node)
  • func (u *UserMetadataManager) OnNodeUpdated(n *graph.Node)
  • func (u *UserMetadataManager) Start()
  • func (u *UserMetadataManager) Stop()

Functions

func DefToMetadata

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

Types

type TopologyManager

type TopologyManager struct {
	*etcd.MasterElector
	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

type UserMetadataManager

type UserMetadataManager struct {
	common.RWMutex
	graph.DefaultGraphListener
	// contains filtered or unexported fields
}

UserMetadataManager describes user metadata manager

func NewUserMetadataManager

func NewUserMetadataManager(g *graph.Graph, u *server.UserMetadataAPIHandler) *UserMetadataManager

NewUserMetadataManager creates a new user metadata manager

func (*UserMetadataManager) OnNodeAdded

func (u *UserMetadataManager) OnNodeAdded(n *graph.Node)

OnNodeAdded event

func (*UserMetadataManager) OnNodeUpdated

func (u *UserMetadataManager) OnNodeUpdated(n *graph.Node)

OnNodeUpdated event

func (*UserMetadataManager) Start

func (u *UserMetadataManager) Start()

Start starts user metadata manager

func (*UserMetadataManager) Stop

func (u *UserMetadataManager) Stop()

Stop stops user metadata manager