Documentation
¶
Index ¶
- func Register()
- type WorkflowService
- func (s *WorkflowService) CancelRun(ctx context.Context, req *dtos.WorkflowCancelRunReq) (*dtos.WorkflowCancelRunResp, error)
- func (s *WorkflowService) GetStatistics(ctx context.Context) (*dtos.WorkflowStatisticsResp, error)
- func (s *WorkflowService) InitSchedule(ctx context.Context) error
- func (s *WorkflowService) Shutdown(ctx context.Context)
- func (s *WorkflowService) StartRun(ctx context.Context, req *dtos.WorkflowStartRunReq) (*dtos.WorkflowStartRunResp, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type WorkflowService ¶
type WorkflowService struct {
// contains filtered or unexported fields
}
func NewWorkflowService ¶
func NewWorkflowService(workflowRepo workflowRepository, workflowRunRepo workflowRunRepository, settingsRepo settingsRepository) *WorkflowService
func (*WorkflowService) CancelRun ¶
func (s *WorkflowService) CancelRun(ctx context.Context, req *dtos.WorkflowCancelRunReq) (*dtos.WorkflowCancelRunResp, error)
func (*WorkflowService) GetStatistics ¶ added in v0.4.0
func (s *WorkflowService) GetStatistics(ctx context.Context) (*dtos.WorkflowStatisticsResp, error)
func (*WorkflowService) InitSchedule ¶
func (s *WorkflowService) InitSchedule(ctx context.Context) error
func (*WorkflowService) Shutdown ¶
func (s *WorkflowService) Shutdown(ctx context.Context)
func (*WorkflowService) StartRun ¶
func (s *WorkflowService) StartRun(ctx context.Context, req *dtos.WorkflowStartRunReq) (*dtos.WorkflowStartRunResp, error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.