Skip to content

nanomsg

Consumes messages via Nanomsg sockets (scalability protocols).

YAML Configurations

Common Config

# Common config fields, showing default values
input:
  label: ""
  nanomsg:
    urls: []
    bind: true
    socket_type: PULL
    sub_filters: []

Currently, only PULL and SUB sockets are supported.

Advanced Config

# All config fields, showing default values
input:
  label: ""
  nanomsg:
    urls: []
    bind: true
    socket_type: PULL
    sub_filters: []
    poll_timeout: 5s

Fields

urls

A list of URLs to connect to (or as). If an item of the list contains commas, it will be expanded into multiple URLs.

Type: array

Default: []

bind

Whether the URLs provided should be connected to or bound as.

Type: bool

Default: true

socket_type

The socket type to use.

Type: string

Default: "PULL"

Options: PULL, SUB.

sub_filters

A list of subscription topic filters to use when consuming from a SUB socket. Specifying a single sub_filter of '' will subscribe to everything.

Type: array

Default: []

poll_timeout

The period to wait until a poll is abandoned and reattempted.

Type: string

Default: "5s"