runner

package

v3.0.0-rc49 Latest Latest Go to latest Published: Oct 14, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func Enqueue(p priority.T, label string, errC chan error, f func() error)

func Run(p priority.T, label string, f func() error) error

func SetDefault(t *T)

func SetMaxRunning(n int)

func Start(ctx context.Context) error

func Stop() error

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

func (t Item) Before(other prioqueue.Interface) bool

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

func New(subQS pubsub.QueueSizer) *T

func NewDefault(subQS pubsub.QueueSizer) *T

func (t *T) Enqueue(p priority.T, label string, errC chan error, f func() error)

Enqueue queues f, the action label names in the logs, to run when one of the max running slots is free, by priority.

func (t *T) Run(p priority.T, label string, f func() error) error

Run runs f, the action label names in the logs, when one of the max running slots is free, by priority, and returns its error.

func (t *T) SetInterval(d time.Duration)

func (t *T) SetMaxRunning(n int)

func (t *T) Start(ctx context.Context) error

func (t *T) Stop() error