traversal

package
v0.0.0-...-5b448de Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2017 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrExecutionError execution error
	ErrExecutionError = errors.New("Error while executing the query")
)

Functions

func ParamToFilter 

func ParamToFilter(k string, v interface{}) (*filters.Filter, error)

ParamToFilter creates a filter based on parameters [RegexMetadataMatcher, NE/LT/GT/GTE/LTE/Inside/Outside/Between/Within/Contains/string,int64 MetadataMatcher]

func ParamsToFilter 

func ParamsToFilter(params ...interface{}) (*filters.Filter, error)

ParamsToFilter convert multiple pairs to a unique filter, logically AND linked

func ParseSortParameter 

func ParseSortParameter(keys ...interface{}) (order common.SortOrder, sortBy string, err error)

ParseSortParameter helper

func SliceToMetadata 

func SliceToMetadata(s ...interface{}) (graph.Metadata, error)

SliceToMetadata slice multiple filters pair to metadata

Types

type BetweenMetadataMatcher 

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

BetweenMetadataMatcher describes a list of metadata that match between the range from, to

func Between 

func Between(from interface{}, to interface{}) *BetweenMetadataMatcher

Between step

type ContainsMetadataMatcher 

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

ContainsMetadataMatcher describes a list of metadata that contains a value

func Contains 

func Contains(s interface{}) *ContainsMetadataMatcher

Contains step

type GTEMetadataMatcher 

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

GTEMetadataMatcher describes a list of metadata that match Greater Than Equal

func Gte 

func Gte(s interface{}) *GTEMetadataMatcher

Gte step

type GTMetadataMatcher 

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

GTMetadataMatcher describes a list of metadata that match GreaterThan

func Gt 

func Gt(s interface{}) *GTMetadataMatcher

Gt step

type GraphStepContext 

type GraphStepContext struct {
	PaginationRange *GraphTraversalRange
}

GraphStepContext a step within a context

type GraphTraversal 

type GraphTraversal struct {
	Graph *graph.Graph
	// contains filtered or unexported fields
}

GraphTraversal describes multiple step within a graph

func NewGraphTraversal 

func NewGraphTraversal(g *graph.Graph, lockGraph bool) *GraphTraversal

NewGraphTraversal creates a new graph traversal

func (*GraphTraversal) Context 

func (t *GraphTraversal) Context(s ...interface{}) *GraphTraversal

Context step : at, [duration]

func (*GraphTraversal) E 

func (t *GraphTraversal) E(s ...interface{}) *GraphTraversalE

E step : [edge ID]

func (*GraphTraversal) Error 

func (t *GraphTraversal) Error() error

func (*GraphTraversal) MarshalJSON 

func (t *GraphTraversal) MarshalJSON() ([]byte, error)

MarshalJSON serialize in JSON

func (*GraphTraversal) RLock 

func (t *GraphTraversal) RLock()

RLock reads lock the graph

func (*GraphTraversal) RUnlock 

func (t *GraphTraversal) RUnlock()

RUnlock reads unlock the graph

func (*GraphTraversal) V 

func (t *GraphTraversal) V(s ...interface{}) *GraphTraversalV

V step : [node ID]

func (*GraphTraversal) Values 

func (t *GraphTraversal) Values() []interface{}

Values returns the graph values

type GraphTraversalE 

type GraphTraversalE struct {
	GraphTraversal *GraphTraversal
	// contains filtered or unexported fields
}

GraphTraversalE traversal steps on Edges

func NewGraphTraversalE 

func NewGraphTraversalE(gt *GraphTraversal, edges []*graph.Edge, err ...error) *GraphTraversalE

NewGraphTraversalE creates a new graph traversal Edges

func (*GraphTraversalE) Count 

func (te *GraphTraversalE) Count(s ...interface{}) *GraphTraversalValue

Count step

func (*GraphTraversalE) Dedup 

func (te *GraphTraversalE) Dedup(keys ...interface{}) *GraphTraversalE

Dedup step : deduplicate

