| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109 |
- package containers
- import (
- "bytes"
- "regexp"
- )
- var (
- phpCmd = regexp.MustCompile(`.*php\d*\.?\d*$`)
- pythonCmd = regexp.MustCompile(`.*python\d*\.?\d*$`)
- nodejsCmd = regexp.MustCompile(`.*node(js)?\d*\.?\d*$`)
- )
- func guessApplicationType(cmdline []byte) string {
- parts := bytes.Split(cmdline, []byte{0})
- cmd := bytes.TrimSuffix(bytes.Fields(parts[0])[0], []byte{':'})
- switch {
- case bytes.HasSuffix(cmd, []byte("memcached")):
- return "memcached"
- case bytes.HasSuffix(cmd, []byte("envoy")):
- return "envoy"
- case bytes.Contains(cmdline, []byte("org.elasticsearch.bootstrap")):
- return "elasticsearch"
- case bytes.Contains(cmdline, []byte("kafka.Kafka")) || bytes.Contains(cmdline, []byte("io.confluent.support.metrics.SupportedKafka")):
- return "kafka"
- case bytes.HasSuffix(cmd, []byte("mongod")):
- return "mongodb"
- case bytes.HasSuffix(cmd, []byte("mongos")):
- return "mongos"
- case bytes.HasSuffix(cmd, []byte("mysqld")):
- return "mysql"
- case bytes.Contains(cmdline, []byte("org.apache.zookeeper.server.quorum.QuorumPeerMain")):
- return "zookeeper"
- case bytes.HasSuffix(cmd, []byte("redis-server")):
- return "redis"
- case bytes.HasSuffix(cmd, []byte("redis-sentinel")):
- return "redis-sentinel"
- case bytes.HasSuffix(cmd, []byte("keydb-server")):
- return "keydb"
- case bytes.HasSuffix(cmd, []byte("beam.smp")) && bytes.Contains(cmdline, []byte("rabbit")):
- return "rabbitmq"
- case bytes.HasSuffix(cmd, []byte("beam.smp")) && bytes.Contains(cmdline, []byte("couch")):
- return "couchbase"
- case bytes.HasSuffix(cmd, []byte("pgbouncer")):
- return "pgbouncer"
- case bytes.HasSuffix(cmd, []byte("postgres")):
- return "postgres"
- case bytes.HasSuffix(cmd, []byte("haproxy")):
- return "haproxy"
- case bytes.HasSuffix(cmd, []byte("nginx")):
- return "nginx"
- case bytes.HasSuffix(cmd, []byte("kubelet")):
- return "kubelet"
- case bytes.HasSuffix(cmd, []byte("kube-apiserver")):
- return "kube-apiserver"
- case bytes.HasSuffix(cmd, []byte("kube-controller-manager")):
- return "kube-controller-manager"
- case bytes.HasSuffix(cmd, []byte("kube-scheduler")):
- return "kube-scheduler"
- case bytes.HasSuffix(cmd, []byte("k3s")):
- return "k3s"
- case bytes.HasSuffix(cmd, []byte("etcd")):
- return "etcd"
- case bytes.HasSuffix(cmd, []byte("dockerd")):
- return "dockerd"
- case bytes.HasSuffix(cmd, []byte("consul")):
- return "consul"
- case bytes.Contains(cmdline, []byte("org.apache.cassandra.service.CassandraDaemon")):
- return "cassandra"
- case bytes.HasSuffix(cmd, []byte("clickhouse-server")):
- return "clickhouse"
- case bytes.HasSuffix(cmd, []byte("traefik")):
- return "traefik"
- case bytes.HasSuffix(cmd, []byte("asd")):
- return "aerospike"
- case bytes.HasSuffix(cmd, []byte("httpd")):
- return "httpd"
- case bytes.HasSuffix(cmd, []byte("influxd")):
- return "influxdb"
- case bytes.Contains(cmdline, []byte("org.apache.catalina.startup.Bootstrap")):
- return "tomcat"
- case bytes.HasSuffix(cmd, []byte("vault")):
- return "vault"
- case bytes.HasSuffix(cmd, []byte("proxysql")):
- return "proxysql"
- case bytes.HasSuffix(cmd, []byte("cockroach")):
- return "cockroach"
- case bytes.HasSuffix(cmd, []byte("prometheus")):
- return "prometheus"
- case bytes.HasSuffix(cmd, []byte("ceph-mon")) ||
- bytes.HasSuffix(cmd, []byte("ceph-mgr")) ||
- bytes.HasSuffix(cmd, []byte("ceph-osd")) ||
- bytes.HasSuffix(cmd, []byte("cephcsi")):
- return "ceph"
- case bytes.HasSuffix(cmd, []byte("rook")):
- return "rook"
- case bytes.HasSuffix(cmd, []byte("nats-server")):
- return "nats"
- case bytes.HasSuffix(cmd, []byte("java")):
- return "java"
- case phpCmd.Match(cmd):
- return "php"
- case pythonCmd.Match(cmd):
- return "python"
- case nodejsCmd.Match(cmd):
- return "nodejs"
- }
- return ""
- }
|
