feat: expose max allocatable IPs thru grpc server

Author: mselim00

go.mod

@@ -177,8 +177,3 @@ require (
 	sigs.k8s.io/structured-merge-diff/v4 v4.6.0 // indirect
 	sigs.k8s.io/yaml v1.4.0 // indirect
 )
-
-replace gopkg.in/yaml.v3 v3.0.0-20200615113413-eeeca48fe776 => gopkg.in/yaml.v3 v3.0.1
-
-// Version of go-cose v1.2.0 and v1.2.1 have been deprecated in favor v1.1.0
-replace github.com/veraison/go-cose => github.com/veraison/go-cose v1.1.0

pkg/ipamd/ipamd.go

@@ -2347,6 +2347,23 @@ func (c *IPAMContext) getPrefixesNeeded() int {
 	return toAllocate
 }
 
+// getMaxIPs returns the maximum number of ipv4 addresses allocatable given the context
+func (c *IPAMContext) getMaxIPs() (int, error) {
+	enisForPods, err := c.getMaxENI()
+	if err != nil {
+		return 0, err
+	}
+	if c.useCustomNetworking {
+		enisForPods = enisForPods - 1
+	}
+
+	ipv4Limit, _, err := c.GetIPv4Limit()
+	if err != nil {
+		return 0, err
+	}
+	return enisForPods * ipv4Limit, nil
+}
+
 func (c *IPAMContext) initENIAndIPLimits() (err error) {
 	if c.enableIPv4 {
 		nodeMaxENI, err := c.getMaxENI()

pkg/ipamd/ipamd_test.go

@@ -1265,6 +1265,63 @@ func TestGetWarmIPTargetStateWithPDenabled(t *testing.T) {
 	assert.Equal(t, 0, over)
 }
 
+func TestGetMaxIPs(t *testing.T) {
+	m := setup(t)
+	defer m.ctrl.Finish()
+
+	for _, testCase := range []struct {
+		enablePrefixDelegation bool
+		useCustomNetworking    bool
+		eniLimit               int
+		eniIpv4Limit           int
+		expectedMaxIps         int
+	}{
+		{
+			// modeled for a t3.medium
+			eniLimit:       3,
+			eniIpv4Limit:   5,
+			expectedMaxIps: 15,
+		},
+		{
+			// modeled for a t3.medium
+			eniLimit:               3,
+			eniIpv4Limit:           5,
+			enablePrefixDelegation: true,
+			expectedMaxIps:         240,
+		},
+		{
+			// modeled for a t3.medium
+			eniLimit:            3,
+			eniIpv4Limit:        5,
+			useCustomNetworking: true,
+			expectedMaxIps:      10,
+		},
+		{
+			// modeled for a t3.medium
+			eniLimit:            3,
+			eniIpv4Limit:        5,
+			useCustomNetworking: true,
+			expectedMaxIps:      10,
+		},
+	} {
+		mockContext := &IPAMContext{
+			awsClient:              m.awsutils,
+			networkClient:          m.network,
+			primaryIP:              make(map[string]string),
+			terminating:            int32(0),
+			enablePrefixDelegation: testCase.enablePrefixDelegation,
+			useCustomNetworking:    testCase.useCustomNetworking,
+		}
+		m.awsutils.EXPECT().GetENILimit().Return(testCase.eniLimit)
+		m.awsutils.EXPECT().GetENIIPv4Limit().Return(testCase.eniIpv4Limit)
+
+		maxIps, err := mockContext.getMaxIPs()
+
+		assert.NoError(t, err)
+		assert.Equal(t, testCase.expectedMaxIps, maxIps)
+	}
+}
+
 func TestIPAMContext_nodeIPPoolTooLow(t *testing.T) {
 	m := setup(t)
 	defer m.ctrl.Finish()

pkg/ipamd/rpc_handler.go

@@ -334,6 +334,18 @@ func (s *server) GetNetworkPolicyConfigs(ctx context.Context, e *emptypb.Empty)
 	return resp, nil
 }
 
+func (s *server) GetMaxAllocatableIPs(ctx context.Context, e *emptypb.Empty) (*rpc.GetMaxAllocatableIPsReply, error) {
+	log.Infof("Received GetMaxAllocatableIPs request")
+
+	maxIPs, err := s.ipamContext.getMaxIPs()
+	resp := &rpc.GetMaxAllocatableIPsReply{
+		MaxAllocatableIPs: int32(maxIPs),
+	}
+
+	log.Infof("Send GetMaxAllocatableIPs: MaxAllocatableIPs: %d, err: %v", resp.MaxAllocatableIPs, err)
+	return resp, err
+}
+
 // RunRPCHandler handles request from gRPC
 func (c *IPAMContext) RunRPCHandler(version string) error {
 	log.Infof("Serving RPC Handler version %s on %s", version, ipamdgRPCaddress)