topology

package

v0.9.0 Latest Latest Go to latest Published: Jan 27, 2017 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func GraphPath(g *graph.Graph, n *graph.Node) string

func NewNetNSContextByNode(g *graph.Graph, n *graph.Node) (*common.NetNSContext, error)

type GraphPathGremlinTraversalStep struct {
}

func (s *GraphPathGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

func (s *GraphPathGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

func (s *GraphPathGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

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

func (p *GraphPathTraversalStep) Error() error

func (p *GraphPathTraversalStep) MarshalJSON() ([]byte, error)

func (p *GraphPathTraversalStep) Values() []interface{}

type HostNodeTIDMap map[string][]string

func BuildHostNodeTIDMap(nodes []*graph.Node) HostNodeTIDMap

type NodePath []*graph.Node

func (p NodePath) Marshal() string

type TIDMapper struct {
	graph.DefaultGraphListener
	Graph *graph.Graph
	// contains filtered or unexported fields
}

func NewTIDMapper(g *graph.Graph) *TIDMapper

func (t *TIDMapper) OnEdgeAdded(e *graph.Edge)

func (t *TIDMapper) OnEdgeUpdated(e *graph.Edge)

func (t *TIDMapper) OnNodeAdded(n *graph.Node)

func (t *TIDMapper) OnNodeUpdated(n *graph.Node)

func (t *TIDMapper) Start()

func (t *TIDMapper) Stop()

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

func NewTopologyTraversalExtension() *TopologyTraversalExtension

func (e *TopologyTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

func (e *TopologyTraversalExtension) ScanIdent(s string) (traversal.Token, bool)