Documentation
¶
Index ¶
- func Convert(graph gdbi.GraphInterface, dataType gdbi.DataType, ...) *gripql.QueryResult
- func Resume(ctx context.Context, pipe gdbi.Pipeline, workdir string, input gdbi.InPipe, ...) <-chan *gripql.QueryResult
- func Run(ctx context.Context, pipe gdbi.Pipeline, workdir string) <-chan *gripql.QueryResult
- func Start(ctx context.Context, pipe gdbi.Pipeline, man gdbi.Manager, bufsize int, ...) gdbi.InPipe
- type State
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Convert ¶
func Convert(graph gdbi.GraphInterface, dataType gdbi.DataType, markTypes map[string]gdbi.DataType, t gdbi.Traveler) *gripql.QueryResult
Convert takes a traveler and converts it to query output
func Resume ¶
func Resume(ctx context.Context, pipe gdbi.Pipeline, workdir string, input gdbi.InPipe, cancel func()) <-chan *gripql.QueryResult
Run starts a pipeline and converts the output to server output structures
Types ¶
type State ¶
type State struct {
LastType gdbi.DataType
MarkTypes map[string]gdbi.DataType
Steps []string
StepOutputs map[string][]string
CurStep string
}
func NewPipelineState ¶
func NewPipelineState(stmts []*gripql.GraphStatement) *State
func (*State) GetLastType ¶
func (*State) SetCurStatment ¶
func (*State) SetLastType ¶
func (*State) StepLoadData ¶
Source Files
Click to show internal directories.
Click to hide internal directories.