relay

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

type CommandOption func(*Command)

type EventStoreOutbox interface {
	UnpublishedEvents(context.Context) ([]RelayEvent, error)
	MarkEventsAsPublised(context.Context, []RelayEvent) error
}

type Publisher interface {
	Publish(context.Context, RelayEvent) error
}

type RelayEvent struct {
	AggregateID esrc.ID
	Sequence    uint64
	RawEvent    esrc.RawEvent
}