engine

Feb 24, 2026

Changes in this version

type TriggerInput

+ func (input *TriggerInput) SetChangeSet(changeSet mutations.ChangeSet)

+ func (input TriggerInput) ChangeSet() mutations.ChangeSet

type WorkflowListeners

+ func (l *WorkflowListeners) HandleWorkflowAssignmentMutationGala(ctx gala.HandlerContext, payload eventqueue.MutationGalaPayload) error

+ func (l *WorkflowListeners) HandleWorkflowMutationGala(ctx gala.HandlerContext, payload eventqueue.MutationGalaPayload) error

Feb 11, 2026

Changes in this version

+ var ErrIntegrationActionQueued = errors.New("integration action queued")

+ var ErrIntegrationAlertPayloadsMissing = errors.New("integration alert payloads missing")

+ var ErrIntegrationEmitterRequired = errors.New("integration emitter required")

+ var ErrIntegrationOperationFailed = errors.New("integration operation failed")

+ var ErrIntegrationOperationNameRequired = errors.New("integration operation name required")

+ var ErrIntegrationOperationsRequired = errors.New("integration operations required")

+ var ErrIntegrationProviderUnknown = errors.New("integration provider unknown")

+ var ErrIntegrationRecordMissing = errors.New("integration record missing for run")

+ var ErrIntegrationRunIDRequired = errors.New("integration run id required")

+ var ErrIntegrationStoreRequired = errors.New("integration store required")

+ var ErrNotificationChannelUnsupported = errors.New("notification channel unsupported")

+ var ErrNotificationTemplateChannelMismatch = errors.New("notification template channel mismatch")

+ var ErrNotificationTemplateDataInvalid = errors.New("notification template data invalid")

+ var ErrNotificationTemplateNotFound = errors.New("notification template not found")

+ var ErrNotificationTemplateReferenceConflict = errors.New("notification template reference conflict")

+ var ErrTemplateRenderDepthExceeded = errors.New("template render depth exceeded")

type CELEvaluator

+ func (e *CELEvaluator) EvaluateValue(ctx context.Context, expression string, vars map[string]any) (any, error)

+ type IntegrationDeps struct

+ Emitter *soiree.EventBus

+ Operations IntegrationOperations

+ Registry IntegrationRegistry

+ Store IntegrationStore

+ type IntegrationOperations interface

+ Run func(ctx context.Context, req types.OperationRequest) (types.OperationResult, error)

+ type IntegrationQueueRequest struct

+ ClientForce bool

+ Config map[string]any

+ Force bool

+ IntegrationID string

+ Operation types.OperationName

+ OrgID string

+ Provider types.ProviderType

+ RunType enums.IntegrationRunType

+ WorkflowMeta *IntegrationWorkflowMeta

+ type IntegrationQueueResult struct

+ EventID string

+ RunID string

+ Status enums.IntegrationRunStatus

+ type IntegrationRegistry interface

+ OperationDescriptors func(provider types.ProviderType) []types.OperationDescriptor

+ type IntegrationStore interface

+ EnsureIntegration func(ctx context.Context, orgID string, provider types.ProviderType) (*ent.Integration, error)

+ type IntegrationWorkflowMeta struct

+ ActionIndex int

+ ActionKey string

+ InstanceID string

+ ObjectID string

+ ObjectType enums.WorkflowObjectType

type WorkflowEngine

+ func (e *WorkflowEngine) QueueIntegrationOperation(ctx context.Context, req IntegrationQueueRequest) (IntegrationQueueResult, error)

+ func (e *WorkflowEngine) SetIntegrationDeps(deps IntegrationDeps) error

Feb 7, 2026

Changes in this version

+ var ErrReviewNoTargets = errors.New("review action has no resolved targets")

type AssignmentStatusCounts

+ ChangesRequested int

+ ChangesRequestedRequired bool

Feb 3, 2026

Changes in this version

+ var ErrWebhookPayloadExpressionFailed = errors.New("webhook payload expression failed")

+ var ErrWebhookPayloadExpressionInvalid = errors.New("webhook payload expression invalid")

+ var ErrWebhookPayloadUnsupported = errors.New("webhook payload is not supported; use payload_expr")

type CELEvaluator

+ func (e *CELEvaluator) EvaluateJSONMap(ctx context.Context, expression string, vars map[string]any) (map[string]any, error)

Jan 28, 2026

Changes in this version

