Documentation ¶
Index ¶
Constants ¶
View Source
const ( OptKeyConnection = "connection" OptKeyName = "name" OptKeyTable = "table" )
View Source
const ( ColumnID = "id" ColumnQueue = "queue" ColumnPayload = "payload" ColumnReservedAt = "reserved_at" ColumnAvaliableAt = "avaliable_at" ColumnCreatedAt = "created_at" ColumnUpdatedAt = "updated_at" )
View Source
const (
DefaultJobTable = "jobs"
)
Variables ¶
View Source
var ErrMissingOptionConnection = errors.New("missing option \"connection\"")
View Source
var ErrMissingOptionName = errors.New("missing option \"name\"")
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// contains filtered or unexported fields
}
func (*Config) FormatOpts ¶
type Job ¶
type Job struct { ID uuid.UUID `gorm:"column:id;primaryKey" json:"id"` Queue string `gorm:"column:queue" json:"queue"` Payload queue.Job `gorm:"column:payload;serializer:json" json:"payload"` Attempts int `gorm:"column:attempts" json:"attempts"` ReservedAt sql.Null[time.Time] `gorm:"column:reserved_at" json:"reserved_at"` AvaliableAt time.Time `gorm:"column:avaliable_at" json:"avaliable_at"` CreatedAt time.Time `gorm:"column:created_at" json:"created_at"` UpdatedAt time.Time `gorm:"column:updated_at" json:"updated_at"` }
func (*Job) GetAttempts ¶
func (*Job) GetPayload ¶
Click to show internal directories.
Click to hide internal directories.