common/prpc, tools/cmd/cproto: prpc client

common/prpc/options.go

+// Copyright 2016 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+package prpc
+
+import (
+        "fmt"
+        "time"
+
+        "google.golang.org/grpc"
+        "google.golang.org/grpc/metadata"
+
+        "github.com/luci/luci-go/common/retry"
+)
+
+// Options controls how RPC requests are sent.
+type Options struct {
+        Retry     func() retry.Iterator // RPC retrial.
+        UserAgent string                // value of User-Agent HTTP header.
+        Insecure  bool                  // if true, use HTTP instead of HTTPS.
+
+        // the rest can be set only using CallOption.
+
+        resHeaderMetadata  *metadata.MD // destination for response HTTP headers.
+        resTrailerMetadata *metadata.MD // destination for response HTTP trailers.
+}
+
+// DefaultOptions are used if no options are specified in Client.
+func DefaultOptions() *Options {
+        return &Options{
+                Retry: func() retry.Iterator {
+                        return &retry.ExponentialBackoff{
+                                Limited: retry.Limited{
+                                        Delay:   time.Second,
+                                        Retries: 5,
+                                },
+                        }
+                },
+        }
+}
+
+func (o *Options) apply(callOptions []grpc.CallOption) {
+        for _, co := range callOptions {
+                prpcCo, ok := co.(CallOption)
+                if !ok {
+                        panic(fmt.Errorf("non-pRPC call option %T is used with pRPC client", co))
+                }
+                prpcCo.Apply(o)
+        }
+}
+
+// CallOption mutates Options.
+type CallOption struct {
+        grpc.CallOption
+        // Apply mutates options.
+        Apply func(*Options)

[dnj, 2016/01/21 07:44:28]

Should this be internal "apply"?

[nodir, 2016/01/22 00:47:24]

I don't mind

+}
+
+// Header returns a CallOption that retrieves the header metadata.
+// Can be used instead of with grpc.Header.
+func Header(md *metadata.MD) *CallOption {
+        return &CallOption{
+                grpc.Header(md),
+                func(o *Options) {
+                        o.resHeaderMetadata = md
+                },
+        }
+}
+
+// Trailer returns a CallOption that retrieves the trailer metadata.
+// Can be used instead of grpc.Trailer.
+func Trailer(md *metadata.MD) *CallOption {
+        return &CallOption{
+                grpc.Trailer(md),
+                func(o *Options) {
+                        o.resTrailerMetadata = md
+                },
+        }
+}