traversal

package

v0.5.0 Latest Latest Go to latest Published: Sep 15, 2016 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitproxy.zycloud.tk/skydive-project/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.GremlinTraversalStepParams) (traversal.GremlinTraversalStep, error)
- func (e *FlowTraversalExtension) ScanIdent(s string) (traversal.Token, bool)
type FlowTraversalStep

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BandwidthGremlinTraversalStep ¶

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

func (*BandwidthGremlinTraversalStep) Exec ¶

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

func (*BandwidthGremlinTraversalStep) Params ¶

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

func (*BandwidthGremlinTraversalStep) Reduce ¶

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

type BandwidthTraversalStep ¶

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

func (*BandwidthTraversalStep) Error ¶

func (b *BandwidthTraversalStep) Error() error

func (*BandwidthTraversalStep) MarshalJSON ¶

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

func (*BandwidthTraversalStep) Values ¶

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

type FlowGremlinTraversalStep ¶

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

func (*FlowGremlinTraversalStep) Exec ¶

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

func (*FlowGremlinTraversalStep) Params ¶

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

func (*FlowGremlinTraversalStep) Reduce ¶

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

type FlowTraversalExtension ¶

type FlowTraversalExtension struct {
	FlowToken      traversal.Token
	BandwidthToken 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.GremlinTraversalStepParams) (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 ¶

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

func (*FlowTraversalStep) Count ¶

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

func (*FlowTraversalStep) Dedup ¶

func (f *FlowTraversalStep) Dedup() *FlowTraversalStep

func (*FlowTraversalStep) Error ¶

func (f *FlowTraversalStep) Error() error

func (*FlowTraversalStep) Has ¶

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{}

Source Files ¶

traversal.go

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