Documentation
¶
Index ¶
- type AsyncClient
- type DefaultGraphListener
- func (c *DefaultGraphListener) OnEdgeAdded(e *Edge)
- func (c *DefaultGraphListener) OnEdgeDeleted(e *Edge)
- func (c *DefaultGraphListener) OnEdgeUpdated(e *Edge)
- func (c *DefaultGraphListener) OnNodeAdded(n *Node)
- func (c *DefaultGraphListener) OnNodeDeleted(n *Node)
- func (d *DefaultGraphListener) OnNodeUpdated(n *Node)
- type Edge
- type EdgeValidator
- type EventListener
- type Forwarder
- func (c *Forwarder) OnConnected()
- func (c *Forwarder) OnDisconnected()
- func (c *Forwarder) OnEdgeAdded(e *Edge)
- func (c *Forwarder) OnEdgeDeleted(e *Edge)
- func (c *Forwarder) OnEdgeUpdated(e *Edge)
- func (c *Forwarder) OnNodeAdded(n *Node)
- func (c *Forwarder) OnNodeDeleted(n *Node)
- func (c *Forwarder) OnNodeUpdated(n *Node)
- type Graph
- func (g *Graph) AddEdge(e *Edge) bool
- func (g *Graph) AddEventListener(l GraphEventListener)
- func (g *Graph) AddMetadata(e interface{}, k string, v interface{})
- func (g *Graph) AddNode(n *Node) bool
- func (g *Graph) AreLinked(n1 *Node, n2 *Node) bool
- func (g *Graph) DelEdge(e *Edge)
- func (g *Graph) DelNode(n *Node)
- func (g *Graph) DelSubGraph(n *Node)
- func (g *Graph) GetEdge(i Identifier) *Edge
- func (g *Graph) GetEdgeNodes(e *Edge) (*Node, *Node)
- func (g *Graph) GetEdges() []*Edge
- func (g *Graph) GetNode(i Identifier) *Node
- func (g *Graph) GetNodes() []*Node
- func (g *Graph) Link(n1 *Node, n2 *Node, m ...Metadata)
- func (g *Graph) LookupChildren(n *Node, f Metadata) []*Node
- func (g *Graph) LookupFirstChild(n *Node, f Metadata) *Node
- func (g *Graph) LookupFirstNode(m Metadata) *Node
- func (g *Graph) LookupNodes(m Metadata) []*Node
- func (g *Graph) LookupNodesFromKey(key string) []*Node
- func (g *Graph) LookupParentNodes(n *Node, f Metadata) []*Node
- func (g *Graph) LookupShortestPath(n *Node, m Metadata, ev ...EdgeValidator) []*Node
- func (g *Graph) MarshalJSON() ([]byte, error)
- func (g *Graph) NewEdge(i Identifier, p *Node, c *Node, m Metadata) *Edge
- func (g *Graph) NewNode(i Identifier, m Metadata) *Node
- func (g *Graph) NotifyEdgeAdded(e *Edge)
- func (g *Graph) NotifyEdgeDeleted(e *Edge)
- func (g *Graph) NotifyEdgeUpdated(e *Edge)
- func (g *Graph) NotifyNodeAdded(n *Node)
- func (g *Graph) NotifyNodeDeleted(n *Node)
- func (g *Graph) NotifyNodeUpdated(n *Node)
- func (g *Graph) RemoveEventListener(l GraphEventListener)
- func (g *Graph) Replace(o *Node, n *Node) *Node
- func (g *Graph) SetMetadata(e interface{}, m Metadata)
- func (g *Graph) StartMetadataTransaction(i interface{}) *MetadataTransaction
- func (g *Graph) String() string
- func (g *Graph) Unlink(n1 *Node, n2 *Node)
- type GraphBackend
- type GraphEventListener
- type GremlinBackend
- func (g GremlinBackend) AddEdge(e *Edge) bool
- func (g GremlinBackend) AddMetadata(i interface{}, k string, v interface{}) bool
- func (g GremlinBackend) AddNode(n *Node) bool
- func (g GremlinBackend) DelEdge(e *Edge) bool
- func (g GremlinBackend) DelNode(n *Node) bool
- func (g GremlinBackend) GetEdge(i Identifier) *Edge
- func (g GremlinBackend) GetEdgeNodes(e *Edge) (*Node, *Node)
- func (g GremlinBackend) GetEdges() []*Edge
- func (g GremlinBackend) GetNode(i Identifier) *Node
- func (g GremlinBackend) GetNodeEdges(n *Node) []*Edge
- func (g GremlinBackend) GetNodes() []*Node
- func (g GremlinBackend) SetMetadata(i interface{}, meta Metadata) bool
- type Identifier
- type MemoryBackend
- func (m MemoryBackend) AddEdge(e *Edge) bool
- func (m MemoryBackend) AddMetadata(i interface{}, k string, v interface{}) bool
- func (m MemoryBackend) AddNode(n *Node) bool
- func (m MemoryBackend) DelEdge(e *Edge) bool
- func (m MemoryBackend) DelNode(n *Node) bool
- func (m MemoryBackend) GetEdge(i Identifier) *Edge
- func (m MemoryBackend) GetEdgeNodes(e *Edge) (*Node, *Node)
- func (m MemoryBackend) GetEdges() []*Edge
- func (m MemoryBackend) GetNode(i Identifier) *Node
- func (m MemoryBackend) GetNodeEdges(n *Node) []*Edge
- func (m MemoryBackend) GetNodes() []*Node
- func (m MemoryBackend) SetMetadata(i interface{}, meta Metadata) bool
- type MemoryBackendEdge
- type MemoryBackendNode
- type Metadata
- type MetadataTransaction
- type Node
- type Server
- type TitangraphBackend
- type WSClient
- type WSMessage
- type WSServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncClient ¶
type AsyncClient struct { Addr string Port int Path string AuthClient *shttp.AuthenticationClient // contains filtered or unexported fields }
func NewAsyncClient ¶
func NewAsyncClient(addr string, port int, path string, authClient *shttp.AuthenticationClient) *AsyncClient
func (*AsyncClient) AddListener ¶
func (c *AsyncClient) AddListener(l EventListener)
func (*AsyncClient) Connect ¶
func (c *AsyncClient) Connect()
func (*AsyncClient) Disconnect ¶
func (c *AsyncClient) Disconnect()
func (*AsyncClient) IsConnected ¶
func (c *AsyncClient) IsConnected() bool
func (*AsyncClient) SendWSMessage ¶
func (c *AsyncClient) SendWSMessage(m WSMessage)
type DefaultGraphListener ¶ added in v0.3.0
type DefaultGraphListener struct { }
default implementation of a graph listener, can be used when not implementing the whole set of callbacks
func (*DefaultGraphListener) OnEdgeAdded ¶ added in v0.3.0
func (c *DefaultGraphListener) OnEdgeAdded(e *Edge)
func (*DefaultGraphListener) OnEdgeDeleted ¶ added in v0.3.0
func (c *DefaultGraphListener) OnEdgeDeleted(e *Edge)
func (*DefaultGraphListener) OnEdgeUpdated ¶ added in v0.3.0
func (c *DefaultGraphListener) OnEdgeUpdated(e *Edge)
func (*DefaultGraphListener) OnNodeAdded ¶ added in v0.3.0
func (c *DefaultGraphListener) OnNodeAdded(n *Node)
func (*DefaultGraphListener) OnNodeDeleted ¶ added in v0.3.0
func (c *DefaultGraphListener) OnNodeDeleted(n *Node)
func (*DefaultGraphListener) OnNodeUpdated ¶ added in v0.3.0
func (d *DefaultGraphListener) OnNodeUpdated(n *Node)
type Edge ¶
type Edge struct {
// contains filtered or unexported fields
}
func (*Edge) MarshalJSON ¶
type EdgeValidator ¶ added in v0.3.0
type EventListener ¶
type EventListener interface { OnConnected() OnDisconnected() }
type Forwarder ¶
type Forwarder struct { Client *AsyncClient Graph *Graph }
func NewForwarder ¶
func NewForwarder(c *AsyncClient, g *Graph) *Forwarder
func (*Forwarder) OnConnected ¶
func (c *Forwarder) OnConnected()
func (*Forwarder) OnDisconnected ¶
func (c *Forwarder) OnDisconnected()
func (*Forwarder) OnEdgeAdded ¶
func (*Forwarder) OnEdgeDeleted ¶
func (*Forwarder) OnEdgeUpdated ¶
func (*Forwarder) OnNodeAdded ¶
func (*Forwarder) OnNodeDeleted ¶
func (*Forwarder) OnNodeUpdated ¶
type Graph ¶
func NewGraph ¶
func NewGraph(b GraphBackend) (*Graph, error)
func (*Graph) AddEventListener ¶
func (g *Graph) AddEventListener(l GraphEventListener)
func (*Graph) AddMetadata ¶ added in v0.2.0
func (*Graph) DelSubGraph ¶
func (*Graph) GetEdge ¶
func (g *Graph) GetEdge(i Identifier) *Edge
func (*Graph) GetNode ¶
func (g *Graph) GetNode(i Identifier) *Node
func (*Graph) LookupFirstChild ¶ added in v0.2.0
func (*Graph) LookupFirstNode ¶
func (*Graph) LookupNodes ¶
func (*Graph) LookupNodesFromKey ¶
func (*Graph) LookupShortestPath ¶ added in v0.3.0
func (g *Graph) LookupShortestPath(n *Node, m Metadata, ev ...EdgeValidator) []*Node
func (*Graph) MarshalJSON ¶
func (*Graph) NotifyEdgeAdded ¶
func (*Graph) NotifyEdgeDeleted ¶
func (*Graph) NotifyEdgeUpdated ¶
func (*Graph) NotifyNodeAdded ¶
func (*Graph) NotifyNodeDeleted ¶
func (*Graph) NotifyNodeUpdated ¶
func (*Graph) RemoveEventListener ¶ added in v0.3.0
func (g *Graph) RemoveEventListener(l GraphEventListener)
func (*Graph) SetMetadata ¶
func (*Graph) StartMetadataTransaction ¶ added in v0.3.0
func (g *Graph) StartMetadataTransaction(i interface{}) *MetadataTransaction
type GraphBackend ¶
type GraphBackend interface { AddNode(n *Node) bool DelNode(n *Node) bool GetNode(i Identifier) *Node GetNodeEdges(n *Node) []*Edge AddEdge(e *Edge) bool DelEdge(e *Edge) bool GetEdge(i Identifier) *Edge GetEdgeNodes(e *Edge) (*Node, *Node) AddMetadata(e interface{}, k string, v interface{}) bool SetMetadata(e interface{}, m Metadata) bool GetNodes() []*Node GetEdges() []*Edge }
func BackendFromConfig ¶
func BackendFromConfig() (GraphBackend, error)
type GraphEventListener ¶
type GremlinBackend ¶
type GremlinBackend struct {
// contains filtered or unexported fields
}
func NewGremlinBackend ¶
func NewGremlinBackend(endpoint string) (*GremlinBackend, error)
func (GremlinBackend) AddEdge ¶
func (g GremlinBackend) AddEdge(e *Edge) bool
func (GremlinBackend) AddMetadata ¶ added in v0.2.0
func (g GremlinBackend) AddMetadata(i interface{}, k string, v interface{}) bool
func (GremlinBackend) AddNode ¶
func (g GremlinBackend) AddNode(n *Node) bool
func (GremlinBackend) DelEdge ¶
func (g GremlinBackend) DelEdge(e *Edge) bool
func (GremlinBackend) DelNode ¶
func (g GremlinBackend) DelNode(n *Node) bool
func (GremlinBackend) GetEdge ¶
func (g GremlinBackend) GetEdge(i Identifier) *Edge
func (GremlinBackend) GetEdgeNodes ¶
func (g GremlinBackend) GetEdgeNodes(e *Edge) (*Node, *Node)
func (GremlinBackend) GetEdges ¶
func (g GremlinBackend) GetEdges() []*Edge
func (GremlinBackend) GetNode ¶
func (g GremlinBackend) GetNode(i Identifier) *Node
func (GremlinBackend) GetNodeEdges ¶
func (g GremlinBackend) GetNodeEdges(n *Node) []*Edge
func (GremlinBackend) GetNodes ¶
func (g GremlinBackend) GetNodes() []*Node
func (GremlinBackend) SetMetadata ¶
func (g GremlinBackend) SetMetadata(i interface{}, meta Metadata) bool
type MemoryBackend ¶
type MemoryBackend struct {
// contains filtered or unexported fields
}
func NewMemoryBackend ¶
func NewMemoryBackend() (*MemoryBackend, error)
func (MemoryBackend) AddEdge ¶
func (m MemoryBackend) AddEdge(e *Edge) bool
func (MemoryBackend) AddMetadata ¶ added in v0.2.0
func (m MemoryBackend) AddMetadata(i interface{}, k string, v interface{}) bool
func (MemoryBackend) AddNode ¶
func (m MemoryBackend) AddNode(n *Node) bool
func (MemoryBackend) DelEdge ¶
func (m MemoryBackend) DelEdge(e *Edge) bool
func (MemoryBackend) DelNode ¶
func (m MemoryBackend) DelNode(n *Node) bool
func (MemoryBackend) GetEdge ¶
func (m MemoryBackend) GetEdge(i Identifier) *Edge
func (MemoryBackend) GetEdgeNodes ¶
func (m MemoryBackend) GetEdgeNodes(e *Edge) (*Node, *Node)
func (MemoryBackend) GetEdges ¶
func (m MemoryBackend) GetEdges() []*Edge
func (MemoryBackend) GetNode ¶
func (m MemoryBackend) GetNode(i Identifier) *Node
func (MemoryBackend) GetNodeEdges ¶
func (m MemoryBackend) GetNodeEdges(n *Node) []*Edge
func (MemoryBackend) GetNodes ¶
func (m MemoryBackend) GetNodes() []*Node
func (MemoryBackend) SetMetadata ¶
func (m MemoryBackend) SetMetadata(i interface{}, meta Metadata) bool
type MemoryBackendEdge ¶
type MemoryBackendEdge struct {
*Edge
}
type MemoryBackendNode ¶
type MemoryBackendNode struct { *Node // contains filtered or unexported fields }
type MetadataTransaction ¶ added in v0.3.0
type MetadataTransaction struct {
// contains filtered or unexported fields
}
func (*MetadataTransaction) AddMetadata ¶ added in v0.3.0
func (t *MetadataTransaction) AddMetadata(k string, v interface{})
func (*MetadataTransaction) Commit ¶ added in v0.3.0
func (t *MetadataTransaction) Commit()
type Node ¶
type Node struct {
// contains filtered or unexported fields
}
func (*Node) MarshalJSON ¶
type Server ¶
func NewServerFromConfig ¶
func (*Server) ListenAndServe ¶
func (s *Server) ListenAndServe()
func (*Server) OnEdgeAdded ¶
func (*Server) OnEdgeDeleted ¶
func (*Server) OnEdgeUpdated ¶
func (*Server) OnNodeAdded ¶
func (*Server) OnNodeDeleted ¶
func (*Server) OnNodeUpdated ¶
type TitangraphBackend ¶ added in v0.3.0
type TitangraphBackend struct {
GremlinBackend
}
func NewTitangraphBackend ¶ added in v0.3.0
func NewTitangraphBackend(endpoint string) (*TitangraphBackend, error)
Source Files
¶
Click to show internal directories.
Click to hide internal directories.