Zabbix

/*

** Zabbix

** Copyright (C) 2001-2022 Zabbix SIA

**

** This program is free software; you can redistribute it and/or modify

** it under the terms of the GNU General Public License as published by

** the Free Software Foundation; either version 2 of the License, or

** (at your option) any later version.

**

** This program is distributed in the hope that it will be useful,

** but WITHOUT ANY WARRANTY; without even the implied warranty of

** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

** GNU General Public License for more details.

**

** You should have received a copy of the GNU General Public License

** along with this program; if not, write to the Free Software

** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

**/

​

package main

​

import (

    "errors"

    "fmt"

    "net"

    "os"

    "path/filepath"

    "time"

​

    "git.zabbix.com/ap/plugin-support/conf"

    "git.zabbix.com/ap/plugin-support/plugin"

    "git.zabbix.com/ap/plugin-support/plugin/comms"

    "zabbix.com/internal/agent"

    "zabbix.com/plugins/external"

)

​

type pluginOptions struct {

    System struct {

        Path string

    }

}

​

func initExternalPlugins(options *agent.AgentOptions) (string, error) {

    paths := make(map[string]string)

​

    for name, p := range options.Plugins {

        var o pluginOptions

        if err := conf.Unmarshal(p, &o, false); err != nil {

            // not an external plugin, just ignore the error

            continue

        }

​

        if err := checkPath(o.System.Path); err != nil {

            return "", err

        }

​

        paths[name] = o.System.Path

    }

​

    if len(paths) == 0 {

        return "", nil

    }

​

    timeout := parseTimeout()

    socket := agent.Options.ExternalPluginsSocket

    err := removeSocket(socket)

    if err != nil {

        return "", err

    }

​

    listener, err := getListener(socket)

    if err != nil {

        return "", err

    }

​

    for name, p := range paths {

        accessor := createAccessor(p, socket, timeout, listener)

        err := initExternalPlugin(name, accessor, options)

        if err != nil {

            return "", err

        }

        accessor.Initial = false

​

        plugin.RegisterMetrics(accessor, name, accessor.Params...)

    }

​

    return socket, nil

}

​

func initExternalPlugin(name string, p *external.Plugin, options *agent.AgentOptions) (err error) {

    p.ExecutePlugin()