renewed1114

Author: Jibbscript

api/v1/log.pb.go

@@ -2,7 +2,14 @@ syntax = "proto3";
 
 package log.v1;
 
-option go_package = "github.com/travisjeffery/api/log_v1";
+option go_package = "github.com/jibbscript/api/log_v1";
+
+service Log {
+  rpc Produce(ProduceRequest) returns (ProduceResponse) {}
+  rpc Consume(ConsumeRequest) returns (ConsumeResponse) {}
+  rpc ConsumeStream(ConsumeRequest) returns (stream ConsumeResponse) {}
+  rpc ProduceStream(stream ProduceRequest) returns (stream ProduceResponse) {}
+}
 
 message Record {
   bytes value = 1;

api/v1/log.proto

@@ -3,10 +3,10 @@ package main
 import (
 	"log"
 
-	"github.com/jibbscript/dlog/internal/server"
+	httpserver "github.com/jibbscript/dlog/internal/server/httpPrototype"
 )
 
 func main() {
-	srv := server.NewHTTPServer(":8080")
+	srv := httpserver.NewHTTPServer(":8080")
 	log.Fatal(srv.ListenAndServe())
 }

cmd/server/main.go

@@ -1,4 +1,4 @@
-package server
+package httpserver
 
 import (
 	"encoding/json"
@@ -18,7 +18,6 @@ func NewHTTPServer(addr string) *http.Server {
 	}
 }
 
-
 type httpServer struct {
 	Log *Log
 }
@@ -45,7 +44,6 @@ type ConsumeResponse struct {
 	Record Record `json:"record"`
 }
 
-
 func (s *httpServer) handleProduce(w http.ResponseWriter, r *http.Request) {
 	var req ProduceRequest
 	err := json.NewDecoder(r.Body).Decode(&req)
@@ -66,7 +64,6 @@ func (s *httpServer) handleProduce(w http.ResponseWriter, r *http.Request) {
 	}
 }
 
-
 func (s *httpServer) handleConsume(w http.ResponseWriter, r *http.Request) {
 	var req ConsumeRequest
 	err := json.NewDecoder(r.Body).Decode(&req)
@@ -90,4 +87,3 @@ func (s *httpServer) handleConsume(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 }
-

internal/server/http.go renamed to internal/server/httpPrototype/http.go

@@ -1,4 +1,4 @@
-package server
+package httpserver
 
 import (
 	"fmt"

internal/server/log.go renamed to internal/server/httpPrototype/log.go

@@ -0,0 +1,6 @@
+package server
+
+import (
+	"context"
+	api ""
+)