wow-compensation-api/me.ahoo.wow.compensation.api

Package-level declarations

Types

@Order(value = 4)

@CommandRoute(appendIdPath = CommandRoute.AppendPath.ALWAYS)

data class ApplyExecutionFailed(val id: String, val error: ErrorDetails, val executeAt: Long, val recoverable: RecoverableType = RecoverableType.UNKNOWN) : Identifier, IRecoverable, ExecutionFailedErrorInfo

ApplyExecutionSuccess

@Order(value = 3)

@CommandRoute(appendIdPath = CommandRoute.AppendPath.ALWAYS)

data class ApplyExecutionSuccess(val id: String, val executeAt: Long) : Identifier, ExecuteAt

ApplyRetrySpec

@Order(value = 5)

@CommandRoute(appendIdPath = CommandRoute.AppendPath.ALWAYS)

data class ApplyRetrySpec(val id: String, val maxRetries: Int, val minBackoff: Int, val executionTimeout: Int) : Identifier, IRetrySpec

ChangeFunction

@Order(value = 6)

@CommandRoute(appendIdPath = CommandRoute.AppendPath.ALWAYS)

data class ChangeFunction(val id: String, val functionKind: FunctionKind, val processorName: String, val contextName: String, val name: String) : Identifier, FunctionInfo

CompensationPrepared

data class CompensationPrepared(val eventId: EventId, val function: FunctionInfoData, val retryState: RetryState) : IRetryState

CreateExecutionFailed

@Order(value = -2147483648)

@CreateAggregate

data class CreateExecutionFailed(val eventId: EventId, val function: FunctionInfoData, val error: ErrorDetails, val executeAt: Long, val retrySpec: RetrySpec? = null, val recoverable: RecoverableType = RecoverableType.UNKNOWN) : ExecutionFailedInfo

ErrorDetails

data class ErrorDetails(val errorCode: String, val errorMsg: String, val stackTrace: String, val bindingErrors: List<BindingError> = emptyList()) : ErrorInfo

EventId

data class EventId(val id: String, val aggregateId: AggregateId, val version: Int) : Identifier, Version, AggregateIdCapable

ExecuteAt

interface ExecuteAt

ExecutionFailedApplied

data class ExecutionFailedApplied(val error: ErrorDetails, val executeAt: Long, val recoverable: RecoverableType = RecoverableType.UNKNOWN) : IRecoverable, ExecutionFailedErrorInfo

ExecutionFailedCreated

data class ExecutionFailedCreated(val eventId: EventId, val function: FunctionInfoData, val error: ErrorDetails, val executeAt: Long, val retryState: RetryState, val retrySpec: RetrySpec, val recoverable: RecoverableType = RecoverableType.UNKNOWN) : ExecutionFailedInfo, IRetryState

ExecutionFailedErrorInfo

interface ExecutionFailedErrorInfo : ExecuteAt

ExecutionFailedInfo

interface ExecutionFailedInfo : IRecoverable, ExecutionFailedErrorInfo

ExecutionFailedStatus

enum ExecutionFailedStatus : Enum<ExecutionFailedStatus>

ExecutionSuccessApplied

data class ExecutionSuccessApplied(val executeAt: Long) : ExecuteAt

ForcePrepareCompensation

@Order(value = 2)

@CommandRoute(appendIdPath = CommandRoute.AppendPath.ALWAYS)

data class ForcePrepareCompensation(val id: String) : Identifier

FunctionChanged

data class FunctionChanged(val name: String, val processorName: String, val contextName: String, val functionKind: FunctionKind) : FunctionInfo

IExecutionFailedState

interface IExecutionFailedState : Identifier, ExecutionFailedInfo, IRetryState

IRecoverable

interface IRecoverable

IRetrySpec

interface IRetrySpec

IRetryState

interface IRetryState

MarkRecoverable

@Order(value = 7)

@CommandRoute(appendIdPath = CommandRoute.AppendPath.ALWAYS)

data class MarkRecoverable(val id: String, val recoverable: RecoverableType) : Identifier, IRecoverable

PrepareCompensation

@Order(value = 1)

@CommandRoute(appendIdPath = CommandRoute.AppendPath.ALWAYS)

data class PrepareCompensation(val id: String) : Identifier

RecoverableMarked

data class RecoverableMarked(val recoverable: RecoverableType) : IRecoverable

RetrySpec

data class RetrySpec(val maxRetries: Int, val minBackoff: Int, val executionTimeout: Int) : IRetrySpec, Materialized

RetrySpecApplied

data class RetrySpecApplied(val maxRetries: Int, val minBackoff: Int, val executionTimeout: Int) : IRetrySpec

RetryState

data class RetryState(val retries: Int, val retryAt: Long, val timeoutAt: Long, val nextRetryAt: Long)