Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
mosquito
v0.9.0
Granite
Base
Mosquito
Base
DoubleRun
HabitatSettings
Id
IrretrievableParameter
Job
JobFailed
Model
NilJob
PeriodicJob
PeriodicTask
Queue
QueuedJob
Redis
KeyBuilder
Runner
ScheduledJob
Serializers
Granite
Primitives
Task
Built with Crystal 1.9.2
2023-10-08 09:30:32 UTC
abstract class
Mosquito::QueuedJob
Mosquito::QueuedJob
Mosquito::Job
Reference
Object
Defined in:
mosquito/queued_job.cr
Instance Method Summary
#enqueue
(in delay_interval : Time::Span)
#enqueue
(at execute_time : Time)
#enqueue
Instance methods inherited from class
Mosquito::Job
executed : Bool
executed
,
executed? : Bool
executed?
,
fail
fail
,
failed? : Bool
failed?
,
log(message)
log
,
perform
perform
,
rescheduleable? : Bool
rescheduleable?
,
run
run
,
succeeded : Bool
succeeded
,
succeeded? : Bool
succeeded?
,
task_id : String | Nil
task_id
,
task_id=(task_id : String | Nil)
task_id=
Class methods inherited from class
Mosquito::Job
config : Hash(String, String)
config
,
job_type : String
job_type
,
queue
queue
Instance methods inherited from module
Mosquito::Serializers::Primitives
deserialize_bool(raw : String) : Bool
deserialize_bool
,
deserialize_char(raw : String) : Char
deserialize_char
,
deserialize_float32(raw : String) : Float32 | Nil
deserialize_float32
,
deserialize_float64(raw : String) : Float64 | Nil
deserialize_float64
,
deserialize_int128(raw : String) : Int128 | Nil
deserialize_int128
,
deserialize_int16(raw : String) : Int16 | Nil
deserialize_int16
,
deserialize_int32(raw : String) : Int32 | Nil
deserialize_int32
,
deserialize_int64(raw : String) : Int64 | Nil
deserialize_int64
,
deserialize_int8(raw : String) : Int8 | Nil
deserialize_int8
,
deserialize_string(raw : String) : String | Nil
deserialize_string
,
deserialize_u_int128(raw : String) : UInt128 | Nil
deserialize_u_int128
,
deserialize_u_int16(raw : String) : UInt16 | Nil
deserialize_u_int16
,
deserialize_u_int32(raw : String) : UInt32 | Nil
deserialize_u_int32
,
deserialize_u_int64(raw : String) : UInt64 | Nil
deserialize_u_int64
,
deserialize_u_int8(raw : String) : UInt8 | Nil
deserialize_u_int8
,
serialize_bool(value : Bool) : String
serialize_bool
,
serialize_char(char : Char) : String
serialize_char
,
serialize_float32(value) : String
serialize_float32
,
serialize_float64(value) : String
serialize_float64
,
serialize_int128(value) : String
serialize_int128
,
serialize_int16(value) : String
serialize_int16
,
serialize_int32(value) : String
serialize_int32
,
serialize_int64(value) : String
serialize_int64
,
serialize_int8(value) : String
serialize_int8
,
serialize_string(str : String) : String
serialize_string
,
serialize_symbol(sym : Symbol) : Nil
serialize_symbol
,
serialize_u_int128(value) : String
serialize_u_int128
,
serialize_u_int16(value) : String
serialize_u_int16
,
serialize_u_int32(value) : String
serialize_u_int32
,
serialize_u_int64(value) : String
serialize_u_int64
,
serialize_u_int8(value) : String
serialize_u_int8
Instance Method Detail
def
enqueue
(in delay_interval : Time::Span)
#
[
View source
]
def
enqueue
(at execute_time : Time)
#
[
View source
]
def
enqueue
#
[
View source
]