background

Documentation

Index

• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Close()
  • func (q *Queue) Enqueue(ctx context.Context, fn func(context.Context))
  • func (q *Queue) Wait()

Types

type Queue

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

Queue manages background tasks execution

func NewQueue

func NewQueue() *Queue

NewQueue creates a new background queue for managing background tasks execution.

func (*Queue) Close

func (q *Queue) Close()

func (*Queue) Enqueue

func (q *Queue) Enqueue(ctx context.Context, fn func(context.Context))

func (*Queue) Wait

func (q *Queue) Wait()

Wait waits for all active tasks to complete. It does not prevent new tasks from being enqueued while waiting.