queue

Documentation

Index

• type Queue
  • func New(ctx context.Context, workers int, ...) *Queue
  • func (q *Queue) Process(ctx context.Context, data interface{}) (interface{}, error)
  • func (q *Queue) Run()

Types

type Queue

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

Queue is a worker queue with a fixed amount of workers

func New

func New(ctx context.Context, workers int, handler func(context.Context, interface{}) (interface{}, error)) *Queue

New creates a new Queue with the specified amount of workers

func (*Queue) Process

func (q *Queue) Process(ctx context.Context, data interface{}) (interface{}, error)

Process adds a job to the queue, waits for it to process, and returns the result

func (*Queue) Run

func (q *Queue) Run()

Run starts the queue and blocks until it's shut down