Update loadbalancer annotations

vultr/loadbalancers.go

@@ -66,6 +66,9 @@ const (
 	annoVultrAlgorithm     = "service.beta.kubernetes.io/vultr-loadbalancer-algorithm"
 	annoVultrSSLRedirect   = "service.beta.kubernetes.io/vultr-loadbalancer-ssl-redirect"
 	annoVultrProxyProtocol = "service.beta.kubernetes.io/vultr-loadbalancer-proxy-protocol"
+	annoVultrLBHTTP2       = "service.beta.kubernetes.io/vultr-loadbalancer-http2"
+	annoVultrLBHTTP3       = "service.beta.kubernetes.io/vultr-loadbalancer-http3"
+	annoVultrLBTimeout     = "service.beta.kubernetes.io/vultr-loadbalancer-timeout"
 
 	annoVultrStickySessionEnabled    = "service.beta.kubernetes.io/vultr-loadbalancer-sticky-session-enabled"
 	annoVultrStickySessionCookieName = "service.beta.kubernetes.io/vultr-loadbalancer-sticky-session-cookie-name"
@@ -76,6 +79,8 @@ const (
 
 	annoVultrNodeCount = "service.beta.kubernetes.io/vultr-loadbalancer-node-count"
 
+	annoVultrLBGlobalRegions = "service.beta.kubernetes.io/vultr-loadbalancer-global-regions"
+
 	// annoVultrLBSSLLastUpdatedTime is used to keep track of when a SVC is updated due to the SSL secret being updated
 	annoVultrLBSSLLastUpdatedTime = "service.beta.kubernetes.io/vultr-loadbalancer-ssl-last-updated"
 
@@ -418,6 +423,11 @@ func (l *loadbalancers) buildLoadBalancerRequest(service *v1.Service, nodes []*v
 		return nil, err
 	}
 
+	timeout, err := getTimeout(service)
+	if err != nil {
+		return nil, err
+	}
+
 	var ssl *govultr.SSL
 	if secretName, ok := service.Annotations[annoVultrLBSSL]; ok {
 		ssl, err = l.GetSSL(service, secretName)
@@ -438,6 +448,11 @@ func (l *loadbalancers) buildLoadBalancerRequest(service *v1.Service, nodes []*v
 		return nil, err
 	}
 
+	globalRegions, err := getGlobalRegions(service)
+	if err != nil {
+		return nil, err
+	}
+
 	nodeC := 1
 
 	if count, ok := service.Annotations[annoVultrNodeCount]; ok {
@@ -461,10 +476,14 @@ func (l *loadbalancers) buildLoadBalancerRequest(service *v1.Service, nodes []*v
 		ForwardingRules:    rules,                                            // all always be set
 		SSL:                ssl,                                              // will always be set
 		SSLRedirect:        govultr.BoolToBoolPtr(getSSLRedirect(service)),   // need to check
+		HTTP2:              govultr.BoolToBoolPtr(getHTTP2(service)),         // need to check
+		HTTP3:              govultr.BoolToBoolPtr(getHTTP3(service)),         // need to check
 		ProxyProtocol:      govultr.BoolToBoolPtr(getProxyProtocol(service)), // need to check
 		BalancingAlgorithm: getAlgorithm(service),                            // will always be set
 		FirewallRules:      firewallRules,                                    // need to check
+		Timeout:            timeout,                                          // need to check
 		VPC:                govultr.StringToStringPtr(vpc),                   // need to check
+		GlobalRegions:      globalRegions,                                    // need to check
 		Nodes:              nodeC,                                            // need to check
 	}, nil
 }
@@ -901,6 +920,61 @@ func getProxyProtocol(service *v1.Service) bool {
 	return pass
 }
 
+func getHTTP2(service *v1.Service) bool {
+	http2, ok := service.Annotations[annoVultrLBHTTP2]
+	if !ok {
+		return false
+	}
+
+	protocolHTTP2, err := strconv.ParseBool(http2)
+	if err != nil {
+		return false
+	}
+
+	return protocolHTTP2
+}
+
+func getHTTP3(service *v1.Service) bool {
+	http3, ok := service.Annotations[annoVultrLBHTTP3]
+	if !ok {
+		return false
+	}
+
+	protocolHTTP3, err := strconv.ParseBool(http3)
+	if err != nil {
+		return false
+	}
+
+	return protocolHTTP3
+}
+
+func getTimeout(service *v1.Service) (int, error) {
+	lbtimeout, ok := service.Annotations[annoVultrLBTimeout]
+	if !ok {
+		return 600, nil
+	}
+
+	timeout, err := strconv.Atoi(lbtimeout)
+	if err != nil {
+		return 0, fmt.Errorf("invalid timeout value: %v", err)
+	}
+	return timeout, nil
+}
+
+func getGlobalRegions(service *v1.Service) ([]string, error) {
+	regions, ok := service.Annotations[annoVultrLBGlobalRegions]
+	if !ok || regions == "" {
+		return nil, nil
+	}
+
+	regionList := strings.Split(regions, ",")
+	for v := range regionList {
+		regionList[v] = strings.TrimSpace(regionList[v])
+	}
+
+	return regionList, nil
+}
+
 func buildFirewallRules(service *v1.Service) ([]govultr.LBFirewallRule, error) {
 	lbFWRules := []govultr.LBFirewallRule{}
 	fwRules := getFirewallRules(service)