Versions in this module Expand all Collapse all v0 v0.1.0 Sep 7, 2026 Changes in this version + func Register(t models.CallbackType, h Handler) + type Dispatcher struct + func Default() *Dispatcher + func NewDispatcher(conn *gorm.DB) *Dispatcher + func (d *Dispatcher) Dispatch(ctx context.Context, jobID, runID uuid.UUID, runErr error) error + func (d *Dispatcher) RetryFailed(ctx context.Context, runID uuid.UUID) error + func (d *Dispatcher) WithHTTPClient(client *http.Client) + type Handler interface + Handle func(ctx context.Context, cfg json.RawMessage, meta Metadata) error + type Metadata struct + CompletedAt *time.Time + Error string + JobAlias string + JobID uuid.UUID + Params map[string]string + RunID uuid.UUID + StartedAt time.Time + Status string + Tasks []TaskState + type NotificationConfig struct + Headers map[string]string + URL string + UserAgent string + Webhook string + type NotificationHandler struct + func NewNotificationHandler(client *http.Client) *NotificationHandler + func (h *NotificationHandler) Handle(ctx context.Context, cfgRaw json.RawMessage, meta Metadata) error + type TaskState struct + AtomID uuid.UUID + Command []string + CompletedAt *time.Time + Engine models.AtomEngine + Error string + Image string + Result string + RuntimeID string + StartedAt *time.Time + Status string + TaskID uuid.UUID
Go to main page