Author: Paolo Lulli <paolo@lulli.net>
Fix compile
server/grpc/metric-grpc-client.go | 17 +++++++++-------- server/grpc/metric-grpc-server.go | 6 +++--- server/proto/yats-grpc_grpc.pb.go | 2 +- server/yats.go | 3 +++
diff --git a/server/grpc/metric-grpc-client.go b/server/grpc/metric-grpc-client.go index aeb543e23dd6aefea44148d7434f8d409e26f4be..b8916c18cb0ccb7a136bb1d01578393d69a312fd 100644 --- a/server/grpc/metric-grpc-client.go +++ b/server/grpc/metric-grpc-client.go @@ -8,7 +8,7 @@ * @author Paolo Lulli* @copyright Paolo Lulli 2024 */ -package main +package grpc import ( "context" @@ -38,11 +38,12 @@ log.Fatalf("could not create item: %v", err) } log.Printf("Item created: %v", res.GetMetric()) - // Read an item - resRead, err := c.ReadMetric(ctx, &proto.ReadMetricRequest{Id: "1"}) - if err != nil { - log.Fatalf("could not read item: %v", err) - } - log.Printf("Item read: %v", resRead.GetMetric()) - + /* + // Read an item + resRead, err := c.ReadMetric(ctx, &proto.ReadMetricRequest{Id: "1"}) + if err != nil { + log.Fatalf("could not read item: %v", err) + } + log.Printf("Item read: %v", resRead.GetMetric()) + */ } diff --git a/server/grpc/metric-grpc-server.go b/server/grpc/metric-grpc-server.go index 2384268684706c59bddd5a06d1ba418b0a20808b..6168a36a59edcbbc39a03c3d3fd70e61f7f2af6b 100644 --- a/server/grpc/metric-grpc-server.go +++ b/server/grpc/metric-grpc-server.go @@ -8,7 +8,7 @@ * @author Paolo Lulli * @copyright Paolo Lulli 2024 */ -package main +package grpc import ( "context" @@ -36,8 +36,8 @@ s.events[event.IdClient] = event return &proto.CreateEventResponse{Event: event}, nil } -func main_server() { - lis, err := net.Listen("tcp", ":50051") +func RunGrpc(address string) { + lis, err := net.Listen("tcp", address) if err != nil { log.Fatalf("failed to listen: %v", err) } diff --git a/server/proto/yats-grpc_grpc.pb.go b/server/proto/yats-grpc_grpc.pb.go index bfff6aab2b504957e76d76794d852b5831dd04a3..565b23b922a8ea3e6e470ff6890e58134c9477b8 100644 --- a/server/proto/yats-grpc_grpc.pb.go +++ b/server/proto/yats-grpc_grpc.pb.go @@ -11,7 +11,7 @@ ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -const _ = grpc.SupportPackageIsVersion7 +const _ = grpc.SupportPackageIsVersion6 // YatsGrpcServiceClient is the client API for YatsGrpcService service. // diff --git a/server/yats.go b/server/yats.go index f900fc12f0e0b85849770719b48369544dcbfefc..a32aa38a702b8c541bf3e59316bba9ee801e9d51 100644 --- a/server/yats.go +++ b/server/yats.go @@ -15,6 +15,7 @@ "fmt" "os" "yats-server/config" "yats-server/db" + "yats-server/grpc" ) var configuration config.Configuration @@ -38,4 +39,6 @@ go MaintenanceThread(configuration) } RestService(configuration) + + go grpc.RunGrpc(":50051") }