queue

Types

ContentType

pub type ContentType {
  Text
  Bytes
  Json
  V8
}

Constructors

```
Text
```
```
Bytes
```
```
Json
```
```
V8
```

Message

</>

pub type Message

MessageBatch

</>

pub type MessageBatch

MessageSendRequest

</>

pub type MessageSendRequest {
  MessageSendRequest(
    body: json.Json,
    content_type: option.Option(ContentType),
    delay_seconds: option.Option(Int),
  )
}

Constructors

MessageSendRequest(
  body: json.Json,
  content_type: option.Option(ContentType),
  delay_seconds: option.Option(Int),
)

Queue

</>

pub type Queue

Values

ack

</>

pub fn ack(message: Message) -> Nil

ack_all

</>

pub fn ack_all(batch: MessageBatch) -> Nil

attempts

</>

pub fn attempts(message: Message) -> Int

body

</>

pub fn body(message: Message) -> dynamic.Dynamic

id

</>

pub fn id(message: Message) -> String

messages

</>

pub fn messages(batch: MessageBatch) -> array.Array(Message)

queue

</>

pub fn queue(batch: MessageBatch) -> String

retry

</>

pub fn retry(
  message: Message,
  delay_seconds: option.Option(Int),
) -> Nil

retry_all

</>

pub fn retry_all(
  batch: MessageBatch,
  delay_seconds: option.Option(Int),
) -> Nil

send

</>

pub fn send(
  queue: Queue,
  message: json.Json,
  content_type: option.Option(ContentType),
  delay_seconds: option.Option(Int),
) -> promise.Promise(Nil)

send_batch

</>

pub fn send_batch(
  queue: Queue,
  messages: List(MessageSendRequest),
  delay_seconds: option.Option(Int),
) -> promise.Promise(Nil)

timestamp

</>

pub fn timestamp(message: Message) -> date.Date