graph

Dec 3, 2018

Changes in this version

+ var EdgeMetadataDecoders = make(map[string]MetadataDecoder)

+ var NodeMetadataDecoders = make(map[string]MetadataDecoder)

+ type Backend interface

+ EdgeAdded func(e *Edge) bool

+ EdgeDeleted func(e *Edge) bool

+ GetEdge func(i Identifier, at Context) []*Edge

+ GetEdgeNodes func(e *Edge, at Context, parentMetadata, childMetadata ElementMatcher) ([]*Node, []*Node)

+ GetEdges func(t Context, m ElementMatcher) []*Edge

+ GetNode func(i Identifier, at Context) []*Node

+ GetNodeEdges func(n *Node, at Context, m ElementMatcher) []*Edge

+ GetNodes func(t Context, m ElementMatcher) []*Node

+ IsHistorySupported func() bool

+ MetadataUpdated func(e interface{}) bool

+ NodeAdded func(n *Node) bool

+ NodeDeleted func(n *Node) bool

+ type Context struct

+ TimePoint bool

+ TimeSlice *common.TimeSlice

type Edge

+ Child Identifier

+ Parent Identifier

+ func (e *Edge) GetFieldKeys() []string

+ func (e *Edge) UnmarshalJSON(b []byte) error

+ type ElementFilter struct

+ func NewElementFilter(f *filters.Filter) *ElementFilter

+ func (mf *ElementFilter) Filter() (*filters.Filter, error)

+ func (mf *ElementFilter) Match(g common.Getter) bool

+ type ElementMatcher interface

+ Filter func() (*filters.Filter, error)

+ Match func(g common.Getter) bool

+ type EventHandler struct

+ func NewEventHandler(maxEvents int) *EventHandler

+ func (g *EventHandler) AddEventListener(l EventListener)

+ func (g *EventHandler) NotifyEvent(kind graphEventType, element interface{})

+ func (g *EventHandler) RemoveEventListener(l EventListener)

type EventListener

+ 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 Indexer struct

+ func NewIndexer(g *Graph, listenerHandler ListenerHandler, hashNode NodeHasher, ...) *Indexer

+ func (i *Indexer) AddEventListener(l EventListener)

+ func (i *Indexer) FromHash(hash string) (nodes []*Node, values []interface{})

+ func (i *Indexer) OnNodeAdded(n *Node)

+ func (i *Indexer) OnNodeDeleted(n *Node)

+ func (i *Indexer) OnNodeUpdated(n *Node)

+ func (i *Indexer) RemoveEventListener(l EventListener)

+ func (i *Indexer) Start()

+ func (i *Indexer) Stop()

+ type ListenerHandler interface

+ AddEventListener func(l EventListener)

+ RemoveEventListener func(l EventListener)

type MemoryBackendEdge

+ func (e MemoryBackendEdge) GetFieldKeys() []string

type MemoryBackendNode

+ func (e MemoryBackendNode) GetFieldKeys() []string

+ type MetadataDecoder func(raw json.RawMessage) (common.Getter, error)

type Node

+ func (e *Node) GetFieldKeys() []string

+ func (n *Node) UnmarshalJSON(b []byte) error

+ type NodeAction interface

+ ProcessNode func(g *Graph, n *Node) bool

+ type Processor struct

+ MetadataIndexer *MetadataIndexer

+ func NewProcessor(g *Graph, listenerHandler ListenerHandler, m ElementMatcher, indexes ...string) (processor *Processor)

+ func (processor *Processor) Cancel(values ...interface{})

+ func (processor *Processor) DoAction(action NodeAction, values ...interface{})

+ func (processor *Processor) OnNodeAdded(n *Node)

+ func (processor *Processor) Start()

+ func (processor *Processor) Stop()

type SyncRequestMsg

+ func (s *SyncRequestMsg) UnmarshalJSON(b []byte) error

+ type Time time.Time

+ func TimeUTC() Time

+ func Unix(sec int64, nsec int64) Time

