enhancers

Documentation

Index

• type GraphFlowEnhancer
  • func NewGraphFlowEnhancer(g *graph.Graph, cache *cache.Cache) *GraphFlowEnhancer
  • func (gfe *GraphFlowEnhancer) Enhance(f *flow.Flow)
  • func (gfe *GraphFlowEnhancer) OnEdgeDeleted(e *graph.Edge)
  • func (gfe *GraphFlowEnhancer) OnNodeDeleted(n *graph.Node)
• type NeutronFlowEnhancer
  • func NewNeutronFlowEnhancer(g *graph.Graph, cache *cache.Cache) *NeutronFlowEnhancer
  • func (nfe *NeutronFlowEnhancer) Enhance(f *flow.Flow)
  • func (nfe *NeutronFlowEnhancer) OnEdgeDeleted(e *graph.Edge)
  • func (nfe *NeutronFlowEnhancer) OnNodeDeleted(n *graph.Node)

Types

type GraphFlowEnhancer

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

GraphFlowEnhancer describes an cache node enhancer

func NewGraphFlowEnhancer

func NewGraphFlowEnhancer(g *graph.Graph, cache *cache.Cache) *GraphFlowEnhancer

NewGraphFlowEnhancer creates a new flow enhancer that will enhance A and B flow nodes TIDs

func (*GraphFlowEnhancer) Enhance

func (gfe *GraphFlowEnhancer) Enhance(f *flow.Flow)

Enhance the graph with local TID node cache

func (*GraphFlowEnhancer) OnEdgeDeleted

func (gfe *GraphFlowEnhancer) OnEdgeDeleted(e *graph.Edge)

OnEdgeDeleted event

func (*GraphFlowEnhancer) OnNodeDeleted

func (gfe *GraphFlowEnhancer) OnNodeDeleted(n *graph.Node)

OnNodeDeleted event

type NeutronFlowEnhancer

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

NeutronFlowEnhancer describes a neutron graph enhancer

func NewNeutronFlowEnhancer

func NewNeutronFlowEnhancer(g *graph.Graph, cache *cache.Cache) *NeutronFlowEnhancer

NewNeutronFlowEnhancer creates a new flow enhancer that will enhance A and B flow nodes TIDs

func (*NeutronFlowEnhancer) Enhance

func (nfe *NeutronFlowEnhancer) Enhance(f *flow.Flow)

Enhance A and B node TID based on neutron database

func (*NeutronFlowEnhancer) OnEdgeDeleted

func (nfe *NeutronFlowEnhancer) OnEdgeDeleted(e *graph.Edge)

OnEdgeDeleted event

func (*NeutronFlowEnhancer) OnNodeDeleted

func (nfe *NeutronFlowEnhancer) OnNodeDeleted(n *graph.Node)

OnNodeDeleted event