outbox

type Config struct {
	// TableName is the name of the database table used by the outbox
	// pattern to store pending events before they are dispatched.
	// Default: "event_outbox"
	TableName string

	// NotifyChannel is the PostgreSQL LISTEN/NOTIFY channel that is
	// used to signal the dispatcher when new events are inserted into
	// the outbox table.
	// Default: "outbox_events"
	NotifyChannel string

	// SendNotify determines whether an explicit NOTIFY should be sent
	// after inserting a new outbox record. This can be disabled if
	// triggers or other mechanisms already handle notifications.
	// Default: false
	SendNotify bool

	// IgnoreNoTx controls behavior when attempting to insert an outbox
	// event outside of an active transaction. If set to true, the insert
	// will be skipped instead of returning an error. Useful in cases
	// where events are only conditionally created.
	// Default: false
	IgnoreNoTx bool
}

type Event interface {
	Name() string
	Payload() json.RawMessage
}

type Outbox struct {
	// contains filtered or unexported fields
}

type Reader struct {
	// contains filtered or unexported fields
}