Merge pull request #71 from layer5io/remove-meshkit

Remove meshkit

Author: kumarabd

smi-conformance/.golangci.yml

@@ -0,0 +1,45 @@
+run:
+  tests: true
+
+linters:
+  enable:
+    - goconst
+    - gocyclo
+    - gofmt
+    - goimports
+    - golint
+    - gosec
+    - govet
+    - misspell
+    - unused
+    - whitespace
+
+linters-settings:
+  goimports:
+    local-prefixes: github.com/openservicemesh/osm
+
+issues:
+  exclude-rules:
+    # Ignore error for ginkgo and gomega dot imports
+    - linters:
+        - golint
+      source: ". \"github.com/onsi/(ginkgo|gomega)\""
+      text: "dot imports"
+    # Ignore error for test framework imports
+    - linters:
+        - golint
+      source: ". \"github.com/openservicemesh/osm/tests/framework\""
+      text: "dot imports"
+    # ignore unused linters on keyvault as this code isn't being used
+    # TODO: disable this rule once keyvault is integrated
+    - path: pkg/certificate/providers/keyvault/
+      linters:
+        - unused
+        - deadcode
+    # Exclude staticcheck messages for deprecated function, variable or constant
+    # This causes issues with package github.com/golang/protobuf/proto
+    - linters:
+        - staticcheck
+      text: "SA1019:"
+  exclude-use-default: false
+

smi-conformance/Makefile

@@ -0,0 +1,3 @@
+.PHONY: go-lint
+go-lint:
+	go run github.com/golangci/golangci-lint/cmd/golangci-lint run --config .golangci.yml

smi-conformance/go.mod

@@ -2,21 +2,30 @@ module github.com/layer5io/learn-layer5/smi-conformance
 
 go 1.13
 
-replace github.com/kudobuilder/kuttl => github.com/layer5io/kuttl v0.4.1-0.20200806180306-b7e46afd657f
-
 require (
+	cloud.google.com/go v0.46.3 // indirect
 	github.com/golang/protobuf v1.4.2
-	github.com/google/go-cmp v0.5.1 // indirect
+	github.com/google/go-cmp v0.5.2 // indirect
 	github.com/grpc-ecosystem/go-grpc-middleware v1.0.1-0.20190118093823-f849b5445de4
+	github.com/kr/text v0.2.0 // indirect
 	github.com/kudobuilder/kuttl v0.0.0-00010101000000-000000000000
-	github.com/kumarabd/gokit v0.2.0
-	github.com/sirupsen/logrus v1.6.0
+	github.com/mattn/go-isatty v0.0.12 // indirect
+	github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e // indirect
+	github.com/onsi/ginkgo v1.14.1 // indirect
+	github.com/onsi/gomega v1.10.2 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
+	github.com/sirupsen/logrus v1.7.0
 	github.com/stretchr/testify v1.6.1 // indirect
-	golang.org/x/sys v0.0.0-20200615200032-f1bc736245b1 // indirect
-	google.golang.org/genproto v0.0.0-20191009194640-548a555dbc03 // indirect
+	golang.org/x/net v0.0.0-20200822124328-c89045814202 // indirect
+	golang.org/x/sys v0.0.0-20201009025420-dfb3f7c4e634 // indirect
+	golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect
+	google.golang.org/genproto v0.0.0-20191108220845-16a3f7862a1a // indirect
 	google.golang.org/grpc v1.30.0
 	google.golang.org/protobuf v1.23.0
+	gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f // indirect
 	k8s.io/api v0.17.3
 	k8s.io/client-go v0.17.3
 	sigs.k8s.io/controller-runtime v0.5.1
 )
+
+replace github.com/kudobuilder/kuttl => github.com/layer5io/kuttl v0.4.1-0.20200806180306-b7e46afd657f

smi-conformance/go.sum

