gflare/queue

Types

pub type Message(a)
pub type Queue

Values

pub fn ack(
  message: Message(a),
) -> promise.Promise(Result(Nil, error.Error))
pub fn message_attempts(message: Message(a)) -> Int
pub fn message_body(message: Message(a)) -> a
pub fn message_id(message: Message(a)) -> String
pub fn message_timestamp(message: Message(a)) -> Int
pub fn retry(
  message: Message(a),
) -> promise.Promise(Result(Nil, error.Error))
pub fn send(
  queue: Queue,
  message: json.Json,
) -> promise.Promise(Result(Nil, error.Error))
pub fn send_batch(
  queue: Queue,
  messages: List(json.Json),
) -> promise.Promise(Result(Nil, error.Error))
Search Document