Function startCommand

internal/collector/instance.go:182–223

startCommand generates the command script used by the collector container

(logDirectories []string, includeLogrotate bool)

// startCommand generates the command script used by the collector container
func startCommand(logDirectories []string, includeLogrotate bool) []string {
	var mkdirScript string
	for _, logDir := range logDirectories {
		mkdirScript += "\n" + shell.MakeDirectories(logDir, "receiver")
	}

	var logrotateCommand string
	if includeLogrotate {
		logrotateCommand = `logrotate -s /tmp/logrotate.status /etc/logrotate.d/logrotate.conf`
	}

	var startScript = fmt.Sprintf(`
%s
OTEL_PIDFILE=/tmp/otel.pid

start_otel_collector() {
	echo "Starting OTel Collector"
	/otelcol-contrib --config %s/config.yaml &
	echo $! > $OTEL_PIDFILE
}
start_otel_collector

exec {fd}<> <(:||:)
while read -r -t 5 -u "${fd}" ||:; do
	%s
	if [[ "${directory}" -nt "/proc/self/fd/${fd}" ]] && kill -HUP $(head -1 ${OTEL_PIDFILE?});
	then
		echo "OTel configuration changed..."
		exec {fd}>&- && exec {fd}<> <(:||:)
		stat --format='Loaded configuration dated %%y' "${directory}"
	fi
	if [[ ! -e /proc/$(head -1 ${OTEL_PIDFILE?}) ]] ; then
		start_otel_collector
	fi
done
`, mkdirScript, configDirectory, logrotateCommand)

	wrapper := `monitor() {` + startScript +
		`}; export directory="$1"; export -f monitor; exec -a "$0" bash -ceu monitor`

	return []string{"bash", "-ceu", "--", wrapper, "collector", configDirectory}
}