memqueue

package

v0.5.1 Latest Latest Go to latest Published: Mar 25, 2022 License: MPL-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewClient(cfg config.Configuration) (queue.Storage, taskq.Factory, error)

func NewQueue(opts queue.QueueOptions) queue.Queuer

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

func (q *MemQueue) Close() error

func (q *MemQueue) Consumer() taskq.QueueConsumer

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

func (q *MemQueue) Write(ctx context.Context, name convoy.TaskName, e *datastore.EventDelivery, delay time.Duration) error