fix: expose gRPC methods on server

Author: fra98

cmd/liqo-controller-manager/main.go

@@ -152,7 +152,7 @@ func main() {
 	// OFFLOADING MODULE
 	// Storage Provisioner parameters
 	enableStorage := pflag.Bool("enable-storage", false, "enable the liqo virtual storage class")
-	virtualStorageClassName := pflag.String("virtual-storage-class-name", consts.DefaultLiqoNamespace, "Name of the virtual storage class")
+	virtualStorageClassName := pflag.String("virtual-storage-class-name", "liqo", "Name of the virtual storage class")
 	realStorageClassName := pflag.String("real-storage-class-name", "", "Name of the real storage class to use for the actual volumes")
 	storageNamespace := pflag.String("storage-namespace", "liqo-storage", "Namespace where the liqo storage-related resources are stored")
 	// Service continuity
@@ -251,12 +251,13 @@ func main() {
 		var ipamClient ipam.IpamClient
 		if *ipamServer != "" {
 			klog.Infof("connecting to the IPAM server %q", *ipamServer)
-			connection, err := grpc.NewClient(*ipamServer, grpc.WithTransportCredentials(insecure.NewCredentials()))
+			conn, err := grpc.NewClient(*ipamServer, grpc.WithTransportCredentials(insecure.NewCredentials()))
 			if err != nil {
 				klog.Errorf("failed to establish a connection to the IPAM %q", *ipamServer)
 				os.Exit(1)
 			}
-			ipamClient = ipam.NewIpamClient(connection)
+			defer conn.Close()
+			ipamClient = ipam.NewIpamClient(conn)
 		}
 
 		if err := modules.SetupNetworkingModule(ctx, mgr, &modules.NetworkingOption{

pkg/ipam/ipam.go

@@ -63,3 +63,28 @@ func New(ctx context.Context, opts *Options) (*LiqoIPAM, error) {
 	opts.HealthServer.SetServingStatus(IPAM_ServiceDesc.ServiceName, grpc_health_v1.HealthCheckResponse_SERVING)
 	return lipam, nil
 }
+
+// IPAcquire acquires a free IP from a given CIDR.
+func (lipam *LiqoIPAM) IPAcquire(_ context.Context, _ *IPAcquireRequest) (*IPAcquireResponse, error) {
+	panic("implement me")
+}
+
+// IPRelease releases an IP from a given CIDR.
+func (lipam *LiqoIPAM) IPRelease(_ context.Context, _ *IPReleaseRequest) (*IPReleaseResponse, error) {
+	panic("implement me")
+}
+
+// NetworkAcquire acquires a network. If it is already reserved, it allocates and reserves a new free one with the same prefix length.
+func (lipam *LiqoIPAM) NetworkAcquire(_ context.Context, _ *NetworkAcquireRequest) (*NetworkAcquireResponse, error) {
+	panic("implement me")
+}
+
+// NetworkRelease releases a network.
+func (lipam *LiqoIPAM) NetworkRelease(_ context.Context, _ *NetworkReleaseRequest) (*NetworkReleaseResponse, error) {
+	panic("implement me")
+}
+
+// NetworkIsAvailable checks if a network is available.
+func (lipam *LiqoIPAM) NetworkIsAvailable(_ context.Context, _ *NetworkAvailableRequest) (*NetworkAvailableResponse, error) {
+	panic("implement me")
+}