Packages
verk
1.1.0
1.7.3
1.7.2
1.7.1
1.7.0
1.6.4
1.6.3
1.6.2
1.6.1
1.6.0
1.5.0
1.4.1
1.4.0
1.3.0
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.1.1
1.1.0
1.0.2
1.0.1
1.0.0
0.14.1
0.14.0
0.13.6
0.13.5
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.1
0.12.0
0.11.1
0.11.0
0.10.0
0.9.13
0.9.12
0.9.11
0.9.10
0.9.9
0.9.8
0.9.7
0.9.6
0.9.5
0.9.4
0.9.3
0.9.2
0.9.1
0.9.0
Verk is a job processing system backed by Redis.
Current section
Files
Jump to
Current section
Files
lib/verk/events.ex
defmodule Verk.Events do
@moduledoc """
Events generated while jobs are being processed
"""
defmodule JobFinished do
@moduledoc """
When a job finishes this event is generated
"""
@type t :: %__MODULE__{job: Verk.Job.t, finished_at: DateTime.t, started_at: DateTime.t}
defstruct [:job, :started_at, :finished_at]
end
defmodule JobStarted do
@moduledoc """
When a job starts this event is generated
"""
@type t :: %__MODULE__{job: Verk.Job.t, started_at: DateTime.t}
defstruct [:job, :started_at]
end
defmodule JobFailed do
@moduledoc """
When a job fails this event is generated
"""
@type t :: %__MODULE__{job: Verk.Job.t, started_at: DateTime.t, failed_at: DateTime.t,
stacktrace: [:erlang.stack_item()], exception: Exception.t}
defstruct [:job, :started_at, :failed_at, :stacktrace, :exception]
end
defmodule QueueRunning do
@moduledoc """
When a queue is running
"""
@type t :: %__MODULE__{queue: atom}
defstruct [:queue]
end
defmodule QueuePausing do
@moduledoc """
When a queue is pausing
"""
@type t :: %__MODULE__{queue: atom}
defstruct [:queue]
end
defmodule QueuePaused do
@moduledoc """
When a queue paused
"""
@type t :: %__MODULE__{queue: atom}
defstruct [:queue]
end
end