pipeline

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
  • func NewPipelineState(stmts []*gripql.GraphStatement) *State
  • func (ps *State) GetLastType() gdbi.DataType
  • func (ps *State) SetCurStatment(a int)
  • func (ps *State) SetLastType(a gdbi.DataType)
  • func (ps *State) StepLoadData() bool

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

func Run

func Run(ctx context.Context, pipe gdbi.Pipeline, workdir string) <-chan *gripql.QueryResult

Run starts a pipeline and converts the output to server output structures

func Start

func Start(ctx context.Context, pipe gdbi.Pipeline, man gdbi.Manager, bufsize int, input gdbi.InPipe, cancel func()) gdbi.InPipe

Start begins processing a query pipeline

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 (ps *State) GetLastType() gdbi.DataType

func (*State) SetCurStatment

func (ps *State) SetCurStatment(a int)

func (*State) SetLastType

func (ps *State) SetLastType(a gdbi.DataType)

func (*State) StepLoadData

func (ps *State) StepLoadData() bool