workers

package

v0.9.79 Latest Latest Go to latest Published: Sep 9, 2026 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewOutboxMessageCleaner(
	repository cleanupRepository, opts ...OutboxMessageCleanerOption,
) *OutboxMessageCleaner

func (c *OutboxMessageCleaner) Run(ctx context.Context, interval, retention time.Duration, batchSize int)

Run deletes one batch at each interval. Retention starts when a message is successfully processed.

type OutboxMessageCleanerOption func(*OutboxMessageCleaner)

func OutboxMessageCleanerWithLogger(logger *slog.Logger) OutboxMessageCleanerOption

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

func NewOutboxMessagePublisher(
	repository repository,
	publisher publisher,
	opts ...OutboxMessagePublisherOption,
) *OutboxMessagePublisher

func (p *OutboxMessagePublisher) Run(
	ctx context.Context, interval time.Duration, batchSize int,
)

type OutboxMessagePublisherOption func(*OutboxMessagePublisher)

func OutboxMessagePublisherWithLogger(logger *slog.Logger) OutboxMessagePublisherOption

func OutboxMessagePublisherWithPublishTimeout(timeout time.Duration) OutboxMessagePublisherOption

func OutboxMessagePublisherWithRetryBackoff(initial, maximum time.Duration) OutboxMessagePublisherOption

Path	Synopsis
mocks Package mocks is a generated GoMock package.	Package mocks is a generated GoMock package.