Skip to content

Commit

Permalink
add acme resolver monitoring (#4223)
Browse files Browse the repository at this point in the history
  • Loading branch information
bxy4543 committed Nov 1, 2023
1 parent 7b6957a commit af1e99f
Showing 1 changed file with 29 additions and 0 deletions.
29 changes: 29 additions & 0 deletions controllers/pkg/resources/named.go
Expand Up @@ -3,6 +3,8 @@ package resources
import (
"strings"

corev1 "k8s.io/api/core/v1"

sealos_networkmanager "github.com/dinoallo/sealos-networkmanager-protoapi"

"sigs.k8s.io/controller-runtime/pkg/client"
Expand Down Expand Up @@ -30,6 +32,7 @@ const (
TerminalIDLabelKey = "TerminalID"
AppLabelKey = "app"
JobNameLabelKey = "job-name"
ACMEChallengeKey = "acme.cert-manager.io/http01-solver"
KubeBlocksBackUpName = "kubeblocks-backup-data"
)

Expand Down Expand Up @@ -59,13 +62,39 @@ func NewResourceNamed(cr client.Object) *ResourceNamed {
case cr.GetName() == KubeBlocksBackUpName:
p._type = JOB
p._name = KubeBlocksBackUpName
case labels[ACMEChallengeKey] != "":
p._type = APP
p._name = getACMEResolverName(cr)
default:
p._type = OTHER
p._name = ""
}
return p
}

const (
acmesolver = "acmesolver"
acmesolverContainerArgsDomainPrefix = "--domain="
)

func getACMEResolverName(obj client.Object) string {
pod, ok := obj.(*corev1.Pod)
if !ok {
return ""
}
for _, container := range pod.Spec.Containers {
if container.Name != acmesolver {
continue
}
for _, arg := range container.Args {
if strings.HasPrefix(arg, acmesolverContainerArgsDomainPrefix) {
return acmesolver + "-" + strings.TrimPrefix(arg, acmesolverContainerArgsDomainPrefix)
}
}
}
return pod.Name
}

func (p *ResourceNamed) Type() uint8 {
return AppType[p._type]
}
Expand Down

0 comments on commit af1e99f

Please sign in to comment.