+ func (t *Time) MarshalJSON() ([]byte, error)

+ func (t *Time) UnmarshalJSON(b []byte) error

+ func (t Time) IsZero() bool

+ func (t Time) Unix() int64

Oct 9, 2018

Changes in this version

+ const EdgeAdded

+ const EdgeDeleted

+ const EdgeUpdated

+ const NodeAdded

+ const NodeDeleted

+ const NodeUpdated

+ const OriginGraphDeletedMsgType

+ type DefaultLinker struct

+ func (dl *DefaultLinker) GetABLinks(node *Node) []*Edge

+ func (dl *DefaultLinker) GetBALinks(node *Node) []*Edge

type Edge

+ func CreateEdge(i Identifier, p *Node, c *Node, m Metadata, t time.Time, h string, ...) *Edge

+ func (e *Edge) SetOrigin(origin string)

type Graph

+ func (g *Graph) CreateEdge(i Identifier, p *Node, c *Node, m Metadata, t time.Time, h ...string) *Edge

+ func (g *Graph) CreateNode(i Identifier, m Metadata, t time.Time, h ...string) *Node

+ func (g *Graph) DelOriginGraph(origin string)

+ func (g *Graph) Origin() string

type GraphEventHandler

+ func (g *GraphEventHandler) NotifyEvent(kind graphEventType, element interface{})

+ type GraphListenerHandler interface

+ AddEventListener func(l GraphEventListener)

+ RemoveEventListener func(l GraphEventListener)

+ type Linker interface

+ GetABLinks func(node *Node) []*Edge

+ GetBALinks func(node *Node) []*Edge

type MemoryBackendEdge

+ func (e MemoryBackendEdge) GetFieldString(field string) (_ string, err error)

+ func (e MemoryBackendEdge) SetOrigin(origin string)

type MemoryBackendNode

+ func (e MemoryBackendNode) SetOrigin(origin string)

+ type MetadataIndexerLinker struct

+ func NewMetadataIndexerLinker(g *Graph, indexer1, indexer2 *MetadataIndexer, edgeMetadata Metadata) *MetadataIndexerLinker

+ func (mil *MetadataIndexerLinker) GetABLinks(node *Node) (edges []*Edge)

+ func (mil *MetadataIndexerLinker) GetBALinks(node *Node) (edges []*Edge)

type Node

+ func CreateNode(i Identifier, m Metadata, t time.Time, h string, s common.ServiceType) *Node

+ func (e *Node) SetOrigin(origin string)

+ type ResourceLinker struct

+ func NewResourceLinker(g *Graph, glh1 GraphListenerHandler, glh2 GraphListenerHandler, linker Linker, ...) *ResourceLinker

+ func (rl *ResourceLinker) Start()

+ func (rl *ResourceLinker) Stop()

Sep 14, 2018

Changes in this version

+ func UnmarshalMessage(msg *ws.StructMessage) (string, interface{}, error)

type MetadataTransaction

+ func (t *MetadataTransaction) DelMetadata(k string)

Aug 8, 2018

Changes in this version

type Edge

+ func (e *Edge) Origin() string

type MemoryBackendEdge

+ func (e MemoryBackendEdge) Origin() string

type MemoryBackendNode

+ func (e MemoryBackendNode) Origin() string

type Metadata

+ func (m *Metadata) SetFieldAndNormalize(k string, v interface{}) bool

type Node

+ func (e *Node) Origin() string

Jun 21, 2018

Changes in this version

+ const ESGraphElementMapping

type ElasticSearchBackend

+ func NewElasticSearchBackendFromClient(client elasticsearch.ElasticSearchClientInterface) (*ElasticSearchBackend, error)

type GraphBackend

+ func NewBackendByName(name string) (backend GraphBackend, err error)

type GraphIndexer

+ func (i *GraphIndexer) AddEventListener(l GraphEventListener)

+ func (i *GraphIndexer) RemoveEventListener(l GraphEventListener)

Apr 12, 2018

