runtimeorchestration

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

type AuditExporter interface {
	Export(context.Context, runtimestate.AuditFactRecord) error
}

type Command struct {
	Tenant    string
	OutboxID  string
	SessionID string
	Kind      CommandKind
	Sequence  uint64
}

type CommandKind string

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

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

type InvocationSchedule struct {
	Tenant      string
	SessionID   string
	TurnID      string
	OperationID runtimestate.OperationID
}

type ProcessConfig struct {
	DatabaseDSN         string
	TemporalEndpoint    string
	TemporalToken       string
	Namespace           string
	TaskQueue           string
	PayloadBlobEndpoint string
	PayloadBlobBucket   string
	PayloadBlobPrefix   string
	PayloadAccessKey    string
	PayloadSecretKey    string
	// AuditSinkEndpoint enables optional delivery of already-committed audit
	// facts. It must be an explicit HTTPS endpoint; the worker never treats it
	// as a fail-closed state mutation boundary.
	AuditSinkEndpoint string
	AuditSinkTimeout  time.Duration
	// InvocationScheduled observes a committed model invocation intent. It is
	// an optional local process observer; it has no authority to alter durable
	// dispatch and must return promptly.
	InvocationScheduled func(InvocationSchedule)
}

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

type PublisherConfig struct {
	Store     runtimestate.RuntimeStateStore
	Tenants   runtimestate.OutboxTenantSource
	Compiler  *runtimestate.Compiler
	Planner   *runtimestate.RuntimeStatePlanner
	Clock     clock.Clock
	Publisher SessionWorkflowPublisher
	// AuditExporter is optional because the base runtime does not claim a
	// mandatory external audit sink. When configured, its delivery is fenced by
	// the exact committed audit fact and the same outbox lease as the route.
	AuditExporter AuditExporter
	Claimer       string
}

type SessionStart struct {
	Tenant    string
	SessionID string
}

type SessionWorkflowPublisher interface {
	StartSession(context.Context, SessionStart) error
	SignalSession(context.Context, SessionStart, Command) error
}

type StateDispatcher interface {
	Dispatch(context.Context, Command) error
}

type Wait func(context.Context, time.Duration) error

type WorkflowInput struct {
	SessionID     string
	NextSequence  uint64
	Dispatched    uint32
	ContinueAfter uint32
}