elasticsearch_rest_resource.rb
View Options

	require 'puppet/parameter/boolean'

	# Provides common properties and parameters for REST-based Elasticsearch types
	module ElasticsearchRESTResource
	# rubocop:disable Metrics/CyclomaticComplexity
	# rubocop:disable Metrics/PerceivedComplexity
	def self.extended(extender)
	extender.newparam(:ca_file) do
	desc 'Absolute path to a CA file to authenticate server certs against.'
	end

	extender.newparam(:ca_path) do
	desc 'Absolute path to a directory containing CA files.'
	end

	extender.newparam(:host) do
	desc 'Hostname or address of Elasticsearch instance.'
	defaultto 'localhost'

	validate do \|value\|
	unless value.is_a? String
	raise Puppet::Error, 'invalid parameter, expected string'
	end
	end
	end

	extender.newparam(:password) do
	desc 'Optional HTTP basic auth plaintext password for Elasticsearch.'
	end

	extender.newparam(:port) do
	desc 'Port to use for Elasticsearch HTTP API operations.'
	defaultto 9200

	munge do \|value\|
	if value.is_a? String
	value.to_i
	elsif value.is_a? Integer
	value
	else
	raise Puppet::Error, "unknown '#{value}' timeout type #{value.class}"
	end
	end

	validate do \|value\|
	raise Puppet::Error, "invalid port value '#{value}'" \
	unless value.to_s =~ /^([0-9]+)$/
	raise Puppet::Error, "invalid port value '#{value}'" \
	unless (0 < Regexp.last_match[0].to_i) \
	and (Regexp.last_match[0].to_i < 65_535)
	end
	end

	extender.newparam(:protocol) do
	desc 'Protocol to use for communication with Elasticsearch.'
	defaultto 'http'
	end

	extender.newparam(:timeout) do
	desc 'HTTP timeout for reading/writing content to Elasticsearch.'
	defaultto 10

	munge do \|value\|
	if value.is_a? String
	value.to_i
	elsif value.is_a? Integer
	value
	else
	raise Puppet::Error, "unknown '#{value}' timeout type #{value.class}"
	end
	end

	validate do \|value\|
	if value.to_s !~ /^\d+$/
	raise Puppet::Error, 'timeout must be a positive integer'
	end
	end
	end

	extender.newparam(:username) do
	desc 'Optional HTTP basic auth username for Elasticsearch.'
	end

	extender.newparam(
	:validate_tls,
	:boolean => true,
	:parent => Puppet::Parameter::Boolean
	) do
	desc 'Whether to verify TLS/SSL certificates.'
	defaultto true
	end
	end
	end # of newtype

File Metadata

Mime Type: text/x-ruby
Expires: Jul 4 2025, 7:15 PM (7 w, 4 d ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3444850

elasticsearch_rest_resource.rb
No OneTemporary
Actions

elasticsearch_rest_resource.rb
View Options

File Metadata

Event Timeline

elasticsearch_rest_resource.rbNo OneTemporaryActions

elasticsearch_rest_resource.rbView Options

File Metadata

Event Timeline

elasticsearch_rest_resource.rb
No OneTemporary
Actions

elasticsearch_rest_resource.rb
View Options