Receive messages POSTed over HTTP(S). HTTP 2.0 is supported when using TLS, which is enabled when key and cert files are specified.

# Common config fields, showing default values
address: ""
path: /post
ws_path: /post/ws
timeout: 5s
rate_limit: ""

You can leave the 'address' config field blank in order to use the instance wide HTTP server.

The field rate_limit allows you to specify an optional rate_limit resource, which will be applied to each HTTP request made and each websocket payload received.

When the rate limit is breached HTTP requests will have a 429 response returned with a Retry-After header. Websocket payloads will be dropped and an optional response payload will be sent as per ws_rate_limit_message.


It's possible to return a response for each message received using synchronous responses. When doing so you can customise headers with the sync_response field headers, which can also use function interpolation in the value based on the response message contents.


The following fields specify endpoints that are registered for sending messages:

path (defaults to /post)

This endpoint expects POST requests where the entire request body is consumed as a single message.

If the request contains a multipart content-type header as per rfc1341 then the multiple parts are consumed as a batch of messages, where each body part is a message of the batch.

ws_path (defaults to /post/ws)

Creates a websocket connection, where payloads received on the socket are passed through the pipeline as a batch of one message.

You may specify an optional ws_welcome_message, which is a static payload to be sent to all clients once a websocket connection is first established.

It's also possible to specify a ws_rate_limit_message, which is a static payload to be sent to clients that have triggered the servers rate limit.


This input adds the following metadata fields to each message:

- http_server_user_agent
- All headers (only first values are taken)
- All query parameters
- All cookies

You can access these metadata fields using function interpolation.



An alternative address to host from. If left empty the service wide address is used.

Type: string
Default: ""


The endpoint path to listen for POST requests.

Type: string
Default: "/post"


The endpoint path to create websocket connections from.

Type: string
Default: "/post/ws"


An optional message to deliver to fresh websocket connections.

Type: string
Default: ""


An optional message to delivery to websocket connections that are rate limited.

Type: string
Default: ""


Timeout for requests. If a consumed messages takes longer than this to be delivered the connection is closed, but the message may still be delivered.

Type: string
Default: "5s"


An optional rate limit to throttle requests by.

Type: string
Default: ""


Only valid with a custom address.

Type: string
Default: ""


Only valid with a custom address.

Type: string
Default: ""


Customise messages returned via synchronous responses.

Type: object
Default: {"headers":{"Content-Type":"application/octet-stream"}}


Specify headers to return with synchronous responses. This field supports interpolation functions that are resolved batch wide.

Type: object
Default: {"Content-Type":"application/octet-stream"}