tasks

Documentation

Index

• type DatabaseQueueMonitor
• type DatabaseQueueMonitorTask
  • func NewDatabaseQueueMonitorTask(cfg DatabaseQueueMonitorTaskConfig) *DatabaseQueueMonitorTask
  • func (t *DatabaseQueueMonitorTask) Check(ctx context.Context, permitId uint64, created time.Time, maxAge time.Duration) bool
  • func (t *DatabaseQueueMonitorTask) Run(ctx context.Context, b broadcaster.Broadcaster)
• type DatabaseQueueMonitorTaskConfig
• type DatabaseQueueSweeper
• type DatabaseQueueSweeperTask
  • func NewDatabaseQueueSweeperTask(cfg DatabaseQueueSweeperTaskConfig) *DatabaseQueueSweeperTask
  • func (q *DatabaseQueueSweeperTask) Run(ctx context.Context)
• type DatabaseQueueSweeperTaskConfig

Types

type DatabaseQueueMonitor

type DatabaseQueueMonitor interface {
	Run(ctx context.Context, b broadcaster.Broadcaster)
	Check(ctx context.Context, permitId uint64, created time.Time, maxAge time.Duration) bool
}

type DatabaseQueueMonitorTask

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

DatabaseQueueMonitorTask a task that monitors queue permit extension notifications. This task also fulfills the `Check` interface method and is used by the `DatabaseQueueSweeperTask` to check for expired permits. This is a persistent task that runs until the provided context is canceled.

func NewDatabaseQueueMonitorTask

func NewDatabaseQueueMonitorTask(cfg DatabaseQueueMonitorTaskConfig) *DatabaseQueueMonitorTask

func (*DatabaseQueueMonitorTask) Check

func (t *DatabaseQueueMonitorTask) Check(ctx context.Context, permitId uint64, created time.Time, maxAge time.Duration) bool

func (*DatabaseQueueMonitorTask) Run

func (t *DatabaseQueueMonitorTask) Run(ctx context.Context, b broadcaster.Broadcaster)

type DatabaseQueueMonitorTaskConfig

type DatabaseQueueMonitorTaskConfig struct {
	QueueName                 string
	SweepAge                  time.Duration
	QueueStore                dbqueuetypes.QueueStore
	NotifyTypePermitExtension uint8
}

type DatabaseQueueSweeper

type DatabaseQueueSweeper interface {
	Run(ctx context.Context)
}

type DatabaseQueueSweeperTask

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

DatabaseQueueSweeperTask a task that checks existing queue permits and sweeps expired permits. Intended to be called by the task manager of your choice. This is a scheduled task that runs periodically when called by a scheduler.

func NewDatabaseQueueSweeperTask

func NewDatabaseQueueSweeperTask(cfg DatabaseQueueSweeperTaskConfig) *DatabaseQueueSweeperTask

func (*DatabaseQueueSweeperTask) Run

func (q *DatabaseQueueSweeperTask) Run(ctx context.Context)

type DatabaseQueueSweeperTaskConfig

type DatabaseQueueSweeperTaskConfig struct {
	QueueName  string
	QueueStore dbqueuetypes.QueueStore
	SweepFor   time.Duration
	Monitor    DatabaseQueueMonitor
}