@@ -1,14 +1,12 @@
 package grpc
 
 import (
-	"errors"
 	"fmt"
 	"net"
 	"time"
 
 	middleware "github.com/grpc-ecosystem/go-grpc-middleware"
 	grpc_recovery "github.com/grpc-ecosystem/go-grpc-middleware/recovery"
-
 	"google.golang.org/grpc"
 
 	"github.com/layer5io/learn-layer5/smi-conformance/conformance"
@@ -19,18 +17,17 @@ type Service struct {
 	Name      string    `json:"name"`
 	Port      string    `json:"port"`
 	Version   string    `json:"version"`
-	StartedAt time.Time `json:"startedat,string"`
+	StartedAt time.Time `json:"startedat"`
 }
 
 // panicHandler is the handler function to handle panic errors
 func panicHandler(r interface{}) error {
 	fmt.Println("500 panic Error")
-	return errors.New(fmt.Sprintf("Panic error for: %+v", r))
+	return fmt.Errorf("Panic error for: %+v", r)
 }
 
-// StartServer starts grpc server
+// Start grpc server
 func Start(s *Service) error {
-
 	address := fmt.Sprintf(":%s", s.Port)
 	listener, err := net.Listen("tcp", address)
 	if err != nil {
@@ -55,5 +52,4 @@ func Start(s *Service) error {
 		return err
 	}
 	return nil
-
 }

smi-conformance/grpc/grpc.go

@@ -32,6 +32,7 @@ var (
 	}
 )
 
+// RunTest return conformance response
 func (s *Service) RunTest(ctx context.Context, req *conformance.Request) (*conformance.Response, error) {
 	var config test_gen.ServiceMesh
 
@@ -68,7 +69,7 @@ func (s *Service) RunTest(ctx context.Context, req *conformance.Request) (*confo
 			d.Result = res.Failure.Message
 			d.Status = "Failing"
 			d.Capability = "None"
-			failures += 1
+			failures++
 			if (res.Assertions - failures) > (res.Assertions / 2) {
 				d.Capability = "Half"
 			}

smi-conformance/grpc/handlers.go

@@ -1,35 +1,26 @@
 package main
 
 import (
-	"fmt"
+	"github.com/layer5io/learn-layer5/smi-conformance/grpc"
 	"os"
+	"sigs.k8s.io/controller-runtime/pkg/log"
 	"time"
-
-	"github.com/layer5io/gokit/logger"
-	"github.com/layer5io/learn-layer5/smi-conformance/grpc"
 )
 
 func main() {
-
 	service := &grpc.Service{
 		Name:      "smi-conformance",
 		Port:      "10011",
 		Version:   "v1.0.0",
 		StartedAt: time.Now(),
 	}
-
 	// Initialize Logger instance
-	log, err := logger.New(service.Name)
-	if err != nil {
-		fmt.Println("Logger Init Failed", err.Error())
-		os.Exit(1)
-	}
-
+	logger := log.Log.WithName(service.Name)
+	logger.Info("Conformance tool Started")
 	// Server Initialization
-	log.Info("Conformance tool Started")
-	err = grpc.Start(service)
+	err := grpc.Start(service)
 	if err != nil {
-		log.Err("Conformance tool crashed!!", err.Error())
+		logger.Error(err, "Conformance tool crashed!!")
 		os.Exit(1)
 	}
 }

smi-conformance/main.go

@@ -26,15 +26,15 @@ type Maesh struct {
 }
 
 func (sm Maesh) SvcAGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s.maesh:%s", SERVICE_A_NAME, namespace, sm.PortSvcA)
+	return fmt.Sprintf("http://%s.%s.maesh:%s", SvcNameA, namespace, sm.PortSvcA)
 }
 
 func (sm Maesh) SvcBGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s.maesh:%s", SERVICE_B_NAME, namespace, sm.PortSvcB)
+	return fmt.Sprintf("http://%s.%s.maesh:%s", SvcNameB, namespace, sm.PortSvcB)
 }
 
 func (sm Maesh) SvcCGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s.maesh:%s", SERVICE_C_NAME, namespace, sm.PortSvcC)
+	return fmt.Sprintf("http://%s.%s.maesh:%s", SvcNameC, namespace, sm.PortSvcC)
 }
 
 func (sm Maesh) SvcAGetPort() string {
@@ -56,15 +56,15 @@ type Linkerd struct {
 }
 
 func (sm Linkerd) SvcAGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_A_NAME, namespace, sm.PortSvcA)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameA, namespace, sm.PortSvcA)
 }
 
 func (sm Linkerd) SvcBGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_B_NAME, namespace, sm.PortSvcB)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameB, namespace, sm.PortSvcB)
 }
 
 func (sm Linkerd) SvcCGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_C_NAME, namespace, sm.PortSvcC)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameC, namespace, sm.PortSvcC)
 }
 
 func (sm Linkerd) SvcAGetPort() string {
@@ -86,15 +86,15 @@ type Istio struct {
 }
 
 func (sm Istio) SvcAGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_A_NAME, namespace, sm.PortSvcA)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameA, namespace, sm.PortSvcA)
 }
 
 func (sm Istio) SvcBGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_B_NAME, namespace, sm.PortSvcB)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameB, namespace, sm.PortSvcB)
 }
 
 func (sm Istio) SvcCGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_C_NAME, namespace, sm.PortSvcC)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameC, namespace, sm.PortSvcC)
 }
 
 func (sm Istio) SvcAGetPort() string {
@@ -116,15 +116,15 @@ type OSM struct {
 }
 
 func (sm OSM) SvcAGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_A_NAME, namespace, sm.PortSvcA)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameA, namespace, sm.PortSvcA)
 }
 
 func (sm OSM) SvcBGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_B_NAME, namespace, sm.PortSvcB)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameB, namespace, sm.PortSvcB)
 }
 
 func (sm OSM) SvcCGetInternalName(namespace string) string {
-	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SERVICE_C_NAME, namespace, sm.PortSvcC)
+	return fmt.Sprintf("http://%s.%s..svc.cluster.local.:%s", SvcNameC, namespace, sm.PortSvcC)
 }
 
 func (sm OSM) SvcAGetPort() string {

smi-conformance/test-gen/service-mesh.go

@@ -104,8 +104,5 @@ func RunTest(meshConfig ServiceMesh, annotations, labels map[string]string) Resu
 			time.Sleep(30 * time.Second)
 		})
 	}()
