client

Jun 17, 2026

Changes in this version

+ var ErrEventMappingDuplicate = errors.New("event mapping already exists")

+ type InboundEventFilter struct

+ Limit int

+ Provider string

+ Repo string

+ StableEvent string

+ State string

+ type InboundEventRecord struct

+ Actor string

+ CloneURL string

+ CreatedAt time.Time

+ DeliveryID string

+ Description string

+ ExternalAction string

+ ExternalEvent string

+ ID int64

+ MappingID string

+ MappingName string

+ MappingStatus string

+ Message string

+ Metadata map[string]string

+ Payload json.RawMessage

+ Provider string

+ Ref string

+ Repo string

+ Severity string

+ StableEvent string

+ State string

+ UpdatedAt time.Time

type NormalizedEvent

+ ExternalAction string

+ ExternalEvent string

+ MappingID string

+ MappingName string

+ MappingStatus string

+ Ref string

+ Repo string

type ProjectStore

+ func (s *ProjectStore) FinishInboundEvent(ctx context.Context, deliveryID, state, description string) error

+ func (s *ProjectStore) GetInboundEvent(ctx context.Context, id int64) (*InboundEventRecord, error)

+ func (s *ProjectStore) ListInboundEvents(ctx context.Context, filter InboundEventFilter) ([]InboundEventRecord, error)

+ func (s *ProjectStore) RecordInboundEvent(ctx context.Context, event protocol.EventMsg, normalized NormalizedEvent) error

Jun 17, 2026

Changes in this version

type ProjectStore

+ func (s *ProjectStore) GetEventMapping(ctx context.Context, id int64) (EventMapping, error)

Jun 17, 2026

Changes in this version

+ var ErrStableEventBuiltIn = errors.New("built-in stable events cannot be deleted or renamed")

+ func ProviderEventOptions() []selectOption

type ProjectStore

+ func (s *ProjectStore) CreateStableEvent(ctx context.Context, stableEvent *StableEventDefinition) (int64, error)

+ func (s *ProjectStore) DeleteStableEvent(ctx context.Context, id int64) error

+ func (s *ProjectStore) GetStableEvent(ctx context.Context, id int64) (*StableEventDefinition, error)

+ func (s *ProjectStore) ListStableEvents(ctx context.Context) ([]StableEventDefinition, error)

+ func (s *ProjectStore) UpdateStableEvent(ctx context.Context, stableEvent *StableEventDefinition) error

+ type ProviderEvent struct

+ Action string

+ Conditions map[string]string

+ Description string

+ Event string

+ Label string

+ Provider string

+ func FilterProviderEvents(provider string) []ProviderEvent

+ func ProviderEventCatalog() []ProviderEvent

type StableEventDefinition

+ BuiltIn bool

+ CreatedAt time.Time

+ Enabled bool

+ Group string

+ ID int64

+ UpdatedAt time.Time

Jun 17, 2026

Changes in this version

+ const StableEventArtifactInitiate

+ const StableEventArtifactPublished

+ const StableEventCommunicationReceived

+ const StableEventSecurityAlarm

+ const StableEventSystemFailure

+ type EventMapping struct

+ Conditions map[string]string

+ CreatedAt time.Time

+ Enabled bool

+ ID int64

+ MappingID string

+ Name string

+ Priority int64

+ Provider string

+ TargetStableEvent string

+ UpdatedAt time.Time

type ExecutionEvent

+ ExternalAction string

+ ExternalEvent string

+ Provider string

+ StableEvent string

+ type NormalizedEvent struct

+ Actor string

+ ID string

+ Metadata map[string]string

+ RawPayloadReference string

+ Source string

+ StableEvent string

+ Timestamp time.Time

+ func NormalizeInboundEvent(ctx context.Context, store *ProjectStore, event protocol.EventMsg) (protocol.EventMsg, NormalizedEvent, error)

type ProjectStore

+ func (s *ProjectStore) CreateEventMapping(ctx context.Context, mapping *EventMapping) (int64, error)

+ func (s *ProjectStore) DeleteEventMapping(ctx context.Context, id int64) error

+ func (s *ProjectStore) ListEventMappings(ctx context.Context) ([]EventMapping, error)

+ func (s *ProjectStore) UpdateEventMapping(ctx context.Context, mapping *EventMapping) error

+ type StableEventDefinition struct

+ Description string