func (*GraphTraversalE) Error 

func (te *GraphTraversalE) Error() error

func (*GraphTraversalE) Has 

func (te *GraphTraversalE) Has(s ...interface{}) *GraphTraversalE

Has step

func (*GraphTraversalE) HasKey 

func (te *GraphTraversalE) HasKey(s string) *GraphTraversalE

HasKey step

func (*GraphTraversalE) HasNot 

func (te *GraphTraversalE) HasNot(s string) *GraphTraversalE

HasNot step

func (*GraphTraversalE) InV 

func (te *GraphTraversalE) InV(s ...interface{}) *GraphTraversalV

InV step, node in

func (*GraphTraversalE) Limit 

func (te *GraphTraversalE) Limit(s ...interface{}) *GraphTraversalE

Limit step

func (*GraphTraversalE) MarshalJSON 

func (te *GraphTraversalE) MarshalJSON() ([]byte, error)

MarshalJSON serialize in JSON

func (*GraphTraversalE) OutV 

func (te *GraphTraversalE) OutV(s ...interface{}) *GraphTraversalV

OutV step, node out

func (*GraphTraversalE) Range 

func (te *GraphTraversalE) Range(s ...interface{}) *GraphTraversalE

Range step

func (*GraphTraversalE) Values 

func (te *GraphTraversalE) Values() []interface{}

Values returns the graph values

type GraphTraversalRange 

type GraphTraversalRange [2]int64

GraphTraversalRange is within a min and a max

func (*GraphTraversalRange) Iterator 

func (r *GraphTraversalRange) Iterator() *common.Iterator

Iterator on the range

type GraphTraversalShortestPath 

type GraphTraversalShortestPath struct {
	GraphTraversal *GraphTraversal
	// contains filtered or unexported fields
}

GraphTraversalShortestPath traversal step shortest path

func (*GraphTraversalShortestPath) Error 

func (sp *GraphTraversalShortestPath) Error() error

func (*GraphTraversalShortestPath) GetNodes 

func (sp *GraphTraversalShortestPath) GetNodes() []*graph.Node

GetNodes : returns all the nodes in single array, so it will used to find flows.

func (*GraphTraversalShortestPath) MarshalJSON 

func (sp *GraphTraversalShortestPath) MarshalJSON() ([]byte, error)

MarshalJSON serialize in JSON

func (*GraphTraversalShortestPath) Values 

func (sp *GraphTraversalShortestPath) Values() []interface{}

Values returns the graph values

type GraphTraversalStep 

type GraphTraversalStep interface {
	Values() []interface{}
	MarshalJSON() ([]byte, error)
	Error() error
}

GraphTraversalStep describes a step in the graph containing Values

type GraphTraversalV 

type GraphTraversalV struct {
	GraphTraversal *GraphTraversal
	// contains filtered or unexported fields
}

GraphTraversalV traversal steps on nodes

func NewGraphTraversalV 

func NewGraphTraversalV(gt *GraphTraversal, nodes []*graph.Node, err ...error) *GraphTraversalV

NewGraphTraversalV returns a new traversal step

func (*GraphTraversalV) Both 

func (tv *GraphTraversalV) Both(s ...interface{}) *GraphTraversalV

Both step

func (*GraphTraversalV) BothE 

func (tv *GraphTraversalV) BothE(s ...interface{}) *GraphTraversalE

BothE : both are edges

func (*GraphTraversalV) Count 

func (tv *GraphTraversalV) Count(s ...interface{}) *GraphTraversalValue

Count step

func (*GraphTraversalV) Dedup 

func (tv *GraphTraversalV) Dedup(s ...interface{}) *GraphTraversalV

Dedup step : deduplicate output

func (*GraphTraversalV) Error 

func (tv *GraphTraversalV) Error() error

func (*GraphTraversalV) GetNodes 

func (tv *GraphTraversalV) GetNodes() (nodes []*graph.Node)

GetNodes returns the step nodes

func (*GraphTraversalV) Has 