+ var ErrApprovalNoTargets = errors.New("approval action has no resolved targets")

+ var ErrFailedToApplyFieldUpdates = errors.New("failed to apply field updates")

+ var ErrFailedToComputeProposalHash = errors.New("failed to compute proposal hash")

+ var ErrFailedToCreateAssignmentTarget = errors.New("failed to create assignment target")

+ var ErrFailedToCreateProposal = errors.New("failed to create workflow proposal inside of proposal manager")

+ var ErrFailedToEnrichWebhookPayload = errors.New("failed to enrich webhook payload")

+ var ErrFailedToLoadProposal = errors.New("failed to load proposal")

+ var ErrFailedToQueryDefinitions = errors.New("failed to query workflow definitions")

+ var ErrFailedToQueryObjectRefs = errors.New("failed to query object refs")

+ var ErrFailedToQueryProposals = errors.New("failed to query proposals")

+ var ErrFailedToResolveNotificationTarget = errors.New("failed to resolve notification target")

+ var ErrFailedToResolveTarget = errors.New("failed to resolve target")

+ var ErrMissingObjectRef = errors.New("workflow object ref is required")

+ type AssignmentStatusCounts struct

+ Approved int

+ Pending int

+ Rejected int

+ RejectedRequired bool

+ func CountAssignmentStatus(assignments []*generated.WorkflowAssignment) AssignmentStatusCounts

+ type CELEvaluator struct

+ func NewCELEvaluator(env *cel.Env, config *workflows.Config) *CELEvaluator

+ func (e *CELEvaluator) Evaluate(ctx context.Context, expression string, vars map[string]any) (bool, error)

+ func (e *CELEvaluator) Validate(expression string) error

+ type ProposalManager struct

+ func NewProposalManager(client *generated.Client) *ProposalManager

+ func (m *ProposalManager) Apply(scope *observability.Scope, proposalID string, obj *workflows.Object) error

+ func (m *ProposalManager) ComputeHash(ctx context.Context, instance *generated.WorkflowInstance, ...) (string, error)

+ func (m *ProposalManager) Create(ctx context.Context, tx *generated.Tx, objRef *generated.WorkflowObjectRef, ...) (*generated.WorkflowProposal, error)

+ func (m *ProposalManager) LoadForObject(ctx context.Context, obj *workflows.Object) (*generated.WorkflowProposal, error)

+ type TriggerInput struct

+ AddedIDs map[string][]string

+ ChangedEdges []string

+ ChangedFields []string

+ EventType string

+ ProposedChanges map[string]any

+ RemovedIDs map[string][]string

type WorkflowEngine

+ func (e *WorkflowEngine) CompleteAssignment(ctx context.Context, assignmentID string, ...) (err error)

+ func (e *WorkflowEngine) EvaluateActionWhen(ctx context.Context, expression string, instance *generated.WorkflowInstance, ...) (bool, error)

+ func (e *WorkflowEngine) Execute(ctx context.Context, action models.WorkflowAction, ...) error

+ func (e *WorkflowEngine) FindMatchingDefinitions(ctx context.Context, schemaType string, eventType string, ...) (defs []*generated.WorkflowDefinition, err error)

+ func (e *WorkflowEngine) ProcessAction(ctx context.Context, instance *generated.WorkflowInstance, ...) error

+ func (e *WorkflowEngine) ResolveTargets(ctx context.Context, target workflows.TargetConfig, obj *workflows.Object) ([]string, error)

+ func (e *WorkflowEngine) TriggerExistingInstance(ctx context.Context, instance *generated.WorkflowInstance, ...) (err error)

+ func (e *WorkflowEngine) TriggerWorkflow(ctx context.Context, def *generated.WorkflowDefinition, obj *workflows.Object, ...) (instance *generated.WorkflowInstance, err error)

+ type WorkflowListeners struct

+ func NewWorkflowListeners(client *generated.Client, engine *WorkflowEngine, emitter soiree.Emitter) *WorkflowListeners

+ func (l *WorkflowListeners) HandleActionCompleted(ctx *soiree.EventContext, payload soiree.WorkflowActionCompletedPayload) (err error)

+ func (l *WorkflowListeners) HandleActionStarted(ctx *soiree.EventContext, payload soiree.WorkflowActionStartedPayload) (err error)

+ func (l *WorkflowListeners) HandleAssignmentCompleted(ctx *soiree.EventContext, payload soiree.WorkflowAssignmentCompletedPayload) (err error)

