mirror of
https://github.com/zrepl/zrepl.git
synced 2024-11-30 20:35:23 +01:00
efe7b17d21
From: github.com/golang/protobuf v1.3.2 google.golang.org/grpc v1.17.0 To: github.com/golang/protobuf v1.4.3 google.golang.org/grpc v1.35.0 google.golang.org/protobuf v1.25.0 About the two protobuf packages: https://developers.google.com/protocol-buffers/docs/reference/go/faq > Version v1.4.0 and higher of github.com/golang/protobuf wrap the new implementation and permit programs to adopt the new API incrementally. For example, the well-known types defined in github.com/golang/protobuf/ptypes are simply aliases of those defined in the newer module. Thus, google.golang.org/protobuf/types/known/emptypb and github.com/golang/protobuf/ptypes/empty may be used interchangeably. Notable Code Changes in zrepl: - generate protobufs now contain a mutex so we can't copy them by value anymore - grpc.WithDialer is deprecated => use grpc.WithContextDialer instead Go1.12 is now actually required by some of the dependencies.
115 lines
2.6 KiB
Go
115 lines
2.6 KiB
Go
// This package demonstrates how the grpcclientidentity package can be used
|
|
// to set up a gRPC greeter service.
|
|
package main
|
|
|
|
import (
|
|
"context"
|
|
"flag"
|
|
"fmt"
|
|
"os"
|
|
"time"
|
|
|
|
"github.com/zrepl/zrepl/config"
|
|
"github.com/zrepl/zrepl/logger"
|
|
"github.com/zrepl/zrepl/rpc/grpcclientidentity/example/pdu"
|
|
"github.com/zrepl/zrepl/rpc/grpcclientidentity/grpchelper"
|
|
"github.com/zrepl/zrepl/transport/tcp"
|
|
)
|
|
|
|
var args struct {
|
|
mode string
|
|
}
|
|
|
|
var log = logger.NewStderrDebugLogger()
|
|
|
|
func main() {
|
|
flag.StringVar(&args.mode, "mode", "", "client|server")
|
|
flag.Parse()
|
|
|
|
switch args.mode {
|
|
case "client":
|
|
client()
|
|
case "server":
|
|
server()
|
|
default:
|
|
log.Printf("unknown mode %q")
|
|
os.Exit(1)
|
|
}
|
|
}
|
|
|
|
func onErr(err error, format string, args ...interface{}) {
|
|
log.WithError(err).Error(fmt.Sprintf("%s: %s", fmt.Sprintf(format, args...), err))
|
|
os.Exit(1)
|
|
}
|
|
|
|
func client() {
|
|
cn, err := tcp.TCPConnecterFromConfig(&config.TCPConnect{
|
|
ConnectCommon: config.ConnectCommon{
|
|
Type: "tcp",
|
|
},
|
|
Address: "127.0.0.1:8080",
|
|
DialTimeout: 10 * time.Second,
|
|
})
|
|
if err != nil {
|
|
onErr(err, "build connecter error")
|
|
}
|
|
|
|
clientConn := grpchelper.ClientConn(cn, log)
|
|
defer clientConn.Close()
|
|
|
|
// normal usage from here on
|
|
|
|
client := pdu.NewGreeterClient(clientConn)
|
|
resp, err := client.Greet(context.Background(), &pdu.GreetRequest{Name: "somethingimadeup"})
|
|
if err != nil {
|
|
onErr(err, "RPC error")
|
|
}
|
|
|
|
fmt.Printf("got response:\n\t%s\n", resp.GetMsg())
|
|
}
|
|
|
|
const clientIdentityKey = "clientIdentity"
|
|
|
|
func server() {
|
|
authListenerFactory, err := tcp.TCPListenerFactoryFromConfig(nil, &config.TCPServe{
|
|
ServeCommon: config.ServeCommon{
|
|
Type: "tcp",
|
|
},
|
|
Listen: "127.0.0.1:8080",
|
|
Clients: map[string]string{
|
|
"127.0.0.1": "localclient",
|
|
"::1": "localclient",
|
|
},
|
|
})
|
|
if err != nil {
|
|
onErr(err, "cannot build listener factory")
|
|
}
|
|
|
|
log := logger.NewStderrDebugLogger()
|
|
|
|
authListener, err := authListenerFactory()
|
|
if err != nil {
|
|
onErr(err, "cannot listen")
|
|
}
|
|
|
|
srv, serve := grpchelper.NewServer(authListener, clientIdentityKey, log, nil)
|
|
|
|
svc := &greeter{prepend: "hello "}
|
|
pdu.RegisterGreeterServer(srv, svc)
|
|
|
|
if err := serve(); err != nil {
|
|
onErr(err, "error serving")
|
|
}
|
|
}
|
|
|
|
type greeter struct {
|
|
pdu.UnsafeGreeterServer
|
|
prepend string
|
|
}
|
|
|
|
func (g *greeter) Greet(ctx context.Context, r *pdu.GreetRequest) (*pdu.GreetResponse, error) {
|
|
ci, _ := ctx.Value(clientIdentityKey).(string)
|
|
log.WithField("clientIdentity", ci).Info("Greet() request") // show that we got the client identity
|
|
return &pdu.GreetResponse{Msg: fmt.Sprintf("%s%s (clientIdentity=%q)", g.prepend, r.GetName(), ci)}, nil
|
|
}
|