engine

package

Go to main page

Versions in this module

v0

v0.6.0

Sep 9, 2026

Changes in this version

+ const DefaultMaxCollection

+ const DefaultMaxVariable

+ type Arrival struct

+ Flow int32

+ Key uint64

type ProcessingContext

+ func (c *ProcessingContext) ArrivalsOnNode(procKey, scopeKey uint64, elementId int32) []Arrival

+ func (c *ProcessingContext) OldestPerFlow(arrivals []Arrival) []Arrival

type Processor

+ func (p *Processor) SetMaxCollection(n int64)

+ func (p *Processor) SetMaxVariable(n int64)

v0.5.0

Sep 8, 2026

Changes in this version

+ const AgentCallIdVariable

+ const DefaultExecutionBudget

+ const DefaultMaxIterations

type Command

+ StartElements []int32

+ ToolCalls []model.ToolCall

type ProcessingContext

+ func (c *ProcessingContext) ChildInstancesOf(callElKey uint64) []uint64

type Processor

+ func (p *Processor) CompleteJobWithToolCalls(jobKey uint64, toolCalls []model.ToolCall, outputs ...model.VariableValue)

+ func (p *Processor) Partition() uint16

+ func (p *Processor) SetExecutionBudget(steps int32)

+ func (p *Processor) SetMaxIterations(n int)

v0.4.0

Aug 26, 2026

v0.3.0

Aug 21, 2026

Changes in this version

+ const LoopCounterVariable

type Command

+ LeaseFor int64

+ Manual bool

+ Reason string

+ type MigrationElement struct

+ AttachedToKey uint64

+ BpmnElementType uint8

+ ElementId int32

+ EventGatewayKey uint64

+ FlowScopeKey uint64

+ Key uint64

+ MultiInstance uint8

+ func MigrationElementOf(key uint64, ei *model.ElementInstanceValue) MigrationElement

+ type MigrationProblem struct

+ ElementID string

+ ElementInstanceKey uint64

+ Reason string

+ func ValidateMigration(from, to *compiler.CompiledProcess, live []MigrationElement, ...) []MigrationProblem

type ProcessingContext

+ func (c *ProcessingContext) AppendMigrationEvent(v model.ProcessMigrationValue)

+ func (c *ProcessingContext) AppendOperatorActionEvent(v model.OperatorActionValue)

type Processor

+ func (p *Processor) ActivateJob(jobKey uint64, worker string, leaseFor int64)

+ func (p *Processor) CompleteJobManually(jobKey uint64, actor, reason string, outputs ...model.VariableValue)

+ func (p *Processor) MigrateInstance(v model.ProcessMigrationValue, actor, reason string)

v0.2.0

Aug 19, 2026

Changes in this version

+ var BuildVersion string

+ type BatchStats struct

+ Commands int

+ CommitSeconds float64

+ Events int

+ Jobs JobStats

+ QueueDepth int

+ SyncSeconds float64

+ type JobStats struct

+ Canceled int

+ Completed int

+ Created int

+ Failed int

+ type Metrics interface

+ BatchCommitted func(BatchStats)

+ CommitFailed func()

+ SyncFailed func()

type Processor

+ func (p *Processor) Checkpoint(root string) (uint64, error)

+ func (p *Processor) CompactLog(checkpointRoot string, consumerLimits []uint64) (int, error)

+ func (p *Processor) LastRecovery() RecoveryStats

+ func (p *Processor) ProcessActive(defKey uint64) bool

+ func (p *Processor) PurgeInstance(piKey uint64, pi *model.ProcessInstanceValue)

+ func (p *Processor) RecoverFrom(checkpointRoot string) error

+ func (p *Processor) SetMetrics(m Metrics)

+ func (p *Processor) SetProcessActive(defKey uint64, active bool)

+ type RecoveryStats struct

+ Done bool

+ Replayed int

+ Seconds float64

v0.1.0

Aug 11, 2026

Changes in this version

+ type CallTargetOverride struct

+ Disabled bool

+ PinnedDefKey uint64

+ RedirectProcessId string

+ type Clock interface

+ Now func() int64

+ type Command struct

+ Actor string

+ Decision *model.DecisionEvaluationValue

+ Intent model.Intent

+ Key uint64

+ RetryBackoff int64

+ SourcePos uint64

+ StartVars []model.VariableValue

+ Value inflightValue

+ ValueType model.ValueType

+ type ProcessingContext struct

+ func (c *ProcessingContext) ActiveChildren(scope uint64) int32

+ func (c *ProcessingContext) AppendCompensableEvent(intent model.Intent, v model.CompensableValue)

+ func (c *ProcessingContext) AppendCreateChildInstanceCommand(defKey uint64, vars []model.VariableValue, parentElementKey uint64)

+ func (c *ProcessingContext) AppendCreateInstanceCommand(defKey uint64, vars []model.VariableValue, correlationKey string)

+ func (c *ProcessingContext) AppendDataObjectEvent(intent model.Intent, v model.DataObjectValue)

+ func (c *ProcessingContext) AppendDecisionEvaluationEvent(v model.DecisionEvaluationValue)