Changes in this version

type CachedBackend

+ func (c *CachedBackend) IsHistorySupported() bool

type ElasticSearchBackend

+ func (b *ElasticSearchBackend) IsHistorySupported() bool

type Graph

+ func (g *Graph) CloneWithContext(context GraphContext) (*Graph, error)

+ func (g *Graph) GetFirstLink(parent, child *Node, metadata Metadata) *Edge

type GraphBackend

+ IsHistorySupported func() bool

type GraphContext

+ TimePoint bool

type GraphIndexer

+ func (i *GraphIndexer) Start()

+ func (i *GraphIndexer) Stop()

type MemoryBackend

+ func (m *MemoryBackend) IsHistorySupported() bool

type OrientDBBackend

+ func (o *OrientDBBackend) IsHistorySupported() bool

Jan 29, 2018

Changes in this version

+ const SortByInt64

+ const SortByString

+ func SortEdges(edges []*Edge, sortBy string, sortOrder common.SortOrder)

+ func SortNodes(nodes []*Node, sortBy string, sortOrder common.SortOrder)

type Edge

+ func (e *Edge) GetFields() ([]string, error)

+ type GraphElementFilter struct

+ func NewGraphElementFilter(f *filters.Filter) *GraphElementFilter

+ func (mf *GraphElementFilter) Filter() (*filters.Filter, error)

+ func (mf *GraphElementFilter) Match(e *graphElement) bool

+ type GraphElementMatcher interface

+ Filter func() (*filters.Filter, error)

+ Match func(e *graphElement) bool

+ type GraphEventHandler struct

+ func NewGraphEventHandler(maxEvents int) *GraphEventHandler

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

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

+ type GraphIndexer struct

+ func NewGraphIndexer(g *Graph, hashNode NodeHasher) *GraphIndexer

+ func (i *GraphIndexer) FromHash(hash string) (nodes []*Node)

+ func (i *GraphIndexer) OnNodeAdded(n *Node)

+ func (i *GraphIndexer) OnNodeDeleted(n *Node)

+ func (i *GraphIndexer) OnNodeUpdated(n *Node)

type Identifier

+ func GenIDNameBased(namespace, name string) Identifier

type MemoryBackendEdge

+ func (e MemoryBackendEdge) GetFields() ([]string, error)

type MemoryBackendNode

+ func (e MemoryBackendNode) GetFields() ([]string, error)

type Metadata

+ func (m *Metadata) SetField(k string, v interface{}) bool

+ func (m Metadata) Filter() (*filters.Filter, error)

+ func (m Metadata) Match(e *graphElement) bool

+ type MetadataIndexer struct

+ func NewMetadataIndexer(g *Graph, m GraphElementMatcher, indexes ...string) (indexer *MetadataIndexer)

+ func (m *MetadataIndexer) Get(values ...interface{}) []*Node

+ func (m *MetadataIndexer) Hash(values ...interface{}) string

type Node

+ func (e *Node) GetFields() ([]string, error)

+ type NodeHasher func(n *Node) string

Dec 6, 2017

Changes in this version

type Graph

+ func (g *Graph) GetNodesMap(t *common.TimeSlice) map[Identifier]*Node

Nov 14, 2017

Changes in this version

type Graph

+ func (g *Graph) Diff(newGraph *Graph) (addedNodes []*Node, removedNodes []*Node, addedEdges []*Edge, ...)

+ type SyncRequestMsg struct

+ GremlinFilter string

Oct 12, 2017

Changes in this version

+ const SyncMsgType

+ var ErrSyncMsgMalFormed = errors.New("SyncMsg/SyncReplyMsg malformed")

+ type SyncMsg struct

+ Edges []*Edge

+ Nodes []*Node

Aug 1, 2017

Changes in this version

+ const CacheOnlyMode

+ const DefaultMode

+ const PersistentOnlyMode

+ var ErrSyncReplyMsgMalFormed = errors.New("SyncReplyMsg malformed")

