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.

stage identifies the command-processing stage, isLastProjection marks the final projection, and commands contains command IDs sent by a saga as a result of this processing.

See also

SimpleWaitSignal

Inheritors

SimpleWaitSignal

Properties

abstract val aggregateId: AggregateId

aggregateVersion

abstract val aggregateVersion: Int?

open val bindingErrors: List<BindingError>

abstract val commandId: String

abstract val commands: List<String>

List of command IDs sent by Saga

abstract val errorCode: String

abstract val errorMsg: String

abstract override val function: FunctionInfoData

abstract override val id: String

isLastProjection

abstract val isLastProjection: Boolean

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.

abstract val signalTime: Long

abstract val stage: CommandStage

open val succeeded: Boolean

abstract val waitCommandId: String

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

Functions

abstract fun copyResult(result: Map<String, Any>): WaitSignal

Creates a copy of this signal with updated result data.

fun AggregateIdCapable.toGroupKey(parallelism: Int = DEFAULT_PARALLELISM): Int

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

fun WaitSignal.toResult(commandMessage: CommandMessage<*>): CommandResult

Converts a WaitSignal to a CommandResult.