outbox

Documentation

Index

• type OutboxBackgroundService
  • func NewOutboxBackgroundService(ctx context.Context, logger *zap.SugaredLogger, ...) (OutboxBackgroundService, error)
• type OutboxPublisher
  • func NewOutboxPublisher(logger *zap.SugaredLogger, entgoClient entities.EntgoClient) (OutboxPublisher, error)

Types

type OutboxBackgroundService

type OutboxBackgroundService interface {
	RunAsync()
	Close()
}

func NewOutboxBackgroundService

func NewOutboxBackgroundService(
	ctx context.Context,
	logger *zap.SugaredLogger,
	outboxConfig outbox.OutboxConfig,
	messageProducer messaging.MessageProducer,
	entgoClient entities.EntgoClient,
	jobScheduler *gocron.Scheduler) (OutboxBackgroundService, error)

type OutboxPublisher

type OutboxPublisher interface {
	PublishWithoutTransaction(
		ctx context.Context,
		topic string,
		key string,
		headers map[string]string,
		event interface{}) error
	Publish(
		ctx context.Context,
		transaction *entities.Tx,
		topic string,
		key string,
		headers map[string]string,
		event interface{}) error
}

func NewOutboxPublisher

func NewOutboxPublisher(
	logger *zap.SugaredLogger,
	entgoClient entities.EntgoClient) (OutboxPublisher, error)