graph

package

Go to main page

Versions in this module

v0

v0.9.0

Jan 27, 2017

Changes in this version

type GraphServer

+ func (s *GraphServer) OnUnregisterClient(c *shttp.WSClient)

+ type HostNodeTIDMap map[string][]string

+ func BuildHostNodeTIDMap(nodes []*Node) HostNodeTIDMap

v0.8.0

Dec 9, 2016

Changes in this version

type ElasticSearchBackend

+ func (b *ElasticSearchBackend) WithContext(graph *Graph, context GraphContext) (*Graph, error)

type Graph

+ func (g *Graph) LookupEdges(pm Metadata, cm Metadata, em Metadata) []*Edge

type GraphBackend

+ WithContext func(graph *Graph, context GraphContext) (*Graph, error)

type GremlinBackend

+ func (g GremlinBackend) WithContext(graph *Graph, context GraphContext) (*Graph, error)

+ type HostNodeIDMap map[string][]string

+ func BuildHostNodeMap(nodes []*Node) HostNodeIDMap

type MemoryBackend

+ func (m MemoryBackend) WithContext(graph *Graph, context GraphContext) (*Graph, error)

type OrientDBBackend

+ func (o *OrientDBBackend) WithContext(graph *Graph, context GraphContext) (*Graph, error)

type ShadowedBackend

+ func (c *ShadowedBackend) WithContext(graph *Graph, context GraphContext) (*Graph, error)

v0.7.0

Nov 8, 2016

Changes in this version

type Forwarder

+ Host string

type Graph

+ func (g *Graph) DelHostGraph(host string)

v0.6.0

Oct 6, 2016

Changes in this version

+ const Direct

+ const Shadowed

+ var ErrBadConfig = errors.New("elasticsearch : Config file is misconfigured, check elasticsearch key format")

+ type ElasticSearchBackend struct

+ func NewElasticSearchBackend(addr string, port string, maxConns int, retrySeconds int) (*ElasticSearchBackend, error)

+ func NewElasticSearchBackendFromConfig() (*ElasticSearchBackend, error)

+ func (b *ElasticSearchBackend) AddEdge(e *Edge) bool

+ func (b *ElasticSearchBackend) AddMetadata(i interface{}, k string, v interface{}) bool

+ func (b *ElasticSearchBackend) AddNode(n *Node) bool

+ func (b *ElasticSearchBackend) DelEdge(e *Edge) bool

+ func (b *ElasticSearchBackend) DelNode(n *Node) bool

+ func (b *ElasticSearchBackend) GetEdge(i Identifier, t *time.Time) *Edge

+ func (b *ElasticSearchBackend) GetEdgeNodes(e *Edge, t *time.Time) (*Node, *Node)

+ func (b *ElasticSearchBackend) GetEdges(t *time.Time) (edges []*Edge)

+ func (b *ElasticSearchBackend) GetNode(i Identifier, t *time.Time) *Node

+ func (b *ElasticSearchBackend) GetNodeEdges(n *Node, t *time.Time) (edges []*Edge)

+ func (b *ElasticSearchBackend) GetNodes(t *time.Time) (nodes []*Node)

+ func (b *ElasticSearchBackend) SetMetadata(i interface{}, m Metadata) bool

type Graph

+ func (g *Graph) LookupParents(n *Node, f Metadata, em ...Metadata) []*Node

+ type ShadowedBackend struct

+ func NewShadowedBackend(persistent GraphBackend) (*ShadowedBackend, error)

+ func (c *ShadowedBackend) AddEdge(e *Edge) bool

+ func (c *ShadowedBackend) AddMetadata(i interface{}, k string, v interface{}) bool

+ func (c *ShadowedBackend) AddNode(n *Node) bool

+ func (c *ShadowedBackend) DelEdge(e *Edge) bool

+ func (c *ShadowedBackend) DelNode(n *Node) bool

+ func (c *ShadowedBackend) GetEdge(i Identifier, t *time.Time) *Edge

+ func (c *ShadowedBackend) GetEdgeNodes(e *Edge, t *time.Time) (*Node, *Node)

+ func (c *ShadowedBackend) GetEdges(t *time.Time) []*Edge

+ func (c *ShadowedBackend) GetNode(i Identifier, t *time.Time) *Node

+ func (c *ShadowedBackend) GetNodeEdges(n *Node, t *time.Time) (edges []*Edge)

+ func (c *ShadowedBackend) GetNodes(t *time.Time) []*Node

+ func (c *ShadowedBackend) SetMetadata(i interface{}, metadata Metadata) bool

