service

Documentation

Index

• type ActionExecutionService
  • func NewActionExecutionService(cluster *cluster.Cluster, metadataService metadata.MetadataService) *ActionExecutionService
  • func (s *ActionExecutionService) HandleActionResult(actionResult *api.ActionResult) error
  • func (ts *ActionExecutionService) Poll(actionName string, batchSize int) (*api.Actions, error)
  • func (ts *ActionExecutionService) Push(res *api.ActionResult) error
• type WorkflowExecutionService
  • func NewWorkflowExecutionService(cluster *cluster.Cluster) *WorkflowExecutionService
  • func (s *WorkflowExecutionService) ConsumeEvent(name string, flowId string, event string) error
  • func (s *WorkflowExecutionService) PauseFlow(name string, flowId string) error
  • func (s *WorkflowExecutionService) ResumeFlow(name string, flowId 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(cluster *cluster.Cluster, metadataService metadata.MetadataService) *ActionExecutionService

func (*ActionExecutionService) HandleActionResult

func (s *ActionExecutionService) HandleActionResult(actionResult *api.ActionResult) error

func (*ActionExecutionService) Poll

func (ts *ActionExecutionService) Poll(actionName string, batchSize int) (*api.Actions, error)

func (*ActionExecutionService) Push

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

type WorkflowExecutionService

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

func NewWorkflowExecutionService

func NewWorkflowExecutionService(cluster *cluster.Cluster) *WorkflowExecutionService

func (*WorkflowExecutionService) ConsumeEvent

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

func (*WorkflowExecutionService) PauseFlow

func (s *WorkflowExecutionService) PauseFlow(name string, flowId string) error

func (*WorkflowExecutionService) ResumeFlow

func (s *WorkflowExecutionService) ResumeFlow(name string, flowId string) error

func (*WorkflowExecutionService) StartFlow

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