workers

package

v0.9.78 Latest Latest Go to latest Published: Sep 6, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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