bg_jobs/events

Types

Event

pub type Event {
  SetupErrorEvent(error: dynamic.Dynamic)
  JobEnqueuedEvent(job: jobs.Job)
  NoWorkerForJobError(job: jobs.JobEnqueueRequest)
  JobReservedEvent(queue_name: String, job: jobs.Job)
  JobStartEvent(queue_name: String, job: jobs.Job)
  JobSucceededEvent(queue_name: String, job: jobs.Job)
  JobFailedEvent(queue_name: String, job: jobs.Job)
  QueuePollingStartedEvent(queue_name: String)
  QueuePollingStopedEvent(queue_name: String)
  QueueErrorEvent(queue_name: String, error: errors.BgJobError)
  DbQueryEvent(sql: String, attributes: List(String))
  DbEvent(operation: String, input: List(String))
  DbResponseEvent(response: String)
  DbErrorEvent(error: errors.BgJobError)
  MonitorReleasingReserved(pid: process.Pid)
  MonitorReleasedJob(jobs.Job)
  MigrateUpComplete
  MigrateDownComplete
}

Constructors

```
SetupErrorEvent(error: dynamic.Dynamic)
```
```
JobEnqueuedEvent(job: jobs.Job)
```

NoWorkerForJobError(job: jobs.JobEnqueueRequest)

JobReservedEvent(queue_name: String, job: jobs.Job)

JobStartEvent(queue_name: String, job: jobs.Job)

JobSucceededEvent(queue_name: String, job: jobs.Job)

JobFailedEvent(queue_name: String, job: jobs.Job)

QueuePollingStartedEvent(queue_name: String)

QueuePollingStopedEvent(queue_name: String)

QueueErrorEvent(queue_name: String, error: errors.BgJobError)

DbQueryEvent(sql: String, attributes: List(String))

DbEvent(operation: String, input: List(String))

```
DbResponseEvent(response: String)
```
```
DbErrorEvent(error: errors.BgJobError)
```

MonitorReleasingReserved(pid: process.Pid)

```
MonitorReleasedJob(jobs.Job)
```
```
MigrateUpComplete
```
```
MigrateDownComplete
```

EventListener

</>

pub type EventListener =
  fn(Event) -> Nil

Functions

send_event

</>

pub fn send_event(
  event_listners: List(fn(Event) -> Nil),
  event: Event,
) -> Nil