appsetup

Documentation

Index

• func NewEntgoClient(logger *zap.SugaredLogger, postgresConfig postgres.PostgresConfig) (entities.EntgoClient, error)
• func NewOutboxBackgroundService(ctx context.Context, logger *zap.SugaredLogger, ...) (outbox2.OutboxBackgroundService, error)

Functions

func NewEntgoClient

func NewEntgoClient(logger *zap.SugaredLogger, postgresConfig postgres.PostgresConfig) (entities.EntgoClient, error)

func NewOutboxBackgroundService

func NewOutboxBackgroundService(ctx context.Context, logger *zap.SugaredLogger, pulsarClient pulsar.PulsarClient, pulsarConfig pulsar.PulsarConfig, outboxConfig outbox.OutboxConfig, entgoClient entities.EntgoClient, jobScheduler *gocron.Scheduler) (outbox2.OutboxBackgroundService, error)