19422986238

Committed 17 Nov 2025 08:22AM UTC coverage: 21.501% (-0.001%) from 21.502%

Build # 19422986238

Build Type

push

github

Committed by

zbb88888

Commit Message

optimize log output (#5916)

Signed-off-by: zhaocongqi <1229896069@qq.com>

Run Details

0 of 4 new or added lines in 1 file covered. (0.0%)

10638 of 49476 relevant lines covered (21.5%)

0.25 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/pkg/controller/vpc_nat.go

package controller

import (
        "fmt"

        k8serrors "k8s.io/apimachinery/pkg/api/errors"
        "k8s.io/klog/v2"

        "github.com/kubeovn/kube-ovn/pkg/util"
)

var (
        vpcNatImage             = ""
        vpcNatGwBgpSpeakerImage = ""
        vpcNatAPINadProvider    = ""
)

func (c *Controller) resyncVpcNatConfig() {
        cm, err := c.configMapsLister.ConfigMaps(c.config.PodNamespace).Get(util.VpcNatConfig)
        if err != nil {
                if !k8serrors.IsNotFound(err) {
                        err = fmt.Errorf("failed to get ovn-vpc-nat-config, %w", err)
                        klog.Error(err)
                }
                return
        }

        // Prefix used to generate the name of the StatefulSet/Pods for a NAT gateway
        // By default it is equal to the value contained in 'util.VpcNatGwNamePrefix'
        vpcNatGwNamePrefix := cm.Data["natGwNamePrefix"]
        if vpcNatGwNamePrefix != "" {
                util.VpcNatGwNamePrefix = vpcNatGwNamePrefix
        } else {
                util.VpcNatGwNamePrefix = util.VpcNatGwNameDefaultPrefix
        }

        // Image we're using to provision the NAT gateways
        image, exist := cm.Data["image"]
        if !exist {
                err = fmt.Errorf("%s should have image field", util.VpcNatConfig)
                klog.Error(err)
                return
        }
        vpcNatImage = image

        // Image for the BGP sidecar of the gateway (optional)
        vpcNatGwBgpSpeakerImage = cm.Data["bgpSpeakerImage"]

        // NetworkAttachmentDefinition provider for the BGP speaker to call the API server
        vpcNatAPINadProvider = cm.Data["apiNadProvider"]
}

1	package controller
2
3	import (
4	"fmt"
5
6	k8serrors "k8s.io/apimachinery/pkg/api/errors"
7	"k8s.io/klog/v2"
8
9	"github.com/kubeovn/kube-ovn/pkg/util"
10	)
11
12	var (
13	vpcNatImage = ""
14	vpcNatGwBgpSpeakerImage = ""
15	vpcNatAPINadProvider = ""
16	)
17
18	func (c *Controller) resyncVpcNatConfig() {	×
19	cm, err := c.configMapsLister.ConfigMaps(c.config.PodNamespace).Get(util.VpcNatConfig)	×
20	if err != nil {	×
NEW 21	if !k8serrors.IsNotFound(err) {	×
NEW 22	err = fmt.Errorf("failed to get ovn-vpc-nat-config, %w", err)	×
NEW 23	klog.Error(err)	×
NEW 24	}	×
25	return	×
26	}
27
28	// Prefix used to generate the name of the StatefulSet/Pods for a NAT gateway
29	// By default it is equal to the value contained in 'util.VpcNatGwNamePrefix'
30	vpcNatGwNamePrefix := cm.Data["natGwNamePrefix"]	×
31	if vpcNatGwNamePrefix != "" {	×
32	util.VpcNatGwNamePrefix = vpcNatGwNamePrefix	×
33	} else {	×
34	util.VpcNatGwNamePrefix = util.VpcNatGwNameDefaultPrefix	×
35	}	×
36
37	// Image we're using to provision the NAT gateways
38	image, exist := cm.Data["image"]	×
39	if !exist {	×
40	err = fmt.Errorf("%s should have image field", util.VpcNatConfig)	×
41	klog.Error(err)	×
42	return	×
43	}	×
44	vpcNatImage = image	×
45		×
46	// Image for the BGP sidecar of the gateway (optional)	×
47	vpcNatGwBgpSpeakerImage = cm.Data["bgpSpeakerImage"]	×
48		×
49	// NetworkAttachmentDefinition provider for the BGP speaker to call the API server	×
50	vpcNatAPINadProvider = cm.Data["apiNadProvider"]	×
51	}

kubeovn / kube-ovn / 19422986238

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous