vendor/github.com/gogo/protobuf/protoc-gen-gogo/testdata/grpc/grpc.pb.go - airflow-on-k8s-operator - Git at Google

 // Code generated by protoc-gen-gogo. DO NOT EDIT.
 // source: grpc/grpc.proto

 package testing // import "github.com/gogo/protobuf/protoc-gen-gogo/testdata/grpc"

 import proto "github.com/gogo/protobuf/proto"
 import fmt "fmt"
 import math "math"

 import context "golang.org/x/net/context"
 import 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.GoGoProtoPackageIsVersion2 // please upgrade the proto package

 type SimpleRequest struct {
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *SimpleRequest) Reset()         { *m = SimpleRequest{} }
 func (m *SimpleRequest) String() string { return proto.CompactTextString(m) }
 func (*SimpleRequest) ProtoMessage()    {}
 func (*SimpleRequest) Descriptor() ([]byte, []int) {
 	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{0}
 }
 func (m *SimpleRequest) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_SimpleRequest.Unmarshal(m, b)
 }
 func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_SimpleRequest.Marshal(b, m, deterministic)
 }
 func (dst *SimpleRequest) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_SimpleRequest.Merge(dst, src)
 }
 func (m *SimpleRequest) XXX_Size() int {
 	return xxx_messageInfo_SimpleRequest.Size(m)
 }
 func (m *SimpleRequest) XXX_DiscardUnknown() {
 	xxx_messageInfo_SimpleRequest.DiscardUnknown(m)
 }

 var xxx_messageInfo_SimpleRequest proto.InternalMessageInfo

 type SimpleResponse struct {
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *SimpleResponse) Reset()         { *m = SimpleResponse{} }
 func (m *SimpleResponse) String() string { return proto.CompactTextString(m) }
 func (*SimpleResponse) ProtoMessage()    {}
 func (*SimpleResponse) Descriptor() ([]byte, []int) {
 	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{1}
 }
 func (m *SimpleResponse) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_SimpleResponse.Unmarshal(m, b)
 }
 func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_SimpleResponse.Marshal(b, m, deterministic)
 }
 func (dst *SimpleResponse) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_SimpleResponse.Merge(dst, src)
 }
 func (m *SimpleResponse) XXX_Size() int {
 	return xxx_messageInfo_SimpleResponse.Size(m)
 }
 func (m *SimpleResponse) XXX_DiscardUnknown() {
 	xxx_messageInfo_SimpleResponse.DiscardUnknown(m)
 }

 var xxx_messageInfo_SimpleResponse proto.InternalMessageInfo

 type StreamMsg struct {
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *StreamMsg) Reset()         { *m = StreamMsg{} }
 func (m *StreamMsg) String() string { return proto.CompactTextString(m) }
 func (*StreamMsg) ProtoMessage()    {}
 func (*StreamMsg) Descriptor() ([]byte, []int) {
 	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{2}
 }
 func (m *StreamMsg) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_StreamMsg.Unmarshal(m, b)
 }
 func (m *StreamMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_StreamMsg.Marshal(b, m, deterministic)
 }
 func (dst *StreamMsg) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_StreamMsg.Merge(dst, src)
 }
 func (m *StreamMsg) XXX_Size() int {
 	return xxx_messageInfo_StreamMsg.Size(m)
 }
 func (m *StreamMsg) XXX_DiscardUnknown() {
 	xxx_messageInfo_StreamMsg.DiscardUnknown(m)
 }

 var xxx_messageInfo_StreamMsg proto.InternalMessageInfo

 type StreamMsg2 struct {
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *StreamMsg2) Reset()         { *m = StreamMsg2{} }
 func (m *StreamMsg2) String() string { return proto.CompactTextString(m) }
 func (*StreamMsg2) ProtoMessage()    {}
 func (*StreamMsg2) Descriptor() ([]byte, []int) {
 	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{3}
 }
 func (m *StreamMsg2) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_StreamMsg2.Unmarshal(m, b)
 }
 func (m *StreamMsg2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_StreamMsg2.Marshal(b, m, deterministic)
 }
 func (dst *StreamMsg2) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_StreamMsg2.Merge(dst, src)
 }
 func (m *StreamMsg2) XXX_Size() int {
 	return xxx_messageInfo_StreamMsg2.Size(m)
 }
 func (m *StreamMsg2) XXX_DiscardUnknown() {
 	xxx_messageInfo_StreamMsg2.DiscardUnknown(m)
 }

 var xxx_messageInfo_StreamMsg2 proto.InternalMessageInfo

 func init() {
 	proto.RegisterType((*SimpleRequest)(nil), "grpc.testing.SimpleRequest")
 	proto.RegisterType((*SimpleResponse)(nil), "grpc.testing.SimpleResponse")
 	proto.RegisterType((*StreamMsg)(nil), "grpc.testing.StreamMsg")
 	proto.RegisterType((*StreamMsg2)(nil), "grpc.testing.StreamMsg2")
 }

 // 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 Test service

 type TestClient interface {
 	UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
 	// This RPC streams from the server only.
 	Downstream(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (Test_DownstreamClient, error)
 	// This RPC streams from the client.
 	Upstream(ctx context.Context, opts ...grpc.CallOption) (Test_UpstreamClient, error)
 	// This one streams in both directions.
 	Bidi(ctx context.Context, opts ...grpc.CallOption) (Test_BidiClient, error)
 }

 type testClient struct {
 	cc *grpc.ClientConn
 }

 func NewTestClient(cc *grpc.ClientConn) TestClient {
 	return &testClient{cc}
 }

 func (c *testClient) UnaryCall(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) {
 	out := new(SimpleResponse)
 	err := c.cc.Invoke(ctx, "/grpc.testing.Test/UnaryCall", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
 	return out, nil
 }

 func (c *testClient) Downstream(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (Test_DownstreamClient, error) {
 	stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[0], "/grpc.testing.Test/Downstream", opts...)
 	if err != nil {
 		return nil, err
 	}
 	x := &testDownstreamClient{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 Test_DownstreamClient interface {
 	Recv() (*StreamMsg, error)
 	grpc.ClientStream
 }

 type testDownstreamClient struct {
 	grpc.ClientStream
 }

 func (x *testDownstreamClient) Recv() (*StreamMsg, error) {
 	m := new(StreamMsg)
 	if err := x.ClientStream.RecvMsg(m); err != nil {
 		return nil, err
 	}
 	return m, nil
 }

 func (c *testClient) Upstream(ctx context.Context, opts ...grpc.CallOption) (Test_UpstreamClient, error) {
 	stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[1], "/grpc.testing.Test/Upstream", opts...)
 	if err != nil {
 		return nil, err
 	}
 	x := &testUpstreamClient{stream}
 	return x, nil
 }

 type Test_UpstreamClient interface {
 	Send(*StreamMsg) error
 	CloseAndRecv() (*SimpleResponse, error)
 	grpc.ClientStream
 }

 type testUpstreamClient struct {
 	grpc.ClientStream
 }

 func (x *testUpstreamClient) Send(m *StreamMsg) error {
 	return x.ClientStream.SendMsg(m)
 }

 func (x *testUpstreamClient) CloseAndRecv() (*SimpleResponse, error) {
 	if err := x.ClientStream.CloseSend(); err != nil {
 		return nil, err
 	}
 	m := new(SimpleResponse)
 	if err := x.ClientStream.RecvMsg(m); err != nil {
 		return nil, err
 	}
 	return m, nil
 }

 func (c *testClient) Bidi(ctx context.Context, opts ...grpc.CallOption) (Test_BidiClient, error) {
 	stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[2], "/grpc.testing.Test/Bidi", opts...)
 	if err != nil {
 		return nil, err
 	}
 	x := &testBidiClient{stream}
 	return x, nil
 }

 type Test_BidiClient interface {
 	Send(*StreamMsg) error
 	Recv() (*StreamMsg2, error)
 	grpc.ClientStream
 }

 type testBidiClient struct {
 	grpc.ClientStream
 }

 func (x *testBidiClient) Send(m *StreamMsg) error {
 	return x.ClientStream.SendMsg(m)
 }

 func (x *testBidiClient) Recv() (*StreamMsg2, error) {
 	m := new(StreamMsg2)
 	if err := x.ClientStream.RecvMsg(m); err != nil {
 		return nil, err
 	}
 	return m, nil
 }

 // Server API for Test service

 type TestServer interface {
 	UnaryCall(context.Context, *SimpleRequest) (*SimpleResponse, error)
 	// This RPC streams from the server only.
 	Downstream(*SimpleRequest, Test_DownstreamServer) error
 	// This RPC streams from the client.
 	Upstream(Test_UpstreamServer) error
 	// This one streams in both directions.
 	Bidi(Test_BidiServer) error
 }

 func RegisterTestServer(s *grpc.Server, srv TestServer) {
 	s.RegisterService(&_Test_serviceDesc, srv)
 }

 func _Test_UnaryCall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(SimpleRequest)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
 	if interceptor == nil {
 		return srv.(TestServer).UnaryCall(ctx, in)
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
 		FullMethod: "/grpc.testing.Test/UnaryCall",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(TestServer).UnaryCall(ctx, req.(*SimpleRequest))
 	}
 	return interceptor(ctx, in, info, handler)
 }

 func _Test_Downstream_Handler(srv interface{}, stream grpc.ServerStream) error {
 	m := new(SimpleRequest)
 	if err := stream.RecvMsg(m); err != nil {
 		return err
 	}
 	return srv.(TestServer).Downstream(m, &testDownstreamServer{stream})
 }

 type Test_DownstreamServer interface {
 	Send(*StreamMsg) error
 	grpc.ServerStream
 }

 type testDownstreamServer struct {
 	grpc.ServerStream
 }

 func (x *testDownstreamServer) Send(m *StreamMsg) error {
 	return x.ServerStream.SendMsg(m)
 }

 func _Test_Upstream_Handler(srv interface{}, stream grpc.ServerStream) error {
 	return srv.(TestServer).Upstream(&testUpstreamServer{stream})
 }

 type Test_UpstreamServer interface {
 	SendAndClose(*SimpleResponse) error
 	Recv() (*StreamMsg, error)
 	grpc.ServerStream
 }

 type testUpstreamServer struct {
 	grpc.ServerStream
 }

 func (x *testUpstreamServer) SendAndClose(m *SimpleResponse) error {
 	return x.ServerStream.SendMsg(m)
 }

 func (x *testUpstreamServer) Recv() (*StreamMsg, error) {
 	m := new(StreamMsg)
 	if err := x.ServerStream.RecvMsg(m); err != nil {
 		return nil, err
 	}
 	return m, nil
 }

 func _Test_Bidi_Handler(srv interface{}, stream grpc.ServerStream) error {
 	return srv.(TestServer).Bidi(&testBidiServer{stream})
 }

 type Test_BidiServer interface {
 	Send(*StreamMsg2) error
 	Recv() (*StreamMsg, error)
 	grpc.ServerStream
 }

 type testBidiServer struct {
 	grpc.ServerStream
 }

 func (x *testBidiServer) Send(m *StreamMsg2) error {
 	return x.ServerStream.SendMsg(m)
 }

 func (x *testBidiServer) Recv() (*StreamMsg, error) {
 	m := new(StreamMsg)
 	if err := x.ServerStream.RecvMsg(m); err != nil {
 		return nil, err
 	}
 	return m, nil
 }

 var _Test_serviceDesc = grpc.ServiceDesc{
 	ServiceName: "grpc.testing.Test",
 	HandlerType: (*TestServer)(nil),
 	Methods: []grpc.MethodDesc{
 		{
 			MethodName: "UnaryCall",
 			Handler:    _Test_UnaryCall_Handler,
 		},
 	},
 	Streams: []grpc.StreamDesc{
 		{
 			StreamName:    "Downstream",
 			Handler:       _Test_Downstream_Handler,
 			ServerStreams: true,
 		},
 		{
 			StreamName:    "Upstream",
 			Handler:       _Test_Upstream_Handler,
 			ClientStreams: true,
 		},
 		{
 			StreamName:    "Bidi",
 			Handler:       _Test_Bidi_Handler,
 			ServerStreams: true,
 			ClientStreams: true,
 		},
 	},
 	Metadata: "grpc/grpc.proto",
 }

 func init() { proto.RegisterFile("grpc/grpc.proto", fileDescriptor_grpc_9f03674ccb9f2c2b) }

 var fileDescriptor_grpc_9f03674ccb9f2c2b = []byte{
 	// 241 bytes of a gzipped FileDescriptorProto
 	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x4f, 0x2f, 0x2a, 0x48,
 	0xd6, 0x07, 0x11, 0x7a, 0x05, 0x45, 0xf9, 0x25, 0xf9, 0x42, 0x3c, 0x60, 0x76, 0x49, 0x6a, 0x71,
 	0x49, 0x66, 0x5e, 0xba, 0x12, 0x3f, 0x17, 0x6f, 0x70, 0x66, 0x6e, 0x41, 0x4e, 0x6a, 0x50, 0x6a,
 	0x61, 0x69, 0x6a, 0x71, 0x89, 0x92, 0x00, 0x17, 0x1f, 0x4c, 0xa0, 0xb8, 0x20, 0x3f, 0xaf, 0x38,
 	0x55, 0x89, 0x9b, 0x8b, 0x33, 0xb8, 0xa4, 0x28, 0x35, 0x31, 0xd7, 0xb7, 0x38, 0x5d, 0x89, 0x87,
 	0x8b, 0x0b, 0xce, 0x31, 0x32, 0x9a, 0xc1, 0xc4, 0xc5, 0x12, 0x92, 0x5a, 0x5c, 0x22, 0xe4, 0xc6,
 	0xc5, 0x19, 0x9a, 0x97, 0x58, 0x54, 0xe9, 0x9c, 0x98, 0x93, 0x23, 0x24, 0xad, 0x87, 0x6c, 0x85,
 	0x1e, 0x8a, 0xf9, 0x52, 0x32, 0xd8, 0x25, 0x21, 0x76, 0x09, 0xb9, 0x70, 0x71, 0xb9, 0xe4, 0x97,
 	0xe7, 0x15, 0x83, 0xad, 0xc0, 0x6f, 0x90, 0x38, 0x9a, 0x24, 0xcc, 0x55, 0x06, 0x8c, 0x42, 0xce,
 	0x5c, 0x1c, 0xa1, 0x05, 0x50, 0x33, 0x70, 0x29, 0xc3, 0xef, 0x10, 0x0d, 0x46, 0x21, 0x5b, 0x2e,
 	0x16, 0xa7, 0xcc, 0x94, 0x4c, 0xdc, 0x06, 0x48, 0xe0, 0x90, 0x30, 0xd2, 0x60, 0x34, 0x60, 0x74,
 	0x72, 0x88, 0xb2, 0x4b, 0xcf, 0x2c, 0xc9, 0x28, 0x4d, 0xd2, 0x4b, 0xce, 0xcf, 0xd5, 0x4f, 0xcf,
 	0x4f, 0xcf, 0xd7, 0x07, 0x87, 0x7f, 0x52, 0x69, 0x1a, 0x84, 0x91, 0xac, 0x9b, 0x9e, 0x9a, 0xa7,
 	0x0b, 0x96, 0x00, 0x19, 0x91, 0x92, 0x58, 0x92, 0x08, 0x8e, 0x26, 0x6b, 0xa8, 0x81, 0x49, 0x6c,
 	0x60, 0x65, 0xc6, 0x80, 0x00, 0x00, 0x00, 0xff, 0xff, 0x16, 0x54, 0x6e, 0x1b, 0xc2, 0x01, 0x00,
 	0x00,
 }
	// Code generated by protoc-gen-gogo. DO NOT EDIT.
	// source: grpc/grpc.proto

	package testing // import "github.com/gogo/protobuf/protoc-gen-gogo/testdata/grpc"

	import proto "github.com/gogo/protobuf/proto"
	import fmt "fmt"
	import math "math"

	import context "golang.org/x/net/context"
	import 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.GoGoProtoPackageIsVersion2 // please upgrade the proto package

	type SimpleRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m SimpleRequest) Reset() { m = SimpleRequest{} }
	func (m *SimpleRequest) String() string { return proto.CompactTextString(m) }
	func (*SimpleRequest) ProtoMessage() {}
	func (*SimpleRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{0}
	}
	func (m *SimpleRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SimpleRequest.Unmarshal(m, b)
	}
	func (m *SimpleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SimpleRequest.Marshal(b, m, deterministic)
	}
	func (dst *SimpleRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SimpleRequest.Merge(dst, src)
	}
	func (m *SimpleRequest) XXX_Size() int {
	return xxx_messageInfo_SimpleRequest.Size(m)
	}
	func (m *SimpleRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_SimpleRequest.DiscardUnknown(m)
	}

	var xxx_messageInfo_SimpleRequest proto.InternalMessageInfo

	type SimpleResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m SimpleResponse) Reset() { m = SimpleResponse{} }
	func (m *SimpleResponse) String() string { return proto.CompactTextString(m) }
	func (*SimpleResponse) ProtoMessage() {}
	func (*SimpleResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{1}
	}
	func (m *SimpleResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SimpleResponse.Unmarshal(m, b)
	}
	func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SimpleResponse.Marshal(b, m, deterministic)
	}
	func (dst *SimpleResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SimpleResponse.Merge(dst, src)
	}
	func (m *SimpleResponse) XXX_Size() int {
	return xxx_messageInfo_SimpleResponse.Size(m)
	}
	func (m *SimpleResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_SimpleResponse.DiscardUnknown(m)
	}

	var xxx_messageInfo_SimpleResponse proto.InternalMessageInfo

	type StreamMsg struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m StreamMsg) Reset() { m = StreamMsg{} }
	func (m *StreamMsg) String() string { return proto.CompactTextString(m) }
	func (*StreamMsg) ProtoMessage() {}
	func (*StreamMsg) Descriptor() ([]byte, []int) {
	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{2}
	}
	func (m *StreamMsg) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_StreamMsg.Unmarshal(m, b)
	}
	func (m *StreamMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_StreamMsg.Marshal(b, m, deterministic)
	}
	func (dst *StreamMsg) XXX_Merge(src proto.Message) {
	xxx_messageInfo_StreamMsg.Merge(dst, src)
	}
	func (m *StreamMsg) XXX_Size() int {
	return xxx_messageInfo_StreamMsg.Size(m)
	}
	func (m *StreamMsg) XXX_DiscardUnknown() {
	xxx_messageInfo_StreamMsg.DiscardUnknown(m)
	}

	var xxx_messageInfo_StreamMsg proto.InternalMessageInfo

	type StreamMsg2 struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m StreamMsg2) Reset() { m = StreamMsg2{} }
	func (m *StreamMsg2) String() string { return proto.CompactTextString(m) }
	func (*StreamMsg2) ProtoMessage() {}
	func (*StreamMsg2) Descriptor() ([]byte, []int) {
	return fileDescriptor_grpc_9f03674ccb9f2c2b, []int{3}
	}
	func (m *StreamMsg2) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_StreamMsg2.Unmarshal(m, b)
	}
	func (m *StreamMsg2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_StreamMsg2.Marshal(b, m, deterministic)
	}
	func (dst *StreamMsg2) XXX_Merge(src proto.Message) {
	xxx_messageInfo_StreamMsg2.Merge(dst, src)
	}
	func (m *StreamMsg2) XXX_Size() int {
	return xxx_messageInfo_StreamMsg2.Size(m)
	}
	func (m *StreamMsg2) XXX_DiscardUnknown() {
	xxx_messageInfo_StreamMsg2.DiscardUnknown(m)
	}

	var xxx_messageInfo_StreamMsg2 proto.InternalMessageInfo

	func init() {
	proto.RegisterType((*SimpleRequest)(nil), "grpc.testing.SimpleRequest")
	proto.RegisterType((*SimpleResponse)(nil), "grpc.testing.SimpleResponse")
	proto.RegisterType((*StreamMsg)(nil), "grpc.testing.StreamMsg")
	proto.RegisterType((*StreamMsg2)(nil), "grpc.testing.StreamMsg2")
	}

	// 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 Test service

	type TestClient interface {
	UnaryCall(ctx context.Context, in SimpleRequest, opts ...grpc.CallOption) (SimpleResponse, error)
	// This RPC streams from the server only.
	Downstream(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (Test_DownstreamClient, error)
	// This RPC streams from the client.
	Upstream(ctx context.Context, opts ...grpc.CallOption) (Test_UpstreamClient, error)
	// This one streams in both directions.
	Bidi(ctx context.Context, opts ...grpc.CallOption) (Test_BidiClient, error)
	}

	type testClient struct {
	cc *grpc.ClientConn
	}

	func NewTestClient(cc *grpc.ClientConn) TestClient {
	return &testClient{cc}
	}

	func (c testClient) UnaryCall(ctx context.Context, in SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error) {
	out := new(SimpleResponse)
	err := c.cc.Invoke(ctx, "/grpc.testing.Test/UnaryCall", in, out, opts...)
	if err != nil {
	return nil, err
	}
	return out, nil
	}

	func (c testClient) Downstream(ctx context.Context, in SimpleRequest, opts ...grpc.CallOption) (Test_DownstreamClient, error) {
	stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[0], "/grpc.testing.Test/Downstream", opts...)
	if err != nil {
	return nil, err
	}
	x := &testDownstreamClient{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 Test_DownstreamClient interface {
	Recv() (*StreamMsg, error)
	grpc.ClientStream
	}

	type testDownstreamClient struct {
	grpc.ClientStream
	}

	func (x testDownstreamClient) Recv() (StreamMsg, error) {
	m := new(StreamMsg)
	if err := x.ClientStream.RecvMsg(m); err != nil {
	return nil, err
	}
	return m, nil
	}

	func (c *testClient) Upstream(ctx context.Context, opts ...grpc.CallOption) (Test_UpstreamClient, error) {
	stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[1], "/grpc.testing.Test/Upstream", opts...)
	if err != nil {
	return nil, err
	}
	x := &testUpstreamClient{stream}
	return x, nil
	}

	type Test_UpstreamClient interface {
	Send(*StreamMsg) error
	CloseAndRecv() (*SimpleResponse, error)
	grpc.ClientStream
	}

	type testUpstreamClient struct {
	grpc.ClientStream
	}

	func (x testUpstreamClient) Send(m StreamMsg) error {
	return x.ClientStream.SendMsg(m)
	}

	func (x testUpstreamClient) CloseAndRecv() (SimpleResponse, error) {
	if err := x.ClientStream.CloseSend(); err != nil {
	return nil, err
	}
	m := new(SimpleResponse)
	if err := x.ClientStream.RecvMsg(m); err != nil {
	return nil, err
	}
	return m, nil
	}

	func (c *testClient) Bidi(ctx context.Context, opts ...grpc.CallOption) (Test_BidiClient, error) {
	stream, err := c.cc.NewStream(ctx, &_Test_serviceDesc.Streams[2], "/grpc.testing.Test/Bidi", opts...)
	if err != nil {
	return nil, err
	}
	x := &testBidiClient{stream}
	return x, nil
	}

	type Test_BidiClient interface {
	Send(*StreamMsg) error
	Recv() (*StreamMsg2, error)
	grpc.ClientStream
	}

	type testBidiClient struct {
	grpc.ClientStream
	}

	func (x testBidiClient) Send(m StreamMsg) error {
	return x.ClientStream.SendMsg(m)
	}

	func (x testBidiClient) Recv() (StreamMsg2, error) {
	m := new(StreamMsg2)
	if err := x.ClientStream.RecvMsg(m); err != nil {
	return nil, err
	}
	return m, nil
	}

	// Server API for Test service

	type TestServer interface {
	UnaryCall(context.Context, SimpleRequest) (SimpleResponse, error)
	// This RPC streams from the server only.
	Downstream(*SimpleRequest, Test_DownstreamServer) error
	// This RPC streams from the client.
	Upstream(Test_UpstreamServer) error
	// This one streams in both directions.
	Bidi(Test_BidiServer) error
	}

	func RegisterTestServer(s *grpc.Server, srv TestServer) {
	s.RegisterService(&_Test_serviceDesc, srv)
	}

	func _Test_UnaryCall_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SimpleRequest)
	if err := dec(in); err != nil {
	return nil, err
	}
	if interceptor == nil {
	return srv.(TestServer).UnaryCall(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
	Server: srv,
	FullMethod: "/grpc.testing.Test/UnaryCall",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
	return srv.(TestServer).UnaryCall(ctx, req.(*SimpleRequest))
	}
	return interceptor(ctx, in, info, handler)
	}

	func _Test_Downstream_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(SimpleRequest)
	if err := stream.RecvMsg(m); err != nil {
	return err
	}
	return srv.(TestServer).Downstream(m, &testDownstreamServer{stream})
	}

	type Test_DownstreamServer interface {
	Send(*StreamMsg) error
	grpc.ServerStream
	}

	type testDownstreamServer struct {
	grpc.ServerStream
	}

	func (x testDownstreamServer) Send(m StreamMsg) error {
	return x.ServerStream.SendMsg(m)
	}

	func _Test_Upstream_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(TestServer).Upstream(&testUpstreamServer{stream})
	}

	type Test_UpstreamServer interface {
	SendAndClose(*SimpleResponse) error
	Recv() (*StreamMsg, error)
	grpc.ServerStream
	}

	type testUpstreamServer struct {
	grpc.ServerStream
	}

	func (x testUpstreamServer) SendAndClose(m SimpleResponse) error {
	return x.ServerStream.SendMsg(m)
	}

	func (x testUpstreamServer) Recv() (StreamMsg, error) {
	m := new(StreamMsg)
	if err := x.ServerStream.RecvMsg(m); err != nil {
	return nil, err
	}
	return m, nil
	}

	func _Test_Bidi_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(TestServer).Bidi(&testBidiServer{stream})
	}

	type Test_BidiServer interface {
	Send(*StreamMsg2) error
	Recv() (*StreamMsg, error)
	grpc.ServerStream
	}

	type testBidiServer struct {
	grpc.ServerStream
	}

	func (x testBidiServer) Send(m StreamMsg2) error {
	return x.ServerStream.SendMsg(m)
	}

	func (x testBidiServer) Recv() (StreamMsg, error) {
	m := new(StreamMsg)
	if err := x.ServerStream.RecvMsg(m); err != nil {
	return nil, err
	}
	return m, nil
	}

	var _Test_serviceDesc = grpc.ServiceDesc{
	ServiceName: "grpc.testing.Test",
	HandlerType: (*TestServer)(nil),
	Methods: []grpc.MethodDesc{
	{
	MethodName: "UnaryCall",
	Handler: _Test_UnaryCall_Handler,
	},
	},
	Streams: []grpc.StreamDesc{
	{
	StreamName: "Downstream",
	Handler: _Test_Downstream_Handler,
	ServerStreams: true,
	},
	{
	StreamName: "Upstream",
	Handler: _Test_Upstream_Handler,
	ClientStreams: true,
	},
	{
	StreamName: "Bidi",
	Handler: _Test_Bidi_Handler,
	ServerStreams: true,
	ClientStreams: true,
	},
	},
	Metadata: "grpc/grpc.proto",
	}

	func init() { proto.RegisterFile("grpc/grpc.proto", fileDescriptor_grpc_9f03674ccb9f2c2b) }

	var fileDescriptor_grpc_9f03674ccb9f2c2b = []byte{
	// 241 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x4f, 0x2f, 0x2a, 0x48,
	0xd6, 0x07, 0x11, 0x7a, 0x05, 0x45, 0xf9, 0x25, 0xf9, 0x42, 0x3c, 0x60, 0x76, 0x49, 0x6a, 0x71,
	0x49, 0x66, 0x5e, 0xba, 0x12, 0x3f, 0x17, 0x6f, 0x70, 0x66, 0x6e, 0x41, 0x4e, 0x6a, 0x50, 0x6a,
	0x61, 0x69, 0x6a, 0x71, 0x89, 0x92, 0x00, 0x17, 0x1f, 0x4c, 0xa0, 0xb8, 0x20, 0x3f, 0xaf, 0x38,
	0x55, 0x89, 0x9b, 0x8b, 0x33, 0xb8, 0xa4, 0x28, 0x35, 0x31, 0xd7, 0xb7, 0x38, 0x5d, 0x89, 0x87,
	0x8b, 0x0b, 0xce, 0x31, 0x32, 0x9a, 0xc1, 0xc4, 0xc5, 0x12, 0x92, 0x5a, 0x5c, 0x22, 0xe4, 0xc6,
	0xc5, 0x19, 0x9a, 0x97, 0x58, 0x54, 0xe9, 0x9c, 0x98, 0x93, 0x23, 0x24, 0xad, 0x87, 0x6c, 0x85,
	0x1e, 0x8a, 0xf9, 0x52, 0x32, 0xd8, 0x25, 0x21, 0x76, 0x09, 0xb9, 0x70, 0x71, 0xb9, 0xe4, 0x97,
	0xe7, 0x15, 0x83, 0xad, 0xc0, 0x6f, 0x90, 0x38, 0x9a, 0x24, 0xcc, 0x55, 0x06, 0x8c, 0x42, 0xce,
	0x5c, 0x1c, 0xa1, 0x05, 0x50, 0x33, 0x70, 0x29, 0xc3, 0xef, 0x10, 0x0d, 0x46, 0x21, 0x5b, 0x2e,
	0x16, 0xa7, 0xcc, 0x94, 0x4c, 0xdc, 0x06, 0x48, 0xe0, 0x90, 0x30, 0xd2, 0x60, 0x34, 0x60, 0x74,
	0x72, 0x88, 0xb2, 0x4b, 0xcf, 0x2c, 0xc9, 0x28, 0x4d, 0xd2, 0x4b, 0xce, 0xcf, 0xd5, 0x4f, 0xcf,
	0x4f, 0xcf, 0xd7, 0x07, 0x87, 0x7f, 0x52, 0x69, 0x1a, 0x84, 0x91, 0xac, 0x9b, 0x9e, 0x9a, 0xa7,
	0x0b, 0x96, 0x00, 0x19, 0x91, 0x92, 0x58, 0x92, 0x08, 0x8e, 0x26, 0x6b, 0xa8, 0x81, 0x49, 0x6c,
	0x60, 0x65, 0xc6, 0x80, 0x00, 0x00, 0x00, 0xff, 0xff, 0x16, 0x54, 0x6e, 0x1b, 0xc2, 0x01, 0x00,
	0x00,
	}