prometheus

Author: miktwon

fpmConfig/fpmConfig.go

@@ -0,0 +1,100 @@
+package fpmConfig
+
+import (
+	"fmt"
+	"io/ioutil"
+	"path"
+	"regexp"
+	"strings"
+
+	"gopkg.in/ini.v1"
+)
+
+type Config struct {
+	Include string
+	Pools   []Pool
+}
+
+type Pool struct {
+	Name       string
+	Listen     string
+	StatusPath string
+}
+
+func Parse(fpmConfigPath string) (Config, error) {
+	c := Config{}
+	cfg := ini.Empty()
+	err := cfg.Append(fpmConfigPath)
+	if err != nil {
+		return c, err
+	}
+
+	global, err := cfg.GetSection("global")
+	if err != nil {
+		return c, err
+	}
+
+	include, err := global.GetKey("include")
+	if err != nil {
+		return c, err
+	}
+
+	c.Include = include.Value()
+
+	file := regexp.QuoteMeta(path.Base(c.Include))
+	file = strings.Replace(file, regexp.QuoteMeta("*"), "(.+)", 1)
+	file = fmt.Sprintf("^%s$", file)
+	fileRx := regexp.MustCompile(file)
+
+	fmpPoolsDir := path.Dir(c.Include)
+	osFileInfo, err := ioutil.ReadDir(fmpPoolsDir)
+	if err != nil {
+		return c, err
+	}
+
+	for _, info := range osFileInfo {
+		if info.IsDir() || !fileRx.MatchString(info.Name()) {
+			continue
+		}
+
+		err = cfg.Append(fmt.Sprintf("%s/%s", fmpPoolsDir, info.Name()))
+		if err != nil {
+			return c, err
+		}
+	}
+
+	for _, section := range cfg.Sections() {
+		_, err = section.GetKey("pm.status_path")
+		if err != nil {
+			continue
+		}
+
+		fillPull(&c, cfg, section.Name())
+	}
+
+	return c, err
+}
+
+func fillPull(config *Config, iniConfig *ini.File, poolName string) error {
+	pool := Pool{}
+	pool.Name = poolName
+
+	section, err := iniConfig.GetSection(poolName)
+	if err != nil {
+		return err
+	}
+
+	key, err := section.GetKey("listen")
+	if err != nil {
+		return err
+	}
+	pool.Listen = key.String()
+
+	key, err = section.GetKey("pm.status_path")
+	if err == nil {
+		pool.StatusPath = key.String()
+	}
+
+	config.Pools = append(config.Pools, pool)
+	return nil
+}

fpmConfig/fpmConfig_test.go

@@ -0,0 +1,17 @@
+package fpmConfig
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestParse(t *testing.T) {
+	c, err := Parse("testData/php-fpm.conf")
+	assert.Nil(t, err)
+	assert.Equal(t, "testData/php-fpm.d/*.conf", c.Include)
+
+	assert.Equal(t, "www", c.Pools[0].Name)
+	assert.Equal(t, "/run/php-fpm/php-fpm.sock", c.Pools[0].Listen)
+	assert.Equal(t, "/status", c.Pools[0].StatusPath)
+}

fpmConfig/testData/php-fpm.conf

