traversal

package

v0.6.0 Latest Latest Go to latest Published: Oct 6, 2016 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/nlewo/skydive

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type BandwidthGremlinTraversalStep
type BandwidthTraversalStep
type FlowGremlinTraversalStep
type FlowTraversalExtension
- 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
type HopsGremlinTraversalStep

Constants ¶

View Source

const (
	FLOW_TOKEN      traversal.Token = 1001
	BANDWIDTH_TOKEN traversal.Token = 1002
	HOPS_TOKEN      traversal.Token = 1003
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BandwidthGremlinTraversalStep ¶ added in v0.5.0

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

func (*BandwidthGremlinTraversalStep) Context ¶ added in v0.6.0

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

func (*BandwidthGremlinTraversalStep) Exec ¶ added in v0.5.0

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

func (*BandwidthGremlinTraversalStep) Reduce ¶ added in v0.5.0

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

type BandwidthTraversalStep ¶ added in v0.5.0

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

func (*BandwidthTraversalStep) Error ¶ added in v0.5.0

func (b *BandwidthTraversalStep) Error() error

func (*BandwidthTraversalStep) MarshalJSON ¶ added in v0.5.0

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

func (*BandwidthTraversalStep) Values ¶ added in v0.5.0

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

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
	BandwidthToken traversal.Token
	HopsToken      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
	// contains filtered or unexported fields
}

func (*FlowTraversalStep) Both ¶ added in v0.5.0

func (f *FlowTraversalStep) Both(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() *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) In ¶

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

func (*FlowTraversalStep) MarshalJSON ¶

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

func (*FlowTraversalStep) Out ¶

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

func (*FlowTraversalStep) Values ¶

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

type HopsGremlinTraversalStep ¶ added in v0.6.0

type HopsGremlinTraversalStep struct {
	TableClient *flow.TableClient
	Storage     storage.Storage
	// 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

Source Files ¶

View all Source files

traversal.go

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