2 files changed, 274 insertions, 0 deletions

diff --git a/vendor/google.golang.org/grpc/stats/handlers.go b/vendor/google.golang.org/grpc/stats/handlers.go
new file mode 100644
index 0000000..05b384c
--- /dev/null
+++ b/vendor/google.golang.org/grpc/stats/handlers.go
@@ -0,0 +1,64 @@
+/*
+ *
+ * Copyright 2016 gRPC authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package stats
+
+import (
+        "net"
+
+        "golang.org/x/net/context"
+)
+
+// ConnTagInfo defines the relevant information needed by connection context tagger.
+type ConnTagInfo struct {
+        // RemoteAddr is the remote address of the corresponding connection.
+        RemoteAddr net.Addr
+        // LocalAddr is the local address of the corresponding connection.
+        LocalAddr net.Addr
+}
+
+// RPCTagInfo defines the relevant information needed by RPC context tagger.
+type RPCTagInfo struct {
+        // FullMethodName is the RPC method in the format of /package.service/method.
+        FullMethodName string
+        // FailFast indicates if this RPC is failfast.
+        // This field is only valid on client side, it's always false on server side.
+        FailFast bool
+}
+
+// Handler defines the interface for the related stats handling (e.g., RPCs, connections).
+type Handler interface {
+        // TagRPC can attach some information to the given context.
+        // The context used for the rest lifetime of the RPC will be derived from
+        // the returned context.
+        TagRPC(context.Context, *RPCTagInfo) context.Context
+        // HandleRPC processes the RPC stats.
+        HandleRPC(context.Context, RPCStats)
+
+        // TagConn can attach some information to the given context.
+        // The returned context will be used for stats handling.
+        // For conn stats handling, the context used in HandleConn for this
+        // connection will be derived from the context returned.
+        // For RPC stats handling,
+        //  - On server side, the context used in HandleRPC for all RPCs on this
+        // connection will be derived from the context returned.
+        //  - On client side, the context is not derived from the context returned.
+        TagConn(context.Context, *ConnTagInfo) context.Context
+        // HandleConn processes the Conn stats.
+        HandleConn(context.Context, ConnStats)
+}
diff --git a/vendor/google.golang.org/grpc/stats/stats.go b/vendor/google.golang.org/grpc/stats/stats.go
new file mode 100644
index 0000000..338a3a7
--- /dev/null
+++ b/vendor/google.golang.org/grpc/stats/stats.go
@@ -0,0 +1,210 @@
+/*
+ *
+ * Copyright 2016 gRPC authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+// Package stats is for collecting and reporting various network and RPC stats.
+// This package is for monitoring purpose only. All fields are read-only.
+// All APIs are experimental.
+package stats // import "google.golang.org/grpc/stats"
+
+import (
+        "net"
+        "time"
+)
+
+// RPCStats contains stats information about RPCs.
+type RPCStats interface {
+        isRPCStats()
+        // IsClient returns true if this RPCStats is from client side.
+        IsClient() bool
+}
+
+// Begin contains stats when an RPC begins.
+// FailFast is only valid if this Begin is from client side.
+type Begin struct {
+        // Client is true if this Begin is from client side.
+        Client bool
+        // BeginTime is the time when the RPC begins.
+        BeginTime time.Time
+        // FailFast indicates if this RPC is failfast.
+        FailFast bool
+}
+
+// IsClient indicates if the stats information is from client side.
+func (s *Begin) IsClient() bool { return s.Client }
+
+func (s *Begin) isRPCStats() {}
+
+// InPayload contains the information for an incoming payload.
+type InPayload struct {
+        // Client is true if this InPayload is from client side.
+        Client bool
+        // Payload is the payload with original type.
+        Payload interface{}
+        // Data is the serialized message payload.
+        Data []byte
+        // Length is the length of uncompressed data.
+        Length int
+        // WireLength is the length of data on wire (compressed, signed, encrypted).
+        WireLength int
+        // RecvTime is the time when the payload is received.
+        RecvTime time.Time
+}
+
+// IsClient indicates if the stats information is from client side.
+func (s *InPayload) IsClient() bool { return s.Client }
+
+func (s *InPayload) isRPCStats() {}
+
+// InHeader contains stats when a header is received.
+type InHeader struct {
+        // Client is true if this InHeader is from client side.
+        Client bool
+        // WireLength is the wire length of header.
+        WireLength int
+
+        // The following fields are valid only if Client is false.
+        // FullMethod is the full RPC method string, i.e., /package.service/method.
+        FullMethod string
+        // RemoteAddr is the remote address of the corresponding connection.
+        RemoteAddr net.Addr
+        // LocalAddr is the local address of the corresponding connection.
+        LocalAddr net.Addr
+        // Compression is the compression algorithm used for the RPC.
+        Compression string
+}
+
+// IsClient indicates if the stats information is from client side.
+func (s *InHeader) IsClient() bool { return s.Client }
+
+func (s *InHeader) isRPCStats() {}
+
+// InTrailer contains stats when a trailer is received.
+type InTrailer struct {
+        // Client is true if this InTrailer is from client side.
+        Client bool
+        // WireLength is the wire length of trailer.
+        WireLength int
+}
+
+// IsClient indicates if the stats information is from client side.
+func (s *InTrailer) IsClient() bool { return s.Client }
+
+func (s *InTrailer) isRPCStats() {}
+
+// OutPayload contains the information for an outgoing payload.
+type OutPayload struct {
+        // Client is true if this OutPayload is from client side.
+        Client bool
+        // Payload is the payload with original type.
+        Payload interface{}
+        // Data is the serialized message payload.
+        Data []byte
+        // Length is the length of uncompressed data.
+        Length int
+        // WireLength is the length of data on wire (compressed, signed, encrypted).
+        WireLength int
+        // SentTime is the time when the payload is sent.
+        SentTime time.Time
+}
+
+// IsClient indicates if this stats information is from client side.
+func (s *OutPayload) IsClient() bool { return s.Client }
+
+func (s *OutPayload) isRPCStats() {}
+
+// OutHeader contains stats when a header is sent.
+type OutHeader struct {
+        // Client is true if this OutHeader is from client side.
+        Client bool
+        // WireLength is the wire length of header.
+        WireLength int
+
+        // The following fields are valid only if Client is true.
+        // FullMethod is the full RPC method string, i.e., /package.service/method.
+        FullMethod string
+        // RemoteAddr is the remote address of the corresponding connection.
+        RemoteAddr net.Addr
+        // LocalAddr is the local address of the corresponding connection.
+        LocalAddr net.Addr
+        // Compression is the compression algorithm used for the RPC.
+        Compression string
+}
+
+// IsClient indicates if this stats information is from client side.
+func (s *OutHeader) IsClient() bool { return s.Client }
+
+func (s *OutHeader) isRPCStats() {}
+
+// OutTrailer contains stats when a trailer is sent.
+type OutTrailer struct {
+        // Client is true if this OutTrailer is from client side.
+        Client bool
+        // WireLength is the wire length of trailer.
+        WireLength int
+}
+
+// IsClient indicates if this stats information is from client side.
+func (s *OutTrailer) IsClient() bool { return s.Client }
+
+func (s *OutTrailer) isRPCStats() {}
+
+// End contains stats when an RPC ends.
+type End struct {
+        // Client is true if this End is from client side.
+        Client bool
+        // EndTime is the time when the RPC ends.
+        EndTime time.Time
+        // Error is the error the RPC ended with. It is an error generated from
+        // status.Status and can be converted back to status.Status using
+        // status.FromError if non-nil.
+        Error error
+}
+
+// IsClient indicates if this is from client side.
+func (s *End) IsClient() bool { return s.Client }
+
+func (s *End) isRPCStats() {}
+
+// ConnStats contains stats information about connections.
+type ConnStats interface {
+        isConnStats()
+        // IsClient returns true if this ConnStats is from client side.
+        IsClient() bool
+}
+
+// ConnBegin contains the stats of a connection when it is established.
+type ConnBegin struct {
+        // Client is true if this ConnBegin is from client side.
+        Client bool
+}
+
+// IsClient indicates if this is from client side.
+func (s *ConnBegin) IsClient() bool { return s.Client }
+
+func (s *ConnBegin) isConnStats() {}
+
+// ConnEnd contains the stats of a connection when it ends.
+type ConnEnd struct {
+        // Client is true if this ConnEnd is from client side.
+        Client bool
+}
+
+// IsClient indicates if this is from client side.
+func (s *ConnEnd) IsClient() bool { return s.Client }
+
+func (s *ConnEnd) isConnStats() {}