outbox_processor

Documentation

Index

• Constants
• type OutboxProcessor
  • func NewOutboxProcessor(natsConn *nats_internal.NATSConnections, repos *repository.Repositories) *OutboxProcessor
  • func (s *OutboxProcessor) Cleanup(ctx context.Context) error
  • func (p *OutboxProcessor) ProcessBatch(ctx context.Context) error

Constants

const (
	LIMIT    = 1000
	LOOKBACK = 72 * time.Hour
)

const (
	MAX_MESSAGES_PER_BATCH = 50
	EVENT_LOCK_TIMEOUT     = 3 * time.Minute
)

Types

type OutboxProcessor

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

func NewOutboxProcessor

func NewOutboxProcessor(
	natsConn *nats_internal.NATSConnections,
	repos *repository.Repositories,
) *OutboxProcessor

func (*OutboxProcessor) Cleanup

func (s *OutboxProcessor) Cleanup(ctx context.Context) error

func (*OutboxProcessor) ProcessBatch

func (p *OutboxProcessor) ProcessBatch(ctx context.Context) error