traversal

Documentation

Index

• Constants
• type BandwidthGremlinTraversalStep
  • 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
  • func (b *BandwidthTraversalStep) Error() error
  • func (b *BandwidthTraversalStep) MarshalJSON() ([]byte, error)
  • func (b *BandwidthTraversalStep) Values() []interface{}
• type FlowGremlinTraversalStep
  • func (s *FlowGremlinTraversalStep) Exec(last traversal.GraphTraversalStep) (traversal.GraphTraversalStep, error)
  • func (s *FlowGremlinTraversalStep) Params() (params []interface{})
  • func (s *FlowGremlinTraversalStep) Reduce(next traversal.GremlinTraversalStep) traversal.GremlinTraversalStep
• 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
  • func (f *FlowTraversalStep) Both(s ...interface{}) *traversal.GraphTraversalV
  • func (f *FlowTraversalStep) Count(s ...interface{}) *traversal.GraphTraversalValue
  • func (f *FlowTraversalStep) Dedup() *FlowTraversalStep
  • func (f *FlowTraversalStep) Error() error
  • func (f *FlowTraversalStep) Has(s ...interface{}) *FlowTraversalStep
  • 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{}

Constants

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

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