baiyue-lastleg/event-bridge-service/src/main/java/com/baiyue/eventbridge/domain/BridgeInbox.java

package com.baiyue.eventbridge.domain;

import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.time.LocalDateTime;
import java.time.Instant;

/**
 * 事件桥入站幂等记录。
 */
@Data
@TableName("bridge_inbox")
public class BridgeInbox {
    @TableId
    private String eventId;
    private String idempotencyKey;
    private String eventType;
    private Integer eventVersion;
    private String sourceRegion;
    private String targetRegion;
    private String tenantId;
    private String aggregateType;
    private String aggregateId;
    private Long aggregateVersion;
    private Long handoverVersion;
    private String traceId;
    private String correlationId;
    private String causationId;
    private Instant occurredAt;
    private String payloadHash;
    private String payloadJson;
    private String status;
    private LocalDateTime receivedAt;
}