controllers

Documentation

Index

• type ExecutorController
  • func NewExecutorController(deps ExecutorControllerDependencies) *ExecutorController
  • func (c *ExecutorController) HandlePollingEvent(ctx fiber.Ctx) error
  • func (c *ExecutorController) PeekData(ctx fiber.Ctx) error
  • func (c *ExecutorController) RegisterWorkspace(ctx fiber.Ctx) error
  • func (c *ExecutorController) StartExecution(ctx fiber.Ctx) error
  • func (c *ExecutorController) TestConnection(ctx fiber.Ctx) error
• type ExecutorControllerDependencies

Types

type ExecutorController

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

ExecutorController handles API-initiated requests to executor services This controller is used when the API needs to send commands to executors

func NewExecutorController

func NewExecutorController(deps ExecutorControllerDependencies) *ExecutorController

func (*ExecutorController) HandlePollingEvent

func (c *ExecutorController) HandlePollingEvent(ctx fiber.Ctx) error

HandlePollingEvent handles a polling event request from the API

func (*ExecutorController) PeekData

func (c *ExecutorController) PeekData(ctx fiber.Ctx) error

func (*ExecutorController) RegisterWorkspace

func (c *ExecutorController) RegisterWorkspace(ctx fiber.Ctx) error

func (*ExecutorController) StartExecution

func (c *ExecutorController) StartExecution(ctx fiber.Ctx) error

StartExecution handles the start of a workflow execution

func (*ExecutorController) TestConnection

func (c *ExecutorController) TestConnection(ctx fiber.Ctx) error

TestConnection handles connection testing requests from the API

type ExecutorControllerDependencies

type ExecutorControllerDependencies struct {
	WorkflowExecutorService      executor.WorkflowExecutorService
	WorkspaceRegistrationManager domain.WorkspaceRegistrationManager
}