kmagent

kmagent [global options] command [command options] [arguments...]

kmagent start [options]

kmagent start --api-key="km_xxxxxxxxxxxxx" --config="/etc/kmagent/collector.yaml"

kmagent stop

kmagent stop

func GetAgentConfigUpdaterURL(collectorEndpoint string) string {
	const fallbackURL = "https://api.kloudmate.com/agents/config-check"

	u, _ := url.Parse(collectorEndpoint)

	host := u.Hostname()
	parts := strings.Split(host, ".")

	if len(parts) < 2 {
		return fallbackURL
	}

	// Reconstruct the root domain from the last two parts.
	//    e.g., "otel.kloudmate.dev" -> "kloudmate.dev"
	rootDomain := parts[len(parts)-2] + "." + parts[len(parts)-1]

	// Build the new URL using the robust url.URL struct
	updateURL := url.URL{
		Scheme: u.Scheme,               // Use the original scheme (e.g., "https")
		Host:   "api." + rootDomain,    // Prepend "api." to the new host
		Path:   "/agents/config-check", // Set the static path
	}

	return updateURL.String()
}

kmagent --version

kmagent version 0.1.0

kmagent --help
kmagent start --help

kmagent start --agent-config="/etc/kmagent/agent-config.yaml"

func makeService(p *Program) (service.Service, error) {
	svcConfig := &service.Config{
		Name:        "kmagent",
		DisplayName: "KloudMate Agent",
		Description: "KloudMate Agent for OpenTelemetry auto instrumentation",
	}
	svc, err := service.New(p, svcConfig)
	if err != nil {
		return nil, fmt.Errorf("error creating service: %w", err)
	}
	return svc, nil
}

sudo systemctl daemon-reload
sudo systemctl enable kmagent
sudo systemctl start kmagent
sudo systemctl status kmagent

launchctl load ~/Library/LaunchAgents/com.kloudmate.agent.plist
launchctl start com.kloudmate.agent
launchctl stop com.kloudmate.agent

docker run -d \
  --name kmagent \
  --restart unless-stopped \
  -v /etc/kmagent:/etc/kmagent \
  -e KM_API_KEY=km_xxxxxxxxxxxxx \
  -e KM_DOCKER_MODE=true \
  kloudmate/kmagent:latest \
  start --agent-config=/etc/kmagent/agent-config.yaml

func (p *Program) Stop(s service.Service) error {
	p.logger.Info("Stopping service...")
	// 1. Signal all dependent components to stop
	if p.cancelFunc != nil {
		p.logger.Info("Cancelling program context...")
		p.cancelFunc()
	}
	// 2. Shutdown the agent gracefully
	if p.kmAgent != nil {
		p.logger.Info("Shutting down KloudMate agent...")
		shutdownCtx, shutdownCancel := context.WithTimeout(context.Background(), 30*time.Second)
		defer shutdownCancel()
		if err := p.kmAgent.Shutdown(shutdownCtx); err != nil {
			p.logger.Errorf("Error during agent shutdown: %v", err)
		} else {
			p.logger.Info("KloudMate agent shut down successfully.")
		}
	}
	// 3. Wait for the main program goroutine to finish
	p.logger.Info("Waiting for program run goroutine to complete...")
	p.wg.Wait()

	p.logger.Info("Service stopped successfully.")
	return nil
}

func getFileLogger(logFile string) (*zap.SugaredLogger, error) {
	// Lumberjack handles log rotation
	writer := zapcore.AddSync(&lumberjack.Logger{
		Filename:   logFile,
		MaxSize:    10, // MB
		MaxBackups: 1,
		MaxAge:     7,    // days
		Compress:   true, // compress old logs
	})

	encoderConfig := zap.NewProductionEncoderConfig()
	encoderConfig.TimeKey = "timestamp"
	encoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
	encoder := zapcore.NewJSONEncoder(encoderConfig)

	core := zapcore.NewTee(
		zapcore.NewCore(encoder, writer, zapcore.InfoLevel),
		zapcore.NewCore(zapcore.NewConsoleEncoder(encoderConfig), zapcore.AddSync(os.Stdout), zapcore.DebugLevel),
	)

	logger := zap.New(core)
	return logger.Sugar(), nil
}

export KM_AGENT_CONFIG="/etc/kmagent/agent-config.yaml"
export KM_COLLECTOR_CONFIG="/etc/kmagent/otel-config.yaml"
export KM_COLLECTOR_ENDPOINT="https://otel.kloudmate.com:4318"
export KM_API_KEY="km_xxxxxxxxxxxxx"
export KM_CONFIG_CHECK_INTERVAL="60"
export KM_UPDATE_ENDPOINT="https://api.kloudmate.com/agents/config-check"
export KM_DOCKER_MODE="false"
export KM_DOCKER_ENDPOINT="unix:///var/run/docker.sock"

kmagent start \
  --api-key="km_xxxxxxxxxxxxx" \
  --config="/etc/kmagent/otel-config.yaml"

kmagent start \
  --api-key="km_xxxxxxxxxxxxx" \
  --collector-endpoint="https://otel.example.com:4318" \
  --update-endpoint="https://api.example.com/agents/config-check" \
  --config="/etc/kmagent/otel-config.yaml"

kmagent start \
  --api-key="km_xxxxxxxxxxxxx" \
  --docker-mode \
  --docker-endpoint="unix:///var/run/docker.sock"

kmagent start --agent-config="/etc/kmagent/agent-config.yaml"

kmagent start \
  --api-key="km_xxxxxxxxxxxxx" \
  --config="/etc/kmagent/otel-config.yaml" \
  --config-check-interval=0

# Systemd
sudo systemctl status kmagent

# Launchd
launchctl list | grep kloudmate

# Systemd journal
sudo journalctl -u kmagent -f

# Log file (if configured)
tail -f /var/log/kmagent.log

# Verify YAML syntax
yamllint /etc/kmagent/agent-config.yaml

# Check file permissions
ls -la /etc/kmagent/