feat: support multiple externalIPs

internal/interfaces/nodeinfo.go

@@ -1,7 +1,7 @@
 package interfaces
 
 type NodeInfo struct {
-	Name       string
-	InternalIP string
-	ExternalIP string
+	Name        string
+	InternalIP  string
+	ExternalIPs []string
 }

internal/kube/kube.go

@@ -47,20 +47,20 @@ func (s *KubeService) GetNodeInfo(ctx context.Context) ([]*interfaces.NodeInfo,
 	var nodeList []*interfaces.NodeInfo
 	for _, node := range nodes.Items {
 		var internalIP string
-		var externalIP string
+		var externalIPs []string
 		for _, address := range node.Status.Addresses {
 			switch address.Type {
 			case v1.NodeInternalIP:
 				internalIP = address.Address
 			case v1.NodeExternalIP:
-				externalIP = address.Address
+				externalIPs = append(externalIPs, address.Address)
 			}
 		}
 		if internalIP != "" {
 			nodeList = append(nodeList, &interfaces.NodeInfo{
-				Name:       node.Name,
-				InternalIP: internalIP,
-				ExternalIP: externalIP,
+				Name:        node.Name,
+				InternalIP:  internalIP,
+				ExternalIPs: externalIPs,
 			})
 		}
 	}

internal/s3policy/s3policy.go

@@ -82,7 +82,7 @@ func NewS3PolicyHelper(helperConfig *S3PolicyHelperConfig) (*S3PolicyHelper, err
 func (h *S3PolicyHelper) ClusterNodesUpdated(ctx context.Context, nodes []*interfaces.NodeInfo) error {
 	var ips []string
 	for _, node := range nodes {
-		ips = append(ips, node.ExternalIP)
+		ips = append(ips, node.ExternalIPs...)
 	}
 	configData := configData{
 		BucketName: h.bucket,

internal/s3policy/s3policy_test.go

@@ -0,0 +1,25 @@
+package s3policy
+
+import (
+	"html/template"
+	"strings"
+	"testing"
+)
+
+func TestBucketPolicyTemplate(t *testing.T) {
+	tem := template.Must(template.New("bucketPolicy").Funcs(template.FuncMap{
+		"sub": sub,
+	}).Parse(bucketPolicyTemplate))
+
+	configData := configData{
+		BucketName: "hello",
+		IPs:        []string{"127.0.0.1", "127.0.0.2"},
+	}
+
+	var policyOutput strings.Builder
+	if err := tem.Execute(&policyOutput, configData); err != nil {
+		t.Errorf("Failed to execute template: %v", err)
+	}
+
+	t.Log(policyOutput.String())
+}