enqueuer

type Enqueuer ¶

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

Enqueuer processes signal enqueue requests in the background. It receives queue signal IDs via a channel and also periodically sweeps for orphaned signals that were never enqueued.

func New(params Params) *Enqueuer

func (e *Enqueuer) Send(queueSignalID string)

type Params ¶

type Params struct {
	fx.In

	DB      *gorm.DB `name:"psql"`
	Cfg     *internal.Config
	TClient temporalclient.Client
	L       *zap.Logger
	LC      fx.Lifecycle
}