outboxcore

type BuildRecordsOptions struct {
	Events   []event.DomainEvent
	Resolver eventcatalog.TopicResolver
	Encoder  eventcodec.PayloadEncoder
	Now      time.Time
}

type FailedTransition struct {
	Status           string
	LastError        string
	NextAttemptAt    time.Time
	UpdatedAt        time.Time
	AttemptIncrement int
}

type PublishedTransition struct {
	Status      string
	PublishedAt time.Time
	UpdatedAt   time.Time
}

type Record struct {
	EventID       string
	EventType     string
	AggregateType string
	AggregateID   string
	TopicName     string
	PayloadJSON   string
	Status        string
	AttemptCount  int
	NextAttemptAt time.Time
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type StatusObservation struct {
	Status          string
	Count           int64
	OldestCreatedAt *time.Time
}