lib/google/bigtable/v2/bigtable_services_pb.rb in google-cloud-bigtable-1.2.2 vs lib/google/bigtable/v2/bigtable_services_pb.rb in google-cloud-bigtable-1.3.0

- old
+ new

@@ -1,7 +1,7 @@ # Generated by the protocol buffer compiler. DO NOT EDIT! -# Source: google/bigtable/v2/bigtable.proto for package 'google.bigtable.v2' +# Source: google/bigtable/v2/bigtable.proto for package 'Google::Cloud::Bigtable::V2' # Original file comments: # Copyright 2019 Google LLC. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -20,49 +20,49 @@ require 'grpc' require 'google/bigtable/v2/bigtable_pb' module Google module Bigtable - module V2 - module Bigtable - # Service for reading from and writing to existing Bigtable tables. - class Service + end +end +module Google::Bigtable::V2 + module Bigtable + # Service for reading from and writing to existing Bigtable tables. + class Service - include GRPC::GenericService + include GRPC::GenericService - self.marshal_class_method = :encode - self.unmarshal_class_method = :decode - self.service_name = 'google.bigtable.v2.Bigtable' + self.marshal_class_method = :encode + self.unmarshal_class_method = :decode + self.service_name = 'google.bigtable.v2.Bigtable' - # Streams back the contents of all requested rows in key order, optionally - # applying the same Reader filter to each. Depending on their size, - # rows and cells may be broken up across multiple responses, but - # atomicity of each row will still be preserved. See the - # ReadRowsResponse documentation for details. - rpc :ReadRows, ReadRowsRequest, stream(ReadRowsResponse) - # Returns a sample of row keys in the table. The returned row keys will - # delimit contiguous sections of the table of approximately equal size, - # which can be used to break up the data for distributed tasks like - # mapreduces. - rpc :SampleRowKeys, SampleRowKeysRequest, stream(SampleRowKeysResponse) - # Mutates a row atomically. Cells already present in the row are left - # unchanged unless explicitly changed by `mutation`. - rpc :MutateRow, MutateRowRequest, MutateRowResponse - # Mutates multiple rows in a batch. Each individual row is mutated - # atomically as in MutateRow, but the entire batch is not executed - # atomically. - rpc :MutateRows, MutateRowsRequest, stream(MutateRowsResponse) - # Mutates a row atomically based on the output of a predicate Reader filter. - rpc :CheckAndMutateRow, CheckAndMutateRowRequest, CheckAndMutateRowResponse - # Modifies a row atomically on the server. The method reads the latest - # existing timestamp and value from the specified columns and writes a new - # entry based on pre-defined read/modify/write rules. The new value for the - # timestamp is the greater of the existing timestamp or the current server - # time. The method returns the new contents of all modified cells. - rpc :ReadModifyWriteRow, ReadModifyWriteRowRequest, ReadModifyWriteRowResponse - end - - Stub = Service.rpc_stub_class - end + # Streams back the contents of all requested rows in key order, optionally + # applying the same Reader filter to each. Depending on their size, + # rows and cells may be broken up across multiple responses, but + # atomicity of each row will still be preserved. See the + # ReadRowsResponse documentation for details. + rpc :ReadRows, ReadRowsRequest, stream(ReadRowsResponse) + # Returns a sample of row keys in the table. The returned row keys will + # delimit contiguous sections of the table of approximately equal size, + # which can be used to break up the data for distributed tasks like + # mapreduces. + rpc :SampleRowKeys, SampleRowKeysRequest, stream(SampleRowKeysResponse) + # Mutates a row atomically. Cells already present in the row are left + # unchanged unless explicitly changed by `mutation`. + rpc :MutateRow, MutateRowRequest, MutateRowResponse + # Mutates multiple rows in a batch. Each individual row is mutated + # atomically as in MutateRow, but the entire batch is not executed + # atomically. + rpc :MutateRows, MutateRowsRequest, stream(MutateRowsResponse) + # Mutates a row atomically based on the output of a predicate Reader filter. + rpc :CheckAndMutateRow, CheckAndMutateRowRequest, CheckAndMutateRowResponse + # Modifies a row atomically on the server. The method reads the latest + # existing timestamp and value from the specified columns and writes a new + # entry based on pre-defined read/modify/write rules. The new value for the + # timestamp is the greater of the existing timestamp or the current server + # time. The method returns the new contents of all modified cells. + rpc :ReadModifyWriteRow, ReadModifyWriteRowRequest, ReadModifyWriteRowResponse end + + Stub = Service.rpc_stub_class end end