server

Documentation

Index

• Constants
• Variables
• func Audit(l *logrus.Entry, task *model.Task) (err error)
• func ExecuteWorkflow(workflow *model.Workflow, userId uint) error
• func InitSqled(exit chan struct{})
• type Sqled
  • func GetSqled() *Sqled
  • func (s *Sqled) AddTask(taskId string, typ int) error
  • func (s *Sqled) AddTaskWaitResult(taskId string, typ int) (*model.Task, error)
  • func (s *Sqled) CleanExpiredTasks(entry *logrus.Entry)
  • func (s *Sqled) CleanExpiredWorkflows(entry *logrus.Entry)
  • func (s *Sqled) HasTask(taskId string) bool
  • func (s *Sqled) Start()
  • func (s *Sqled) WorkflowSchedule(entry *logrus.Entry)

Constants

const (
	ActionTypeAudit = iota + 1
	ActionTypeExecute
	ActionTypeRollback
)

const (
	SqlAuditTaskExpiredTime = 3 * 24 // 3 days
)

Variables

var (
	ErrActionExecuteOnExecutedTask       = _errors.New("task has been executed, can not do execute on it")
	ErrActionExecuteOnNonAuditedTask     = _errors.New("task has not been audited, can not do execute on it")
	ErrActionRollbackOnRollbackedTask    = _errors.New("task has been rollbacked, can not do rollback on it")
	ErrActionRollbackOnExecuteFailedTask = _errors.New("task has been executed failed, can not do rollback on it")
	ErrActionRollbackOnNonExecutedTask   = _errors.New("task has not been executed, can not do rollback on it")
)

Functions

func Audit

func Audit(l *logrus.Entry, task *model.Task) (err error)

func ExecuteWorkflow

func ExecuteWorkflow(workflow *model.Workflow, userId uint) error

func InitSqled

func InitSqled(exit chan struct{})

Types

type Sqled

type Sqled struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Sqled is an async task scheduling service. receive tasks from queue, the tasks include inspect, execute, rollback; and the task will only be executed once.

func GetSqled

func GetSqled() *Sqled

func (*Sqled) AddTask

func (s *Sqled) AddTask(taskId string, typ int) error

func (*Sqled) AddTaskWaitResult

func (s *Sqled) AddTaskWaitResult(taskId string, typ int) (*model.Task, error)

func (*Sqled) CleanExpiredTasks

func (s *Sqled) CleanExpiredTasks(entry *logrus.Entry)

func (*Sqled) CleanExpiredWorkflows

func (s *Sqled) CleanExpiredWorkflows(entry *logrus.Entry)

func (*Sqled) HasTask

func (s *Sqled) HasTask(taskId string) bool

func (*Sqled) Start

func (s *Sqled) Start()

func (*Sqled) WorkflowSchedule

func (s *Sqled) WorkflowSchedule(entry *logrus.Entry)