v0.5.0

Sep 15, 2016

Changes in this version

type Forwarder

+ Root *Node

v0.4.0

Aug 4, 2016

Changes in this version

+ const Namespace

type Edge

+ func (e *Edge) Decode(i interface{}) error

+ func (e *Edge) GetChild() Identifier

+ func (e *Edge) GetParent() Identifier

+ func (e *Edge) Host() string

+ func (e *Edge) JsonRawMessage() *json.RawMessage

+ func (e *Edge) MatchMetadata(f Metadata) bool

type Forwarder

+ func NewForwarderFromConfig(c *shttp.WSAsyncClient, g *Graph) *Forwarder

type Graph

+ func NewGraphFromConfig(backend GraphBackend) (*Graph, error)

+ func NewGraphWithContext(hostID string, b GraphBackend, c GraphContext) (*Graph, error)

+ func (g *Graph) GetContext() GraphContext

+ func (g *Graph) GetNodeEdges(n *Node) []*Edge

+ func (g *Graph) WithContext(c GraphContext) *Graph

+ type GraphContext struct

+ Time *time.Time

+ func (c *GraphContext) GetTime() time.Time

+ type GraphServer struct

+ Graph *Graph

+ WSServer *shttp.WSServer

+ func (s *GraphServer) OnEdgeAdded(e *Edge)

+ func (s *GraphServer) OnEdgeDeleted(e *Edge)

+ func (s *GraphServer) OnEdgeUpdated(e *Edge)

+ func (s *GraphServer) OnMessage(c *shttp.WSClient, msg shttp.WSMessage)

+ func (s *GraphServer) OnNodeAdded(n *Node)

+ func (s *GraphServer) OnNodeDeleted(n *Node)

+ func (s *GraphServer) OnNodeUpdated(n *Node)

type MemoryBackendEdge

+ func (e MemoryBackendEdge) Host() string

+ func (e MemoryBackendEdge) MatchMetadata(f Metadata) bool

type MemoryBackendNode

+ func (e MemoryBackendNode) Host() string

+ func (e MemoryBackendNode) MatchMetadata(f Metadata) bool

+ type MetadataMatcher interface

+ Match func(v interface{}) bool

type Node

+ func (e *Node) Host() string

+ func (e *Node) MatchMetadata(f Metadata) bool

+ func (n *Node) Decode(i interface{}) error

+ func (n *Node) JsonRawMessage() *json.RawMessage

+ type OrientDBBackend struct

+ func NewOrientDBBackend(addr string, database string, username string, password string) (*OrientDBBackend, error)

+ func NewOrientDBBackendFromConfig() (*OrientDBBackend, error)

+ func (o *OrientDBBackend) AddEdge(e *Edge) bool

+ func (o *OrientDBBackend) AddMetadata(i interface{}, k string, v interface{}) bool

+ func (o *OrientDBBackend) AddNode(n *Node) bool

+ func (o *OrientDBBackend) DelEdge(e *Edge) bool

+ func (o *OrientDBBackend) DelNode(n *Node) bool

+ func (o *OrientDBBackend) GetEdge(i Identifier, t time.Time) *Edge

+ func (o *OrientDBBackend) GetEdgeNodes(e *Edge, t time.Time) (n1 *Node, n2 *Node)

+ func (o *OrientDBBackend) GetEdges(t time.Time) (edges []*Edge)

+ func (o *OrientDBBackend) GetNode(i Identifier, t time.Time) *Node

+ func (o *OrientDBBackend) GetNodeEdges(n *Node, t time.Time) (edges []*Edge)

+ func (o *OrientDBBackend) GetNodes(t time.Time) (nodes []*Node)

+ func (o *OrientDBBackend) SetMetadata(i interface{}, m Metadata) bool

v0.3.0

Apr 26, 2016

Changes in this version

type AsyncClient

+ AuthClient *shttp.AuthenticationClient

+ type DefaultGraphListener struct

+ 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 EdgeValidator func(e *Edge) bool

type Graph

+ func (g *Graph) GetEdgeNodes(e *Edge) (*Node, *Node)

+ func (g *Graph) LookupShortestPath(n *Node, m Metadata, ev ...EdgeValidator) []*Node

+ func (g *Graph) RemoveEventListener(l GraphEventListener)

+ func (g *Graph) StartMetadataTransaction(i interface{}) *MetadataTransaction

+ type MetadataTransaction struct

+ func (t *MetadataTransaction) AddMetadata(k string, v interface{})

+ func (t *MetadataTransaction) Commit()

+ type TitangraphBackend struct

