公开符号 24

class

RunCompletionOutcome

L49
class RunCompletionOutcome(StrEnum)

Caller-authored terminal intent for one Run.

class

FinalizerStatus

L57
class FinalizerStatus(StrEnum)

Portable outcome reported by one data-consumer finalizer.

class

RunLifecycleContractError

L66
class RunLifecycleContractError(RuntimeError)

Stable base error for completion/finalizer protocol violations.

class

RunCompletionConflictError

L70
class RunCompletionConflictError(RunLifecycleContractError)

An idempotency key was reused with different completion content.

class

FinalizerRegistrationError

L74
class FinalizerRegistrationError(RunLifecycleContractError)

A finalizer registration is late, unauthorized, or conflicting.

class

FinalizerResultError

L78
class FinalizerResultError(RunLifecycleContractError)

A finalizer result is early, mismatched, or conflicting.

class

RunCompletionRequest

L83
class RunCompletionRequest(object)

Idempotent request to complete the current Run. Plugin identity is intentionally absent. Core replaces caller identity with the scoped identity attached to ``run.lifecycle``.

字段类型默认值
request_idstr
outcomeRunCompletionOutcome | str
reason_codestr
summaryFrozenDict[str, object] | Mapping[str, object]field(default_factory=FrozenDict)
schemastrfield(default='fastsim-run-completion-request/1', init=False)
class

RunCompletionReceipt

L110
class RunCompletionReceipt(object)

Admission result. It never contains another plugin's private summary.

字段类型默认值
request_idstr
requester_instancestr
completion_sequenceint
wonbool
winning_instancestr | None
winning_sequenceint | None
schemastrfield(default='fastsim-run-completion-receipt/1', init=False)
class

RunCompletionWinner

L144
class RunCompletionWinner(object)

当前源码未提供公开 docstring。

字段类型默认值
request_idstr
requester_instancestr
completion_sequenceint
outcomeRunCompletionOutcome | str
reason_codestr
summaryFrozenDict[str, object] | Mapping[str, object]
schemastrfield(default='fastsim-run-completion-winner/1', init=False)
class

FinalizerRegistrationRequest

L173
class FinalizerRegistrationRequest(object)

当前源码未提供公开 docstring。

字段类型默认值
finalizer_idstr
requiredbool
requested_timeout_sfloat
schemastrfield(default='fastsim-plugin-finalizer-registration/1', init=False)
class

FinalizerResult

L191
class FinalizerResult(object)

当前源码未提供公开 docstring。

字段类型默认值
finalizer_idstr
statusFinalizerStatus | str
reason_codestr
summaryFrozenDict[str, object] | Mapping[str, object]field(default_factory=FrozenDict)
output_commit_receiptstuple[RunOutputCommitReceipt, ...]()
schemastrfield(default='fastsim-plugin-finalizer-result/1', init=False)
class

FinalizerCompletionReceipt

L216
class FinalizerCompletionReceipt(object)

当前源码未提供公开 docstring。

字段类型默认值
finalizer_idstr
instancestr
result_sequenceint
acceptedboolTrue
schemastrfield(default='fastsim-plugin-finalizer-completion-receipt/1', init=False)
class

FinalizerSnapshot

L234
class FinalizerSnapshot(object)

当前源码未提供公开 docstring。

字段类型默认值
finalizer_idstr
instancestr
requiredbool
requested_timeout_sfloat
effective_timeout_sfloat
activebool
resultFinalizerResult | None
schemastrfield(default='fastsim-plugin-finalizer-snapshot/1', init=False)
class

TerminalSemanticCut

L267
class TerminalSemanticCut(object)

Terminal fences for each selected globally ordered source. ``observation_sequence`` identifies the active mutually exclusive observation capture lane: legacy snapshot/barrier sequence when no locked explicit demand exists, or channel/barrier ``capture_sequence`` when it does. Consumers must not assume it is always a snapshot sequence.

字段类型默认值
run_idstr
record_sequenceint
lifecycle_sequenceint
control_audit_sequenceint
plugin_event_sequenceint
observation_sequenceint
media_sequenceint0
fluid_audit_sequenceint0
render_state_sequenceint0
schemastrfield(default='fastsim-terminal-semantic-cut/1', init=False)
class

RunFinalOutcome

L305
class RunFinalOutcome(object)

当前源码未提供公开 docstring。

字段类型默认值
outcomeRunCompletionOutcome | str
reason_codestr
stop_reasonstr
degradedbool
sourcestr
required_finalizer_failurestuple[str, ...]()
optional_finalizer_failurestuple[str, ...]()
schemastrfield(default='fastsim-run-final-outcome/1', init=False)
class

RunCompletionSnapshot

L364
class RunCompletionSnapshot(object)

当前源码未提供公开 docstring。

字段类型默认值
statestr
winnerRunCompletionWinner | None
finalizerstuple[FinalizerSnapshot, ...]
terminal_cutTerminalSemanticCut | None
final_outcomeRunFinalOutcome | None
schemastrfield(default='fastsim-run-completion-snapshot/1', init=False)
class

RunTerminalPolicy

L397
class RunTerminalPolicy(object)

Trusted launch policy; never compiled from scenario or plugin config.

