Load Event Stream - Wow-Compensation

请求参数

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

返回响应

🟢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
  }
]