statusmgr

package

v0.34.1 Latest Latest Go to latest Published: Sep 29, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

View Source

const (
	QueueName           = "status-manager"
	PriorityLookForWork = 2
	PriorityCleanup     = 3
	PriorityProcess     = 4
)

This section is empty.

This section is empty.

type CleanupArgs struct{}

func (CleanupArgs) Kind() string

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

DB manages outgoing status updates.

func NewDB(ctx context.Context, db *sql.DB, reg *nfydest.Registry, cfg config.Source) (*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

Setup implements processinglock.Setupable.

type LookForWorkArgs struct {
	AlertID int64 `json:",omitempty"`
}

func (LookForWorkArgs) Kind() string

type ProcessArgs struct {
	SubscriptionID int64
}

ProcessArgs is the arguments for processing a single subscription.

func (ProcessArgs) Kind() string