1// Code generated by protoc-gen-go. DO NOT EDIT. 2// source: google/bigtable/v1/bigtable_service.proto 3 4package bigtable 5 6import ( 7 context "context" 8 fmt "fmt" 9 math "math" 10 11 proto "github.com/golang/protobuf/proto" 12 empty "github.com/golang/protobuf/ptypes/empty" 13 _ "google.golang.org/genproto/googleapis/api/annotations" 14 grpc "google.golang.org/grpc" 15 codes "google.golang.org/grpc/codes" 16 status "google.golang.org/grpc/status" 17) 18 19// Reference imports to suppress errors if they are not otherwise used. 20var _ = proto.Marshal 21var _ = fmt.Errorf 22var _ = math.Inf 23 24// This is a compile-time assertion to ensure that this generated file 25// is compatible with the proto package it is being compiled against. 26// A compilation error at this line likely means your copy of the 27// proto package needs to be updated. 28const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package 29 30func init() { 31 proto.RegisterFile("google/bigtable/v1/bigtable_service.proto", fileDescriptor_a9a2f3a013379609) 32} 33 34var fileDescriptor_a9a2f3a013379609 = []byte{ 35 // 521 bytes of a gzipped FileDescriptorProto 36 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x94, 0xcd, 0x6e, 0xd4, 0x30, 37 0x10, 0xc7, 0x65, 0x0e, 0xa8, 0x58, 0x42, 0x08, 0x4b, 0x14, 0x69, 0xe1, 0x14, 0xa0, 0xa2, 0x11, 38 0x8d, 0xdb, 0x72, 0x0b, 0xe2, 0xd0, 0x45, 0x50, 0x21, 0x58, 0x51, 0xa5, 0xe2, 0x43, 0xe5, 0xb0, 39 0x78, 0x93, 0x69, 0x08, 0x4d, 0xe2, 0x60, 0x7b, 0x37, 0x5a, 0xaa, 0x5e, 0x38, 0x71, 0xe7, 0x11, 40 0x10, 0x17, 0x5e, 0x80, 0x23, 0xef, 0x00, 0x67, 0x6e, 0x3c, 0x08, 0xb2, 0x63, 0x2f, 0x2c, 0x0d, 41 0xcb, 0x8a, 0xee, 0x29, 0x8e, 0xe6, 0x3f, 0x33, 0xbf, 0xff, 0xf8, 0x03, 0xaf, 0xa6, 0x9c, 0xa7, 42 0x39, 0xd0, 0x41, 0x96, 0x2a, 0x36, 0xc8, 0x81, 0x8e, 0x36, 0x26, 0xeb, 0xbe, 0x04, 0x31, 0xca, 43 0x62, 0x08, 0x2a, 0xc1, 0x15, 0x27, 0xa4, 0x91, 0x06, 0x2e, 0x1c, 0x8c, 0x36, 0x3a, 0x97, 0x6d, 44 0x3a, 0xab, 0x32, 0xca, 0xca, 0x92, 0x2b, 0xa6, 0x32, 0x5e, 0xca, 0x26, 0xa3, 0xb3, 0x32, 0xab, 45 0x78, 0xc2, 0x14, 0xb3, 0xba, 0xcd, 0x39, 0x20, 0xfa, 0x05, 0x48, 0xc9, 0x52, 0x70, 0xb5, 0x2f, 46 0xd9, 0x1c, 0xf3, 0x37, 0x18, 0xee, 0x53, 0x28, 0x2a, 0x35, 0x6e, 0x82, 0x9b, 0xdf, 0x97, 0xf0, 47 0xb9, 0xae, 0x2d, 0xb0, 0xdb, 0xe4, 0x93, 0x8f, 0x08, 0x2f, 0x45, 0xc0, 0x92, 0x88, 0xd7, 0x92, 48 0x5c, 0x09, 0x8e, 0x9b, 0x09, 0x5c, 0x34, 0x82, 0xd7, 0x43, 0x90, 0xaa, 0x73, 0x75, 0xb6, 0x48, 49 0x56, 0xbc, 0x94, 0xe0, 0x3d, 0x7c, 0xfb, 0xed, 0xc7, 0xfb, 0x53, 0xf7, 0xbc, 0x2d, 0x4d, 0x7d, 50 0xd8, 0x30, 0x97, 0xac, 0x80, 0xdb, 0x95, 0xe0, 0xaf, 0x20, 0x56, 0x92, 0xfa, 0xf4, 0x0d, 0x2f, 51 0x41, 0x7f, 0xe3, 0x7c, 0x28, 0x15, 0x08, 0xbd, 0x34, 0x42, 0x49, 0xfd, 0x23, 0x2a, 0x78, 0x2d, 52 0x43, 0x01, 0x2c, 0x09, 0x91, 0xbf, 0x8e, 0xc8, 0x67, 0x84, 0xcf, 0xee, 0xb2, 0xa2, 0xca, 0x21, 53 0xe2, 0xf5, 0x03, 0x18, 0x4b, 0x72, 0xbd, 0x8d, 0x63, 0x4a, 0xe2, 0x88, 0x57, 0xe7, 0x50, 0x5a, 54 0xec, 0x47, 0x06, 0xfb, 0x3e, 0xd9, 0x3e, 0x11, 0xb6, 0x34, 0xb5, 0x75, 0xe1, 0x75, 0x44, 0x3e, 55 0x20, 0x7c, 0xa6, 0x37, 0x54, 0x4c, 0xe9, 0x66, 0xa4, 0x75, 0x7a, 0x93, 0xb0, 0x23, 0x5e, 0x76, 56 0x2a, 0xb7, 0x8f, 0xc1, 0x5d, 0xbd, 0x8f, 0xde, 0x33, 0x83, 0x17, 0x79, 0xbd, 0x93, 0xe0, 0xd1, 57 0x43, 0xc1, 0xeb, 0xfe, 0x01, 0x8c, 0x8f, 0xc2, 0xc2, 0x34, 0x0e, 0x91, 0x4f, 0x3e, 0x21, 0x8c, 58 0x27, 0x18, 0x92, 0x5c, 0x9b, 0x89, 0x39, 0x99, 0xec, 0xca, 0xbf, 0x64, 0x76, 0xac, 0x3d, 0xc3, 59 0xbd, 0xed, 0x75, 0xff, 0x93, 0xdb, 0x82, 0xea, 0x9a, 0x1a, 0xf6, 0x2b, 0xc2, 0xe7, 0xef, 0xbc, 60 0x84, 0xf8, 0x60, 0xab, 0x4c, 0x7e, 0x8d, 0xf6, 0x46, 0x1b, 0xcc, 0x31, 0x99, 0x43, 0x5f, 0x9b, 61 0x53, 0x6d, 0x1d, 0xbc, 0x30, 0x0e, 0xf6, 0xbc, 0xc7, 0x0b, 0x9a, 0x7c, 0x3c, 0xd5, 0x49, 0x9b, 62 0xfa, 0x82, 0x30, 0xd1, 0xd7, 0xa8, 0xc7, 0x93, 0x6c, 0x7f, 0xfc, 0x54, 0x64, 0x8d, 0xab, 0xb5, 63 0xbf, 0x5d, 0xb7, 0x69, 0x9d, 0xb3, 0x75, 0xb1, 0x55, 0xce, 0x6b, 0x8f, 0x19, 0x03, 0xcf, 0xbd, 64 0x27, 0x0b, 0x32, 0x20, 0xa6, 0x11, 0x42, 0xe4, 0x77, 0x2b, 0xbc, 0x1c, 0xf3, 0xa2, 0x05, 0xa0, 65 0x7b, 0xe1, 0x8f, 0x67, 0x47, 0xee, 0xe8, 0x73, 0xbd, 0x83, 0xf6, 0x42, 0x2b, 0x4e, 0x79, 0xce, 66 0xca, 0x34, 0xe0, 0x22, 0xa5, 0x29, 0x94, 0xe6, 0xd4, 0xd3, 0x26, 0xc4, 0xaa, 0x4c, 0xfe, 0xfe, 67 0x04, 0xde, 0x72, 0xeb, 0x77, 0x08, 0x0d, 0x4e, 0x1b, 0xe5, 0xcd, 0x9f, 0x01, 0x00, 0x00, 0xff, 68 0xff, 0x4c, 0x27, 0x6e, 0x9a, 0xb0, 0x05, 0x00, 0x00, 69} 70 71// Reference imports to suppress errors if they are not otherwise used. 72var _ context.Context 73var _ grpc.ClientConnInterface 74 75// This is a compile-time assertion to ensure that this generated file 76// is compatible with the grpc package it is being compiled against. 77const _ = grpc.SupportPackageIsVersion6 78 79// BigtableServiceClient is the client API for BigtableService service. 80// 81// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. 82type BigtableServiceClient interface { 83 // Streams back the contents of all requested rows, optionally applying 84 // the same Reader filter to each. Depending on their size, rows may be 85 // broken up across multiple responses, but atomicity of each row will still 86 // be preserved. 87 ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigtableService_ReadRowsClient, error) 88 // Returns a sample of row keys in the table. The returned row keys will 89 // delimit contiguous sections of the table of approximately equal size, 90 // which can be used to break up the data for distributed tasks like 91 // mapreduces. 92 SampleRowKeys(ctx context.Context, in *SampleRowKeysRequest, opts ...grpc.CallOption) (BigtableService_SampleRowKeysClient, error) 93 // Mutates a row atomically. Cells already present in the row are left 94 // unchanged unless explicitly changed by 'mutation'. 95 MutateRow(ctx context.Context, in *MutateRowRequest, opts ...grpc.CallOption) (*empty.Empty, error) 96 // Mutates multiple rows in a batch. Each individual row is mutated 97 // atomically as in MutateRow, but the entire batch is not executed 98 // atomically. 99 MutateRows(ctx context.Context, in *MutateRowsRequest, opts ...grpc.CallOption) (*MutateRowsResponse, error) 100 // Mutates a row atomically based on the output of a predicate Reader filter. 101 CheckAndMutateRow(ctx context.Context, in *CheckAndMutateRowRequest, opts ...grpc.CallOption) (*CheckAndMutateRowResponse, error) 102 // Modifies a row atomically, reading the latest existing timestamp/value from 103 // the specified columns and writing a new value at 104 // max(existing timestamp, current server time) based on pre-defined 105 // read/modify/write rules. Returns the new contents of all modified cells. 106 ReadModifyWriteRow(ctx context.Context, in *ReadModifyWriteRowRequest, opts ...grpc.CallOption) (*Row, error) 107} 108 109type bigtableServiceClient struct { 110 cc grpc.ClientConnInterface 111} 112 113func NewBigtableServiceClient(cc grpc.ClientConnInterface) BigtableServiceClient { 114 return &bigtableServiceClient{cc} 115} 116 117func (c *bigtableServiceClient) ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigtableService_ReadRowsClient, error) { 118 stream, err := c.cc.NewStream(ctx, &_BigtableService_serviceDesc.Streams[0], "/google.bigtable.v1.BigtableService/ReadRows", opts...) 119 if err != nil { 120 return nil, err 121 } 122 x := &bigtableServiceReadRowsClient{stream} 123 if err := x.ClientStream.SendMsg(in); err != nil { 124 return nil, err 125 } 126 if err := x.ClientStream.CloseSend(); err != nil { 127 return nil, err 128 } 129 return x, nil 130} 131 132type BigtableService_ReadRowsClient interface { 133 Recv() (*ReadRowsResponse, error) 134 grpc.ClientStream 135} 136 137type bigtableServiceReadRowsClient struct { 138 grpc.ClientStream 139} 140 141func (x *bigtableServiceReadRowsClient) Recv() (*ReadRowsResponse, error) { 142 m := new(ReadRowsResponse) 143 if err := x.ClientStream.RecvMsg(m); err != nil { 144 return nil, err 145 } 146 return m, nil 147} 148 149func (c *bigtableServiceClient) SampleRowKeys(ctx context.Context, in *SampleRowKeysRequest, opts ...grpc.CallOption) (BigtableService_SampleRowKeysClient, error) { 150 stream, err := c.cc.NewStream(ctx, &_BigtableService_serviceDesc.Streams[1], "/google.bigtable.v1.BigtableService/SampleRowKeys", opts...) 151 if err != nil { 152 return nil, err 153 } 154 x := &bigtableServiceSampleRowKeysClient{stream} 155 if err := x.ClientStream.SendMsg(in); err != nil { 156 return nil, err 157 } 158 if err := x.ClientStream.CloseSend(); err != nil { 159 return nil, err 160 } 161 return x, nil 162} 163 164type BigtableService_SampleRowKeysClient interface { 165 Recv() (*SampleRowKeysResponse, error) 166 grpc.ClientStream 167} 168 169type bigtableServiceSampleRowKeysClient struct { 170 grpc.ClientStream 171} 172 173func (x *bigtableServiceSampleRowKeysClient) Recv() (*SampleRowKeysResponse, error) { 174 m := new(SampleRowKeysResponse) 175 if err := x.ClientStream.RecvMsg(m); err != nil { 176 return nil, err 177 } 178 return m, nil 179} 180 181func (c *bigtableServiceClient) MutateRow(ctx context.Context, in *MutateRowRequest, opts ...grpc.CallOption) (*empty.Empty, error) { 182 out := new(empty.Empty) 183 err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/MutateRow", in, out, opts...) 184 if err != nil { 185 return nil, err 186 } 187 return out, nil 188} 189 190func (c *bigtableServiceClient) MutateRows(ctx context.Context, in *MutateRowsRequest, opts ...grpc.CallOption) (*MutateRowsResponse, error) { 191 out := new(MutateRowsResponse) 192 err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/MutateRows", in, out, opts...) 193 if err != nil { 194 return nil, err 195 } 196 return out, nil 197} 198 199func (c *bigtableServiceClient) CheckAndMutateRow(ctx context.Context, in *CheckAndMutateRowRequest, opts ...grpc.CallOption) (*CheckAndMutateRowResponse, error) { 200 out := new(CheckAndMutateRowResponse) 201 err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/CheckAndMutateRow", in, out, opts...) 202 if err != nil { 203 return nil, err 204 } 205 return out, nil 206} 207 208func (c *bigtableServiceClient) ReadModifyWriteRow(ctx context.Context, in *ReadModifyWriteRowRequest, opts ...grpc.CallOption) (*Row, error) { 209 out := new(Row) 210 err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/ReadModifyWriteRow", in, out, opts...) 211 if err != nil { 212 return nil, err 213 } 214 return out, nil 215} 216 217// BigtableServiceServer is the server API for BigtableService service. 218type BigtableServiceServer interface { 219 // Streams back the contents of all requested rows, optionally applying 220 // the same Reader filter to each. Depending on their size, rows may be 221 // broken up across multiple responses, but atomicity of each row will still 222 // be preserved. 223 ReadRows(*ReadRowsRequest, BigtableService_ReadRowsServer) error 224 // Returns a sample of row keys in the table. The returned row keys will 225 // delimit contiguous sections of the table of approximately equal size, 226 // which can be used to break up the data for distributed tasks like 227 // mapreduces. 228 SampleRowKeys(*SampleRowKeysRequest, BigtableService_SampleRowKeysServer) error 229 // Mutates a row atomically. Cells already present in the row are left 230 // unchanged unless explicitly changed by 'mutation'. 231 MutateRow(context.Context, *MutateRowRequest) (*empty.Empty, error) 232 // Mutates multiple rows in a batch. Each individual row is mutated 233 // atomically as in MutateRow, but the entire batch is not executed 234 // atomically. 235 MutateRows(context.Context, *MutateRowsRequest) (*MutateRowsResponse, error) 236 // Mutates a row atomically based on the output of a predicate Reader filter. 237 CheckAndMutateRow(context.Context, *CheckAndMutateRowRequest) (*CheckAndMutateRowResponse, error) 238 // Modifies a row atomically, reading the latest existing timestamp/value from 239 // the specified columns and writing a new value at 240 // max(existing timestamp, current server time) based on pre-defined 241 // read/modify/write rules. Returns the new contents of all modified cells. 242 ReadModifyWriteRow(context.Context, *ReadModifyWriteRowRequest) (*Row, error) 243} 244 245// UnimplementedBigtableServiceServer can be embedded to have forward compatible implementations. 246type UnimplementedBigtableServiceServer struct { 247} 248 249func (*UnimplementedBigtableServiceServer) ReadRows(req *ReadRowsRequest, srv BigtableService_ReadRowsServer) error { 250 return status.Errorf(codes.Unimplemented, "method ReadRows not implemented") 251} 252func (*UnimplementedBigtableServiceServer) SampleRowKeys(req *SampleRowKeysRequest, srv BigtableService_SampleRowKeysServer) error { 253 return status.Errorf(codes.Unimplemented, "method SampleRowKeys not implemented") 254} 255func (*UnimplementedBigtableServiceServer) MutateRow(ctx context.Context, req *MutateRowRequest) (*empty.Empty, error) { 256 return nil, status.Errorf(codes.Unimplemented, "method MutateRow not implemented") 257} 258func (*UnimplementedBigtableServiceServer) MutateRows(ctx context.Context, req *MutateRowsRequest) (*MutateRowsResponse, error) { 259 return nil, status.Errorf(codes.Unimplemented, "method MutateRows not implemented") 260} 261func (*UnimplementedBigtableServiceServer) CheckAndMutateRow(ctx context.Context, req *CheckAndMutateRowRequest) (*CheckAndMutateRowResponse, error) { 262 return nil, status.Errorf(codes.Unimplemented, "method CheckAndMutateRow not implemented") 263} 264func (*UnimplementedBigtableServiceServer) ReadModifyWriteRow(ctx context.Context, req *ReadModifyWriteRowRequest) (*Row, error) { 265 return nil, status.Errorf(codes.Unimplemented, "method ReadModifyWriteRow not implemented") 266} 267 268func RegisterBigtableServiceServer(s *grpc.Server, srv BigtableServiceServer) { 269 s.RegisterService(&_BigtableService_serviceDesc, srv) 270} 271 272func _BigtableService_ReadRows_Handler(srv interface{}, stream grpc.ServerStream) error { 273 m := new(ReadRowsRequest) 274 if err := stream.RecvMsg(m); err != nil { 275 return err 276 } 277 return srv.(BigtableServiceServer).ReadRows(m, &bigtableServiceReadRowsServer{stream}) 278} 279 280type BigtableService_ReadRowsServer interface { 281 Send(*ReadRowsResponse) error 282 grpc.ServerStream 283} 284 285type bigtableServiceReadRowsServer struct { 286 grpc.ServerStream 287} 288 289func (x *bigtableServiceReadRowsServer) Send(m *ReadRowsResponse) error { 290 return x.ServerStream.SendMsg(m) 291} 292 293func _BigtableService_SampleRowKeys_Handler(srv interface{}, stream grpc.ServerStream) error { 294 m := new(SampleRowKeysRequest) 295 if err := stream.RecvMsg(m); err != nil { 296 return err 297 } 298 return srv.(BigtableServiceServer).SampleRowKeys(m, &bigtableServiceSampleRowKeysServer{stream}) 299} 300 301type BigtableService_SampleRowKeysServer interface { 302 Send(*SampleRowKeysResponse) error 303 grpc.ServerStream 304} 305 306type bigtableServiceSampleRowKeysServer struct { 307 grpc.ServerStream 308} 309 310func (x *bigtableServiceSampleRowKeysServer) Send(m *SampleRowKeysResponse) error { 311 return x.ServerStream.SendMsg(m) 312} 313 314func _BigtableService_MutateRow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 315 in := new(MutateRowRequest) 316 if err := dec(in); err != nil { 317 return nil, err 318 } 319 if interceptor == nil { 320 return srv.(BigtableServiceServer).MutateRow(ctx, in) 321 } 322 info := &grpc.UnaryServerInfo{ 323 Server: srv, 324 FullMethod: "/google.bigtable.v1.BigtableService/MutateRow", 325 } 326 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 327 return srv.(BigtableServiceServer).MutateRow(ctx, req.(*MutateRowRequest)) 328 } 329 return interceptor(ctx, in, info, handler) 330} 331 332func _BigtableService_MutateRows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 333 in := new(MutateRowsRequest) 334 if err := dec(in); err != nil { 335 return nil, err 336 } 337 if interceptor == nil { 338 return srv.(BigtableServiceServer).MutateRows(ctx, in) 339 } 340 info := &grpc.UnaryServerInfo{ 341 Server: srv, 342 FullMethod: "/google.bigtable.v1.BigtableService/MutateRows", 343 } 344 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 345 return srv.(BigtableServiceServer).MutateRows(ctx, req.(*MutateRowsRequest)) 346 } 347 return interceptor(ctx, in, info, handler) 348} 349 350func _BigtableService_CheckAndMutateRow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 351 in := new(CheckAndMutateRowRequest) 352 if err := dec(in); err != nil { 353 return nil, err 354 } 355 if interceptor == nil { 356 return srv.(BigtableServiceServer).CheckAndMutateRow(ctx, in) 357 } 358 info := &grpc.UnaryServerInfo{ 359 Server: srv, 360 FullMethod: "/google.bigtable.v1.BigtableService/CheckAndMutateRow", 361 } 362 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 363 return srv.(BigtableServiceServer).CheckAndMutateRow(ctx, req.(*CheckAndMutateRowRequest)) 364 } 365 return interceptor(ctx, in, info, handler) 366} 367 368func _BigtableService_ReadModifyWriteRow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 369 in := new(ReadModifyWriteRowRequest) 370 if err := dec(in); err != nil { 371 return nil, err 372 } 373 if interceptor == nil { 374 return srv.(BigtableServiceServer).ReadModifyWriteRow(ctx, in) 375 } 376 info := &grpc.UnaryServerInfo{ 377 Server: srv, 378 FullMethod: "/google.bigtable.v1.BigtableService/ReadModifyWriteRow", 379 } 380 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 381 return srv.(BigtableServiceServer).ReadModifyWriteRow(ctx, req.(*ReadModifyWriteRowRequest)) 382 } 383 return interceptor(ctx, in, info, handler) 384} 385 386var _BigtableService_serviceDesc = grpc.ServiceDesc{ 387 ServiceName: "google.bigtable.v1.BigtableService", 388 HandlerType: (*BigtableServiceServer)(nil), 389 Methods: []grpc.MethodDesc{ 390 { 391 MethodName: "MutateRow", 392 Handler: _BigtableService_MutateRow_Handler, 393 }, 394 { 395 MethodName: "MutateRows", 396 Handler: _BigtableService_MutateRows_Handler, 397 }, 398 { 399 MethodName: "CheckAndMutateRow", 400 Handler: _BigtableService_CheckAndMutateRow_Handler, 401 }, 402 { 403 MethodName: "ReadModifyWriteRow", 404 Handler: _BigtableService_ReadModifyWriteRow_Handler, 405 }, 406 }, 407 Streams: []grpc.StreamDesc{ 408 { 409 StreamName: "ReadRows", 410 Handler: _BigtableService_ReadRows_Handler, 411 ServerStreams: true, 412 }, 413 { 414 StreamName: "SampleRowKeys", 415 Handler: _BigtableService_SampleRowKeys_Handler, 416 ServerStreams: true, 417 }, 418 }, 419 Metadata: "google/bigtable/v1/bigtable_service.proto", 420} 421