WIP: Refactor framework

Makefile

@@ -3,4 +3,8 @@ LDFLAGS := "-s -w -X 'github.com/database-mesh/waterline/pkg/vesrion.GitCommit=`
 build:
 	mkdir -p bin
 	go build -ldflags=${LDFLAGS} -o bin/waterline cmd/waterline/main.go
+linux:
+	mkdir -p bin
+	GOOS=linux GOARCH=amd64 go build -ldflags=${LDFLAGS} -o bin/waterline cmd/waterline/main.go
+
 

api/v1alpha1/sqltrafficqos_types.go → api/v1alpha1/trafficqos_types.go

@@ -41,20 +41,20 @@ type TrafficQoSGroup struct {
 	Ceil string `json:"ceil",omitempty`
 }
 
-// SQLTrafficQoSSpec defines the desired state of SQLTrafficQoS
-type SQLTrafficQoSSpec struct {
+// TrafficQoSSpec defines the desired state of TrafficQoS
+type TrafficQoSSpec struct {
 	// INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
 	// Important: Run "make" to regenerate code after modifying this file
 
-	// Foo is an example field of SQLTrafficQoS. Edit sqltrafficqos_types.go to remove/update
+	// Foo is an example field of TrafficQoS. Edit trafficqos_types.go to remove/update
 	NetworkDevice string             `json:"networkDevice"`
 	QoSClass      QoSClassType       `json:"qosClass,omitempty"`
 	Strategy      TrafficQoSStrategy `json:"strategy",omitempty`
 	Groups        []TrafficQoSGroup  `json:"groups"`
 }
 
-// SQLTrafficQoSStatus defines the observed state of SQLTrafficQoS
-type SQLTrafficQoSStatus struct {
+// TrafficQoSStatus defines the observed state of TrafficQoS
+type TrafficQoSStatus struct {
 	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
 	// Important: Run "make" to regenerate code after modifying this file
 
@@ -64,24 +64,24 @@ type SQLTrafficQoSStatus struct {
 //+kubebuilder:object:root=true
 //+kubebuilder:subresource:status
 
-// SQLTrafficQoS is the Schema for the sqltrafficqos API
-type SQLTrafficQoS struct {
+// TrafficQoS is the Schema for the trafficqos API
+type TrafficQoS struct {
 	metav1.TypeMeta   `json:",inline"`
 	metav1.ObjectMeta `json:"metadata,omitempty"`
 
-	Spec   SQLTrafficQoSSpec   `json:"spec,omitempty"`
-	Status SQLTrafficQoSStatus `json:"status,omitempty"`
+	Spec   TrafficQoSSpec   `json:"spec,omitempty"`
+	Status TrafficQoSStatus `json:"status,omitempty"`
 }
 
 //+kubebuilder:object:root=true
 
-// SQLTrafficQoSList contains a list of SQLTrafficQoS
-type SQLTrafficQoSList struct {
+// TrafficQoSList contains a list of TrafficQoS
+type TrafficQoSList struct {
 	metav1.TypeMeta `json:",inline"`
 	metav1.ListMeta `json:"metadata,omitempty"`
-	Items           []SQLTrafficQoS `json:"items"`
+	Items           []TrafficQoS `json:"items"`
 }
 
 func init() {
-	SchemeBuilder.Register(&SQLTrafficQoS{}, &SQLTrafficQoSList{})
+	SchemeBuilder.Register(&TrafficQoS{}, &TrafficQoSList{})
 }

api/v1alpha1/sqltrafficqos_webhook.go → api/v1alpha1/trafficqos_webhook.go

@@ -22,52 +22,52 @@ import (
 )
 
 // log is for logging in this package.
-var sqltrafficqoslog = logf.Log.WithName("sqltrafficqos-resource")
+var trafficqoslog = logf.Log.WithName("trafficqos-resource")
 
-func (r *SQLTrafficQoS) SetupWebhookWithManager(mgr ctrl.Manager) error {
+func (r *TrafficQoS) SetupWebhookWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewWebhookManagedBy(mgr).
 		For(r).
 		Complete()
 }
 
 // TODO(user): EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
 
-//+kubebuilder:webhook:path=/mutate-database-mesh-io-database-mesh-io-v1alpha1-sqltrafficqos,mutating=true,failurePolicy=fail,sideEffects=None,groups=database-mesh.io.database-mesh.io,resources=sqltrafficqos,verbs=create;update,versions=v1alpha1,name=msqltrafficqos.kb.io,admissionReviewVersions=v1
+//+kubebuilder:webhook:path=/mutate-database-mesh-io-database-mesh-io-v1alpha1-trafficqos,mutating=true,failurePolicy=fail,sideEffects=None,groups=database-mesh.io.database-mesh.io,resources=trafficqos,verbs=create;update,versions=v1alpha1,name=mtrafficqos.kb.io,admissionReviewVersions=v1
 
-var _ webhook.Defaulter = &SQLTrafficQoS{}
+var _ webhook.Defaulter = &TrafficQoS{}
 
 // Default implements webhook.Defaulter so a webhook will be registered for the type
-func (r *SQLTrafficQoS) Default() {
-	sqltrafficqoslog.Info("default", "name", r.Name)
+func (r *TrafficQoS) Default() {
+	trafficqoslog.Info("default", "name", r.Name)
 
 	// TODO(user): fill in your defaulting logic.
 }
 
 // TODO(user): change verbs to "verbs=create;update;delete" if you want to enable deletion validation.
-//+kubebuilder:webhook:path=/validate-database-mesh-io-database-mesh-io-v1alpha1-sqltrafficqos,mutating=false,failurePolicy=fail,sideEffects=None,groups=database-mesh.io.database-mesh.io,resources=sqltrafficqos,verbs=create;update,versions=v1alpha1,name=vsqltrafficqos.kb.io,admissionReviewVersions=v1
+//+kubebuilder:webhook:path=/validate-database-mesh-io-database-mesh-io-v1alpha1-trafficqos,mutating=false,failurePolicy=fail,sideEffects=None,groups=database-mesh.io.database-mesh.io,resources=trafficqos,verbs=create;update,versions=v1alpha1,name=vtrafficqos.kb.io,admissionReviewVersions=v1
 
-var _ webhook.Validator = &SQLTrafficQoS{}
+var _ webhook.Validator = &TrafficQoS{}
 
 // ValidateCreate implements webhook.Validator so a webhook will be registered for the type
-func (r *SQLTrafficQoS) ValidateCreate() error {
-	sqltrafficqoslog.Info("validate create", "name", r.Name)
+func (r *TrafficQoS) ValidateCreate() error {
+	trafficqoslog.Info("validate create", "name", r.Name)
 
 	// TODO(user): fill in your validation logic upon object creation.
 
 	return nil
 }
 
 // ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
-func (r *SQLTrafficQoS) ValidateUpdate(old runtime.Object) error {
-	sqltrafficqoslog.Info("validate update", "name", r.Name)
+func (r *TrafficQoS) ValidateUpdate(old runtime.Object) error {
+	trafficqoslog.Info("validate update", "name", r.Name)
 
 	// TODO(user): fill in your validation logic upon object update.
 	return nil
 }
 
 // ValidateDelete implements webhook.Validator so a webhook will be registered for the type
-func (r *SQLTrafficQoS) ValidateDelete() error {
-	sqltrafficqoslog.Info("validate delete", "name", r.Name)
+func (r *TrafficQoS) ValidateDelete() error {
+	trafficqoslog.Info("validate delete", "name", r.Name)
 
 	// TODO(user): fill in your validation logic upon object deletion.
 	return nil

api/v1alpha1/trafficqosmapping_webhook.go

@@ -0,0 +1,74 @@
+// Copyright 2022 Database Mesh Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package v1alpha1
+
+import (
+	"k8s.io/apimachinery/pkg/runtime"
+	ctrl "sigs.k8s.io/controller-runtime"
+	logf "sigs.k8s.io/controller-runtime/pkg/log"
+	"sigs.k8s.io/controller-runtime/pkg/webhook"
+)
+
+// log is for logging in this package.
+var trafficqosmappinglog = logf.Log.WithName("trafficqosmapping-resource")
+
+func (r *TrafficQoSMapping) SetupWebhookWithManager(mgr ctrl.Manager) error {
+	return ctrl.NewWebhookManagedBy(mgr).
+		For(r).
+		Complete()
+}
+
+// TODO(user): EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
+
+//+kubebuilder:webhook:path=/mutate-database-mesh-io-database-mesh-io-v1alpha1-TrafficQoSMapping,mutating=true,failurePolicy=fail,sideEffects=None,groups=database-mesh.io.database-mesh.io,resources=trafficqosmapping,verbs=create;update,versions=v1alpha1,name=mtrafficqosmapping.kb.io,admissionReviewVersions=v1
+
+var _ webhook.Defaulter = &TrafficQoSMapping{}
+
+// Default implements webhook.Defaulter so a webhook will be registered for the type
+func (r *TrafficQoSMapping) Default() {
+	trafficqosmappinglog.Info("default", "name", r.Name)
+
+	// TODO(user): fill in your defaulting logic.
+}
+
+// TODO(user): change verbs to "verbs=create;update;delete" if you want to enable deletion validation.
+//+kubebuilder:webhook:path=/validate-database-mesh-io-database-mesh-io-v1alpha1-TrafficQoSMapping,mutating=false,failurePolicy=fail,sideEffects=None,groups=database-mesh.io.database-mesh.io,resources=trafficqosmapping,verbs=create;update,versions=v1alpha1,name=vtrafficqosmapping.kb.io,admissionReviewVersions=v1
+
+var _ webhook.Validator = &TrafficQoSMapping{}
+
+// ValidateCreate implements webhook.Validator so a webhook will be registered for the type
+func (r *TrafficQoSMapping) ValidateCreate() error {
+	trafficqosmappinglog.Info("validate create", "name", r.Name)
+
+	// TODO(user): fill in your validation logic upon object creation.
+
+	return nil
+}
+
+// ValidateUpdate implements webhook.Validator so a webhook will be registered for the type
+func (r *TrafficQoSMapping) ValidateUpdate(old runtime.Object) error {
+	trafficqosmappinglog.Info("validate update", "name", r.Name)
+
+	// TODO(user): fill in your validation logic upon object update.
+	return nil
+}
+
+// ValidateDelete implements webhook.Validator so a webhook will be registered for the type
+func (r *TrafficQoSMapping) ValidateDelete() error {
+	trafficqosmappinglog.Info("validate delete", "name", r.Name)
+
+	// TODO(user): fill in your validation logic upon object deletion.
+	return nil
+}

api/v1alpha1/trafficqosmappping_types.go

@@ -0,0 +1,66 @@
+// Copyright 2022 Database Mesh Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package v1alpha1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
+// NOTE: json tags are required.  Any new fields you add must have json tags for the fields to be serialized.
+
+// TrafficQoSMappingSpec defines the desired state of TrafficQoSMapping
+type TrafficQoSMappingSpec struct {
+	// INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
+	// Important: Run "make" to regenerate code after modifying this file
+
+	// Foo is an example field of TrafficQoSMapping. Edit trafficqos_types.go to remove/update
+	References map[string]string `json:"references`
+
+	//
+	// 1:1 <- virtualdatabase namespace / name
+}
+
+// TrafficQoSMappingStatus defines the observed state of TrafficQoSMapping
+type TrafficQoSMappingStatus struct {
+	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
+	// Important: Run "make" to regenerate code after modifying this file
+
+	//TODO: add ObservedGeneration
+}
+
+//+kubebuilder:object:root=true
+//+kubebuilder:subresource:status
+
+// TrafficQoSMapping is the Schema for the trafficqos API
+type TrafficQoSMapping struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec TrafficQoSMappingSpec `json:"spec,omitempty"`
+}
+
+//+kubebuilder:object:root=true
+
+// TrafficQoSMappingList contains a list of TrafficQoSMapping
+type TrafficQoSMappingList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []TrafficQoSMapping `json:"items"`
+}
+
+func init() {
+	SchemeBuilder.Register(&TrafficQoSMapping{}, &TrafficQoSMappingList{})
+}

api/v1alpha1/virtualdatabase_types.go

@@ -46,18 +46,18 @@ type VirtualDatabaseSpec struct {
 	// Important: Run "make" to regenerate code after modifying this file
 
 	// Foo is an example field of VirtualDatabase. Edit virtualdatabase_types.go to remove/update
-	Selector  map[string]string     `json:"selector"`
+	Selector  map[string]string     `json:"selector"` // TODO: Is it needed ? Or is it applied with Endpoints ?
 	Server    VirtualDatabaseServer `json:"server"`
 	QoS       string                `json:"qos"`
-	Bandwidth string                `json:"bandwidth`
+	Bandwidth string                `json:"bandwidth"`
 }
 
 // VirtualDatabaseStatus defines the observed state of VirtualDatabase
 type VirtualDatabaseStatus struct {
 	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
 	// Important: Run "make" to regenerate code after modifying this file
-	PodList            []string `json:"podList"`
-	ObservedGeneration int64    `json:"observedGeneration,omitempty"`
+	ClassInfo          string `json:"classInfo"`
+	ObservedGeneration int64  `json:"observedGeneration,omitempty"`
 }
 
 type Pod string