rotationmanager

package

v0.34.0 Latest Latest Go to latest Published: Aug 22, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Details

View Source

const (
	QueueName         = "rotation-manager"
	PriorityScheduled = 1
	PriorityEvent     = 2
	PriorityLFW       = 4
)

This section is empty.

This section is empty.

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

DB manages rotations in Postgres.

func NewDB(ctx context.Context, db *sql.DB, riverDBSQL *river.Client[*sql.Tx]) (*DB, error)

NewDB will create a new DB, preparing all statements necessary.

func (db *DB) Name() string

Name returns the name of the module.

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

Setup implements processinglock.Setupable.

type LookForWorkArgs struct{}

func (LookForWorkArgs) Kind() string

type UpdateArgs struct {
	RotationID uuid.UUID
}

func (UpdateArgs) Kind() string