字段类型默认值
global_deadline_sfloat120.0
per_consumer_cap_sfloat60.0
cleanup_reserve_sfloat10.0
class

ScopedFinalizerHandle

L412
class ScopedFinalizerHandle(Protocol)

Process-local finalizer completion capability.

finalizer_id
ScopedFinalizerHandle.finalizer_id(self) -> str

当前源码未提供公开 docstring。

effective_timeout_s
ScopedFinalizerHandle.effective_timeout_s(self) -> float

当前源码未提供公开 docstring。

complete
ScopedFinalizerHandle.complete(self, result: FinalizerResult) -> FinalizerCompletionReceipt

当前源码未提供公开 docstring。

class

ScopedControlAuditSubscription

L425
class ScopedControlAuditSubscription(Protocol)

Bounded, revocable subscription to the portable control audit stream.

closed
ScopedControlAuditSubscription.closed(self) -> bool

当前源码未提供公开 docstring。

queued_items
ScopedControlAuditSubscription.queued_items(self) -> int

当前源码未提供公开 docstring。

queued_bytes
ScopedControlAuditSubscription.queued_bytes(self) -> int

当前源码未提供公开 docstring。

dropped_items
ScopedControlAuditSubscription.dropped_items(self) -> int

当前源码未提供公开 docstring。

dropped_bytes
ScopedControlAuditSubscription.dropped_bytes(self) -> int

当前源码未提供公开 docstring。

get
ScopedControlAuditSubscription.get(self, timeout: float | None=None) -> ControlAuditStreamItem

当前源码未提供公开 docstring。

get_async
async ScopedControlAuditSubscription.get_async(self, timeout: float | None=None) -> ControlAuditStreamItem

当前源码未提供公开 docstring。

close
ScopedControlAuditSubscription.close(self) -> None

当前源码未提供公开 docstring。

class

ControlAuditService

L451
class ControlAuditService(Protocol)

Capability-scoped access to authored and applied control evidence.

service_id
ControlAuditService.service_id(self) -> str

当前源码未提供公开 docstring。

subscribe
ControlAuditService.subscribe(self, capacity: int=1024, max_item_bytes: int=1048576, overload: ControlAuditOverloadPolicy | str=ControlAuditOverloadPolicy.FAIL_RUN) -> ScopedControlAuditSubscription

当前源码未提供公开 docstring。

class

RunLifecycleSubscription

L466
class RunLifecycleSubscription(Protocol)

Bounded, revocable stream of portable run-lifecycle envelopes.

closed
RunLifecycleSubscription.closed(self) -> bool

当前源码未提供公开 docstring。

dropped
RunLifecycleSubscription.dropped(self) -> int

当前源码未提供公开 docstring。

get
RunLifecycleSubscription.get(self, timeout: float | None=None) -> object

当前源码未提供公开 docstring。

get_async
async RunLifecycleSubscription.get_async(self, timeout: float | None=None) -> object

当前源码未提供公开 docstring。

close
RunLifecycleSubscription.close(self) -> None

当前源码未提供公开 docstring。

class

RunLifecycleService

L483
class RunLifecycleService(Protocol)

Scoped lifecycle view plus completion/finalizer admission.

service_id
RunLifecycleService.service_id(self) -> str

当前源码未提供公开 docstring。

snapshot
RunLifecycleService.snapshot(self) -> object

当前源码未提供公开 docstring。

request_completion
RunLifecycleService.request_completion(self, request: RunCompletionRequest) -> RunCompletionReceipt

当前源码未提供公开 docstring。

register_finalizer
RunLifecycleService.register_finalizer(self, request: FinalizerRegistrationRequest) -> ScopedFinalizerHandle

当前源码未提供公开 docstring。

subscribe
RunLifecycleService.subscribe(self, capacity: int=64, max_item_bytes: int=1048576, *, replay_history: bool=False, from_record_sequence: int | None=None) -> RunLifecycleSubscription

当前源码未提供公开 docstring。

class

PluginEventSubscriptionService

L564
class PluginEventSubscriptionService(Protocol)

Bounded, revocable stream of portable plugin-event envelopes.

closed
PluginEventSubscriptionService.closed(self) -> bool

当前源码未提供公开 docstring。

dropped
PluginEventSubscriptionService.dropped(self) -> int

当前源码未提供公开 docstring。

get
PluginEventSubscriptionService.get(self, timeout: float | None=None) -> object

当前源码未提供公开 docstring。

get_async
async PluginEventSubscriptionService.get_async(self, timeout: float | None=None) -> object

当前源码未提供公开 docstring。

close
PluginEventSubscriptionService.close(self) -> None

当前源码未提供公开 docstring。

class

EventSubscribeService

L581
class EventSubscribeService(Protocol)

Topic-filtered event view with optional ordered-history bootstrap.

service_id
EventSubscribeService.service_id(self) -> str

当前源码未提供公开 docstring。

subscribe
EventSubscribeService.subscribe(self, capacity: int=64, max_item_bytes: int=1048576, overload: str='drop_oldest', topics: tuple[str, ...]=(), *, replay_history: bool=False, from_record_sequence: int | None=None) -> PluginEventSubscriptionService

当前源码未提供公开 docstring。