task

Documentation

Index

• Variables
• func CreateTask(name convoy.TaskName, group convoy.Group, handler interface{}) *taskq.Task
• func CreateTasks(groupRepo convoy.GroupRepository, handler interface{}) error
• func ProcessDeadLetters(job *queue.Job)
• func ProcessEventDelivery(appRepo convoy.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 convoy.Group, handler interface{}) *taskq.Task

func CreateTasks

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

func ProcessDeadLetters

func ProcessDeadLetters(job *queue.Job)

func ProcessEventDelivery

func ProcessEventDelivery(appRepo convoy.ApplicationRepository, eventDeliveryRepo convoy.EventDeliveryRepository, groupRepo convoy.GroupRepository) 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