-
Notifications
You must be signed in to change notification settings - Fork 1
/
main.go
42 lines (33 loc) · 967 Bytes
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package main
import (
"context"
"github.com/golang/protobuf/ptypes/empty"
"github.com/micro-stacks/discov"
pb "github.com/micro-stacks/discov/examples/proto"
"google.golang.org/grpc"
"google.golang.org/grpc/grpclog"
"google.golang.org/grpc/resolver"
"os"
"time"
)
var greetingSrv pb.GreetingClient
func init() {
grpclog.SetLoggerV2(grpclog.NewLoggerV2(os.Stdout, os.Stderr, os.Stderr))
resolver.Register(discov.NewBuilder(discov.WithDNSPollingInterval(time.Second)))
greetingClientConn, err := grpc.Dial("discov://dns/greeting-svc:8080", grpc.WithInsecure())
if err != nil {
panic(err)
}
greetingSrv = pb.NewGreetingClient(greetingClientConn)
}
func main() {
grpclog.Infoln("rpc client start")
for range time.Tick(time.Second) {
resp, err := greetingSrv.Greet(context.TODO(), new(empty.Empty))
if err != nil {
grpclog.Errorf("call greet failed: %v\n", err)
continue
}
grpclog.Infof("receive response: %s\n", resp.Value)
}
}