Defined Type: riemann::subscribe

Defined in:
manifests/subscribe.pp

Overview

Define riemann::subscribe

This class type implements a subscription to a riemann instance If included, the host will be sent events from the hosts implementing riemann::publish using forward see riemann.io/api/riemann.streams.html#var-forward

Parameters:

batch: see riemann.io/api/riemann.streams.html#var-batch queue_size: async-queue size see riemann.io/api/riemann.config.html#var-async-queue.21 async_queue_name: the name of the async queue where: the clojure code string used in the (where …) clause in the

publisher's riemann config. Example: `(service "my service")`
defaults to `true` which means all events will be forwarded

Parameters:

  • batch (Any) (defaults to: '200 1')
  • async_queue_options (Any) (defaults to: { ':core-pool-size' => '4', ':max-pool-size' => '128', ':queue-size' => '1000', })
  • stream (Any) (defaults to: $title)
  • streams (Any) (defaults to: 'default')
  • puppet_environment (Any) (defaults to: $environment) 


23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'manifests/subscribe.pp', line 23

define riemann::subscribe (
  $batch = '200 1',
  $async_queue_options = {
    ':core-pool-size' => '4',
    ':max-pool-size'  => '128',
    ':queue-size'     => '1000',
  },
  $stream = $title,
  $streams = 'default',
  $puppet_environment = $environment
) {
  $_sanitized_title = regsubst($title,' ','_')
  $async_queue_name = "${::hostname}-${_sanitized_title}"
  $async_queue_options_string = join(sort(join_keys_to_values($async_queue_options, ' ')),' ')
  # 'let' statement fragment
  @@riemann::config::fragment { "let ${streams} publish ${async_queue_name}":
    content            => template('riemann/subscribe-let.erb'),
    section            => "let streams ${streams} ${stream}",
    subscriber         => $::clientcert,
    puppet_environment => $puppet_environment
  }
  # 'stream' statement
  @@riemann::config::fragment { "stream ${streams} publish ${stream} part2 ${::clientcert}":
    content            => template('riemann/subscribe-stream.erb'),
    section            => "streams ${streams} ${stream}",
    subscriber         => $::clientcert,
    puppet_environment => $puppet_environment
  }
}