runner

package

v3.0.0-beta10 Latest Latest Go to latest Published: Dec 12, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

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

func Run(p priority.T, 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, errC chan error, f func() error)

func (t *T) Run(p priority.T, f func() error) 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