Documentation ¶
Index ¶
- func ContextProviders() []string
- func Handlers() []string
- func RegisterContextProvider(name string, newContextProviderFunc NewContextProviderFunc)
- func RegisterHandler(name string, newHandlerFunc NewHandlerFunc)
- func RegisterRunner(name string, newRunnerFunc NewRunnerFunc)
- func Runners() []string
- type Context
- type ContextProvider
- type ErrorHandler
- type Flow
- type FlowOption
- type Handler
- type LocalContext
- func (p *LocalContext) Delete(key string) Context
- func (p *LocalContext) Flush()
- func (p *LocalContext) Get(key string) (value interface{}, exist bool)
- func (p LocalContext) GetAll() map[string]interface{}
- func (p *LocalContext) ID() string
- func (p LocalContext) Keys() []string
- func (p *LocalContext) Set(key string, value interface{}) Context
- type LocalContextProvider
- type NewContextProviderFunc
- type NewHandlerFunc
- type NewRunnerFunc
- type PipeTaskRunner
- type Step
- type Task
- type TaskRunner
- type TaskStatus
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ContextProviders ¶
func ContextProviders() []string
func RegisterContextProvider ¶
func RegisterContextProvider(name string, newContextProviderFunc NewContextProviderFunc)
func RegisterHandler ¶
func RegisterHandler(name string, newHandlerFunc NewHandlerFunc)
func RegisterRunner ¶
func RegisterRunner(name string, newRunnerFunc NewRunnerFunc)
Types ¶
type ContextProvider ¶
type ContextProvider interface {
NewContext(conf config.Configuration) Context
}
func NewContextProvider ¶
func NewContextProvider(name string, conf config.Configuration) (contextProvider ContextProvider, err error)
func NewLocalContextProvider ¶
func NewLocalContextProvider(conf config.Configuration) (provider ContextProvider, err error)
type FlowOption ¶
func Config ¶
func Config(conf config.Configuration) FlowOption
func ConfigFile ¶
func ConfigFile(filename string) FlowOption
func ConfigString ¶
func ConfigString(str string) FlowOption
type Handler ¶
func NewHandler ¶
func NewHandler(name string, conf config.Configuration) (handler Handler, err error)
type LocalContext ¶
type LocalContext struct {
// contains filtered or unexported fields
}
func (*LocalContext) Delete ¶
func (p *LocalContext) Delete(key string) Context
func (*LocalContext) Flush ¶
func (p *LocalContext) Flush()
func (*LocalContext) Get ¶
func (p *LocalContext) Get(key string) (value interface{}, exist bool)
func (LocalContext) GetAll ¶
func (p LocalContext) GetAll() map[string]interface{}
func (*LocalContext) ID ¶
func (p *LocalContext) ID() string
func (LocalContext) Keys ¶
func (p LocalContext) Keys() []string
func (*LocalContext) Set ¶
func (p *LocalContext) Set(key string, value interface{}) Context
type LocalContextProvider ¶
type LocalContextProvider struct { }
func (*LocalContextProvider) NewContext ¶
func (p *LocalContextProvider) NewContext(conf config.Configuration) Context
type NewContextProviderFunc ¶
type NewContextProviderFunc func(conf config.Configuration) (contextProvider ContextProvider, err error)
type NewHandlerFunc ¶
type NewHandlerFunc func(conf config.Configuration) (handler Handler, err error)
type NewRunnerFunc ¶
type NewRunnerFunc func(conf config.Configuration) (runner TaskRunner, err error)
type PipeTaskRunner ¶
type PipeTaskRunner struct {
// contains filtered or unexported fields
}
func (*PipeTaskRunner) Name ¶
func (p *PipeTaskRunner) Name() string
func (*PipeTaskRunner) Run ¶
func (p *PipeTaskRunner) Run(task *Task)
func (*PipeTaskRunner) SetErrorHandler ¶
func (p *PipeTaskRunner) SetErrorHandler(handler ErrorHandler)
type Task ¶
type Task struct {
// contains filtered or unexported fields
}
func (*Task) LatestError ¶
func (*Task) Status ¶
func (p *Task) Status() TaskStatus
type TaskRunner ¶
type TaskRunner interface { Run(task *Task) SetErrorHandler(handler ErrorHandler) }
func NewPipeTaskRunner ¶
func NewPipeTaskRunner(conf config.Configuration) (runner TaskRunner, err error)
func NewRunner ¶
func NewRunner(name string, conf config.Configuration) (runner TaskRunner, err error)
type TaskStatus ¶
type TaskStatus int
var ( TaskStatusReady TaskStatus = 1 TaskStatusPending TaskStatus = 2 TaskStatusRunning TaskStatus = 3 TaskStatusDone TaskStatus = 4 )
Click to show internal directories.
Click to hide internal directories.