+ func (l *WorkflowListeners) HandleAssignmentCreated(ctx *soiree.EventContext, payload soiree.WorkflowAssignmentCreatedPayload) (err error)

+ func (l *WorkflowListeners) HandleInstanceCompleted(ctx *soiree.EventContext, payload soiree.WorkflowInstanceCompletedPayload) (err error)

+ func (l *WorkflowListeners) HandleWorkflowAssignmentMutation(ctx *soiree.EventContext, payload *events.MutationPayload) error

+ func (l *WorkflowListeners) HandleWorkflowMutation(ctx *soiree.EventContext, payload *events.MutationPayload) error

+ func (l *WorkflowListeners) HandleWorkflowTriggered(ctx *soiree.EventContext, payload soiree.WorkflowTriggeredPayload) (err error)

Jan 22, 2026

Changes in this version

+ var ErrActionExecutionFailed = errors.New("action execution failed")

+ var ErrActionIndexOutOfBounds = errors.New("workflow action index out of bounds")

+ var ErrAssignmentActionNotFound = errors.New("workflow assignment action not found")

+ var ErrAssignmentCreationFailed = errors.New("failed to create workflow assignment")

+ var ErrAssignmentNotFound = errors.New("workflow assignment not found")

+ var ErrAssignmentUpdateFailed = errors.New("failed to update workflow assignment")

+ var ErrCELCompilationFailed = errors.New("failed to compile CEL")

+ var ErrCELNilOutput = errors.New("CEL evaluation returned nil output")

+ var ErrCELPanic = errors.New("CEL evaluation panic")

+ var ErrCELProgramCreationFailed = errors.New("failed to create CEL program")

+ var ErrCELTypeMismatch = errors.New("CEL expression must return boolean")

+ var ErrCELValueExtraction = errors.New("failed to extract boolean value from CEL result")

+ var ErrConditionFailed = errors.New("condition evaluation failed")

+ var ErrEvaluationTimeout = errors.New("CEL evaluation timeout")

+ var ErrExecutorNotAvailable = errors.New("executor is nil")

+ var ErrFieldNotWorkflowEligible = errors.New("field is not eligible for workflow modification")

+ var ErrInstanceNotFound = errors.New("workflow instance not found")

+ var ErrIntegrationFailed = errors.New("integration operation failed")

+ var ErrIntegrationManagerNotAvailable = errors.New("integration operations manager not available")

+ var ErrIntegrationOwnerRequired = errors.New("integration action requires instance owner_id")

+ var ErrIntegrationProviderRequired = errors.New("integration action requires provider")

+ var ErrInvalidActionType = errors.New("invalid action type")

+ var ErrInvalidObjectType = errors.New("invalid object type")

+ var ErrInvalidState = errors.New("invalid workflow state")

+ var ErrInvalidTargetType = errors.New("invalid target type")

+ var ErrMarshalPayload = errors.New("failed to marshal payload")

+ var ErrMissingRequiredField = errors.New("missing required field")

+ var ErrNilClient = errors.New("ent client is required to initialize workflow engine")

+ var ErrNoMatchingDefinitions = errors.New("no matching workflow definitions")

+ var ErrNotificationCreationFailed = errors.New("failed to create notification")

+ var ErrObjectNil = errors.New("object is nil")

+ var ErrObjectRefMissingID = errors.New("workflow object ref has no object ID set")

+ var ErrProposalChangesModified = errors.New("proposal changes modified after approval")

+ var ErrTargetResolutionFailed = errors.New("target resolution failed")

+ var ErrUnmarshalParams = errors.New("failed to unmarshal action params")

+ var ErrUnsupportedTimeFormat = errors.New("unsupported time format")

+ var ErrWebhookFailed = errors.New("webhook request failed")

+ var ErrWebhookURLRequired = errors.New("webhook action requires url")

+ var ErrWorkflowNotFound = errors.New("workflow definition not found")

+ type WorkflowEngine struct

+ func NewWorkflowEngine(client *generated.Client, emitter soiree.Emitter, opts ...workflows.ConfigOpts) (*WorkflowEngine, error)

+ func NewWorkflowEngineWithConfig(client *generated.Client, emitter soiree.Emitter, config *workflows.Config) (*WorkflowEngine, error)

+ func (e *WorkflowEngine) EvaluateConditions(ctx context.Context, def *generated.WorkflowDefinition, obj *workflows.Object, ...) (bool, error)