traversal

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 27, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	FLOW_TOKEN         traversal.Token = 1001
	METRICS_TOKEN      traversal.Token = 1002
	HOPS_TOKEN         traversal.Token = 1003
	NODES_TOKEN        traversal.Token = 1004
	CAPTURE_NODE_TOKEN traversal.Token = 1005
	AGGREGATES_TOKEN   traversal.Token = 1006
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AggregatesGremlinTraversalStep added in v0.9.0 

type AggregatesGremlinTraversalStep struct {
	// contains filtered or unexported fields
}

func (*AggregatesGremlinTraversalStep) Context added in v0.9.0 

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

func (*AggregatesGremlinTraversalStep) Exec added in v0.9.0 

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

func (*AggregatesGremlinTraversalStep) Reduce added in v0.9.0 

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

type CaptureNodeGremlinTraversalStep added in v0.8.0 

type CaptureNodeGremlinTraversalStep struct {
	// contains filtered or unexported fields
}

func (*CaptureNodeGremlinTraversalStep) Context added in v0.8.0 

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

func (*CaptureNodeGremlinTraversalStep) Exec added in v0.8.0 

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

func (*CaptureNodeGremlinTraversalStep) Reduce added in v0.8.0 

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

type FlowGremlinTraversalStep 

type FlowGremlinTraversalStep struct {
	TableClient *flow.TableClient
	Storage     storage.Storage
	// contains filtered or unexported fields
}

func (*FlowGremlinTraversalStep) Context added in v0.6.0 

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

func (*FlowGremlinTraversalStep) Exec 

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

func (*FlowGremlinTraversalStep) Reduce added in v0.5.0 

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

type FlowTraversalExtension 

type FlowTraversalExtension struct {
	FlowToken        traversal.Token
	MetricsToken     traversal.Token
	BandwidthToken   traversal.Token
	HopsToken        traversal.Token
	NodesToken       traversal.Token
	CaptureNodeToken traversal.Token
	AggregatesToken  traversal.Token
	TableClient      *flow.TableClient
	Storage          storage.Storage
}

func NewFlowTraversalExtension 

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

func (*FlowTraversalExtension) ParseStep 

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

func (*FlowTraversalExtension) ScanIdent 

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

type FlowTraversalStep 

type FlowTraversalStep struct {
	GraphTraversal *traversal.GraphTraversal
	Storage        storage.Storage
	// contains filtered or unexported fields
}

func (*FlowTraversalStep) Both added in v0.5.0 

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

func (*FlowTraversalStep) CaptureNode added in v0.8.0 

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

func (*FlowTraversalStep) Count added in v0.5.0 

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

func (*FlowTraversalStep) Dedup added in v0.5.0 

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

func (*FlowTraversalStep) Error 

func (f *FlowTraversalStep) Error() error

func (*FlowTraversalStep) Has added in v0.5.0 

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

func (*FlowTraversalStep) Hops added in v0.8.0 

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

func (*FlowTraversalStep) In 

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

func (*FlowTraversalStep) MarshalJSON 

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

func (*FlowTraversalStep) Metrics added in v0.9.0 

func (f *FlowTraversalStep) Metrics() *MetricsTraversalStep

func (*FlowTraversalStep) Nodes added in v0.7.0 

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

func (*FlowTraversalStep) Out 

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

func (*FlowTraversalStep) PropertyKeys added in v0.8.0 

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

func (*FlowTraversalStep) PropertyValues added in v0.8.0 

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

func (*FlowTraversalStep) Sort added in v0.7.0 

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

func (*FlowTraversalStep) Sum added in v0.8.0 

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

Sum aggregates integer values mapped by 'key' cross flows

func (*FlowTraversalStep) Values 

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

type HopsGremlinTraversalStep added in v0.6.0 

type HopsGremlinTraversalStep struct {
	// contains filtered or unexported fields
}

func (*HopsGremlinTraversalStep) Context added in v0.6.0 

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

func (*HopsGremlinTraversalStep) Exec added in v0.6.0 

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

func (*HopsGremlinTraversalStep) Reduce added in v0.6.0 

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

type MetricsGremlinTraversalStep added in v0.8.0 

type MetricsGremlinTraversalStep struct {
	TableClient *flow.TableClient
	Storage     storage.Storage
	// contains filtered or unexported fields
}

func (*MetricsGremlinTraversalStep) Context added in v0.8.0 

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

func (*MetricsGremlinTraversalStep) Exec added in v0.8.0 

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

func (*MetricsGremlinTraversalStep) Reduce added in v0.8.0 

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

type MetricsTraversalStep added in v0.8.0 

type MetricsTraversalStep struct {
	GraphTraversal *traversal.GraphTraversal
	// contains filtered or unexported fields
}

func (*MetricsTraversalStep) Aggregates added in v0.9.0 

func (m *MetricsTraversalStep) Aggregates() *MetricsTraversalStep

Aggregates merges multiple metrics array into one by summing overlapping metrics. It returns a unique array will all the aggregated metrics.

func (*MetricsTraversalStep) Count added in v0.8.0 

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

func (*MetricsTraversalStep) Error added in v0.8.0 

func (b *MetricsTraversalStep) Error() error

func (*MetricsTraversalStep) MarshalJSON added in v0.8.0 

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

func (*MetricsTraversalStep) Sum added in v0.9.0 

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

Sum aggregates integer values mapped by 'key' cross flows

func (*MetricsTraversalStep) Values added in v0.8.0 

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

type NodesGremlinTraversalStep added in v0.7.0 

type NodesGremlinTraversalStep struct {
	// contains filtered or unexported fields
}

func (*NodesGremlinTraversalStep) Context added in v0.7.0 

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

func (*NodesGremlinTraversalStep) Exec added in v0.7.0 

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

func (*NodesGremlinTraversalStep) Reduce added in v0.7.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.