queue

Documentation

Index

• type Job
• type QueueOptions
• type Queuer
• type Storage
  • func NewLocalStorage() Storage

Types

type Job

type Job struct {
	Err error  `json:"err"`
	ID  string `json:"id"`
}

type QueueOptions

type QueueOptions struct {
	Name string

	Type string

	Redis *redis.Client

	Factory taskq.Factory

	Storage Storage
}

type Queuer

type Queuer interface {
	io.Closer
	Write(context.Context, convoy.TaskName, *datastore.EventDelivery, time.Duration) error
	Consumer() taskq.QueueConsumer
}

type Storage

type Storage interface {
	Exists(ctx context.Context, key string) bool
}

func NewLocalStorage

func NewLocalStorage() Storage