Documentation
¶
Index ¶
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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