diff --git a/api/controller/olm_operator_api.proto b/api/controller/olm_operator_api.proto deleted file mode 100644 index 5cb0fb2..0000000 --- a/api/controller/olm_operator_api.proto +++ /dev/null @@ -1,161 +0,0 @@ -syntax = "proto3"; - -package percona.platform.dbaas.controller.v1beta1; - -option go_package = "controller;controllerv1beta1"; - -import "controller/common.proto"; -import "controller/olm_types.proto"; -import "github.com/mwitkow/go-proto-validators/validator.proto"; - -// OLMOperatorAPI provides APIs for managing OLM. -service OLMOperatorAPI { - // InstallOLMOperator installs the OLM. - rpc InstallOLMOperator(InstallOLMOperatorRequest) returns (InstallOLMOperatorResponse); - // InstallOperator installs an operator usin OLM. - rpc InstallOperator(InstallOperatorRequest) returns (InstallOperatorResponse); - // ListInstallPlans gets the list of install plans matching the criteria. - rpc ListInstallPlans(ListInstallPlansRequest) returns (ListInstallPlansResponse); - // ApproveInstallPlan approves an install plan for installation or upgrade. - rpc ApproveInstallPlan(ApproveInstallPlanRequest) returns (ApproveInstallPlanResponse); - // ListSubscriptions lists all available subscriptions. - rpc ListSubscriptions(ListSubscriptionsRequest) returns (ListSubscriptionsResponse); - // GetSubscription returns a subscription by name. - rpc GetSubscription(GetSubscriptionRequest) returns (GetSubscriptionResponse); -} - -// InstallOLMOperatorRequest has the necesary fields to start an OLM operator installation. -message InstallOLMOperatorRequest { - // Kubernetes auth. - KubeAuth kube_auth = 1 [ - (validator.field) = { - msg_exists: true - } - ]; - // Operator version to be installed. - string version = 2; -} - -// InstallOLMOperatorResponse is the OLM Operator installation response. -message InstallOLMOperatorResponse {} - -// InstallOperatorRequest holds the necesary fields to request an operator installation -// usin the OLM operator. -message InstallOperatorRequest { - // Kubernetes auth. - KubeAuth kube_auth = 1 [ - (validator.field) = { - msg_exists: true - } - ]; - // Destination namespace. - string namespace = 2; - // Operator's name. - string name = 3; - // Operator group to create. - string operator_group = 4; - // Catalog source name. - string catalog_source = 5; - // Catalog source namespace. - string catalog_source_namespace = 6; - // Channel. - string channel = 7; - // Install approval type. Manual, Automatic. - string install_plan_approval = 8; - // Starting CSV. - string starting_csv = 9; -} - -// InstallOperatorResponse holds the response after installing an operator via OLM. -message InstallOperatorResponse {} - -// ListInstallPlansRequest gets the list of install plans for a namespace. -message ListInstallPlansRequest { - // Kubernetes auth. - KubeAuth kube_auth = 1 [ - (validator.field) = { - msg_exists: true - } - ]; - // Destination namespace. - string namespace = 2; - // Operator's name. - string name = 3; - // Operator group to create. - bool not_approved_only = 4; -} - -// ListInstallPlansResponse has all the install plans for the install plans list request. -message ListInstallPlansResponse { - // InstallPlan item. - message InstallPlan { - // Namespace. - string namespace = 1; - // Name. - string name = 2; - // CSV. - string csv = 3; - // Approval: manual, automatic. - string approval = 4; - // Approved. - bool approved = 5; - } - // List install plan items. - repeated InstallPlan items = 1; -} - -// ApproveInstallPlanRequest has the necesary fields to approve an install plan for installation or upgrade. -message ApproveInstallPlanRequest { - // Kubernetes auth. - KubeAuth kube_auth = 1 [ - (validator.field) = { - msg_exists: true - } - ]; - // Namespace. - string namespace = 2; - // Name is install plan name. - string name = 3; - // Subscription name. - // This is used in cases when we don't have the install plan name but we know the subscription name. - string subscription_name = 4; -} - -// ApproveInstallPlanResponse is the install plan approval response. -message ApproveInstallPlanResponse {} - -// ListSubscriptionsRequest request subscriptions/ -message ListSubscriptionsRequest { - // Kubernetes auth. - KubeAuth kube_auth = 1 [ - (validator.field) = { - msg_exists: true - } - ]; -} - -// ListSubscriptionsRequest request subscriptions/ -message GetSubscriptionRequest { - // Kubernetes auth. - KubeAuth kube_auth = 1 [ - (validator.field) = { - msg_exists: true - } - ]; - // Namespace. - string namespace = 2; - // Subscription name. Usually is the operator's name. - string name = 3; -} - -// GetSubscriptionResponse response. -message GetSubscriptionResponse { - // Items is the actual list of subscriptions. - Subscription subscription = 1; -} - -// ListSubscriptionsResponse response. -message ListSubscriptionsResponse { - // Items is the actual list of subscriptions. - repeated Subscription items = 1; -} diff --git a/api/controller/olm_types.proto b/api/controller/olm_types.proto deleted file mode 100644 index 4a3dee5..0000000 --- a/api/controller/olm_types.proto +++ /dev/null @@ -1,25 +0,0 @@ -syntax = "proto3"; - -package percona.platform.dbaas.controller.v1beta1; - -option go_package = "controller;controllerv1beta1"; - -// Subscription represents an OLM operator subscription. -message Subscription { - // Namespace. - string namespace = 1; - // Subscription name. - string name = 2; - // Package is the operator name. - string package = 3; - // Source is the catalog source. - string source = 4; - // Channel. - string channel = 5; - // Latest known csv. - string current_csv = 6; - // Currently installed csv. - string installed_csv = 7; - // Install Plan name. - string install_plan_name = 8; -} diff --git a/gen/controller/olm_operator_api.pb.go b/gen/controller/olm_operator_api.pb.go deleted file mode 100644 index e46b68b..0000000 --- a/gen/controller/olm_operator_api.pb.go +++ /dev/null @@ -1,1543 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.25.0 -// protoc v3.13.0 -// source: controller/olm_operator_api.proto - -package controllerv1beta1 - -import ( - context "context" - reflect "reflect" - sync "sync" - - proto "github.com/golang/protobuf/proto" - _ "github.com/mwitkow/go-proto-validators" - grpc "google.golang.org/grpc" - codes "google.golang.org/grpc/codes" - status "google.golang.org/grpc/status" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" -) - -const ( - // Verify that this generated code is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) - // Verify that runtime/protoimpl is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) -) - -// This is a compile-time assertion that a sufficiently up-to-date version -// of the legacy proto package is being used. -const _ = proto.ProtoPackageIsVersion4 - -// InstallOLMOperatorRequest has the necesary fields to start an OLM operator installation. -type InstallOLMOperatorRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Kubernetes auth. - KubeAuth *KubeAuth `protobuf:"bytes,1,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"` - // Operator version to be installed. - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` -} - -func (x *InstallOLMOperatorRequest) Reset() { - *x = InstallOLMOperatorRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *InstallOLMOperatorRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*InstallOLMOperatorRequest) ProtoMessage() {} - -func (x *InstallOLMOperatorRequest) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[0] - 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 InstallOLMOperatorRequest.ProtoReflect.Descriptor instead. -func (*InstallOLMOperatorRequest) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{0} -} - -func (x *InstallOLMOperatorRequest) GetKubeAuth() *KubeAuth { - if x != nil { - return x.KubeAuth - } - return nil -} - -func (x *InstallOLMOperatorRequest) GetVersion() string { - if x != nil { - return x.Version - } - return "" -} - -// InstallOLMOperatorResponse is the OLM Operator installation response. -type InstallOLMOperatorResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields -} - -func (x *InstallOLMOperatorResponse) Reset() { - *x = InstallOLMOperatorResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[1] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *InstallOLMOperatorResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*InstallOLMOperatorResponse) ProtoMessage() {} - -func (x *InstallOLMOperatorResponse) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[1] - 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 InstallOLMOperatorResponse.ProtoReflect.Descriptor instead. -func (*InstallOLMOperatorResponse) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{1} -} - -// InstallOperatorRequest holds the necesary fields to request an operator installation -// usin the OLM operator. -type InstallOperatorRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Kubernetes auth. - KubeAuth *KubeAuth `protobuf:"bytes,1,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"` - // Destination namespace. - Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` - // Operator's name. - Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` - // Operator group to create. - OperatorGroup string `protobuf:"bytes,4,opt,name=operator_group,json=operatorGroup,proto3" json:"operator_group,omitempty"` - // Catalog source name. - CatalogSource string `protobuf:"bytes,5,opt,name=catalog_source,json=catalogSource,proto3" json:"catalog_source,omitempty"` - // Catalog source namespace. - CatalogSourceNamespace string `protobuf:"bytes,6,opt,name=catalog_source_namespace,json=catalogSourceNamespace,proto3" json:"catalog_source_namespace,omitempty"` - // Channel. - Channel string `protobuf:"bytes,7,opt,name=channel,proto3" json:"channel,omitempty"` - // Install approval type. Manual, Automatic. - InstallPlanApproval string `protobuf:"bytes,8,opt,name=install_plan_approval,json=installPlanApproval,proto3" json:"install_plan_approval,omitempty"` - // Starting CSV. - StartingCsv string `protobuf:"bytes,9,opt,name=starting_csv,json=startingCsv,proto3" json:"starting_csv,omitempty"` -} - -func (x *InstallOperatorRequest) Reset() { - *x = InstallOperatorRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[2] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *InstallOperatorRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*InstallOperatorRequest) ProtoMessage() {} - -func (x *InstallOperatorRequest) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[2] - 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 InstallOperatorRequest.ProtoReflect.Descriptor instead. -func (*InstallOperatorRequest) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{2} -} - -func (x *InstallOperatorRequest) GetKubeAuth() *KubeAuth { - if x != nil { - return x.KubeAuth - } - return nil -} - -func (x *InstallOperatorRequest) GetNamespace() string { - if x != nil { - return x.Namespace - } - return "" -} - -func (x *InstallOperatorRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *InstallOperatorRequest) GetOperatorGroup() string { - if x != nil { - return x.OperatorGroup - } - return "" -} - -func (x *InstallOperatorRequest) GetCatalogSource() string { - if x != nil { - return x.CatalogSource - } - return "" -} - -func (x *InstallOperatorRequest) GetCatalogSourceNamespace() string { - if x != nil { - return x.CatalogSourceNamespace - } - return "" -} - -func (x *InstallOperatorRequest) GetChannel() string { - if x != nil { - return x.Channel - } - return "" -} - -func (x *InstallOperatorRequest) GetInstallPlanApproval() string { - if x != nil { - return x.InstallPlanApproval - } - return "" -} - -func (x *InstallOperatorRequest) GetStartingCsv() string { - if x != nil { - return x.StartingCsv - } - return "" -} - -// InstallOperatorResponse holds the response after installing an operator via OLM. -type InstallOperatorResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields -} - -func (x *InstallOperatorResponse) Reset() { - *x = InstallOperatorResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[3] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *InstallOperatorResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*InstallOperatorResponse) ProtoMessage() {} - -func (x *InstallOperatorResponse) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[3] - 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 InstallOperatorResponse.ProtoReflect.Descriptor instead. -func (*InstallOperatorResponse) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{3} -} - -// ListInstallPlansRequest gets the list of install plans for a namespace. -type ListInstallPlansRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Kubernetes auth. - KubeAuth *KubeAuth `protobuf:"bytes,1,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"` - // Destination namespace. - Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` - // Operator's name. - Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` - // Operator group to create. - NotApprovedOnly bool `protobuf:"varint,4,opt,name=not_approved_only,json=notApprovedOnly,proto3" json:"not_approved_only,omitempty"` -} - -func (x *ListInstallPlansRequest) Reset() { - *x = ListInstallPlansRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[4] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ListInstallPlansRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ListInstallPlansRequest) ProtoMessage() {} - -func (x *ListInstallPlansRequest) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[4] - 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 ListInstallPlansRequest.ProtoReflect.Descriptor instead. -func (*ListInstallPlansRequest) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{4} -} - -func (x *ListInstallPlansRequest) GetKubeAuth() *KubeAuth { - if x != nil { - return x.KubeAuth - } - return nil -} - -func (x *ListInstallPlansRequest) GetNamespace() string { - if x != nil { - return x.Namespace - } - return "" -} - -func (x *ListInstallPlansRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *ListInstallPlansRequest) GetNotApprovedOnly() bool { - if x != nil { - return x.NotApprovedOnly - } - return false -} - -// ListInstallPlansResponse has all the install plans for the install plans list request. -type ListInstallPlansResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // List install plan items. - Items []*ListInstallPlansResponse_InstallPlan `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` -} - -func (x *ListInstallPlansResponse) Reset() { - *x = ListInstallPlansResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[5] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ListInstallPlansResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ListInstallPlansResponse) ProtoMessage() {} - -func (x *ListInstallPlansResponse) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[5] - 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 ListInstallPlansResponse.ProtoReflect.Descriptor instead. -func (*ListInstallPlansResponse) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{5} -} - -func (x *ListInstallPlansResponse) GetItems() []*ListInstallPlansResponse_InstallPlan { - if x != nil { - return x.Items - } - return nil -} - -// ApproveInstallPlanRequest has the necesary fields to approve an install plan for installation or upgrade. -type ApproveInstallPlanRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Kubernetes auth. - KubeAuth *KubeAuth `protobuf:"bytes,1,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"` - // Namespace. - Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` - // Name is install plan name. - Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` - // Subscription name. - // This is used in cases when we don't have the install plan name but we know the subscription name. - SubscriptionName string `protobuf:"bytes,4,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"` -} - -func (x *ApproveInstallPlanRequest) Reset() { - *x = ApproveInstallPlanRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[6] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ApproveInstallPlanRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ApproveInstallPlanRequest) ProtoMessage() {} - -func (x *ApproveInstallPlanRequest) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[6] - 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 ApproveInstallPlanRequest.ProtoReflect.Descriptor instead. -func (*ApproveInstallPlanRequest) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{6} -} - -func (x *ApproveInstallPlanRequest) GetKubeAuth() *KubeAuth { - if x != nil { - return x.KubeAuth - } - return nil -} - -func (x *ApproveInstallPlanRequest) GetNamespace() string { - if x != nil { - return x.Namespace - } - return "" -} - -func (x *ApproveInstallPlanRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *ApproveInstallPlanRequest) GetSubscriptionName() string { - if x != nil { - return x.SubscriptionName - } - return "" -} - -// ApproveInstallPlanResponse is the install plan approval response. -type ApproveInstallPlanResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields -} - -func (x *ApproveInstallPlanResponse) Reset() { - *x = ApproveInstallPlanResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[7] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ApproveInstallPlanResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ApproveInstallPlanResponse) ProtoMessage() {} - -func (x *ApproveInstallPlanResponse) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[7] - 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 ApproveInstallPlanResponse.ProtoReflect.Descriptor instead. -func (*ApproveInstallPlanResponse) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{7} -} - -// ListSubscriptionsRequest request subscriptions/ -type ListSubscriptionsRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Kubernetes auth. - KubeAuth *KubeAuth `protobuf:"bytes,1,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"` -} - -func (x *ListSubscriptionsRequest) Reset() { - *x = ListSubscriptionsRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[8] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ListSubscriptionsRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ListSubscriptionsRequest) ProtoMessage() {} - -func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[8] - 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 ListSubscriptionsRequest.ProtoReflect.Descriptor instead. -func (*ListSubscriptionsRequest) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{8} -} - -func (x *ListSubscriptionsRequest) GetKubeAuth() *KubeAuth { - if x != nil { - return x.KubeAuth - } - return nil -} - -// ListSubscriptionsRequest request subscriptions/ -type GetSubscriptionRequest struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Kubernetes auth. - KubeAuth *KubeAuth `protobuf:"bytes,1,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"` - // Namespace. - Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` - // Subscription name. Usually is the operator's name. - Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` -} - -func (x *GetSubscriptionRequest) Reset() { - *x = GetSubscriptionRequest{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[9] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *GetSubscriptionRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*GetSubscriptionRequest) ProtoMessage() {} - -func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[9] - 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 GetSubscriptionRequest.ProtoReflect.Descriptor instead. -func (*GetSubscriptionRequest) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{9} -} - -func (x *GetSubscriptionRequest) GetKubeAuth() *KubeAuth { - if x != nil { - return x.KubeAuth - } - return nil -} - -func (x *GetSubscriptionRequest) GetNamespace() string { - if x != nil { - return x.Namespace - } - return "" -} - -func (x *GetSubscriptionRequest) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -// GetSubscriptionResponse response. -type GetSubscriptionResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Items is the actual list of subscriptions. - Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"` -} - -func (x *GetSubscriptionResponse) Reset() { - *x = GetSubscriptionResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[10] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *GetSubscriptionResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*GetSubscriptionResponse) ProtoMessage() {} - -func (x *GetSubscriptionResponse) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[10] - 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 GetSubscriptionResponse.ProtoReflect.Descriptor instead. -func (*GetSubscriptionResponse) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{10} -} - -func (x *GetSubscriptionResponse) GetSubscription() *Subscription { - if x != nil { - return x.Subscription - } - return nil -} - -// ListSubscriptionsResponse response. -type ListSubscriptionsResponse struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Items is the actual list of subscriptions. - Items []*Subscription `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` -} - -func (x *ListSubscriptionsResponse) Reset() { - *x = ListSubscriptionsResponse{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[11] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ListSubscriptionsResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ListSubscriptionsResponse) ProtoMessage() {} - -func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[11] - 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 ListSubscriptionsResponse.ProtoReflect.Descriptor instead. -func (*ListSubscriptionsResponse) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{11} -} - -func (x *ListSubscriptionsResponse) GetItems() []*Subscription { - if x != nil { - return x.Items - } - return nil -} - -// InstallPlan item. -type ListInstallPlansResponse_InstallPlan struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Namespace. - Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` - // Name. - Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` - // CSV. - Csv string `protobuf:"bytes,3,opt,name=csv,proto3" json:"csv,omitempty"` - // Approval: manual, automatic. - Approval string `protobuf:"bytes,4,opt,name=approval,proto3" json:"approval,omitempty"` - // Approved. - Approved bool `protobuf:"varint,5,opt,name=approved,proto3" json:"approved,omitempty"` -} - -func (x *ListInstallPlansResponse_InstallPlan) Reset() { - *x = ListInstallPlansResponse_InstallPlan{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_operator_api_proto_msgTypes[12] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *ListInstallPlansResponse_InstallPlan) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ListInstallPlansResponse_InstallPlan) ProtoMessage() {} - -func (x *ListInstallPlansResponse_InstallPlan) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_operator_api_proto_msgTypes[12] - 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 ListInstallPlansResponse_InstallPlan.ProtoReflect.Descriptor instead. -func (*ListInstallPlansResponse_InstallPlan) Descriptor() ([]byte, []int) { - return file_controller_olm_operator_api_proto_rawDescGZIP(), []int{5, 0} -} - -func (x *ListInstallPlansResponse_InstallPlan) GetNamespace() string { - if x != nil { - return x.Namespace - } - return "" -} - -func (x *ListInstallPlansResponse_InstallPlan) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *ListInstallPlansResponse_InstallPlan) GetCsv() string { - if x != nil { - return x.Csv - } - return "" -} - -func (x *ListInstallPlansResponse_InstallPlan) GetApproval() string { - if x != nil { - return x.Approval - } - return "" -} - -func (x *ListInstallPlansResponse_InstallPlan) GetApproved() bool { - if x != nil { - return x.Approved - } - return false -} - -var File_controller_olm_operator_api_proto protoreflect.FileDescriptor - -var file_controller_olm_operator_api_proto_rawDesc = []byte{ - 0x0a, 0x21, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x6f, 0x6c, 0x6d, - 0x5f, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x5f, 0x61, 0x70, 0x69, 0x2e, 0x70, 0x72, - 0x6f, 0x74, 0x6f, 0x12, 0x29, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, - 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, - 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x1a, 0x17, - 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x63, 0x6f, 0x6d, 0x6d, 0x6f, - 0x6e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1a, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, - 0x6c, 0x65, 0x72, 0x2f, 0x6f, 0x6c, 0x6d, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x70, 0x72, - 0x6f, 0x74, 0x6f, 0x1a, 0x36, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, - 0x6d, 0x77, 0x69, 0x74, 0x6b, 0x6f, 0x77, 0x2f, 0x67, 0x6f, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x2d, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x6f, 0x72, 0x73, 0x2f, 0x76, 0x61, 0x6c, 0x69, - 0x64, 0x61, 0x74, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x8f, 0x01, 0x0a, 0x19, - 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4f, 0x4c, 0x4d, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, - 0x6f, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x58, 0x0a, 0x09, 0x6b, 0x75, 0x62, - 0x65, 0x5f, 0x61, 0x75, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x70, - 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, - 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, - 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, - 0x68, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x01, 0x52, 0x08, 0x6b, 0x75, 0x62, 0x65, 0x41, - 0x75, 0x74, 0x68, 0x12, 0x18, 0x0a, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x1c, 0x0a, - 0x1a, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4f, 0x4c, 0x4d, 0x4f, 0x70, 0x65, 0x72, 0x61, - 0x74, 0x6f, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x9d, 0x03, 0x0a, 0x16, - 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x52, - 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x58, 0x0a, 0x09, 0x6b, 0x75, 0x62, 0x65, 0x5f, 0x61, - 0x75, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x70, 0x65, 0x72, 0x63, - 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, - 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, - 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, 0x68, 0x42, 0x06, - 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x01, 0x52, 0x08, 0x6b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, 0x68, - 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x12, - 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, - 0x6d, 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x5f, 0x67, - 0x72, 0x6f, 0x75, 0x70, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x6f, 0x70, 0x65, 0x72, - 0x61, 0x74, 0x6f, 0x72, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x12, 0x25, 0x0a, 0x0e, 0x63, 0x61, 0x74, - 0x61, 0x6c, 0x6f, 0x67, 0x5f, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x0d, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x53, 0x6f, 0x75, 0x72, 0x63, 0x65, - 0x12, 0x38, 0x0a, 0x18, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x5f, 0x73, 0x6f, 0x75, 0x72, - 0x63, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x06, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x16, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x53, 0x6f, 0x75, 0x72, 0x63, - 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x68, - 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x68, 0x61, - 0x6e, 0x6e, 0x65, 0x6c, 0x12, 0x32, 0x0a, 0x15, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x5f, - 0x70, 0x6c, 0x61, 0x6e, 0x5f, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x61, 0x6c, 0x18, 0x08, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x13, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, - 0x41, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x61, 0x6c, 0x12, 0x21, 0x0a, 0x0c, 0x73, 0x74, 0x61, 0x72, - 0x74, 0x69, 0x6e, 0x67, 0x5f, 0x63, 0x73, 0x76, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, - 0x73, 0x74, 0x61, 0x72, 0x74, 0x69, 0x6e, 0x67, 0x43, 0x73, 0x76, 0x22, 0x19, 0x0a, 0x17, 0x49, - 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x52, 0x65, - 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xd1, 0x01, 0x0a, 0x17, 0x4c, 0x69, 0x73, 0x74, 0x49, - 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, - 0x73, 0x74, 0x12, 0x58, 0x0a, 0x09, 0x6b, 0x75, 0x62, 0x65, 0x5f, 0x61, 0x75, 0x74, 0x68, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, - 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, - 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, - 0x31, 0x2e, 0x4b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, 0x68, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, - 0x20, 0x01, 0x52, 0x08, 0x6b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, 0x68, 0x12, 0x1c, 0x0a, 0x09, - 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, - 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x2a, - 0x0a, 0x11, 0x6e, 0x6f, 0x74, 0x5f, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x65, 0x64, 0x5f, 0x6f, - 0x6e, 0x6c, 0x79, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0f, 0x6e, 0x6f, 0x74, 0x41, 0x70, - 0x70, 0x72, 0x6f, 0x76, 0x65, 0x64, 0x4f, 0x6e, 0x6c, 0x79, 0x22, 0x8d, 0x02, 0x0a, 0x18, 0x4c, - 0x69, 0x73, 0x74, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x73, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x65, 0x0a, 0x05, 0x69, 0x74, 0x65, 0x6d, 0x73, - 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x4f, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, - 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, - 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, - 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, 0x6c, - 0x61, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x49, 0x6e, 0x73, 0x74, - 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x52, 0x05, 0x69, 0x74, 0x65, 0x6d, 0x73, 0x1a, 0x89, - 0x01, 0x0a, 0x0b, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x12, 0x1c, - 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x12, 0x0a, 0x04, - 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, - 0x12, 0x10, 0x0a, 0x03, 0x63, 0x73, 0x76, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x63, - 0x73, 0x76, 0x12, 0x1a, 0x0a, 0x08, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x61, 0x6c, 0x18, 0x04, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x61, 0x6c, 0x12, 0x1a, - 0x0a, 0x08, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x65, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08, - 0x52, 0x08, 0x61, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x65, 0x64, 0x22, 0xd4, 0x01, 0x0a, 0x19, 0x41, - 0x70, 0x70, 0x72, 0x6f, 0x76, 0x65, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, - 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x58, 0x0a, 0x09, 0x6b, 0x75, 0x62, 0x65, - 0x5f, 0x61, 0x75, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x70, 0x65, - 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, - 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, - 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, 0x68, - 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x01, 0x52, 0x08, 0x6b, 0x75, 0x62, 0x65, 0x41, 0x75, - 0x74, 0x68, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, - 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, - 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, - 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x2b, 0x0a, 0x11, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, - 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x10, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x4e, 0x61, 0x6d, - 0x65, 0x22, 0x1c, 0x0a, 0x1a, 0x41, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x65, 0x49, 0x6e, 0x73, 0x74, - 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, - 0x74, 0x0a, 0x18, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, - 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x58, 0x0a, 0x09, 0x6b, - 0x75, 0x62, 0x65, 0x5f, 0x61, 0x75, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, - 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, - 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, - 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4b, 0x75, 0x62, 0x65, 0x41, - 0x75, 0x74, 0x68, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x01, 0x52, 0x08, 0x6b, 0x75, 0x62, - 0x65, 0x41, 0x75, 0x74, 0x68, 0x22, 0xa4, 0x01, 0x0a, 0x16, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, - 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x12, 0x58, 0x0a, 0x09, 0x6b, 0x75, 0x62, 0x65, 0x5f, 0x61, 0x75, 0x74, 0x68, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, - 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, - 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, - 0x4b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, 0x68, 0x42, 0x06, 0xe2, 0xdf, 0x1f, 0x02, 0x20, 0x01, - 0x52, 0x08, 0x6b, 0x75, 0x62, 0x65, 0x41, 0x75, 0x74, 0x68, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, - 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, - 0x61, 0x6d, 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, - 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x76, 0x0a, 0x17, - 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x5b, 0x0a, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, - 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, - 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, - 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, - 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, - 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, - 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x6a, 0x0a, 0x19, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 0x62, 0x73, - 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, - 0x65, 0x12, 0x4d, 0x0a, 0x05, 0x69, 0x74, 0x65, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, - 0x32, 0x37, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, - 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, - 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x75, 0x62, - 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x69, 0x74, 0x65, 0x6d, 0x73, - 0x32, 0xcd, 0x07, 0x0a, 0x0e, 0x4f, 0x4c, 0x4d, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, - 0x41, 0x50, 0x49, 0x12, 0xa1, 0x01, 0x0a, 0x12, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4f, - 0x4c, 0x4d, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x12, 0x44, 0x2e, 0x70, 0x65, 0x72, - 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, - 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, - 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4f, 0x4c, - 0x4d, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, - 0x1a, 0x45, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, - 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, - 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x49, 0x6e, 0x73, - 0x74, 0x61, 0x6c, 0x6c, 0x4f, 0x4c, 0x4d, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x98, 0x01, 0x0a, 0x0f, 0x49, 0x6e, 0x73, 0x74, - 0x61, 0x6c, 0x6c, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x12, 0x41, 0x2e, 0x70, 0x65, - 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, - 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, - 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x4f, - 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x42, - 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, - 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, - 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x49, 0x6e, 0x73, 0x74, 0x61, - 0x6c, 0x6c, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x6f, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, - 0x73, 0x65, 0x12, 0x9b, 0x01, 0x0a, 0x10, 0x4c, 0x69, 0x73, 0x74, 0x49, 0x6e, 0x73, 0x74, 0x61, - 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x73, 0x12, 0x42, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, - 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, - 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, - 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, - 0x6c, 0x61, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x43, 0x2e, 0x70, 0x65, - 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, - 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, - 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x49, 0x6e, 0x73, 0x74, - 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, - 0x12, 0xa1, 0x01, 0x0a, 0x12, 0x41, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x65, 0x49, 0x6e, 0x73, 0x74, - 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x12, 0x44, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, - 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, - 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, - 0x74, 0x61, 0x31, 0x2e, 0x41, 0x70, 0x70, 0x72, 0x6f, 0x76, 0x65, 0x49, 0x6e, 0x73, 0x74, 0x61, - 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x45, 0x2e, - 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, - 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, - 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x41, 0x70, 0x70, 0x72, 0x6f, 0x76, - 0x65, 0x49, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x50, 0x6c, 0x61, 0x6e, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x9e, 0x01, 0x0a, 0x11, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 0x62, - 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x43, 0x2e, 0x70, 0x65, 0x72, - 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, - 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, - 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, - 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, - 0x44, 0x2e, 0x70, 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, - 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, - 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x4c, 0x69, 0x73, 0x74, - 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x98, 0x01, 0x0a, 0x0f, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, - 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x41, 0x2e, 0x70, 0x65, 0x72, 0x63, - 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, 0x62, 0x61, - 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, 0x76, 0x31, - 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, - 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x42, 0x2e, 0x70, - 0x65, 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, - 0x64, 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, - 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x47, 0x65, 0x74, 0x53, 0x75, 0x62, 0x73, - 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, - 0x42, 0x1e, 0x5a, 0x1c, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x3b, 0x63, - 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, - 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -} - -var ( - file_controller_olm_operator_api_proto_rawDescOnce sync.Once - file_controller_olm_operator_api_proto_rawDescData = file_controller_olm_operator_api_proto_rawDesc -) - -func file_controller_olm_operator_api_proto_rawDescGZIP() []byte { - file_controller_olm_operator_api_proto_rawDescOnce.Do(func() { - file_controller_olm_operator_api_proto_rawDescData = protoimpl.X.CompressGZIP(file_controller_olm_operator_api_proto_rawDescData) - }) - return file_controller_olm_operator_api_proto_rawDescData -} - -var file_controller_olm_operator_api_proto_msgTypes = make([]protoimpl.MessageInfo, 13) -var file_controller_olm_operator_api_proto_goTypes = []interface{}{ - (*InstallOLMOperatorRequest)(nil), // 0: percona.platform.dbaas.controller.v1beta1.InstallOLMOperatorRequest - (*InstallOLMOperatorResponse)(nil), // 1: percona.platform.dbaas.controller.v1beta1.InstallOLMOperatorResponse - (*InstallOperatorRequest)(nil), // 2: percona.platform.dbaas.controller.v1beta1.InstallOperatorRequest - (*InstallOperatorResponse)(nil), // 3: percona.platform.dbaas.controller.v1beta1.InstallOperatorResponse - (*ListInstallPlansRequest)(nil), // 4: percona.platform.dbaas.controller.v1beta1.ListInstallPlansRequest - (*ListInstallPlansResponse)(nil), // 5: percona.platform.dbaas.controller.v1beta1.ListInstallPlansResponse - (*ApproveInstallPlanRequest)(nil), // 6: percona.platform.dbaas.controller.v1beta1.ApproveInstallPlanRequest - (*ApproveInstallPlanResponse)(nil), // 7: percona.platform.dbaas.controller.v1beta1.ApproveInstallPlanResponse - (*ListSubscriptionsRequest)(nil), // 8: percona.platform.dbaas.controller.v1beta1.ListSubscriptionsRequest - (*GetSubscriptionRequest)(nil), // 9: percona.platform.dbaas.controller.v1beta1.GetSubscriptionRequest - (*GetSubscriptionResponse)(nil), // 10: percona.platform.dbaas.controller.v1beta1.GetSubscriptionResponse - (*ListSubscriptionsResponse)(nil), // 11: percona.platform.dbaas.controller.v1beta1.ListSubscriptionsResponse - (*ListInstallPlansResponse_InstallPlan)(nil), // 12: percona.platform.dbaas.controller.v1beta1.ListInstallPlansResponse.InstallPlan - (*KubeAuth)(nil), // 13: percona.platform.dbaas.controller.v1beta1.KubeAuth - (*Subscription)(nil), // 14: percona.platform.dbaas.controller.v1beta1.Subscription -} -var file_controller_olm_operator_api_proto_depIdxs = []int32{ - 13, // 0: percona.platform.dbaas.controller.v1beta1.InstallOLMOperatorRequest.kube_auth:type_name -> percona.platform.dbaas.controller.v1beta1.KubeAuth - 13, // 1: percona.platform.dbaas.controller.v1beta1.InstallOperatorRequest.kube_auth:type_name -> percona.platform.dbaas.controller.v1beta1.KubeAuth - 13, // 2: percona.platform.dbaas.controller.v1beta1.ListInstallPlansRequest.kube_auth:type_name -> percona.platform.dbaas.controller.v1beta1.KubeAuth - 12, // 3: percona.platform.dbaas.controller.v1beta1.ListInstallPlansResponse.items:type_name -> percona.platform.dbaas.controller.v1beta1.ListInstallPlansResponse.InstallPlan - 13, // 4: percona.platform.dbaas.controller.v1beta1.ApproveInstallPlanRequest.kube_auth:type_name -> percona.platform.dbaas.controller.v1beta1.KubeAuth - 13, // 5: percona.platform.dbaas.controller.v1beta1.ListSubscriptionsRequest.kube_auth:type_name -> percona.platform.dbaas.controller.v1beta1.KubeAuth - 13, // 6: percona.platform.dbaas.controller.v1beta1.GetSubscriptionRequest.kube_auth:type_name -> percona.platform.dbaas.controller.v1beta1.KubeAuth - 14, // 7: percona.platform.dbaas.controller.v1beta1.GetSubscriptionResponse.subscription:type_name -> percona.platform.dbaas.controller.v1beta1.Subscription - 14, // 8: percona.platform.dbaas.controller.v1beta1.ListSubscriptionsResponse.items:type_name -> percona.platform.dbaas.controller.v1beta1.Subscription - 0, // 9: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.InstallOLMOperator:input_type -> percona.platform.dbaas.controller.v1beta1.InstallOLMOperatorRequest - 2, // 10: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.InstallOperator:input_type -> percona.platform.dbaas.controller.v1beta1.InstallOperatorRequest - 4, // 11: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.ListInstallPlans:input_type -> percona.platform.dbaas.controller.v1beta1.ListInstallPlansRequest - 6, // 12: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.ApproveInstallPlan:input_type -> percona.platform.dbaas.controller.v1beta1.ApproveInstallPlanRequest - 8, // 13: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.ListSubscriptions:input_type -> percona.platform.dbaas.controller.v1beta1.ListSubscriptionsRequest - 9, // 14: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.GetSubscription:input_type -> percona.platform.dbaas.controller.v1beta1.GetSubscriptionRequest - 1, // 15: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.InstallOLMOperator:output_type -> percona.platform.dbaas.controller.v1beta1.InstallOLMOperatorResponse - 3, // 16: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.InstallOperator:output_type -> percona.platform.dbaas.controller.v1beta1.InstallOperatorResponse - 5, // 17: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.ListInstallPlans:output_type -> percona.platform.dbaas.controller.v1beta1.ListInstallPlansResponse - 7, // 18: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.ApproveInstallPlan:output_type -> percona.platform.dbaas.controller.v1beta1.ApproveInstallPlanResponse - 11, // 19: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.ListSubscriptions:output_type -> percona.platform.dbaas.controller.v1beta1.ListSubscriptionsResponse - 10, // 20: percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI.GetSubscription:output_type -> percona.platform.dbaas.controller.v1beta1.GetSubscriptionResponse - 15, // [15:21] is the sub-list for method output_type - 9, // [9:15] is the sub-list for method input_type - 9, // [9:9] is the sub-list for extension type_name - 9, // [9:9] is the sub-list for extension extendee - 0, // [0:9] is the sub-list for field type_name -} - -func init() { file_controller_olm_operator_api_proto_init() } -func file_controller_olm_operator_api_proto_init() { - if File_controller_olm_operator_api_proto != nil { - return - } - file_controller_common_proto_init() - file_controller_olm_types_proto_init() - if !protoimpl.UnsafeEnabled { - file_controller_olm_operator_api_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*InstallOLMOperatorRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*InstallOLMOperatorResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*InstallOperatorRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*InstallOperatorResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ListInstallPlansRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ListInstallPlansResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ApproveInstallPlanRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ApproveInstallPlanResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ListSubscriptionsRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetSubscriptionRequest); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*GetSubscriptionResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ListSubscriptionsResponse); i { - case 0: - return &v.state - case 1: - return &v.sizeCache - case 2: - return &v.unknownFields - default: - return nil - } - } - file_controller_olm_operator_api_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ListInstallPlansResponse_InstallPlan); 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{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_controller_olm_operator_api_proto_rawDesc, - NumEnums: 0, - NumMessages: 13, - NumExtensions: 0, - NumServices: 1, - }, - GoTypes: file_controller_olm_operator_api_proto_goTypes, - DependencyIndexes: file_controller_olm_operator_api_proto_depIdxs, - MessageInfos: file_controller_olm_operator_api_proto_msgTypes, - }.Build() - File_controller_olm_operator_api_proto = out.File - file_controller_olm_operator_api_proto_rawDesc = nil - file_controller_olm_operator_api_proto_goTypes = nil - file_controller_olm_operator_api_proto_depIdxs = nil -} - -// Reference imports to suppress errors if they are not otherwise used. -var _ context.Context -var _ grpc.ClientConnInterface - -// This is a compile-time assertion to ensure that this generated file -// is compatible with the grpc package it is being compiled against. -const _ = grpc.SupportPackageIsVersion6 - -// OLMOperatorAPIClient is the client API for OLMOperatorAPI service. -// -// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. -type OLMOperatorAPIClient interface { - // InstallOLMOperator installs the OLM. - InstallOLMOperator(ctx context.Context, in *InstallOLMOperatorRequest, opts ...grpc.CallOption) (*InstallOLMOperatorResponse, error) - // InstallOperator installs an operator usin OLM. - InstallOperator(ctx context.Context, in *InstallOperatorRequest, opts ...grpc.CallOption) (*InstallOperatorResponse, error) - // ListInstallPlans gets the list of install plans matching the criteria. - ListInstallPlans(ctx context.Context, in *ListInstallPlansRequest, opts ...grpc.CallOption) (*ListInstallPlansResponse, error) - // ApproveInstallPlan approves an install plan for installation or upgrade. - ApproveInstallPlan(ctx context.Context, in *ApproveInstallPlanRequest, opts ...grpc.CallOption) (*ApproveInstallPlanResponse, error) - // ListSubscriptions lists all available subscriptions. - ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) - // GetSubscription returns a subscription by name. - GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*GetSubscriptionResponse, error) -} - -type oLMOperatorAPIClient struct { - cc grpc.ClientConnInterface -} - -func NewOLMOperatorAPIClient(cc grpc.ClientConnInterface) OLMOperatorAPIClient { - return &oLMOperatorAPIClient{cc} -} - -func (c *oLMOperatorAPIClient) InstallOLMOperator(ctx context.Context, in *InstallOLMOperatorRequest, opts ...grpc.CallOption) (*InstallOLMOperatorResponse, error) { - out := new(InstallOLMOperatorResponse) - err := c.cc.Invoke(ctx, "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/InstallOLMOperator", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *oLMOperatorAPIClient) InstallOperator(ctx context.Context, in *InstallOperatorRequest, opts ...grpc.CallOption) (*InstallOperatorResponse, error) { - out := new(InstallOperatorResponse) - err := c.cc.Invoke(ctx, "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/InstallOperator", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *oLMOperatorAPIClient) ListInstallPlans(ctx context.Context, in *ListInstallPlansRequest, opts ...grpc.CallOption) (*ListInstallPlansResponse, error) { - out := new(ListInstallPlansResponse) - err := c.cc.Invoke(ctx, "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/ListInstallPlans", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *oLMOperatorAPIClient) ApproveInstallPlan(ctx context.Context, in *ApproveInstallPlanRequest, opts ...grpc.CallOption) (*ApproveInstallPlanResponse, error) { - out := new(ApproveInstallPlanResponse) - err := c.cc.Invoke(ctx, "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/ApproveInstallPlan", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *oLMOperatorAPIClient) ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error) { - out := new(ListSubscriptionsResponse) - err := c.cc.Invoke(ctx, "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/ListSubscriptions", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -func (c *oLMOperatorAPIClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*GetSubscriptionResponse, error) { - out := new(GetSubscriptionResponse) - err := c.cc.Invoke(ctx, "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/GetSubscription", in, out, opts...) - if err != nil { - return nil, err - } - return out, nil -} - -// OLMOperatorAPIServer is the server API for OLMOperatorAPI service. -type OLMOperatorAPIServer interface { - // InstallOLMOperator installs the OLM. - InstallOLMOperator(context.Context, *InstallOLMOperatorRequest) (*InstallOLMOperatorResponse, error) - // InstallOperator installs an operator usin OLM. - InstallOperator(context.Context, *InstallOperatorRequest) (*InstallOperatorResponse, error) - // ListInstallPlans gets the list of install plans matching the criteria. - ListInstallPlans(context.Context, *ListInstallPlansRequest) (*ListInstallPlansResponse, error) - // ApproveInstallPlan approves an install plan for installation or upgrade. - ApproveInstallPlan(context.Context, *ApproveInstallPlanRequest) (*ApproveInstallPlanResponse, error) - // ListSubscriptions lists all available subscriptions. - ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) - // GetSubscription returns a subscription by name. - GetSubscription(context.Context, *GetSubscriptionRequest) (*GetSubscriptionResponse, error) -} - -// UnimplementedOLMOperatorAPIServer can be embedded to have forward compatible implementations. -type UnimplementedOLMOperatorAPIServer struct { -} - -func (*UnimplementedOLMOperatorAPIServer) InstallOLMOperator(context.Context, *InstallOLMOperatorRequest) (*InstallOLMOperatorResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method InstallOLMOperator not implemented") -} -func (*UnimplementedOLMOperatorAPIServer) InstallOperator(context.Context, *InstallOperatorRequest) (*InstallOperatorResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method InstallOperator not implemented") -} -func (*UnimplementedOLMOperatorAPIServer) ListInstallPlans(context.Context, *ListInstallPlansRequest) (*ListInstallPlansResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method ListInstallPlans not implemented") -} -func (*UnimplementedOLMOperatorAPIServer) ApproveInstallPlan(context.Context, *ApproveInstallPlanRequest) (*ApproveInstallPlanResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method ApproveInstallPlan not implemented") -} -func (*UnimplementedOLMOperatorAPIServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method ListSubscriptions not implemented") -} -func (*UnimplementedOLMOperatorAPIServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*GetSubscriptionResponse, error) { - return nil, status.Errorf(codes.Unimplemented, "method GetSubscription not implemented") -} - -func RegisterOLMOperatorAPIServer(s *grpc.Server, srv OLMOperatorAPIServer) { - s.RegisterService(&_OLMOperatorAPI_serviceDesc, srv) -} - -func _OLMOperatorAPI_InstallOLMOperator_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(InstallOLMOperatorRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(OLMOperatorAPIServer).InstallOLMOperator(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/InstallOLMOperator", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(OLMOperatorAPIServer).InstallOLMOperator(ctx, req.(*InstallOLMOperatorRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _OLMOperatorAPI_InstallOperator_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(InstallOperatorRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(OLMOperatorAPIServer).InstallOperator(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/InstallOperator", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(OLMOperatorAPIServer).InstallOperator(ctx, req.(*InstallOperatorRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _OLMOperatorAPI_ListInstallPlans_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(ListInstallPlansRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(OLMOperatorAPIServer).ListInstallPlans(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/ListInstallPlans", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(OLMOperatorAPIServer).ListInstallPlans(ctx, req.(*ListInstallPlansRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _OLMOperatorAPI_ApproveInstallPlan_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(ApproveInstallPlanRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(OLMOperatorAPIServer).ApproveInstallPlan(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/ApproveInstallPlan", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(OLMOperatorAPIServer).ApproveInstallPlan(ctx, req.(*ApproveInstallPlanRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _OLMOperatorAPI_ListSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(ListSubscriptionsRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(OLMOperatorAPIServer).ListSubscriptions(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/ListSubscriptions", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(OLMOperatorAPIServer).ListSubscriptions(ctx, req.(*ListSubscriptionsRequest)) - } - return interceptor(ctx, in, info, handler) -} - -func _OLMOperatorAPI_GetSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { - in := new(GetSubscriptionRequest) - if err := dec(in); err != nil { - return nil, err - } - if interceptor == nil { - return srv.(OLMOperatorAPIServer).GetSubscription(ctx, in) - } - info := &grpc.UnaryServerInfo{ - Server: srv, - FullMethod: "/percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI/GetSubscription", - } - handler := func(ctx context.Context, req interface{}) (interface{}, error) { - return srv.(OLMOperatorAPIServer).GetSubscription(ctx, req.(*GetSubscriptionRequest)) - } - return interceptor(ctx, in, info, handler) -} - -var _OLMOperatorAPI_serviceDesc = grpc.ServiceDesc{ - ServiceName: "percona.platform.dbaas.controller.v1beta1.OLMOperatorAPI", - HandlerType: (*OLMOperatorAPIServer)(nil), - Methods: []grpc.MethodDesc{ - { - MethodName: "InstallOLMOperator", - Handler: _OLMOperatorAPI_InstallOLMOperator_Handler, - }, - { - MethodName: "InstallOperator", - Handler: _OLMOperatorAPI_InstallOperator_Handler, - }, - { - MethodName: "ListInstallPlans", - Handler: _OLMOperatorAPI_ListInstallPlans_Handler, - }, - { - MethodName: "ApproveInstallPlan", - Handler: _OLMOperatorAPI_ApproveInstallPlan_Handler, - }, - { - MethodName: "ListSubscriptions", - Handler: _OLMOperatorAPI_ListSubscriptions_Handler, - }, - { - MethodName: "GetSubscription", - Handler: _OLMOperatorAPI_GetSubscription_Handler, - }, - }, - Streams: []grpc.StreamDesc{}, - Metadata: "controller/olm_operator_api.proto", -} diff --git a/gen/controller/olm_operator_api.validator.pb.go b/gen/controller/olm_operator_api.validator.pb.go deleted file mode 100644 index a6ef1d5..0000000 --- a/gen/controller/olm_operator_api.validator.pb.go +++ /dev/null @@ -1,125 +0,0 @@ -// Code generated by protoc-gen-gogo. DO NOT EDIT. -// source: controller/olm_operator_api.proto - -package controllerv1beta1 - -import ( - fmt "fmt" - math "math" - - proto "github.com/golang/protobuf/proto" - _ "github.com/mwitkow/go-proto-validators" - github_com_mwitkow_go_proto_validators "github.com/mwitkow/go-proto-validators" -) - -// Reference imports to suppress errors if they are not otherwise used. -var _ = proto.Marshal -var _ = fmt.Errorf -var _ = math.Inf - -func (this *InstallOLMOperatorRequest) Validate() error { - if nil == this.KubeAuth { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", fmt.Errorf("message must exist")) - } - if this.KubeAuth != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.KubeAuth); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", err) - } - } - return nil -} -func (this *InstallOLMOperatorResponse) Validate() error { - return nil -} -func (this *InstallOperatorRequest) Validate() error { - if nil == this.KubeAuth { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", fmt.Errorf("message must exist")) - } - if this.KubeAuth != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.KubeAuth); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", err) - } - } - return nil -} -func (this *InstallOperatorResponse) Validate() error { - return nil -} -func (this *ListInstallPlansRequest) Validate() error { - if nil == this.KubeAuth { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", fmt.Errorf("message must exist")) - } - if this.KubeAuth != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.KubeAuth); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", err) - } - } - return nil -} -func (this *ListInstallPlansResponse) Validate() error { - for _, item := range this.Items { - if item != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("Items", err) - } - } - } - return nil -} -func (this *ListInstallPlansResponse_InstallPlan) Validate() error { - return nil -} -func (this *ApproveInstallPlanRequest) Validate() error { - if nil == this.KubeAuth { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", fmt.Errorf("message must exist")) - } - if this.KubeAuth != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.KubeAuth); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", err) - } - } - return nil -} -func (this *ApproveInstallPlanResponse) Validate() error { - return nil -} -func (this *ListSubscriptionsRequest) Validate() error { - if nil == this.KubeAuth { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", fmt.Errorf("message must exist")) - } - if this.KubeAuth != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.KubeAuth); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", err) - } - } - return nil -} -func (this *GetSubscriptionRequest) Validate() error { - if nil == this.KubeAuth { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", fmt.Errorf("message must exist")) - } - if this.KubeAuth != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.KubeAuth); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("KubeAuth", err) - } - } - return nil -} -func (this *GetSubscriptionResponse) Validate() error { - if this.Subscription != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(this.Subscription); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("Subscription", err) - } - } - return nil -} -func (this *ListSubscriptionsResponse) Validate() error { - for _, item := range this.Items { - if item != nil { - if err := github_com_mwitkow_go_proto_validators.CallValidatorIfExists(item); err != nil { - return github_com_mwitkow_go_proto_validators.FieldError("Items", err) - } - } - } - return nil -} diff --git a/gen/controller/olm_types.pb.go b/gen/controller/olm_types.pb.go deleted file mode 100644 index bdd6602..0000000 --- a/gen/controller/olm_types.pb.go +++ /dev/null @@ -1,230 +0,0 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. -// versions: -// protoc-gen-go v1.25.0 -// protoc v3.13.0 -// source: controller/olm_types.proto - -package controllerv1beta1 - -import ( - reflect "reflect" - sync "sync" - - proto "github.com/golang/protobuf/proto" - protoreflect "google.golang.org/protobuf/reflect/protoreflect" - protoimpl "google.golang.org/protobuf/runtime/protoimpl" -) - -const ( - // Verify that this generated code is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) - // Verify that runtime/protoimpl is sufficiently up-to-date. - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) -) - -// This is a compile-time assertion that a sufficiently up-to-date version -// of the legacy proto package is being used. -const _ = proto.ProtoPackageIsVersion4 - -// Subscription represents an OLM operator subscription. -type Subscription struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Namespace. - Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` - // Subscription name. - Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` - // Package is the operator name. - Package string `protobuf:"bytes,3,opt,name=package,proto3" json:"package,omitempty"` - // Source is the catalog source. - Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` - // Channel. - Channel string `protobuf:"bytes,5,opt,name=channel,proto3" json:"channel,omitempty"` - // Latest known csv. - CurrentCsv string `protobuf:"bytes,6,opt,name=current_csv,json=currentCsv,proto3" json:"current_csv,omitempty"` - // Currently installed csv. - InstalledCsv string `protobuf:"bytes,7,opt,name=installed_csv,json=installedCsv,proto3" json:"installed_csv,omitempty"` - // Install Plan name. - InstallPlanName string `protobuf:"bytes,8,opt,name=install_plan_name,json=installPlanName,proto3" json:"install_plan_name,omitempty"` -} - -func (x *Subscription) Reset() { - *x = Subscription{} - if protoimpl.UnsafeEnabled { - mi := &file_controller_olm_types_proto_msgTypes[0] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) - } -} - -func (x *Subscription) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*Subscription) ProtoMessage() {} - -func (x *Subscription) ProtoReflect() protoreflect.Message { - mi := &file_controller_olm_types_proto_msgTypes[0] - 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 Subscription.ProtoReflect.Descriptor instead. -func (*Subscription) Descriptor() ([]byte, []int) { - return file_controller_olm_types_proto_rawDescGZIP(), []int{0} -} - -func (x *Subscription) GetNamespace() string { - if x != nil { - return x.Namespace - } - return "" -} - -func (x *Subscription) GetName() string { - if x != nil { - return x.Name - } - return "" -} - -func (x *Subscription) GetPackage() string { - if x != nil { - return x.Package - } - return "" -} - -func (x *Subscription) GetSource() string { - if x != nil { - return x.Source - } - return "" -} - -func (x *Subscription) GetChannel() string { - if x != nil { - return x.Channel - } - return "" -} - -func (x *Subscription) GetCurrentCsv() string { - if x != nil { - return x.CurrentCsv - } - return "" -} - -func (x *Subscription) GetInstalledCsv() string { - if x != nil { - return x.InstalledCsv - } - return "" -} - -func (x *Subscription) GetInstallPlanName() string { - if x != nil { - return x.InstallPlanName - } - return "" -} - -var File_controller_olm_types_proto protoreflect.FileDescriptor - -var file_controller_olm_types_proto_rawDesc = []byte{ - 0x0a, 0x1a, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2f, 0x6f, 0x6c, 0x6d, - 0x5f, 0x74, 0x79, 0x70, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x29, 0x70, 0x65, - 0x72, 0x63, 0x6f, 0x6e, 0x61, 0x2e, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x2e, 0x64, - 0x62, 0x61, 0x61, 0x73, 0x2e, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x2e, - 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x22, 0xfe, 0x01, 0x0a, 0x0c, 0x53, 0x75, 0x62, 0x73, - 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x6e, 0x61, 0x6d, 0x65, - 0x73, 0x70, 0x61, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x6e, 0x61, 0x6d, - 0x65, 0x73, 0x70, 0x61, 0x63, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x70, 0x61, - 0x63, 0x6b, 0x61, 0x67, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x70, 0x61, 0x63, - 0x6b, 0x61, 0x67, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x18, 0x04, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x12, 0x18, 0x0a, 0x07, - 0x63, 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, - 0x68, 0x61, 0x6e, 0x6e, 0x65, 0x6c, 0x12, 0x1f, 0x0a, 0x0b, 0x63, 0x75, 0x72, 0x72, 0x65, 0x6e, - 0x74, 0x5f, 0x63, 0x73, 0x76, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x63, 0x75, 0x72, - 0x72, 0x65, 0x6e, 0x74, 0x43, 0x73, 0x76, 0x12, 0x23, 0x0a, 0x0d, 0x69, 0x6e, 0x73, 0x74, 0x61, - 0x6c, 0x6c, 0x65, 0x64, 0x5f, 0x63, 0x73, 0x76, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, - 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x65, 0x64, 0x43, 0x73, 0x76, 0x12, 0x2a, 0x0a, 0x11, - 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, 0x5f, 0x70, 0x6c, 0x61, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, - 0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x69, 0x6e, 0x73, 0x74, 0x61, 0x6c, 0x6c, - 0x50, 0x6c, 0x61, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x42, 0x1e, 0x5a, 0x1c, 0x63, 0x6f, 0x6e, 0x74, - 0x72, 0x6f, 0x6c, 0x6c, 0x65, 0x72, 0x3b, 0x63, 0x6f, 0x6e, 0x74, 0x72, 0x6f, 0x6c, 0x6c, 0x65, - 0x72, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, -} - -var ( - file_controller_olm_types_proto_rawDescOnce sync.Once - file_controller_olm_types_proto_rawDescData = file_controller_olm_types_proto_rawDesc -) - -func file_controller_olm_types_proto_rawDescGZIP() []byte { - file_controller_olm_types_proto_rawDescOnce.Do(func() { - file_controller_olm_types_proto_rawDescData = protoimpl.X.CompressGZIP(file_controller_olm_types_proto_rawDescData) - }) - return file_controller_olm_types_proto_rawDescData -} - -var file_controller_olm_types_proto_msgTypes = make([]protoimpl.MessageInfo, 1) -var file_controller_olm_types_proto_goTypes = []interface{}{ - (*Subscription)(nil), // 0: percona.platform.dbaas.controller.v1beta1.Subscription -} -var file_controller_olm_types_proto_depIdxs = []int32{ - 0, // [0:0] is the sub-list for method output_type - 0, // [0:0] is the sub-list for method input_type - 0, // [0:0] is the sub-list for extension type_name - 0, // [0:0] is the sub-list for extension extendee - 0, // [0:0] is the sub-list for field type_name -} - -func init() { file_controller_olm_types_proto_init() } -func file_controller_olm_types_proto_init() { - if File_controller_olm_types_proto != nil { - return - } - if !protoimpl.UnsafeEnabled { - file_controller_olm_types_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*Subscription); 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{ - File: protoimpl.DescBuilder{ - GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_controller_olm_types_proto_rawDesc, - NumEnums: 0, - NumMessages: 1, - NumExtensions: 0, - NumServices: 0, - }, - GoTypes: file_controller_olm_types_proto_goTypes, - DependencyIndexes: file_controller_olm_types_proto_depIdxs, - MessageInfos: file_controller_olm_types_proto_msgTypes, - }.Build() - File_controller_olm_types_proto = out.File - file_controller_olm_types_proto_rawDesc = nil - file_controller_olm_types_proto_goTypes = nil - file_controller_olm_types_proto_depIdxs = nil -} diff --git a/gen/controller/olm_types.validator.pb.go b/gen/controller/olm_types.validator.pb.go deleted file mode 100644 index 765a7e0..0000000 --- a/gen/controller/olm_types.validator.pb.go +++ /dev/null @@ -1,20 +0,0 @@ -// Code generated by protoc-gen-gogo. DO NOT EDIT. -// source: controller/olm_types.proto - -package controllerv1beta1 - -import ( - fmt "fmt" - math "math" - - proto "github.com/golang/protobuf/proto" -) - -// Reference imports to suppress errors if they are not otherwise used. -var _ = proto.Marshal -var _ = fmt.Errorf -var _ = math.Inf - -func (this *Subscription) Validate() error { - return nil -}