eq_queue

type Container interface {
	// Get queue for queueId
	Get(queueId string) (q Queue, found bool)

	// Get queue for queueId. Panic when a queue is not found for the id.
	MustGet(queueId string) Queue

	// Wait for complete all queues
	Wait()

	// Suspend queue. Workers will be shutdown, but do not wait for worker shutdown.
	Suspend() (session eq_bundle.Session, err error)
}

type Definition interface {
	// Define a queue
	Define(queueId string, f interface{}, ctx ...interface{})

	// Traverse
	Each(f func(queueId string, f interface{}, ctx []interface{}))

	// Create a new container
	Current() Container

	// Restore container from the session
	Restore(session eq_bundle.Session) (Container, error)

	// Add error handler listener
	AddErrorListener(h ErrorListener)
}

type ErrorListener eq_mould.ErrorListener

type Opt func(o Opts) Opts

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

type Queue interface {
	// Enqueue data into the queue.
	Enqueue(p interface{})

	// Create sub queue with batchId
	Batch(batchId string) Queue
}