service

Documentation

Index

• type ActionExecutionService
  • func NewActionExecutionService(container *container.DIContiner) *ActionExecutionService
  • func (s *ActionExecutionService) HandleTaskResult(taskResult *api.TaskResult) error
  • func (ts *ActionExecutionService) Poll(taskName string, batchSize int) (*api.Tasks, error)
  • func (ts *ActionExecutionService) Push(res *api.TaskResult) error
• type WorkflowExecutionService
  • func NewWorkflowExecutionService(container *container.DIContiner) *WorkflowExecutionService
  • func (s *WorkflowExecutionService) ConsumeEvent(name string, flowId string, event string) error
  • func (s *WorkflowExecutionService) StartFlow(name string, input map[string]any) (string, error)

Types

type ActionExecutionService

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

func NewActionExecutionService

func NewActionExecutionService(container *container.DIContiner) *ActionExecutionService

func (*ActionExecutionService) HandleTaskResult

func (s *ActionExecutionService) HandleTaskResult(taskResult *api.TaskResult) error

func (*ActionExecutionService) Poll

func (ts *ActionExecutionService) Poll(taskName string, batchSize int) (*api.Tasks, error)

func (*ActionExecutionService) Push

func (ts *ActionExecutionService) Push(res *api.TaskResult) error

type WorkflowExecutionService

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

func NewWorkflowExecutionService

func NewWorkflowExecutionService(container *container.DIContiner) *WorkflowExecutionService

func (*WorkflowExecutionService) ConsumeEvent

func (s *WorkflowExecutionService) ConsumeEvent(name string, flowId string, event string) error

func (*WorkflowExecutionService) StartFlow

func (s *WorkflowExecutionService) StartFlow(name string, input map[string]any) (string, error)