workflow

Documentation

Index

• func Register()
• type WorkflowService
  • func NewWorkflowService(repo workflowRepository) *WorkflowService
  • func (s *WorkflowService) InitSchedule(ctx context.Context) error
  • func (s *WorkflowService) Run(ctx context.Context, options *domain.WorkflowRunReq) error
  • func (s *WorkflowService) Stop()

Functions

func Register

func Register()

Types

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, options *domain.WorkflowRunReq) error

func (*WorkflowService) Stop

func (s *WorkflowService) Stop()