Implementation of a gRPC transport

Makefile

@@ -42,4 +42,19 @@ cov:
 	INTEG_TESTS=yes gocov test github.com/hashicorp/raft | gocov-html > /tmp/coverage.html
 	open /tmp/coverage.html
 
+.PHONY: proto	
+proto: proto-tools proto-no-tools
+
+.PHONY: proto-no-tools
+proto-no-tools:
+	buf generate
+	mog -source './proto/transport/v1/*.pb.go'
+
+.PHONY: proto-tools
+proto-tools:
+	go install github.com/bufbuild/buf/cmd/buf@v1.11.0
+	go install google.golang.org/protobuf/cmd/protoc-gen-go@$(shell grep google.golang.org/protobuf go.mod | awk '{print $$2}')
+	go install google.golang.org/grpc/cmd/protoc-gen-go-grpc@v1.2.0
+	go install github.com/hashicorp/mog@v0.3.0
+
 .PHONY: test cov integ deps dep-linter lint

buf.gen.yaml

@@ -0,0 +1,14 @@
+version: v1
+managed:
+  enabled: true
+  go_package_prefix:
+    default: github.com/hashicorp/raft
+plugins:
+  - name: go
+    out: .
+    opt: paths=source_relative
+  - name: go-grpc
+    out: .
+    opt:
+      - paths=source_relative
+      - require_unimplemented_servers=false

buf.yaml

@@ -0,0 +1,17 @@
+version: v1
+lint:
+  use:
+    - DEFAULT
+  except:
+    # we want to enable our Go packages to have a pb prefix to make goimports more
+    # intelligently handle fixing up imports and hopefully getting it right.
+    - PACKAGE_DIRECTORY_MATCH
+
+    # if we ever need a v2 we can have a second version with the .v2 version in the package name
+    - PACKAGE_VERSION_SUFFIX
+
+  service_suffix: Service
+  allow_comment_ignores: true
+breaking:
+  use:
+    - FILE

go.mod

@@ -8,5 +8,7 @@ require (
 	github.com/armon/go-metrics v0.0.0-20190430140413-ec5e00d3c878
 	github.com/hashicorp/go-hclog v0.9.1
 	github.com/hashicorp/go-msgpack v0.5.5
-	github.com/stretchr/testify v1.3.0
+	github.com/stretchr/testify v1.7.0
+	google.golang.org/grpc v1.51.0
+	google.golang.org/protobuf v1.28.1
 )

proto/transport/v1/conversion.go

@@ -0,0 +1,15 @@
+package transportv1
+
+import (
+	"time"
+
+	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
+)
+
+func TimeFromProto(t *timestamppb.Timestamp) time.Time {
+	return t.AsTime()
+}
+
+func TimeToProto(t time.Time) *timestamppb.Timestamp {
+	return timestamppb.New(t)
+}