signalmgr

package

v0.35.0 Latest Latest Go to latest Published: Sep 15, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

View Source

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

This section is empty.

This section is empty.

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