limil/cert-manager-webhook-dnspod
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add debug logs

Browse Source
This commit is contained in:
Hanfei Shen 2020-06-16 16:53:38 +08:00
parent d49708234b
commit c982be0160
No known key found for this signature in database
GPG Key ID: 8645106F29EA1F55
2 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
go.mod
View File

@ -8,4 +8,5 @@ require (
k8s.io/apiextensions-apiserver v0.17.0 k8s.io/apiextensions-apiserver v0.17.0
k8s.io/apimachinery v0.17.0 k8s.io/apimachinery v0.17.0
k8s.io/client-go v0.17.0 k8s.io/client-go v0.17.0
k8s.io/klog v1.0.0
) )

12
main.go
View File

@ -10,6 +10,7 @@ import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
"k8s.io/klog"
"github.com/jetstack/cert-manager/pkg/acme/webhook/apis/acme/v1alpha1" "github.com/jetstack/cert-manager/pkg/acme/webhook/apis/acme/v1alpha1"
"github.com/jetstack/cert-manager/pkg/acme/webhook/cmd" "github.com/jetstack/cert-manager/pkg/acme/webhook/cmd"
@ -87,22 +88,26 @@ func (c *customDNSProviderSolver) Name() string {
func (c *customDNSProviderSolver) Present(ch *v1alpha1.ChallengeRequest) error { func (c *customDNSProviderSolver) Present(ch *v1alpha1.ChallengeRequest) error {
cfg, err := loadConfig(ch.Config) cfg, err := loadConfig(ch.Config)
if err != nil { if err != nil {
klog.Errorf("Failed to log config %v: %v", ch.Config, err)
return err return err
} }
dnspodClient, err := c.getDNSPod(ch, cfg) dnspodClient, err := c.getDNSPod(ch, cfg)
if err != nil { if err != nil {
klog.Errorf("Failed to get dnspod client %v: %v", cfg, err)
return err return err
} }
domainID, err := getDomainID(dnspodClient, ch.ResolvedZone) domainID, err := getDomainID(dnspodClient, ch.ResolvedZone)
if err != nil { if err != nil {
klog.Errorf("Failed to get domain id %s: %v", ch.ResolvedZone, err)
return err return err
} }
recordAttributes := newTxtRecord(ch.ResolvedZone, ch.ResolvedFQDN, ch.Key, *cfg.TTL) recordAttributes := newTxtRecord(ch.ResolvedZone, ch.ResolvedFQDN, ch.Key, *cfg.TTL)
_, _, err = dnspodClient.Domains.CreateRecord(domainID, *recordAttributes) _, _, err = dnspodClient.Domains.CreateRecord(domainID, *recordAttributes)
if err != nil { if err != nil {
klog.Errorf("Failed to create record: %v", err)
return fmt.Errorf("dnspod API call failed: %v", err) return fmt.Errorf("dnspod API call failed: %v", err)
} }
@ -118,21 +123,25 @@ func (c *customDNSProviderSolver) Present(ch *v1alpha1.ChallengeRequest) error {
func (c *customDNSProviderSolver) CleanUp(ch *v1alpha1.ChallengeRequest) error { func (c *customDNSProviderSolver) CleanUp(ch *v1alpha1.ChallengeRequest) error {
cfg, err := loadConfig(ch.Config) cfg, err := loadConfig(ch.Config)
if err != nil { if err != nil {
klog.Errorf("Failed to log config %v: %v", ch.Config, err)
return err return err
} }
dnspodClient, err := c.getDNSPod(ch, cfg) dnspodClient, err := c.getDNSPod(ch, cfg)
if err != nil { if err != nil {
klog.Errorf("Failed to get dnspod client %v: %v", cfg, err)
return err return err
} }
domainID, err := getDomainID(dnspodClient, ch.ResolvedZone) domainID, err := getDomainID(dnspodClient, ch.ResolvedZone)
if err != nil { if err != nil {
klog.Errorf("Failed to get domain id %s: %v", ch.ResolvedZone, err)
return err return err
} }
records, err := findTxtRecords(dnspodClient, domainID, ch.ResolvedZone, ch.ResolvedFQDN) records, err := findTxtRecords(dnspodClient, domainID, ch.ResolvedZone, ch.ResolvedFQDN)
if err != nil && !strings.Contains(err.Error(), "No records") { if err != nil && !strings.Contains(err.Error(), "No records") {
klog.Errorf("Failed to find txt records (%s, %s, %s): %v", domainID, ch.ResolvedZone, ch.ResolvedFQDN, err)
return err return err
} }
@ -143,6 +152,7 @@ func (c *customDNSProviderSolver) CleanUp(ch *v1alpha1.ChallengeRequest) error {
_, err := dnspodClient.Domains.DeleteRecord(domainID, record.ID) _, err := dnspodClient.Domains.DeleteRecord(domainID, record.ID)
if err != nil { if err != nil {
klog.Errorf("Failed to delete record (%s, %s): %v", domainID, record.ID, err)
return err return err
} }
} }
@ -162,6 +172,7 @@ func (c *customDNSProviderSolver) CleanUp(ch *v1alpha1.ChallengeRequest) error {
func (c *customDNSProviderSolver) Initialize(kubeClientConfig *rest.Config, stopCh <-chan struct{}) error { func (c *customDNSProviderSolver) Initialize(kubeClientConfig *rest.Config, stopCh <-chan struct{}) error {
cl, err := kubernetes.NewForConfig(kubeClientConfig) cl, err := kubernetes.NewForConfig(kubeClientConfig)
if err != nil { if err != nil {
klog.Errorf("Failed to new kubernetes client: %v", err)
return err return err
} }
c.client = cl c.client = cl
@ -258,6 +269,7 @@ func findTxtRecords(client *dnspod.Client, domainID, zone, fqdn string) ([]dnspo
recordName := extractRecordName(fqdn, zone) recordName := extractRecordName(fqdn, zone)
records, _, err := client.Domains.ListRecords(domainID, recordName) records, _, err := client.Domains.ListRecords(domainID, recordName)
if err != nil { if err != nil {
klog.Errorf("Failed to list records (%s, %s): %v", domainID, recordName, err)
return records, fmt.Errorf("dnspod API call has failed: %v", err) return records, fmt.Errorf("dnspod API call has failed: %v", err)
} }