spanner/internal/benchwrapper/proto/spanner.pb.go - gocloud - Git at Google

 // Code generated by protoc-gen-go. DO NOT EDIT.
 // source: spanner.proto

 package spanner_bench

 import (
 	context "context"
 	fmt "fmt"
 	math "math"

 	proto "github.com/golang/protobuf/proto"
 	grpc "google.golang.org/grpc"
 	codes "google.golang.org/grpc/codes"
 	status "google.golang.org/grpc/status"
 )

 // 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.ProtoPackageIsVersion3 // please upgrade the proto package

 type ReadQuery struct {
 	// The query to use in the read call.
 	Query                string   `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *ReadQuery) Reset()         { *m = ReadQuery{} }
 func (m *ReadQuery) String() string { return proto.CompactTextString(m) }
 func (*ReadQuery) ProtoMessage()    {}
 func (*ReadQuery) Descriptor() ([]byte, []int) {
 	return fileDescriptor_879d3e919e93c6ba, []int{0}
 }

 func (m *ReadQuery) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_ReadQuery.Unmarshal(m, b)
 }
 func (m *ReadQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_ReadQuery.Marshal(b, m, deterministic)
 }
 func (m *ReadQuery) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_ReadQuery.Merge(m, src)
 }
 func (m *ReadQuery) XXX_Size() int {
 	return xxx_messageInfo_ReadQuery.Size(m)
 }
 func (m *ReadQuery) XXX_DiscardUnknown() {
 	xxx_messageInfo_ReadQuery.DiscardUnknown(m)
 }

 var xxx_messageInfo_ReadQuery proto.InternalMessageInfo

 func (m *ReadQuery) GetQuery() string {
 	if m != nil {
 		return m.Query
 	}
 	return ""
 }

 type User struct {
 	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
 	Age                  int64    `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"`
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *User) Reset()         { *m = User{} }
 func (m *User) String() string { return proto.CompactTextString(m) }
 func (*User) ProtoMessage()    {}
 func (*User) Descriptor() ([]byte, []int) {
 	return fileDescriptor_879d3e919e93c6ba, []int{1}
 }

 func (m *User) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_User.Unmarshal(m, b)
 }
 func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_User.Marshal(b, m, deterministic)
 }
 func (m *User) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_User.Merge(m, src)
 }
 func (m *User) XXX_Size() int {
 	return xxx_messageInfo_User.Size(m)
 }
 func (m *User) XXX_DiscardUnknown() {
 	xxx_messageInfo_User.DiscardUnknown(m)
 }

 var xxx_messageInfo_User proto.InternalMessageInfo

 func (m *User) GetName() string {
 	if m != nil {
 		return m.Name
 	}
 	return ""
 }

 func (m *User) GetAge() int64 {
 	if m != nil {
 		return m.Age
 	}
 	return 0
 }

 type InsertQuery struct {
 	// The query to use in the insert call.
 	Users                []*User  `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *InsertQuery) Reset()         { *m = InsertQuery{} }
 func (m *InsertQuery) String() string { return proto.CompactTextString(m) }
 func (*InsertQuery) ProtoMessage()    {}
 func (*InsertQuery) Descriptor() ([]byte, []int) {
 	return fileDescriptor_879d3e919e93c6ba, []int{2}
 }

 func (m *InsertQuery) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_InsertQuery.Unmarshal(m, b)
 }
 func (m *InsertQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_InsertQuery.Marshal(b, m, deterministic)
 }
 func (m *InsertQuery) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_InsertQuery.Merge(m, src)
 }
 func (m *InsertQuery) XXX_Size() int {
 	return xxx_messageInfo_InsertQuery.Size(m)
 }
 func (m *InsertQuery) XXX_DiscardUnknown() {
 	xxx_messageInfo_InsertQuery.DiscardUnknown(m)
 }

 var xxx_messageInfo_InsertQuery proto.InternalMessageInfo

 func (m *InsertQuery) GetUsers() []*User {
 	if m != nil {
 		return m.Users
 	}
 	return nil
 }

 type UpdateQuery struct {
 	// The queries to use in the update call.
 	Queries              []string `protobuf:"bytes,1,rep,name=Queries,proto3" json:"Queries,omitempty"`
 	XXX_NoUnkeyedLiteral struct{} `json:"-"`
 	XXX_unrecognized     []byte   `json:"-"`
 	XXX_sizecache        int32    `json:"-"`
 }

 func (m *UpdateQuery) Reset()         { *m = UpdateQuery{} }
 func (m *UpdateQuery) String() string { return proto.CompactTextString(m) }
 func (*UpdateQuery) ProtoMessage()    {}
 func (*UpdateQuery) Descriptor() ([]byte, []int) {
 	return fileDescriptor_879d3e919e93c6ba, []int{3}
 }

 func (m *UpdateQuery) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_UpdateQuery.Unmarshal(m, b)
 }
 func (m *UpdateQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_UpdateQuery.Marshal(b, m, deterministic)
 }
 func (m *UpdateQuery) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_UpdateQuery.Merge(m, src)
 }
 func (m *UpdateQuery) XXX_Size() int {
 	return xxx_messageInfo_UpdateQuery.Size(m)
 }
 func (m *UpdateQuery) XXX_DiscardUnknown() {
 	xxx_messageInfo_UpdateQuery.DiscardUnknown(m)
 }

 var xxx_messageInfo_UpdateQuery proto.InternalMessageInfo

 func (m *UpdateQuery) GetQueries() []string {
 	if m != nil {
 		return m.Queries
 	}
 	return nil
 }

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

 func (m *EmptyResponse) Reset()         { *m = EmptyResponse{} }
 func (m *EmptyResponse) String() string { return proto.CompactTextString(m) }
 func (*EmptyResponse) ProtoMessage()    {}
 func (*EmptyResponse) Descriptor() ([]byte, []int) {
 	return fileDescriptor_879d3e919e93c6ba, []int{4}
 }

 func (m *EmptyResponse) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_EmptyResponse.Unmarshal(m, b)
 }
 func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_EmptyResponse.Marshal(b, m, deterministic)
 }
 func (m *EmptyResponse) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_EmptyResponse.Merge(m, src)
 }
 func (m *EmptyResponse) XXX_Size() int {
 	return xxx_messageInfo_EmptyResponse.Size(m)
 }
 func (m *EmptyResponse) XXX_DiscardUnknown() {
 	xxx_messageInfo_EmptyResponse.DiscardUnknown(m)
 }

 var xxx_messageInfo_EmptyResponse proto.InternalMessageInfo

 func init() {
 	proto.RegisterType((*ReadQuery)(nil), "spanner_bench.ReadQuery")
 	proto.RegisterType((*User)(nil), "spanner_bench.User")
 	proto.RegisterType((*InsertQuery)(nil), "spanner_bench.InsertQuery")
 	proto.RegisterType((*UpdateQuery)(nil), "spanner_bench.UpdateQuery")
 	proto.RegisterType((*EmptyResponse)(nil), "spanner_bench.EmptyResponse")
 }

 func init() { proto.RegisterFile("spanner.proto", fileDescriptor_879d3e919e93c6ba) }

 var fileDescriptor_879d3e919e93c6ba = []byte{
 	// 254 bytes of a gzipped FileDescriptorProto
 	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x91, 0xb1, 0x4e, 0xc3, 0x30,
 	0x10, 0x86, 0x31, 0x49, 0x8b, 0x72, 0x51, 0x05, 0xba, 0x32, 0x58, 0x15, 0x43, 0xf0, 0x42, 0x90,
 	0x50, 0x86, 0xb2, 0x30, 0x22, 0x04, 0x03, 0x23, 0x46, 0x15, 0x23, 0x72, 0xe9, 0x09, 0x18, 0xea,
 	0x58, 0xb6, 0x3b, 0xf4, 0x79, 0x79, 0x11, 0xe4, 0x1c, 0x45, 0x6d, 0x18, 0xe8, 0xf6, 0xff, 0xf2,
 	0xdd, 0x77, 0xfa, 0x64, 0x18, 0x05, 0x67, 0xac, 0x25, 0xdf, 0x38, 0xdf, 0xc6, 0x16, 0x37, 0xf5,
 	0x75, 0x4e, 0xf6, 0xed, 0x43, 0x9d, 0x43, 0xa1, 0xc9, 0x2c, 0x9e, 0x56, 0xe4, 0xd7, 0x78, 0x0a,
 	0x83, 0x2e, 0x48, 0x51, 0x89, 0xba, 0xd0, 0x5c, 0xd4, 0x15, 0xe4, 0xb3, 0x40, 0x1e, 0x11, 0x72,
 	0x6b, 0x96, 0xf4, 0xf3, 0xd8, 0x65, 0x3c, 0x81, 0xcc, 0xbc, 0x93, 0x3c, 0xac, 0x44, 0x9d, 0xe9,
 	0x14, 0xd5, 0x0d, 0x94, 0x8f, 0x36, 0x90, 0x8f, 0x8c, 0xbc, 0x84, 0xc1, 0x2a, 0x90, 0x0f, 0x52,
 	0x54, 0x59, 0x5d, 0x4e, 0xc7, 0xcd, 0xce, 0xf9, 0x26, 0x81, 0x35, 0x4f, 0xa8, 0x0b, 0x28, 0x67,
 	0x6e, 0x61, 0x22, 0xf1, 0xa6, 0x84, 0xa3, 0x14, 0x3e, 0x89, 0x77, 0x0b, 0xbd, 0xa9, 0xea, 0x18,
 	0x46, 0x0f, 0x4b, 0x17, 0xd7, 0x9a, 0x82, 0x6b, 0x6d, 0xa0, 0xe9, 0x97, 0x80, 0xf1, 0x33, 0x73,
 	0xef, 0x12, 0xf6, 0xc5, 0x1b, 0xe7, 0xc8, 0xe3, 0x2d, 0xe4, 0x49, 0x0e, 0x65, 0xef, 0xea, 0xaf,
 	0xf1, 0xe4, 0xac, 0xf7, 0xb2, 0xc3, 0x55, 0x07, 0x78, 0x0f, 0x43, 0xb6, 0xc1, 0x49, 0x6f, 0x72,
 	0x4b, 0x72, 0x1f, 0x0a, 0x9b, 0xfd, 0xa1, 0x6c, 0x09, 0xff, 0x47, 0x99, 0x0f, 0xbb, 0x0f, 0xbc,
 	0xfe, 0x0e, 0x00, 0x00, 0xff, 0xff, 0x1e, 0x2e, 0xa6, 0x11, 0xd1, 0x01, 0x00, 0x00,
 }

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

 // SpannerBenchWrapperClient is the client API for SpannerBenchWrapper service.
 //
 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
 type SpannerBenchWrapperClient interface {
 	// Read represents operations like Go's ReadOnlyTransaction.Query, Java's
 	// ReadOnlyTransaction.executeQuery, Python's snapshot.read, and Node's
 	// Transaction.Read.
 	//
 	// It will typically be used to read many items.
 	Read(ctx context.Context, in *ReadQuery, opts ...grpc.CallOption) (*EmptyResponse, error)
 	// Insert represents operations like Go's Client.Apply, Java's
 	// DatabaseClient.writeAtLeastOnce, Python's transaction.commit, and Node's
 	// Transaction.Commit.
 	//
 	// It will typically be used to insert many items.
 	Insert(ctx context.Context, in *InsertQuery, opts ...grpc.CallOption) (*EmptyResponse, error)
 	// Update represents operations like Go's ReadWriteTransaction.BatchUpdate,
 	// Java's TransactionRunner.run, Python's Batch.update, and Node's
 	// Transaction.BatchUpdate.
 	//
 	// It will typically be used to update many items.
 	Update(ctx context.Context, in *UpdateQuery, opts ...grpc.CallOption) (*EmptyResponse, error)
 }

 type spannerBenchWrapperClient struct {
 	cc *grpc.ClientConn
 }

 func NewSpannerBenchWrapperClient(cc *grpc.ClientConn) SpannerBenchWrapperClient {
 	return &spannerBenchWrapperClient{cc}
 }

 func (c *spannerBenchWrapperClient) Read(ctx context.Context, in *ReadQuery, opts ...grpc.CallOption) (*EmptyResponse, error) {
 	out := new(EmptyResponse)
 	err := c.cc.Invoke(ctx, "/spanner_bench.SpannerBenchWrapper/Read", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
 	return out, nil
 }

 func (c *spannerBenchWrapperClient) Insert(ctx context.Context, in *InsertQuery, opts ...grpc.CallOption) (*EmptyResponse, error) {
 	out := new(EmptyResponse)
 	err := c.cc.Invoke(ctx, "/spanner_bench.SpannerBenchWrapper/Insert", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
 	return out, nil
 }

 func (c *spannerBenchWrapperClient) Update(ctx context.Context, in *UpdateQuery, opts ...grpc.CallOption) (*EmptyResponse, error) {
 	out := new(EmptyResponse)
 	err := c.cc.Invoke(ctx, "/spanner_bench.SpannerBenchWrapper/Update", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
 	return out, nil
 }

 // SpannerBenchWrapperServer is the server API for SpannerBenchWrapper service.
 type SpannerBenchWrapperServer interface {
 	// Read represents operations like Go's ReadOnlyTransaction.Query, Java's
 	// ReadOnlyTransaction.executeQuery, Python's snapshot.read, and Node's
 	// Transaction.Read.
 	//
 	// It will typically be used to read many items.
 	Read(context.Context, *ReadQuery) (*EmptyResponse, error)
 	// Insert represents operations like Go's Client.Apply, Java's
 	// DatabaseClient.writeAtLeastOnce, Python's transaction.commit, and Node's
 	// Transaction.Commit.
 	//
 	// It will typically be used to insert many items.
 	Insert(context.Context, *InsertQuery) (*EmptyResponse, error)
 	// Update represents operations like Go's ReadWriteTransaction.BatchUpdate,
 	// Java's TransactionRunner.run, Python's Batch.update, and Node's
 	// Transaction.BatchUpdate.
 	//
 	// It will typically be used to update many items.
 	Update(context.Context, *UpdateQuery) (*EmptyResponse, error)
 }

 // UnimplementedSpannerBenchWrapperServer can be embedded to have forward compatible implementations.
 type UnimplementedSpannerBenchWrapperServer struct {
 }

 func (*UnimplementedSpannerBenchWrapperServer) Read(ctx context.Context, req *ReadQuery) (*EmptyResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method Read not implemented")
 }
 func (*UnimplementedSpannerBenchWrapperServer) Insert(ctx context.Context, req *InsertQuery) (*EmptyResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method Insert not implemented")
 }
 func (*UnimplementedSpannerBenchWrapperServer) Update(ctx context.Context, req *UpdateQuery) (*EmptyResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
 }

 func RegisterSpannerBenchWrapperServer(s *grpc.Server, srv SpannerBenchWrapperServer) {
 	s.RegisterService(&_SpannerBenchWrapper_serviceDesc, srv)
 }

 func _SpannerBenchWrapper_Read_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(ReadQuery)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
 	if interceptor == nil {
 		return srv.(SpannerBenchWrapperServer).Read(ctx, in)
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
 		FullMethod: "/spanner_bench.SpannerBenchWrapper/Read",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(SpannerBenchWrapperServer).Read(ctx, req.(*ReadQuery))
 	}
 	return interceptor(ctx, in, info, handler)
 }

 func _SpannerBenchWrapper_Insert_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(InsertQuery)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
 	if interceptor == nil {
 		return srv.(SpannerBenchWrapperServer).Insert(ctx, in)
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
 		FullMethod: "/spanner_bench.SpannerBenchWrapper/Insert",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(SpannerBenchWrapperServer).Insert(ctx, req.(*InsertQuery))
 	}
 	return interceptor(ctx, in, info, handler)
 }

 func _SpannerBenchWrapper_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
 	in := new(UpdateQuery)
 	if err := dec(in); err != nil {
 		return nil, err
 	}
 	if interceptor == nil {
 		return srv.(SpannerBenchWrapperServer).Update(ctx, in)
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
 		FullMethod: "/spanner_bench.SpannerBenchWrapper/Update",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(SpannerBenchWrapperServer).Update(ctx, req.(*UpdateQuery))
 	}
 	return interceptor(ctx, in, info, handler)
 }

 var _SpannerBenchWrapper_serviceDesc = grpc.ServiceDesc{
 	ServiceName: "spanner_bench.SpannerBenchWrapper",
 	HandlerType: (*SpannerBenchWrapperServer)(nil),
 	Methods: []grpc.MethodDesc{
 		{
 			MethodName: "Read",
 			Handler:    _SpannerBenchWrapper_Read_Handler,
 		},
 		{
 			MethodName: "Insert",
 			Handler:    _SpannerBenchWrapper_Insert_Handler,
 		},
 		{
 			MethodName: "Update",
 			Handler:    _SpannerBenchWrapper_Update_Handler,
 		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "spanner.proto",
 }
	// Code generated by protoc-gen-go. DO NOT EDIT.
	// source: spanner.proto

	package spanner_bench

	import (
	context "context"
	fmt "fmt"
	math "math"

	proto "github.com/golang/protobuf/proto"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	)

	// 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.ProtoPackageIsVersion3 // please upgrade the proto package

	type ReadQuery struct {
	// The query to use in the read call.
	Query string `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m ReadQuery) Reset() { m = ReadQuery{} }
	func (m *ReadQuery) String() string { return proto.CompactTextString(m) }
	func (*ReadQuery) ProtoMessage() {}
	func (*ReadQuery) Descriptor() ([]byte, []int) {
	return fileDescriptor_879d3e919e93c6ba, []int{0}
	}

	func (m *ReadQuery) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ReadQuery.Unmarshal(m, b)
	}
	func (m *ReadQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ReadQuery.Marshal(b, m, deterministic)
	}
	func (m *ReadQuery) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ReadQuery.Merge(m, src)
	}
	func (m *ReadQuery) XXX_Size() int {
	return xxx_messageInfo_ReadQuery.Size(m)
	}
	func (m *ReadQuery) XXX_DiscardUnknown() {
	xxx_messageInfo_ReadQuery.DiscardUnknown(m)
	}

	var xxx_messageInfo_ReadQuery proto.InternalMessageInfo

	func (m *ReadQuery) GetQuery() string {
	if m != nil {
	return m.Query
	}
	return ""
	}

	type User struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Age int64 `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m User) Reset() { m = User{} }
	func (m *User) String() string { return proto.CompactTextString(m) }
	func (*User) ProtoMessage() {}
	func (*User) Descriptor() ([]byte, []int) {
	return fileDescriptor_879d3e919e93c6ba, []int{1}
	}

	func (m *User) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_User.Unmarshal(m, b)
	}
	func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_User.Marshal(b, m, deterministic)
	}
	func (m *User) XXX_Merge(src proto.Message) {
	xxx_messageInfo_User.Merge(m, src)
	}
	func (m *User) XXX_Size() int {
	return xxx_messageInfo_User.Size(m)
	}
	func (m *User) XXX_DiscardUnknown() {
	xxx_messageInfo_User.DiscardUnknown(m)
	}

	var xxx_messageInfo_User proto.InternalMessageInfo

	func (m *User) GetName() string {
	if m != nil {
	return m.Name
	}
	return ""
	}

	func (m *User) GetAge() int64 {
	if m != nil {
	return m.Age
	}
	return 0
	}

	type InsertQuery struct {
	// The query to use in the insert call.
	Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m InsertQuery) Reset() { m = InsertQuery{} }
	func (m *InsertQuery) String() string { return proto.CompactTextString(m) }
	func (*InsertQuery) ProtoMessage() {}
	func (*InsertQuery) Descriptor() ([]byte, []int) {
	return fileDescriptor_879d3e919e93c6ba, []int{2}
	}

	func (m *InsertQuery) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_InsertQuery.Unmarshal(m, b)
	}
	func (m *InsertQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_InsertQuery.Marshal(b, m, deterministic)
	}
	func (m *InsertQuery) XXX_Merge(src proto.Message) {
	xxx_messageInfo_InsertQuery.Merge(m, src)
	}
	func (m *InsertQuery) XXX_Size() int {
	return xxx_messageInfo_InsertQuery.Size(m)
	}
	func (m *InsertQuery) XXX_DiscardUnknown() {
	xxx_messageInfo_InsertQuery.DiscardUnknown(m)
	}

	var xxx_messageInfo_InsertQuery proto.InternalMessageInfo

	func (m InsertQuery) GetUsers() []User {
	if m != nil {
	return m.Users
	}
	return nil
	}

	type UpdateQuery struct {
	// The queries to use in the update call.
	Queries []string `protobuf:"bytes,1,rep,name=Queries,proto3" json:"Queries,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m UpdateQuery) Reset() { m = UpdateQuery{} }
	func (m *UpdateQuery) String() string { return proto.CompactTextString(m) }
	func (*UpdateQuery) ProtoMessage() {}
	func (*UpdateQuery) Descriptor() ([]byte, []int) {
	return fileDescriptor_879d3e919e93c6ba, []int{3}
	}

	func (m *UpdateQuery) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_UpdateQuery.Unmarshal(m, b)
	}
	func (m *UpdateQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_UpdateQuery.Marshal(b, m, deterministic)
	}
	func (m *UpdateQuery) XXX_Merge(src proto.Message) {
	xxx_messageInfo_UpdateQuery.Merge(m, src)
	}
	func (m *UpdateQuery) XXX_Size() int {
	return xxx_messageInfo_UpdateQuery.Size(m)
	}
	func (m *UpdateQuery) XXX_DiscardUnknown() {
	xxx_messageInfo_UpdateQuery.DiscardUnknown(m)
	}

	var xxx_messageInfo_UpdateQuery proto.InternalMessageInfo

	func (m *UpdateQuery) GetQueries() []string {
	if m != nil {
	return m.Queries
	}
	return nil
	}

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

	func (m EmptyResponse) Reset() { m = EmptyResponse{} }
	func (m *EmptyResponse) String() string { return proto.CompactTextString(m) }
	func (*EmptyResponse) ProtoMessage() {}
	func (*EmptyResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_879d3e919e93c6ba, []int{4}
	}

	func (m *EmptyResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_EmptyResponse.Unmarshal(m, b)
	}
	func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_EmptyResponse.Marshal(b, m, deterministic)
	}
	func (m *EmptyResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_EmptyResponse.Merge(m, src)
	}
	func (m *EmptyResponse) XXX_Size() int {
	return xxx_messageInfo_EmptyResponse.Size(m)
	}
	func (m *EmptyResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_EmptyResponse.DiscardUnknown(m)
	}

	var xxx_messageInfo_EmptyResponse proto.InternalMessageInfo

	func init() {
	proto.RegisterType((*ReadQuery)(nil), "spanner_bench.ReadQuery")
	proto.RegisterType((*User)(nil), "spanner_bench.User")
	proto.RegisterType((*InsertQuery)(nil), "spanner_bench.InsertQuery")
	proto.RegisterType((*UpdateQuery)(nil), "spanner_bench.UpdateQuery")
	proto.RegisterType((*EmptyResponse)(nil), "spanner_bench.EmptyResponse")
	}

	func init() { proto.RegisterFile("spanner.proto", fileDescriptor_879d3e919e93c6ba) }

	var fileDescriptor_879d3e919e93c6ba = []byte{
	// 254 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x91, 0xb1, 0x4e, 0xc3, 0x30,
	0x10, 0x86, 0x31, 0x49, 0x8b, 0x72, 0x51, 0x05, 0xba, 0x32, 0x58, 0x15, 0x43, 0xf0, 0x42, 0x90,
	0x50, 0x86, 0xb2, 0x30, 0x22, 0x04, 0x03, 0x23, 0x46, 0x15, 0x23, 0x72, 0xe9, 0x09, 0x18, 0xea,
	0x58, 0xb6, 0x3b, 0xf4, 0x79, 0x79, 0x11, 0xe4, 0x1c, 0x45, 0x6d, 0x18, 0xe8, 0xf6, 0xff, 0xf2,
	0xdd, 0x77, 0xfa, 0x64, 0x18, 0x05, 0x67, 0xac, 0x25, 0xdf, 0x38, 0xdf, 0xc6, 0x16, 0x37, 0xf5,
	0x75, 0x4e, 0xf6, 0xed, 0x43, 0x9d, 0x43, 0xa1, 0xc9, 0x2c, 0x9e, 0x56, 0xe4, 0xd7, 0x78, 0x0a,
	0x83, 0x2e, 0x48, 0x51, 0x89, 0xba, 0xd0, 0x5c, 0xd4, 0x15, 0xe4, 0xb3, 0x40, 0x1e, 0x11, 0x72,
	0x6b, 0x96, 0xf4, 0xf3, 0xd8, 0x65, 0x3c, 0x81, 0xcc, 0xbc, 0x93, 0x3c, 0xac, 0x44, 0x9d, 0xe9,
	0x14, 0xd5, 0x0d, 0x94, 0x8f, 0x36, 0x90, 0x8f, 0x8c, 0xbc, 0x84, 0xc1, 0x2a, 0x90, 0x0f, 0x52,
	0x54, 0x59, 0x5d, 0x4e, 0xc7, 0xcd, 0xce, 0xf9, 0x26, 0x81, 0x35, 0x4f, 0xa8, 0x0b, 0x28, 0x67,
	0x6e, 0x61, 0x22, 0xf1, 0xa6, 0x84, 0xa3, 0x14, 0x3e, 0x89, 0x77, 0x0b, 0xbd, 0xa9, 0xea, 0x18,
	0x46, 0x0f, 0x4b, 0x17, 0xd7, 0x9a, 0x82, 0x6b, 0x6d, 0xa0, 0xe9, 0x97, 0x80, 0xf1, 0x33, 0x73,
	0xef, 0x12, 0xf6, 0xc5, 0x1b, 0xe7, 0xc8, 0xe3, 0x2d, 0xe4, 0x49, 0x0e, 0x65, 0xef, 0xea, 0xaf,
	0xf1, 0xe4, 0xac, 0xf7, 0xb2, 0xc3, 0x55, 0x07, 0x78, 0x0f, 0x43, 0xb6, 0xc1, 0x49, 0x6f, 0x72,
	0x4b, 0x72, 0x1f, 0x0a, 0x9b, 0xfd, 0xa1, 0x6c, 0x09, 0xff, 0x47, 0x99, 0x0f, 0xbb, 0x0f, 0xbc,
	0xfe, 0x0e, 0x00, 0x00, 0xff, 0xff, 0x1e, 0x2e, 0xa6, 0x11, 0xd1, 0x01, 0x00, 0x00,
	}

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

	// SpannerBenchWrapperClient is the client API for SpannerBenchWrapper service.
	//
	// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
	type SpannerBenchWrapperClient interface {
	// Read represents operations like Go's ReadOnlyTransaction.Query, Java's
	// ReadOnlyTransaction.executeQuery, Python's snapshot.read, and Node's
	// Transaction.Read.
	//
	// It will typically be used to read many items.
	Read(ctx context.Context, in ReadQuery, opts ...grpc.CallOption) (EmptyResponse, error)
	// Insert represents operations like Go's Client.Apply, Java's
	// DatabaseClient.writeAtLeastOnce, Python's transaction.commit, and Node's
	// Transaction.Commit.
	//
	// It will typically be used to insert many items.
	Insert(ctx context.Context, in InsertQuery, opts ...grpc.CallOption) (EmptyResponse, error)
	// Update represents operations like Go's ReadWriteTransaction.BatchUpdate,
	// Java's TransactionRunner.run, Python's Batch.update, and Node's
	// Transaction.BatchUpdate.
	//
	// It will typically be used to update many items.
	Update(ctx context.Context, in UpdateQuery, opts ...grpc.CallOption) (EmptyResponse, error)
	}

	type spannerBenchWrapperClient struct {
	cc *grpc.ClientConn
	}

	func NewSpannerBenchWrapperClient(cc *grpc.ClientConn) SpannerBenchWrapperClient {
	return &spannerBenchWrapperClient{cc}
	}

	func (c spannerBenchWrapperClient) Read(ctx context.Context, in ReadQuery, opts ...grpc.CallOption) (*EmptyResponse, error) {
	out := new(EmptyResponse)
	err := c.cc.Invoke(ctx, "/spanner_bench.SpannerBenchWrapper/Read", in, out, opts...)
	if err != nil {
	return nil, err
	}
	return out, nil
	}

	func (c spannerBenchWrapperClient) Insert(ctx context.Context, in InsertQuery, opts ...grpc.CallOption) (*EmptyResponse, error) {
	out := new(EmptyResponse)
	err := c.cc.Invoke(ctx, "/spanner_bench.SpannerBenchWrapper/Insert", in, out, opts...)
	if err != nil {
	return nil, err
	}
	return out, nil
	}

	func (c spannerBenchWrapperClient) Update(ctx context.Context, in UpdateQuery, opts ...grpc.CallOption) (*EmptyResponse, error) {
	out := new(EmptyResponse)
	err := c.cc.Invoke(ctx, "/spanner_bench.SpannerBenchWrapper/Update", in, out, opts...)
	if err != nil {
	return nil, err
	}
	return out, nil
	}

	// SpannerBenchWrapperServer is the server API for SpannerBenchWrapper service.
	type SpannerBenchWrapperServer interface {
	// Read represents operations like Go's ReadOnlyTransaction.Query, Java's
	// ReadOnlyTransaction.executeQuery, Python's snapshot.read, and Node's
	// Transaction.Read.
	//
	// It will typically be used to read many items.
	Read(context.Context, ReadQuery) (EmptyResponse, error)
	// Insert represents operations like Go's Client.Apply, Java's
	// DatabaseClient.writeAtLeastOnce, Python's transaction.commit, and Node's
	// Transaction.Commit.
	//
	// It will typically be used to insert many items.
	Insert(context.Context, InsertQuery) (EmptyResponse, error)
	// Update represents operations like Go's ReadWriteTransaction.BatchUpdate,
	// Java's TransactionRunner.run, Python's Batch.update, and Node's
	// Transaction.BatchUpdate.
	//
	// It will typically be used to update many items.
	Update(context.Context, UpdateQuery) (EmptyResponse, error)
	}

	// UnimplementedSpannerBenchWrapperServer can be embedded to have forward compatible implementations.
	type UnimplementedSpannerBenchWrapperServer struct {
	}

	func (UnimplementedSpannerBenchWrapperServer) Read(ctx context.Context, req ReadQuery) (*EmptyResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Read not implemented")
	}
	func (UnimplementedSpannerBenchWrapperServer) Insert(ctx context.Context, req InsertQuery) (*EmptyResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Insert not implemented")
	}
	func (UnimplementedSpannerBenchWrapperServer) Update(ctx context.Context, req UpdateQuery) (*EmptyResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Update not implemented")
	}

	func RegisterSpannerBenchWrapperServer(s *grpc.Server, srv SpannerBenchWrapperServer) {
	s.RegisterService(&_SpannerBenchWrapper_serviceDesc, srv)
	}

	func _SpannerBenchWrapper_Read_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ReadQuery)
	if err := dec(in); err != nil {
	return nil, err
	}
	if interceptor == nil {
	return srv.(SpannerBenchWrapperServer).Read(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
	Server: srv,
	FullMethod: "/spanner_bench.SpannerBenchWrapper/Read",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
	return srv.(SpannerBenchWrapperServer).Read(ctx, req.(*ReadQuery))
	}
	return interceptor(ctx, in, info, handler)
	}

	func _SpannerBenchWrapper_Insert_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(InsertQuery)
	if err := dec(in); err != nil {
	return nil, err
	}
	if interceptor == nil {
	return srv.(SpannerBenchWrapperServer).Insert(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
	Server: srv,
	FullMethod: "/spanner_bench.SpannerBenchWrapper/Insert",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
	return srv.(SpannerBenchWrapperServer).Insert(ctx, req.(*InsertQuery))
	}
	return interceptor(ctx, in, info, handler)
	}

	func _SpannerBenchWrapper_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateQuery)
	if err := dec(in); err != nil {
	return nil, err
	}
	if interceptor == nil {
	return srv.(SpannerBenchWrapperServer).Update(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
	Server: srv,
	FullMethod: "/spanner_bench.SpannerBenchWrapper/Update",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
	return srv.(SpannerBenchWrapperServer).Update(ctx, req.(*UpdateQuery))
	}
	return interceptor(ctx, in, info, handler)
	}

	var _SpannerBenchWrapper_serviceDesc = grpc.ServiceDesc{
	ServiceName: "spanner_bench.SpannerBenchWrapper",
	HandlerType: (*SpannerBenchWrapperServer)(nil),
	Methods: []grpc.MethodDesc{
	{
	MethodName: "Read",
	Handler: _SpannerBenchWrapper_Read_Handler,
	},
	{
	MethodName: "Insert",
	Handler: _SpannerBenchWrapper_Insert_Handler,
	},
	{
	MethodName: "Update",
	Handler: _SpannerBenchWrapper_Update_Handler,
	},
	},
	Streams: []grpc.StreamDesc{},
	Metadata: "spanner.proto",
	}