workflow

Documentation

Index

• func AddEvent() error
• type WorkflowRepository
• type WorkflowService
  • func NewWorkflowService(repo WorkflowRepository) *WorkflowService
  • func (s *WorkflowService) InitSchedule(ctx context.Context) error
  • func (s *WorkflowService) Run(ctx context.Context, req *domain.WorkflowRunReq) error

Functions

func AddEvent

func AddEvent() error

Types

type WorkflowRepository

type WorkflowRepository interface {
	Get(ctx context.Context, id string) (*domain.Workflow, error)
	SaveRunLog(ctx context.Context, log *domain.WorkflowRunLog) error
	ListEnabledAuto(ctx context.Context) ([]domain.Workflow, error)
}

type WorkflowService

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

func NewWorkflowService

func NewWorkflowService(repo WorkflowRepository) *WorkflowService

func (*WorkflowService) InitSchedule

func (s *WorkflowService) InitSchedule(ctx context.Context) error

func (*WorkflowService) Run

func (s *WorkflowService) Run(ctx context.Context, req *domain.WorkflowRunReq) error