Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.