From 9ae30c08f99dcfee430240012cfcac5fe9779655 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mat=C3=BA=C5=A1=20Mrekaj?= Date: Fri, 3 May 2024 10:00:23 +0200 Subject: [PATCH] correct api endpoint change (#1366) * correct api endpoint change * fix typo * Auto commit - update kustomization.yaml --------- Co-authored-by: CI/CD pipeline --- Makefile | 2 +- manifests/claudie/kustomization.yaml | 16 +- .../testing-framework/kustomization.yaml | 2 +- proto/kuber.proto | 114 +++--- proto/pb/ansibler.pb.go | 4 +- proto/pb/ansibler_grpc.pb.go | 37 +- proto/pb/claudie-operator.pb.go | 4 +- proto/pb/claudie-operator_grpc.pb.go | 12 +- proto/pb/config.pb.go | 4 +- proto/pb/contextBox.pb.go | 4 +- proto/pb/contextBox_grpc.pb.go | 62 ++- proto/pb/kubeEleven.pb.go | 4 +- proto/pb/kubeEleven_grpc.pb.go | 17 +- proto/pb/kuber.pb.go | 377 ++++++++++++------ proto/pb/kuber_grpc.pb.go | 184 +++++---- proto/pb/terraformer.pb.go | 4 +- proto/pb/terraformer_grpc.pb.go | 17 +- .../ansible-playbooks/apiEndpointChange.yml | 6 + .../adapters/outbound/kuber_connector.go | 6 + services/builder/domain/ports/kuber_port.go | 1 + .../builder/domain/usecases/kuber_caller.go | 6 +- services/kuber/client/client.go | 5 + .../adapters/inbound/grpc/kuber_service.go | 4 + .../usecases/patch_cluster_info_configmap.go | 14 +- .../domain/usecases/patch_kube_proxy.go | 121 ++++++ 25 files changed, 657 insertions(+), 370 deletions(-) create mode 100644 services/kuber/server/domain/usecases/patch_kube_proxy.go diff --git a/Makefile b/Makefile index 81975f1cf..45c8854a1 100644 --- a/Makefile +++ b/Makefile @@ -1,7 +1,7 @@ .PHONY: proto contextbox scheduler builder terraformer ansibler kubeEleven test database minio containerimgs crd crd-apply controller-gen kind-load-images # Enforce same version of protoc -PROTOC_VERSION = "25.1" +PROTOC_VERSION = "26.1" CURRENT_VERSION = $$(protoc --version | awk '{print $$2}') # Generate all .proto files proto: diff --git a/manifests/claudie/kustomization.yaml b/manifests/claudie/kustomization.yaml index 28aef4f3c..c5f83a33f 100644 --- a/manifests/claudie/kustomization.yaml +++ b/manifests/claudie/kustomization.yaml @@ -58,20 +58,20 @@ apiVersion: kustomize.config.k8s.io/v1beta1 kind: Kustomization images: - name: ghcr.io/berops/claudie/ansibler - newTag: 1eac122-2739 + newTag: 45e9b32-2753 - name: ghcr.io/berops/claudie/autoscaler-adapter newTag: 688726a-1932 - name: ghcr.io/berops/claudie/builder - newTag: 1eac122-2739 + newTag: 45e9b32-2753 - name: ghcr.io/berops/claudie/claudie-operator - newTag: 684a010-2740 + newTag: 45e9b32-2753 - name: ghcr.io/berops/claudie/context-box - newTag: 1eac122-2739 + newTag: 45e9b32-2753 - name: ghcr.io/berops/claudie/kube-eleven - newTag: 1eac122-2739 + newTag: 45e9b32-2753 - name: ghcr.io/berops/claudie/kuber - newTag: 1eac122-2739 + newTag: 45e9b32-2753 - name: ghcr.io/berops/claudie/scheduler - newTag: 1eac122-2739 + newTag: 45e9b32-2753 - name: ghcr.io/berops/claudie/terraformer - newTag: 1eac122-2739 + newTag: 45e9b32-2753 diff --git a/manifests/testing-framework/kustomization.yaml b/manifests/testing-framework/kustomization.yaml index ef90d6230..947ed5e0c 100644 --- a/manifests/testing-framework/kustomization.yaml +++ b/manifests/testing-framework/kustomization.yaml @@ -37,4 +37,4 @@ secretGenerator: images: - name: ghcr.io/berops/claudie/testing-framework - newTag: 1eac122-2739 + newTag: 45e9b32-2753 diff --git a/proto/kuber.proto b/proto/kuber.proto index 1e8490ba6..36ed5e48a 100644 --- a/proto/kuber.proto +++ b/proto/kuber.proto @@ -4,12 +4,8 @@ import "proto/config.proto"; option go_package = "proto/pb"; -message SetUpStorageRequest { - K8scluster desiredCluster = 1; -} -message SetUpStorageResponse { - K8scluster desiredCluster = 1; -} +message SetUpStorageRequest { K8scluster desiredCluster = 1; } +message SetUpStorageResponse { K8scluster desiredCluster = 1; } message StoreKubeconfigRequest { K8scluster cluster = 1; @@ -18,9 +14,7 @@ message StoreKubeconfigRequest { message StoreKubeconfigResponse {} -message DeleteKubeconfigRequest { - K8scluster cluster = 1; -} +message DeleteKubeconfigRequest { K8scluster cluster = 1; } message DeleteKubeconfigResponse {} @@ -30,9 +24,7 @@ message DeleteNodesRequest { repeated string masterNodes = 3; } -message DeleteNodesResponse { - K8scluster cluster = 1; -} +message DeleteNodesResponse { K8scluster cluster = 1; } message StoreClusterMetadataRequest { K8scluster cluster = 1; @@ -49,77 +41,95 @@ message StoreLBScrapeConfigRequest { message StoreLBScrapeConfigResponse {} -message RemoveLBScrapeConfigRequest { - K8scluster cluster = 1; -} +message RemoveLBScrapeConfigRequest { K8scluster cluster = 1; } message RemoveLBScrapeConfigResponse {} -message DeleteClusterMetadataRequest { - K8scluster cluster = 1; -} +message DeleteClusterMetadataRequest { K8scluster cluster = 1; } message DeleteClusterMetadataResponse {} -message PatchNodesRequest { - K8scluster cluster = 1; -} +message PatchNodesRequest { K8scluster cluster = 1; } message PatchNodesResponse {} -message SetUpClusterAutoscalerRequest{ +message SetUpClusterAutoscalerRequest { string projectName = 1; K8scluster cluster = 2; } message SetUpClusterAutoscalerResponse {} -message DestroyClusterAutoscalerRequest{ +message DestroyClusterAutoscalerRequest { string projectName = 1; K8scluster cluster = 2; } message DestroyClusterAutoscalerResponse {} -message PatchClusterInfoConfigMapRequest { - K8scluster desiredCluster = 1; -} +message PatchClusterInfoConfigMapRequest { K8scluster desiredCluster = 1; } message PatchClusterInfoConfigMapResponse {} -message CiliumRolloutRestartRequest{ - K8scluster cluster = 1; -} +message CiliumRolloutRestartRequest { K8scluster cluster = 1; } -message CiliumRolloutRestartResponse{} +message CiliumRolloutRestartResponse {} + +message PatchKubeProxyConfigMapRequest { K8scluster desiredCluster = 1; } +message PatchKubeProxyConfigMapResponse {} service KuberService { - // RemoveLBScrapeConfig removes scrape config for every LB detached from this cluster. - rpc RemoveLBScrapeConfig(RemoveLBScrapeConfigRequest) returns (RemoveLBScrapeConfigResponse); - // StoreLBScrapeConfig stores scrape config for every LB attached to this cluster. - rpc StoreLBScrapeConfig(StoreLBScrapeConfigRequest) returns (StoreLBScrapeConfigResponse); - // StoreClusterMetadata creates a secret, which holds the private key and a list of public IP addresses of the cluster supplied. - rpc StoreClusterMetadata(StoreClusterMetadataRequest) returns (StoreClusterMetadataResponse); - // DeleteClusterMetadata deletes the secret holding the private key and public IP addresses of the cluster supplied. - rpc DeleteClusterMetadata(DeleteClusterMetadataRequest) returns (DeleteClusterMetadataResponse); + // RemoveLBScrapeConfig removes scrape config for every LB detached from this + // cluster. + rpc RemoveLBScrapeConfig(RemoveLBScrapeConfigRequest) + returns (RemoveLBScrapeConfigResponse); + // StoreLBScrapeConfig stores scrape config for every LB attached to this + // cluster. + rpc StoreLBScrapeConfig(StoreLBScrapeConfigRequest) + returns (StoreLBScrapeConfigResponse); + // StoreClusterMetadata creates a secret, which holds the private key and a + // list of public IP addresses of the cluster supplied. + rpc StoreClusterMetadata(StoreClusterMetadataRequest) + returns (StoreClusterMetadataResponse); + // DeleteClusterMetadata deletes the secret holding the private key and public + // IP addresses of the cluster supplied. + rpc DeleteClusterMetadata(DeleteClusterMetadataRequest) + returns (DeleteClusterMetadataResponse); // SetUpStorage installs Longhorn into the cluster. rpc SetUpStorage(SetUpStorageRequest) returns (SetUpStorageResponse); - // StoreKubeconfig creates a secret, which holds the kubeconfig of a Claudie-created cluster. + // StoreKubeconfig creates a secret, which holds the kubeconfig of a + // Claudie-created cluster. rpc StoreKubeconfig(StoreKubeconfigRequest) returns (StoreKubeconfigResponse); - // DeleteKubeconfig removes the secret that holds the kubeconfig of a Claudie-created cluster. - rpc DeleteKubeconfig(DeleteKubeconfigRequest) returns (DeleteKubeconfigResponse); + // DeleteKubeconfig removes the secret that holds the kubeconfig of a + // Claudie-created cluster. + rpc DeleteKubeconfig(DeleteKubeconfigRequest) + returns (DeleteKubeconfigResponse); // DeleteNodes deletes the specified nodes from a k8s cluster. rpc DeleteNodes(DeleteNodesRequest) returns (DeleteNodesResponse); - // PatchNodes applies attributes like providerID, labels or taints to the nodes. + // PatchNodes applies attributes like providerID, labels or taints to the + // nodes. rpc PatchNodes(PatchNodesRequest) returns (PatchNodesResponse); - // SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter for every cluster specified. - rpc SetUpClusterAutoscaler(SetUpClusterAutoscalerRequest) returns (SetUpClusterAutoscalerResponse); - // DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter for every cluster specified. - rpc DestroyClusterAutoscaler(DestroyClusterAutoscalerRequest) returns (DestroyClusterAutoscalerResponse); - // PatchClusterInfoConfigMap updates the cluster-info config map in the kube-public namespace with the the - // kubeconfig. This needs to be done after an api endpoint change as the config map in the kube-public namespace - // is used by kubeadm when joining. - rpc PatchClusterInfoConfigMap(PatchClusterInfoConfigMapRequest) returns (PatchClusterInfoConfigMapResponse); + // SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter + // for every cluster specified. + rpc SetUpClusterAutoscaler(SetUpClusterAutoscalerRequest) + returns (SetUpClusterAutoscalerResponse); + // DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter + // for every cluster specified. + rpc DestroyClusterAutoscaler(DestroyClusterAutoscalerRequest) + returns (DestroyClusterAutoscalerResponse); + // PatchClusterInfoConfigMap updates the cluster-info config map in the + // kube-public namespace with the the kubeconfig. This needs to be done after + // an api endpoint change as the config map in the kube-public namespace is + // used by kubeadm when joining. + rpc PatchClusterInfoConfigMap(PatchClusterInfoConfigMapRequest) + returns (PatchClusterInfoConfigMapResponse); + // PatchCubeProxyConfigMap updates the kube-proxy config map with the value of + // the server: from the passed in kubeconfig and subsequently restarts all + // kube-proxy pods in the kube-system namespace. This change needs to be done + // after a endpoint change is performed. + rpc PatchKubeProxyConfigMap(PatchKubeProxyConfigMapRequest) + returns (PatchKubeProxyConfigMapResponse); // CiliumRolloutRestart performs a rollout restart of the cilium daemonset. - rpc CiliumRolloutRestart(CiliumRolloutRestartRequest) returns (CiliumRolloutRestartResponse); -} \ No newline at end of file + rpc CiliumRolloutRestart(CiliumRolloutRestartRequest) + returns (CiliumRolloutRestartResponse); +} diff --git a/proto/pb/ansibler.pb.go b/proto/pb/ansibler.pb.go index 50438b260..009ddae14 100644 --- a/proto/pb/ansibler.pb.go +++ b/proto/pb/ansibler.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v4.25.1 +// protoc-gen-go v1.28.1 +// protoc v5.26.1 // source: proto/ansibler.proto package pb diff --git a/proto/pb/ansibler_grpc.pb.go b/proto/pb/ansibler_grpc.pb.go index 05fc48393..006661a17 100644 --- a/proto/pb/ansibler_grpc.pb.go +++ b/proto/pb/ansibler_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.1 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.26.1 // source: proto/ansibler.proto package pb @@ -18,15 +18,6 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 -const ( - AnsiblerService_InstallNodeRequirements_FullMethodName = "/claudie.AnsiblerService/InstallNodeRequirements" - AnsiblerService_InstallVPN_FullMethodName = "/claudie.AnsiblerService/InstallVPN" - AnsiblerService_SetUpLoadbalancers_FullMethodName = "/claudie.AnsiblerService/SetUpLoadbalancers" - AnsiblerService_TeardownLoadBalancers_FullMethodName = "/claudie.AnsiblerService/TeardownLoadBalancers" - AnsiblerService_UpdateAPIEndpoint_FullMethodName = "/claudie.AnsiblerService/UpdateAPIEndpoint" - AnsiblerService_RemoveClaudieUtilities_FullMethodName = "/claudie.AnsiblerService/RemoveClaudieUtilities" -) - // AnsiblerServiceClient is the client API for AnsiblerService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -57,7 +48,7 @@ func NewAnsiblerServiceClient(cc grpc.ClientConnInterface) AnsiblerServiceClient func (c *ansiblerServiceClient) InstallNodeRequirements(ctx context.Context, in *InstallRequest, opts ...grpc.CallOption) (*InstallResponse, error) { out := new(InstallResponse) - err := c.cc.Invoke(ctx, AnsiblerService_InstallNodeRequirements_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.AnsiblerService/InstallNodeRequirements", in, out, opts...) if err != nil { return nil, err } @@ -66,7 +57,7 @@ func (c *ansiblerServiceClient) InstallNodeRequirements(ctx context.Context, in func (c *ansiblerServiceClient) InstallVPN(ctx context.Context, in *InstallRequest, opts ...grpc.CallOption) (*InstallResponse, error) { out := new(InstallResponse) - err := c.cc.Invoke(ctx, AnsiblerService_InstallVPN_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.AnsiblerService/InstallVPN", in, out, opts...) if err != nil { return nil, err } @@ -75,7 +66,7 @@ func (c *ansiblerServiceClient) InstallVPN(ctx context.Context, in *InstallReque func (c *ansiblerServiceClient) SetUpLoadbalancers(ctx context.Context, in *SetUpLBRequest, opts ...grpc.CallOption) (*SetUpLBResponse, error) { out := new(SetUpLBResponse) - err := c.cc.Invoke(ctx, AnsiblerService_SetUpLoadbalancers_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.AnsiblerService/SetUpLoadbalancers", in, out, opts...) if err != nil { return nil, err } @@ -84,7 +75,7 @@ func (c *ansiblerServiceClient) SetUpLoadbalancers(ctx context.Context, in *SetU func (c *ansiblerServiceClient) TeardownLoadBalancers(ctx context.Context, in *TeardownLBRequest, opts ...grpc.CallOption) (*TeardownLBResponse, error) { out := new(TeardownLBResponse) - err := c.cc.Invoke(ctx, AnsiblerService_TeardownLoadBalancers_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.AnsiblerService/TeardownLoadBalancers", in, out, opts...) if err != nil { return nil, err } @@ -93,7 +84,7 @@ func (c *ansiblerServiceClient) TeardownLoadBalancers(ctx context.Context, in *T func (c *ansiblerServiceClient) UpdateAPIEndpoint(ctx context.Context, in *UpdateAPIEndpointRequest, opts ...grpc.CallOption) (*UpdateAPIEndpointResponse, error) { out := new(UpdateAPIEndpointResponse) - err := c.cc.Invoke(ctx, AnsiblerService_UpdateAPIEndpoint_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.AnsiblerService/UpdateAPIEndpoint", in, out, opts...) if err != nil { return nil, err } @@ -102,7 +93,7 @@ func (c *ansiblerServiceClient) UpdateAPIEndpoint(ctx context.Context, in *Updat func (c *ansiblerServiceClient) RemoveClaudieUtilities(ctx context.Context, in *RemoveClaudieUtilitiesRequest, opts ...grpc.CallOption) (*RemoveClaudieUtilitiesResponse, error) { out := new(RemoveClaudieUtilitiesResponse) - err := c.cc.Invoke(ctx, AnsiblerService_RemoveClaudieUtilities_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.AnsiblerService/RemoveClaudieUtilities", in, out, opts...) if err != nil { return nil, err } @@ -175,7 +166,7 @@ func _AnsiblerService_InstallNodeRequirements_Handler(srv interface{}, ctx conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: AnsiblerService_InstallNodeRequirements_FullMethodName, + FullMethod: "/claudie.AnsiblerService/InstallNodeRequirements", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AnsiblerServiceServer).InstallNodeRequirements(ctx, req.(*InstallRequest)) @@ -193,7 +184,7 @@ func _AnsiblerService_InstallVPN_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: AnsiblerService_InstallVPN_FullMethodName, + FullMethod: "/claudie.AnsiblerService/InstallVPN", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AnsiblerServiceServer).InstallVPN(ctx, req.(*InstallRequest)) @@ -211,7 +202,7 @@ func _AnsiblerService_SetUpLoadbalancers_Handler(srv interface{}, ctx context.Co } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: AnsiblerService_SetUpLoadbalancers_FullMethodName, + FullMethod: "/claudie.AnsiblerService/SetUpLoadbalancers", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AnsiblerServiceServer).SetUpLoadbalancers(ctx, req.(*SetUpLBRequest)) @@ -229,7 +220,7 @@ func _AnsiblerService_TeardownLoadBalancers_Handler(srv interface{}, ctx context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: AnsiblerService_TeardownLoadBalancers_FullMethodName, + FullMethod: "/claudie.AnsiblerService/TeardownLoadBalancers", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AnsiblerServiceServer).TeardownLoadBalancers(ctx, req.(*TeardownLBRequest)) @@ -247,7 +238,7 @@ func _AnsiblerService_UpdateAPIEndpoint_Handler(srv interface{}, ctx context.Con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: AnsiblerService_UpdateAPIEndpoint_FullMethodName, + FullMethod: "/claudie.AnsiblerService/UpdateAPIEndpoint", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AnsiblerServiceServer).UpdateAPIEndpoint(ctx, req.(*UpdateAPIEndpointRequest)) @@ -265,7 +256,7 @@ func _AnsiblerService_RemoveClaudieUtilities_Handler(srv interface{}, ctx contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: AnsiblerService_RemoveClaudieUtilities_FullMethodName, + FullMethod: "/claudie.AnsiblerService/RemoveClaudieUtilities", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(AnsiblerServiceServer).RemoveClaudieUtilities(ctx, req.(*RemoveClaudieUtilitiesRequest)) diff --git a/proto/pb/claudie-operator.pb.go b/proto/pb/claudie-operator.pb.go index 347c30e7e..1bd6fb13c 100644 --- a/proto/pb/claudie-operator.pb.go +++ b/proto/pb/claudie-operator.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v4.25.1 +// protoc-gen-go v1.28.1 +// protoc v5.26.1 // source: proto/claudie-operator.proto package pb diff --git a/proto/pb/claudie-operator_grpc.pb.go b/proto/pb/claudie-operator_grpc.pb.go index a0338bd68..1e34f1c82 100644 --- a/proto/pb/claudie-operator_grpc.pb.go +++ b/proto/pb/claudie-operator_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.1 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.26.1 // source: proto/claudie-operator.proto package pb @@ -18,10 +18,6 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 -const ( - OperatorService_SendAutoscalerEvent_FullMethodName = "/claudie.OperatorService/SendAutoscalerEvent" -) - // OperatorServiceClient is the client API for OperatorService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -40,7 +36,7 @@ func NewOperatorServiceClient(cc grpc.ClientConnInterface) OperatorServiceClient func (c *operatorServiceClient) SendAutoscalerEvent(ctx context.Context, in *SendAutoscalerEventRequest, opts ...grpc.CallOption) (*SendAutoscalerEventResponse, error) { out := new(SendAutoscalerEventResponse) - err := c.cc.Invoke(ctx, OperatorService_SendAutoscalerEvent_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.OperatorService/SendAutoscalerEvent", in, out, opts...) if err != nil { return nil, err } @@ -86,7 +82,7 @@ func _OperatorService_SendAutoscalerEvent_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: OperatorService_SendAutoscalerEvent_FullMethodName, + FullMethod: "/claudie.OperatorService/SendAutoscalerEvent", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(OperatorServiceServer).SendAutoscalerEvent(ctx, req.(*SendAutoscalerEventRequest)) diff --git a/proto/pb/config.pb.go b/proto/pb/config.pb.go index 69684b323..c3c896a8b 100644 --- a/proto/pb/config.pb.go +++ b/proto/pb/config.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v4.25.1 +// protoc-gen-go v1.28.1 +// protoc v5.26.1 // source: proto/config.proto package pb diff --git a/proto/pb/contextBox.pb.go b/proto/pb/contextBox.pb.go index 9bbb830bf..f32cf91e9 100644 --- a/proto/pb/contextBox.pb.go +++ b/proto/pb/contextBox.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v4.25.1 +// protoc-gen-go v1.28.1 +// protoc v5.26.1 // source: proto/contextBox.proto package pb diff --git a/proto/pb/contextBox_grpc.pb.go b/proto/pb/contextBox_grpc.pb.go index e252a8ee5..fe02481d5 100644 --- a/proto/pb/contextBox_grpc.pb.go +++ b/proto/pb/contextBox_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.1 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.26.1 // source: proto/contextBox.proto package pb @@ -18,20 +18,6 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 -const ( - ContextBoxService_SaveConfigOperator_FullMethodName = "/claudie.ContextBoxService/SaveConfigOperator" - ContextBoxService_SaveConfigScheduler_FullMethodName = "/claudie.ContextBoxService/SaveConfigScheduler" - ContextBoxService_SaveConfigBuilder_FullMethodName = "/claudie.ContextBoxService/SaveConfigBuilder" - ContextBoxService_SaveWorkflowState_FullMethodName = "/claudie.ContextBoxService/SaveWorkflowState" - ContextBoxService_GetConfigFromDB_FullMethodName = "/claudie.ContextBoxService/GetConfigFromDB" - ContextBoxService_GetConfigScheduler_FullMethodName = "/claudie.ContextBoxService/GetConfigScheduler" - ContextBoxService_GetConfigBuilder_FullMethodName = "/claudie.ContextBoxService/GetConfigBuilder" - ContextBoxService_GetAllConfigs_FullMethodName = "/claudie.ContextBoxService/GetAllConfigs" - ContextBoxService_DeleteConfig_FullMethodName = "/claudie.ContextBoxService/DeleteConfig" - ContextBoxService_DeleteConfigFromDB_FullMethodName = "/claudie.ContextBoxService/DeleteConfigFromDB" - ContextBoxService_UpdateNodepool_FullMethodName = "/claudie.ContextBoxService/UpdateNodepool" -) - // ContextBoxServiceClient is the client API for ContextBoxService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -71,7 +57,7 @@ func NewContextBoxServiceClient(cc grpc.ClientConnInterface) ContextBoxServiceCl func (c *contextBoxServiceClient) SaveConfigOperator(ctx context.Context, in *SaveConfigRequest, opts ...grpc.CallOption) (*SaveConfigResponse, error) { out := new(SaveConfigResponse) - err := c.cc.Invoke(ctx, ContextBoxService_SaveConfigOperator_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/SaveConfigOperator", in, out, opts...) if err != nil { return nil, err } @@ -80,7 +66,7 @@ func (c *contextBoxServiceClient) SaveConfigOperator(ctx context.Context, in *Sa func (c *contextBoxServiceClient) SaveConfigScheduler(ctx context.Context, in *SaveConfigRequest, opts ...grpc.CallOption) (*SaveConfigResponse, error) { out := new(SaveConfigResponse) - err := c.cc.Invoke(ctx, ContextBoxService_SaveConfigScheduler_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/SaveConfigScheduler", in, out, opts...) if err != nil { return nil, err } @@ -89,7 +75,7 @@ func (c *contextBoxServiceClient) SaveConfigScheduler(ctx context.Context, in *S func (c *contextBoxServiceClient) SaveConfigBuilder(ctx context.Context, in *SaveConfigRequest, opts ...grpc.CallOption) (*SaveConfigResponse, error) { out := new(SaveConfigResponse) - err := c.cc.Invoke(ctx, ContextBoxService_SaveConfigBuilder_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/SaveConfigBuilder", in, out, opts...) if err != nil { return nil, err } @@ -98,7 +84,7 @@ func (c *contextBoxServiceClient) SaveConfigBuilder(ctx context.Context, in *Sav func (c *contextBoxServiceClient) SaveWorkflowState(ctx context.Context, in *SaveWorkflowStateRequest, opts ...grpc.CallOption) (*SaveWorkflowStateResponse, error) { out := new(SaveWorkflowStateResponse) - err := c.cc.Invoke(ctx, ContextBoxService_SaveWorkflowState_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/SaveWorkflowState", in, out, opts...) if err != nil { return nil, err } @@ -107,7 +93,7 @@ func (c *contextBoxServiceClient) SaveWorkflowState(ctx context.Context, in *Sav func (c *contextBoxServiceClient) GetConfigFromDB(ctx context.Context, in *GetConfigFromDBRequest, opts ...grpc.CallOption) (*GetConfigFromDBResponse, error) { out := new(GetConfigFromDBResponse) - err := c.cc.Invoke(ctx, ContextBoxService_GetConfigFromDB_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/GetConfigFromDB", in, out, opts...) if err != nil { return nil, err } @@ -116,7 +102,7 @@ func (c *contextBoxServiceClient) GetConfigFromDB(ctx context.Context, in *GetCo func (c *contextBoxServiceClient) GetConfigScheduler(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error) { out := new(GetConfigResponse) - err := c.cc.Invoke(ctx, ContextBoxService_GetConfigScheduler_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/GetConfigScheduler", in, out, opts...) if err != nil { return nil, err } @@ -125,7 +111,7 @@ func (c *contextBoxServiceClient) GetConfigScheduler(ctx context.Context, in *Ge func (c *contextBoxServiceClient) GetConfigBuilder(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error) { out := new(GetConfigResponse) - err := c.cc.Invoke(ctx, ContextBoxService_GetConfigBuilder_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/GetConfigBuilder", in, out, opts...) if err != nil { return nil, err } @@ -134,7 +120,7 @@ func (c *contextBoxServiceClient) GetConfigBuilder(ctx context.Context, in *GetC func (c *contextBoxServiceClient) GetAllConfigs(ctx context.Context, in *GetAllConfigsRequest, opts ...grpc.CallOption) (*GetAllConfigsResponse, error) { out := new(GetAllConfigsResponse) - err := c.cc.Invoke(ctx, ContextBoxService_GetAllConfigs_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/GetAllConfigs", in, out, opts...) if err != nil { return nil, err } @@ -143,7 +129,7 @@ func (c *contextBoxServiceClient) GetAllConfigs(ctx context.Context, in *GetAllC func (c *contextBoxServiceClient) DeleteConfig(ctx context.Context, in *DeleteConfigRequest, opts ...grpc.CallOption) (*DeleteConfigResponse, error) { out := new(DeleteConfigResponse) - err := c.cc.Invoke(ctx, ContextBoxService_DeleteConfig_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/DeleteConfig", in, out, opts...) if err != nil { return nil, err } @@ -152,7 +138,7 @@ func (c *contextBoxServiceClient) DeleteConfig(ctx context.Context, in *DeleteCo func (c *contextBoxServiceClient) DeleteConfigFromDB(ctx context.Context, in *DeleteConfigRequest, opts ...grpc.CallOption) (*DeleteConfigResponse, error) { out := new(DeleteConfigResponse) - err := c.cc.Invoke(ctx, ContextBoxService_DeleteConfigFromDB_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/DeleteConfigFromDB", in, out, opts...) if err != nil { return nil, err } @@ -161,7 +147,7 @@ func (c *contextBoxServiceClient) DeleteConfigFromDB(ctx context.Context, in *De func (c *contextBoxServiceClient) UpdateNodepool(ctx context.Context, in *UpdateNodepoolRequest, opts ...grpc.CallOption) (*UpdateNodepoolResponse, error) { out := new(UpdateNodepoolResponse) - err := c.cc.Invoke(ctx, ContextBoxService_UpdateNodepool_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.ContextBoxService/UpdateNodepool", in, out, opts...) if err != nil { return nil, err } @@ -258,7 +244,7 @@ func _ContextBoxService_SaveConfigOperator_Handler(srv interface{}, ctx context. } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_SaveConfigOperator_FullMethodName, + FullMethod: "/claudie.ContextBoxService/SaveConfigOperator", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).SaveConfigOperator(ctx, req.(*SaveConfigRequest)) @@ -276,7 +262,7 @@ func _ContextBoxService_SaveConfigScheduler_Handler(srv interface{}, ctx context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_SaveConfigScheduler_FullMethodName, + FullMethod: "/claudie.ContextBoxService/SaveConfigScheduler", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).SaveConfigScheduler(ctx, req.(*SaveConfigRequest)) @@ -294,7 +280,7 @@ func _ContextBoxService_SaveConfigBuilder_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_SaveConfigBuilder_FullMethodName, + FullMethod: "/claudie.ContextBoxService/SaveConfigBuilder", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).SaveConfigBuilder(ctx, req.(*SaveConfigRequest)) @@ -312,7 +298,7 @@ func _ContextBoxService_SaveWorkflowState_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_SaveWorkflowState_FullMethodName, + FullMethod: "/claudie.ContextBoxService/SaveWorkflowState", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).SaveWorkflowState(ctx, req.(*SaveWorkflowStateRequest)) @@ -330,7 +316,7 @@ func _ContextBoxService_GetConfigFromDB_Handler(srv interface{}, ctx context.Con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_GetConfigFromDB_FullMethodName, + FullMethod: "/claudie.ContextBoxService/GetConfigFromDB", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).GetConfigFromDB(ctx, req.(*GetConfigFromDBRequest)) @@ -348,7 +334,7 @@ func _ContextBoxService_GetConfigScheduler_Handler(srv interface{}, ctx context. } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_GetConfigScheduler_FullMethodName, + FullMethod: "/claudie.ContextBoxService/GetConfigScheduler", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).GetConfigScheduler(ctx, req.(*GetConfigRequest)) @@ -366,7 +352,7 @@ func _ContextBoxService_GetConfigBuilder_Handler(srv interface{}, ctx context.Co } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_GetConfigBuilder_FullMethodName, + FullMethod: "/claudie.ContextBoxService/GetConfigBuilder", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).GetConfigBuilder(ctx, req.(*GetConfigRequest)) @@ -384,7 +370,7 @@ func _ContextBoxService_GetAllConfigs_Handler(srv interface{}, ctx context.Conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_GetAllConfigs_FullMethodName, + FullMethod: "/claudie.ContextBoxService/GetAllConfigs", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).GetAllConfigs(ctx, req.(*GetAllConfigsRequest)) @@ -402,7 +388,7 @@ func _ContextBoxService_DeleteConfig_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_DeleteConfig_FullMethodName, + FullMethod: "/claudie.ContextBoxService/DeleteConfig", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).DeleteConfig(ctx, req.(*DeleteConfigRequest)) @@ -420,7 +406,7 @@ func _ContextBoxService_DeleteConfigFromDB_Handler(srv interface{}, ctx context. } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_DeleteConfigFromDB_FullMethodName, + FullMethod: "/claudie.ContextBoxService/DeleteConfigFromDB", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).DeleteConfigFromDB(ctx, req.(*DeleteConfigRequest)) @@ -438,7 +424,7 @@ func _ContextBoxService_UpdateNodepool_Handler(srv interface{}, ctx context.Cont } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: ContextBoxService_UpdateNodepool_FullMethodName, + FullMethod: "/claudie.ContextBoxService/UpdateNodepool", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ContextBoxServiceServer).UpdateNodepool(ctx, req.(*UpdateNodepoolRequest)) diff --git a/proto/pb/kubeEleven.pb.go b/proto/pb/kubeEleven.pb.go index 1f69fac73..66488f8e9 100644 --- a/proto/pb/kubeEleven.pb.go +++ b/proto/pb/kubeEleven.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v4.25.1 +// protoc-gen-go v1.28.1 +// protoc v5.26.1 // source: proto/kubeEleven.proto package pb diff --git a/proto/pb/kubeEleven_grpc.pb.go b/proto/pb/kubeEleven_grpc.pb.go index c83810da6..9e886d644 100644 --- a/proto/pb/kubeEleven_grpc.pb.go +++ b/proto/pb/kubeEleven_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.1 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.26.1 // source: proto/kubeEleven.proto package pb @@ -18,11 +18,6 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 -const ( - KubeElevenService_BuildCluster_FullMethodName = "/claudie.KubeElevenService/BuildCluster" - KubeElevenService_DestroyCluster_FullMethodName = "/claudie.KubeElevenService/DestroyCluster" -) - // KubeElevenServiceClient is the client API for KubeElevenService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -43,7 +38,7 @@ func NewKubeElevenServiceClient(cc grpc.ClientConnInterface) KubeElevenServiceCl func (c *kubeElevenServiceClient) BuildCluster(ctx context.Context, in *BuildClusterRequest, opts ...grpc.CallOption) (*BuildClusterResponse, error) { out := new(BuildClusterResponse) - err := c.cc.Invoke(ctx, KubeElevenService_BuildCluster_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KubeElevenService/BuildCluster", in, out, opts...) if err != nil { return nil, err } @@ -52,7 +47,7 @@ func (c *kubeElevenServiceClient) BuildCluster(ctx context.Context, in *BuildClu func (c *kubeElevenServiceClient) DestroyCluster(ctx context.Context, in *DestroyClusterRequest, opts ...grpc.CallOption) (*DestroyClusterResponse, error) { out := new(DestroyClusterResponse) - err := c.cc.Invoke(ctx, KubeElevenService_DestroyCluster_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KubeElevenService/DestroyCluster", in, out, opts...) if err != nil { return nil, err } @@ -103,7 +98,7 @@ func _KubeElevenService_BuildCluster_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KubeElevenService_BuildCluster_FullMethodName, + FullMethod: "/claudie.KubeElevenService/BuildCluster", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KubeElevenServiceServer).BuildCluster(ctx, req.(*BuildClusterRequest)) @@ -121,7 +116,7 @@ func _KubeElevenService_DestroyCluster_Handler(srv interface{}, ctx context.Cont } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KubeElevenService_DestroyCluster_FullMethodName, + FullMethod: "/claudie.KubeElevenService/DestroyCluster", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KubeElevenServiceServer).DestroyCluster(ctx, req.(*DestroyClusterRequest)) diff --git a/proto/pb/kuber.pb.go b/proto/pb/kuber.pb.go index 54f5c1132..7b3902dc9 100644 --- a/proto/pb/kuber.pb.go +++ b/proto/pb/kuber.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v4.25.1 +// protoc-gen-go v1.28.1 +// protoc v5.26.1 // source: proto/kuber.proto package pb @@ -1207,6 +1207,91 @@ func (*CiliumRolloutRestartResponse) Descriptor() ([]byte, []int) { return file_proto_kuber_proto_rawDescGZIP(), []int{25} } +type PatchKubeProxyConfigMapRequest struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + DesiredCluster *K8Scluster `protobuf:"bytes,1,opt,name=desiredCluster,proto3" json:"desiredCluster,omitempty"` +} + +func (x *PatchKubeProxyConfigMapRequest) Reset() { + *x = PatchKubeProxyConfigMapRequest{} + if protoimpl.UnsafeEnabled { + mi := &file_proto_kuber_proto_msgTypes[26] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PatchKubeProxyConfigMapRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PatchKubeProxyConfigMapRequest) ProtoMessage() {} + +func (x *PatchKubeProxyConfigMapRequest) ProtoReflect() protoreflect.Message { + mi := &file_proto_kuber_proto_msgTypes[26] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PatchKubeProxyConfigMapRequest.ProtoReflect.Descriptor instead. +func (*PatchKubeProxyConfigMapRequest) Descriptor() ([]byte, []int) { + return file_proto_kuber_proto_rawDescGZIP(), []int{26} +} + +func (x *PatchKubeProxyConfigMapRequest) GetDesiredCluster() *K8Scluster { + if x != nil { + return x.DesiredCluster + } + return nil +} + +type PatchKubeProxyConfigMapResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *PatchKubeProxyConfigMapResponse) Reset() { + *x = PatchKubeProxyConfigMapResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_proto_kuber_proto_msgTypes[27] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *PatchKubeProxyConfigMapResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*PatchKubeProxyConfigMapResponse) ProtoMessage() {} + +func (x *PatchKubeProxyConfigMapResponse) ProtoReflect() protoreflect.Message { + mi := &file_proto_kuber_proto_msgTypes[27] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use PatchKubeProxyConfigMapResponse.ProtoReflect.Descriptor instead. +func (*PatchKubeProxyConfigMapResponse) Descriptor() ([]byte, []int) { + return file_proto_kuber_proto_rawDescGZIP(), []int{27} +} + var File_proto_kuber_proto protoreflect.FileDescriptor var file_proto_kuber_proto_rawDesc = []byte{ @@ -1328,78 +1413,93 @@ var file_proto_kuber_proto_rawDesc = []byte{ 0x13, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x4b, 0x38, 0x73, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x07, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x22, 0x1e, 0x0a, 0x1c, 0x43, 0x69, 0x6c, 0x69, 0x75, 0x6d, 0x52, 0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74, 0x52, 0x65, - 0x73, 0x74, 0x61, 0x72, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, 0xe4, 0x09, - 0x0a, 0x0c, 0x4b, 0x75, 0x62, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x63, - 0x0a, 0x14, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x4c, 0x42, 0x53, 0x63, 0x72, 0x61, 0x70, 0x65, - 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x24, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, - 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x4c, 0x42, 0x53, 0x63, 0x72, 0x61, 0x70, 0x65, 0x43, - 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x63, - 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x4c, 0x42, 0x53, - 0x63, 0x72, 0x61, 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, - 0x6e, 0x73, 0x65, 0x12, 0x60, 0x0a, 0x13, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4c, 0x42, 0x53, 0x63, - 0x72, 0x61, 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x23, 0x2e, 0x63, 0x6c, 0x61, - 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4c, 0x42, 0x53, 0x63, 0x72, 0x61, - 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, - 0x24, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4c, + 0x73, 0x74, 0x61, 0x72, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x5d, 0x0a, + 0x1e, 0x50, 0x61, 0x74, 0x63, 0x68, 0x4b, 0x75, 0x62, 0x65, 0x50, 0x72, 0x6f, 0x78, 0x79, 0x43, + 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, + 0x3b, 0x0a, 0x0e, 0x64, 0x65, 0x73, 0x69, 0x72, 0x65, 0x64, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, + 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x13, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, + 0x65, 0x2e, 0x4b, 0x38, 0x73, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x52, 0x0e, 0x64, 0x65, + 0x73, 0x69, 0x72, 0x65, 0x64, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x22, 0x21, 0x0a, 0x1f, + 0x50, 0x61, 0x74, 0x63, 0x68, 0x4b, 0x75, 0x62, 0x65, 0x50, 0x72, 0x6f, 0x78, 0x79, 0x43, 0x6f, + 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x32, + 0xd2, 0x0a, 0x0a, 0x0c, 0x4b, 0x75, 0x62, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, + 0x12, 0x63, 0x0a, 0x14, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x4c, 0x42, 0x53, 0x63, 0x72, 0x61, + 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x24, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, + 0x69, 0x65, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x4c, 0x42, 0x53, 0x63, 0x72, 0x61, 0x70, + 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, + 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x52, 0x65, 0x6d, 0x6f, 0x76, 0x65, 0x4c, 0x42, 0x53, 0x63, 0x72, 0x61, 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x63, 0x0a, 0x14, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x43, 0x6c, - 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x24, 0x2e, - 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x43, 0x6c, 0x75, - 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, - 0x6f, 0x72, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, - 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x66, 0x0a, 0x15, 0x44, 0x65, - 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, - 0x61, 0x74, 0x61, 0x12, 0x25, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, - 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, - 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x63, 0x6c, 0x61, - 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, - 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, - 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x55, 0x70, 0x53, 0x74, 0x6f, 0x72, 0x61, - 0x67, 0x65, 0x12, 0x1c, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x65, 0x74, - 0x55, 0x70, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x1a, 0x1d, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x65, 0x74, 0x55, 0x70, - 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, - 0x54, 0x0a, 0x0f, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, - 0x69, 0x67, 0x12, 0x1f, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, 0x6f, - 0x72, 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, - 0x6f, 0x72, 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x57, 0x0a, 0x10, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4b, - 0x75, 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x20, 0x2e, 0x63, 0x6c, 0x61, 0x75, - 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, - 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x63, 0x6c, + 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x60, 0x0a, 0x13, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4c, 0x42, + 0x53, 0x63, 0x72, 0x61, 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x23, 0x2e, 0x63, + 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4c, 0x42, 0x53, 0x63, + 0x72, 0x61, 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x74, 0x1a, 0x24, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, 0x6f, 0x72, + 0x65, 0x4c, 0x42, 0x53, 0x63, 0x72, 0x61, 0x70, 0x65, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x63, 0x0a, 0x14, 0x53, 0x74, 0x6f, 0x72, 0x65, + 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, + 0x24, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x43, + 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x25, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, + 0x53, 0x74, 0x6f, 0x72, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, + 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x66, 0x0a, 0x15, + 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, + 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x25, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, + 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, + 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x63, + 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x43, 0x6c, 0x75, + 0x73, 0x74, 0x65, 0x72, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x52, 0x65, 0x73, 0x70, + 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4b, 0x0a, 0x0c, 0x53, 0x65, 0x74, 0x55, 0x70, 0x53, 0x74, 0x6f, + 0x72, 0x61, 0x67, 0x65, 0x12, 0x1c, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, + 0x65, 0x74, 0x55, 0x70, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x1d, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x65, 0x74, + 0x55, 0x70, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x12, 0x54, 0x0a, 0x0f, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, + 0x6e, 0x66, 0x69, 0x67, 0x12, 0x1f, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, + 0x74, 0x6f, 0x72, 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x20, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, + 0x53, 0x74, 0x6f, 0x72, 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x57, 0x0a, 0x10, 0x44, 0x65, 0x6c, 0x65, 0x74, + 0x65, 0x4b, 0x75, 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x20, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4b, 0x75, 0x62, 0x65, - 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, - 0x0a, 0x0b, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x1b, 0x2e, - 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, - 0x64, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x63, 0x6c, 0x61, - 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x73, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x45, 0x0a, 0x0a, 0x50, 0x61, 0x74, 0x63, - 0x68, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x1a, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, - 0x2e, 0x50, 0x61, 0x74, 0x63, 0x68, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x50, 0x61, 0x74, - 0x63, 0x68, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, - 0x69, 0x0a, 0x16, 0x53, 0x65, 0x74, 0x55, 0x70, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, - 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x12, 0x26, 0x2e, 0x63, 0x6c, 0x61, 0x75, - 0x64, 0x69, 0x65, 0x2e, 0x53, 0x65, 0x74, 0x55, 0x70, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, - 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, - 0x74, 0x1a, 0x27, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x65, 0x74, 0x55, - 0x70, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, - 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x6f, 0x0a, 0x18, 0x44, 0x65, - 0x73, 0x74, 0x72, 0x6f, 0x79, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, 0x75, 0x74, 0x6f, - 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x12, 0x28, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, - 0x2e, 0x44, 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, - 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x1a, 0x29, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x73, 0x74, 0x72, - 0x6f, 0x79, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, - 0x6c, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x72, 0x0a, 0x19, 0x50, - 0x61, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x43, - 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x12, 0x29, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, - 0x69, 0x65, 0x2e, 0x50, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, - 0x6e, 0x66, 0x6f, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x1a, 0x2a, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x50, 0x61, - 0x74, 0x63, 0x68, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x43, 0x6f, + 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, + 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4b, 0x75, + 0x62, 0x65, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, + 0x12, 0x48, 0x0a, 0x0b, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, + 0x1b, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, + 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x63, + 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x4e, 0x6f, 0x64, + 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x45, 0x0a, 0x0a, 0x50, 0x61, + 0x74, 0x63, 0x68, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x12, 0x1a, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, + 0x69, 0x65, 0x2e, 0x50, 0x61, 0x74, 0x63, 0x68, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x50, + 0x61, 0x74, 0x63, 0x68, 0x4e, 0x6f, 0x64, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x12, 0x69, 0x0a, 0x16, 0x53, 0x65, 0x74, 0x55, 0x70, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, + 0x72, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x12, 0x26, 0x2e, 0x63, 0x6c, + 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x65, 0x74, 0x55, 0x70, 0x43, 0x6c, 0x75, 0x73, 0x74, + 0x65, 0x72, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x27, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x53, 0x65, + 0x74, 0x55, 0x70, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, + 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x6f, 0x0a, 0x18, + 0x44, 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, 0x75, + 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x12, 0x28, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, + 0x69, 0x65, 0x2e, 0x44, 0x65, 0x73, 0x74, 0x72, 0x6f, 0x79, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, + 0x72, 0x41, 0x75, 0x74, 0x6f, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, + 0x73, 0x74, 0x1a, 0x29, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x44, 0x65, 0x73, + 0x74, 0x72, 0x6f, 0x79, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x41, 0x75, 0x74, 0x6f, 0x73, + 0x63, 0x61, 0x6c, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x72, 0x0a, + 0x19, 0x50, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, 0x6e, 0x66, + 0x6f, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x12, 0x29, 0x2e, 0x63, 0x6c, 0x61, + 0x75, 0x64, 0x69, 0x65, 0x2e, 0x50, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, + 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x2a, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, + 0x50, 0x61, 0x74, 0x63, 0x68, 0x43, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, + 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, + 0x65, 0x12, 0x6c, 0x0a, 0x17, 0x50, 0x61, 0x74, 0x63, 0x68, 0x4b, 0x75, 0x62, 0x65, 0x50, 0x72, + 0x6f, 0x78, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x12, 0x27, 0x2e, 0x63, + 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, 0x50, 0x61, 0x74, 0x63, 0x68, 0x4b, 0x75, 0x62, 0x65, + 0x50, 0x72, 0x6f, 0x78, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x28, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, 0x65, 0x2e, + 0x50, 0x61, 0x74, 0x63, 0x68, 0x4b, 0x75, 0x62, 0x65, 0x50, 0x72, 0x6f, 0x78, 0x79, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4d, 0x61, 0x70, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x63, 0x0a, 0x14, 0x43, 0x69, 0x6c, 0x69, 0x75, 0x6d, 0x52, 0x6f, 0x6c, 0x6c, 0x6f, 0x75, 0x74, 0x52, 0x65, 0x73, 0x74, 0x61, 0x72, 0x74, 0x12, 0x24, 0x2e, 0x63, 0x6c, 0x61, 0x75, 0x64, 0x69, @@ -1423,7 +1523,7 @@ func file_proto_kuber_proto_rawDescGZIP() []byte { return file_proto_kuber_proto_rawDescData } -var file_proto_kuber_proto_msgTypes = make([]protoimpl.MessageInfo, 26) +var file_proto_kuber_proto_msgTypes = make([]protoimpl.MessageInfo, 28) var file_proto_kuber_proto_goTypes = []interface{}{ (*SetUpStorageRequest)(nil), // 0: claudie.SetUpStorageRequest (*SetUpStorageResponse)(nil), // 1: claudie.SetUpStorageResponse @@ -1451,58 +1551,63 @@ var file_proto_kuber_proto_goTypes = []interface{}{ (*PatchClusterInfoConfigMapResponse)(nil), // 23: claudie.PatchClusterInfoConfigMapResponse (*CiliumRolloutRestartRequest)(nil), // 24: claudie.CiliumRolloutRestartRequest (*CiliumRolloutRestartResponse)(nil), // 25: claudie.CiliumRolloutRestartResponse - (*K8Scluster)(nil), // 26: claudie.K8scluster - (*LBcluster)(nil), // 27: claudie.LBcluster + (*PatchKubeProxyConfigMapRequest)(nil), // 26: claudie.PatchKubeProxyConfigMapRequest + (*PatchKubeProxyConfigMapResponse)(nil), // 27: claudie.PatchKubeProxyConfigMapResponse + (*K8Scluster)(nil), // 28: claudie.K8scluster + (*LBcluster)(nil), // 29: claudie.LBcluster } var file_proto_kuber_proto_depIdxs = []int32{ - 26, // 0: claudie.SetUpStorageRequest.desiredCluster:type_name -> claudie.K8scluster - 26, // 1: claudie.SetUpStorageResponse.desiredCluster:type_name -> claudie.K8scluster - 26, // 2: claudie.StoreKubeconfigRequest.cluster:type_name -> claudie.K8scluster - 26, // 3: claudie.DeleteKubeconfigRequest.cluster:type_name -> claudie.K8scluster - 26, // 4: claudie.DeleteNodesRequest.cluster:type_name -> claudie.K8scluster - 26, // 5: claudie.DeleteNodesResponse.cluster:type_name -> claudie.K8scluster - 26, // 6: claudie.StoreClusterMetadataRequest.cluster:type_name -> claudie.K8scluster - 27, // 7: claudie.StoreClusterMetadataRequest.loadbalancers:type_name -> claudie.LBcluster - 26, // 8: claudie.StoreLBScrapeConfigRequest.cluster:type_name -> claudie.K8scluster - 27, // 9: claudie.StoreLBScrapeConfigRequest.desiredLoadbalancers:type_name -> claudie.LBcluster - 26, // 10: claudie.RemoveLBScrapeConfigRequest.cluster:type_name -> claudie.K8scluster - 26, // 11: claudie.DeleteClusterMetadataRequest.cluster:type_name -> claudie.K8scluster - 26, // 12: claudie.PatchNodesRequest.cluster:type_name -> claudie.K8scluster - 26, // 13: claudie.SetUpClusterAutoscalerRequest.cluster:type_name -> claudie.K8scluster - 26, // 14: claudie.DestroyClusterAutoscalerRequest.cluster:type_name -> claudie.K8scluster - 26, // 15: claudie.PatchClusterInfoConfigMapRequest.desiredCluster:type_name -> claudie.K8scluster - 26, // 16: claudie.CiliumRolloutRestartRequest.cluster:type_name -> claudie.K8scluster - 12, // 17: claudie.KuberService.RemoveLBScrapeConfig:input_type -> claudie.RemoveLBScrapeConfigRequest - 10, // 18: claudie.KuberService.StoreLBScrapeConfig:input_type -> claudie.StoreLBScrapeConfigRequest - 8, // 19: claudie.KuberService.StoreClusterMetadata:input_type -> claudie.StoreClusterMetadataRequest - 14, // 20: claudie.KuberService.DeleteClusterMetadata:input_type -> claudie.DeleteClusterMetadataRequest - 0, // 21: claudie.KuberService.SetUpStorage:input_type -> claudie.SetUpStorageRequest - 2, // 22: claudie.KuberService.StoreKubeconfig:input_type -> claudie.StoreKubeconfigRequest - 4, // 23: claudie.KuberService.DeleteKubeconfig:input_type -> claudie.DeleteKubeconfigRequest - 6, // 24: claudie.KuberService.DeleteNodes:input_type -> claudie.DeleteNodesRequest - 16, // 25: claudie.KuberService.PatchNodes:input_type -> claudie.PatchNodesRequest - 18, // 26: claudie.KuberService.SetUpClusterAutoscaler:input_type -> claudie.SetUpClusterAutoscalerRequest - 20, // 27: claudie.KuberService.DestroyClusterAutoscaler:input_type -> claudie.DestroyClusterAutoscalerRequest - 22, // 28: claudie.KuberService.PatchClusterInfoConfigMap:input_type -> claudie.PatchClusterInfoConfigMapRequest - 24, // 29: claudie.KuberService.CiliumRolloutRestart:input_type -> claudie.CiliumRolloutRestartRequest - 13, // 30: claudie.KuberService.RemoveLBScrapeConfig:output_type -> claudie.RemoveLBScrapeConfigResponse - 11, // 31: claudie.KuberService.StoreLBScrapeConfig:output_type -> claudie.StoreLBScrapeConfigResponse - 9, // 32: claudie.KuberService.StoreClusterMetadata:output_type -> claudie.StoreClusterMetadataResponse - 15, // 33: claudie.KuberService.DeleteClusterMetadata:output_type -> claudie.DeleteClusterMetadataResponse - 1, // 34: claudie.KuberService.SetUpStorage:output_type -> claudie.SetUpStorageResponse - 3, // 35: claudie.KuberService.StoreKubeconfig:output_type -> claudie.StoreKubeconfigResponse - 5, // 36: claudie.KuberService.DeleteKubeconfig:output_type -> claudie.DeleteKubeconfigResponse - 7, // 37: claudie.KuberService.DeleteNodes:output_type -> claudie.DeleteNodesResponse - 17, // 38: claudie.KuberService.PatchNodes:output_type -> claudie.PatchNodesResponse - 19, // 39: claudie.KuberService.SetUpClusterAutoscaler:output_type -> claudie.SetUpClusterAutoscalerResponse - 21, // 40: claudie.KuberService.DestroyClusterAutoscaler:output_type -> claudie.DestroyClusterAutoscalerResponse - 23, // 41: claudie.KuberService.PatchClusterInfoConfigMap:output_type -> claudie.PatchClusterInfoConfigMapResponse - 25, // 42: claudie.KuberService.CiliumRolloutRestart:output_type -> claudie.CiliumRolloutRestartResponse - 30, // [30:43] is the sub-list for method output_type - 17, // [17:30] is the sub-list for method input_type - 17, // [17:17] is the sub-list for extension type_name - 17, // [17:17] is the sub-list for extension extendee - 0, // [0:17] is the sub-list for field type_name + 28, // 0: claudie.SetUpStorageRequest.desiredCluster:type_name -> claudie.K8scluster + 28, // 1: claudie.SetUpStorageResponse.desiredCluster:type_name -> claudie.K8scluster + 28, // 2: claudie.StoreKubeconfigRequest.cluster:type_name -> claudie.K8scluster + 28, // 3: claudie.DeleteKubeconfigRequest.cluster:type_name -> claudie.K8scluster + 28, // 4: claudie.DeleteNodesRequest.cluster:type_name -> claudie.K8scluster + 28, // 5: claudie.DeleteNodesResponse.cluster:type_name -> claudie.K8scluster + 28, // 6: claudie.StoreClusterMetadataRequest.cluster:type_name -> claudie.K8scluster + 29, // 7: claudie.StoreClusterMetadataRequest.loadbalancers:type_name -> claudie.LBcluster + 28, // 8: claudie.StoreLBScrapeConfigRequest.cluster:type_name -> claudie.K8scluster + 29, // 9: claudie.StoreLBScrapeConfigRequest.desiredLoadbalancers:type_name -> claudie.LBcluster + 28, // 10: claudie.RemoveLBScrapeConfigRequest.cluster:type_name -> claudie.K8scluster + 28, // 11: claudie.DeleteClusterMetadataRequest.cluster:type_name -> claudie.K8scluster + 28, // 12: claudie.PatchNodesRequest.cluster:type_name -> claudie.K8scluster + 28, // 13: claudie.SetUpClusterAutoscalerRequest.cluster:type_name -> claudie.K8scluster + 28, // 14: claudie.DestroyClusterAutoscalerRequest.cluster:type_name -> claudie.K8scluster + 28, // 15: claudie.PatchClusterInfoConfigMapRequest.desiredCluster:type_name -> claudie.K8scluster + 28, // 16: claudie.CiliumRolloutRestartRequest.cluster:type_name -> claudie.K8scluster + 28, // 17: claudie.PatchKubeProxyConfigMapRequest.desiredCluster:type_name -> claudie.K8scluster + 12, // 18: claudie.KuberService.RemoveLBScrapeConfig:input_type -> claudie.RemoveLBScrapeConfigRequest + 10, // 19: claudie.KuberService.StoreLBScrapeConfig:input_type -> claudie.StoreLBScrapeConfigRequest + 8, // 20: claudie.KuberService.StoreClusterMetadata:input_type -> claudie.StoreClusterMetadataRequest + 14, // 21: claudie.KuberService.DeleteClusterMetadata:input_type -> claudie.DeleteClusterMetadataRequest + 0, // 22: claudie.KuberService.SetUpStorage:input_type -> claudie.SetUpStorageRequest + 2, // 23: claudie.KuberService.StoreKubeconfig:input_type -> claudie.StoreKubeconfigRequest + 4, // 24: claudie.KuberService.DeleteKubeconfig:input_type -> claudie.DeleteKubeconfigRequest + 6, // 25: claudie.KuberService.DeleteNodes:input_type -> claudie.DeleteNodesRequest + 16, // 26: claudie.KuberService.PatchNodes:input_type -> claudie.PatchNodesRequest + 18, // 27: claudie.KuberService.SetUpClusterAutoscaler:input_type -> claudie.SetUpClusterAutoscalerRequest + 20, // 28: claudie.KuberService.DestroyClusterAutoscaler:input_type -> claudie.DestroyClusterAutoscalerRequest + 22, // 29: claudie.KuberService.PatchClusterInfoConfigMap:input_type -> claudie.PatchClusterInfoConfigMapRequest + 26, // 30: claudie.KuberService.PatchKubeProxyConfigMap:input_type -> claudie.PatchKubeProxyConfigMapRequest + 24, // 31: claudie.KuberService.CiliumRolloutRestart:input_type -> claudie.CiliumRolloutRestartRequest + 13, // 32: claudie.KuberService.RemoveLBScrapeConfig:output_type -> claudie.RemoveLBScrapeConfigResponse + 11, // 33: claudie.KuberService.StoreLBScrapeConfig:output_type -> claudie.StoreLBScrapeConfigResponse + 9, // 34: claudie.KuberService.StoreClusterMetadata:output_type -> claudie.StoreClusterMetadataResponse + 15, // 35: claudie.KuberService.DeleteClusterMetadata:output_type -> claudie.DeleteClusterMetadataResponse + 1, // 36: claudie.KuberService.SetUpStorage:output_type -> claudie.SetUpStorageResponse + 3, // 37: claudie.KuberService.StoreKubeconfig:output_type -> claudie.StoreKubeconfigResponse + 5, // 38: claudie.KuberService.DeleteKubeconfig:output_type -> claudie.DeleteKubeconfigResponse + 7, // 39: claudie.KuberService.DeleteNodes:output_type -> claudie.DeleteNodesResponse + 17, // 40: claudie.KuberService.PatchNodes:output_type -> claudie.PatchNodesResponse + 19, // 41: claudie.KuberService.SetUpClusterAutoscaler:output_type -> claudie.SetUpClusterAutoscalerResponse + 21, // 42: claudie.KuberService.DestroyClusterAutoscaler:output_type -> claudie.DestroyClusterAutoscalerResponse + 23, // 43: claudie.KuberService.PatchClusterInfoConfigMap:output_type -> claudie.PatchClusterInfoConfigMapResponse + 27, // 44: claudie.KuberService.PatchKubeProxyConfigMap:output_type -> claudie.PatchKubeProxyConfigMapResponse + 25, // 45: claudie.KuberService.CiliumRolloutRestart:output_type -> claudie.CiliumRolloutRestartResponse + 32, // [32:46] is the sub-list for method output_type + 18, // [18:32] is the sub-list for method input_type + 18, // [18:18] is the sub-list for extension type_name + 18, // [18:18] is the sub-list for extension extendee + 0, // [0:18] is the sub-list for field type_name } func init() { file_proto_kuber_proto_init() } @@ -1824,6 +1929,30 @@ func file_proto_kuber_proto_init() { return nil } } + file_proto_kuber_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PatchKubeProxyConfigMapRequest); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_proto_kuber_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*PatchKubeProxyConfigMapResponse); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } } type x struct{} out := protoimpl.TypeBuilder{ @@ -1831,7 +1960,7 @@ func file_proto_kuber_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_proto_kuber_proto_rawDesc, NumEnums: 0, - NumMessages: 26, + NumMessages: 28, NumExtensions: 0, NumServices: 1, }, diff --git a/proto/pb/kuber_grpc.pb.go b/proto/pb/kuber_grpc.pb.go index 0d86f7340..082d201e1 100644 --- a/proto/pb/kuber_grpc.pb.go +++ b/proto/pb/kuber_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.1 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.26.1 // source: proto/kuber.proto package pb @@ -18,52 +18,51 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 -const ( - KuberService_RemoveLBScrapeConfig_FullMethodName = "/claudie.KuberService/RemoveLBScrapeConfig" - KuberService_StoreLBScrapeConfig_FullMethodName = "/claudie.KuberService/StoreLBScrapeConfig" - KuberService_StoreClusterMetadata_FullMethodName = "/claudie.KuberService/StoreClusterMetadata" - KuberService_DeleteClusterMetadata_FullMethodName = "/claudie.KuberService/DeleteClusterMetadata" - KuberService_SetUpStorage_FullMethodName = "/claudie.KuberService/SetUpStorage" - KuberService_StoreKubeconfig_FullMethodName = "/claudie.KuberService/StoreKubeconfig" - KuberService_DeleteKubeconfig_FullMethodName = "/claudie.KuberService/DeleteKubeconfig" - KuberService_DeleteNodes_FullMethodName = "/claudie.KuberService/DeleteNodes" - KuberService_PatchNodes_FullMethodName = "/claudie.KuberService/PatchNodes" - KuberService_SetUpClusterAutoscaler_FullMethodName = "/claudie.KuberService/SetUpClusterAutoscaler" - KuberService_DestroyClusterAutoscaler_FullMethodName = "/claudie.KuberService/DestroyClusterAutoscaler" - KuberService_PatchClusterInfoConfigMap_FullMethodName = "/claudie.KuberService/PatchClusterInfoConfigMap" - KuberService_CiliumRolloutRestart_FullMethodName = "/claudie.KuberService/CiliumRolloutRestart" -) - // KuberServiceClient is the client API for KuberService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type KuberServiceClient interface { - // RemoveLBScrapeConfig removes scrape config for every LB detached from this cluster. + // RemoveLBScrapeConfig removes scrape config for every LB detached from this + // cluster. RemoveLBScrapeConfig(ctx context.Context, in *RemoveLBScrapeConfigRequest, opts ...grpc.CallOption) (*RemoveLBScrapeConfigResponse, error) - // StoreLBScrapeConfig stores scrape config for every LB attached to this cluster. + // StoreLBScrapeConfig stores scrape config for every LB attached to this + // cluster. StoreLBScrapeConfig(ctx context.Context, in *StoreLBScrapeConfigRequest, opts ...grpc.CallOption) (*StoreLBScrapeConfigResponse, error) - // StoreClusterMetadata creates a secret, which holds the private key and a list of public IP addresses of the cluster supplied. + // StoreClusterMetadata creates a secret, which holds the private key and a + // list of public IP addresses of the cluster supplied. StoreClusterMetadata(ctx context.Context, in *StoreClusterMetadataRequest, opts ...grpc.CallOption) (*StoreClusterMetadataResponse, error) - // DeleteClusterMetadata deletes the secret holding the private key and public IP addresses of the cluster supplied. + // DeleteClusterMetadata deletes the secret holding the private key and public + // IP addresses of the cluster supplied. DeleteClusterMetadata(ctx context.Context, in *DeleteClusterMetadataRequest, opts ...grpc.CallOption) (*DeleteClusterMetadataResponse, error) // SetUpStorage installs Longhorn into the cluster. SetUpStorage(ctx context.Context, in *SetUpStorageRequest, opts ...grpc.CallOption) (*SetUpStorageResponse, error) - // StoreKubeconfig creates a secret, which holds the kubeconfig of a Claudie-created cluster. + // StoreKubeconfig creates a secret, which holds the kubeconfig of a + // Claudie-created cluster. StoreKubeconfig(ctx context.Context, in *StoreKubeconfigRequest, opts ...grpc.CallOption) (*StoreKubeconfigResponse, error) - // DeleteKubeconfig removes the secret that holds the kubeconfig of a Claudie-created cluster. + // DeleteKubeconfig removes the secret that holds the kubeconfig of a + // Claudie-created cluster. DeleteKubeconfig(ctx context.Context, in *DeleteKubeconfigRequest, opts ...grpc.CallOption) (*DeleteKubeconfigResponse, error) // DeleteNodes deletes the specified nodes from a k8s cluster. DeleteNodes(ctx context.Context, in *DeleteNodesRequest, opts ...grpc.CallOption) (*DeleteNodesResponse, error) - // PatchNodes applies attributes like providerID, labels or taints to the nodes. + // PatchNodes applies attributes like providerID, labels or taints to the + // nodes. PatchNodes(ctx context.Context, in *PatchNodesRequest, opts ...grpc.CallOption) (*PatchNodesResponse, error) - // SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter for every cluster specified. + // SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter + // for every cluster specified. SetUpClusterAutoscaler(ctx context.Context, in *SetUpClusterAutoscalerRequest, opts ...grpc.CallOption) (*SetUpClusterAutoscalerResponse, error) - // DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter for every cluster specified. + // DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter + // for every cluster specified. DestroyClusterAutoscaler(ctx context.Context, in *DestroyClusterAutoscalerRequest, opts ...grpc.CallOption) (*DestroyClusterAutoscalerResponse, error) - // PatchClusterInfoConfigMap updates the cluster-info config map in the kube-public namespace with the the - // kubeconfig. This needs to be done after an api endpoint change as the config map in the kube-public namespace - // is used by kubeadm when joining. + // PatchClusterInfoConfigMap updates the cluster-info config map in the + // kube-public namespace with the the kubeconfig. This needs to be done after + // an api endpoint change as the config map in the kube-public namespace is + // used by kubeadm when joining. PatchClusterInfoConfigMap(ctx context.Context, in *PatchClusterInfoConfigMapRequest, opts ...grpc.CallOption) (*PatchClusterInfoConfigMapResponse, error) + // PatchCubeProxyConfigMap updates the kube-proxy config map with the value of + // the server: from the passed in kubeconfig and subsequently restarts all + // kube-proxy pods in the kube-system namespace. This change needs to be done + // after a endpoint change is performed. + PatchKubeProxyConfigMap(ctx context.Context, in *PatchKubeProxyConfigMapRequest, opts ...grpc.CallOption) (*PatchKubeProxyConfigMapResponse, error) // CiliumRolloutRestart performs a rollout restart of the cilium daemonset. CiliumRolloutRestart(ctx context.Context, in *CiliumRolloutRestartRequest, opts ...grpc.CallOption) (*CiliumRolloutRestartResponse, error) } @@ -78,7 +77,7 @@ func NewKuberServiceClient(cc grpc.ClientConnInterface) KuberServiceClient { func (c *kuberServiceClient) RemoveLBScrapeConfig(ctx context.Context, in *RemoveLBScrapeConfigRequest, opts ...grpc.CallOption) (*RemoveLBScrapeConfigResponse, error) { out := new(RemoveLBScrapeConfigResponse) - err := c.cc.Invoke(ctx, KuberService_RemoveLBScrapeConfig_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/RemoveLBScrapeConfig", in, out, opts...) if err != nil { return nil, err } @@ -87,7 +86,7 @@ func (c *kuberServiceClient) RemoveLBScrapeConfig(ctx context.Context, in *Remov func (c *kuberServiceClient) StoreLBScrapeConfig(ctx context.Context, in *StoreLBScrapeConfigRequest, opts ...grpc.CallOption) (*StoreLBScrapeConfigResponse, error) { out := new(StoreLBScrapeConfigResponse) - err := c.cc.Invoke(ctx, KuberService_StoreLBScrapeConfig_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/StoreLBScrapeConfig", in, out, opts...) if err != nil { return nil, err } @@ -96,7 +95,7 @@ func (c *kuberServiceClient) StoreLBScrapeConfig(ctx context.Context, in *StoreL func (c *kuberServiceClient) StoreClusterMetadata(ctx context.Context, in *StoreClusterMetadataRequest, opts ...grpc.CallOption) (*StoreClusterMetadataResponse, error) { out := new(StoreClusterMetadataResponse) - err := c.cc.Invoke(ctx, KuberService_StoreClusterMetadata_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/StoreClusterMetadata", in, out, opts...) if err != nil { return nil, err } @@ -105,7 +104,7 @@ func (c *kuberServiceClient) StoreClusterMetadata(ctx context.Context, in *Store func (c *kuberServiceClient) DeleteClusterMetadata(ctx context.Context, in *DeleteClusterMetadataRequest, opts ...grpc.CallOption) (*DeleteClusterMetadataResponse, error) { out := new(DeleteClusterMetadataResponse) - err := c.cc.Invoke(ctx, KuberService_DeleteClusterMetadata_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/DeleteClusterMetadata", in, out, opts...) if err != nil { return nil, err } @@ -114,7 +113,7 @@ func (c *kuberServiceClient) DeleteClusterMetadata(ctx context.Context, in *Dele func (c *kuberServiceClient) SetUpStorage(ctx context.Context, in *SetUpStorageRequest, opts ...grpc.CallOption) (*SetUpStorageResponse, error) { out := new(SetUpStorageResponse) - err := c.cc.Invoke(ctx, KuberService_SetUpStorage_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/SetUpStorage", in, out, opts...) if err != nil { return nil, err } @@ -123,7 +122,7 @@ func (c *kuberServiceClient) SetUpStorage(ctx context.Context, in *SetUpStorageR func (c *kuberServiceClient) StoreKubeconfig(ctx context.Context, in *StoreKubeconfigRequest, opts ...grpc.CallOption) (*StoreKubeconfigResponse, error) { out := new(StoreKubeconfigResponse) - err := c.cc.Invoke(ctx, KuberService_StoreKubeconfig_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/StoreKubeconfig", in, out, opts...) if err != nil { return nil, err } @@ -132,7 +131,7 @@ func (c *kuberServiceClient) StoreKubeconfig(ctx context.Context, in *StoreKubec func (c *kuberServiceClient) DeleteKubeconfig(ctx context.Context, in *DeleteKubeconfigRequest, opts ...grpc.CallOption) (*DeleteKubeconfigResponse, error) { out := new(DeleteKubeconfigResponse) - err := c.cc.Invoke(ctx, KuberService_DeleteKubeconfig_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/DeleteKubeconfig", in, out, opts...) if err != nil { return nil, err } @@ -141,7 +140,7 @@ func (c *kuberServiceClient) DeleteKubeconfig(ctx context.Context, in *DeleteKub func (c *kuberServiceClient) DeleteNodes(ctx context.Context, in *DeleteNodesRequest, opts ...grpc.CallOption) (*DeleteNodesResponse, error) { out := new(DeleteNodesResponse) - err := c.cc.Invoke(ctx, KuberService_DeleteNodes_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/DeleteNodes", in, out, opts...) if err != nil { return nil, err } @@ -150,7 +149,7 @@ func (c *kuberServiceClient) DeleteNodes(ctx context.Context, in *DeleteNodesReq func (c *kuberServiceClient) PatchNodes(ctx context.Context, in *PatchNodesRequest, opts ...grpc.CallOption) (*PatchNodesResponse, error) { out := new(PatchNodesResponse) - err := c.cc.Invoke(ctx, KuberService_PatchNodes_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/PatchNodes", in, out, opts...) if err != nil { return nil, err } @@ -159,7 +158,7 @@ func (c *kuberServiceClient) PatchNodes(ctx context.Context, in *PatchNodesReque func (c *kuberServiceClient) SetUpClusterAutoscaler(ctx context.Context, in *SetUpClusterAutoscalerRequest, opts ...grpc.CallOption) (*SetUpClusterAutoscalerResponse, error) { out := new(SetUpClusterAutoscalerResponse) - err := c.cc.Invoke(ctx, KuberService_SetUpClusterAutoscaler_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/SetUpClusterAutoscaler", in, out, opts...) if err != nil { return nil, err } @@ -168,7 +167,7 @@ func (c *kuberServiceClient) SetUpClusterAutoscaler(ctx context.Context, in *Set func (c *kuberServiceClient) DestroyClusterAutoscaler(ctx context.Context, in *DestroyClusterAutoscalerRequest, opts ...grpc.CallOption) (*DestroyClusterAutoscalerResponse, error) { out := new(DestroyClusterAutoscalerResponse) - err := c.cc.Invoke(ctx, KuberService_DestroyClusterAutoscaler_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/DestroyClusterAutoscaler", in, out, opts...) if err != nil { return nil, err } @@ -177,7 +176,16 @@ func (c *kuberServiceClient) DestroyClusterAutoscaler(ctx context.Context, in *D func (c *kuberServiceClient) PatchClusterInfoConfigMap(ctx context.Context, in *PatchClusterInfoConfigMapRequest, opts ...grpc.CallOption) (*PatchClusterInfoConfigMapResponse, error) { out := new(PatchClusterInfoConfigMapResponse) - err := c.cc.Invoke(ctx, KuberService_PatchClusterInfoConfigMap_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/PatchClusterInfoConfigMap", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *kuberServiceClient) PatchKubeProxyConfigMap(ctx context.Context, in *PatchKubeProxyConfigMapRequest, opts ...grpc.CallOption) (*PatchKubeProxyConfigMapResponse, error) { + out := new(PatchKubeProxyConfigMapResponse) + err := c.cc.Invoke(ctx, "/claudie.KuberService/PatchKubeProxyConfigMap", in, out, opts...) if err != nil { return nil, err } @@ -186,7 +194,7 @@ func (c *kuberServiceClient) PatchClusterInfoConfigMap(ctx context.Context, in * func (c *kuberServiceClient) CiliumRolloutRestart(ctx context.Context, in *CiliumRolloutRestartRequest, opts ...grpc.CallOption) (*CiliumRolloutRestartResponse, error) { out := new(CiliumRolloutRestartResponse) - err := c.cc.Invoke(ctx, KuberService_CiliumRolloutRestart_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.KuberService/CiliumRolloutRestart", in, out, opts...) if err != nil { return nil, err } @@ -197,32 +205,47 @@ func (c *kuberServiceClient) CiliumRolloutRestart(ctx context.Context, in *Ciliu // All implementations must embed UnimplementedKuberServiceServer // for forward compatibility type KuberServiceServer interface { - // RemoveLBScrapeConfig removes scrape config for every LB detached from this cluster. + // RemoveLBScrapeConfig removes scrape config for every LB detached from this + // cluster. RemoveLBScrapeConfig(context.Context, *RemoveLBScrapeConfigRequest) (*RemoveLBScrapeConfigResponse, error) - // StoreLBScrapeConfig stores scrape config for every LB attached to this cluster. + // StoreLBScrapeConfig stores scrape config for every LB attached to this + // cluster. StoreLBScrapeConfig(context.Context, *StoreLBScrapeConfigRequest) (*StoreLBScrapeConfigResponse, error) - // StoreClusterMetadata creates a secret, which holds the private key and a list of public IP addresses of the cluster supplied. + // StoreClusterMetadata creates a secret, which holds the private key and a + // list of public IP addresses of the cluster supplied. StoreClusterMetadata(context.Context, *StoreClusterMetadataRequest) (*StoreClusterMetadataResponse, error) - // DeleteClusterMetadata deletes the secret holding the private key and public IP addresses of the cluster supplied. + // DeleteClusterMetadata deletes the secret holding the private key and public + // IP addresses of the cluster supplied. DeleteClusterMetadata(context.Context, *DeleteClusterMetadataRequest) (*DeleteClusterMetadataResponse, error) // SetUpStorage installs Longhorn into the cluster. SetUpStorage(context.Context, *SetUpStorageRequest) (*SetUpStorageResponse, error) - // StoreKubeconfig creates a secret, which holds the kubeconfig of a Claudie-created cluster. + // StoreKubeconfig creates a secret, which holds the kubeconfig of a + // Claudie-created cluster. StoreKubeconfig(context.Context, *StoreKubeconfigRequest) (*StoreKubeconfigResponse, error) - // DeleteKubeconfig removes the secret that holds the kubeconfig of a Claudie-created cluster. + // DeleteKubeconfig removes the secret that holds the kubeconfig of a + // Claudie-created cluster. DeleteKubeconfig(context.Context, *DeleteKubeconfigRequest) (*DeleteKubeconfigResponse, error) // DeleteNodes deletes the specified nodes from a k8s cluster. DeleteNodes(context.Context, *DeleteNodesRequest) (*DeleteNodesResponse, error) - // PatchNodes applies attributes like providerID, labels or taints to the nodes. + // PatchNodes applies attributes like providerID, labels or taints to the + // nodes. PatchNodes(context.Context, *PatchNodesRequest) (*PatchNodesResponse, error) - // SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter for every cluster specified. + // SetUpClusterAutoscaler deploys Cluster Autoscaler and Autoscaler Adapter + // for every cluster specified. SetUpClusterAutoscaler(context.Context, *SetUpClusterAutoscalerRequest) (*SetUpClusterAutoscalerResponse, error) - // DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter for every cluster specified. + // DestroyClusterAutoscaler deletes Cluster Autoscaler and Autoscaler Adapter + // for every cluster specified. DestroyClusterAutoscaler(context.Context, *DestroyClusterAutoscalerRequest) (*DestroyClusterAutoscalerResponse, error) - // PatchClusterInfoConfigMap updates the cluster-info config map in the kube-public namespace with the the - // kubeconfig. This needs to be done after an api endpoint change as the config map in the kube-public namespace - // is used by kubeadm when joining. + // PatchClusterInfoConfigMap updates the cluster-info config map in the + // kube-public namespace with the the kubeconfig. This needs to be done after + // an api endpoint change as the config map in the kube-public namespace is + // used by kubeadm when joining. PatchClusterInfoConfigMap(context.Context, *PatchClusterInfoConfigMapRequest) (*PatchClusterInfoConfigMapResponse, error) + // PatchCubeProxyConfigMap updates the kube-proxy config map with the value of + // the server: from the passed in kubeconfig and subsequently restarts all + // kube-proxy pods in the kube-system namespace. This change needs to be done + // after a endpoint change is performed. + PatchKubeProxyConfigMap(context.Context, *PatchKubeProxyConfigMapRequest) (*PatchKubeProxyConfigMapResponse, error) // CiliumRolloutRestart performs a rollout restart of the cilium daemonset. CiliumRolloutRestart(context.Context, *CiliumRolloutRestartRequest) (*CiliumRolloutRestartResponse, error) mustEmbedUnimplementedKuberServiceServer() @@ -268,6 +291,9 @@ func (UnimplementedKuberServiceServer) DestroyClusterAutoscaler(context.Context, func (UnimplementedKuberServiceServer) PatchClusterInfoConfigMap(context.Context, *PatchClusterInfoConfigMapRequest) (*PatchClusterInfoConfigMapResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method PatchClusterInfoConfigMap not implemented") } +func (UnimplementedKuberServiceServer) PatchKubeProxyConfigMap(context.Context, *PatchKubeProxyConfigMapRequest) (*PatchKubeProxyConfigMapResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method PatchKubeProxyConfigMap not implemented") +} func (UnimplementedKuberServiceServer) CiliumRolloutRestart(context.Context, *CiliumRolloutRestartRequest) (*CiliumRolloutRestartResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CiliumRolloutRestart not implemented") } @@ -294,7 +320,7 @@ func _KuberService_RemoveLBScrapeConfig_Handler(srv interface{}, ctx context.Con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_RemoveLBScrapeConfig_FullMethodName, + FullMethod: "/claudie.KuberService/RemoveLBScrapeConfig", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).RemoveLBScrapeConfig(ctx, req.(*RemoveLBScrapeConfigRequest)) @@ -312,7 +338,7 @@ func _KuberService_StoreLBScrapeConfig_Handler(srv interface{}, ctx context.Cont } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_StoreLBScrapeConfig_FullMethodName, + FullMethod: "/claudie.KuberService/StoreLBScrapeConfig", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).StoreLBScrapeConfig(ctx, req.(*StoreLBScrapeConfigRequest)) @@ -330,7 +356,7 @@ func _KuberService_StoreClusterMetadata_Handler(srv interface{}, ctx context.Con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_StoreClusterMetadata_FullMethodName, + FullMethod: "/claudie.KuberService/StoreClusterMetadata", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).StoreClusterMetadata(ctx, req.(*StoreClusterMetadataRequest)) @@ -348,7 +374,7 @@ func _KuberService_DeleteClusterMetadata_Handler(srv interface{}, ctx context.Co } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_DeleteClusterMetadata_FullMethodName, + FullMethod: "/claudie.KuberService/DeleteClusterMetadata", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).DeleteClusterMetadata(ctx, req.(*DeleteClusterMetadataRequest)) @@ -366,7 +392,7 @@ func _KuberService_SetUpStorage_Handler(srv interface{}, ctx context.Context, de } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_SetUpStorage_FullMethodName, + FullMethod: "/claudie.KuberService/SetUpStorage", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).SetUpStorage(ctx, req.(*SetUpStorageRequest)) @@ -384,7 +410,7 @@ func _KuberService_StoreKubeconfig_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_StoreKubeconfig_FullMethodName, + FullMethod: "/claudie.KuberService/StoreKubeconfig", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).StoreKubeconfig(ctx, req.(*StoreKubeconfigRequest)) @@ -402,7 +428,7 @@ func _KuberService_DeleteKubeconfig_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_DeleteKubeconfig_FullMethodName, + FullMethod: "/claudie.KuberService/DeleteKubeconfig", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).DeleteKubeconfig(ctx, req.(*DeleteKubeconfigRequest)) @@ -420,7 +446,7 @@ func _KuberService_DeleteNodes_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_DeleteNodes_FullMethodName, + FullMethod: "/claudie.KuberService/DeleteNodes", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).DeleteNodes(ctx, req.(*DeleteNodesRequest)) @@ -438,7 +464,7 @@ func _KuberService_PatchNodes_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_PatchNodes_FullMethodName, + FullMethod: "/claudie.KuberService/PatchNodes", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).PatchNodes(ctx, req.(*PatchNodesRequest)) @@ -456,7 +482,7 @@ func _KuberService_SetUpClusterAutoscaler_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_SetUpClusterAutoscaler_FullMethodName, + FullMethod: "/claudie.KuberService/SetUpClusterAutoscaler", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).SetUpClusterAutoscaler(ctx, req.(*SetUpClusterAutoscalerRequest)) @@ -474,7 +500,7 @@ func _KuberService_DestroyClusterAutoscaler_Handler(srv interface{}, ctx context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_DestroyClusterAutoscaler_FullMethodName, + FullMethod: "/claudie.KuberService/DestroyClusterAutoscaler", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).DestroyClusterAutoscaler(ctx, req.(*DestroyClusterAutoscalerRequest)) @@ -492,7 +518,7 @@ func _KuberService_PatchClusterInfoConfigMap_Handler(srv interface{}, ctx contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_PatchClusterInfoConfigMap_FullMethodName, + FullMethod: "/claudie.KuberService/PatchClusterInfoConfigMap", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).PatchClusterInfoConfigMap(ctx, req.(*PatchClusterInfoConfigMapRequest)) @@ -500,6 +526,24 @@ func _KuberService_PatchClusterInfoConfigMap_Handler(srv interface{}, ctx contex return interceptor(ctx, in, info, handler) } +func _KuberService_PatchKubeProxyConfigMap_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(PatchKubeProxyConfigMapRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(KuberServiceServer).PatchKubeProxyConfigMap(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/claudie.KuberService/PatchKubeProxyConfigMap", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(KuberServiceServer).PatchKubeProxyConfigMap(ctx, req.(*PatchKubeProxyConfigMapRequest)) + } + return interceptor(ctx, in, info, handler) +} + func _KuberService_CiliumRolloutRestart_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CiliumRolloutRestartRequest) if err := dec(in); err != nil { @@ -510,7 +554,7 @@ func _KuberService_CiliumRolloutRestart_Handler(srv interface{}, ctx context.Con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: KuberService_CiliumRolloutRestart_FullMethodName, + FullMethod: "/claudie.KuberService/CiliumRolloutRestart", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(KuberServiceServer).CiliumRolloutRestart(ctx, req.(*CiliumRolloutRestartRequest)) @@ -573,6 +617,10 @@ var KuberService_ServiceDesc = grpc.ServiceDesc{ MethodName: "PatchClusterInfoConfigMap", Handler: _KuberService_PatchClusterInfoConfigMap_Handler, }, + { + MethodName: "PatchKubeProxyConfigMap", + Handler: _KuberService_PatchKubeProxyConfigMap_Handler, + }, { MethodName: "CiliumRolloutRestart", Handler: _KuberService_CiliumRolloutRestart_Handler, diff --git a/proto/pb/terraformer.pb.go b/proto/pb/terraformer.pb.go index 33402387a..e45189348 100644 --- a/proto/pb/terraformer.pb.go +++ b/proto/pb/terraformer.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.33.0 -// protoc v4.25.1 +// protoc-gen-go v1.28.1 +// protoc v5.26.1 // source: proto/terraformer.proto package pb diff --git a/proto/pb/terraformer_grpc.pb.go b/proto/pb/terraformer_grpc.pb.go index 911a6d38d..df4c5da95 100644 --- a/proto/pb/terraformer_grpc.pb.go +++ b/proto/pb/terraformer_grpc.pb.go @@ -1,7 +1,7 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.1 +// - protoc-gen-go-grpc v1.2.0 +// - protoc v5.26.1 // source: proto/terraformer.proto package pb @@ -18,11 +18,6 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 -const ( - TerraformerService_BuildInfrastructure_FullMethodName = "/claudie.TerraformerService/BuildInfrastructure" - TerraformerService_DestroyInfrastructure_FullMethodName = "/claudie.TerraformerService/DestroyInfrastructure" -) - // TerraformerServiceClient is the client API for TerraformerService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. @@ -43,7 +38,7 @@ func NewTerraformerServiceClient(cc grpc.ClientConnInterface) TerraformerService func (c *terraformerServiceClient) BuildInfrastructure(ctx context.Context, in *BuildInfrastructureRequest, opts ...grpc.CallOption) (*BuildInfrastructureResponse, error) { out := new(BuildInfrastructureResponse) - err := c.cc.Invoke(ctx, TerraformerService_BuildInfrastructure_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.TerraformerService/BuildInfrastructure", in, out, opts...) if err != nil { return nil, err } @@ -52,7 +47,7 @@ func (c *terraformerServiceClient) BuildInfrastructure(ctx context.Context, in * func (c *terraformerServiceClient) DestroyInfrastructure(ctx context.Context, in *DestroyInfrastructureRequest, opts ...grpc.CallOption) (*DestroyInfrastructureResponse, error) { out := new(DestroyInfrastructureResponse) - err := c.cc.Invoke(ctx, TerraformerService_DestroyInfrastructure_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, "/claudie.TerraformerService/DestroyInfrastructure", in, out, opts...) if err != nil { return nil, err } @@ -103,7 +98,7 @@ func _TerraformerService_BuildInfrastructure_Handler(srv interface{}, ctx contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: TerraformerService_BuildInfrastructure_FullMethodName, + FullMethod: "/claudie.TerraformerService/BuildInfrastructure", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(TerraformerServiceServer).BuildInfrastructure(ctx, req.(*BuildInfrastructureRequest)) @@ -121,7 +116,7 @@ func _TerraformerService_DestroyInfrastructure_Handler(srv interface{}, ctx cont } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: TerraformerService_DestroyInfrastructure_FullMethodName, + FullMethod: "/claudie.TerraformerService/DestroyInfrastructure", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(TerraformerServiceServer).DestroyInfrastructure(ctx, req.(*DestroyInfrastructureRequest)) diff --git a/services/ansibler/server/ansible-playbooks/apiEndpointChange.yml b/services/ansibler/server/ansible-playbooks/apiEndpointChange.yml index b1111f5e0..dd83e2d27 100644 --- a/services/ansibler/server/ansible-playbooks/apiEndpointChange.yml +++ b/services/ansibler/server/ansible-playbooks/apiEndpointChange.yml @@ -77,6 +77,12 @@ - "kubelet" - "containerd" + - name: restart controller + shell: "crictl pods | grep kube-controller-manager | awk '{print $1}' | xargs -I {} sh -c 'crictl stopp {} && crictl rmp {}'" + + - name: restart scheduler + shell: "crictl pods | grep kube-scheduler | awk '{print $1}' | xargs -I {} sh -c 'crictl stopp {} && crictl rmp {}'" + - hosts: compute gather_facts: true become: true diff --git a/services/builder/adapters/outbound/kuber_connector.go b/services/builder/adapters/outbound/kuber_connector.go index f5697dddc..4d24c0af1 100644 --- a/services/builder/adapters/outbound/kuber_connector.go +++ b/services/builder/adapters/outbound/kuber_connector.go @@ -136,6 +136,12 @@ func (k *KuberConnector) CiliumRolloutRestart(cluster *pb.K8Scluster, kuberGrpcC }) } +func (k *KuberConnector) PatchKubeProxyConfigMap(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error { + return kuber.PatchKubeProxyConfigMap(kuberGrpcClient, &pb.PatchKubeProxyConfigMapRequest{ + DesiredCluster: builderCtx.DesiredCluster, + }) +} + // Disconnect closes the underlying gRPC connection to kuber microservice. func (k *KuberConnector) Disconnect() { cutils.CloseClientConnection(k.Connection) diff --git a/services/builder/domain/ports/kuber_port.go b/services/builder/domain/ports/kuber_port.go index fb11493e8..3e05b23c1 100644 --- a/services/builder/domain/ports/kuber_port.go +++ b/services/builder/domain/ports/kuber_port.go @@ -16,6 +16,7 @@ type KuberPort interface { SetUpClusterAutoscaler(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error DestroyClusterAutoscaler(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error PatchClusterInfoConfigMap(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error + PatchKubeProxyConfigMap(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error PatchNodes(builderCtx *utils.BuilderContext, kuberGrpcClient pb.KuberServiceClient) error DeleteNodes(cluster *pb.K8Scluster, masterNodes, workerNodes []string, kuberGrpcClient pb.KuberServiceClient) (*pb.DeleteNodesResponse, error) CiliumRolloutRestart(cluster *pb.K8Scluster, kuberGrpcClient pb.KuberServiceClient) error diff --git a/services/builder/domain/usecases/kuber_caller.go b/services/builder/domain/usecases/kuber_caller.go index bb782e4bd..19d38e64d 100644 --- a/services/builder/domain/usecases/kuber_caller.go +++ b/services/builder/domain/usecases/kuber_caller.go @@ -21,12 +21,14 @@ func (u *Usecases) reconcileK8sConfiguration(ctx *utils.BuilderContext, cboxClie return err } - // Only patch cluster-info ConfigMap if kubeconfig changed. + // Only patch ConfigMaps if kubeconfig changed. if ctx.CurrentCluster != nil && (ctx.CurrentCluster.Kubeconfig != ctx.DesiredCluster.Kubeconfig) { - // Set new description. if err := u.callPatchClusterInfoConfigMap(ctx, cboxClient); err != nil { return err } + if err := u.Kuber.PatchKubeProxyConfigMap(ctx, kuberClient); err != nil { + return err + } } // If previous cluster had loadbalancers, and the new one does not, the old scrape config will be removed. diff --git a/services/kuber/client/client.go b/services/kuber/client/client.go index 5c24a91f4..46080aa81 100644 --- a/services/kuber/client/client.go +++ b/services/kuber/client/client.go @@ -113,3 +113,8 @@ func PatchClusterInfoConfigMap(c pb.KuberServiceClient, req *pb.PatchClusterInfo _, err := c.PatchClusterInfoConfigMap(context.Background(), req) return err } + +func PatchKubeProxyConfigMap(c pb.KuberServiceClient, req *pb.PatchKubeProxyConfigMapRequest) error { + _, err := c.PatchKubeProxyConfigMap(context.Background(), req) + return err +} diff --git a/services/kuber/server/adapters/inbound/grpc/kuber_service.go b/services/kuber/server/adapters/inbound/grpc/kuber_service.go index 740db0c92..4d5a2abef 100644 --- a/services/kuber/server/adapters/inbound/grpc/kuber_service.go +++ b/services/kuber/server/adapters/inbound/grpc/kuber_service.go @@ -13,6 +13,10 @@ type KuberGrpcService struct { usecases *usecases.Usecases } +func (k *KuberGrpcService) PatchKubeProxyConfigMap(ctx context.Context, request *pb.PatchKubeProxyConfigMapRequest) (*pb.PatchKubeProxyConfigMapResponse, error) { + return k.usecases.PatchKubeProxyConfigMap(ctx, request) +} + func (k *KuberGrpcService) CiliumRolloutRestart(ctx context.Context, request *pb.CiliumRolloutRestartRequest) (*pb.CiliumRolloutRestartResponse, error) { return k.usecases.CiliumRolloutRestart(request) } diff --git a/services/kuber/server/domain/usecases/patch_cluster_info_configmap.go b/services/kuber/server/domain/usecases/patch_cluster_info_configmap.go index faf161bbb..726592b1d 100644 --- a/services/kuber/server/domain/usecases/patch_cluster_info_configmap.go +++ b/services/kuber/server/domain/usecases/patch_cluster_info_configmap.go @@ -21,15 +21,6 @@ import ( func (u *Usecases) PatchClusterInfoConfigMap(request *pb.PatchClusterInfoConfigMapRequest) (*pb.PatchClusterInfoConfigMapResponse, error) { logger := utils.CreateLoggerWithClusterName(utils.GetClusterID(request.DesiredCluster.ClusterInfo)) logger.Info().Msgf("Patching cluster info ConfigMap") - var err error - // Log error if any - defer func() { - if err != nil { - logger.Err(err).Msgf("Error while patching cluster-info Config Map") - } else { - logger.Info().Msgf("Cluster-info Config Map patched successfully") - } - }() k := kubectl.Kubectl{ Kubeconfig: request.DesiredCluster.Kubeconfig, @@ -48,12 +39,12 @@ func (u *Usecases) PatchClusterInfoConfigMap(request *pb.PatchClusterInfoConfigM configMapKubeconfig := gjson.Get(string(configMap), "data.kubeconfig") var rawKubeconfig map[string]interface{} - if err = yaml.Unmarshal([]byte(request.DesiredCluster.Kubeconfig), &rawKubeconfig); err != nil { + if err := yaml.Unmarshal([]byte(request.DesiredCluster.Kubeconfig), &rawKubeconfig); err != nil { return nil, fmt.Errorf("failed to unmarshal kubeconfig, malformed yaml : %w", err) } var rawConfigMapKubeconfig map[string]interface{} - if err = yaml.Unmarshal([]byte(configMapKubeconfig.String()), &rawConfigMapKubeconfig); err != nil { + if err := yaml.Unmarshal([]byte(configMapKubeconfig.String()), &rawConfigMapKubeconfig); err != nil { return nil, fmt.Errorf("failed to update cluster info config map, malformed yaml : %w", err) } @@ -90,5 +81,6 @@ func (u *Usecases) PatchClusterInfoConfigMap(request *pb.PatchClusterInfoConfigM return nil, fmt.Errorf("failed to patch config map: %w", err) } + logger.Info().Msgf("Cluster-info Config Map patched successfully") return &pb.PatchClusterInfoConfigMapResponse{}, nil } diff --git a/services/kuber/server/domain/usecases/patch_kube_proxy.go b/services/kuber/server/domain/usecases/patch_kube_proxy.go new file mode 100644 index 000000000..13e879f82 --- /dev/null +++ b/services/kuber/server/domain/usecases/patch_kube_proxy.go @@ -0,0 +1,121 @@ +package usecases + +import ( + "context" + "errors" + "fmt" + + "github.com/berops/claudie/internal/kubectl" + "github.com/berops/claudie/internal/utils" + "github.com/berops/claudie/proto/pb" + "gopkg.in/yaml.v3" +) + +func (u *Usecases) PatchKubeProxyConfigMap(ctx context.Context, request *pb.PatchKubeProxyConfigMapRequest) (*pb.PatchKubeProxyConfigMapResponse, error) { + logger := utils.CreateLoggerWithClusterName(utils.GetClusterID(request.DesiredCluster.ClusterInfo)) + logger.Info().Msgf("Patching kube-proxy ConfigMap") + + k := kubectl.Kubectl{ + Kubeconfig: request.DesiredCluster.Kubeconfig, + } + + configMap, err := k.KubectlGet("cm kube-proxy", "-oyaml", "-n kube-system") + if err != nil { + return nil, err + } + + if configMap == nil { + return &pb.PatchKubeProxyConfigMapResponse{}, nil + } + + var desiredKubeconfig map[string]interface{} + if err := yaml.Unmarshal([]byte(request.DesiredCluster.Kubeconfig), &desiredKubeconfig); err != nil { + return nil, fmt.Errorf("failed to unmarshal kubeconfig, malformed yaml : %w", err) + } + + var rawConfigMap map[string]interface{} + if err := yaml.Unmarshal(configMap, &rawConfigMap); err != nil { + return nil, fmt.Errorf("failed to update cluster info config map, malformed yaml : %w", err) + } + + // get the new api server address + desiredCluster, err := extractClusterFromKubeconfig(desiredKubeconfig) + if err != nil { + return nil, fmt.Errorf("failed to extract cluster data from kubeconfing of desired state") + } + + if err := updateKubeconfigServerEndpoint(rawConfigMap, desiredCluster["server"]); err != nil { + return nil, fmt.Errorf("failed to patch kube-proxy kubeconfig: %w", err) + } + + b, err := yaml.Marshal(rawConfigMap) + if err != nil { + return nil, fmt.Errorf("failed to marshal patched config map : %w", err) + } + + if err = k.KubectlApplyString(string(b), "-n kube-system"); err != nil { + return nil, fmt.Errorf("failed to patch config map: %w", err) + } + + // Delete old kube-proxy pods to use updated config-map + if err := k.KubectlDeleteResource("pods", "-l k8s-app=kube-proxy", "-n kube-system"); err != nil { + return nil, fmt.Errorf("failed to restart kube-proxy pods: %w", err) + } + + logger.Info().Msgf("Kube-proxy Config Map patched successfully") + return &pb.PatchKubeProxyConfigMapResponse{}, nil +} + +func extractClusterFromKubeconfig(root map[string]any) (map[string]any, error) { + clustersSlice, ok := root["clusters"].([]any) + if !ok { + return nil, errors.New("expected 'clusters' to be an []any") + } + if len(clustersSlice) == 0 { + return nil, errors.New("no clusters to patch") + } + + cluster, ok := clustersSlice[0].(map[string]any) + if !ok { + return nil, errors.New("expected clusters to be of type map[string]any") + } + + clusterData, ok := cluster["cluster"].(map[string]any) + if !ok { + return nil, errors.New("expeted clusters of the kubeconfig to be of type map[string]any") + } + + return clusterData, nil +} + +func updateKubeconfigServerEndpoint(root map[string]any, val any) error { + data, ok := root["data"].(map[string]any) + if !ok { + return errors.New("expected 'data' field to be a map[string]any") + } + + kubeConf, ok := data["kubeconfig.conf"].(string) + if !ok { + return errors.New("expected 'kubeconfig.conf' to be a string") + } + + var kubeConfMap map[string]any + if err := yaml.Unmarshal([]byte(kubeConf), &kubeConfMap); err != nil { + return err + } + + cluster, err := extractClusterFromKubeconfig(kubeConfMap) + if err != nil { + return err + } + + cluster["server"] = val + + b, err := yaml.Marshal(kubeConfMap) + if err != nil { + return err + } + + data["kubeconfig.conf"] = string(b) + return nil +}