func (tv *GraphTraversalV) Has(s ...interface{}) *GraphTraversalV

Has step

func (*GraphTraversalV) HasKey 

func (tv *GraphTraversalV) HasKey(s string) *GraphTraversalV

HasKey step

func (*GraphTraversalV) HasNot 

func (tv *GraphTraversalV) HasNot(s string) *GraphTraversalV

HasNot step

func (*GraphTraversalV) In 

func (tv *GraphTraversalV) In(s ...interface{}) *GraphTraversalV

In node step

func (*GraphTraversalV) InE 

func (tv *GraphTraversalV) InE(s ...interface{}) *GraphTraversalE

InE step of an node

func (*GraphTraversalV) Limit 

func (tv *GraphTraversalV) Limit(s ...interface{}) *GraphTraversalV

Limit step

func (*GraphTraversalV) MarshalJSON 

func (tv *GraphTraversalV) MarshalJSON() ([]byte, error)

MarshalJSON serialize in JSON

func (*GraphTraversalV) Metrics 

func (tv *GraphTraversalV) Metrics() *MetricsTraversalStep

Metrics step : packets counters

func (*GraphTraversalV) Out 

func (tv *GraphTraversalV) Out(s ...interface{}) *GraphTraversalV

Out step : out of a node step

func (*GraphTraversalV) OutE 

func (tv *GraphTraversalV) OutE(s ...interface{}) *GraphTraversalE

OutE step : out of an edge

func (*GraphTraversalV) PropertyKeys 

func (tv *GraphTraversalV) PropertyKeys(keys ...interface{}) *GraphTraversalValue

PropertyKeys returns at this step, all the metadata keys of each metadata

func (*GraphTraversalV) PropertyValues 

func (tv *GraphTraversalV) PropertyValues(k ...interface{}) *GraphTraversalValue

PropertyValues returns at this step, the values of each metadata selected by the first key

func (*GraphTraversalV) Range 

func (tv *GraphTraversalV) Range(s ...interface{}) *GraphTraversalV

Range step

func (*GraphTraversalV) ShortestPathTo 

func (tv *GraphTraversalV) ShortestPathTo(m graph.Metadata, e graph.Metadata) *GraphTraversalShortestPath

ShortestPathTo step

func (*GraphTraversalV) Sort 

func (tv *GraphTraversalV) Sort(keys ...interface{}) *GraphTraversalV

Sort step

func (*GraphTraversalV) Sum 

func (tv *GraphTraversalV) Sum(keys ...interface{}) *GraphTraversalValue

Sum step : key returns the sum of the metadata values of the first argument key

func (*GraphTraversalV) Values 

func (tv *GraphTraversalV) Values() []interface{}

Values returns the graph values

type GraphTraversalValue 

type GraphTraversalValue struct {
	GraphTraversal *GraphTraversal
	// contains filtered or unexported fields
}

GraphTraversalValue traversal step value

func NewGraphTraversalValue 

func NewGraphTraversalValue(gt *GraphTraversal, value interface{}, err ...error) *GraphTraversalValue

NewGraphTraversalValue creates a new traversal value step

func (*GraphTraversalValue) Dedup 

func (t *GraphTraversalValue) Dedup(keys ...interface{}) *GraphTraversalValue

Dedup step : deduplicate

func (*GraphTraversalValue) Error 

func (t *GraphTraversalValue) Error() error

func (*GraphTraversalValue) MarshalJSON 

func (t *GraphTraversalValue) MarshalJSON() ([]byte, error)

MarshalJSON serialize in JSON

func (*GraphTraversalValue) Values 

func (t *GraphTraversalValue) Values() []interface{}

Values return the graph values

type GremlinTraversalContext 

type GremlinTraversalContext struct {
	StepContext GraphStepContext
	Params      []interface{}
}

GremlinTraversalContext describes the context of a step

func (*GremlinTraversalContext) Context 

func (p *GremlinTraversalContext) Context() *GremlinTraversalContext

Context step

func (*GremlinTraversalContext) ReduceRange 

