cookbooks/logstash/recipes/default.rb

   1 #
   2 # Cookbook:: logstash
   3 # Recipe:: default
   4 #
   5 # Copyright:: 2015, OpenStreetMap Foundation
   6 #
   7 # Licensed under the Apache License, Version 2.0 (the "License");
   8 # you may not use this file except in compliance with the License.
   9 # You may obtain a copy of the License at
  10 #
  11 #     https://www.apache.org/licenses/LICENSE-2.0
  12 #
  13 # Unless required by applicable law or agreed to in writing, software
  14 # distributed under the License is distributed on an "AS IS" BASIS,
  15 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16 # See the License for the specific language governing permissions and
  17 # limitations under the License.
  18 #
  19
  20 include_recipe "elasticsearch"
  21 include_recipe "networking"
  22
  23 keys = data_bag_item("logstash", "keys")
  24
  25 package %w[
  26   openjdk-11-jre-headless
  27   logstash
  28   logrotate
  29 ]
  30
  31 cookbook_file "/var/lib/logstash/beats.crt" do
  32   source "beats.crt"
  33   user "root"
  34   group "logstash"
  35   mode "644"
  36   notifies :restart, "service[logstash]"
  37 end
  38
  39 file "/var/lib/logstash/beats.key" do
  40   content keys["beats"].join("\n")
  41   user "root"
  42   group "logstash"
  43   mode "640"
  44   notifies :restart, "service[logstash]"
  45 end
  46
  47 template "/etc/logstash/conf.d/chef.conf" do
  48   source "logstash.conf.erb"
  49   user "root"
  50   group "root"
  51   mode "644"
  52   notifies :start, "service[logstash]"
  53 end
  54
  55 file "/etc/logrotate.d/logstash" do
  56   mode "644"
  57 end
  58
  59 template "/etc/default/logstash" do
  60   source "logstash.default.erb"
  61   user "root"
  62   group "root"
  63   mode "644"
  64   notifies :restart, "service[logstash]"
  65 end
  66
  67 service "logstash" do
  68   action [:enable, :start]
  69 end
  70
  71 template "/etc/cron.daily/expire-logstash" do
  72   source "expire.erb"
  73   owner "root"
  74   group "root"
  75   mode "755"
  76 end
  77
  78 forwarders = []
  79
  80 search(:node, "recipes:logstash\\:\\:forwarder").each do |forwarder|
  81   forwarders.append(forwarder.ipaddresses(:role => :external))
  82 end
  83
  84 search(:node, "roles:gateway").each do |forwarder|
  85   forwarders.append(forwarder.ipaddresses(:role => :external))
  86 end
  87
  88 firewall_rule "accept-logstash" do
  89   action :accept
  90   context :incoming
  91   protocol :tcp
  92   source forwarders
  93   dest_ports %w[5043 5044]
  94   source_ports "1024-65535"
  95   not_if { forwarders.empty? }
  96 end