common

Documentation

Index

• func ClientOrigin(c websocket.Speaker) string
• func DelSubGraphOfOrigin(g *graph.Graph, origin string)
• type Forwarder
  • func NewForwarder(g *graph.Graph, pool ws.StructSpeakerPool) *Forwarder
  • func (t *Forwarder) GetMaster() ws.Speaker
  • func (t *Forwarder) OnEdgeAdded(e *graph.Edge)
  • func (t *Forwarder) OnEdgeDeleted(e *graph.Edge)
  • func (t *Forwarder) OnEdgeUpdated(e *graph.Edge)
  • func (t *Forwarder) OnNewMaster(c ws.Speaker)
  • func (t *Forwarder) OnNodeAdded(n *graph.Node)
  • func (t *Forwarder) OnNodeDeleted(n *graph.Node)
  • func (t *Forwarder) OnNodeUpdated(n *graph.Node)
• type PersistencePolicy
• type PublisherEndpoint
  • func NewPublisherEndpoint(pool ws.StructSpeakerPool, g *graph.Graph, validator validator.Validator) (*PublisherEndpoint, error)
  • func (t *PublisherEndpoint) OnDisconnected(c ws.Speaker)
  • func (t *PublisherEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)
• type SubscriberEndpoint
  • func NewSubscriberEndpoint(pool ws.StructSpeakerPool, g *graph.Graph, ...) *SubscriberEndpoint
  • func (t *SubscriberEndpoint) OnConnected(c ws.Speaker)
  • func (t *SubscriberEndpoint) OnDisconnected(c ws.Speaker)
  • func (t *SubscriberEndpoint) OnEdgeAdded(e *graph.Edge)
  • func (t *SubscriberEndpoint) OnEdgeDeleted(e *graph.Edge)
  • func (t *SubscriberEndpoint) OnEdgeUpdated(e *graph.Edge)
  • func (t *SubscriberEndpoint) OnNodeAdded(n *graph.Node)
  • func (t *SubscriberEndpoint) OnNodeDeleted(n *graph.Node)
  • func (t *SubscriberEndpoint) OnNodeUpdated(n *graph.Node)
  • func (t *SubscriberEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

Functions

func ClientOrigin

func ClientOrigin(c websocket.Speaker) string

ClientOrigin return a string identifying a client using its service type and host id

func DelSubGraphOfOrigin

func DelSubGraphOfOrigin(g *graph.Graph, origin string)

DelSubGraphOfOrigin deletes all the nodes with a specified origin

Types

type Forwarder

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

Forwarder forwards the topology to only one master server. When switching from one analyzer to another one the agent does a full re-sync since some messages could have been lost.

func NewForwarder

func NewForwarder(g *graph.Graph, pool ws.StructSpeakerPool) *Forwarder

NewForwarder returns a new Graph forwarder which forwards event of the given graph to the given WebSocket JSON speakers.

func (*Forwarder) GetMaster

func (t *Forwarder) GetMaster() ws.Speaker

GetMaster returns the current analyzer the agent is sending its events to

func (*Forwarder) OnEdgeAdded

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

OnEdgeAdded graph edge added event. Implements the EventListener interface.

func (*Forwarder) OnEdgeDeleted

func (t *Forwarder) OnEdgeDeleted(e *graph.Edge)

OnEdgeDeleted graph edge deleted event. Implements the EventListener interface.

func (*Forwarder) OnEdgeUpdated

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

OnEdgeUpdated graph edge updated event. Implements the EventListener interface.

func (*Forwarder) OnNewMaster

func (t *Forwarder) OnNewMaster(c ws.Speaker)

OnNewMaster is called by the master election mechanism when a new master is elected. In such case a "Re-sync" is triggered in order to be in sync with the new master.

func (*Forwarder) OnNodeAdded

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

OnNodeAdded graph node added event. Implements the EventListener interface.

func (*Forwarder) OnNodeDeleted

func (t *Forwarder) OnNodeDeleted(n *graph.Node)

OnNodeDeleted graph node deleted event. Implements the EventListener interface.

func (*Forwarder) OnNodeUpdated

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

OnNodeUpdated graph node updated event. Implements the EventListener interface.

type PersistencePolicy

type PersistencePolicy string

PersistencePolicy defines Persistent policy for publishers

const (
	// Persistent means that the graph elements created will always remain
	Persistent PersistencePolicy = "Persistent"
	// DeleteOnDisconnect means the graph elements created will be deleted on client disconnect
	DeleteOnDisconnect PersistencePolicy = "DeleteOnDisconnect"
)

type PublisherEndpoint

type PublisherEndpoint struct {
	common.RWMutex
	ws.DefaultSpeakerEventHandler

	Graph *graph.Graph
	// contains filtered or unexported fields
}

PublisherEndpoint serves the graph for external publishers, for instance an external program that interacts with the Skydive graph.

func NewPublisherEndpoint

func NewPublisherEndpoint(pool ws.StructSpeakerPool, g *graph.Graph, validator validator.Validator) (*PublisherEndpoint, error)

NewPublisherEndpoint returns a new server for external publishers.

func (*PublisherEndpoint) OnDisconnected

func (t *PublisherEndpoint) OnDisconnected(c ws.Speaker)

OnDisconnected called when a publisher got disconnected.

func (*PublisherEndpoint) OnStructMessage

func (t *PublisherEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

OnStructMessage is triggered by message coming from a publisher.

type SubscriberEndpoint

type SubscriberEndpoint struct {
	common.RWMutex
	ws.DefaultSpeakerEventHandler

	Graph *graph.Graph
	// contains filtered or unexported fields
}

SubscriberEndpoint sends all the modifications to its subscribers.

func NewSubscriberEndpoint

func NewSubscriberEndpoint(pool ws.StructSpeakerPool, g *graph.Graph, tr *traversal.GremlinTraversalParser) *SubscriberEndpoint

NewSubscriberEndpoint returns a new server to be used by external subscribers, for instance the WebUI.

func (*SubscriberEndpoint) OnConnected

func (t *SubscriberEndpoint) OnConnected(c ws.Speaker)

OnConnected called when a subscriber got connected.

func (*SubscriberEndpoint) OnDisconnected

func (t *SubscriberEndpoint) OnDisconnected(c ws.Speaker)

OnDisconnected called when a subscriber got disconnected.

func (*SubscriberEndpoint) OnEdgeAdded

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

OnEdgeAdded graph edge added event. Implements the GraphEventListener interface.

func (*SubscriberEndpoint) OnEdgeDeleted

func (t *SubscriberEndpoint) OnEdgeDeleted(e *graph.Edge)

OnEdgeDeleted graph edge deleted event. Implements the GraphEventListener interface.

func (*SubscriberEndpoint) OnEdgeUpdated

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

OnEdgeUpdated graph edge updated event. Implements the GraphEventListener interface.

func (*SubscriberEndpoint) OnNodeAdded

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

OnNodeAdded graph node added event. Implements the GraphEventListener interface.

func (*SubscriberEndpoint) OnNodeDeleted

func (t *SubscriberEndpoint) OnNodeDeleted(n *graph.Node)

OnNodeDeleted graph node deleted event. Implements the GraphEventListener interface.

func (*SubscriberEndpoint) OnNodeUpdated

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

OnNodeUpdated graph node updated event. Implements the GraphEventListener interface.

func (*SubscriberEndpoint) OnStructMessage

func (t *SubscriberEndpoint) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

OnStructMessage is triggered when receiving a message from a subscriber. It only responds to SyncRequestMsgType messages