+ Event string

+ ExampleSources []string

+ Title string

+ WorkflowUses []string

+ func StableEventDefinitions() []StableEventDefinition

Jun 17, 2026

Changes in this version

+ const ResponseModeIterateData

+ const ResponseModeNoop

+ const ResponseModeSendData

+ const WorkflowActionHTTPRequest

+ const WorkflowActionLegacyCommand

+ const WorkflowActionProjectMessage

+ const WorkflowActionRunCommand

+ const WorkflowActionTriggerProjectEvent

type DAGStep

+ Config string

+ Type string

Jun 17, 2026

Changes in this version

type ProjectStore

+ func (s *ProjectStore) ListProjectSummaries(ctx context.Context, org, search string) ([]ProjectSummary, error)

+ type ProjectSummary struct

+ Name string

+ Owner string

+ Repo string

+ State string

+ UpdatedAt time.Time

Jun 15, 2026

Changes in this version

+ const NodeStateFailure

+ const NodeStateSkipped

+ const NodeStateSuccess

+ const WorkflowScopeGlobal

+ const WorkflowScopeRepo

+ func Validate(g Graph) error

type Config

+ MaxNodeWorkers int

+ type DAGEdge struct

+ Condition string

+ From string

+ To string

+ type DAGStep struct

+ Capture string

+ Command string

+ ContinueOnError bool

+ Key string

+ Name string

+ Timeout time.Duration

+ type Graph struct

+ Edges []DAGEdge

+ Nodes map[string]DAGStep

+ Order []string

+ func BuildGraph(nodes []WorkflowNode, edges []WorkflowEdge) (Graph, error)

+ type NodeResult struct

+ ExitCode int

+ Key string

+ Output string

+ State string

+ func Execute(ctx context.Context, g Graph, rc *RunContext, run NodeRunner, ...) ([]NodeResult, error)

+ type NodeRunner func(ctx context.Context, step DAGStep, rc *RunContext) NodeResult

type ProjectStore

+ func (s *ProjectStore) CreateWorkflow(ctx context.Context, wf *Workflow) (int64, error)

+ func (s *ProjectStore) DeleteWorkflow(ctx context.Context, id int64) error

+ func (s *ProjectStore) FinishRun(ctx context.Context, runID int64, state string)

+ func (s *ProjectStore) FinishRunNode(ctx context.Context, runID int64, nodeKey, state string, exitCode int, ...)

+ func (s *ProjectStore) GetRun(ctx context.Context, id int64) (*WorkflowRun, error)

+ func (s *ProjectStore) GetWorkflow(ctx context.Context, id int64) (*Workflow, error)

+ func (s *ProjectStore) ListRuns(ctx context.Context, repo string, limit int) ([]WorkflowRun, error)

+ func (s *ProjectStore) ListWorkflows(ctx context.Context, scope, repo, eventType string) ([]Workflow, error)

+ func (s *ProjectStore) PruneRuns(ctx context.Context, repo string, retain int)

+ func (s *ProjectStore) ResolveWorkflow(ctx context.Context, repo, eventType, action string) (*Workflow, error)

+ func (s *ProjectStore) SetWorkflowEnabled(ctx context.Context, id int64, enabled bool) error

+ func (s *ProjectStore) StartRun(ctx context.Context, run *WorkflowRun) (int64, error)

+ func (s *ProjectStore) StartRunNode(ctx context.Context, runID int64, nodeKey string)

+ func (s *ProjectStore) UpdateWorkflow(ctx context.Context, wf *Workflow) error

+ type RunContext struct

+ BaseEnv []string

+ Vars map[string]string

+ WorkspaceDir string

type WebConfig

+ StaticDir string

+ Token string

+ type Workflow struct

+ CreatedAt time.Time

+ Edges []WorkflowEdge

+ Enabled bool

+ EventType string

+ ID int64

+ Name string

+ Nodes []WorkflowNode

+ Repo string

+ Scope string

+ UpdatedAt time.Time

+ Version int64

+ type WorkflowEdge struct

+ Condition string

+ FromNode string

+ ID int64

+ ToNode string

+ type WorkflowNode struct

+ Capture string

+ Command string

+ Config string

+ ContinueOnError bool

+ ID int64

+ Name string

+ NodeKey string

+ PosX float64

+ PosY float64

+ TimeoutSeconds int64

+ Type string

