Outboxer interface

outbox_outboxer.go

type Outboxer interface {
    // Send expects an active gorm transaction alongwith
    // a registered JobHandler and creates a new outbox job.
    Send(context.Context, *gorm.DB, JobHandler) error

    // Start initiates fetcher and processor goroutines to pick up and
    // process persisted outbox jobs.
    Start(context.Context)

    // Stop gracefully terminates all the outbox goroutines.
    Stop(context.Context)

    // RegisterJobHandler registers JobHandler structs.
    RegisterJobHandler(JobHandler) error

    // RegisterMetrics expects a prometheus registerer and is used
    // to register outbox metrics.
    RegisterMetrics(registerer prometheus.Registerer) error
}