traversal

Oct 12, 2017

Changes in this version

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

+ BpfToken traversal.Token

type RawPacketsTraversalStep

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

Aug 1, 2017

Changes in this version

type FlowTraversalExtension

+ RawPacketsToken traversal.Token

type FlowTraversalStep

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

+ 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) Error() error

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

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

Jan 27, 2017

Changes in this version

+ const AGGREGATES_TOKEN

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

+ AggregatesToken traversal.Token

type FlowTraversalStep

+ Storage storage.Storage

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

type MetricsTraversalStep

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

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

Dec 9, 2016

Changes in this version

+ const CAPTURE_NODE_TOKEN

+ const METRICS_TOKEN

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

+ CaptureNodeToken traversal.Token

+ MetricsToken traversal.Token

type FlowTraversalStep

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

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

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

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

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

+ type MetricsGremlinTraversalStep struct

+ Storage storage.Storage

+ TableClient *flow.TableClient

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

+ GraphTraversal *traversal.GraphTraversal

+ func (b *MetricsTraversalStep) Error() error

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

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

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

Nov 8, 2016

Changes in this version

+ const NODES_TOKEN

type FlowTraversalExtension

+ NodesToken traversal.Token

type FlowTraversalStep

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

+ func (f *FlowTraversalStep) Sort() *FlowTraversalStep

+ type NodesGremlinTraversalStep struct

+ Storage storage.Storage

+ TableClient *flow.TableClient

+ 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

Oct 6, 2016

Changes in this version

+ const HOPS_TOKEN

type BandwidthGremlinTraversalStep

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

type FlowGremlinTraversalStep

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

type FlowTraversalExtension

+ HopsToken traversal.Token

+ type HopsGremlinTraversalStep struct

+ Storage storage.Storage

+ TableClient *flow.TableClient

+ 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

Sep 15, 2016

Changes in this version

+ const BANDWIDTH_TOKEN

+ const FLOW_TOKEN

+ type BandwidthGremlinTraversalStep struct

+ Storage storage.Storage

+ TableClient *flow.TableClient

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

+ func (s *BandwidthGremlinTraversalStep) Params() (params []interface{})

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

+ type BandwidthTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

+ func (b *BandwidthTraversalStep) Error() error

+ func (b *BandwidthTraversalStep) MarshalJSON() ([]byte, error)

+ func (b *BandwidthTraversalStep) Values() []interface{}

type FlowGremlinTraversalStep

+ func (s *FlowGremlinTraversalStep) Params() (params []interface{})

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

type FlowTraversalExtension

+ BandwidthToken traversal.Token

type FlowTraversalStep

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

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

+ func (f *FlowTraversalStep) Dedup() *FlowTraversalStep

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

Aug 4, 2016

Changes in this version

+ type FlowGremlinTraversalStep struct

+ Storage storage.Storage

+ TableClient *flow.TableClient

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

+ type FlowTraversalExtension struct

+ FlowToken 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.GremlinTraversalStepParams) (traversal.GremlinTraversalStep, error)

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

+ type FlowTraversalStep struct

+ GraphTraversal *traversal.GraphTraversal

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

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

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

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

+ func (p *FlowTraversalStep) Error() error