이벤트 소싱

CREATE TABLE journals (
│ -- 이벤트가 구분되는 개체의 ID
│ aggregate_id VARCHAR(255) NOT NULL,
│ -- 이벤트 번호 (1부터 시작)
│ sequence_number INT8 NOT NULL,
│ -- 이벤트 타입 (어떤 객체로 역직렬화할지 결정)
│ manifest VARCHAR(255) NOT NULL,
│ -- protobuf 이벤트 바이너리
│ journal BYTEA NOT NULL,
│ -- 이벤트가 만들어진 시간
│ created_at TIMESTAMP NOT NULL,
│
│ PRIMARY KEY (aggregate_id, sequence_number)
);

CREATE TABLE snapshots (
│ -- 이벤트가 구분되는 개체의 ID
│ aggregate_id VARCHAR(255) NOT NULL,
│ -- 스냅샷이 반영하고 있는 마지막 이벤트 번호
│ -- 예시) 100일 경우 100번 째 이벤트까지 리플레이한 상태
│ sequence_number INT8 NOT NULL,
│ -- 이벤트 타입 (어떤 객체로 역직렬화할지 결정)
│ manifest VARCHAR(255) NOT NULL,
│ -- protobuf 이벤트 바이너리
│ snapshot BYTEA NOT NULL,
│ -- 이벤트가 만들어진 시간
│ created_at TIMESTAMP NOT NULL,
│
│ PRIMARY KEY (aggregate_id, sequence_number)
);