avro.pb.go

Documentation: cloud.google.com/go/bigquery/storage/apiv1/storagepb

     1  // Copyright 2023 Google LLC
     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.32.0
    18  // 	protoc        v4.25.2
    19  // source: google/cloud/bigquery/storage/v1/avro.proto
    20  
    21  package storagepb
    22  
    23  import (
    24  	reflect "reflect"
    25  	sync "sync"
    26  
    27  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    28  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    29  )
    30  
    31  const (
    32  	// Verify that this generated code is sufficiently up-to-date.
    33  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    34  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    35  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    36  )
    37  
    38  // Avro schema.
    39  type AvroSchema struct {
    40  	state         protoimpl.MessageState
    41  	sizeCache     protoimpl.SizeCache
    42  	unknownFields protoimpl.UnknownFields
    43  
    44  	// Json serialized schema, as described at
    45  	// https://avro.apache.org/docs/1.8.1/spec.html.
    46  	Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
    47  }
    48  
    49  func (x *AvroSchema) Reset() {
    50  	*x = AvroSchema{}
    51  	if protoimpl.UnsafeEnabled {
    52  		mi := &file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[0]
    53  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    54  		ms.StoreMessageInfo(mi)
    55  	}
    56  }
    57  
    58  func (x *AvroSchema) String() string {
    59  	return protoimpl.X.MessageStringOf(x)
    60  }
    61  
    62  func (*AvroSchema) ProtoMessage() {}
    63  
    64  func (x *AvroSchema) ProtoReflect() protoreflect.Message {
    65  	mi := &file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[0]
    66  	if protoimpl.UnsafeEnabled && x != nil {
    67  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    68  		if ms.LoadMessageInfo() == nil {
    69  			ms.StoreMessageInfo(mi)
    70  		}
    71  		return ms
    72  	}
    73  	return mi.MessageOf(x)
    74  }
    75  
    76  // Deprecated: Use AvroSchema.ProtoReflect.Descriptor instead.
    77  func (*AvroSchema) Descriptor() ([]byte, []int) {
    78  	return file_google_cloud_bigquery_storage_v1_avro_proto_rawDescGZIP(), []int{0}
    79  }
    80  
    81  func (x *AvroSchema) GetSchema() string {
    82  	if x != nil {
    83  		return x.Schema
    84  	}
    85  	return ""
    86  }
    87  
    88  // Avro rows.
    89  type AvroRows struct {
    90  	state         protoimpl.MessageState
    91  	sizeCache     protoimpl.SizeCache
    92  	unknownFields protoimpl.UnknownFields
    93  
    94  	// Binary serialized rows in a block.
    95  	SerializedBinaryRows []byte `protobuf:"bytes,1,opt,name=serialized_binary_rows,json=serializedBinaryRows,proto3" json:"serialized_binary_rows,omitempty"`
    96  	// [Deprecated] The count of rows in the returning block.
    97  	// Please use the format-independent ReadRowsResponse.row_count instead.
    98  	//
    99  	// Deprecated: Marked as deprecated in google/cloud/bigquery/storage/v1/avro.proto.
   100  	RowCount int64 `protobuf:"varint,2,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
   101  }
   102  
   103  func (x *AvroRows) Reset() {
   104  	*x = AvroRows{}
   105  	if protoimpl.UnsafeEnabled {
   106  		mi := &file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[1]
   107  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   108  		ms.StoreMessageInfo(mi)
   109  	}
   110  }
   111  
   112  func (x *AvroRows) String() string {
   113  	return protoimpl.X.MessageStringOf(x)
   114  }
   115  
   116  func (*AvroRows) ProtoMessage() {}
   117  
   118  func (x *AvroRows) ProtoReflect() protoreflect.Message {
   119  	mi := &file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[1]
   120  	if protoimpl.UnsafeEnabled && x != nil {
   121  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   122  		if ms.LoadMessageInfo() == nil {
   123  			ms.StoreMessageInfo(mi)
   124  		}
   125  		return ms
   126  	}
   127  	return mi.MessageOf(x)
   128  }
   129  
   130  // Deprecated: Use AvroRows.ProtoReflect.Descriptor instead.
   131  func (*AvroRows) Descriptor() ([]byte, []int) {
   132  	return file_google_cloud_bigquery_storage_v1_avro_proto_rawDescGZIP(), []int{1}
   133  }
   134  
   135  func (x *AvroRows) GetSerializedBinaryRows() []byte {
   136  	if x != nil {
   137  		return x.SerializedBinaryRows
   138  	}
   139  	return nil
   140  }
   141  
   142  // Deprecated: Marked as deprecated in google/cloud/bigquery/storage/v1/avro.proto.
   143  func (x *AvroRows) GetRowCount() int64 {
   144  	if x != nil {
   145  		return x.RowCount
   146  	}
   147  	return 0
   148  }
   149  
   150  // Contains options specific to Avro Serialization.
   151  type AvroSerializationOptions struct {
   152  	state         protoimpl.MessageState
   153  	sizeCache     protoimpl.SizeCache
   154  	unknownFields protoimpl.UnknownFields
   155  
   156  	// Enable displayName attribute in Avro schema.
   157  	//
   158  	// The Avro specification requires field names to be alphanumeric.  By
   159  	// default, in cases when column names do not conform to these requirements
   160  	// (e.g. non-ascii unicode codepoints) and Avro is requested as an output
   161  	// format, the CreateReadSession call will fail.
   162  	//
   163  	// Setting this field to true, populates avro field names with a placeholder
   164  	// value and populates a "displayName" attribute for every avro field with the
   165  	// original column name.
   166  	EnableDisplayNameAttribute bool `protobuf:"varint,1,opt,name=enable_display_name_attribute,json=enableDisplayNameAttribute,proto3" json:"enable_display_name_attribute,omitempty"`
   167  }
   168  
   169  func (x *AvroSerializationOptions) Reset() {
   170  	*x = AvroSerializationOptions{}
   171  	if protoimpl.UnsafeEnabled {
   172  		mi := &file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[2]
   173  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   174  		ms.StoreMessageInfo(mi)
   175  	}
   176  }
   177  
   178  func (x *AvroSerializationOptions) String() string {
   179  	return protoimpl.X.MessageStringOf(x)
   180  }
   181  
   182  func (*AvroSerializationOptions) ProtoMessage() {}
   183  
   184  func (x *AvroSerializationOptions) ProtoReflect() protoreflect.Message {
   185  	mi := &file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[2]
   186  	if protoimpl.UnsafeEnabled && x != nil {
   187  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   188  		if ms.LoadMessageInfo() == nil {
   189  			ms.StoreMessageInfo(mi)
   190  		}
   191  		return ms
   192  	}
   193  	return mi.MessageOf(x)
   194  }
   195  
   196  // Deprecated: Use AvroSerializationOptions.ProtoReflect.Descriptor instead.
   197  func (*AvroSerializationOptions) Descriptor() ([]byte, []int) {
   198  	return file_google_cloud_bigquery_storage_v1_avro_proto_rawDescGZIP(), []int{2}
   199  }
   200  
   201  func (x *AvroSerializationOptions) GetEnableDisplayNameAttribute() bool {
   202  	if x != nil {
   203  		return x.EnableDisplayNameAttribute
   204  	}
   205  	return false
   206  }
   207  
   208  var File_google_cloud_bigquery_storage_v1_avro_proto protoreflect.FileDescriptor
   209  
   210  var file_google_cloud_bigquery_storage_v1_avro_proto_rawDesc = []byte{
   211  	0x0a, 0x2b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
   212  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
   213  	0x76, 0x31, 0x2f, 0x61, 0x76, 0x72, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x20, 0x67,
   214  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
   215  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x22,
   216  	0x24, 0x0a, 0x0a, 0x41, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x16, 0x0a,
   217  	0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73,
   218  	0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x61, 0x0a, 0x08, 0x41, 0x76, 0x72, 0x6f, 0x52, 0x6f, 0x77,
   219  	0x73, 0x12, 0x34, 0x0a, 0x16, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f,
   220  	0x62, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x5f, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28,
   221  	0x0c, 0x52, 0x14, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x42, 0x69, 0x6e,
   222  	0x61, 0x72, 0x79, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x1f, 0x0a, 0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63,
   223  	0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x42, 0x02, 0x18, 0x01, 0x52, 0x08,
   224  	0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0x5d, 0x0a, 0x18, 0x41, 0x76, 0x72, 0x6f,
   225  	0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74,
   226  	0x69, 0x6f, 0x6e, 0x73, 0x12, 0x41, 0x0a, 0x1d, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x64,
   227  	0x69, 0x73, 0x70, 0x6c, 0x61, 0x79, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x5f, 0x61, 0x74, 0x74, 0x72,
   228  	0x69, 0x62, 0x75, 0x74, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x1a, 0x65, 0x6e, 0x61,
   229  	0x62, 0x6c, 0x65, 0x44, 0x69, 0x73, 0x70, 0x6c, 0x61, 0x79, 0x4e, 0x61, 0x6d, 0x65, 0x41, 0x74,
   230  	0x74, 0x72, 0x69, 0x62, 0x75, 0x74, 0x65, 0x42, 0xb9, 0x01, 0x0a, 0x24, 0x63, 0x6f, 0x6d, 0x2e,
   231  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
   232  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
   233  	0x42, 0x09, 0x41, 0x76, 0x72, 0x6f, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3e, 0x63,
   234  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
   235  	0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72,
   236  	0x61, 0x67, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x76, 0x31, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   237  	0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0xaa, 0x02, 0x20,
   238  	0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x42, 0x69, 0x67,
   239  	0x51, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x56, 0x31,
   240  	0xca, 0x02, 0x20, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c,
   241  	0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x5c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
   242  	0x5c, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   243  }
   244  
   245  var (
   246  	file_google_cloud_bigquery_storage_v1_avro_proto_rawDescOnce sync.Once
   247  	file_google_cloud_bigquery_storage_v1_avro_proto_rawDescData = file_google_cloud_bigquery_storage_v1_avro_proto_rawDesc
   248  )
   249  
   250  func file_google_cloud_bigquery_storage_v1_avro_proto_rawDescGZIP() []byte {
   251  	file_google_cloud_bigquery_storage_v1_avro_proto_rawDescOnce.Do(func() {
   252  		file_google_cloud_bigquery_storage_v1_avro_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1_avro_proto_rawDescData)
   253  	})
   254  	return file_google_cloud_bigquery_storage_v1_avro_proto_rawDescData
   255  }
   256  
   257  var file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
   258  var file_google_cloud_bigquery_storage_v1_avro_proto_goTypes = []interface{}{
   259  	(*AvroSchema)(nil),               // 0: google.cloud.bigquery.storage.v1.AvroSchema
   260  	(*AvroRows)(nil),                 // 1: google.cloud.bigquery.storage.v1.AvroRows
   261  	(*AvroSerializationOptions)(nil), // 2: google.cloud.bigquery.storage.v1.AvroSerializationOptions
   262  }
   263  var file_google_cloud_bigquery_storage_v1_avro_proto_depIdxs = []int32{
   264  	0, // [0:0] is the sub-list for method output_type
   265  	0, // [0:0] is the sub-list for method input_type
   266  	0, // [0:0] is the sub-list for extension type_name
   267  	0, // [0:0] is the sub-list for extension extendee
   268  	0, // [0:0] is the sub-list for field type_name
   269  }
   270  
   271  func init() { file_google_cloud_bigquery_storage_v1_avro_proto_init() }
   272  func file_google_cloud_bigquery_storage_v1_avro_proto_init() {
   273  	if File_google_cloud_bigquery_storage_v1_avro_proto != nil {
   274  		return
   275  	}
   276  	if !protoimpl.UnsafeEnabled {
   277  		file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   278  			switch v := v.(*AvroSchema); i {
   279  			case 0:
   280  				return &v.state
   281  			case 1:
   282  				return &v.sizeCache
   283  			case 2:
   284  				return &v.unknownFields
   285  			default:
   286  				return nil
   287  			}
   288  		}
   289  		file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   290  			switch v := v.(*AvroRows); i {
   291  			case 0:
   292  				return &v.state
   293  			case 1:
   294  				return &v.sizeCache
   295  			case 2:
   296  				return &v.unknownFields
   297  			default:
   298  				return nil
   299  			}
   300  		}
   301  		file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   302  			switch v := v.(*AvroSerializationOptions); i {
   303  			case 0:
   304  				return &v.state
   305  			case 1:
   306  				return &v.sizeCache
   307  			case 2:
   308  				return &v.unknownFields
   309  			default:
   310  				return nil
   311  			}
   312  		}
   313  	}
   314  	type x struct{}
   315  	out := protoimpl.TypeBuilder{
   316  		File: protoimpl.DescBuilder{
   317  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   318  			RawDescriptor: file_google_cloud_bigquery_storage_v1_avro_proto_rawDesc,
   319  			NumEnums:      0,
   320  			NumMessages:   3,
   321  			NumExtensions: 0,
   322  			NumServices:   0,
   323  		},
   324  		GoTypes:           file_google_cloud_bigquery_storage_v1_avro_proto_goTypes,
   325  		DependencyIndexes: file_google_cloud_bigquery_storage_v1_avro_proto_depIdxs,
   326  		MessageInfos:      file_google_cloud_bigquery_storage_v1_avro_proto_msgTypes,
   327  	}.Build()
   328  	File_google_cloud_bigquery_storage_v1_avro_proto = out.File
   329  	file_google_cloud_bigquery_storage_v1_avro_proto_rawDesc = nil
   330  	file_google_cloud_bigquery_storage_v1_avro_proto_goTypes = nil
   331  	file_google_cloud_bigquery_storage_v1_avro_proto_depIdxs = nil
   332  }
   333
View as plain text