server

type EventData struct {
	AggregateName string `json:"aggregate_name"`
	AggregateID   string `json:"aggregate_id"`
	EventName     string `json:"event_name"`
	Version       int64  `json:"version"`
	Data          any    `json:"data"`
	TimeMillis    int64  `json:"time_millis"`
}

type FetchAggregateEventInput struct {
	WaitTimeMillisIfEmpty int64  `json:"wait_time_millis_if_empty"`
	AggregateName         string `json:"aggregate_name"`
	AfterID               int    `json:"after_id"`
	Limit                 int    `json:"limit"`
}

type FetchAllEventInput struct {
	WaitTimeMillisIfEmpty int64 `json:"wait_time_millis_if_empty"`
	AfterID               int   `json:"after_id"`
	Limit                 int   `json:"limit"`
}

type RetrieveInput struct {
	AggregateID   string `json:"aggregate_id"`
	AggregateName string `json:"aggregate_name"`
	AfterVersion  int    `json:"after_version"`
}