+ func NewTitangraphBackend(endpoint string) (*TitangraphBackend, error)

v0.2.0

Feb 23, 2016

Changes in this version

type Alert

+ func (a *Alert) RegisterRPCEndpoints()

type Edge

+ func (e *Edge) Metadata() Metadata

type Graph

+ func (g *Graph) AddMetadata(e interface{}, k string, v interface{})

+ func (g *Graph) LookupFirstChild(n *Node, f Metadata) *Node

type GraphBackend

+ AddMetadata func(e interface{}, k string, v interface{}) bool

type GremlinBackend

+ func (g GremlinBackend) AddMetadata(i interface{}, k string, v interface{}) bool

type MemoryBackend

+ func (m MemoryBackend) AddMetadata(i interface{}, k string, v interface{}) bool

type MemoryBackendEdge

+ func (e MemoryBackendEdge) Metadata() Metadata

type MemoryBackendNode

+ func (e MemoryBackendNode) Metadata() Metadata

+ type Metadata map[string]interface

+ func (m *Metadata) String() string

type Node

+ func (e *Node) Metadata() Metadata

v0.1.0

Feb 10, 2016

Changes in this version

+ const MaxAlertMessageQueue

+ type Alert struct

+ Graph *Graph

+ Router *mux.Router

+ func NewAlert(g *Graph, router *mux.Router) *Alert

+ func (a *Alert) AddEventListener(l AlertEventListener)

+ func (a *Alert) DelEventListener(l AlertEventListener)

+ func (c *Alert) AlertDelete(w http.ResponseWriter, r *http.Request)

+ func (c *Alert) AlertIndex(w http.ResponseWriter, r *http.Request)

+ func (c *Alert) AlertInsert(w http.ResponseWriter, r *http.Request)

+ func (c *Alert) AlertShow(w http.ResponseWriter, r *http.Request)

+ func (c *Alert) EvalNodes()

+ func (c *Alert) OnConnected()

+ func (c *Alert) OnDisconnected()

+ func (c *Alert) OnEdgeAdded(e *Edge)

+ func (c *Alert) OnEdgeDeleted(e *Edge)

+ func (c *Alert) OnEdgeUpdated(e *Edge)

+ func (c *Alert) OnNodeAdded(n *Node)

+ func (c *Alert) OnNodeDeleted(n *Node)

+ func (c *Alert) OnNodeUpdated(n *Node)

+ func (c *Alert) Register(atp AlertTestParam) *AlertTest

+ func (c *Alert) RegisterRpcEndpoints()

+ func (c *Alert) UnRegister(atp AlertTestParam)

+ type AlertEventListener interface

+ OnAlert func(n *AlertMessage)

+ type AlertMessage struct

+ Count int

+ Reason string

+ ReasonData interface{}

+ Timestamp time.Time

+ Type AlertType

+ UUID uuid.UUID

+ func (am *AlertMessage) Marshal() []byte

+ func (am *AlertMessage) String() string

+ type AlertTest struct

+ Count int

+ CreateTime time.Time

+ Type AlertType

+ UUID *uuid.UUID

+ type AlertTestParam struct

+ Action string

+ Description string

+ Name string

+ Select string

+ Test string

+ type AlertType int

+ const FIXED

+ const THRESHOLD

+ type AsyncClient struct

+ Addr string

+ Path string

+ Port int

+ func NewAsyncClient(addr string, port int, path string) *AsyncClient

+ func (c *AsyncClient) AddListener(l EventListener)

+ func (c *AsyncClient) Connect()

+ func (c *AsyncClient) Disconnect()

+ func (c *AsyncClient) IsConnected() bool

+ func (c *AsyncClient) SendWSMessage(m WSMessage)

+ type ClientType int

+ const ALERTCLIENT

+ const GRAPHCLIENT

+ type Edge struct

+ func (e *Edge) MarshalJSON() ([]byte, error)

+ func (e *Edge) Metadatas() Metadatas

+ func (e *Edge) String() string

+ type EventListener interface

+ OnConnected func()

+ OnDisconnected func()

+ type Forwarder struct

+ Client *AsyncClient

+ Graph *Graph

+ func NewForwarder(c *AsyncClient, g *Graph) *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 struct

+ func NewGraph(b GraphBackend) (*Graph, error)

+ func (g *Graph) AddEdge(e *Edge) bool

+ func (g *Graph) AddEventListener(l GraphEventListener)

+ 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) GetAncestorsTo(n *Node, f Metadatas) ([]*Node, bool)

+ func (g *Graph) GetEdge(i Identifier) *Edge

