Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( MaxMessageSize = 262144 MaxMessageSizeExceeded = errors.New("exceeded maximum supported message size for SQS") )
Functions ¶
This section is empty.
Types ¶
type EnqueueError ¶
func (*EnqueueError) Error ¶
func (e *EnqueueError) Error() string
type Job ¶
type Job struct { JobClass string `json:"job_class,omitempty"` JobID string `json:"job_id,omitempty"` ProviderJobID *string `json:"provider_job_id,omitempty"` QueueName string `json:"queue_name,omitempty"` Priority *int `json:"priority,omitempty"` Arguments interface{} `json:"arguments,omitempty"` Executions int `json:"executions,omitempty"` ExceptionExecutions map[string]string `json:"exception_executions,omitempty"` Locale string `json:"locale,omitempty"` Timezone string `json:"timezone,omitempty"` EnqueuedAt time.Time `json:"enqueued_at,omitempty"` EnqueueError error `json:"enqueue_error,omitempty"` }
Click to show internal directories.
Click to hide internal directories.