@@ -0,0 +1,125 @@
+;;;;;;;;;;;;;;;;;;;;;
+; FPM Configuration ;
+;;;;;;;;;;;;;;;;;;;;;
+
+; All relative paths in this configuration file are relative to PHP's install
+; prefix (/usr). This prefix can be dynamically changed by using the
+; '-p' argument from the command line.
+
+;;;;;;;;;;;;;;;;;;
+; Global Options ;
+;;;;;;;;;;;;;;;;;;
+
+[global]
+; Pid file
+; Note: the default prefix is /var
+; Default Value: none
+;pid = /run/php-fpm/php-fpm.pid
+
+; Error log file
+; If it's set to "syslog", log is sent to syslogd instead of being written
+; into a local file.
+; Note: the default prefix is /var
+; Default Value: log/php-fpm.log
+error_log = syslog
+
+; syslog_facility is used to specify what type of program is logging the
+; message. This lets syslogd specify that messages from different facilities
+; will be handled differently.
+; See syslog(3) for possible values (ex daemon equiv LOG_DAEMON)
+; Default Value: daemon
+;syslog.facility = daemon
+
+; syslog_ident is prepended to every message. If you have multiple FPM
+; instances running on the same server, you can change the default value
+; which must suit common needs.
+; Default Value: php-fpm
+;syslog.ident = php-fpm
+
+; Log level
+; Possible Values: alert, error, warning, notice, debug
+; Default Value: notice
+;log_level = notice
+
+; If this number of child processes exit with SIGSEGV or SIGBUS within the time
+; interval set by emergency_restart_interval then FPM will restart. A value
+; of '0' means 'Off'.
+; Default Value: 0
+;emergency_restart_threshold = 0
+
+; Interval of time used by emergency_restart_interval to determine when
+; a graceful restart will be initiated.  This can be useful to work around
+; accidental corruptions in an accelerator's shared memory.
+; Available Units: s(econds), m(inutes), h(ours), or d(ays)
+; Default Unit: seconds
+; Default Value: 0
+;emergency_restart_interval = 0
+
+; Time limit for child processes to wait for a reaction on signals from master.
+; Available units: s(econds), m(inutes), h(ours), or d(ays)
+; Default Unit: seconds
+; Default Value: 0
+;process_control_timeout = 0
+
+; The maximum number of processes FPM will fork. This has been designed to control
+; the global number of processes when using dynamic PM within a lot of pools.
+; Use it with caution.
+; Note: A value of 0 indicates no limit
+; Default Value: 0
+; process.max = 128
+
+; Specify the nice(2) priority to apply to the master process (only if set)
+; The value can vary from -19 (highest priority) to 20 (lowest priority)
+; Note: - It will only work if the FPM master process is launched as root
+;       - The pool process will inherit the master process priority
+;         unless specified otherwise
+; Default Value: no set
+; process.priority = -19
+
+; Send FPM to background. Set to 'no' to keep FPM in foreground for debugging.
+; Default Value: yes
+;daemonize = yes
+
+; Set open file descriptor rlimit for the master process.
+; Default Value: system defined value
+;rlimit_files = 1024
+
+; Set max core size rlimit for the master process.
+; Possible Values: 'unlimited' or an integer greater or equal to 0
+; Default Value: system defined value
+;rlimit_core = 0
+
+; Specify the event mechanism FPM will use. The following is available:
+; - select     (any POSIX os)
+; - poll       (any POSIX os)
+; - epoll      (linux >= 2.5.44)
+; - kqueue     (FreeBSD >= 4.1, OpenBSD >= 2.9, NetBSD >= 2.0)
+; - /dev/poll  (Solaris >= 7)
+; - port       (Solaris >= 10)
+; Default Value: not set (auto detection)
+;events.mechanism = epoll
+
+; When FPM is built with systemd integration, specify the interval,
+; in seconds, between health report notification to systemd.
+; Set to 0 to disable.
+; Available Units: s(econds), m(inutes), h(ours)
+; Default Unit: seconds
+; Default value: 10
+;systemd_interval = 10
+
+;;;;;;;;;;;;;;;;;;;;
+; Pool Definitions ;
+;;;;;;;;;;;;;;;;;;;;
+
+; Multiple pools of child processes may be started with different listening
+; ports and different management options.  The name of the pool will be
+; used in logs and stats. There is no limitation on the number of pools which
+; FPM can handle. Your system will tell you anyway :)
+
+; Include one or more files. If glob(3) exists, it is used to include a bunch of
+; files from a glob(3) pattern. This directive can be used everywhere in the
+; file.
+; Relative path can also be used. They will be prefixed by:
+;  - the global prefix if it's been set (-p argument)
+;  - /usr otherwise
+include=testData/php-fpm.d/*.conf