memqueue

package

v0.6.0-rc Latest Latest Go to latest Published: May 25, 2022 License: MPL-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func NewQueue(opts queue.QueueOptions) queue.Queuer

type MemQueue struct {
	Name string
	// contains filtered or unexported fields
}

func (q *MemQueue) Broker() disq.Broker

func (q *MemQueue) Consume(ctx context.Context) error

func (q *MemQueue) Length() (int, error)

func (q *MemQueue) Publish(ctx context.Context, name convoy.TaskName, job *queue.Job, delay time.Duration) error

func (q *MemQueue) Stop() error