Documentation ¶
Index ¶
- Constants
- type CronHandler
- type JobAttr
- type Manager
- type MirrorPlugin
- func (f MirrorPlugin) Close(ctx context.Context) error
- func (d MirrorPlugin) CreateEntry(ctx context.Context, attr pluginapi.EntryAttr) (*pluginapi.Entry, error)
- func (d MirrorPlugin) FindEntry(ctx context.Context, name string) (*pluginapi.Entry, error)
- func (f MirrorPlugin) Fsync(ctx context.Context) error
- func (d MirrorPlugin) IsGroup(ctx context.Context) (bool, error)
- func (d MirrorPlugin) ListChildren(ctx context.Context) ([]*pluginapi.Entry, error)
- func (m *MirrorPlugin) Name() string
- func (f MirrorPlugin) ReadAt(ctx context.Context, dest []byte, off int64) (int64, error)
- func (d MirrorPlugin) RemoveEntry(ctx context.Context, en *pluginapi.Entry) error
- func (f MirrorPlugin) Trunc(ctx context.Context) error
- func (m *MirrorPlugin) Type() types.PluginType
- func (d MirrorPlugin) UpdateEntry(ctx context.Context, en *pluginapi.Entry) error
- func (m *MirrorPlugin) Version() string
- func (f MirrorPlugin) WriteAt(ctx context.Context, data []byte, off int64) (int64, error)
Constants ¶
View Source
const ( MirrorPluginName = "workflow" MirrorPluginVersion = "1.0" MirrorDirRoot = "root" MirrorDirWorkflows = "workflows" MirrorDirJobs = "jobs" MirrorFileType = ".yaml" MirrorRootDirName = ".workflow" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CronHandler ¶
type CronHandler struct { *cron.Cron // contains filtered or unexported fields }
func (*CronHandler) Register ¶
func (c *CronHandler) Register(wf *types.WorkflowSpec) error
func (*CronHandler) Start ¶
func (c *CronHandler) Start(ctx context.Context)
func (*CronHandler) Unregister ¶
func (c *CronHandler) Unregister(wfID string)
type Manager ¶
type Manager interface { Start(stopCh chan struct{}) ListWorkflows(ctx context.Context) ([]*types.WorkflowSpec, error) GetWorkflow(ctx context.Context, wfId string) (*types.WorkflowSpec, error) CreateWorkflow(ctx context.Context, spec *types.WorkflowSpec) (*types.WorkflowSpec, error) UpdateWorkflow(ctx context.Context, spec *types.WorkflowSpec) (*types.WorkflowSpec, error) DeleteWorkflow(ctx context.Context, wfId string) error ListJobs(ctx context.Context, wfId string) ([]*types.WorkflowJob, error) GetJob(ctx context.Context, wfId string, jobID string) (*types.WorkflowJob, error) TriggerWorkflow(ctx context.Context, wfId string, tgt types.WorkflowTarget, attr JobAttr) (*types.WorkflowJob, error) PauseWorkflowJob(ctx context.Context, jobId string) error ResumeWorkflowJob(ctx context.Context, jobId string) error CancelWorkflowJob(ctx context.Context, jobId string) error }
type MirrorPlugin ¶
type MirrorPlugin struct {
// contains filtered or unexported fields
}
MirrorPlugin is an implementation of plugin.MirrorPlugin, which supports managing workflows using POSIX operations.
virtual directory structure as follows:
. |--workflows |--<workflow_id>.yaml |--jobs |--<workflow_id> |--<job_id>.yaml
func (MirrorPlugin) CreateEntry ¶
func (MirrorPlugin) ListChildren ¶
func (*MirrorPlugin) Name ¶
func (m *MirrorPlugin) Name() string
func (MirrorPlugin) RemoveEntry ¶
func (*MirrorPlugin) Type ¶
func (m *MirrorPlugin) Type() types.PluginType
func (MirrorPlugin) UpdateEntry ¶
func (*MirrorPlugin) Version ¶
func (m *MirrorPlugin) Version() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.