func (p *GremlinTraversalContext) ReduceRange(next GremlinTraversalStep) bool

ReduceRange Context step

type GremlinTraversalExtension 

type GremlinTraversalExtension interface {
	ScanIdent(s string) (Token, bool)
	ParseStep(t Token, p GremlinTraversalContext) (GremlinTraversalStep, error)
}

GremlinTraversalExtension interface for Gremlin language extension

type GremlinTraversalParser 

type GremlinTraversalParser struct {
	sync.RWMutex
	Graph *graph.Graph
	// contains filtered or unexported fields
}

GremlinTraversalParser describes a parser of gremlin graph expression The mechanism is based on Reduce and Exec steps

func NewGremlinTraversalParser 

func NewGremlinTraversalParser(g *graph.Graph) *GremlinTraversalParser

NewGremlinTraversalParser creates a new gremlin language parser on the graph

func (*GremlinTraversalParser) AddTraversalExtension 

func (p *GremlinTraversalParser) AddTraversalExtension(e GremlinTraversalExtension)

AddTraversalExtension registers a new gremlin traversal extension

func (*GremlinTraversalParser) Parse 

func (p *GremlinTraversalParser) Parse(r io.Reader, lockGraph bool) (*GremlinTraversalSequence, error)

Parse the Gremlin language and returns a traversal sequence

type GremlinTraversalScanner 

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

GremlinTraversalScanner describes a buffer scanner for Gremlin expression extension

func NewGremlinTraversalScanner 

func NewGremlinTraversalScanner(r io.Reader, e []GremlinTraversalExtension) *GremlinTraversalScanner

NewGremlinTraversalScanner creates a new Gremlin expression scanner

func (*GremlinTraversalScanner) Scan 

func (s *GremlinTraversalScanner) Scan() (tok Token, lit string)

Scan and returns tokens

type GremlinTraversalSequence 

type GremlinTraversalSequence struct {
	GraphTraversal *GraphTraversal
	// contains filtered or unexported fields
}

GremlinTraversalSequence describes a sequence of steps

func (*GremlinTraversalSequence) Exec 

func (s *GremlinTraversalSequence) Exec() (GraphTraversalStep, error)

Exec sequence step

type GremlinTraversalStep 

type GremlinTraversalStep interface {
	Exec(last GraphTraversalStep) (GraphTraversalStep, error)
	Reduce(previous GremlinTraversalStep) GremlinTraversalStep
	Context() *GremlinTraversalContext
}

GremlinTraversalStep describes a step

type GremlinTraversalStepBoth 

type GremlinTraversalStepBoth struct {
	GremlinTraversalContext
}

GremlinTraversalStepBoth step

func (*GremlinTraversalStepBoth) Exec 

func (s *GremlinTraversalStepBoth) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Both step

func (*GremlinTraversalStepBoth) Reduce 

func (s *GremlinTraversalStepBoth) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Both step

type GremlinTraversalStepBothE 

type GremlinTraversalStepBothE struct {
	GremlinTraversalContext
}

GremlinTraversalStepBothE step

func (*GremlinTraversalStepBothE) Exec 

func (s *GremlinTraversalStepBothE) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec BothE step

func (*GremlinTraversalStepBothE) Reduce 

func (s *GremlinTraversalStepBothE) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce BothE step

type GremlinTraversalStepContext 

type GremlinTraversalStepContext struct {
	GremlinTraversalContext
}

GremlinTraversalStepContext step

func (*GremlinTraversalStepContext) Exec 

func (s *GremlinTraversalStepContext) Exec(last GraphTraversalStep) (_ GraphTraversalStep, err error)

Exec Context step

func (*GremlinTraversalStepContext) Reduce 

func (s *GremlinTraversalStepContext) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Context step

type GremlinTraversalStepCount 

type GremlinTraversalStepCount struct {
	GremlinTraversalContext
}

GremlinTraversalStepCount step

func (*GremlinTraversalStepCount) Exec 

func (s *GremlinTraversalStepCount) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Count step