+ type WorkflowRun struct

+ DeliveryID string

+ DurationMillis int64

+ EventType string

+ FinishedAt *time.Time

+ Hash string

+ ID int64

+ Nodes []WorkflowRunNode

+ Ref string

+ Repo string

+ StartedAt time.Time

+ State string

+ Trigger string

+ WorkflowID int64

+ type WorkflowRunNode struct

+ DurationMillis int64

+ ExitCode int64

+ FinishedAt *time.Time

+ ID int64

+ NodeKey string

+ Output string

+ RunID int64

+ StartedAt *time.Time

+ State string

Jun 12, 2026

Changes in this version

+ type ReplayDispatcher func(context.Context, protocol.EventMsg)

+ type ReplayRef struct

+ Hash string

+ Ref string

+ Type string

Apr 26, 2026

Changes in this version

type ProjectStore

+ func (s *ProjectStore) StartConfiguredEvent(ctx context.Context, repo string, event protocol.EventMsg, hookName string)

Apr 26, 2026

Changes in this version

+ type ConfiguredEvent struct

+ Action string

+ DeliveryID string

+ Description string

+ DurationMillis int64

+ Event string

+ EventKey string

+ FinishedAt *time.Time

+ Hash string

+ Hook string

+ LatestOutput string

+ Ref string

+ Repo string

+ Source string

+ StartedAt *time.Time

+ State string

+ UpdatedAt time.Time

type ProjectState

+ ConfiguredEvents []ConfiguredEvent

type ProjectStore

+ func OpenMemoryProjectStore(ctx context.Context) (*ProjectStore, error)

+ func (s *ProjectStore) ListConfiguredEvents(ctx context.Context, repo string) ([]ConfiguredEvent, error)

+ func (s *ProjectStore) SyncConfiguredEvents(ctx context.Context, repo, repoPath string, cfg Config)

+ func (s *ProjectStore) UpdateConfiguredEvent(ctx context.Context, repo string, event protocol.EventMsg, ...)

Apr 26, 2026

Changes in this version

+ type ProjectEvent struct

+ Action string

+ DeliveryID string

+ Description string

+ DurationMillis int64

+ Event string

+ FinishedAt *time.Time

+ Hash string

+ LatestOutput string

+ Ref string

+ Repo string

+ StartedAt time.Time

+ State string

+ UpdatedAt time.Time

type ProjectState

+ RecentEvents []ProjectEvent

type ProjectStore

+ func (s *ProjectStore) ListProjectEvents(ctx context.Context, repo string, limit int) ([]ProjectEvent, error)

+ func (s *ProjectStore) PruneProjectEvents(ctx context.Context, repo string, retain int)

+ func (s *ProjectStore) RecordProjectEvent(ctx context.Context, event ExecutionEvent)

Apr 26, 2026

Changes in this version

+ func CurrentGitState(repoPath string) (string, string, error)

type Config

+ State StateConfig

+ type ProjectState struct

+ Action string

+ DeliveryID string

+ Description string

+ DurationMillis int64

+ Event string

+ FinishedAt *time.Time

+ Hash string

+ LatestOutput string

+ Ref string

+ Repo string

+ StartedAt time.Time

+ State string

+ UpdatedAt time.Time

+ type ProjectStore struct

+ func OpenProjectStore(ctx context.Context, cfg StateConfig) (*ProjectStore, error)

+ func (s *ProjectStore) Close() error

+ func (s *ProjectStore) FinishProject(ctx context.Context, event ExecutionEvent)

+ func (s *ProjectStore) GetProject(ctx context.Context, repo string) (*ProjectState, error)

+ func (s *ProjectStore) ListProjects(ctx context.Context) ([]ProjectState, error)

+ func (s *ProjectStore) SeedFromReposDir(ctx context.Context, reposDir string)

+ func (s *ProjectStore) StartProject(ctx context.Context, event ExecutionEvent)

+ func (s *ProjectStore) UpdateGitState(ctx context.Context, repo, ref, hash string)

+ func (s *ProjectStore) UpdateOutput(ctx context.Context, repo, state, output string)

+ func (s *ProjectStore) UpsertManagedProject(ctx context.Context, repo, ref, hash string)

+ type StateConfig struct

+ Enabled bool

+ Path string

Apr 26, 2026

Changes in this version

+ func StartWebConsole(ctx context.Context, cfg WebConfig, logStore *ExecutionLog) error

