core

Documentation

Index

• func BuildPipeline(pc starriver.PipelineConf, status starriver.PipelineStatus, ...) (_ starriver.Pipeline, err error)
• func NewDataContext(ctx context.Context, pipeline starriver.Pipeline, ...) starriver.DataContext
• type ContextOption
  • func SetLogLevel(level starriver.LogLevel) ContextOption
  • func SetLogger(logger starriver.Logger) ContextOption
  • func SetRequestID(requestID string) ContextOption
  • func SetSharedDataStore(sharedDataStore starriver.SharedDataStore) ContextOption
• type GraphWalker
  • func (walker *GraphWalker) Walk(graph dag.DAG, dataContext starriver.DataContext) error

Functions

func BuildPipeline

func BuildPipeline(pc starriver.PipelineConf, status starriver.PipelineStatus, taskStatuses map[string]starriver.TaskStatus) (_ starriver.Pipeline, err error)

func NewDataContext

func NewDataContext(ctx context.Context, pipeline starriver.Pipeline, initialData map[string]interface{},
	opts ...ContextOption) starriver.DataContext

Types

type ContextOption

type ContextOption func(*dataContext)

func SetLogLevel

func SetLogLevel(level starriver.LogLevel) ContextOption

func SetLogger

func SetLogger(logger starriver.Logger) ContextOption

func SetRequestID

func SetRequestID(requestID string) ContextOption

func SetSharedDataStore

func SetSharedDataStore(sharedDataStore starriver.SharedDataStore) ContextOption

type GraphWalker

type GraphWalker struct {
	ParallelSem util.Semaphore

	Pipeline starriver.Pipeline
	// contains filtered or unexported fields
}

func (*GraphWalker) Walk

func (walker *GraphWalker) Walk(graph dag.DAG, dataContext starriver.DataContext) error