Rebasing changes after knative renaming

cmd/queue/BUILD.bazel

@@ -9,14 +9,12 @@ go_library(
         "//cmd/util:go_default_library",
         "//pkg/apis/serving/v1alpha1:go_default_library",
         "//pkg/autoscaler:go_default_library",
+        "//pkg/h2c:go_default_library",
         "//pkg/logging:go_default_library",
         "//pkg/logging/logkey:go_default_library",
-        "//pkg/h2c:go_default_library",
         "//pkg/queue:go_default_library",
-        "//vendor/github.com/golang/glog:go_default_library",
         "//vendor/github.com/gorilla/websocket:go_default_library",
         "//vendor/go.uber.org/zap:go_default_library",
-        "//vendor/golang.org/x/net/http2:go_default_library",
         "//vendor/k8s.io/client-go/kubernetes:go_default_library",
         "//vendor/k8s.io/client-go/rest:go_default_library",
     ],

cmd/queue/main.go

@@ -19,7 +19,6 @@ import (
 	"bytes"
 	"context"
 	"encoding/gob"
-	"errors"
 	"flag"
 	"fmt"
 	"io"
@@ -33,7 +32,6 @@ import (
 	"syscall"
 	"time"
 
-	"github.com/google/tcpproxy"
 	"github.com/knative/serving/cmd/util"
 	"github.com/knative/serving/pkg/apis/serving/v1alpha1"
 	"github.com/knative/serving/pkg/autoscaler"
@@ -92,11 +90,6 @@ var (
 	singleConcurrencyBreaker = queue.NewBreaker(singleConcurrencyQueueDepth, 1)
 )
 
-type Proxy struct {
-	HttpProxy *http.Server
-	TcpProxy  *tcpproxy.Proxy
-}
-
 func initEnv() {
 	podName = util.GetRequiredEnvOrFatal("ELA_POD", logger)
 	elaNamespace = util.GetRequiredEnvOrFatal("ELA_NAMESPACE", logger)
@@ -106,28 +99,6 @@ func initEnv() {
 	elaAutoscalerPort = util.GetRequiredEnvOrFatal("ELA_AUTOSCALER_PORT", logger)
 }
 
-func (p *Proxy) Run() error {
-	if p.HttpProxy != nil {
-		if err := p.HttpProxy.ListenAndServe(); err != nil {
-			return err
-		}
-	}
-<<<<<<< HEAD:cmd/queue/main.go
-	if p.TcpProxy != nil {
-		if err := p.TcpProxy.Run(); err != nil {
-			return err
-		}
-	}
-	return errors.New("No proxies to run - both HttpProxy and TcpProxy are nil.")
-=======
-
-	httpProxy = httputil.NewSingleHostReverseProxy(target)
-
-	h2cProxy = httputil.NewSingleHostReverseProxy(target)
-	h2cProxy.Transport = h2c.NewTransport()
->>>>>>> Update the activator to use an h2c server:cmd/ela-queue/main.go
-}
-
 func connectStatSink() {
 	autoscalerEndpoint := fmt.Sprintf("ws://%s.%s.svc.cluster.local:%s",
 		elaAutoscaler, queue.AutoscalerNamespace, elaAutoscalerPort)
@@ -301,7 +272,9 @@ func main() {
 	if err != nil {
 		logger.Fatal("Failed to parse localhost url", zap.Error(err))
 	}
-	proxy = httputil.NewSingleHostReverseProxy(target)
+	httpProxy = httputil.NewSingleHostReverseProxy(target)
+	h2cProxy = httputil.NewSingleHostReverseProxy(target)
+	h2cProxy.Transport = h2c.NewTransport()
 
 	logger.Info("Queue container is starting")
 	config, err := rest.InClusterConfig()

pkg/controller/route/route_test.go

@@ -1522,7 +1522,7 @@ func TestCreateRouteWithGRPCProtocol(t *testing.T) {
 	rev := getTestRevision("test-rev")
 	rev.Spec.Protocol = "grpc"
 
-	elaClient.ElafrosV1alpha1().Revisions(testNamespace).Create(rev)
+	elaClient.ServingV1alpha1().Revisions(testNamespace).Create(rev)
 
 	// A route targeting the revision
 	route := getTestRouteWithTrafficTargets(
@@ -1533,9 +1533,9 @@ func TestCreateRouteWithGRPCProtocol(t *testing.T) {
 			},
 		},
 	)
-	elaClient.ElafrosV1alpha1().Routes(testNamespace).Create(route)
+	elaClient.ServingV1alpha1().Routes(testNamespace).Create(route)
 	// Since updateRouteEvent looks in the lister, we need to add it to the informer
-	elaInformer.Elafros().V1alpha1().Routes().Informer().GetIndexer().Add(route)
+	elaInformer.Serving().V1alpha1().Routes().Informer().GetIndexer().Add(route)
 
 	controller.updateRouteEvent(KeyOrDie(route))
 

pkg/h2c/BUILD.bazel

@@ -6,7 +6,7 @@ go_library(
         "h2c.go",
         "transport.go",
     ],
-    importpath = "github.com/elafros/elafros/pkg/h2c",
+    importpath = "github.com/knative/serving/pkg/h2c",
     visibility = ["//visibility:public"],
     deps = [
         "//vendor/golang.org/x/net/http/httpguts:go_default_library",

sample/grpc-ping/BUILD

@@ -3,7 +3,7 @@ load("@io_bazel_rules_go//go:def.bzl", "go_binary", "go_library")
 go_library(
     name = "go_default_library",
     srcs = ["grpc-ping.go"],
-    importpath = "github.com/elafros/elafros/sample/grpc-ping",
+    importpath = "github.com/knative/serving/sample/grpc-ping",
     visibility = ["//visibility:private"],
     deps = [
         "//sample/grpc-ping/proto:go_default_library",

sample/grpc-ping/README.md

@@ -4,7 +4,7 @@ A simple gRPC server written in Go that you can use for testing.
 
 ## Prerequisites
 
-1. [Install Elafros](https://github.com/elafros/install/blob/master/README.md)
+1. [Install Knative](https://github.com/knative/install/blob/master/README.md)
 1. Install [docker](https://www.docker.com/)
 
 ## Build and run the gRPC server
@@ -22,9 +22,9 @@ docker build \
 docker push "${REPO}/sample/grpc-ping"
 
 # Replace the image reference with our published image.
-perl -pi -e "s@github.com/elafros/elafros/sample/grpc-ping@${REPO}/sample/grpc-ping@g" sample/grpc-ping/*.yaml
+perl -pi -e "s@github.com/knative/serving/sample/grpc-ping@${REPO}/sample/grpc-ping@g" sample/grpc-ping/*.yaml
 
-# Deploy the Elafros sample
+# Deploy the Knative sample
 kubectl apply -f sample/grpc-ping/sample.yaml
 
 ```

sample/grpc-ping/client/BUILD.bazel

@@ -3,7 +3,7 @@ load("@io_bazel_rules_go//go:def.bzl", "go_binary", "go_library")
 go_library(
     name = "go_default_library",
     srcs = ["client.go"],
-    importpath = "github.com/elafros/elafros/sample/grpc-ping/client",
+    importpath = "github.com/knative/serving/sample/grpc-ping/client",
     visibility = ["//visibility:private"],
     deps = [
         "//sample/grpc-ping/proto:go_default_library",

sample/grpc-ping/client/client.go

@@ -7,14 +7,14 @@ import (
 	"log"
 	"time"
 
-	pb "github.com/elafros/elafros/sample/grpc-ping/proto"
+	pb "github.com/knative/serving/sample/grpc-ping/proto"
 	"golang.org/x/net/context"
 	"google.golang.org/grpc"
 )
 
 var (
 	serverAddr         = flag.String("server_addr", "127.0.0.1:8080", "The server address in the format of host:port")
-	serverHostOverride = flag.String("server_host_override", "grpc.elafros.dev", "")
+	serverHostOverride = flag.String("server_host_override", "grpc.knative.dev", "")
 )
 
 func main() {

sample/grpc-ping/grpc-ping.go

@@ -7,7 +7,7 @@ import (
 	"net"
 	"time"
 
-	ping "github.com/elafros/elafros/sample/grpc-ping/proto"
+	ping "github.com/knative/serving/sample/grpc-ping/proto"
 	"golang.org/x/net/context"
 	"google.golang.org/grpc"
 )

sample/grpc-ping/proto/BUILD.bazel

@@ -3,7 +3,7 @@ load("@io_bazel_rules_go//go:def.bzl", "go_library")
 go_library(
     name = "go_default_library",
     srcs = ["ping.pb.go"],
-    importpath = "github.com/elafros/elafros/sample/grpc-ping/proto",
+    importpath = "github.com/knative/serving/sample/grpc-ping/proto",
     visibility = ["//visibility:public"],
     deps = [
         "//vendor/github.com/golang/protobuf/proto:go_default_library",

sample/grpc-ping/sample.yaml

@@ -1,5 +1,5 @@
 ---
-apiVersion: elafros.dev/v1alpha1
+apiVersion: serving.knative.dev/v1alpha1
 kind: Route
 metadata:
   name: grpc-ping
@@ -9,7 +9,7 @@ spec:
   - configurationName: grpc-ping
     percent: 100
 ---
-apiVersion: elafros.dev/v1alpha1
+apiVersion: serving.knative.dev/v1alpha1
 kind: Configuration
 metadata:
   name: grpc-ping
@@ -22,4 +22,4 @@ spec:
     spec:
       protocol: grpc
       container:
-        image: github.com/elafros/elafros/sample/grpc-ping
+        image: github.com/knative/serving/sample/grpc-ping

test/e2e/BUILD.bazel

@@ -10,9 +10,12 @@ go_test(
     deps = [
         "//pkg/apis/serving/v1alpha1:go_default_library",
         "//test:go_default_library",
+        "//test/e2e/test_images/helloworld-grpc/proto:go_default_library",
+        "//vendor/google.golang.org/grpc:go_default_library",
         "//vendor/k8s.io/api/core/v1:go_default_library",
         "//vendor/k8s.io/api/extensions/v1beta1:go_default_library",
         "//vendor/k8s.io/apimachinery/pkg/apis/meta/v1:go_default_library",
+        "//vendor/k8s.io/apimachinery/pkg/util/wait:go_default_library",
         "//vendor/k8s.io/client-go/plugin/pkg/client/auth/gcp:go_default_library",
     ],
 )

test/e2e/e2e_test.go

@@ -3,7 +3,7 @@ package e2e
 import (
 	"testing"
 
-	"github.com/knative/serving/pkg/apis/ela/v1alpha1"
+	"github.com/knative/serving/pkg/apis/serving/v1alpha1"
 	"github.com/knative/serving/test"
 	// Mysteriously required to support GCP auth (required by k8s libs).
 	// Apparently just importing it is enough. @_@ side effects @_@.

test/e2e/errorcondition_test.go

@@ -45,7 +45,7 @@ func TestContainerErrorMsg(t *testing.T) {
 	imagePath := strings.Join([]string{test.Flags.DockerRepo, "invalidhelloworld"}, "/")
 
 	log.Printf("Creating a new Route and Configuration %s", imagePath)
-	err := CreateRouteAndConfig(clients, imagePath)
+	err := CreateRouteAndConfig(clients, imagePath, v1alpha1.RevisionProtocolHTTP)
 	if err != nil {
 		t.Fatalf("Failed to create Route and Configuration: %v", err)
 	}

test/e2e/helloworld_test.go

@@ -130,9 +130,12 @@ func waitForHelloWorldGRPCEndpoint(address string, spoofDomain string) error {
 		ctx, cancel := context.WithTimeout(context.Background(), 120*time.Second)
 		defer cancel()
 
-		resp, err := client.Hello(ctx, &hello.Request{Msg: "world"})
+		req := &hello.Request{Msg: "world"}
+		log.Printf("Retrying gRPC request: %+v", req)
+		resp, err := client.Hello(ctx, req)
 		if err != nil {
-			return true, err
+			// Continue to poll since the Ingress may take a while to start serving requests
+			return false, nil
 		}
 
 		expectedResponse := "Hello world"
@@ -141,7 +144,7 @@ func waitForHelloWorldGRPCEndpoint(address string, spoofDomain string) error {
 		if receivedResponse == expectedResponse {
 			return true, nil
 		}
-		return false, fmt.Errorf("Did not get expected response message %s, got %s", expectedResponse, receivedResponse)
+		return true, fmt.Errorf("Did not get expected response message %s, got %s", expectedResponse, receivedResponse)
 	})
 	return err
 }

test/e2e/test_images/helloworld-grpc/BUILD.bazel

@@ -0,0 +1,19 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_binary", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["helloworld.go"],
+    importpath = "github.com/knative/serving/test/e2e/test_images/helloworld-grpc",
+    visibility = ["//visibility:private"],
+    deps = [
+        "//test/e2e/test_images/helloworld-grpc/proto:go_default_library",
+        "//vendor/golang.org/x/net/context:go_default_library",
+        "//vendor/google.golang.org/grpc:go_default_library",
+    ],
+)
+
+go_binary(
+    name = "helloworld-grpc",
+    embed = [":go_default_library"],
+    visibility = ["//visibility:public"],
+)

test/e2e/test_images/helloworld-grpc/Dockerfile

@@ -1,6 +1,6 @@
 FROM golang:latest
 
-ENV APP ${GOPATH}/src/github.com/elafros/elafros/test/e2e/test_images/helloworld-grpc
+ENV APP ${GOPATH}/src/github.com/knative/serving/test/e2e/test_images/helloworld-grpc
 
 RUN mkdir -p "$APP"
 ADD . "$APP"

test/e2e/test_images/helloworld-grpc/helloworld.go

@@ -5,7 +5,7 @@ import (
 	"log"
 	"net"
 
-	hello "github.com/elafros/elafros/test/e2e/test_images/helloworld-grpc/proto"
+	hello "github.com/knative/serving/test/e2e/test_images/helloworld-grpc/proto"
 	"golang.org/x/net/context"
 	"google.golang.org/grpc"
 )

test/e2e/test_images/helloworld-grpc/proto/BUILD.bazel

@@ -0,0 +1,13 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["helloworld.pb.go"],
+    importpath = "github.com/knative/serving/test/e2e/test_images/helloworld-grpc/proto",
+    visibility = ["//visibility:public"],
+    deps = [
+        "//vendor/github.com/golang/protobuf/proto:go_default_library",
+        "//vendor/golang.org/x/net/context:go_default_library",
+        "//vendor/google.golang.org/grpc:go_default_library",
+    ],
+)