+ var ErrSyncRequestMalFormed = errors.New("SyncRequestMsg malformed")

type CachedBackend

+ func (c *CachedBackend) EdgeAdded(e *Edge) bool

+ func (c *CachedBackend) EdgeDeleted(e *Edge) bool

+ func (c *CachedBackend) MetadataUpdated(i interface{}) bool

+ func (c *CachedBackend) NodeAdded(n *Node) bool

+ func (c *CachedBackend) NodeDeleted(n *Node) bool

type Edge

+ func (e *Edge) GetFieldStringList(name string) ([]string, error)

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

type ElasticSearchBackend

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

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

+ func (b *ElasticSearchBackend) MetadataUpdated(i interface{}) bool

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

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

type Graph

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

+ func (g *Graph) EdgeDeleted(e *Edge)

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

+ func (g *Graph) NodeAdded(n *Node) bool

+ func (g *Graph) NodeDeleted(n *Node)

+ func (g *Graph) NodeUpdated(n *Node) bool

type GraphBackend

+ EdgeAdded func(e *Edge) bool

+ EdgeDeleted func(e *Edge) bool

+ MetadataUpdated func(e interface{}) bool

+ NodeAdded func(n *Node) bool

+ NodeDeleted func(n *Node) bool

type InterfaceMetric

+ func (im *InterfaceMetric) GetFieldInt64(field string) (int64, error)

type MemoryBackend

+ func (m *MemoryBackend) EdgeAdded(e *Edge) bool

+ func (m *MemoryBackend) EdgeDeleted(e *Edge) bool

+ func (m *MemoryBackend) MetadataUpdated(i interface{}) bool

+ func (m *MemoryBackend) NodeAdded(n *Node) bool

+ func (m *MemoryBackend) NodeDeleted(n *Node) bool

type MemoryBackendEdge

+ func (e MemoryBackendEdge) GetFieldStringList(name string) ([]string, error)

type MemoryBackendNode

+ func (e MemoryBackendNode) GetFieldStringList(name string) ([]string, error)

type Node

+ func (e *Node) GetFieldStringList(name string) ([]string, error)

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

type OrientDBBackend

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

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

+ func (o *OrientDBBackend) MetadataUpdated(i interface{}) bool

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

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

type Server

+ WSServer *shttp.WSServer

+ func (s *Server) AddEventHandler(h ServerEventHandler)

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

+ type ServerEventHandler interface

+ OnGraphMessage func(c *shttp.WSClient, m shttp.WSMessage, msgType string, obj interface{})

May 5, 2017

Changes in this version

type GraphServer

+ func (s *GraphServer) AddEventHandler(h GraphServerEventHandler)

+ type GraphServerEventHandler interface

+ OnGraphMessage func(c *shttp.WSClient, m shttp.WSMessage, msgType string, obj interface{})

type Metadata

+ func (m Metadata) Clone() Metadata

Mar 31, 2017

Changes in this version

+ const CACHE_ONLY_MODE

+ const DEFAULT_MODE

+ const EdgeAddedMsgType

+ const EdgeDeletedMsgType

+ const EdgeUpdatedMsgType

+ const HostGraphDeletedMsgType

+ const NodeAddedMsgType

+ const NodeDeletedMsgType

+ const NodeUpdatedMsgType

+ const PERSISTENT_ONLY_MODE

+ const SyncReplyMsgType

+ const SyncRequestMsgType

+ var SyncReplyMsgMalFormed = errors.New("SyncReplyMsg malformed")

+ var SyncRequestMalFormed = errors.New("SyncRequestMsg malformed")

+ func NewFilterForEdge(parent Identifier, child Identifier) *filters.Filter

+ func NewFilterForMetadata(m Metadata) (*filters.Filter, error)

+ func NewFilterForTime(t time.Time) *filters.Filter

+ func NewFilterForTimeSlice(t *common.TimeSlice) *filters.Filter

+ type CachedBackend struct

