server

Documentation

Index

• type APIServer
  • func NewAPIServer(engine *workflow.Engine, store workflow.StateStore) *APIServer
  • func (s *APIServer) Handler() http.Handler
• type EventHub
  • func NewEventHub(buffer int) *EventHub
  • func (h *EventHub) CloseRun(runID string)
  • func (h *EventHub) Emit(ctx context.Context, e workflow.Event)
  • func (h *EventHub) Subscribe(runID string) (<-chan workflow.Event, func())
• type RunOptionsInput
• type RunRequest
• type RunResponse

Types

type APIServer

type APIServer struct {
	Engine *workflow.Engine
	Store  workflow.StateStore
	Hub    *EventHub
	Logger *slog.Logger
	// contains filtered or unexported fields
}

func NewAPIServer

func NewAPIServer(engine *workflow.Engine, store workflow.StateStore) *APIServer

func (*APIServer) Handler

func (s *APIServer) Handler() http.Handler

type EventHub

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

func NewEventHub

func NewEventHub(buffer int) *EventHub

func (*EventHub) CloseRun

func (h *EventHub) CloseRun(runID string)

func (*EventHub) Emit

func (h *EventHub) Emit(ctx context.Context, e workflow.Event)

func (*EventHub) Subscribe

func (h *EventHub) Subscribe(runID string) (<-chan workflow.Event, func())

type RunOptionsInput

type RunOptionsInput struct {
	RunID       string   `json:"run_id,omitempty"`
	Start       []string `json:"start,omitempty"`
	Concurrency int      `json:"concurrency,omitempty"`
	FailFast    *bool    `json:"fail_fast,omitempty"`
	AllowCycles bool     `json:"allow_cycles,omitempty"`
}

type RunRequest

type RunRequest struct {
	Definition json.RawMessage  `json:"definition"`
	Options    *RunOptionsInput `json:"options,omitempty"`
}

type RunResponse

type RunResponse struct {
	WorkflowID string `json:"workflow_id,omitempty"`
	RunID      string `json:"run_id,omitempty"`
	Status     string `json:"status,omitempty"`
}