sse server

The sse server binding converts inbound http request-response streams into sse request-response streams.

sse_server:
  type: sse
  kind: server
  exit: sse_kafka_proxy

Configuration (* required)

options

object

The sse specific options.

options:
  retry: 2000

options.retry

integer | Default: 2000

Retry delay in milliseconds.

options.requests

array of object

The requests specific options.

requests[].path

string

The path selector.

requests[].content

enum [ double, float, int32, int64, json, string ], object

Enforce validation for the request content.

content.model*

enum [ double, float, int32, int64, json, string ]

A schema or type to validate the request content. Refer to the individual model docs for type specific implementation.

routes

array of object

Conditional sse specific routes.

routes:
  - guarded:
      my_guard:
        - read:items
    when:
      - path: /items
    exit: sse_kafka_proxy

routes[].guarded

object as map of named array of string

List of roles required by each named guard to authorize this route.

routes:
  - guarded:
      my_guard:
        - read:items

routes[].when

array of object

List of conditions (any match) to match this route. Read more: When a route matches

routes:
  - when:
      - path: /items

when[].path

string

Path pattern.

routes[].exit

string

Next binding when following this route.

routes:
  - when:
    ...
    exit: sse_kafka_proxy

exit

string

Default exit binding when no conditional routes are viable.

exit: echo_server

telemetry

object

Defines the desired telemetry for the binding.

telemetry.metrics

array

Telemetry metrics to track

telemetry:
  metrics:
    - stream.*
    - http.*