nanomsg

Consumes messages via Nanomsg sockets (scalability protocols).

Common

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

Advanced

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

Currently only PULL and SUB sockets are supported.

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: ["tcp://*:5555"]

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"