tasks

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 10, 2021 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ISequentialTasks

type ISequentialTasks interface {
	NewSequentialTask([]steps.IStepWorkflow, string) ITaskWorkflow
}

func NewSequentialTasks

func NewSequentialTasks(logger *zap.Logger) (sequentialTasks ISequentialTasks)

type ITaskWorkflow

type ITaskWorkflow interface {
	Run() error
}

type ITasks

type ITasks interface {
	NewTask(string, map[string]interface{}, string) ITaskWorkflow
}

func NewTasks

func NewTasks(logger *zap.Logger) (tasks ITasks)

type SequentialTask

type SequentialTask struct {
	Steps []steps.IStepWorkflow
	Task
}

func (*SequentialTask) Run

func (sequentialTask *SequentialTask) Run() (err error)

type SequentialTasks

type SequentialTasks struct {
	Logger *zap.Logger
}

func (*SequentialTasks) NewSequentialTask

func (st *SequentialTasks) NewSequentialTask(steps []steps.IStepWorkflow, node string) (sequentialTask ITaskWorkflow)

type Task

type Task struct {
	Node   string
	Logger *zap.Logger
}

type Tasks

type Tasks struct {
	SequentialTasks ISequentialTasks
	Logger          *zap.Logger
}

func (*Tasks) NewTask

func (t *Tasks) NewTask(taskType string, stepData map[string]interface{}, node string) (task ITaskWorkflow)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL