signalmgr

package

v0.33.0 Latest Latest Go to latest Published: Nov 19, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Details

View Source

const (
	QueueName               = "engine-signal-mgr"
	PriorityScheduleAll     = 2
	PriorityMaintCleanup    = 3
	PriorityScheduleService = 4
)

This section is empty.

func TriggerService(ctx context.Context, r *river.Client[pgx.Tx], serviceID uuid.UUID) error

TriggerService will attempt to schedule messages for the given service immediately.

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

DB schedules outgoing signal messages.

func NewDB(ctx context.Context, db *sql.DB) (*DB, error)

NewDB creates a new DB.

func (db *DB) Name() string

Name returns the name of the module.

func (db *DB) Setup(ctx context.Context, args processinglock.SetupArgs) error

type MaintArgs struct{}

func (MaintArgs) Kind() string

type SchedMsgsArgs struct {
	ServiceID uuid.NullUUID
}

func (SchedMsgsArgs) Kind() string