+ 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)

+ func (g *Graph) LookupChildren(n *Node, f Metadatas) []*Node

+ func (g *Graph) LookupFirstNode(m Metadatas) *Node

+ func (g *Graph) LookupNodes(m Metadatas) []*Node

+ func (g *Graph) LookupNodesFromKey(key string) []*Node

+ func (g *Graph) LookupParentNodes(n *Node, f Metadatas) []*Node

+ func (g *Graph) MarshalJSON() ([]byte, error)

+ func (g *Graph) NewEdge(i Identifier, p *Node, c *Node, m Metadatas) *Edge

+ func (g *Graph) NewNode(i Identifier, m Metadatas) *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) Replace(o *Node, n *Node, m Metadatas) *Node

+ func (g *Graph) SetMetadata(e interface{}, k string, v interface{})

+ func (g *Graph) SetMetadatas(e interface{}, m Metadatas)

+ func (g *Graph) String() string

+ func (g *Graph) Unlink(n1 *Node, n2 *Node)

+ type GraphBackend interface

+ AddEdge func(e *Edge) bool

+ AddNode func(n *Node) bool

+ DelEdge func(e *Edge) bool

+ DelNode func(n *Node) bool

+ GetEdge func(i Identifier) *Edge

+ GetEdgeNodes func(e *Edge) (*Node, *Node)

+ GetEdges func() []*Edge

+ GetNode func(i Identifier) *Node

+ GetNodeEdges func(n *Node) []*Edge

+ GetNodes func() []*Node

+ SetMetadata func(e interface{}, k string, v interface{}) bool

+ SetMetadatas func(e interface{}, m Metadatas) bool

+ func BackendFromConfig() (GraphBackend, error)

+ type GraphEventListener interface

+ OnEdgeAdded func(e *Edge)

+ OnEdgeDeleted func(e *Edge)

+ OnEdgeUpdated func(e *Edge)

+ OnNodeAdded func(n *Node)

+ OnNodeDeleted func(n *Node)

+ OnNodeUpdated func(n *Node)

+ type GremlinBackend struct

+ func NewGremlinBackend(addr string, port int) (*GremlinBackend, error)

+ func (g GremlinBackend) AddEdge(e *Edge) 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{}, k string, v interface{}) bool

+ func (g GremlinBackend) SetMetadatas(i interface{}, meta Metadatas) bool

+ type Identifier string

+ func GenID() Identifier

+ type MemoryBackend struct

+ func NewMemoryBackend() (*MemoryBackend, error)

+ func (m MemoryBackend) AddEdge(e *Edge) 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{}, k string, v interface{}) bool

+ func (m MemoryBackend) SetMetadatas(i interface{}, meta Metadatas) bool

+ type MemoryBackendEdge struct

+ func (e MemoryBackendEdge) Metadatas() Metadatas

+ func (e MemoryBackendEdge) String() string

+ type MemoryBackendNode struct

+ func (e MemoryBackendNode) Metadatas() Metadatas

+ func (e MemoryBackendNode) String() string

+ type Metadatas map[string]interface

+ func (m *Metadatas) String() string

+ type Node struct

+ func (e *Node) Metadatas() Metadatas

+ func (e *Node) String() string

+ func (n *Node) MarshalJSON() ([]byte, error)

+ type Server struct

+ Alert *Alert

+ Graph *Graph

+ Host string

+ Router *mux.Router

+ func NewServer(g *Graph, a *Alert, router *mux.Router, pongWait time.Duration) *Server

+ func NewServerFromConfig(g *Graph, a *Alert, router *mux.Router) (*Server, error)

+ func (s *Server) ListenAndServe()

+ func (s *Server) OnEdgeAdded(e *Edge)

+ func (s *Server) OnEdgeDeleted(e *Edge)

+ func (s *Server) OnEdgeUpdated(e *Edge)

+ func (s *Server) OnNodeAdded(n *Node)

+ func (s *Server) OnNodeDeleted(n *Node)

+ func (s *Server) OnNodeUpdated(n *Node)

+ func (s *Server) Stop()

+ type WSClient struct

+ Type ClientType

+ func (c *WSClient) OnAlert(amsg *AlertMessage)

+ type WSMessage struct

+ Obj interface{}

+ Type string

+ func UnmarshalWSMessage(b []byte) (WSMessage, error)

+ func (g WSMessage) Marshal() []byte

+ func (g WSMessage) String() string

+ type WSServer struct

+ Alert *Alert

+ Graph *Graph

+ func (s *WSServer) ListenAndServe()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL