Added configuration for pulic-ip through node annotation

Signed-off-by: Roberto Bonafiglia <roberto.bonafiglia@suse.com>

main.go

@@ -262,6 +262,15 @@ func main() {
 
 	// Work out which interface to use
 	var extIface *backend.ExternalInterface
+
+	annotatedPublicIP, annotatedPublicIPv6 := sm.GetStoredPublicIP(ctx)
+	if annotatedPublicIP != "" {
+		opts.publicIP = annotatedPublicIP
+	}
+	if annotatedPublicIPv6 != "" {
+		opts.publicIPv6 = annotatedPublicIPv6
+	}
+
 	optsPublicIP := ipmatch.PublicIPOpts{
 		PublicIP:   opts.publicIP,
 		PublicIPv6: opts.publicIPv6,

pkg/subnet/etcd/local_manager.go

@@ -83,6 +83,10 @@ func (m *LocalManager) GetStoredMacAddress(ctx context.Context) string {
 	return ""
 }
 
+func (m *LocalManager) GetStoredPublicIP(ctx context.Context) (string, string) {
+	return "",""
+}
+
 func (m *LocalManager) GetNetworkConfig(ctx context.Context) (*subnet.Config, error) {
 	cfg, err := m.registry.getNetworkConfig(ctx)
 	if err != nil {

pkg/subnet/kube/kube.go

@@ -631,3 +631,22 @@ func (ksm *kubeSubnetManager) GetStoredMacAddress(ctx context.Context) string {
 
 	return ""
 }
+
+// GetStoredPublicIP reads if there are any public IP configured as annotation when flannel starts
+func (ksm *kubeSubnetManager) GetStoredPublicIP(ctx context.Context) (string, string) {
+	// get mac info from Name func.
+	node, err := ksm.client.CoreV1().Nodes().Get(ctx, ksm.nodeName, metav1.GetOptions{})
+	if err != nil {
+		log.Errorf("Failed to get node for backend data: %v", err)
+		return "", ""
+	}
+
+	if node != nil && node.Annotations != nil {
+		log.Infof("List of node(%s) annotations: %#+v", ksm.nodeName, node.Annotations)
+		publicIP := node.Annotations[ksm.annotations.BackendPublicIP]
+		publicIPv6 := node.Annotations[ksm.annotations.BackendPublicIPv6]
+		return publicIP, publicIPv6
+	}
+
+	return "", ""
+}

pkg/subnet/subnet.go

@@ -115,6 +115,7 @@ type Manager interface {
 	CompleteLease(ctx context.Context, lease *lease.Lease, wg *sync.WaitGroup) error
 
 	GetStoredMacAddress(ctx context.Context) string
+	GetStoredPublicIP(ctx context.Context) (string, string)
 	Name() string
 }