+ func (c *ProcessingContext) AppendElementCommand(key uint64, intent model.Intent, v model.ElementInstanceValue)

+ func (c *ProcessingContext) AppendElementEvent(key uint64, intent model.Intent, v model.ElementInstanceValue)

+ func (c *ProcessingContext) AppendInboundDeliveryEvent(v model.InboundDeliveryValue)

+ func (c *ProcessingContext) AppendIncidentEvent(intent model.Intent, v model.IncidentValue)

+ func (c *ProcessingContext) AppendJobEvent(key uint64, intent model.Intent, v model.JobValue)

+ func (c *ProcessingContext) AppendMessageFlowEvent(v model.MessageFlowValue)

+ func (c *ProcessingContext) AppendMessageSubscriptionEvent(key uint64, intent model.Intent, v model.MessageSubscriptionValue)

+ func (c *ProcessingContext) AppendProcessInstanceCommand(key uint64, intent model.Intent, v model.ProcessInstanceValue)

+ func (c *ProcessingContext) AppendProcessInstanceEvent(key uint64, intent model.Intent, v model.ProcessInstanceValue)

+ func (c *ProcessingContext) AppendSignalSubscriptionEvent(key uint64, intent model.Intent, v model.SignalSubscriptionValue)

+ func (c *ProcessingContext) AppendTimerEvent(key uint64, intent model.Intent, v model.TimerValue)

+ func (c *ProcessingContext) AppendVariableAuditEvent(v model.VariableAuditValue)

+ func (c *ProcessingContext) AppendVariableEvent(intent model.Intent, v model.VariableValue)

+ func (c *ProcessingContext) ElementInstancesOnNode(procKey uint64, elementId int32) []uint64

+ func (c *ProcessingContext) ForEachActiveProcessInstance(fn func(piKey uint64, pi *model.ProcessInstanceValue))

+ func (c *ProcessingContext) ForEachElementInstance(procKey uint64, fn func(elKey uint64))

+ func (c *ProcessingContext) ForEachStartTimer(fn func(key uint64, v model.TimerValue))

+ func (c *ProcessingContext) GetDataObject(scope uint64, name string) *model.DataObjectValue

+ func (c *ProcessingContext) GetElementInstance(key uint64) *model.ElementInstanceValue

+ func (c *ProcessingContext) GetIncident(elKey uint64) *model.IncidentValue

+ func (c *ProcessingContext) GetJob(key uint64) *model.JobValue

+ func (c *ProcessingContext) GetProcessInstance(key uint64) *model.ProcessInstanceValue

+ func (c *ProcessingContext) GetVariable(scope uint64, name string) *model.VariableValue

+ func (c *ProcessingContext) IsCanceling(txKey uint64) bool

+ func (c *ProcessingContext) JobOfElement(elKey uint64) (uint64, bool)

+ func (c *ProcessingContext) NewKey() uint64

+ func (c *ProcessingContext) NotifyJobAvailable(jobType int32)

+ func (c *ProcessingContext) Now() int64

+ func (c *ProcessingContext) ResolveVariable(startScope uint64, name string) *model.VariableValue

+ func (c *ProcessingContext) TokenCanStillReach(procKey uint64, nodeId int32, reaches map[int32]bool) bool

+ func (c *ProcessingContext) VariablesOfScope(scope uint64, fn func(v model.VariableValue))

+ type Processor struct

+ func New(partition uint16, log *wal.Log, store *state.Store, clock Clock) *Processor

+ func (p *Processor) ArmStartTimers(defKey uint64)

+ func (p *Processor) AssignJob(jobKey uint64, assignee string)

+ func (p *Processor) CancelInstance(piKey uint64)

+ func (p *Processor) ClearCallTargetOverride(calledProcessId string)

+ func (p *Processor) CompleteJob(jobKey uint64, outputs ...model.VariableValue)

+ func (p *Processor) CompleteJobWithDecision(jobKey uint64, decision *model.DecisionEvaluationValue, ...)

+ func (p *Processor) CreateInstance(defKey uint64, startVars ...model.VariableValue)

+ func (p *Processor) Deploy(cp *compiler.CompiledProcess)

+ func (p *Processor) FailJob(jobKey uint64, retries int32, message string, backoff int64)

+ func (p *Processor) PublishInbound(sourceID string, seq uint64, name, correlationKey string, ...)

+ func (p *Processor) PublishMessage(name, correlationKey string, vars ...model.VariableValue)

+ func (p *Processor) Recover() error

+ func (p *Processor) ResolveIncident(elementKey uint64, retries int32)

+ func (p *Processor) RunUntilIdle() error

+ func (p *Processor) SetCallTargetOverride(calledProcessId string, ov CallTargetOverride)

+ func (p *Processor) SetJobNotifier(fn func(jobType int32))

+ func (p *Processor) SetVariables(piKey, scopeKey uint64, actor string, vars ...model.VariableValue)

+ func (p *Processor) ThrowJobError(jobKey uint64, errorCode string)

+ func (p *Processor) TickTimers() error

+ func (p *Processor) TriggerDueTimers() error

+ func (p *Processor) Undeploy(defKey uint64)

+ type SystemClock struct

+ func (SystemClock) Now() int64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL