{%- if grains.role in ['so-heavynode'] %}
  {%- set HOST = salt['grains.get']('host') %}
{%- else %}
  {%- set HOST = salt['grains.get']('master') %}
{%- endif %}
  {%- set THREADS = salt['pillar.get']('logstash_settings:ls_input_threads', '') %}
{%- set BATCH = salt['pillar.get']('logstash_settings:ls_pipeline_batch_size', 125) %}
input {
	redis {
		host => '{{ HOST }}'
		port => 9696
		ssl => true
		data_type => 'list'
		key => 'logstash:unparsed'
		type => 'redis-input'
		threads => {{ THREADS }}
		batch_count => {{ BATCH }}
	}
}