{% set THREADS = salt['pillar.get']('logstash_settings:ls_input_threads', '') -%}
{% set BATCH = salt['pillar.get']('logstash_settings:ls_pipeline_batch_size', 125) -%}
{% from 'logstash/map.jinja' import REDIS_NODES with context -%}

{% for index in range(REDIS_NODES|length) -%}
{%   for host in REDIS_NODES[index] -%}
input {
        redis {
                host => '{{ host }}'
                port => 9696
                ssl => true
                data_type => 'list'
                key => 'logstash:unparsed'
                type => 'redis-input'
                threads => {{ THREADS }}
                batch_count => {{ BATCH }}
        }
}
{%   endfor %}
{% endfor -%}