gflare/queue
Types
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))