+ func NewCachedBackend(persistent GraphBackend) (*CachedBackend, error)

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

+ func (c *CachedBackend) AddMetadata(i interface{}, k string, v interface{}, t time.Time) bool

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

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

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

+ func (c *CachedBackend) GetEdge(i Identifier, t *common.TimeSlice) []*Edge

+ func (c *CachedBackend) GetEdgeNodes(e *Edge, t *common.TimeSlice, parentMetadata, childMetadata Metadata) ([]*Node, []*Node)

+ func (c *CachedBackend) GetEdges(t *common.TimeSlice, m Metadata) []*Edge

+ func (c *CachedBackend) GetNode(i Identifier, t *common.TimeSlice) []*Node

+ func (c *CachedBackend) GetNodeEdges(n *Node, t *common.TimeSlice, m Metadata) (edges []*Edge)

+ func (c *CachedBackend) GetNodes(t *common.TimeSlice, m Metadata) []*Node

+ func (c *CachedBackend) SetMetadata(i interface{}, metadata Metadata, t time.Time) bool

+ func (c *CachedBackend) SetMode(mode int)

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

type Edge

+ func (e *Edge) GetField(name string) (interface{}, bool)

+ func (e *Edge) GetFieldInt64(field string) (_ int64, err error)

+ func (e *Edge) GetFieldString(name string) (string, error)

type ElasticSearchBackend

+ func (b *ElasticSearchBackend) Query(obj string, tsq *TimedSearchQuery) (sr elastigo.SearchResult, _ error)

+ func (b *ElasticSearchBackend) SearchEdges(tsq *TimedSearchQuery) (edges []*Edge)

+ func (b *ElasticSearchBackend) SearchNodes(tsq *TimedSearchQuery) (nodes []*Node)

type Graph

+ func (g *Graph) DelMetadata(i interface{}, k string) bool

+ func (g *Graph) GetHost() string

type GraphContext

+ TimeSlice *common.TimeSlice

+ type InterfaceMetric struct

+ Collisions int64

+ Multicast int64

+ RxBytes int64

+ RxCompressed int64

+ RxCrcErrors int64

+ RxDropped int64

+ RxErrors int64

+ RxFifoErrors int64

+ RxFrameErrors int64

+ RxLengthErrors int64

+ RxMissedErrors int64

+ RxOverErrors int64

+ RxPackets int64

+ TxAbortedErrors int64

+ TxBytes int64

+ TxCarrierErrors int64

+ TxCompressed int64

+ TxDropped int64

+ TxErrors int64

+ TxFifoErrors int64

+ TxHeartbeatErrors int64

+ TxPackets int64

+ TxWindowErrors int64

+ func (im *InterfaceMetric) Add(m common.Metric) common.Metric

+ func (im *InterfaceMetric) GetField(field string) (int64, error)

type MemoryBackendEdge

+ func (e MemoryBackendEdge) GetField(name string) (interface{}, bool)

+ func (e MemoryBackendEdge) GetFieldInt64(field string) (_ int64, err error)

type MemoryBackendNode

+ func (e MemoryBackendNode) GetField(name string) (interface{}, bool)

+ func (e MemoryBackendNode) GetFieldInt64(field string) (_ int64, err error)

+ func (e MemoryBackendNode) GetFieldString(field string) (_ string, err error)

type MetadataTransaction

+ Metadata Metadata

type Node

+ func (e *Node) GetField(name string) (interface{}, bool)

+ func (e *Node) GetFieldInt64(field string) (_ int64, err error)

+ func (e *Node) GetFieldString(field string) (_ string, err error)

+ type SyncReplyMsg struct

+ Edges []*Edge

+ Nodes []*Node

+ type TimedSearchQuery struct

+ MetadataFilter *filters.Filter

+ TimeFilter *filters.Filter

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

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)

Nov 8, 2016

Changes in this version

type Forwarder

+ Host string

type Graph

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

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

Sep 15, 2016

Changes in this version

type Forwarder

+ Root *Node

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

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)

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

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