task

Documentation

Index

• Variables
• func CreateTask(name convoy.TaskName, group datastore.Group, handler interface{}) *taskq.Task
• func CreateTasks(groupRepo datastore.GroupRepository, handler interface{}) error
• func ProcessDeadLetters(job *queue.Job)
• func ProcessEventDelivery(appRepo datastore.ApplicationRepository, ...) func(*queue.Job) error
• type EndpointError
  • func (e *EndpointError) Delay() time.Duration
  • func (e *EndpointError) Error() string

Variables

var ErrDeliveryAttemptFailed = errors.New("Error sending event")

Functions

func CreateTask

func CreateTask(name convoy.TaskName, group datastore.Group, handler interface{}) *taskq.Task

func CreateTasks

func CreateTasks(groupRepo datastore.GroupRepository, handler interface{}) error

func ProcessDeadLetters

func ProcessDeadLetters(job *queue.Job)

func ProcessEventDelivery

func ProcessEventDelivery(appRepo datastore.ApplicationRepository, eventDeliveryRepo datastore.EventDeliveryRepository, groupRepo datastore.GroupRepository, rateLimiter limiter.RateLimiter) func(*queue.Job) error

Types

type EndpointError

type EndpointError struct {
	Err error
	// contains filtered or unexported fields
}

func (*EndpointError) Delay

func (e *EndpointError) Delay() time.Duration

func (*EndpointError) Error

func (e *EndpointError) Error() string