-	select {
-	case x := <-c:
-		return x
-	}
+	return <-c
 }

smi-conformance/test-gen/test_gen.go

@@ -38,14 +38,17 @@ func (smi *SMIConformance) trafficBlocked(
 		return []error{err}
 	}
 	clusterIPs, err := GetClusterIPs(kubeClient, namespace)
-
+	if err != nil {
+		t.Fail()
+		return []error{err}
+	}
 	ClearAllMetrics(clusterIPs, smi.SMObj)
 
 	// This test will make SERVICE A make a request to SERVICE B
 	svcBTestURL := fmt.Sprintf("%s/%s", smi.SMObj.SvcBGetInternalName(namespace), ECHO)
 	var jsonStr = []byte(`{"url":"` + svcBTestURL + `", "body":"", "method": "GET", "headers": {}}`)
 
-	url := fmt.Sprintf("http://%s:%s/%s", clusterIPs[SERVICE_A_NAME], smi.SMObj.SvcAGetPort(), CALL)
+	url := fmt.Sprintf("http://%s:%s/%s", clusterIPs[SvcNameA], smi.SMObj.SvcAGetPort(), CALL)
 	_, err = httpClient.Post(url, "application/json", bytes.NewBuffer(jsonStr))
 
 	Logger.Logf("URL : \n", url)
@@ -56,7 +59,7 @@ func (smi *SMIConformance) trafficBlocked(
 		return []error{err}
 	}
 
-	metricsSvcA, err := GetMetrics(clusterIPs[SERVICE_A_NAME], "9091")
+	metricsSvcA, err := GetMetrics(clusterIPs[SvcNameA], "9091")
 	if err != nil {
 		t.Fail()
 		Logger.Logf("Error : %s", err.Error())
@@ -100,14 +103,18 @@ func (smi *SMIConformance) trafficAllow(
 		return []error{err}
 	}
 	clusterIPs, err := GetClusterIPs(kubeClient, namespace)
-
+	if err!=nil{
+		t.Fail()
+		Logger.Logf("Error : %s", err.Error())
+		return []error{err}
+	}
 	ClearAllMetrics(clusterIPs, smi.SMObj)
 
 	// This test will make SERVICE A make a request to SERVICE B
 	svcBTestURL := fmt.Sprintf("%s/%s", smi.SMObj.SvcBGetInternalName(namespace), ECHO)
 	var jsonStr = []byte(`{"url":"` + svcBTestURL + `", "body":"", "method": "GET", "headers": {}}`)
 
-	url := fmt.Sprintf("http://%s:%s/%s", clusterIPs[SERVICE_A_NAME], smi.SMObj.SvcAGetPort(), CALL)
+	url := fmt.Sprintf("http://%s:%s/%s", clusterIPs[SvcNameA], smi.SMObj.SvcAGetPort(), CALL)
 	_, err = httpClient.Post(url, "application/json", bytes.NewBuffer(jsonStr))
 
 	Logger.Logf("URL : \n", url)
@@ -118,7 +125,7 @@ func (smi *SMIConformance) trafficAllow(
 		return []error{err}
 	}
 
-	metricsSvcA, err := GetMetrics(clusterIPs[SERVICE_A_NAME], "9091")
+	metricsSvcA, err := GetMetrics(clusterIPs[SvcNameA], "9091")
 
 	if err != nil {
 		t.Fail()
@@ -143,7 +150,7 @@ func (smi *SMIConformance) trafficAllow(
 	}
 	Logger.Log("Validated: Response destination")
 
-	metricsSvcB, err := GetMetrics(clusterIPs[SERVICE_B_NAME], "9091")
+	metricsSvcB, err := GetMetrics(clusterIPs[SvcNameB], "9091")
 	if err != nil {
 		t.Fail()
 		Logger.Log("Error: ", err)