RigInboundGateway.ApiProxy.Handler.Kinesis (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

Handles requests for Kinesis targets.

Link to this section Summary

Link to this section Functions

Specs

config() :: any()

Returns module configuration.

If application environment contains values in Keyword or Map struct, defaults from macro usage will be recursively merged with application configuration.

If one of the configuration parameters does not exist or can not be resolved, raises ArgumentError.

Link to this function

do_handle_http_request(conn, request_path, partition, event, response_from, topic \\ nil)

View Source
Link to this function

handle_http_request(conn, api, endpoint, request_path)

View Source

Produce the request to a Kinesis topic and optionally wait for the (correlated) response.

Expects a JSON encoded CloudEvent in the HTTP body.

Optionally set a partition key via this field:

rig: {"target_partition":"the-partition-key"}

Link to this function

respond_with_bad_request(conn, response_from, description)

View Source