in mse-go-demo/grpc/b-server/main.go [29:50]
func (s *server) BMethod(ctx context.Context, req *b_api_pb.BRequest) (*b_api_pb.BReply, error) {
conn, err := grpc.DialContext(
ctx,
address,
grpc.WithInsecure(),
grpc.WithBlock(),
)
if err != nil {
log.Fatalf("did not connect: %v", err)
}
defer conn.Close()
cClient := c_api_pb.NewCServiceClient(conn)
cReply, err := cClient.CMethod(ctx, &c_api_pb.CRequest{})
if err != nil {
return nil, err
}
reply := &b_api_pb.BReply{
Message: generateMessage("B") + "->" + cReply.GetMessage(),
}
return reply, nil
}