Watch OpenSergo CRD actively in Istio environment

config/samples/opensergo_virtual_workload_samples.yaml

@@ -0,0 +1,16 @@
+apiVersion: traffic.opensergo.io/v1alpha1
+kind: VirtualWorkload
+metadata:
+  name: service-provider-virtual-workload
+  namespace: default
+  labels:
+    app: service-provider
+spec:
+  host: service-provider
+  subsets:
+    - labels:
+        version: v1
+      name: v1
+    - labels:
+        version: v2
+      name: v2

constant/istio_constant.go

@@ -0,0 +1,31 @@
+package constant
+
+const (
+	EXTENSION_ROUTE_FALL_BACK = "envoy.router.cluster_specifier_plugin.cluster_fallback"
+	CRD_API_VERSION           = "apiVersion"
+	CRD_KIND                  = "kind"
+	CRD_METADATA              = "metadata"
+	CRD_SPEC                  = "spec"
+	CRD_NAME                  = "name"
+
+	META_RESOURCE_VERSION = "resourceVersion"
+	META_UID              = "uid"
+
+	VERSION_V1_ALPHA3 = "networking.istio.io/v1alpha3"
+
+	VIRTUAL_SERVICE_KIND       = "VirtualService"
+	VIRTUAL_SERVICE_HOST       = "hosts"
+	VIRTUAL_SERVICE_HTTP_MATCH = "http"
+
+	DESTINATION_RULE_KIND              = "DestinationRule"
+	DESTINATION_RULE_EXPORT_TO         = "exportTo"
+	DESTINATION_RULE_HOST              = "host"
+	DESTINATION_RULE_SUBSETS           = "subsets"
+	DESTINATION_RULE_TRAFFIC_POLICY    = "trafficPolicy"
+	DESTINATION_RULE_WORKLOAD_SELECTOR = "workloadSelector"
+
+	CDS_URL = "type.googleapis.com/envoy.config.cluster.v3.Cluster"
+	EDS_URL = "type.googleapis.com/envoy.config.endpoint.v3.ClusterLoadAssignment"
+	LDS_URL = "type.googleapis.com/envoy.config.listener.v3.Listener"
+	RDS_URL = "type.googleapis.com/envoy.config.route.v3.RouteConfiguration"
+)

go.mod

@@ -3,22 +3,34 @@ module github.com/opensergo/opensergo-control-plane
 go 1.14
 
 require (
-	github.com/alibaba/sentinel-golang v1.0.3
-	github.com/cncf/xds/go v0.0.0-20220314180256-7f1daf1720fc
+	cloud.google.com/go/compute/metadata v0.2.3 // indirect
+	github.com/Azure/go-autorest/autorest v0.11.12 // indirect
+	github.com/alibaba/sentinel-golang v1.0.4
+	github.com/blang/semver v3.5.1+incompatible // indirect
+	github.com/emicklei/go-restful v2.9.5+incompatible // indirect
 	github.com/envoyproxy/go-control-plane v0.10.3-0.20221109183938-2935a23e638f
 	github.com/envoyproxy/protoc-gen-validate v0.6.7
-	github.com/go-logr/logr v0.4.0
+	github.com/go-logr/logr v1.2.3
+	github.com/go-openapi/spec v0.19.5 // indirect
 	github.com/golang/protobuf v1.5.2
+	github.com/googleapis/gnostic v0.5.5 // indirect
+	github.com/hashicorp/golang-lru v0.5.4 // indirect
+	github.com/imdario/mergo v0.3.12 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/kr/pretty v0.3.0 // indirect
+	github.com/kr/pty v1.1.5 // indirect
 	github.com/pkg/errors v0.9.1
 	github.com/rogpeppe/go-internal v1.8.0 // indirect
+	go.etcd.io/etcd v0.5.0-alpha.5.0.20200910180754-dd1b699fc489 // indirect
 	go.uber.org/atomic v1.7.0
-	google.golang.org/genproto v0.0.0-20220329172620-7be39ac1afc7
+	golang.org/x/oauth2 v0.4.0 // indirect
+	google.golang.org/genproto v0.0.0-20221202195650-67e5cbc046fd
 	google.golang.org/grpc v1.51.0
 	google.golang.org/protobuf v1.28.1
 	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
-	k8s.io/apimachinery v0.21.4
-	k8s.io/client-go v0.21.4
-	sigs.k8s.io/controller-runtime v0.9.7
+	istio.io/api v0.0.0-20230113171715-aef7f00818fc // indirect
+	k8s.io/api v0.26.0
+	k8s.io/apimachinery v0.26.0
+	k8s.io/client-go v0.26.0
+	sigs.k8s.io/controller-runtime v0.14.1
 )

pkg/api/v1alpha1/traffic/virtual_workload.go

@@ -0,0 +1,47 @@
+// Copyright 2022, OpenSergo 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 traffic
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// +kubebuilder:object:root=true
+type VirtualWorkload struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec VirtualWorkloadSpec `json:"spec,omitempty"`
+
+	Status VirtualWorkloadStatus `json:"status,omitempty"`
+}
+
+// HttpRequestMatchRuleList contains a list of HttpRequestMatchRule.
+// +kubebuilder:object:root=true
+type VirtualWorkloadList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []VirtualWorkload `json:"items"`
+}
+
+// HttpRequestMatchRuleStatus defines the observed state of HttpRequestMatchRule.
+type VirtualWorkloadStatus struct {
+	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
+	// Important: Run "make" to regenerate code after modifying this file
+}
+
+func init() {
+	SchemeBuilder.Register(&VirtualWorkload{}, &VirtualWorkloadList{})
+}