helpers

package

v0.19.1069 Latest Latest Go to latest Published: Jul 17, 2026 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

View Source

const GeneralSignalsQueueName = "general-signals"

This section is empty.

This section is empty.

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

func New(params Params) *Helpers

func (h *Helpers) EnsureGeneralQueue(ctx context.Context) (*app.Queue, error)

EnsureGeneralQueue creates the general-signals queue if it doesn't already exist. Safe to call multiple times — queueClient.Create is idempotent.

type Params struct {
	fx.In

	Cfg         *internal.Config
	DB          *gorm.DB `name:"psql"`
	QueueClient *queueclient.Client
}