func getCopyMetadataJsonCommand()

in pkg/controller/broker/broker_controller.go [350:359]

• 10 lines of code
• 2 McCabe index (conditional complexity)

func getCopyMetadataJsonCommand(dir string, sourcePodName string, namespace string, k8s *tool.K8sClient) string {
	cmdOpts := buildInputCommand(dir)
	topicsJsonStr, err := exec(cmdOpts, sourcePodName, k8s, namespace)
	if err != nil {
		log.Error(err, "exec command failed, output is: "+topicsJsonStr)
		return ""
	}
	topicsCommand := buildOutputCommand(topicsJsonStr, dir)
	return strings.Join(topicsCommand, " ")
}