Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions build.mk
Original file line number Diff line number Diff line change
Expand Up @@ -147,9 +147,11 @@ lint:
ifeq ($(CI),true)
@echo "Running in GitHub Actions"
golangci-lint run -v
go run golang.org/x/tools/gopls/internal/analysis/modernize/cmd/modernize@latest -test ./...
else
@echo "Running in local environment"
golangci-lint run -v --fix
go run golang.org/x/tools/gopls/internal/analysis/modernize/cmd/modernize@latest -test --fix ./...
endif

.PHONY: lint-windows
Expand Down
14 changes: 7 additions & 7 deletions cmd/cni/cni.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ func main() {
Add: cmdAdd,
Del: cmdDel,
}
about := fmt.Sprintf("CNI kube-ovn plugin %s", versions.VERSION)
about := "CNI kube-ovn plugin " + versions.VERSION
skel.PluginMainFuncs(funcs, version.All, about)
}

Expand Down Expand Up @@ -111,7 +111,7 @@ func generateCNIResult(cniResponse *request.CniResponse, netns string) current.R
var netMask *net.IPNet
var gwStr string
addRoutes := len(result.Routes) == 0
for _, cidrBlock := range strings.Split(cniResponse.CIDR, ",") {
for cidrBlock := range strings.SplitSeq(cniResponse.CIDR, ",") {
_, netMask, _ = net.ParseCIDR(cidrBlock)
gwStr = ""
if util.CheckProtocol(cidrBlock) == kubeovnv1.ProtocolIPv4 {
Expand Down Expand Up @@ -227,16 +227,16 @@ func parseValueFromArgs(key, argString string) (string, error) {
if argString == "" {
return "", types.NewError(types.ErrInvalidNetworkConfig, "Invalid Configuration", "CNI_ARGS is required")
}
args := strings.Split(argString, ";")
for _, arg := range args {
if strings.HasPrefix(arg, fmt.Sprintf("%s=", key)) {
value := strings.TrimPrefix(arg, fmt.Sprintf("%s=", key))
args := strings.SplitSeq(argString, ";")
for arg := range args {
if strings.HasPrefix(arg, key+"=") {
value := strings.TrimPrefix(arg, key+"=")
if len(value) > 0 {
return value, nil
}
}
}
return "", types.NewError(types.ErrInvalidNetworkConfig, "Invalid Configuration", fmt.Sprintf("%s is required in CNI_ARGS", key))
return "", types.NewError(types.ErrInvalidNetworkConfig, "Invalid Configuration", key+" is required in CNI_ARGS")
}

func assignV4Address(ipAddress, gateway string, mask *net.IPNet) (*current.IPConfig, *types.Route) {
Expand Down
3 changes: 1 addition & 2 deletions cmd/daemon/cniserver.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ package main

import (
"errors"
"fmt"
"net"
"net/http"
"net/http/pprof"
Expand Down Expand Up @@ -81,7 +80,7 @@ func main() {
stopCh := ctx.Done()
podInformerFactory := kubeinformers.NewSharedInformerFactoryWithOptions(config.KubeClient, 0,
kubeinformers.WithTweakListOptions(func(listOption *v1.ListOptions) {
listOption.FieldSelector = fmt.Sprintf("spec.nodeName=%s", config.NodeName)
listOption.FieldSelector = "spec.nodeName=" + config.NodeName
listOption.AllowWatchBookmarks = true
}))
nodeInformerFactory := kubeinformers.NewSharedInformerFactoryWithOptions(config.KubeClient, 0,
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/condition.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,10 +41,10 @@ type Condition struct {
ObservedGeneration int64 `json:"observedGeneration,omitempty"`
// Last time the condition was probed
// +optional
LastUpdateTime metav1.Time `json:"lastUpdateTime,omitempty"`
LastUpdateTime metav1.Time `json:"lastUpdateTime"`
// Last time the condition transitioned from one status to another.
// +optional
LastTransitionTime metav1.Time `json:"lastTransitionTime,omitempty"`
LastTransitionTime metav1.Time `json:"lastTransitionTime"`
}

type Conditions []Condition
Expand Down
2 changes: 1 addition & 1 deletion pkg/apis/kubeovn/v1/ip.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ type IPList struct {
// +genclient:nonNamespaced
type IP struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec IPSpec `json:"spec"`
}
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/ippool.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,10 @@ type IPPoolList struct {
// +genclient:nonNamespaced
type IPPool struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec IPPoolSpec `json:"spec"`
Status IPPoolStatus `json:"status,omitempty"`
Status IPPoolStatus `json:"status"`
}

type IPPoolSpec struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/iptables-dnat-rule.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type IptablesDnatRuleList struct {
// +resourceName=iptables-dnat-rules
type IptablesDnatRule struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec IptablesDnatRuleSpec `json:"spec"`
Status IptablesDnatRuleStatus `json:"status,omitempty"`
Status IptablesDnatRuleStatus `json:"status"`
}

type IptablesDnatRuleSpec struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/iptables-eip.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type IptablesEIPList struct {
// +resourceName=iptables-eips
type IptablesEIP struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec IptablesEIPSpec `json:"spec"`
Status IptablesEIPStatus `json:"status,omitempty"`
Status IptablesEIPStatus `json:"status"`
}
type IptablesEIPSpec struct {
V4ip string `json:"v4ip"`
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/iptables-fip-rule.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type IptablesFIPRuleList struct {
// +resourceName=iptables-fip-rules
type IptablesFIPRule struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec IptablesFIPRuleSpec `json:"spec"`
Status IptablesFIPRuleStatus `json:"status,omitempty"`
Status IptablesFIPRuleStatus `json:"status"`
}
type IptablesFIPRuleSpec struct {
EIP string `json:"eip"`
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/iptables-snat-rule.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type IptablesSnatRuleList struct {
// +resourceName=iptables-snat-rules
type IptablesSnatRule struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec IptablesSnatRuleSpec `json:"spec"`
Status IptablesSnatRuleStatus `json:"status,omitempty"`
Status IptablesSnatRuleStatus `json:"status"`
}

type IptablesSnatRuleSpec struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/ovn-dnat-rule.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type OvnDnatRuleList struct {
// +resourceName=ovn-dnat-rules
type OvnDnatRule struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec OvnDnatRuleSpec `json:"spec"`
Status OvnDnatRuleStatus `json:"status,omitempty"`
Status OvnDnatRuleStatus `json:"status"`
}

type OvnDnatRuleSpec struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/ovn-eip.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type OvnEipList struct {
// +resourceName=ovn-eips
type OvnEip struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec OvnEipSpec `json:"spec"`
Status OvnEipStatus `json:"status,omitempty"`
Status OvnEipStatus `json:"status"`
}
type OvnEipSpec struct {
ExternalSubnet string `json:"externalSubnet"`
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/ovn-fip.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type OvnFipList struct {
// +resourceName=ovn-fips
type OvnFip struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec OvnFipSpec `json:"spec"`
Status OvnFipStatus `json:"status,omitempty"`
Status OvnFipStatus `json:"status"`
}
type OvnFipSpec struct {
OvnEip string `json:"ovnEip"`
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/ovn-snat-rule.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,10 @@ type OvnSnatRuleList struct {
// +resourceName=ovn-snat-rules
type OvnSnatRule struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec OvnSnatRuleSpec `json:"spec"`
Status OvnSnatRuleStatus `json:"status,omitempty"`
Status OvnSnatRuleStatus `json:"status"`
}

type OvnSnatRuleSpec struct {
Expand Down
6 changes: 4 additions & 2 deletions pkg/apis/kubeovn/v1/provider-network.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
package v1

import (
"slices"

corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
Expand All @@ -19,7 +21,7 @@ type ProviderNetworkList struct {
// +resourceName=provider-networks
type ProviderNetwork struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec ProviderNetworkSpec `json:"spec"`
Status ProviderNetworkStatus `json:"status"`
Expand Down Expand Up @@ -201,7 +203,7 @@ func (s *ProviderNetworkStatus) RemoveNodeConditions(node string) bool {
for i := 0; i < len(s.Conditions); {
if s.Conditions[i].Node == node {
changed = true
s.Conditions = append(s.Conditions[:i], s.Conditions[i+1:]...)
s.Conditions = slices.Delete(s.Conditions, i, i+1)
} else {
i++
}
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/qos-policy.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,10 +41,10 @@ type QoSPolicyList struct {
// +resourceName=qos-policies
type QoSPolicy struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec QoSPolicySpec `json:"spec"`
Status QoSPolicyStatus `json:"status,omitempty"`
Status QoSPolicyStatus `json:"status"`
}
type QoSPolicySpec struct {
BandwidthLimitRules QoSPolicyBandwidthLimitRules `json:"bandwidthLimitRules"`
Expand Down
2 changes: 1 addition & 1 deletion pkg/apis/kubeovn/v1/register_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ func TestAddResources(t *testing.T) {
}

var hasTypeMeta, hasObjMeta, hasListMeta bool
for i := 0; i < st.NumFields(); i++ {
for i := range st.NumFields() {
v := st.Field(i)
if !v.Embedded() || !v.Exported() {
continue
Expand Down
2 changes: 1 addition & 1 deletion pkg/apis/kubeovn/v1/security-group.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@ type SecurityGroupList struct {
// +resourceName=security-groups
type SecurityGroup struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec SecurityGroupSpec `json:"spec"`
Status SecurityGroupStatus `json:"status"`
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/subnet.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,10 @@ type SubnetList struct {
// +genclient:nonNamespaced
type Subnet struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec SubnetSpec `json:"spec"`
Status SubnetStatus `json:"status,omitempty"`
Status SubnetStatus `json:"status"`
}

type SubnetSpec struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/switch-lb-rule.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,10 +18,10 @@ type SwitchLBRuleList struct {
// +resourceName=switch-lb-rules
type SwitchLBRule struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec SwitchLBRuleSpec `json:"spec"`
Status SwitchLBRuleStatus `json:"status,omitempty"`
Status SwitchLBRuleStatus `json:"status"`
}

type SwitchLBRuleSpec struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/vip.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ type VipList struct {
// +genclient:nonNamespaced
type Vip struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec VipSpec `json:"spec"`
Status VipStatus `json:"status,omitempty"`
Status VipStatus `json:"status"`
}

type VipSpec struct {
Expand Down
2 changes: 1 addition & 1 deletion pkg/apis/kubeovn/v1/vlan.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ type VlanList struct {
// +genclient:nonNamespaced
type Vlan struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec VlanSpec `json:"spec"`
Status VlanStatus `json:"status"`
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/vpc-dns.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,10 +18,10 @@ type VpcDnsList struct {
// +resourceName=vpc-dnses
type VpcDns struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec VpcDNSSpec `json:"spec"`
Status VpcDNSStatus `json:"status,omitempty"`
Status VpcDNSStatus `json:"status"`
}

type VpcDNSSpec struct {
Expand Down
8 changes: 4 additions & 4 deletions pkg/apis/kubeovn/v1/vpc-egress-gateway.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,10 @@ type VpcEgressGatewayList struct {
// vpc egress gateway is used to forward the egress traffic from the VPC to the external network
type VpcEgressGateway struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec VpcEgressGatewaySpec `json:"spec"`
Status VpcEgressGatewayStatus `json:"status,omitempty"`
Status VpcEgressGatewayStatus `json:"status"`
}

// Ready returns true if the VpcEgressGateway has been processed successfully and is ready to serve traffic
Expand Down Expand Up @@ -68,7 +68,7 @@ type VpcEgressGatewaySpec struct {
ExternalIPs []string `json:"externalIPs,omitempty"`

// BFD configuration
BFD VpcEgressGatewayBFDConfig `json:"bfd,omitempty"`
BFD VpcEgressGatewayBFDConfig `json:"bfd"`
// egress policies
// at least one policy must be specified
Policies []VpcEgressGatewayPolicy `json:"policies,omitempty"`
Expand Down Expand Up @@ -116,7 +116,7 @@ type VpcEgressGatewayStatus struct {
Conditions Conditions `json:"conditions,omitempty"`

// workload information
Workload VpcEgressWorkload `json:"workload,omitempty"`
Workload VpcEgressWorkload `json:"workload"`
}

type VpcEgressWorkload struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/vpc-nat-gateway.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,10 +23,10 @@ type VpcNatGatewayList struct {
// +resourceName=vpc-nat-gateways
type VpcNatGateway struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec VpcNatGatewaySpec `json:"spec"`
Status VpcNatGatewayStatus `json:"status,omitempty"`
Status VpcNatGatewayStatus `json:"status"`
}

type VpcNatGatewaySpec struct {
Expand Down
4 changes: 2 additions & 2 deletions pkg/apis/kubeovn/v1/vpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,10 +38,10 @@ type VpcList struct {
// +genclient:nonNamespaced
type Vpc struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
metav1.ObjectMeta `json:"metadata"`

Spec VpcSpec `json:"spec"`
Status VpcStatus `json:"status,omitempty"`
Status VpcStatus `json:"status"`
}

type VpcSpec struct {
Expand Down
Loading
Loading