Documentation
¶
Index ¶
- type OutboxMessageCleaner
- type OutboxMessageCleanerOption
- func OutboxMessageCleanerWithBatchSize(batchSize int) OutboxMessageCleanerOption
- func OutboxMessageCleanerWithInterval(interval time.Duration) OutboxMessageCleanerOption
- func OutboxMessageCleanerWithLogger(logger *slog.Logger) OutboxMessageCleanerOption
- func OutboxMessageCleanerWithMaxBatches(maxBatches int) OutboxMessageCleanerOption
- func OutboxMessageCleanerWithRetention(retention time.Duration) OutboxMessageCleanerOption
- type OutboxMessagePublisher
- type OutboxMessagePublisherOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutboxMessageCleaner ¶ added in v0.9.79
type OutboxMessageCleaner struct {
// contains filtered or unexported fields
}
func NewOutboxMessageCleaner ¶ added in v0.9.79
func NewOutboxMessageCleaner( repository cleanupRepository, opts ...OutboxMessageCleanerOption, ) *OutboxMessageCleaner
func (*OutboxMessageCleaner) Run ¶ added in v0.9.79
func (c *OutboxMessageCleaner) Run(ctx context.Context)
Run deletes up to maxBatches at each interval. Retention starts when a message is successfully processed, and each cycle uses a single retention cutoff.
type OutboxMessageCleanerOption ¶ added in v0.9.79
type OutboxMessageCleanerOption func(*OutboxMessageCleaner)
func OutboxMessageCleanerWithBatchSize ¶ added in v0.9.80
func OutboxMessageCleanerWithBatchSize(batchSize int) OutboxMessageCleanerOption
func OutboxMessageCleanerWithInterval ¶ added in v0.9.80
func OutboxMessageCleanerWithInterval(interval time.Duration) OutboxMessageCleanerOption
func OutboxMessageCleanerWithLogger ¶ added in v0.9.79
func OutboxMessageCleanerWithLogger(logger *slog.Logger) OutboxMessageCleanerOption
func OutboxMessageCleanerWithMaxBatches ¶ added in v0.9.80
func OutboxMessageCleanerWithMaxBatches(maxBatches int) OutboxMessageCleanerOption
func OutboxMessageCleanerWithRetention ¶ added in v0.9.80
func OutboxMessageCleanerWithRetention(retention time.Duration) OutboxMessageCleanerOption
type OutboxMessagePublisher ¶
type OutboxMessagePublisher struct {
// contains filtered or unexported fields
}
func NewOutboxMessagePublisher ¶
func NewOutboxMessagePublisher( repository repository, publisher publisher, opts ...OutboxMessagePublisherOption, ) *OutboxMessagePublisher
type OutboxMessagePublisherOption ¶
type OutboxMessagePublisherOption func(*OutboxMessagePublisher)
func OutboxMessagePublisherWithLogger ¶
func OutboxMessagePublisherWithLogger(logger *slog.Logger) OutboxMessagePublisherOption
func OutboxMessagePublisherWithPublishTimeout ¶ added in v0.9.79
func OutboxMessagePublisherWithPublishTimeout(timeout time.Duration) OutboxMessagePublisherOption
func OutboxMessagePublisherWithRetryBackoff ¶ added in v0.9.79
func OutboxMessagePublisherWithRetryBackoff(initial, maximum time.Duration) OutboxMessagePublisherOption
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.