types

Documentation

Index

• type Requeuer
  • func BufferedRequeuer(size int) Requeuer
  • func ConcurrentRequeuer(max int) Requeuer

Types

type Requeuer

type Requeuer interface {
	Requeue()
	Dequeue() <-chan interface{}
}

Requeuer handle requeues/enqueues into a channel to allow job syncronization. There might be different implementations due to how the blocking aspect is handled.

func BufferedRequeuer

func BufferedRequeuer(size int) Requeuer

BufferedRequeuer returns a static buffered requeuer of a fixed size. After the number of sync requests overflow the size the Requeue() calls will be blocking

func ConcurrentRequeuer

func ConcurrentRequeuer(max int) Requeuer

ConcurrentRequeuer returns a dynamic requeuer of a maximum size. Requeue() will never be blocking, but when the maximum size is crossed we stop enqueueing