grpc/client/main.go

   1 // Copyright (C) 2016 Sebastian 'tokkee' Harl <sh@tokkee.org>
   2 // All rights reserved.
   3 //
   4 // Redistribution and use in source and binary forms, with or without
   5 // modification, are permitted provided that the following conditions
   6 // are met:
   7 // 1. Redistributions of source code must retain the above copyright
   8 //    notice, this list of conditions and the following disclaimer.
   9 // 2. Redistributions in binary form must reproduce the above copyright
  10 //    notice, this list of conditions and the following disclaimer in the
  11 //    documentation and/or other materials provided with the distribution.
  12 //
  13 // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  14 // ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
  15 // TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  16 // PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR
  17 // CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
  18 // EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  19 // PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
  20 // OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
  21 // WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
  22 // OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  23 // ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  24
  25 // client implements a simple client for the backend protocol.
  26 package main
  27
  28 import (
  29         "flag"
  30         "log"
  31
  32         "golang.org/x/net/context"
  33         "google.golang.org/grpc"
  34
  35         pb "tokkee.org/go-talk/grpc/proto/backend"
  36 )
  37
  38 var (
  39         server = flag.String("server", "localhost:50051", "server address")
  40 )
  41
  42 func main() {
  43         ctx := context.Background()
  44         flag.Parse()
  45
  46         if flag.NArg() != 1 {
  47                 log.Fatal("Missing query.")
  48         }
  49         query := flag.Arg(0)
  50
  51         conn, err := grpc.Dial(*server, grpc.WithInsecure())
  52         if err != nil {
  53                 log.Fatalf("Failed to connect to server at %s: %v", *server, err)
  54         }
  55         defer conn.Close()
  56
  57         c := pb.NewBackendClient(conn)
  58         res, err := c.Query(ctx, &pb.QueryRequest{Query: query})
  59         if err != nil {
  60                 log.Fatalf("Query failed: %v", err)
  61         }
  62         log.Printf("%s: %d\n", res.Type, res.N)
  63 }