type Config

+ Web WebConfig

+ type ExecutionEvent struct

+ Action string

+ DeliveryID string

+ Description string

+ DurationMillis int64

+ Event string

+ FinishedAt *time.Time

+ Hooks []HookExecution

+ ID string

+ Ref string

+ Repo string

+ Sender string

+ StartedAt time.Time

+ State string

+ UpdatedAt time.Time

+ type ExecutionLog struct

+ func NewExecutionLog(cfg WebConfig) *ExecutionLog

+ func (l *ExecutionLog) AddHook(deliveryID, name, state, output string)

+ func (l *ExecutionLog) Events() []ExecutionEvent

+ func (l *ExecutionLog) FinishEvent(deliveryID, state, desc string)

+ func (l *ExecutionLog) FinishHook(deliveryID, name, state, output string)

+ func (l *ExecutionLog) StartEvent(event protocol.EventMsg)

+ func (l *ExecutionLog) StartHook(deliveryID, name string)

+ func (l *ExecutionLog) Subscribe() (<-chan ExecutionEvent, func())

+ type HookExecution struct

+ DurationMillis int64

+ FinishedAt *time.Time

+ Name string

+ Output string

+ StartedAt time.Time

+ State string

+ type WebConfig struct

+ Enabled bool

+ Listen string

+ MaxEvents int

+ MaxOutputBytes int

Apr 7, 2026

Changes in this version

type Config

+ DefaultNotify string

+ DefaultNotifyOn []string

Apr 7, 2026

Changes in this version

+ func ShouldNotify(notifyOn []string, state string) bool

+ type ApprovalData struct

+ Repos map[string]bool

+ Senders map[string]bool

+ type ApprovalStore struct

+ Data ApprovalData

+ func NewApprovalStore(path string) *ApprovalStore

+ func (s *ApprovalStore) ApproveRepo(repo string) error

+ func (s *ApprovalStore) ApproveSender(sender string) error

+ func (s *ApprovalStore) IsApproved(repo, sender string) bool

+ func (s *ApprovalStore) List() string

+ func (s *ApprovalStore) RevokeRepo(repo string) error

+ func (s *ApprovalStore) RevokeSender(sender string) error

type Config

+ ApprovalsPath string

+ Notifier notifier.Config

+ RequireApproval bool

type EventHooks

+ Notify string

+ NotifyOn []string

type HookSet

+ EventNotify string

+ EventNotifyOn []string

+ Notify string

+ NotifyOn []string

Apr 5, 2026

Changes in this version

+ var GitHubWebhookEvents = map[string][]string

type Config

+ GlobalAllowedPost []string

+ GlobalAllowedPre []string

+ GlobalIgnorePost []string

+ GlobalIgnorePre []string

Apr 4, 2026

Changes in this version

type Config

+ LogLevel string

Apr 4, 2026

Changes in this version

+ func StartRepoChecker(ctx context.Context, cfg Config)

type Config

+ AutoCheck *bool

+ MaxWorkers int

+ type RepoLocks struct

+ func NewRepoLocks() *RepoLocks

+ func (r *RepoLocks) Lock(repo string)

+ func (r *RepoLocks) Unlock(repo string)

Apr 4, 2026

Changes in this version

+ var Version = "dev"

+ func StartAutoUpdater(ctx context.Context)

type Config

+ AutoUpdate bool

+ GlobalHooks struct{ ... }

Apr 4, 2026

Changes in this version

+ func Checkout(repoPath string, event protocol.EventMsg) error

+ func EnsureRepo(reposDir, repoName, cloneURL string) (string, error)

+ func Run(ctx context.Context, cfg Config)

+ func RunHook(ctx context.Context, repoPath, hook string, event protocol.EventMsg) error

+ func RunHookWithOutput(ctx context.Context, repoPath, hook string, event protocol.EventMsg) (string, error)

+ type Config struct

+ ClientID string

+ Relay string

+ ReposDir string

+ Subscribe []string

+ Token string

+ type EventHooks struct

+ Post string

+ Pre string

+ type EventicConfig struct

+ Events map[string]EventHooks

+ Hooks struct{ ... }

+ type HookSet struct

+ EventPost string

+ EventPre string

+ Post string

+ Pre string

+ func DiscoverHooks(repoPath string, event protocol.EventMsg) HookSet