wow-core/me.ahoo.wow.command.wait/WaitSignal

WaitSignal

interface WaitSignal : Identifier, WaitCommandIdCapable, CommandId, AggregateIdCapable, NullableAggregateVersionCapable, ErrorInfo, SignalTimeCapable, CommandResultCapable, FunctionInfoCapable<FunctionInfoData>

Signal representing a command processing stage completion.

WaitSignal contains all information about a specific stage in command processing, including success/failure status, aggregate state, and any generated commands.

See also

Inheritors

Properties

Link copied to clipboard
abstract val aggregateId: AggregateId
Link copied to clipboard
abstract val aggregateVersion: Int?
Link copied to clipboard
Link copied to clipboard
abstract val commandId: String
Link copied to clipboard
abstract val commands: List<String>

List of command IDs sent by Saga

Link copied to clipboard
abstract val errorCode: String
Link copied to clipboard
abstract val errorMsg: String
Link copied to clipboard
abstract override val function: FunctionInfoData
Link copied to clipboard
abstract val id: String
Link copied to clipboard
abstract val isLastProjection: Boolean

whether this is the final projection for the command

Link copied to clipboard
abstract val result: Map<String, Any>

The result of the command execution as a map. Keys represent result field names, values are the corresponding data.

Link copied to clipboard
abstract val signalTime: Long
Link copied to clipboard
abstract val stage: CommandStage

the command processing stage this signal represents

Link copied to clipboard
open val succeeded: Boolean
Link copied to clipboard
abstract val waitCommandId: String

The unique identifier for the wait command. This ID is used to match wait strategies with command processing results.

Functions

Link copied to clipboard
abstract fun copyResult(result: Map<String, Any>): WaitSignal

Creates a copy of this signal with updated result data.

Link copied to clipboard
fun AggregateIdCapable.toGroupKey(parallelism: Int = DEFAULT_PARALLELISM): Int

Computes a grouping key for parallel processing based on the aggregate ID.

Link copied to clipboard
fun WaitSignal.toResult(commandMessage: CommandMessage<*>): CommandResult

Converts a WaitSignal to a CommandResult.

Generated by Dokka
© 2025 Copyright