Function runFunctionCLI

src/go/cmd/godplugin/main.go:142–244

(opts *cli.Option)

}

func runFunctionCLI(opts *cli.Option) int {
	functionName := strings.TrimSpace(opts.Function)
	if functionName == "" {
		writeFunctionError(400, "missing function name (expected module:method)")
		return 1
	}

	moduleName, methodID, err := functions.SplitFunctionName(functionName)
	if err != nil {
		writeFunctionError(400, "%v", err)
		return 1
	}

	creator, ok := collectorapi.DefaultRegistry.Lookup(moduleName)
	if !ok {
		writeFunctionError(404, "unknown module '%s'", moduleName)
		return 1
	}
	if creator.Methods == nil {
		writeFunctionError(404, "module '%s' does not expose functions", moduleName)
		return 1
	}
	if methodID == "" {
		writeFunctionError(400, "missing method name in function '%s'", functionName)
		return 1
	}

	payloadBytes, payloadTimeout, err := readFunctionPayload(opts.FunctionPayload)
	if err != nil {
		writeFunctionError(400, "%v", err)
		return 1
	}

	timeout, err := resolveFunctionTimeout(opts.FunctionTimeout, payloadTimeout)
	if err != nil {
		writeFunctionError(400, "%v", err)
		return 1
	}

	reg := confgroup.Registry{}
	reg.Register(moduleName, confgroup.Default{
		MinUpdateEvery:     opts.UpdateEvery,
		UpdateEvery:        creator.UpdateEvery,
		AutoDetectionRetry: creator.AutoDetectionRetry,
		Priority:           creator.Priority,
	})

	groups, err := loadConfigGroups(moduleName, reg, pluginconfig.CollectorsDir())
	if err != nil {
		writeFunctionError(500, "%v", err)
		return 1
	}
	if len(groups) == 0 {
		writeFunctionError(404, "no configs found for module '%s'", moduleName)
		return 1
	}

	ctx, cancel := context.WithCancel(context.Background())