diff --git a/cmd/kusk/cmd/add_gateway.go b/cmd/kusk/cmd/add_gateway.go
new file mode 100644
index 000000000..58bf6a29c
--- /dev/null
+++ b/cmd/kusk/cmd/add_gateway.go
@@ -0,0 +1,254 @@
+/*
+The MIT License (MIT)
+
+Copyright © 2022 Kubeshop
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.
+.
+*/
+package cmd
+
+import (
+	"context"
+	"fmt"
+	"strconv"
+	"strings"
+
+	kuskv1 "github.com/kubeshop/kusk-gateway/api/v1alpha1"
+	"github.com/kubeshop/kusk-gateway/cmd/kusk/internal/errors"
+	"github.com/kubeshop/kusk-gateway/cmd/kusk/internal/utils"
+	"github.com/manifoldco/promptui"
+	"github.com/spf13/cobra"
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/util/validation"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+var (
+	gatewayName    string
+	svcType        string
+	port           string
+	defaultGateway bool
+)
+
+var addGatewayCMD = &cobra.Command{
+	Use:           "add",
+	Aliases:       []string{"create"},
+	Short:         "Installs instance of Envoyfleet",
+	SilenceUsage:  true,
+	SilenceErrors: true,
+	RunE:          addRun,
+	PreRunE: func(cmd *cobra.Command, args []string) error {
+
+		if len(svcType) > 0 {
+			if svcType != "ClusterIP" && svcType != "LoadBalancer" {
+				return fmt.Errorf("svcType values can only be ClusterIP or LoadBalancer")
+			}
+		}
+		if len(port) > 0 {
+			pport, err := strconv.Atoi(port)
+			if err != nil {
+				return fmt.Errorf("port value must be an integer")
+			}
+
+			if pport > 65535 {
+				return fmt.Errorf("port number cannot be higher than 65535")
+			}
+		}
+
+		if len(gatewayName) > 0 {
+			errs := validation.IsQualifiedName(gatewayName)
+			if len(errs) > 0 {
+				return fmt.Errorf(strings.Join(errs, ","))
+			}
+		}
+
+		if defaultGateway {
+			c, err := utils.GetK8sClient()
+			fleets := &kuskv1.EnvoyFleetList{}
+
+			if err != nil {
+				return err
+			}
+
+			if err := c.List(context.TODO(), fleets, &client.ListOptions{}); err != nil {
+				return err
+			}
+
+			for _, f := range fleets.Items {
+				if f.Spec.Default {
+					return fmt.Errorf("there is already a default gateway in you cluster")
+				}
+			}
+		}
+		return nil
+	},
+}
+
+func init() {
+	gatewayCMD.AddCommand(addGatewayCMD)
+	addGatewayCMD.Flags().StringVarP(&namespace, "namespace", "n", "", "namespace where the new gateway will be created")
+	addGatewayCMD.Flags().StringVarP(&svcType, "serviceType", "s", "", "Service type of the gateway. Supported options LoadBalancer, ClusterIP")
+	addGatewayCMD.Flags().StringVarP(&port, "port", "p", "", "port for the gateway. Supported values are from 0 to 65536")
+	addGatewayCMD.Flags().StringVarP(&gatewayName, "name", "", "", "name of the gateway")
+	addGatewayCMD.Flags().BoolVarP(&defaultGateway, "default", "", false, "Indicates if the geteway is the default gateway in the cluster")
+}
+
+func addRun(cmd *cobra.Command, args []string) error {
+	reportError := func(err error) {
+		if err != nil {
+			errors.NewErrorReporter(cmd, err).Report()
+		}
+	}
+
+	var err error
+	fleet := &kuskv1.EnvoyFleet{}
+	fleets := &kuskv1.EnvoyFleetList{}
+
+	c, err := utils.GetK8sClient()
+	if err != nil {
+		reportError(err)
+		return err
+	}
+
+	if len(gatewayName) == 0 {
+		gatewayName, err = namePrompt.Run()
+		if err != nil {
+			fmt.Println(err)
+		}
+	}
+
+	fleet.Name = gatewayName
+
+	if len(gatewayName) == 0 {
+		return nil
+	}
+
+	if err := c.List(context.TODO(), fleets, &client.ListOptions{}); err != nil {
+		return err
+	}
+	thereIsDefault := false
+	for _, f := range fleets.Items {
+		if f.Spec.Default {
+			thereIsDefault = true
+			break
+		}
+	}
+
+	if !thereIsDefault {
+		_, t, _ := defaultPrompt.Run()
+		deflt, _ := strconv.ParseBool(t)
+		fleet.Spec.Default = deflt
+	}
+
+	if len(namespace) == 0 {
+		namespaces := &corev1.NamespaceList{}
+		if err := c.List(cmd.Context(), namespaces, &client.ListOptions{}); err != nil {
+			reportError(err)
+			return err
+		}
+
+		namespacesPrompt := promptui.Select{
+			Label: "Select a namespace",
+		}
+
+		namespaceNames := []string{}
+		for _, ns := range namespaces.Items {
+			namespaceNames = append(namespaceNames, ns.Name)
+		}
+		namespacesPrompt.Items = namespaceNames
+		_, namespace, _ = namespacesPrompt.Run()
+	}
+
+	fleet.Namespace = namespace
+
+	if len(svcType) == 0 {
+		_, svcType, _ = serviceTypePrompt.Run()
+	}
+	fleet.Spec.Service = &kuskv1.ServiceConfig{
+		Type: corev1.ServiceType(svcType),
+	}
+
+	if len(port) == 0 {
+		port, err = portPrompt.Run()
+		if err != nil {
+			return err
+		}
+	}
+
+	svcPort, _ := strconv.Atoi(port)
+	fleet.Spec.Service.Ports = []corev1.ServicePort{
+		{
+			Port: int32(svcPort),
+		},
+	}
+
+	if err := c.Create(cmd.Context(), fleet, &client.CreateOptions{}); err != nil {
+		reportError(err)
+		return err
+	}
+
+	fmt.Printf("%s fleet created\n", fleet.Name)
+	return nil
+}
+
+var defaultPrompt = promptui.Select{
+	Label: "Do you want your gateway to be the default in the cluster",
+	Items: []bool{true, false},
+}
+var serviceTypePrompt = promptui.Select{
+	Label: "Pick service type you want to use",
+	Items: []string{"LoadBalancer", "ClusterIP"},
+}
+
+var namePrompt = promptui.Prompt{
+	Label: "Please input name for the new gateway instance",
+}
+
+var portPrompt = promptui.Prompt{
+	Label:    "Input desired service port",
+	Validate: validatePort,
+}
+
+func validatePort(input string) error {
+	pport, err := strconv.Atoi(input)
+	if err != nil {
+		return err
+	}
+	if pport > 65535 {
+		return fmt.Errorf("port number cannot be higher than 65535")
+	}
+	c, err := utils.GetK8sClient()
+	if err != nil {
+		return err
+	}
+	services := corev1.ServiceList{}
+	c.List(context.Background(), &services, &client.ListOptions{})
+
+	for _, svc := range services.Items {
+		if svc.Spec.Type == "LoadBalancer" {
+			for _, p := range svc.Spec.Ports {
+				if p.Port == int32(pport) {
+					return fmt.Errorf("port %d already taken, please choose different one", pport)
+				}
+			}
+		}
+	}
+	return nil
+}
diff --git a/cmd/kusk/cmd/gateway.go b/cmd/kusk/cmd/gateway.go
new file mode 100644
index 000000000..34b4e883f
--- /dev/null
+++ b/cmd/kusk/cmd/gateway.go
@@ -0,0 +1,44 @@
+/*
+The MIT License (MIT)
+
+Copyright © 2022 Kubeshop
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.
+.
+*/
+
+package cmd
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/spf13/cobra"
+)
+
+var gatewayCMD = &cobra.Command{
+	Use: "gateway",
+	Run: func(cmd *cobra.Command, args []string) {
+		fmt.Fprint(os.Stderr, "The gateway command cannot be run directly. Please run: 'kusk gateway add'\n")
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(gatewayCMD)
+}
diff --git a/cmd/kusk/cmd/remove_gateway.go b/cmd/kusk/cmd/remove_gateway.go
new file mode 100644
index 000000000..9d9ae8b0f
--- /dev/null
+++ b/cmd/kusk/cmd/remove_gateway.go
@@ -0,0 +1,107 @@
+/*
+The MIT License (MIT)
+
+Copyright © 2022 Kubeshop
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.
+.
+*/
+package cmd
+
+import (
+	"context"
+	"fmt"
+
+	kuskv1 "github.com/kubeshop/kusk-gateway/api/v1alpha1"
+	"github.com/kubeshop/kusk-gateway/cmd/kusk/internal/kuskui"
+	"github.com/kubeshop/kusk-gateway/cmd/kusk/internal/utils"
+	"github.com/manifoldco/promptui"
+	"github.com/spf13/cobra"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+var removeGateway = &cobra.Command{
+	Use:           "remove",
+	Short:         "Removes selected instance of EnvoyFleet",
+	SilenceErrors: true,
+	SilenceUsage:  true,
+	RunE:          removeRun,
+}
+
+func init() {
+	gatewayCMD.AddCommand(removeGateway)
+	removeGateway.Flags().BoolVar(&confirm, "no-confirm", false, "uninstall without prompt")
+}
+
+func removeRun(cmd *cobra.Command, args []string) error {
+	c, err := utils.GetK8sClient()
+	if err != nil {
+		return err
+	}
+
+	fleets := &kuskv1.EnvoyFleetList{}
+	if err := c.List(context.TODO(), fleets, &client.ListOptions{}); err != nil {
+		return err
+	}
+
+	envoySelect := promptui.Select{
+		Label: "Select Gateway you want to remove",
+	}
+
+	items := []string{}
+	for _, f := range fleets.Items {
+		items = append(items, fmt.Sprintf("%s/%s", f.Namespace, f.Name))
+	}
+
+	envoySelect.Items = items
+
+	index, name, err := envoySelect.Run()
+	if err != nil {
+		return err
+	}
+	fmt.Println(name)
+	proceed := confirm
+
+	if !confirm {
+		prompt := promptui.Prompt{
+			Label:     "Removing Gateway instance will render all associated APIs unoperations. Are you sure you want to uninstall Gateway",
+			IsConfirm: true,
+		}
+		result, err := prompt.Run()
+		if err != nil {
+			return nil
+		}
+
+		if result == "N" || result == "n" || result == "" {
+			kuskui.PrintInfo("Exiting...")
+			return nil
+		}
+		proceed = true
+	}
+
+	if proceed {
+		if err := c.Delete(cmd.Context(), &fleets.Items[index], &client.DeleteAllOfOptions{}); err != nil {
+			return err
+		}
+		fmt.Printf("%s fleet removed\n", fleets.Items[index].Name)
+
+	}
+
+	return nil
+}
diff --git a/cmd/kusk/manifests/api_server.yaml b/cmd/kusk/manifests/api_server.yaml
index e6afdc0a6..5ac94bdcf 100644
--- a/cmd/kusk/manifests/api_server.yaml
+++ b/cmd/kusk/manifests/api_server.yaml
@@ -129,4 +129,4 @@ spec:
   selector:
     app.kubernetes.io/instance: kusk-gateway-api
     app.kubernetes.io/name: kusk-gateway-api
-  type: LoadBalancer
+  type: ClusterIP