Sequins

Sequins.Pipeline.Data (Sequins v0.8.0)

Functions for converting Broadway SQS messages into Sequins messages and preparing the results for SNS

Link to this section Summary

Types

t()

Functions

attrs_to_map(attrs)

Convert SQS message attributes to a map

extract(data)

Extract processable data and attributes from an SQS Broadway.Message

map_to_attrs(map)

Convert a map to SQS message attributes

update(arg, caller)

Assemble the return value to hand off to the SNS batcher

Link to this section Types

Link to this type

t()

Specs

t() :: {term(), map()}

Link to this section Functions

Link to this function

attrs_to_map(attrs)

Convert SQS message attributes to a map

Link to this function

extract(data)

Extract processable data and attributes from an SQS Broadway.Message

Link to this function

map_to_attrs(map)

Convert a map to SQS message attributes

Link to this function

update(arg, caller)

Assemble the return value to hand off to the SNS batcher