Auth

    For the security, only authorized clients can invoke services.

    Servers receive requests, first check the auth token. They reject requests with invalid tokens.

    Client must set the token:

    2. func main() {
    3.     flag.Parse()
    5.     d := client.NewPeer2PeerDiscovery("tcp@"+*addr, "")
    7.     option := client.DefaultOption
    8.     option.ReadTimeout = 10 * time.Second
    10.     defer xclient.Close()
    12.     //xclient.Auth("bearer tGzv3JOkF0XG5Qx2TlKWIA")
    13.     xclient.Auth("bearer abcdefg1234567")
    15.     args := &example.Args{
    16.         A: 10,
    17.         B: 20,
    18.     }
    19.     reply := &example.Reply{}
    20.     ctx := context.WithValue(context.Background(), share.ReqMetaDataKey, make(map[string]string))
    21.     err := xclient.Call(ctx, "Mul", args, reply)
    22.     if err != nil {
    23.         log.Fatalf("failed to call: %v", err)
    24.     }
    26.     log.Printf("%d * %d = %d", args.A, args.B, reply.C)

    By smallnest updated 2018-12-04 11:47:26