Documentation
¶
Index ¶
- type DBTX
- type InsertOutboxEventsParams
- type OutboxEvent
- type Queries
- func (q *Queries) DeleteOutboxEvents(ctx context.Context, ids []string) error
- func (q *Queries) GetOutboxEventsForPublish(ctx context.Context) ([]OutboxEvent, error)
- func (q *Queries) InsertOutboxEvents(ctx context.Context, arg InsertOutboxEventsParams) error
- func (q *Queries) MarkOutboxEventAsPublished(ctx context.Context, ids []string) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutboxEvent ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) DeleteOutboxEvents ¶
func (*Queries) GetOutboxEventsForPublish ¶
func (q *Queries) GetOutboxEventsForPublish(ctx context.Context) ([]OutboxEvent, error)
func (*Queries) InsertOutboxEvents ¶
func (q *Queries) InsertOutboxEvents(ctx context.Context, arg InsertOutboxEventsParams) error
func (*Queries) MarkOutboxEventAsPublished ¶
Click to show internal directories.
Click to hide internal directories.