func (*GremlinTraversalStepCount) Reduce 

func (s *GremlinTraversalStepCount) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Count step

type GremlinTraversalStepDedup 

type GremlinTraversalStepDedup struct {
	GremlinTraversalContext
}

GremlinTraversalStepDedup step

func (*GremlinTraversalStepDedup) Exec 

func (s *GremlinTraversalStepDedup) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Dedup step

func (*GremlinTraversalStepDedup) Reduce 

func (s *GremlinTraversalStepDedup) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Dedup step

type GremlinTraversalStepE 

type GremlinTraversalStepE struct {
	GremlinTraversalContext
}

GremlinTraversalStepE step

func (*GremlinTraversalStepE) Exec 

func (s *GremlinTraversalStepE) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec E step

func (*GremlinTraversalStepE) Reduce 

func (s *GremlinTraversalStepE) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce E step

type GremlinTraversalStepG 

type GremlinTraversalStepG struct {
	GremlinTraversalContext
}

GremlinTraversalStepG step

func (*GremlinTraversalStepG) Exec 

func (s *GremlinTraversalStepG) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec G step

func (*GremlinTraversalStepG) Reduce 

func (s *GremlinTraversalStepG) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce G step

type GremlinTraversalStepHas 

type GremlinTraversalStepHas struct {
	GremlinTraversalContext
}

GremlinTraversalStepHas step

func (*GremlinTraversalStepHas) Exec 

func (s *GremlinTraversalStepHas) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Has step

func (*GremlinTraversalStepHas) Reduce 

func (s *GremlinTraversalStepHas) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Has step

type GremlinTraversalStepHasKey 

type GremlinTraversalStepHasKey struct {
	GremlinTraversalContext
}

GremlinTraversalStepHasKey step

func (*GremlinTraversalStepHasKey) Exec 

func (s *GremlinTraversalStepHasKey) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec HasKey step

func (*GremlinTraversalStepHasKey) Reduce 

func (s *GremlinTraversalStepHasKey) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce HasKey step

type GremlinTraversalStepHasNot 

type GremlinTraversalStepHasNot struct {
	GremlinTraversalContext
}

GremlinTraversalStepHasNot step

func (*GremlinTraversalStepHasNot) Exec 

func (s *GremlinTraversalStepHasNot) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec HasNot

func (*GremlinTraversalStepHasNot) Reduce 

func (s *GremlinTraversalStepHasNot) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce HasNot step

type GremlinTraversalStepIn 

type GremlinTraversalStepIn struct {
	GremlinTraversalContext
}

GremlinTraversalStepIn step

func (*GremlinTraversalStepIn) Exec 

func (s *GremlinTraversalStepIn) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec In step

func (*GremlinTraversalStepIn) Reduce 

func (s *GremlinTraversalStepIn) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce In step

type GremlinTraversalStepInE 

type GremlinTraversalStepInE struct {
	GremlinTraversalContext
}

GremlinTraversalStepInE step

func (*GremlinTraversalStepInE) Exec 

func (s *GremlinTraversalStepInE) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec InE step

func (*GremlinTraversalStepInE) Reduce 

func (s *GremlinTraversalStepInE) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce InE step

type GremlinTraversalStepInV 

type GremlinTraversalStepInV struct {
	GremlinTraversalContext
}

GremlinTraversalStepInV step

func (*GremlinTraversalStepInV) Exec 

func (s *GremlinTraversalStepInV) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec InV step

func (*GremlinTraversalStepInV) Reduce 

func (s *GremlinTraversalStepInV) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce InV step

type GremlinTraversalStepKeys 

type GremlinTraversalStepKeys struct {
	GremlinTraversalContext
}

GremlinTraversalStepKeys step

func (*GremlinTraversalStepKeys) Exec 

func (s *GremlinTraversalStepKeys) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Keys step

func (*GremlinTraversalStepKeys) Reduce 

func (s *GremlinTraversalStepKeys) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Keys step

type GremlinTraversalStepLimit 

