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"`
	Event *datastore.Event `json:"event"`
}

type QueueOptions

type QueueOptions struct {
	Name string

	Type string

	Redis *redis.Client

	Factory taskq.Factory

	Storage Storage
}

type Queuer

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

type Storage

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

func NewLocalStorage

func NewLocalStorage() Storage