workflow

Documentation

Index

• Variables
• type Manager
  • func NewWorkflowManager(ctrl controller.Controller) (*Manager, error)
  • func (m *Manager) FileSaveHandler(obj *types.Object)
  • func (m *Manager) Run() error
  • func (m *Manager) WorkFlowDestroyHandler(obj *types.Object)
  • func (m *Manager) WorkFlowHandler(obj *types.Object)
• type NanaJob
  • func NewNanaJob(ctrl controller.Controller, workflow *Workflow, jobObj, value *types.Object) (*NanaJob, *types.Job, error)
  • func (n NanaJob) GetControlPolicy() flow.ControlPolicy
  • func (n NanaJob) GetHooks() flow.Hooks
  • func (n *NanaJob) GetMessage() string
  • func (n *NanaJob) GetStatus() fsm.Status
  • func (n NanaJob) ID() flow.FID
  • func (n *NanaJob) NextBatch(ctx *flow.Context) ([]flow.Task, error)
  • func (n *NanaJob) Run() error
  • func (n *NanaJob) SetMessage(msg string)
  • func (n *NanaJob) SetStatus(status fsm.Status)
  • func (n NanaJob) Setup(ctx *flow.Context) error
  • func (n NanaJob) Teardown(ctx *flow.Context)
  • func (n NanaJob) Type() flow.FType
• type NanaTask
  • func (n *NanaTask) Do(ctx *flow.Context) error
  • func (n *NanaTask) GetMessage() string
  • func (n *NanaTask) GetStatus() fsm.Status
  • func (n *NanaTask) Name() flow.TName
  • func (n *NanaTask) SetMessage(msg string)
  • func (n *NanaTask) SetStatus(status fsm.Status)
  • func (n *NanaTask) Setup(ctx *flow.Context) error
  • func (n *NanaTask) Teardown(ctx *flow.Context)
• type Registry
• type Workflow
  • func NewWorkflow(name string, rule types.Rule, plugins []plugin.Plugin) *Workflow

Variables

var (
	FlowCtl     *controller.FlowController
	FlowStorage storage.Interface
)

Types

type Manager

type Manager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewWorkflowManager

func NewWorkflowManager(ctrl controller.Controller) (*Manager, error)

func (*Manager) FileSaveHandler

func (m *Manager) FileSaveHandler(obj *types.Object)

func (*Manager) Run

func (m *Manager) Run() error

func (*Manager) WorkFlowDestroyHandler

func (m *Manager) WorkFlowDestroyHandler(obj *types.Object)

func (*Manager) WorkFlowHandler

func (m *Manager) WorkFlowHandler(obj *types.Object)

type NanaJob

type NanaJob struct {
	Id string
	// contains filtered or unexported fields
}

func NewNanaJob

func NewNanaJob(ctrl controller.Controller, workflow *Workflow, jobObj, value *types.Object) (*NanaJob, *types.Job, error)

func (NanaJob) GetControlPolicy

func (n NanaJob) GetControlPolicy() flow.ControlPolicy

func (NanaJob) GetHooks

func (n NanaJob) GetHooks() flow.Hooks

func (*NanaJob) GetMessage

func (n *NanaJob) GetMessage() string

func (*NanaJob) GetStatus

func (n *NanaJob) GetStatus() fsm.Status

func (NanaJob) ID

func (n NanaJob) ID() flow.FID

func (*NanaJob) NextBatch

func (n *NanaJob) NextBatch(ctx *flow.Context) ([]flow.Task, error)

func (*NanaJob) Run

func (n *NanaJob) Run() error

func (*NanaJob) SetMessage

func (n *NanaJob) SetMessage(msg string)

func (*NanaJob) SetStatus

func (n *NanaJob) SetStatus(status fsm.Status)

func (NanaJob) Setup

func (n NanaJob) Setup(ctx *flow.Context) error

func (NanaJob) Teardown

func (n NanaJob) Teardown(ctx *flow.Context)

func (NanaJob) Type

func (n NanaJob) Type() flow.FType

type NanaTask

type NanaTask struct {
	// contains filtered or unexported fields
}

func (*NanaTask) Do

func (n *NanaTask) Do(ctx *flow.Context) error

func (*NanaTask) GetMessage

func (n *NanaTask) GetMessage() string

func (*NanaTask) GetStatus

func (n *NanaTask) GetStatus() fsm.Status

func (*NanaTask) Name

func (n *NanaTask) Name() flow.TName

func (*NanaTask) SetMessage

func (n *NanaTask) SetMessage(msg string)

func (*NanaTask) SetStatus

func (n *NanaTask) SetStatus(status fsm.Status)

func (*NanaTask) Setup

func (n *NanaTask) Setup(ctx *flow.Context) error

func (*NanaTask) Teardown

func (n *NanaTask) Teardown(ctx *flow.Context)

type Registry

type Registry struct {
}

type Workflow

type Workflow struct {
	Name    string          `json:"name"`
	Rule    types.Rule      `json:"rule"`
	Plugins []plugin.Plugin `json:"plugins"`
	// contains filtered or unexported fields
}

func NewWorkflow

func NewWorkflow(name string, rule types.Rule, plugins []plugin.Plugin) *Workflow