Update go dependencies for e2e tests

This commit is contained in:
Manuel Alejandro de Brito Fontes 2019-06-18 23:43:06 -04:00
parent 5670e3d9de
commit 6140fdd31d
No known key found for this signature in database
GPG key ID: 786136016A8BA02A
5 changed files with 895 additions and 9 deletions

3
go.mod
View file

@ -36,6 +36,7 @@ require (
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
github.com/modern-go/reflect2 v1.0.1 // indirect
github.com/moul/http2curl v1.0.0 // indirect
github.com/moul/pb v0.0.0-20180404114147-54bdd96e6a52
github.com/ncabatoff/go-seq v0.0.0-20180805175032-b08ef85ed833 // indirect
github.com/ncabatoff/process-exporter v0.0.0-20180915144445-bdf24ef23850
github.com/ncabatoff/procfs v0.0.0-20180903163354-e1a38cb53622 // indirect
@ -61,6 +62,8 @@ require (
go.uber.org/atomic v1.4.0 // indirect
go.uber.org/multierr v1.1.0 // indirect
go.uber.org/zap v1.10.0 // indirect
golang.org/x/net v0.0.0-20190311183353-d8887717615a
google.golang.org/grpc v1.19.1
gopkg.in/fsnotify/fsnotify.v1 v1.4.7
gopkg.in/go-playground/assert.v1 v1.2.1 // indirect
gopkg.in/go-playground/pool.v3 v3.1.1

2
go.sum
View file

@ -164,6 +164,8 @@ github.com/modern-go/reflect2 v1.0.1 h1:9f412s+6RmYXLWZSEzVVgPGK7C2PphHj5RJrvfx9
github.com/modern-go/reflect2 v1.0.1/go.mod h1:bx2lNnkwVCuqBIxFjflWJWanXIb3RllmbCylyMrvgv0=
github.com/moul/http2curl v1.0.0 h1:dRMWoAtb+ePxMlLkrCbAqh4TlPHXvoGUSQ323/9Zahs=
github.com/moul/http2curl v1.0.0/go.mod h1:8UbvGypXm98wA/IqH45anm5Y2Z6ep6O31QGOAZ3H0fQ=
github.com/moul/pb v0.0.0-20180404114147-54bdd96e6a52 h1:8zDEa5yAIWYBHSDpPbSgGIBL/SvPSE9/FlB3aQ54d/A=
github.com/moul/pb v0.0.0-20180404114147-54bdd96e6a52/go.mod h1:jE2HT8eoucYyUPBFJMreiVlC3KPHkDMtN8wn+ef7Y64=
github.com/mwitkow/go-conntrack v0.0.0-20161129095857-cc309e4a2223/go.mod h1:qRWi+5nqEBWmkhHvq77mSJWrCKwh8bxhgT7d/eI7P4U=
github.com/ncabatoff/go-seq v0.0.0-20180805175032-b08ef85ed833 h1:t4WWQ9I797y7QUgeEjeXnVb+oYuEDQc6gLvrZJTYo94=
github.com/ncabatoff/go-seq v0.0.0-20180805175032-b08ef85ed833/go.mod h1:0CznHmXSjMEqs5Tezj/w2emQoM41wzYM9KpDKUHPYag=

5
vendor/github.com/moul/pb/grpcbin/go-grpc/export.go generated vendored Normal file
View file

@ -0,0 +1,5 @@
package grpcbin
// this file exports unexported variables
var GRPCBin_serviceDesc = _GRPCBin_serviceDesc

875
vendor/github.com/moul/pb/grpcbin/go-grpc/grpcbin.pb.go generated vendored Normal file
View file

@ -0,0 +1,875 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: grpcbin.proto
/*
Package grpcbin is a generated protocol buffer package.
It is generated from these files:
grpcbin.proto
It has these top-level messages:
HeadersMessage
SpecificErrorRequest
EmptyMessage
DummyMessage
IndexReply
*/
package grpcbin
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import (
context "golang.org/x/net/context"
grpc "google.golang.org/grpc"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
type DummyMessage_Enum int32
const (
DummyMessage_ENUM_0 DummyMessage_Enum = 0
DummyMessage_ENUM_1 DummyMessage_Enum = 1
DummyMessage_ENUM_2 DummyMessage_Enum = 2
)
var DummyMessage_Enum_name = map[int32]string{
0: "ENUM_0",
1: "ENUM_1",
2: "ENUM_2",
}
var DummyMessage_Enum_value = map[string]int32{
"ENUM_0": 0,
"ENUM_1": 1,
"ENUM_2": 2,
}
func (x DummyMessage_Enum) String() string {
return proto.EnumName(DummyMessage_Enum_name, int32(x))
}
func (DummyMessage_Enum) EnumDescriptor() ([]byte, []int) { return fileDescriptor0, []int{3, 0} }
type HeadersMessage struct {
Metadata map[string]*HeadersMessage_Values `protobuf:"bytes,1,rep,name=Metadata" json:"Metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}
func (m *HeadersMessage) Reset() { *m = HeadersMessage{} }
func (m *HeadersMessage) String() string { return proto.CompactTextString(m) }
func (*HeadersMessage) ProtoMessage() {}
func (*HeadersMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
func (m *HeadersMessage) GetMetadata() map[string]*HeadersMessage_Values {
if m != nil {
return m.Metadata
}
return nil
}
type HeadersMessage_Values struct {
Values []string `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}
func (m *HeadersMessage_Values) Reset() { *m = HeadersMessage_Values{} }
func (m *HeadersMessage_Values) String() string { return proto.CompactTextString(m) }
func (*HeadersMessage_Values) ProtoMessage() {}
func (*HeadersMessage_Values) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0, 0} }
func (m *HeadersMessage_Values) GetValues() []string {
if m != nil {
return m.Values
}
return nil
}
type SpecificErrorRequest struct {
Code uint32 `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
Reason string `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
}
func (m *SpecificErrorRequest) Reset() { *m = SpecificErrorRequest{} }
func (m *SpecificErrorRequest) String() string { return proto.CompactTextString(m) }
func (*SpecificErrorRequest) ProtoMessage() {}
func (*SpecificErrorRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{1} }
func (m *SpecificErrorRequest) GetCode() uint32 {
if m != nil {
return m.Code
}
return 0
}
func (m *SpecificErrorRequest) GetReason() string {
if m != nil {
return m.Reason
}
return ""
}
type EmptyMessage struct {
}
func (m *EmptyMessage) Reset() { *m = EmptyMessage{} }
func (m *EmptyMessage) String() string { return proto.CompactTextString(m) }
func (*EmptyMessage) ProtoMessage() {}
func (*EmptyMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{2} }
type DummyMessage struct {
FString string `protobuf:"bytes,1,opt,name=f_string,json=fString" json:"f_string,omitempty"`
FStrings []string `protobuf:"bytes,2,rep,name=f_strings,json=fStrings" json:"f_strings,omitempty"`
FInt32 int32 `protobuf:"varint,3,opt,name=f_int32,json=fInt32" json:"f_int32,omitempty"`
FInt32S []int32 `protobuf:"varint,4,rep,packed,name=f_int32s,json=fInt32s" json:"f_int32s,omitempty"`
FEnum DummyMessage_Enum `protobuf:"varint,5,opt,name=f_enum,json=fEnum,enum=grpcbin.DummyMessage_Enum" json:"f_enum,omitempty"`
FEnums []DummyMessage_Enum `protobuf:"varint,6,rep,packed,name=f_enums,json=fEnums,enum=grpcbin.DummyMessage_Enum" json:"f_enums,omitempty"`
FSub *DummyMessage_Sub `protobuf:"bytes,7,opt,name=f_sub,json=fSub" json:"f_sub,omitempty"`
FSubs []*DummyMessage_Sub `protobuf:"bytes,8,rep,name=f_subs,json=fSubs" json:"f_subs,omitempty"`
FBool bool `protobuf:"varint,9,opt,name=f_bool,json=fBool" json:"f_bool,omitempty"`
FBools []bool `protobuf:"varint,10,rep,packed,name=f_bools,json=fBools" json:"f_bools,omitempty"`
FInt64 int64 `protobuf:"varint,11,opt,name=f_int64,json=fInt64" json:"f_int64,omitempty"`
FInt64S []int64 `protobuf:"varint,12,rep,packed,name=f_int64s,json=fInt64s" json:"f_int64s,omitempty"`
FBytes []byte `protobuf:"bytes,13,opt,name=f_bytes,json=fBytes,proto3" json:"f_bytes,omitempty"`
FBytess [][]byte `protobuf:"bytes,14,rep,name=f_bytess,json=fBytess,proto3" json:"f_bytess,omitempty"`
FFloat float32 `protobuf:"fixed32,15,opt,name=f_float,json=fFloat" json:"f_float,omitempty"`
FFloats []float32 `protobuf:"fixed32,16,rep,packed,name=f_floats,json=fFloats" json:"f_floats,omitempty"`
}
func (m *DummyMessage) Reset() { *m = DummyMessage{} }
func (m *DummyMessage) String() string { return proto.CompactTextString(m) }
func (*DummyMessage) ProtoMessage() {}
func (*DummyMessage) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3} }
func (m *DummyMessage) GetFString() string {
if m != nil {
return m.FString
}
return ""
}
func (m *DummyMessage) GetFStrings() []string {
if m != nil {
return m.FStrings
}
return nil
}
func (m *DummyMessage) GetFInt32() int32 {
if m != nil {
return m.FInt32
}
return 0
}
func (m *DummyMessage) GetFInt32S() []int32 {
if m != nil {
return m.FInt32S
}
return nil
}
func (m *DummyMessage) GetFEnum() DummyMessage_Enum {
if m != nil {
return m.FEnum
}
return DummyMessage_ENUM_0
}
func (m *DummyMessage) GetFEnums() []DummyMessage_Enum {
if m != nil {
return m.FEnums
}
return nil
}
func (m *DummyMessage) GetFSub() *DummyMessage_Sub {
if m != nil {
return m.FSub
}
return nil
}
func (m *DummyMessage) GetFSubs() []*DummyMessage_Sub {
if m != nil {
return m.FSubs
}
return nil
}
func (m *DummyMessage) GetFBool() bool {
if m != nil {
return m.FBool
}
return false
}
func (m *DummyMessage) GetFBools() []bool {
if m != nil {
return m.FBools
}
return nil
}
func (m *DummyMessage) GetFInt64() int64 {
if m != nil {
return m.FInt64
}
return 0
}
func (m *DummyMessage) GetFInt64S() []int64 {
if m != nil {
return m.FInt64S
}
return nil
}
func (m *DummyMessage) GetFBytes() []byte {
if m != nil {
return m.FBytes
}
return nil
}
func (m *DummyMessage) GetFBytess() [][]byte {
if m != nil {
return m.FBytess
}
return nil
}
func (m *DummyMessage) GetFFloat() float32 {
if m != nil {
return m.FFloat
}
return 0
}
func (m *DummyMessage) GetFFloats() []float32 {
if m != nil {
return m.FFloats
}
return nil
}
type DummyMessage_Sub struct {
FString string `protobuf:"bytes,1,opt,name=f_string,json=fString" json:"f_string,omitempty"`
}
func (m *DummyMessage_Sub) Reset() { *m = DummyMessage_Sub{} }
func (m *DummyMessage_Sub) String() string { return proto.CompactTextString(m) }
func (*DummyMessage_Sub) ProtoMessage() {}
func (*DummyMessage_Sub) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{3, 0} }
func (m *DummyMessage_Sub) GetFString() string {
if m != nil {
return m.FString
}
return ""
}
type IndexReply struct {
Description string `protobuf:"bytes,1,opt,name=description" json:"description,omitempty"`
Endpoints []*IndexReply_Endpoint `protobuf:"bytes,2,rep,name=endpoints" json:"endpoints,omitempty"`
}
func (m *IndexReply) Reset() { *m = IndexReply{} }
func (m *IndexReply) String() string { return proto.CompactTextString(m) }
func (*IndexReply) ProtoMessage() {}
func (*IndexReply) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4} }
func (m *IndexReply) GetDescription() string {
if m != nil {
return m.Description
}
return ""
}
func (m *IndexReply) GetEndpoints() []*IndexReply_Endpoint {
if m != nil {
return m.Endpoints
}
return nil
}
type IndexReply_Endpoint struct {
Path string `protobuf:"bytes,1,opt,name=path" json:"path,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
}
func (m *IndexReply_Endpoint) Reset() { *m = IndexReply_Endpoint{} }
func (m *IndexReply_Endpoint) String() string { return proto.CompactTextString(m) }
func (*IndexReply_Endpoint) ProtoMessage() {}
func (*IndexReply_Endpoint) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{4, 0} }
func (m *IndexReply_Endpoint) GetPath() string {
if m != nil {
return m.Path
}
return ""
}
func (m *IndexReply_Endpoint) GetDescription() string {
if m != nil {
return m.Description
}
return ""
}
func init() {
proto.RegisterType((*HeadersMessage)(nil), "grpcbin.HeadersMessage")
proto.RegisterType((*HeadersMessage_Values)(nil), "grpcbin.HeadersMessage.Values")
proto.RegisterType((*SpecificErrorRequest)(nil), "grpcbin.SpecificErrorRequest")
proto.RegisterType((*EmptyMessage)(nil), "grpcbin.EmptyMessage")
proto.RegisterType((*DummyMessage)(nil), "grpcbin.DummyMessage")
proto.RegisterType((*DummyMessage_Sub)(nil), "grpcbin.DummyMessage.Sub")
proto.RegisterType((*IndexReply)(nil), "grpcbin.IndexReply")
proto.RegisterType((*IndexReply_Endpoint)(nil), "grpcbin.IndexReply.Endpoint")
proto.RegisterEnum("grpcbin.DummyMessage_Enum", DummyMessage_Enum_name, DummyMessage_Enum_value)
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// Client API for GRPCBin service
type GRPCBinClient interface {
// This endpoint
Index(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*IndexReply, error)
// Unary endpoint that takes no argument and replies an empty message.
Empty(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*EmptyMessage, error)
// Unary endpoint that replies a received DummyMessage
DummyUnary(ctx context.Context, in *DummyMessage, opts ...grpc.CallOption) (*DummyMessage, error)
// Stream endpoint that sends back 10 times the received DummyMessage
DummyServerStream(ctx context.Context, in *DummyMessage, opts ...grpc.CallOption) (GRPCBin_DummyServerStreamClient, error)
// Stream endpoint that receives 10 DummyMessages and replies with the last received one
DummyClientStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBin_DummyClientStreamClient, error)
// Stream endpoint that sends back a received DummyMessage indefinitely (chat mode)
DummyBidirectionalStreamStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBin_DummyBidirectionalStreamStreamClient, error)
// Unary endpoint that raises a specified (by code) gRPC error
SpecificError(ctx context.Context, in *SpecificErrorRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
// Unary endpoint that raises a random gRPC error
RandomError(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*EmptyMessage, error)
// Unary endpoint that returns headers
HeadersUnary(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*HeadersMessage, error)
// Unary endpoint that returns no respnose
NoResponseUnary(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*EmptyMessage, error)
}
type gRPCBinClient struct {
cc *grpc.ClientConn
}
func NewGRPCBinClient(cc *grpc.ClientConn) GRPCBinClient {
return &gRPCBinClient{cc}
}
func (c *gRPCBinClient) Index(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*IndexReply, error) {
out := new(IndexReply)
err := grpc.Invoke(ctx, "/grpcbin.GRPCBin/Index", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gRPCBinClient) Empty(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*EmptyMessage, error) {
out := new(EmptyMessage)
err := grpc.Invoke(ctx, "/grpcbin.GRPCBin/Empty", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gRPCBinClient) DummyUnary(ctx context.Context, in *DummyMessage, opts ...grpc.CallOption) (*DummyMessage, error) {
out := new(DummyMessage)
err := grpc.Invoke(ctx, "/grpcbin.GRPCBin/DummyUnary", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gRPCBinClient) DummyServerStream(ctx context.Context, in *DummyMessage, opts ...grpc.CallOption) (GRPCBin_DummyServerStreamClient, error) {
stream, err := grpc.NewClientStream(ctx, &_GRPCBin_serviceDesc.Streams[0], c.cc, "/grpcbin.GRPCBin/DummyServerStream", opts...)
if err != nil {
return nil, err
}
x := &gRPCBinDummyServerStreamClient{stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
return x, nil
}
type GRPCBin_DummyServerStreamClient interface {
Recv() (*DummyMessage, error)
grpc.ClientStream
}
type gRPCBinDummyServerStreamClient struct {
grpc.ClientStream
}
func (x *gRPCBinDummyServerStreamClient) Recv() (*DummyMessage, error) {
m := new(DummyMessage)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *gRPCBinClient) DummyClientStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBin_DummyClientStreamClient, error) {
stream, err := grpc.NewClientStream(ctx, &_GRPCBin_serviceDesc.Streams[1], c.cc, "/grpcbin.GRPCBin/DummyClientStream", opts...)
if err != nil {
return nil, err
}
x := &gRPCBinDummyClientStreamClient{stream}
return x, nil
}
type GRPCBin_DummyClientStreamClient interface {
Send(*DummyMessage) error
CloseAndRecv() (*DummyMessage, error)
grpc.ClientStream
}
type gRPCBinDummyClientStreamClient struct {
grpc.ClientStream
}
func (x *gRPCBinDummyClientStreamClient) Send(m *DummyMessage) error {
return x.ClientStream.SendMsg(m)
}
func (x *gRPCBinDummyClientStreamClient) CloseAndRecv() (*DummyMessage, error) {
if err := x.ClientStream.CloseSend(); err != nil {
return nil, err
}
m := new(DummyMessage)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *gRPCBinClient) DummyBidirectionalStreamStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBin_DummyBidirectionalStreamStreamClient, error) {
stream, err := grpc.NewClientStream(ctx, &_GRPCBin_serviceDesc.Streams[2], c.cc, "/grpcbin.GRPCBin/DummyBidirectionalStreamStream", opts...)
if err != nil {
return nil, err
}
x := &gRPCBinDummyBidirectionalStreamStreamClient{stream}
return x, nil
}
type GRPCBin_DummyBidirectionalStreamStreamClient interface {
Send(*DummyMessage) error
Recv() (*DummyMessage, error)
grpc.ClientStream
}
type gRPCBinDummyBidirectionalStreamStreamClient struct {
grpc.ClientStream
}
func (x *gRPCBinDummyBidirectionalStreamStreamClient) Send(m *DummyMessage) error {
return x.ClientStream.SendMsg(m)
}
func (x *gRPCBinDummyBidirectionalStreamStreamClient) Recv() (*DummyMessage, error) {
m := new(DummyMessage)
if err := x.ClientStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func (c *gRPCBinClient) SpecificError(ctx context.Context, in *SpecificErrorRequest, opts ...grpc.CallOption) (*EmptyMessage, error) {
out := new(EmptyMessage)
err := grpc.Invoke(ctx, "/grpcbin.GRPCBin/SpecificError", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gRPCBinClient) RandomError(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*EmptyMessage, error) {
out := new(EmptyMessage)
err := grpc.Invoke(ctx, "/grpcbin.GRPCBin/RandomError", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gRPCBinClient) HeadersUnary(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*HeadersMessage, error) {
out := new(HeadersMessage)
err := grpc.Invoke(ctx, "/grpcbin.GRPCBin/HeadersUnary", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *gRPCBinClient) NoResponseUnary(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (*EmptyMessage, error) {
out := new(EmptyMessage)
err := grpc.Invoke(ctx, "/grpcbin.GRPCBin/NoResponseUnary", in, out, c.cc, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Server API for GRPCBin service
type GRPCBinServer interface {
// This endpoint
Index(context.Context, *EmptyMessage) (*IndexReply, error)
// Unary endpoint that takes no argument and replies an empty message.
Empty(context.Context, *EmptyMessage) (*EmptyMessage, error)
// Unary endpoint that replies a received DummyMessage
DummyUnary(context.Context, *DummyMessage) (*DummyMessage, error)
// Stream endpoint that sends back 10 times the received DummyMessage
DummyServerStream(*DummyMessage, GRPCBin_DummyServerStreamServer) error
// Stream endpoint that receives 10 DummyMessages and replies with the last received one
DummyClientStream(GRPCBin_DummyClientStreamServer) error
// Stream endpoint that sends back a received DummyMessage indefinitely (chat mode)
DummyBidirectionalStreamStream(GRPCBin_DummyBidirectionalStreamStreamServer) error
// Unary endpoint that raises a specified (by code) gRPC error
SpecificError(context.Context, *SpecificErrorRequest) (*EmptyMessage, error)
// Unary endpoint that raises a random gRPC error
RandomError(context.Context, *EmptyMessage) (*EmptyMessage, error)
// Unary endpoint that returns headers
HeadersUnary(context.Context, *EmptyMessage) (*HeadersMessage, error)
// Unary endpoint that returns no respnose
NoResponseUnary(context.Context, *EmptyMessage) (*EmptyMessage, error)
}
func RegisterGRPCBinServer(s *grpc.Server, srv GRPCBinServer) {
s.RegisterService(&_GRPCBin_serviceDesc, srv)
}
func _GRPCBin_Index_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EmptyMessage)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(GRPCBinServer).Index(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/grpcbin.GRPCBin/Index",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(GRPCBinServer).Index(ctx, req.(*EmptyMessage))
}
return interceptor(ctx, in, info, handler)
}
func _GRPCBin_Empty_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EmptyMessage)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(GRPCBinServer).Empty(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/grpcbin.GRPCBin/Empty",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(GRPCBinServer).Empty(ctx, req.(*EmptyMessage))
}
return interceptor(ctx, in, info, handler)
}
func _GRPCBin_DummyUnary_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DummyMessage)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(GRPCBinServer).DummyUnary(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/grpcbin.GRPCBin/DummyUnary",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(GRPCBinServer).DummyUnary(ctx, req.(*DummyMessage))
}
return interceptor(ctx, in, info, handler)
}
func _GRPCBin_DummyServerStream_Handler(srv interface{}, stream grpc.ServerStream) error {
m := new(DummyMessage)
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(GRPCBinServer).DummyServerStream(m, &gRPCBinDummyServerStreamServer{stream})
}
type GRPCBin_DummyServerStreamServer interface {
Send(*DummyMessage) error
grpc.ServerStream
}
type gRPCBinDummyServerStreamServer struct {
grpc.ServerStream
}
func (x *gRPCBinDummyServerStreamServer) Send(m *DummyMessage) error {
return x.ServerStream.SendMsg(m)
}
func _GRPCBin_DummyClientStream_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(GRPCBinServer).DummyClientStream(&gRPCBinDummyClientStreamServer{stream})
}
type GRPCBin_DummyClientStreamServer interface {
SendAndClose(*DummyMessage) error
Recv() (*DummyMessage, error)
grpc.ServerStream
}
type gRPCBinDummyClientStreamServer struct {
grpc.ServerStream
}
func (x *gRPCBinDummyClientStreamServer) SendAndClose(m *DummyMessage) error {
return x.ServerStream.SendMsg(m)
}
func (x *gRPCBinDummyClientStreamServer) Recv() (*DummyMessage, error) {
m := new(DummyMessage)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func _GRPCBin_DummyBidirectionalStreamStream_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(GRPCBinServer).DummyBidirectionalStreamStream(&gRPCBinDummyBidirectionalStreamStreamServer{stream})
}
type GRPCBin_DummyBidirectionalStreamStreamServer interface {
Send(*DummyMessage) error
Recv() (*DummyMessage, error)
grpc.ServerStream
}
type gRPCBinDummyBidirectionalStreamStreamServer struct {
grpc.ServerStream
}
func (x *gRPCBinDummyBidirectionalStreamStreamServer) Send(m *DummyMessage) error {
return x.ServerStream.SendMsg(m)
}
func (x *gRPCBinDummyBidirectionalStreamStreamServer) Recv() (*DummyMessage, error) {
m := new(DummyMessage)
if err := x.ServerStream.RecvMsg(m); err != nil {
return nil, err
}
return m, nil
}
func _GRPCBin_SpecificError_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SpecificErrorRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(GRPCBinServer).SpecificError(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/grpcbin.GRPCBin/SpecificError",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(GRPCBinServer).SpecificError(ctx, req.(*SpecificErrorRequest))
}
return interceptor(ctx, in, info, handler)
}
func _GRPCBin_RandomError_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EmptyMessage)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(GRPCBinServer).RandomError(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/grpcbin.GRPCBin/RandomError",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(GRPCBinServer).RandomError(ctx, req.(*EmptyMessage))
}
return interceptor(ctx, in, info, handler)
}
func _GRPCBin_HeadersUnary_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EmptyMessage)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(GRPCBinServer).HeadersUnary(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/grpcbin.GRPCBin/HeadersUnary",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(GRPCBinServer).HeadersUnary(ctx, req.(*EmptyMessage))
}
return interceptor(ctx, in, info, handler)
}
func _GRPCBin_NoResponseUnary_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(EmptyMessage)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(GRPCBinServer).NoResponseUnary(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/grpcbin.GRPCBin/NoResponseUnary",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(GRPCBinServer).NoResponseUnary(ctx, req.(*EmptyMessage))
}
return interceptor(ctx, in, info, handler)
}
var _GRPCBin_serviceDesc = grpc.ServiceDesc{
ServiceName: "grpcbin.GRPCBin",
HandlerType: (*GRPCBinServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Index",
Handler: _GRPCBin_Index_Handler,
},
{
MethodName: "Empty",
Handler: _GRPCBin_Empty_Handler,
},
{
MethodName: "DummyUnary",
Handler: _GRPCBin_DummyUnary_Handler,
},
{
MethodName: "SpecificError",
Handler: _GRPCBin_SpecificError_Handler,
},
{
MethodName: "RandomError",
Handler: _GRPCBin_RandomError_Handler,
},
{
MethodName: "HeadersUnary",
Handler: _GRPCBin_HeadersUnary_Handler,
},
{
MethodName: "NoResponseUnary",
Handler: _GRPCBin_NoResponseUnary_Handler,
},
},
Streams: []grpc.StreamDesc{
{
StreamName: "DummyServerStream",
Handler: _GRPCBin_DummyServerStream_Handler,
ServerStreams: true,
},
{
StreamName: "DummyClientStream",
Handler: _GRPCBin_DummyClientStream_Handler,
ClientStreams: true,
},
{
StreamName: "DummyBidirectionalStreamStream",
Handler: _GRPCBin_DummyBidirectionalStreamStream_Handler,
ServerStreams: true,
ClientStreams: true,
},
},
Metadata: "grpcbin.proto",
}
func init() { proto.RegisterFile("grpcbin.proto", fileDescriptor0) }
var fileDescriptor0 = []byte{
// 769 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x55, 0xdd, 0x6e, 0xe3, 0x44,
0x18, 0xcd, 0xc4, 0xb1, 0x9d, 0x7c, 0xf9, 0xd9, 0x30, 0xb0, 0xec, 0x6c, 0x80, 0xd5, 0xc8, 0x12,
0x92, 0xc5, 0x45, 0x94, 0x4d, 0x43, 0x40, 0x2b, 0x90, 0x76, 0xb3, 0x84, 0xd2, 0x8b, 0x56, 0x68,
0x42, 0xb9, 0xe1, 0x22, 0xb2, 0xe3, 0x71, 0xb1, 0x48, 0xc6, 0xc6, 0x63, 0x57, 0xe4, 0x8d, 0xb8,
0xe0, 0x69, 0x78, 0x00, 0x9e, 0x05, 0xcd, 0xd8, 0x71, 0x93, 0x92, 0x14, 0xb5, 0x57, 0xfd, 0xfe,
0xce, 0x39, 0x5f, 0xcf, 0x8c, 0x27, 0xd0, 0xbd, 0x49, 0x93, 0x95, 0x1f, 0x89, 0x61, 0x92, 0xc6,
0x59, 0x8c, 0xed, 0x32, 0x75, 0xfe, 0x46, 0xd0, 0xfb, 0x81, 0x7b, 0x01, 0x4f, 0xe5, 0x25, 0x97,
0xd2, 0xbb, 0xe1, 0xf8, 0x1d, 0x34, 0x2f, 0x79, 0xe6, 0x05, 0x5e, 0xe6, 0x11, 0x44, 0x0d, 0xb7,
0x3d, 0xfe, 0x7c, 0xb8, 0x43, 0x1f, 0x8e, 0x0e, 0x77, 0x73, 0x73, 0x91, 0xa5, 0x5b, 0x56, 0xc1,
0x06, 0x14, 0xac, 0x9f, 0xbd, 0x75, 0xce, 0x25, 0xfe, 0x18, 0xac, 0x5b, 0x1d, 0x69, 0xaa, 0x16,
0x2b, 0xb3, 0xc1, 0x2f, 0xd0, 0x3d, 0x00, 0xe3, 0x3e, 0x18, 0xbf, 0xf1, 0x2d, 0x41, 0x14, 0xb9,
0x2d, 0xa6, 0x42, 0x3c, 0x01, 0x53, 0x0f, 0x93, 0x3a, 0x45, 0x6e, 0x7b, 0xfc, 0xea, 0xd4, 0x12,
0x85, 0x12, 0x2b, 0x86, 0xdf, 0xd4, 0xbf, 0x46, 0xce, 0x0c, 0x3e, 0x5a, 0x24, 0x7c, 0x15, 0x85,
0xd1, 0x6a, 0x9e, 0xa6, 0x71, 0xca, 0xf8, 0xef, 0x39, 0x97, 0x19, 0xc6, 0xd0, 0x58, 0xc5, 0x01,
0xd7, 0x22, 0x5d, 0xa6, 0x63, 0xb5, 0x60, 0xca, 0x3d, 0x19, 0x0b, 0x2d, 0xd3, 0x62, 0x65, 0xe6,
0xf4, 0xa0, 0x33, 0xdf, 0x24, 0xd9, 0xb6, 0x54, 0x71, 0xfe, 0x69, 0x40, 0xe7, 0xbb, 0x7c, 0xb3,
0xd9, 0x15, 0xf0, 0x4b, 0x68, 0x86, 0x4b, 0x99, 0xa5, 0x91, 0xb8, 0x29, 0xb7, 0xb6, 0xc3, 0x85,
0x4e, 0xf1, 0x27, 0xd0, 0xda, 0xb5, 0x24, 0xa9, 0xeb, 0xff, 0xbb, 0x59, 0xf6, 0x24, 0x7e, 0x01,
0x76, 0xb8, 0x8c, 0x44, 0x76, 0x36, 0x26, 0x06, 0x45, 0xae, 0xc9, 0xac, 0xf0, 0x42, 0x65, 0x05,
0xa1, 0x6e, 0x48, 0xd2, 0xa0, 0x86, 0x6b, 0x32, 0xbb, 0xe8, 0x48, 0xfc, 0x1a, 0xac, 0x70, 0xc9,
0x45, 0xbe, 0x21, 0x26, 0x45, 0x6e, 0x6f, 0x3c, 0xa8, 0xbc, 0xd8, 0x5f, 0x69, 0x38, 0x17, 0xf9,
0x86, 0x99, 0xa1, 0xfa, 0x83, 0xcf, 0x94, 0x8c, 0x82, 0x48, 0x62, 0x51, 0xe3, 0x7f, 0x30, 0x96,
0xc6, 0x48, 0x3c, 0x04, 0x33, 0x5c, 0xca, 0xdc, 0x27, 0xb6, 0xb6, 0xfc, 0xe5, 0x71, 0xc8, 0x22,
0xf7, 0x59, 0x23, 0x5c, 0xe4, 0x3e, 0x1e, 0xa9, 0xbd, 0x64, 0xee, 0x4b, 0xd2, 0xd4, 0x17, 0xe5,
0x01, 0x80, 0xa9, 0x00, 0x12, 0x3f, 0x57, 0x08, 0x3f, 0x8e, 0xd7, 0xa4, 0x45, 0x91, 0xdb, 0x64,
0x66, 0x38, 0x8b, 0xe3, 0x75, 0x61, 0x8a, 0x2a, 0x4b, 0x02, 0xd4, 0x70, 0x9b, 0xcc, 0xd2, 0xf5,
0x3b, 0xb7, 0xa6, 0x13, 0xd2, 0xa6, 0xc8, 0x35, 0x0a, 0xb7, 0xa6, 0x93, 0xca, 0xad, 0xe9, 0x44,
0x92, 0x0e, 0x35, 0x5c, 0xa3, 0x70, 0x6b, 0x3a, 0x29, 0x31, 0xfe, 0x36, 0xe3, 0x92, 0x74, 0x29,
0x72, 0x3b, 0x8a, 0x4c, 0x65, 0x05, 0x46, 0x37, 0x24, 0xe9, 0x51, 0xc3, 0xed, 0x30, 0xbb, 0xe8,
0x94, 0x98, 0x70, 0x1d, 0x7b, 0x19, 0x79, 0x46, 0x91, 0x5b, 0x67, 0x56, 0xf8, 0xbd, 0xca, 0x0a,
0x8c, 0x6e, 0x48, 0xd2, 0xa7, 0x86, 0x5b, 0x67, 0x76, 0xd1, 0x91, 0x03, 0x0a, 0x86, 0x32, 0xe1,
0xf4, 0x45, 0x70, 0xbe, 0x80, 0x86, 0x3e, 0x0c, 0x00, 0x6b, 0x7e, 0x75, 0x7d, 0xb9, 0x1c, 0xf5,
0x6b, 0x55, 0xfc, 0xba, 0x8f, 0xaa, 0x78, 0xdc, 0xaf, 0x3b, 0x7f, 0x21, 0x80, 0x0b, 0x11, 0xf0,
0x3f, 0x18, 0x4f, 0xd6, 0x5b, 0x4c, 0xa1, 0x1d, 0x70, 0xb9, 0x4a, 0xa3, 0x24, 0x8b, 0x62, 0x51,
0x12, 0xef, 0x97, 0xf0, 0x1b, 0x68, 0x71, 0x11, 0x24, 0x71, 0x24, 0xb2, 0xe2, 0x96, 0xb5, 0xc7,
0x9f, 0x56, 0xfe, 0xdf, 0x31, 0x0d, 0xe7, 0xe5, 0x10, 0xbb, 0x1b, 0x1f, 0xbc, 0x85, 0xe6, 0xae,
0xac, 0xbe, 0x8a, 0xc4, 0xcb, 0x7e, 0x2d, 0x25, 0x74, 0x7c, 0x5f, 0xbd, 0xfe, 0x1f, 0xf5, 0xf1,
0x9f, 0x26, 0xd8, 0xe7, 0xec, 0xc7, 0xf7, 0xb3, 0x48, 0xe0, 0x2f, 0xc1, 0xd4, 0x7a, 0xf8, 0x79,
0xa5, 0xbf, 0xff, 0xed, 0x0c, 0x3e, 0x3c, 0xb2, 0x96, 0x53, 0xc3, 0x5f, 0x81, 0xa9, 0xc7, 0x4e,
0xc1, 0x8e, 0x97, 0x9d, 0x1a, 0xfe, 0x06, 0x40, 0xdf, 0xaf, 0x6b, 0xe1, 0xa5, 0xfb, 0xe8, 0xfd,
0x4b, 0x37, 0x38, 0x5e, 0x76, 0x6a, 0x78, 0x0e, 0x1f, 0xe8, 0xca, 0x82, 0xa7, 0xb7, 0x3c, 0x5d,
0x64, 0x29, 0xf7, 0x36, 0x8f, 0x25, 0x19, 0xa1, 0x8a, 0xe6, 0xfd, 0x3a, 0xe2, 0x22, 0x7b, 0x1a,
0x8d, 0x8b, 0xf0, 0x4f, 0xf0, 0x4a, 0xd7, 0x66, 0x51, 0x10, 0xa5, 0x7c, 0xa5, 0xbc, 0xf5, 0xd6,
0x05, 0xdb, 0x53, 0x39, 0x47, 0x08, 0x9f, 0x43, 0xf7, 0xe0, 0x05, 0xc4, 0x9f, 0x55, 0xd3, 0xc7,
0x5e, 0xc6, 0xd3, 0x56, 0x7f, 0x0b, 0x6d, 0xe6, 0x89, 0x20, 0xde, 0x14, 0x34, 0x8f, 0x3d, 0xa9,
0xb7, 0xd0, 0x29, 0x5f, 0xeb, 0xfb, 0x67, 0x75, 0x80, 0x7f, 0x71, 0xe2, 0x6d, 0x77, 0x6a, 0xf8,
0x1d, 0x3c, 0xbb, 0x8a, 0x19, 0x97, 0x49, 0x2c, 0x24, 0x7f, 0x90, 0xe4, 0xd4, 0x12, 0xbe, 0xa5,
0x7f, 0xf3, 0xce, 0xfe, 0x0d, 0x00, 0x00, 0xff, 0xff, 0xfe, 0x68, 0x45, 0xaa, 0x04, 0x07, 0x00,
0x00,
}

19
vendor/modules.txt vendored
View file

@ -71,10 +71,10 @@ github.com/gogo/protobuf/protoc-gen-gogo/descriptor
github.com/golang/groupcache/lru
# github.com/golang/protobuf v1.3.1
github.com/golang/protobuf/proto
github.com/golang/protobuf/ptypes/any
github.com/golang/protobuf/ptypes
github.com/golang/protobuf/ptypes/timestamp
github.com/golang/protobuf/ptypes/any
github.com/golang/protobuf/ptypes/duration
github.com/golang/protobuf/ptypes/timestamp
github.com/golang/protobuf/ptypes/wrappers
github.com/golang/protobuf/jsonpb
github.com/golang/protobuf/protoc-gen-go/generator
@ -145,6 +145,8 @@ github.com/modern-go/concurrent
github.com/modern-go/reflect2
# github.com/moul/http2curl v1.0.0
github.com/moul/http2curl
# github.com/moul/pb v0.0.0-20180404114147-54bdd96e6a52
github.com/moul/pb/grpcbin/go-grpc
# github.com/ncabatoff/go-seq v0.0.0-20180805175032-b08ef85ed833
github.com/ncabatoff/go-seq/seq
# github.com/ncabatoff/process-exporter v0.0.0-20180915144445-bdf24ef23850
@ -258,18 +260,18 @@ go.uber.org/zap/internal/exit
# golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2
golang.org/x/crypto/ssh/terminal
# golang.org/x/net v0.0.0-20190311183353-d8887717615a
golang.org/x/net/context
golang.org/x/net/publicsuffix
golang.org/x/net/trace
golang.org/x/net/http2
golang.org/x/net/html/charset
golang.org/x/net/http/httpguts
golang.org/x/net/internal/timeseries
golang.org/x/net/http2/hpack
golang.org/x/net/http/httpguts
golang.org/x/net/idna
golang.org/x/net/context
golang.org/x/net/html
golang.org/x/net/context/ctxhttp
golang.org/x/net/trace
golang.org/x/net/html/atom
golang.org/x/net/internal/timeseries
# golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421
golang.org/x/oauth2
golang.org/x/oauth2/google
@ -360,11 +362,11 @@ google.golang.org/genproto/googleapis/api/httpbody
google.golang.org/genproto/protobuf/field_mask
# google.golang.org/grpc v1.19.1
google.golang.org/grpc
google.golang.org/grpc/credentials
google.golang.org/grpc/balancer
google.golang.org/grpc/balancer/roundrobin
google.golang.org/grpc/codes
google.golang.org/grpc/connectivity
google.golang.org/grpc/credentials
google.golang.org/grpc/encoding
google.golang.org/grpc/encoding/proto
google.golang.org/grpc/grpclog
@ -386,8 +388,8 @@ google.golang.org/grpc/resolver/passthrough
google.golang.org/grpc/stats
google.golang.org/grpc/status
google.golang.org/grpc/tap
google.golang.org/grpc/balancer/base
google.golang.org/grpc/credentials/internal
google.golang.org/grpc/balancer/base
google.golang.org/grpc/binarylog/grpc_binarylog_v1
google.golang.org/grpc/internal/syscall
# gopkg.in/fsnotify.v1 v1.4.7
@ -460,7 +462,6 @@ k8s.io/apimachinery/pkg/util/intstr
k8s.io/apimachinery/pkg/util/sets
k8s.io/apimachinery/pkg/labels
k8s.io/apimachinery/pkg/util/runtime
k8s.io/apimachinery/pkg/util/version
k8s.io/apimachinery/pkg/watch
k8s.io/apimachinery/pkg/util/version
k8s.io/apimachinery/pkg/fields