Source file src/google.golang.org/genproto/googleapis/bigtable/v1/bigtable_service.pb.go

Documentation: google.golang.org/genproto/googleapis/bigtable/v1

     1  // Copyright 2018 Google Inc.
     2  //
     3  // Licensed under the Apache License, Version 2.0 (the "License");
     4  // you may not use this file except in compliance with the License.
     5  // You may obtain a copy of the License at
     6  //
     7  //     http://www.apache.org/licenses/LICENSE-2.0
     8  //
     9  // Unless required by applicable law or agreed to in writing, software
    10  // distributed under the License is distributed on an "AS IS" BASIS,
    11  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12  // See the License for the specific language governing permissions and
    13  // limitations under the License.
    14  
    15  // Code generated by protoc-gen-go. DO NOT EDIT.
    16  // versions:
    17  // 	protoc-gen-go v1.25.0
    18  // 	protoc        v3.13.0
    19  // source: google/bigtable/v1/bigtable_service.proto
    20  
    21  package bigtable
    22  
    23  import (
    24  	context "context"
    25  	reflect "reflect"
    26  
    27  	proto "github.com/golang/protobuf/proto"
    28  	_ "google.golang.org/genproto/googleapis/api/annotations"
    29  	grpc "google.golang.org/grpc"
    30  	codes "google.golang.org/grpc/codes"
    31  	status "google.golang.org/grpc/status"
    32  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    33  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    34  	emptypb "google.golang.org/protobuf/types/known/emptypb"
    35  )
    36  
    37  const (
    38  	// Verify that this generated code is sufficiently up-to-date.
    39  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    40  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    41  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    42  )
    43  
    44  // This is a compile-time assertion that a sufficiently up-to-date version
    45  // of the legacy proto package is being used.
    46  const _ = proto.ProtoPackageIsVersion4
    47  
    48  var File_google_bigtable_v1_bigtable_service_proto protoreflect.FileDescriptor
    49  
    50  var file_google_bigtable_v1_bigtable_service_proto_rawDesc = []byte{
    51  	0x0a, 0x29, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c,
    52  	0x65, 0x2f, 0x76, 0x31, 0x2f, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x73, 0x65,
    53  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x12, 0x67, 0x6f, 0x6f,
    54  	0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x1a,
    55  	0x1c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f,
    56  	0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x26, 0x67,
    57  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2f, 0x76,
    58  	0x31, 0x2f, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x2e,
    59  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x62, 0x69,
    60  	0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62,
    61  	0x6c, 0x65, 0x5f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x6d, 0x65, 0x73, 0x73, 0x61,
    62  	0x67, 0x65, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
    63  	0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79,
    64  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x32, 0xdd, 0x08, 0x0a, 0x0f, 0x42, 0x69, 0x67, 0x74, 0x61,
    65  	0x62, 0x6c, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0xa5, 0x01, 0x0a, 0x08, 0x52,
    66  	0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x23, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
    67  	0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x61,
    68  	0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x24, 0x2e, 0x67,
    69  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76,
    70  	0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
    71  	0x73, 0x65, 0x22, 0x4c, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x46, 0x22, 0x41, 0x2f, 0x76, 0x31, 0x2f,
    72  	0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
    73  	0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x7a, 0x6f, 0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x63,
    74  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73,
    75  	0x2f, 0x2a, 0x7d, 0x2f, 0x72, 0x6f, 0x77, 0x73, 0x3a, 0x72, 0x65, 0x61, 0x64, 0x3a, 0x01, 0x2a,
    76  	0x30, 0x01, 0x12, 0xb7, 0x01, 0x0a, 0x0d, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x52, 0x6f, 0x77,
    77  	0x4b, 0x65, 0x79, 0x73, 0x12, 0x28, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69,
    78  	0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65,
    79  	0x52, 0x6f, 0x77, 0x4b, 0x65, 0x79, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x29,
    80  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65,
    81  	0x2e, 0x76, 0x31, 0x2e, 0x53, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x52, 0x6f, 0x77, 0x4b, 0x65, 0x79,
    82  	0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4f, 0x82, 0xd3, 0xe4, 0x93, 0x02,
    83  	0x49, 0x12, 0x47, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61,
    84  	0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x7a, 0x6f,
    85  	0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a,
    86  	0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x72, 0x6f, 0x77, 0x73, 0x3a,
    87  	0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x4b, 0x65, 0x79, 0x73, 0x30, 0x01, 0x12, 0xa3, 0x01, 0x0a,
    88  	0x09, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x12, 0x24, 0x2e, 0x67, 0x6f, 0x6f,
    89  	0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e,
    90  	0x4d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
    91  	0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62,
    92  	0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x58, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x52,
    93  	0x22, 0x4d, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d,
    94  	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x7a, 0x6f, 0x6e,
    95  	0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f,
    96  	0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x72, 0x6f, 0x77, 0x73, 0x2f, 0x7b,
    97  	0x72, 0x6f, 0x77, 0x5f, 0x6b, 0x65, 0x79, 0x7d, 0x3a, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x3a,
    98  	0x01, 0x2a, 0x12, 0xaa, 0x01, 0x0a, 0x0a, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77,
    99  	0x73, 0x12, 0x25, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61,
   100  	0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77,
   101  	0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x26, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   102  	0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x4d, 0x75,
   103  	0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
   104  	0x22, 0x4d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x47, 0x22, 0x42, 0x2f, 0x76, 0x31, 0x2f, 0x7b, 0x74,
   105  	0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
   106  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x7a, 0x6f, 0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x63, 0x6c, 0x75,
   107  	0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x2a,
   108  	0x7d, 0x3a, 0x6d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x73, 0x3a, 0x01, 0x2a, 0x12,
   109  	0xd2, 0x01, 0x0a, 0x11, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x41, 0x6e, 0x64, 0x4d, 0x75, 0x74, 0x61,
   110  	0x74, 0x65, 0x52, 0x6f, 0x77, 0x12, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62,
   111  	0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x68, 0x65, 0x63, 0x6b,
   112  	0x41, 0x6e, 0x64, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75,
   113  	0x65, 0x73, 0x74, 0x1a, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67,
   114  	0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x68, 0x65, 0x63, 0x6b, 0x41, 0x6e,
   115  	0x64, 0x4d, 0x75, 0x74, 0x61, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
   116  	0x73, 0x65, 0x22, 0x60, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x5a, 0x22, 0x55, 0x2f, 0x76, 0x31, 0x2f,
   117  	0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a,
   118  	0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x7a, 0x6f, 0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x2f, 0x63,
   119  	0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73,
   120  	0x2f, 0x2a, 0x7d, 0x2f, 0x72, 0x6f, 0x77, 0x73, 0x2f, 0x7b, 0x72, 0x6f, 0x77, 0x5f, 0x6b, 0x65,
   121  	0x79, 0x7d, 0x3a, 0x63, 0x68, 0x65, 0x63, 0x6b, 0x41, 0x6e, 0x64, 0x4d, 0x75, 0x74, 0x61, 0x74,
   122  	0x65, 0x3a, 0x01, 0x2a, 0x12, 0xbf, 0x01, 0x0a, 0x12, 0x52, 0x65, 0x61, 0x64, 0x4d, 0x6f, 0x64,
   123  	0x69, 0x66, 0x79, 0x57, 0x72, 0x69, 0x74, 0x65, 0x52, 0x6f, 0x77, 0x12, 0x2d, 0x2e, 0x67, 0x6f,
   124  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31,
   125  	0x2e, 0x52, 0x65, 0x61, 0x64, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x79, 0x57, 0x72, 0x69, 0x74, 0x65,
   126  	0x52, 0x6f, 0x77, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x67, 0x6f, 0x6f,
   127  	0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31, 0x2e,
   128  	0x52, 0x6f, 0x77, 0x22, 0x61, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x5b, 0x22, 0x56, 0x2f, 0x76, 0x31,
   129  	0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f,
   130  	0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x7a, 0x6f, 0x6e, 0x65, 0x73, 0x2f, 0x2a, 0x2f,
   131  	0x63, 0x6c, 0x75, 0x73, 0x74, 0x65, 0x72, 0x73, 0x2f, 0x2a, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65,
   132  	0x73, 0x2f, 0x2a, 0x7d, 0x2f, 0x72, 0x6f, 0x77, 0x73, 0x2f, 0x7b, 0x72, 0x6f, 0x77, 0x5f, 0x6b,
   133  	0x65, 0x79, 0x7d, 0x3a, 0x72, 0x65, 0x61, 0x64, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x79, 0x57, 0x72,
   134  	0x69, 0x74, 0x65, 0x3a, 0x01, 0x2a, 0x42, 0x70, 0x0a, 0x16, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f,
   135  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x76, 0x31,
   136  	0x42, 0x15, 0x42, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
   137  	0x65, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3a, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   138  	0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e,
   139  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
   140  	0x2f, 0x62, 0x69, 0x67, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2f, 0x76, 0x31, 0x3b, 0x62, 0x69, 0x67,
   141  	0x74, 0x61, 0x62, 0x6c, 0x65, 0x88, 0x01, 0x01, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   142  }
   143  
   144  var file_google_bigtable_v1_bigtable_service_proto_goTypes = []interface{}{
   145  	(*ReadRowsRequest)(nil),           // 0: google.bigtable.v1.ReadRowsRequest
   146  	(*SampleRowKeysRequest)(nil),      // 1: google.bigtable.v1.SampleRowKeysRequest
   147  	(*MutateRowRequest)(nil),          // 2: google.bigtable.v1.MutateRowRequest
   148  	(*MutateRowsRequest)(nil),         // 3: google.bigtable.v1.MutateRowsRequest
   149  	(*CheckAndMutateRowRequest)(nil),  // 4: google.bigtable.v1.CheckAndMutateRowRequest
   150  	(*ReadModifyWriteRowRequest)(nil), // 5: google.bigtable.v1.ReadModifyWriteRowRequest
   151  	(*ReadRowsResponse)(nil),          // 6: google.bigtable.v1.ReadRowsResponse
   152  	(*SampleRowKeysResponse)(nil),     // 7: google.bigtable.v1.SampleRowKeysResponse
   153  	(*emptypb.Empty)(nil),             // 8: google.protobuf.Empty
   154  	(*MutateRowsResponse)(nil),        // 9: google.bigtable.v1.MutateRowsResponse
   155  	(*CheckAndMutateRowResponse)(nil), // 10: google.bigtable.v1.CheckAndMutateRowResponse
   156  	(*Row)(nil),                       // 11: google.bigtable.v1.Row
   157  }
   158  var file_google_bigtable_v1_bigtable_service_proto_depIdxs = []int32{
   159  	0,  // 0: google.bigtable.v1.BigtableService.ReadRows:input_type -> google.bigtable.v1.ReadRowsRequest
   160  	1,  // 1: google.bigtable.v1.BigtableService.SampleRowKeys:input_type -> google.bigtable.v1.SampleRowKeysRequest
   161  	2,  // 2: google.bigtable.v1.BigtableService.MutateRow:input_type -> google.bigtable.v1.MutateRowRequest
   162  	3,  // 3: google.bigtable.v1.BigtableService.MutateRows:input_type -> google.bigtable.v1.MutateRowsRequest
   163  	4,  // 4: google.bigtable.v1.BigtableService.CheckAndMutateRow:input_type -> google.bigtable.v1.CheckAndMutateRowRequest
   164  	5,  // 5: google.bigtable.v1.BigtableService.ReadModifyWriteRow:input_type -> google.bigtable.v1.ReadModifyWriteRowRequest
   165  	6,  // 6: google.bigtable.v1.BigtableService.ReadRows:output_type -> google.bigtable.v1.ReadRowsResponse
   166  	7,  // 7: google.bigtable.v1.BigtableService.SampleRowKeys:output_type -> google.bigtable.v1.SampleRowKeysResponse
   167  	8,  // 8: google.bigtable.v1.BigtableService.MutateRow:output_type -> google.protobuf.Empty
   168  	9,  // 9: google.bigtable.v1.BigtableService.MutateRows:output_type -> google.bigtable.v1.MutateRowsResponse
   169  	10, // 10: google.bigtable.v1.BigtableService.CheckAndMutateRow:output_type -> google.bigtable.v1.CheckAndMutateRowResponse
   170  	11, // 11: google.bigtable.v1.BigtableService.ReadModifyWriteRow:output_type -> google.bigtable.v1.Row
   171  	6,  // [6:12] is the sub-list for method output_type
   172  	0,  // [0:6] is the sub-list for method input_type
   173  	0,  // [0:0] is the sub-list for extension type_name
   174  	0,  // [0:0] is the sub-list for extension extendee
   175  	0,  // [0:0] is the sub-list for field type_name
   176  }
   177  
   178  func init() { file_google_bigtable_v1_bigtable_service_proto_init() }
   179  func file_google_bigtable_v1_bigtable_service_proto_init() {
   180  	if File_google_bigtable_v1_bigtable_service_proto != nil {
   181  		return
   182  	}
   183  	file_google_bigtable_v1_bigtable_data_proto_init()
   184  	file_google_bigtable_v1_bigtable_service_messages_proto_init()
   185  	type x struct{}
   186  	out := protoimpl.TypeBuilder{
   187  		File: protoimpl.DescBuilder{
   188  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   189  			RawDescriptor: file_google_bigtable_v1_bigtable_service_proto_rawDesc,
   190  			NumEnums:      0,
   191  			NumMessages:   0,
   192  			NumExtensions: 0,
   193  			NumServices:   1,
   194  		},
   195  		GoTypes:           file_google_bigtable_v1_bigtable_service_proto_goTypes,
   196  		DependencyIndexes: file_google_bigtable_v1_bigtable_service_proto_depIdxs,
   197  	}.Build()
   198  	File_google_bigtable_v1_bigtable_service_proto = out.File
   199  	file_google_bigtable_v1_bigtable_service_proto_rawDesc = nil
   200  	file_google_bigtable_v1_bigtable_service_proto_goTypes = nil
   201  	file_google_bigtable_v1_bigtable_service_proto_depIdxs = nil
   202  }
   203  
   204  // Reference imports to suppress errors if they are not otherwise used.
   205  var _ context.Context
   206  var _ grpc.ClientConnInterface
   207  
   208  // This is a compile-time assertion to ensure that this generated file
   209  // is compatible with the grpc package it is being compiled against.
   210  const _ = grpc.SupportPackageIsVersion6
   211  
   212  // BigtableServiceClient is the client API for BigtableService service.
   213  //
   214  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   215  type BigtableServiceClient interface {
   216  	// Streams back the contents of all requested rows, optionally applying
   217  	// the same Reader filter to each. Depending on their size, rows may be
   218  	// broken up across multiple responses, but atomicity of each row will still
   219  	// be preserved.
   220  	ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigtableService_ReadRowsClient, error)
   221  	// Returns a sample of row keys in the table. The returned row keys will
   222  	// delimit contiguous sections of the table of approximately equal size,
   223  	// which can be used to break up the data for distributed tasks like
   224  	// mapreduces.
   225  	SampleRowKeys(ctx context.Context, in *SampleRowKeysRequest, opts ...grpc.CallOption) (BigtableService_SampleRowKeysClient, error)
   226  	// Mutates a row atomically. Cells already present in the row are left
   227  	// unchanged unless explicitly changed by 'mutation'.
   228  	MutateRow(ctx context.Context, in *MutateRowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
   229  	// Mutates multiple rows in a batch. Each individual row is mutated
   230  	// atomically as in MutateRow, but the entire batch is not executed
   231  	// atomically.
   232  	MutateRows(ctx context.Context, in *MutateRowsRequest, opts ...grpc.CallOption) (*MutateRowsResponse, error)
   233  	// Mutates a row atomically based on the output of a predicate Reader filter.
   234  	CheckAndMutateRow(ctx context.Context, in *CheckAndMutateRowRequest, opts ...grpc.CallOption) (*CheckAndMutateRowResponse, error)
   235  	// Modifies a row atomically, reading the latest existing timestamp/value from
   236  	// the specified columns and writing a new value at
   237  	// max(existing timestamp, current server time) based on pre-defined
   238  	// read/modify/write rules. Returns the new contents of all modified cells.
   239  	ReadModifyWriteRow(ctx context.Context, in *ReadModifyWriteRowRequest, opts ...grpc.CallOption) (*Row, error)
   240  }
   241  
   242  type bigtableServiceClient struct {
   243  	cc grpc.ClientConnInterface
   244  }
   245  
   246  func NewBigtableServiceClient(cc grpc.ClientConnInterface) BigtableServiceClient {
   247  	return &bigtableServiceClient{cc}
   248  }
   249  
   250  func (c *bigtableServiceClient) ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigtableService_ReadRowsClient, error) {
   251  	stream, err := c.cc.NewStream(ctx, &_BigtableService_serviceDesc.Streams[0], "/google.bigtable.v1.BigtableService/ReadRows", opts...)
   252  	if err != nil {
   253  		return nil, err
   254  	}
   255  	x := &bigtableServiceReadRowsClient{stream}
   256  	if err := x.ClientStream.SendMsg(in); err != nil {
   257  		return nil, err
   258  	}
   259  	if err := x.ClientStream.CloseSend(); err != nil {
   260  		return nil, err
   261  	}
   262  	return x, nil
   263  }
   264  
   265  type BigtableService_ReadRowsClient interface {
   266  	Recv() (*ReadRowsResponse, error)
   267  	grpc.ClientStream
   268  }
   269  
   270  type bigtableServiceReadRowsClient struct {
   271  	grpc.ClientStream
   272  }
   273  
   274  func (x *bigtableServiceReadRowsClient) Recv() (*ReadRowsResponse, error) {
   275  	m := new(ReadRowsResponse)
   276  	if err := x.ClientStream.RecvMsg(m); err != nil {
   277  		return nil, err
   278  	}
   279  	return m, nil
   280  }
   281  
   282  func (c *bigtableServiceClient) SampleRowKeys(ctx context.Context, in *SampleRowKeysRequest, opts ...grpc.CallOption) (BigtableService_SampleRowKeysClient, error) {
   283  	stream, err := c.cc.NewStream(ctx, &_BigtableService_serviceDesc.Streams[1], "/google.bigtable.v1.BigtableService/SampleRowKeys", opts...)
   284  	if err != nil {
   285  		return nil, err
   286  	}
   287  	x := &bigtableServiceSampleRowKeysClient{stream}
   288  	if err := x.ClientStream.SendMsg(in); err != nil {
   289  		return nil, err
   290  	}
   291  	if err := x.ClientStream.CloseSend(); err != nil {
   292  		return nil, err
   293  	}
   294  	return x, nil
   295  }
   296  
   297  type BigtableService_SampleRowKeysClient interface {
   298  	Recv() (*SampleRowKeysResponse, error)
   299  	grpc.ClientStream
   300  }
   301  
   302  type bigtableServiceSampleRowKeysClient struct {
   303  	grpc.ClientStream
   304  }
   305  
   306  func (x *bigtableServiceSampleRowKeysClient) Recv() (*SampleRowKeysResponse, error) {
   307  	m := new(SampleRowKeysResponse)
   308  	if err := x.ClientStream.RecvMsg(m); err != nil {
   309  		return nil, err
   310  	}
   311  	return m, nil
   312  }
   313  
   314  func (c *bigtableServiceClient) MutateRow(ctx context.Context, in *MutateRowRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
   315  	out := new(emptypb.Empty)
   316  	err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/MutateRow", in, out, opts...)
   317  	if err != nil {
   318  		return nil, err
   319  	}
   320  	return out, nil
   321  }
   322  
   323  func (c *bigtableServiceClient) MutateRows(ctx context.Context, in *MutateRowsRequest, opts ...grpc.CallOption) (*MutateRowsResponse, error) {
   324  	out := new(MutateRowsResponse)
   325  	err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/MutateRows", in, out, opts...)
   326  	if err != nil {
   327  		return nil, err
   328  	}
   329  	return out, nil
   330  }
   331  
   332  func (c *bigtableServiceClient) CheckAndMutateRow(ctx context.Context, in *CheckAndMutateRowRequest, opts ...grpc.CallOption) (*CheckAndMutateRowResponse, error) {
   333  	out := new(CheckAndMutateRowResponse)
   334  	err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/CheckAndMutateRow", in, out, opts...)
   335  	if err != nil {
   336  		return nil, err
   337  	}
   338  	return out, nil
   339  }
   340  
   341  func (c *bigtableServiceClient) ReadModifyWriteRow(ctx context.Context, in *ReadModifyWriteRowRequest, opts ...grpc.CallOption) (*Row, error) {
   342  	out := new(Row)
   343  	err := c.cc.Invoke(ctx, "/google.bigtable.v1.BigtableService/ReadModifyWriteRow", in, out, opts...)
   344  	if err != nil {
   345  		return nil, err
   346  	}
   347  	return out, nil
   348  }
   349  
   350  // BigtableServiceServer is the server API for BigtableService service.
   351  type BigtableServiceServer interface {
   352  	// Streams back the contents of all requested rows, optionally applying
   353  	// the same Reader filter to each. Depending on their size, rows may be
   354  	// broken up across multiple responses, but atomicity of each row will still
   355  	// be preserved.
   356  	ReadRows(*ReadRowsRequest, BigtableService_ReadRowsServer) error
   357  	// Returns a sample of row keys in the table. The returned row keys will
   358  	// delimit contiguous sections of the table of approximately equal size,
   359  	// which can be used to break up the data for distributed tasks like
   360  	// mapreduces.
   361  	SampleRowKeys(*SampleRowKeysRequest, BigtableService_SampleRowKeysServer) error
   362  	// Mutates a row atomically. Cells already present in the row are left
   363  	// unchanged unless explicitly changed by 'mutation'.
   364  	MutateRow(context.Context, *MutateRowRequest) (*emptypb.Empty, error)
   365  	// Mutates multiple rows in a batch. Each individual row is mutated
   366  	// atomically as in MutateRow, but the entire batch is not executed
   367  	// atomically.
   368  	MutateRows(context.Context, *MutateRowsRequest) (*MutateRowsResponse, error)
   369  	// Mutates a row atomically based on the output of a predicate Reader filter.
   370  	CheckAndMutateRow(context.Context, *CheckAndMutateRowRequest) (*CheckAndMutateRowResponse, error)
   371  	// Modifies a row atomically, reading the latest existing timestamp/value from
   372  	// the specified columns and writing a new value at
   373  	// max(existing timestamp, current server time) based on pre-defined
   374  	// read/modify/write rules. Returns the new contents of all modified cells.
   375  	ReadModifyWriteRow(context.Context, *ReadModifyWriteRowRequest) (*Row, error)
   376  }
   377  
   378  // UnimplementedBigtableServiceServer can be embedded to have forward compatible implementations.
   379  type UnimplementedBigtableServiceServer struct {
   380  }
   381  
   382  func (*UnimplementedBigtableServiceServer) ReadRows(*ReadRowsRequest, BigtableService_ReadRowsServer) error {
   383  	return status.Errorf(codes.Unimplemented, "method ReadRows not implemented")
   384  }
   385  func (*UnimplementedBigtableServiceServer) SampleRowKeys(*SampleRowKeysRequest, BigtableService_SampleRowKeysServer) error {
   386  	return status.Errorf(codes.Unimplemented, "method SampleRowKeys not implemented")
   387  }
   388  func (*UnimplementedBigtableServiceServer) MutateRow(context.Context, *MutateRowRequest) (*emptypb.Empty, error) {
   389  	return nil, status.Errorf(codes.Unimplemented, "method MutateRow not implemented")
   390  }
   391  func (*UnimplementedBigtableServiceServer) MutateRows(context.Context, *MutateRowsRequest) (*MutateRowsResponse, error) {
   392  	return nil, status.Errorf(codes.Unimplemented, "method MutateRows not implemented")
   393  }
   394  func (*UnimplementedBigtableServiceServer) CheckAndMutateRow(context.Context, *CheckAndMutateRowRequest) (*CheckAndMutateRowResponse, error) {
   395  	return nil, status.Errorf(codes.Unimplemented, "method CheckAndMutateRow not implemented")
   396  }
   397  func (*UnimplementedBigtableServiceServer) ReadModifyWriteRow(context.Context, *ReadModifyWriteRowRequest) (*Row, error) {
   398  	return nil, status.Errorf(codes.Unimplemented, "method ReadModifyWriteRow not implemented")
   399  }
   400  
   401  func RegisterBigtableServiceServer(s *grpc.Server, srv BigtableServiceServer) {
   402  	s.RegisterService(&_BigtableService_serviceDesc, srv)
   403  }
   404  
   405  func _BigtableService_ReadRows_Handler(srv interface{}, stream grpc.ServerStream) error {
   406  	m := new(ReadRowsRequest)
   407  	if err := stream.RecvMsg(m); err != nil {
   408  		return err
   409  	}
   410  	return srv.(BigtableServiceServer).ReadRows(m, &bigtableServiceReadRowsServer{stream})
   411  }
   412  
   413  type BigtableService_ReadRowsServer interface {
   414  	Send(*ReadRowsResponse) error
   415  	grpc.ServerStream
   416  }
   417  
   418  type bigtableServiceReadRowsServer struct {
   419  	grpc.ServerStream
   420  }
   421  
   422  func (x *bigtableServiceReadRowsServer) Send(m *ReadRowsResponse) error {
   423  	return x.ServerStream.SendMsg(m)
   424  }
   425  
   426  func _BigtableService_SampleRowKeys_Handler(srv interface{}, stream grpc.ServerStream) error {
   427  	m := new(SampleRowKeysRequest)
   428  	if err := stream.RecvMsg(m); err != nil {
   429  		return err
   430  	}
   431  	return srv.(BigtableServiceServer).SampleRowKeys(m, &bigtableServiceSampleRowKeysServer{stream})
   432  }
   433  
   434  type BigtableService_SampleRowKeysServer interface {
   435  	Send(*SampleRowKeysResponse) error
   436  	grpc.ServerStream
   437  }
   438  
   439  type bigtableServiceSampleRowKeysServer struct {
   440  	grpc.ServerStream
   441  }
   442  
   443  func (x *bigtableServiceSampleRowKeysServer) Send(m *SampleRowKeysResponse) error {
   444  	return x.ServerStream.SendMsg(m)
   445  }
   446  
   447  func _BigtableService_MutateRow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   448  	in := new(MutateRowRequest)
   449  	if err := dec(in); err != nil {
   450  		return nil, err
   451  	}
   452  	if interceptor == nil {
   453  		return srv.(BigtableServiceServer).MutateRow(ctx, in)
   454  	}
   455  	info := &grpc.UnaryServerInfo{
   456  		Server:     srv,
   457  		FullMethod: "/google.bigtable.v1.BigtableService/MutateRow",
   458  	}
   459  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   460  		return srv.(BigtableServiceServer).MutateRow(ctx, req.(*MutateRowRequest))
   461  	}
   462  	return interceptor(ctx, in, info, handler)
   463  }
   464  
   465  func _BigtableService_MutateRows_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   466  	in := new(MutateRowsRequest)
   467  	if err := dec(in); err != nil {
   468  		return nil, err
   469  	}
   470  	if interceptor == nil {
   471  		return srv.(BigtableServiceServer).MutateRows(ctx, in)
   472  	}
   473  	info := &grpc.UnaryServerInfo{
   474  		Server:     srv,
   475  		FullMethod: "/google.bigtable.v1.BigtableService/MutateRows",
   476  	}
   477  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   478  		return srv.(BigtableServiceServer).MutateRows(ctx, req.(*MutateRowsRequest))
   479  	}
   480  	return interceptor(ctx, in, info, handler)
   481  }
   482  
   483  func _BigtableService_CheckAndMutateRow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   484  	in := new(CheckAndMutateRowRequest)
   485  	if err := dec(in); err != nil {
   486  		return nil, err
   487  	}
   488  	if interceptor == nil {
   489  		return srv.(BigtableServiceServer).CheckAndMutateRow(ctx, in)
   490  	}
   491  	info := &grpc.UnaryServerInfo{
   492  		Server:     srv,
   493  		FullMethod: "/google.bigtable.v1.BigtableService/CheckAndMutateRow",
   494  	}
   495  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   496  		return srv.(BigtableServiceServer).CheckAndMutateRow(ctx, req.(*CheckAndMutateRowRequest))
   497  	}
   498  	return interceptor(ctx, in, info, handler)
   499  }
   500  
   501  func _BigtableService_ReadModifyWriteRow_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
   502  	in := new(ReadModifyWriteRowRequest)
   503  	if err := dec(in); err != nil {
   504  		return nil, err
   505  	}
   506  	if interceptor == nil {
   507  		return srv.(BigtableServiceServer).ReadModifyWriteRow(ctx, in)
   508  	}
   509  	info := &grpc.UnaryServerInfo{
   510  		Server:     srv,
   511  		FullMethod: "/google.bigtable.v1.BigtableService/ReadModifyWriteRow",
   512  	}
   513  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
   514  		return srv.(BigtableServiceServer).ReadModifyWriteRow(ctx, req.(*ReadModifyWriteRowRequest))
   515  	}
   516  	return interceptor(ctx, in, info, handler)
   517  }
   518  
   519  var _BigtableService_serviceDesc = grpc.ServiceDesc{
   520  	ServiceName: "google.bigtable.v1.BigtableService",
   521  	HandlerType: (*BigtableServiceServer)(nil),
   522  	Methods: []grpc.MethodDesc{
   523  		{
   524  			MethodName: "MutateRow",
   525  			Handler:    _BigtableService_MutateRow_Handler,
   526  		},
   527  		{
   528  			MethodName: "MutateRows",
   529  			Handler:    _BigtableService_MutateRows_Handler,
   530  		},
   531  		{
   532  			MethodName: "CheckAndMutateRow",
   533  			Handler:    _BigtableService_CheckAndMutateRow_Handler,
   534  		},
   535  		{
   536  			MethodName: "ReadModifyWriteRow",
   537  			Handler:    _BigtableService_ReadModifyWriteRow_Handler,
   538  		},
   539  	},
   540  	Streams: []grpc.StreamDesc{
   541  		{
   542  			StreamName:    "ReadRows",
   543  			Handler:       _BigtableService_ReadRows_Handler,
   544  			ServerStreams: true,
   545  		},
   546  		{
   547  			StreamName:    "SampleRowKeys",
   548  			Handler:       _BigtableService_SampleRowKeys_Handler,
   549  			ServerStreams: true,
   550  		},
   551  	},
   552  	Metadata: "google/bigtable/v1/bigtable_service.proto",
   553  }
   554  

View as plain text