Wow-Compensation
  1. compensation.execution_failed
Wow-Compensation
  • wow
    • The receiving endpoint of the wait signal
    • Unified Sending Endpoint For Command Messages
    • Get Wow Metadata
    • Generate Global ID
    • Generate BI Sync Script
  • compensation.execution_failed
    • create_execution_failed
      POST
    • prepare_compensation
      PUT
    • force_prepare_compensation
      PUT
    • apply_execution_success
      PUT
    • apply_execution_failed
      PUT
    • apply_retry_spec
      PUT
    • change_function
      PUT
    • mark_recoverable
      PUT
    • Delete aggregate
      DELETE
    • Recover deleted aggregate
      PUT
    • Get Aggregate Tracing
      GET
    • Load State Aggregate
      GET
    • Load Versioned State Aggregate
      GET
    • Load Time Based State Aggregate
      GET
    • Get Snapshot
      GET
    • Regenerate Aggregate Snapshot
      PUT
    • Batch Regenerate Aggregate Snapshot
      PUT
    • Count Snapshot
      POST
    • List Query Snapshot
      POST
    • List Query Snapshot State
      POST
    • Paged Query Snapshot
      POST
    • Paged Query Snapshot State
      POST
    • Single Snapshot
      POST
    • Single Snapshot State
      POST
    • Load Event Stream
      GET
    • List Query Event Stream
      POST
    • Paged Query Event Stream
      POST
    • Count Event Stream
      POST
    • Event Compensate
      PUT
    • Resend State Event
      POST
  1. compensation.execution_failed

Load Event Stream

GET
/execution_failed/{id}/event/{headVersion}/{tailVersion}
compensation.execution_failed

请求参数

Path 参数
id
string 
必需
aggregate id
headVersion
integer <int32>
必需
The head version of the aggregate.
示例值:
1
tailVersion
integer <int32>
必需
The tail version of the aggregate.
示例值:
2147483647

示例代码

Shell
JavaScript
Java
Swift
Go
PHP
Python
HTTP
C
C#
Objective-C
Ruby
OCaml
Dart
R
请求示例请求示例
Shell
JavaScript
Java
Swift
curl --location --request GET 'http://dev-cn.your-api-server.com/execution_failed//event//'

返回响应

🟢200成功
application/json
Headers
Wow-Error-Code
string 
可选
Body
array of:
id
string 
必需
The ID of the domain event stream.
>= 1 字符
contextName
string 
必需
The name of the context to which the domain event stream belongs
>= 1 字符
aggregateName
string 
必需
The name of the aggregate to which the domain event stream belongs
>= 1 字符
header
object 
可选
message header
user_agent
string 
可选
user agent
remote_ip
string 
remote ip
可选
trace_id
string 
trace id
可选
command_operator
string 
可选
command operator
local_first
boolean 
可选
local first
command_wait_endpoint
string <url>
可选
command wait endpoint
command_wait_stage
enum<string> 
可选
枚举值:
SENTPROCESSEDSNAPSHOTPROJECTEDEVENT_HANDLEDSAGA_HANDLED
默认值:
PROCESSED
额外字段
integer  | number  | string  | boolean 
可选
tenantId
string 
必需
The tenant id of the aggregate
>= 1 字符
aggregateId
string 
必需
The id of the aggregate
>= 1 字符
ownerId
string 
必需
The owner ID of the aggregate resource
默认值:
commandId
string 
可选
The ID of the command message.
>= 1 字符
requestId
string 
可选
The request ID of the command message, which is used to check the idempotency of the command message
>= 1 字符
version
integer <int32>
必需
The version of the domain event stream
body
array [anyOf] 
必需
A list of domain events for the domain event stream
>= 1 items
object 
compensation_prepared
可选
The body of the domain event
object 
execution_failed_applied
可选
The body of the domain event
object 
execution_failed_created
可选
The body of the domain event
object 
execution_success_applied
可选
The body of the domain event
object 
function_changed
可选
The body of the domain event
object 
recoverable_marked
可选
The body of the domain event
object 
retry_spec_applied
可选
The body of the domain event
createTime
integer <int64>
必需
The time when the domain event stream was created
示例
[
    {
        "id": "string",
        "contextName": "string",
        "aggregateName": "string",
        "header": {
            "user_agent": "string",
            "remote_ip": "string",
            "trace_id": "string",
            "command_operator": "string",
            "local_first": true,
            "command_wait_endpoint": "string",
            "command_wait_stage": "PROCESSED"
        },
        "tenantId": "string",
        "aggregateId": "string",
        "ownerId": "",
        "commandId": "string",
        "requestId": "string",
        "version": 0,
        "body": [
            {
                "id": "string",
                "name": "compensation_prepared",
                "revision": "0.0.1",
                "bodyType": "me.ahoo.wow.compensation.api.CompensationPrepared",
                "body": {
                    "eventId": {
                        "aggregateId": {
                            "contextName": "string",
                            "aggregateName": "string",
                            "tenantId": "(0)",
                            "aggregateId": "string"
                        },
                        "id": "string",
                        "version": 0,
                        "initialized": true,
                        "isInitialVersion": true
                    },
                    "function": {
                        "contextName": "string",
                        "functionKind": "COMMAND",
                        "name": "string",
                        "processorName": "string"
                    },
                    "retryState": {
                        "nextRetryAt": 0,
                        "retries": 0,
                        "retryAt": 0,
                        "timeoutAt": 0
                    }
                }
            }
        ],
        "createTime": 0
    }
]
上一页
Single Snapshot State
下一页
List Query Event Stream
Built with