type GremlinTraversalStepLimit struct {
	GremlinTraversalContext
}

GremlinTraversalStepLimit step

func (*GremlinTraversalStepLimit) Exec 

func (s *GremlinTraversalStepLimit) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Limit step

func (*GremlinTraversalStepLimit) Reduce 

func (s *GremlinTraversalStepLimit) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Limit step

type GremlinTraversalStepMetrics 

type GremlinTraversalStepMetrics struct {
	GremlinTraversalContext
}

GremlinTraversalStepMetrics step

func (*GremlinTraversalStepMetrics) Exec 

func (s *GremlinTraversalStepMetrics) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Metrics step

func (*GremlinTraversalStepMetrics) Reduce 

func (s *GremlinTraversalStepMetrics) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Metrics step

type GremlinTraversalStepOut 

type GremlinTraversalStepOut struct {
	GremlinTraversalContext
}

GremlinTraversalStepOut step

func (*GremlinTraversalStepOut) Exec 

func (s *GremlinTraversalStepOut) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Out step

func (*GremlinTraversalStepOut) Reduce 

func (s *GremlinTraversalStepOut) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Out step

type GremlinTraversalStepOutE 

type GremlinTraversalStepOutE struct {
	GremlinTraversalContext
}

GremlinTraversalStepOutE step

func (*GremlinTraversalStepOutE) Exec 

func (s *GremlinTraversalStepOutE) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec OutE step

func (*GremlinTraversalStepOutE) Reduce 

func (s *GremlinTraversalStepOutE) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce OutE step

type GremlinTraversalStepOutV 

type GremlinTraversalStepOutV struct {
	GremlinTraversalContext
}

GremlinTraversalStepOutV step

func (*GremlinTraversalStepOutV) Exec 

func (s *GremlinTraversalStepOutV) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec OutV step

func (*GremlinTraversalStepOutV) Reduce 

func (s *GremlinTraversalStepOutV) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce OutV step

type GremlinTraversalStepRange 

type GremlinTraversalStepRange struct {
	GremlinTraversalContext
}

GremlinTraversalStepRange step

func (*GremlinTraversalStepRange) Exec 

func (s *GremlinTraversalStepRange) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Range step

func (*GremlinTraversalStepRange) Reduce 

func (s *GremlinTraversalStepRange) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Range step

type GremlinTraversalStepShortestPathTo 

type GremlinTraversalStepShortestPathTo struct {
	GremlinTraversalContext
}

GremlinTraversalStepShortestPathTo step

func (*GremlinTraversalStepShortestPathTo) Exec 

func (s *GremlinTraversalStepShortestPathTo) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec ShortestPathTo step

func (*GremlinTraversalStepShortestPathTo) Reduce 

func (s *GremlinTraversalStepShortestPathTo) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce ShortestPathTo step

type GremlinTraversalStepSort 

type GremlinTraversalStepSort struct {
	GremlinTraversalContext
}

GremlinTraversalStepSort step

func (*GremlinTraversalStepSort) Exec 

func (s *GremlinTraversalStepSort) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Sort step

func (*GremlinTraversalStepSort) Reduce 

func (s *GremlinTraversalStepSort) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Sort step

type GremlinTraversalStepSum 

type GremlinTraversalStepSum struct {
	GremlinTraversalContext
}

GremlinTraversalStepSum step

func (*GremlinTraversalStepSum) Exec 

func (s *GremlinTraversalStepSum) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Sum step

func (*GremlinTraversalStepSum) Reduce 

func (s *GremlinTraversalStepSum) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Sum step

type GremlinTraversalStepV 

type GremlinTraversalStepV struct {
	GremlinTraversalContext
}

GremlinTraversalStepV step

func (*GremlinTraversalStepV) Exec 

func (s *GremlinTraversalStepV) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec V step

func (*GremlinTraversalStepV) Reduce 

func (s *GremlinTraversalStepV) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce V step

type GremlinTraversalStepValues 

