Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrDeliveryAttemptFailed = errors.New("Error sending event")
Functions ¶
func CreateTask ¶
func CreateTask(name convoy.TaskName, cfg config.Configuration, handler interface{}) *taskq.Task
func ProcessDeadLetters ¶
func ProcessMessages ¶ added in v0.2.1
func ProcessMessages(appRepo convoy.ApplicationRepository, msgRepo convoy.MessageRepository, orgRepo 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
Source Files
Click to show internal directories.
Click to hide internal directories.