Paged Query Event Stream - Wow-Compensation

请求参数

Body 参数application/json

condition

object (wow.api.query.Condition)

必需

children

array[object (wow.api.query.Condition) {5}]

可选

默认值:

[]

field

string

可选

operator

enum<string>

必需

枚举值:

ANDORNORIDIDSAGGREGATE_IDAGGREGATE_IDSTENANT_IDOWNER_IDDELETEDALLEQNEGTLTGTELTECONTAINSINNOT_INBETWEENALL_INSTARTS_WITHENDS_WITHELEM_MATCHNULLNOT_NULLTRUEFALSEEXISTSTODAYBEFORE_TODAYTOMORROWTHIS_WEEKNEXT_WEEKLAST_WEEKTHIS_MONTHLAST_MONTHRECENT_DAYSEARLIER_DAYSRAW

options

object (compensation.StringObjectMap)

可选

value

可选

pagination

object (wow.api.query.Pagination)

可选

index

integer <int32>

必需

默认值:

1

size

integer <int32>

必需

默认值:

10

projection

object (wow.api.query.Projection)

可选

exclude

array[string]

可选

默认值:

[]

include

array[string]

可选

默认值:

[]

sort

array[object (wow.api.query.Sort) {2}]

可选

默认值:

[]

direction

enum<string>

必需

枚举值:

ASCDESC

field

string

必需

示例

{
    "condition": {
        "children": "[]",
        "field": "string",
        "operator": "AND",
        "options": {},
        "value": null
    },
    "pagination": {
        "index": "1",
        "size": "10"
    },
    "projection": {
        "exclude": "[]",
        "include": "[]"
    },
    "sort": "[]"
}

示例代码

Shell

JavaScript

Java

Swift

Go

PHP

Python

HTTP

C

C#

Objective-C

Ruby

OCaml

Dart

R

curl --location --request POST 'http://dev-cn.your-api-server.com/execution_failed/event/paged' \
--header 'Content-Type: application/json' \
--data-raw '{
    "condition": {
        "children": "[]",
        "field": "string",
        "operator": "AND",
        "options": {},
        "value": null
    },
    "pagination": {
        "index": "1",
        "size": "10"
    },
    "projection": {
        "exclude": "[]",
        "include": "[]"
    },
    "sort": "[]"
}'

返回响应

🟢200成功

application/json

Headers

Wow-Error-Code

string

可选

Body

list

array[object (compensation.ExecutionFailedAggregatedDomainEventStream) {12}]

必需

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

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

createTime

integer <int64>

必需

The time when the domain event stream was created

total

integer <int64>

必需

示例

{
    "list": [
        {
            "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
                        },
                        "function": {
                            "contextName": "string",
                            "functionKind": "COMMAND",
                            "name": "string",
                            "processorName": "string"
                        },
                        "retryState": {
                            "nextRetryAt": 0,
                            "retries": 0,
                            "retryAt": 0,
                            "timeoutAt": 0
                        }
                    }
                }
            ],
            "createTime": 0
        }
    ],
    "total": 0
}