feat: buf support

Signed-off-by: Valery Piashchynski <piashchynski.valery@gmail.com>

Author: rustatian

Makefile

@@ -8,6 +8,6 @@ generate-proto:
 	protoc -I./proto/jobs/v1 --go_out=./proto/jobs/v1 jobs.proto
 	protoc -I./proto/kv/v1 --go_out=./proto/kv/v1 kv.proto
 	protoc -I./proto/websockets/v1 --go_out=./proto/websockets/v1 websockets.proto
-	protoc -I./proto/cache/v1beta --go_out=./proto/cache/v1beta response.proto
+	protoc -I./proto/cache/v1 --go_out=./proto/cache/v1 response.proto
 	protoc -I./proto/http/v1beta --go_out=./proto/http/v1beta http.proto
 	protoc -I./proto/service/v1 --go_out=./proto/service/v1 service.proto

README.md

@@ -37,18 +37,26 @@ Here as you see, our `package foo` depends only on the `api` repository, thus yo
 
 ---
 
+## ALL protobuf API located here: [Buf](https://buf.build/roadrunner-server/api)  
+To install and use generated packages:
+```bash
+go get go.buf.build/protocolbuffers/go/roadrunner-server/api
+```
+
 Proto API used for the external integrations for the RPC (mostly) or as the internal communications. For example:
 
 ```go
 package foo
 
 import (
-	jobsv1beta "github.com/roadrunner-server/api/v2/proto/jobs/v1beta"
+	jobsv1 "go.buf.build/protocolbuffers/go/roadrunner-server/api"
 )
 
-func Push(in *jobsv1beta.PushRequest, out *jobsv1beta.Empty) error {
+func Push(in *jobsv1.PushRequest, out *jobsv1.Empty) error {
 	return nil
 }
 ```
 
 Here is the method used in the RR to accept the `Job` from the external system.
+
+You may also navigate to the [`DOCS`](https://buf.build/roadrunner-server/api/docs) tab and inspect the full API. 

buf.gen.yaml

@@ -0,0 +1,13 @@
+version: v1
+
+plugins:
+  - name: go
+    opt:
+      - paths=source_relative
+    out: proto
+
+  - name: go-grpc
+    out: proto
+    opt:
+      - paths=source_relative
+      - require_unimplemented_servers=false

buf.work.yaml

@@ -0,0 +1,4 @@
+version: v1
+
+directories:
+  - proto

buf.yaml

@@ -0,0 +1,11 @@
+version: v1
+name: buf.build/roadrunner-server/api
+deps:
+  - buf.build/googleapis/googleapis
+
+breaking:
+  use:
+    - FILE
+lint:
+  use:
+    - DEFAULT

go.mod

@@ -7,8 +7,8 @@ require (
 	github.com/prometheus/client_golang v1.12.1
 	github.com/roadrunner-server/goridge/v3 v3.4.1
 	github.com/valyala/fasthttp v1.36.0
+	go.buf.build/protocolbuffers/go/roadrunner-server/api v1.2.1
 	go.uber.org/zap v1.21.0
-	google.golang.org/protobuf v1.28.0
 )
 
 require (
@@ -26,4 +26,5 @@ require (
 	go.uber.org/atomic v1.9.0 // indirect
 	go.uber.org/multierr v1.8.0 // indirect
 	golang.org/x/sys v0.0.0-20220429121018-84afa8d3f7b3 // indirect
+	google.golang.org/protobuf v1.28.0 // indirect
 )

go.sum

@@ -213,6 +213,8 @@ github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9de
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
+go.buf.build/protocolbuffers/go/roadrunner-server/api v1.2.1 h1:hj0YSuHUwQoxjoarYjqSCx2Pxy/qndrtMQsA4y6W57k=
+go.buf.build/protocolbuffers/go/roadrunner-server/api v1.2.1/go.mod h1:iGiZ72YpQLUTuxA0Ynq5SQ9gcseK0Ny1bbVbA0sHdvU=
 go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
 go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
 go.opencensus.io v0.22.2/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=

plugins/fasthttp/interface.go

@@ -1,6 +1,6 @@
 package kv
 
-import kvv1 "github.com/roadrunner-server/api/v2/proto/kv/v1"
+import kvv1 "go.buf.build/protocolbuffers/go/roadrunner-server/api/proto/kv/v1"
 
 // Storage represents single abstract storage.
 type Storage interface {

plugins/kv/interface.go

@@ -0,0 +1,14 @@
+syntax = "proto3";
+
+package cache.v1;
+
+message Response {
+  bytes data = 1;
+  uint64 code = 2;
+  map<string, HeaderValue> headers = 3;
+  string timestamp = 4;
+}
+
+message HeaderValue {
+  repeated string value = 1;
+}