traversal

Aug 17, 2021

Changes in this version

+ type AscendantsGremlinTraversalStep struct

+ func (d *AscendantsGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (d *AscendantsGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (d *AscendantsGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) (traversal.GremlinTraversalStep, error)

+ type AscendantsTraversalExtension struct

+ AscendantsToken traversal.Token

+ func NewAscendantsTraversalExtension() *AscendantsTraversalExtension

+ func (e *AscendantsTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *AscendantsTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

Nov 15, 2019

Changes in this version

type FlowTraversalExtension

+ GroupToken traversal.Token

type FlowTraversalStep

+ func (f *FlowTraversalStep) Group(ctx traversal.StepContext, s ...interface{}) *GroupTraversalStep

+ type GroupGremlinTraversalStep struct

+ func (g *GroupGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (g *GroupGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (g *GroupGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) (traversal.GremlinTraversalStep, error)

+ type GroupTraversalExtension struct

+ MoreThanToken traversal.Token

+ func NewGroupTraversalExtension() *GroupTraversalExtension

+ func (e *GroupTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *GroupTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

+ type GroupTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

+ func (ts *GroupTraversalStep) Error() error

+ func (ts *GroupTraversalStep) MarshalJSON() ([]byte, error)

+ func (ts *GroupTraversalStep) MoreThan(ctx traversal.StepContext, s ...interface{}) *GroupTraversalStep

+ func (ts *GroupTraversalStep) Values() []interface{}

+ type MoreThanGremlinTraversalStep struct

+ func (g *MoreThanGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (g *MoreThanGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (g *MoreThanGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) (traversal.GremlinTraversalStep, error)

Dec 3, 2018

Changes in this version

type FlowTraversalStep

+ func (f *FlowTraversalStep) HasEither(ctx traversal.StepContext, s ...interface{}) *FlowTraversalStep

+ type NextHop struct

+ IP string

+ IfIndex int64

+ MAC string

+ type NextHopGremlinTraversalStep struct

+ func (nh *NextHopGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (nh *NextHopGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (nh *NextHopGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) (traversal.GremlinTraversalStep, error)

+ type NextHopTraversalExtension struct

+ NextHopToken traversal.Token

+ func NewNextHopTraversalExtension() *NextHopTraversalExtension

+ func (e *NextHopTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *NextHopTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

+ type NextHopTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

+ func NewNextHopTraversalStep(gt *traversal.GraphTraversal, value map[string]*NextHop) *NextHopTraversalStep

+ func NewNextHopTraversalStepFromError(err ...error) *NextHopTraversalStep

+ func (t *NextHopTraversalStep) Error() error

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

+ func (t *NextHopTraversalStep) Values() []interface{}

type SocketsTraversalStep

+ func (s *SocketsTraversalStep) HasEither(ctx traversal.StepContext, params ...interface{}) *SocketsTraversalStep

Aug 8, 2018

Changes in this version

+ type DescendantsGremlinTraversalStep struct

+ func (d *DescendantsGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (d *DescendantsGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (d *DescendantsGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type DescendantsTraversalExtension struct

+ DescendantsToken traversal.Token

+ func NewDescendantsTraversalExtension() *DescendantsTraversalExtension

+ func (e *DescendantsTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *DescendantsTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

type MetricsTraversalStep

+ func (m *MetricsTraversalStep) PropertyKeys(keys ...interface{}) *traversal.GraphTraversalValue

+ type RawPacketsTraversalExtension struct

+ RawPacketsToken traversal.Token

+ func NewRawPacketsTraversalExtension() *RawPacketsTraversalExtension

+ func (e *RawPacketsTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *RawPacketsTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

Apr 12, 2018

Changes in this version

+ func NewSocketIndexer(g *graph.Graph) *graph.GraphIndexer

type FlowTraversalStep

+ func (f *FlowTraversalStep) Sockets(s ...interface{}) *SocketsTraversalStep

type MetricsTraversalStep

+ func NewMetricsTraversalStepFromError(err error) *MetricsTraversalStep

+ type SocketsGremlinTraversalStep struct

+ func (s *SocketsGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (s *SocketsGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (s *SocketsGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type SocketsTraversalExtension struct

+ SocketsToken traversal.Token

+ func NewSocketsTraversalExtension() *SocketsTraversalExtension

+ func (e *SocketsTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *SocketsTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

+ type SocketsTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

+ func Sockets(tv *traversal.GraphTraversalV) *SocketsTraversalStep

+ func (s *SocketsTraversalStep) Error() error

+ func (s *SocketsTraversalStep) Has(params ...interface{}) *SocketsTraversalStep

+ func (s *SocketsTraversalStep) MarshalJSON() ([]byte, error)

+ func (s *SocketsTraversalStep) PropertyValues(keys ...interface{}) *traversal.GraphTraversalValue

+ func (s *SocketsTraversalStep) Values() []interface{}

Jan 29, 2018

Changes in this version

+ func TopologyGremlinQuery(g *graph.Graph, query string) (traversal.GraphTraversalStep, error)

+ type AggregatesGremlinTraversalStep struct

+ func (a *AggregatesGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (a *AggregatesGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (a *AggregatesGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type BpfGremlinTraversalStep struct

+ func (s *BpfGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (s *BpfGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (s *BpfGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type CaptureNodeGremlinTraversalStep struct

+ func (s *CaptureNodeGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (s *CaptureNodeGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (s *CaptureNodeGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type FlowGremlinTraversalStep struct

+ Storage storage.Storage

+ TableClient *flow.TableClient

+ func (s *FlowGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (s *FlowGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (s *FlowGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type FlowTraversalExtension struct

+ AggregatesToken traversal.Token

+ BpfToken traversal.Token

+ CaptureNodeToken traversal.Token

+ FlowToken traversal.Token

+ HopsToken traversal.Token

+ NodesToken traversal.Token

+ RawPacketsToken traversal.Token

+ Storage storage.Storage

+ TableClient *flow.TableClient

+ func NewFlowTraversalExtension(client *flow.TableClient, storage storage.Storage) *FlowTraversalExtension

+ func (e *FlowTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *FlowTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

+ type FlowTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

+ Storage storage.Storage

+ func (f *FlowTraversalStep) Both(s ...interface{}) *traversal.GraphTraversalV

+ func (f *FlowTraversalStep) CaptureNode(s ...interface{}) *traversal.GraphTraversalV

+ func (f *FlowTraversalStep) Count(s ...interface{}) *traversal.GraphTraversalValue

+ func (f *FlowTraversalStep) Dedup(keys ...interface{}) *FlowTraversalStep

+ func (f *FlowTraversalStep) Error() error

+ func (f *FlowTraversalStep) FlowMetrics() *MetricsTraversalStep

+ func (f *FlowTraversalStep) Has(s ...interface{}) *FlowTraversalStep

+ func (f *FlowTraversalStep) Hops(s ...interface{}) *traversal.GraphTraversalV

+ func (f *FlowTraversalStep) In(s ...interface{}) *traversal.GraphTraversalV

+ func (f *FlowTraversalStep) MarshalJSON() ([]byte, error)

+ func (f *FlowTraversalStep) Nodes(s ...interface{}) *traversal.GraphTraversalV

+ func (f *FlowTraversalStep) Out(s ...interface{}) *traversal.GraphTraversalV

+ func (f *FlowTraversalStep) PropertyKeys(keys ...interface{}) *traversal.GraphTraversalValue

+ func (f *FlowTraversalStep) PropertyValues(keys ...interface{}) *traversal.GraphTraversalValue

+ func (f *FlowTraversalStep) RawPackets() *RawPacketsTraversalStep

+ func (f *FlowTraversalStep) Sort(keys ...interface{}) *FlowTraversalStep

+ func (f *FlowTraversalStep) Sum(keys ...interface{}) *traversal.GraphTraversalValue

+ func (f *FlowTraversalStep) Values() []interface{}

+ type HopsGremlinTraversalStep struct

+ func (s *HopsGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (s *HopsGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (s *HopsGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type MetricsGremlinTraversalStep struct

+ func (s *MetricsGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (s *MetricsGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (s *MetricsGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type MetricsTraversalExtension struct

+ MetricsToken traversal.Token

+ func NewMetricsTraversalExtension() *MetricsTraversalExtension

+ func (e *MetricsTraversalExtension) ParseStep(t traversal.Token, p traversal.GremlinTraversalContext) (traversal.GremlinTraversalStep, error)

+ func (e *MetricsTraversalExtension) ScanIdent(s string) (traversal.Token, bool)

+ type MetricsTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

+ func InterfaceMetrics(tv *traversal.GraphTraversalV) *MetricsTraversalStep

+ func NewMetricsTraversalStep(gt *traversal.GraphTraversal, metrics map[string][]common.Metric, err error) *MetricsTraversalStep

+ func (m *MetricsTraversalStep) Aggregates() *MetricsTraversalStep

+ func (m *MetricsTraversalStep) Count(s ...interface{}) *traversal.GraphTraversalValue

+ func (m *MetricsTraversalStep) Error() error

+ func (m *MetricsTraversalStep) MarshalJSON() ([]byte, error)

+ func (m *MetricsTraversalStep) Sum(keys ...interface{}) *traversal.GraphTraversalValue

+ func (m *MetricsTraversalStep) Values() []interface{}

+ type NodesGremlinTraversalStep struct

+ func (s *NodesGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (s *NodesGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (s *NodesGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type RawPacketsGremlinTraversalStep struct

+ func (r *RawPacketsGremlinTraversalStep) Context() *traversal.GremlinTraversalContext

+ func (r *RawPacketsGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)

+ func (r *RawPacketsGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep

+ type RawPacketsTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

+ func (r *RawPacketsTraversalStep) BPF(s ...interface{}) *RawPacketsTraversalStep

+ func (r *RawPacketsTraversalStep) Error() error

+ func (r *RawPacketsTraversalStep) MarshalJSON() ([]byte, error)

+ func (r *RawPacketsTraversalStep) Values() []interface{}