mirror of
https://github.com/google/flatbuffers.git
synced 2026-06-04 04:33:23 +00:00
0c7ae58164
Implemented server.go and half implemented client.go Finishes implementation for greeter go example Update grpc code for monster.fbs Adds a couple of cpp methods Adhere to gofmt standards Adds a readme for issues with grpc
75 lines
1.9 KiB
Go
75 lines
1.9 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"flag"
|
|
"fmt"
|
|
"io"
|
|
"log"
|
|
"time"
|
|
|
|
flatbuffers "github.com/google/flatbuffers/go"
|
|
models "github.com/google/flatbuffers/grpc/examples/go/greeter/models"
|
|
"google.golang.org/grpc"
|
|
)
|
|
|
|
var (
|
|
addr = "3000"
|
|
name = flag.String("name", "Flatbuffers", "name to be sent to server :D")
|
|
)
|
|
|
|
func printSayHello(client models.GreeterClient, name string) {
|
|
log.Printf("Name to be sent (%s)", name)
|
|
b := flatbuffers.NewBuilder(0)
|
|
i := b.CreateString(name)
|
|
models.HelloRequestStart(b)
|
|
models.HelloRequestAddName(b, i)
|
|
b.Finish(models.HelloRequestEnd(b))
|
|
|
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
|
defer cancel()
|
|
request, err := client.SayHello(ctx, b, grpc.CallContentSubtype("flatbuffers"))
|
|
if err != nil {
|
|
log.Fatalf("%v.SayHello(_) = _, %v: ", client, err)
|
|
}
|
|
log.Printf("server said %q", request.Message())
|
|
}
|
|
|
|
func printSayManyHello(client models.GreeterClient, name string) {
|
|
log.Printf("Name to be sent (%s)", name)
|
|
b := flatbuffers.NewBuilder(0)
|
|
i := b.CreateString(name)
|
|
models.HelloRequestStart(b)
|
|
models.HelloRequestAddName(b, i)
|
|
b.Finish(models.HelloRequestEnd(b))
|
|
|
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
|
defer cancel()
|
|
stream, err := client.SayManyHellos(ctx, b, grpc.CallContentSubtype("flatbuffers"))
|
|
if err != nil {
|
|
log.Fatalf("%v.SayManyHellos(_) = _, %v", client, err)
|
|
}
|
|
for {
|
|
request, err := stream.Recv()
|
|
if err == io.EOF {
|
|
break
|
|
}
|
|
if err != nil {
|
|
log.Fatalf("%v.SayManyHellos(_) = _, %v", client, err)
|
|
}
|
|
log.Printf("server said %q", request.Message())
|
|
}
|
|
}
|
|
|
|
func main() {
|
|
flag.Parse()
|
|
conn, err := grpc.Dial(fmt.Sprintf("localhost:%d", 3000), grpc.WithInsecure(), grpc.WithCodec(flatbuffers.FlatbuffersCodec{}))
|
|
if err != nil {
|
|
log.Fatalf("fail to dial: %v", err)
|
|
}
|
|
defer conn.Close()
|
|
client := models.NewGreeterClient(conn)
|
|
printSayHello(client, *name)
|
|
printSayManyHello(client, *name)
|
|
}
|