type GremlinTraversalStepValues struct {
	GremlinTraversalContext
}

GremlinTraversalStepValues step

func (*GremlinTraversalStepValues) Exec 

func (s *GremlinTraversalStepValues) Exec(last GraphTraversalStep) (GraphTraversalStep, error)

Exec Values step

func (*GremlinTraversalStepValues) Reduce 

func (s *GremlinTraversalStepValues) Reduce(next GremlinTraversalStep) GremlinTraversalStep

Reduce Values step

type InsideMetadataMatcher 

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

InsideMetadataMatcher describes a list of metadata that match inside the range from, to

func Inside 

func Inside(from, to interface{}) *InsideMetadataMatcher

Inside step

type LTEMetadataMatcher 

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

LTEMetadataMatcher describes a list of metadata that match Less Than Equal

func Lte 

func Lte(s interface{}) *LTEMetadataMatcher

Lte step

type LTMetadataMatcher 

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

LTMetadataMatcher describes a list of metadata that match LessThan

func Lt 

func Lt(s interface{}) *LTMetadataMatcher

Lt step

type MetricsTraversalStep 

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

MetricsTraversalStep traversal step metric interface counters

func NewMetricsTraversalStep 

func NewMetricsTraversalStep(gt *GraphTraversal, metrics map[string][]*common.TimedMetric, err error) *MetricsTraversalStep

NewMetricsTraversalStep creates a new tranversal metric step

func (*MetricsTraversalStep) Aggregates 

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 

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

Count step

func (*MetricsTraversalStep) Error 

func (m *MetricsTraversalStep) Error() error

func (*MetricsTraversalStep) MarshalJSON 

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

MarshalJSON serialize in JSON

func (*MetricsTraversalStep) Sum 

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

Sum aggregates integer values mapped by 'key' cross flows

func (*MetricsTraversalStep) Values 

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

Values returns the graph metric values

type NEMetadataMatcher 

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

NEMetadataMatcher describes a list of metadata that match NotEqual

func Ne 

func Ne(s interface{}) *NEMetadataMatcher

Ne step

type OutsideMetadataMatcher 

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

OutsideMetadataMatcher describes a list of metadata that match outside the range from, to

func Outside 

func Outside(from, to interface{}) *OutsideMetadataMatcher

Outside step

type RegexMetadataMatcher 

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

RegexMetadataMatcher describes a list of metadata that match a regex

func Regex 

func Regex(expr string) *RegexMetadataMatcher

Regex step

type Since 

type Since struct {
	Seconds int64
}

Since describes a list of metadata that match since seconds

type Token 

type Token int

Token represents a lexical token. 

const (
	// Special tokens
	ILLEGAL Token = iota
	EOF
	WS

	// Literals
	IDENT

	// Misc characters
	COMMA
	DOT
	LEFT_PARENTHESIS
	RIGHT_PARENTHESIS
	STRING
	NUMBER

	// Keywords
	G
	V
	E
	HAS
	HASKEY
	HASNOT
	OUT
	IN
	OUTV
	INV
	OUTE
	INE
	BOTHE
	DEDUP
	WITHIN
	WITHOUT
	METADATA
	SHORTESTPATHTO
	NE
	BOTH
	CONTEXT
	REGEX
	LT
	GT
	LTE
	GTE
	INSIDE
	OUTSIDE
	BETWEEN
	COUNT
	RANGE
	LIMIT
	SORT
	VALUES
	KEYS
	SUM
	METRICS
	ASC
	DESC
	CONTAINS
)

Default language token, extension token start at 1000

type WithinMetadataMatcher 

type WithinMetadataMatcher struct {
	List []interface{}
}

WithinMetadataMatcher describes a list of metadata that should match (within)

func Within 

func Within(s ...interface{}) *WithinMetadataMatcher

Within step

type WithoutMetadataMatcher 

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

WithoutMetadataMatcher describes a list of metadata that shouldn't match (without)

func Without 

func Without(s ...interface{}) *WithoutMetadataMatcher

Without step

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.