stream.pb.go

Documentation: google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1alpha2

     1  // Copyright 2021 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.25.0-devel
    18  // 	protoc        v3.13.0
    19  // source: google/cloud/bigquery/storage/v1alpha2/stream.proto
    20  
    21  package storage
    22  
    23  import (
    24  	reflect "reflect"
    25  	sync "sync"
    26  
    27  	proto "github.com/golang/protobuf/proto"
    28  	_ "google.golang.org/genproto/googleapis/api/annotations"
    29  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    30  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    31  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    32  )
    33  
    34  const (
    35  	// Verify that this generated code is sufficiently up-to-date.
    36  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    37  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    38  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    39  )
    40  
    41  // This is a compile-time assertion that a sufficiently up-to-date version
    42  // of the legacy proto package is being used.
    43  const _ = proto.ProtoPackageIsVersion4
    44  
    45  type WriteStream_Type int32
    46  
    47  const (
    48  	// Unknown type.
    49  	WriteStream_TYPE_UNSPECIFIED WriteStream_Type = 0
    50  	// Data will commit automatically and appear as soon as the write is
    51  	// acknowledged.
    52  	WriteStream_COMMITTED WriteStream_Type = 1
    53  	// Data is invisible until the stream is committed.
    54  	WriteStream_PENDING WriteStream_Type = 2
    55  	// Data is only visible up to the offset to which it was flushed.
    56  	WriteStream_BUFFERED WriteStream_Type = 3
    57  )
    58  
    59  // Enum value maps for WriteStream_Type.
    60  var (
    61  	WriteStream_Type_name = map[int32]string{
    62  		0: "TYPE_UNSPECIFIED",
    63  		1: "COMMITTED",
    64  		2: "PENDING",
    65  		3: "BUFFERED",
    66  	}
    67  	WriteStream_Type_value = map[string]int32{
    68  		"TYPE_UNSPECIFIED": 0,
    69  		"COMMITTED":        1,
    70  		"PENDING":          2,
    71  		"BUFFERED":         3,
    72  	}
    73  )
    74  
    75  func (x WriteStream_Type) Enum() *WriteStream_Type {
    76  	p := new(WriteStream_Type)
    77  	*p = x
    78  	return p
    79  }
    80  
    81  func (x WriteStream_Type) String() string {
    82  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    83  }
    84  
    85  func (WriteStream_Type) Descriptor() protoreflect.EnumDescriptor {
    86  	return file_google_cloud_bigquery_storage_v1alpha2_stream_proto_enumTypes[0].Descriptor()
    87  }
    88  
    89  func (WriteStream_Type) Type() protoreflect.EnumType {
    90  	return &file_google_cloud_bigquery_storage_v1alpha2_stream_proto_enumTypes[0]
    91  }
    92  
    93  func (x WriteStream_Type) Number() protoreflect.EnumNumber {
    94  	return protoreflect.EnumNumber(x)
    95  }
    96  
    97  // Deprecated: Use WriteStream_Type.Descriptor instead.
    98  func (WriteStream_Type) EnumDescriptor() ([]byte, []int) {
    99  	return file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescGZIP(), []int{0, 0}
   100  }
   101  
   102  // Information about a single stream that gets data inside the storage system.
   103  type WriteStream struct {
   104  	state         protoimpl.MessageState
   105  	sizeCache     protoimpl.SizeCache
   106  	unknownFields protoimpl.UnknownFields
   107  
   108  	// Output only. Name of the stream, in the form
   109  	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
   110  	Name string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   111  	Type WriteStream_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.bigquery.storage.v1alpha2.WriteStream_Type" json:"type,omitempty"`
   112  	// Output only. Create time of the stream. For the _default stream, this is the
   113  	// creation_time of the table.
   114  	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
   115  	// Output only. Commit time of the stream.
   116  	// If a stream is of `COMMITTED` type, then it will have a commit_time same as
   117  	// `create_time`. If the stream is of `PENDING` type, commit_time being empty
   118  	// means it is not committed.
   119  	CommitTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
   120  	// Output only. The schema of the destination table. It is only returned in
   121  	// `CreateWriteStream` response. Caller should generate data that's
   122  	// compatible with this schema to send in initial `AppendRowsRequest`.
   123  	// The table schema could go out of date during the life time of the stream.
   124  	TableSchema *TableSchema `protobuf:"bytes,5,opt,name=table_schema,json=tableSchema,proto3" json:"table_schema,omitempty"`
   125  	// Id set by client to annotate its identity.
   126  	ExternalId string `protobuf:"bytes,6,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
   127  }
   128  
   129  func (x *WriteStream) Reset() {
   130  	*x = WriteStream{}
   131  	if protoimpl.UnsafeEnabled {
   132  		mi := &file_google_cloud_bigquery_storage_v1alpha2_stream_proto_msgTypes[0]
   133  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   134  		ms.StoreMessageInfo(mi)
   135  	}
   136  }
   137  
   138  func (x *WriteStream) String() string {
   139  	return protoimpl.X.MessageStringOf(x)
   140  }
   141  
   142  func (*WriteStream) ProtoMessage() {}
   143  
   144  func (x *WriteStream) ProtoReflect() protoreflect.Message {
   145  	mi := &file_google_cloud_bigquery_storage_v1alpha2_stream_proto_msgTypes[0]
   146  	if protoimpl.UnsafeEnabled && x != nil {
   147  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   148  		if ms.LoadMessageInfo() == nil {
   149  			ms.StoreMessageInfo(mi)
   150  		}
   151  		return ms
   152  	}
   153  	return mi.MessageOf(x)
   154  }
   155  
   156  // Deprecated: Use WriteStream.ProtoReflect.Descriptor instead.
   157  func (*WriteStream) Descriptor() ([]byte, []int) {
   158  	return file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescGZIP(), []int{0}
   159  }
   160  
   161  func (x *WriteStream) GetName() string {
   162  	if x != nil {
   163  		return x.Name
   164  	}
   165  	return ""
   166  }
   167  
   168  func (x *WriteStream) GetType() WriteStream_Type {
   169  	if x != nil {
   170  		return x.Type
   171  	}
   172  	return WriteStream_TYPE_UNSPECIFIED
   173  }
   174  
   175  func (x *WriteStream) GetCreateTime() *timestamppb.Timestamp {
   176  	if x != nil {
   177  		return x.CreateTime
   178  	}
   179  	return nil
   180  }
   181  
   182  func (x *WriteStream) GetCommitTime() *timestamppb.Timestamp {
   183  	if x != nil {
   184  		return x.CommitTime
   185  	}
   186  	return nil
   187  }
   188  
   189  func (x *WriteStream) GetTableSchema() *TableSchema {
   190  	if x != nil {
   191  		return x.TableSchema
   192  	}
   193  	return nil
   194  }
   195  
   196  func (x *WriteStream) GetExternalId() string {
   197  	if x != nil {
   198  		return x.ExternalId
   199  	}
   200  	return ""
   201  }
   202  
   203  var File_google_cloud_bigquery_storage_v1alpha2_stream_proto protoreflect.FileDescriptor
   204  
   205  var file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDesc = []byte{
   206  	0x0a, 0x33, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
   207  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
   208  	0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e,
   209  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x26, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
   210  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
   211  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x1a, 0x1f, 0x67,
   212  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f,
   213  	0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19,
   214  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75,
   215  	0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   216  	0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
   217  	0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61,
   218  	0x32, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67,
   219  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74,
   220  	0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xbb,
   221  	0x04, 0x0a, 0x0b, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17,
   222  	0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41,
   223  	0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x51, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18,
   224  	0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x38, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
   225  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
   226  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x57,
   227  	0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x42,
   228  	0x03, 0xe0, 0x41, 0x05, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72,
   229  	0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32,
   230  	0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
   231  	0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03,
   232  	0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b,
   233  	0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28,
   234  	0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
   235  	0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0,
   236  	0x41, 0x03, 0x52, 0x0a, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x5b,
   237  	0x0a, 0x0c, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x05,
   238  	0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
   239  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
   240  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x2e, 0x54, 0x61,
   241  	0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0b,
   242  	0x74, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x1f, 0x0a, 0x0b, 0x65,
   243  	0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x5f, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09,
   244  	0x52, 0x0a, 0x65, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x49, 0x64, 0x22, 0x46, 0x0a, 0x04,
   245  	0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53,
   246  	0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x43, 0x4f,
   247  	0x4d, 0x4d, 0x49, 0x54, 0x54, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x45, 0x4e,
   248  	0x44, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x12, 0x0c, 0x0a, 0x08, 0x42, 0x55, 0x46, 0x46, 0x45, 0x52,
   249  	0x45, 0x44, 0x10, 0x03, 0x3a, 0x76, 0xea, 0x41, 0x73, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75,
   250  	0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   251  	0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53,
   252  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x45, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
   253  	0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65,
   254  	0x74, 0x73, 0x2f, 0x7b, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x7d, 0x2f, 0x74, 0x61, 0x62,
   255  	0x6c, 0x65, 0x73, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65,
   256  	0x61, 0x6d, 0x73, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x7d, 0x42, 0xda, 0x01, 0x0a,
   257  	0x2a, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
   258  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
   259  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x32, 0x5a, 0x4d, 0x67, 0x6f, 0x6f,
   260  	0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67,
   261  	0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
   262  	0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
   263  	0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x61, 0x6c, 0x70, 0x68,
   264  	0x61, 0x32, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0xea, 0x41, 0x5c, 0x0a, 0x24, 0x62,
   265  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67,
   266  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61,
   267  	0x62, 0x6c, 0x65, 0x12, 0x34, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70,
   268  	0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73,
   269  	0x2f, 0x7b, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x7d, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65,
   270  	0x73, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x7d, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
   271  	0x33,
   272  }
   273  
   274  var (
   275  	file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescOnce sync.Once
   276  	file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescData = file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDesc
   277  )
   278  
   279  func file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescGZIP() []byte {
   280  	file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescOnce.Do(func() {
   281  		file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescData)
   282  	})
   283  	return file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDescData
   284  }
   285  
   286  var file_google_cloud_bigquery_storage_v1alpha2_stream_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
   287  var file_google_cloud_bigquery_storage_v1alpha2_stream_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
   288  var file_google_cloud_bigquery_storage_v1alpha2_stream_proto_goTypes = []interface{}{
   289  	(WriteStream_Type)(0),         // 0: google.cloud.bigquery.storage.v1alpha2.WriteStream.Type
   290  	(*WriteStream)(nil),           // 1: google.cloud.bigquery.storage.v1alpha2.WriteStream
   291  	(*timestamppb.Timestamp)(nil), // 2: google.protobuf.Timestamp
   292  	(*TableSchema)(nil),           // 3: google.cloud.bigquery.storage.v1alpha2.TableSchema
   293  }
   294  var file_google_cloud_bigquery_storage_v1alpha2_stream_proto_depIdxs = []int32{
   295  	0, // 0: google.cloud.bigquery.storage.v1alpha2.WriteStream.type:type_name -> google.cloud.bigquery.storage.v1alpha2.WriteStream.Type
   296  	2, // 1: google.cloud.bigquery.storage.v1alpha2.WriteStream.create_time:type_name -> google.protobuf.Timestamp
   297  	2, // 2: google.cloud.bigquery.storage.v1alpha2.WriteStream.commit_time:type_name -> google.protobuf.Timestamp
   298  	3, // 3: google.cloud.bigquery.storage.v1alpha2.WriteStream.table_schema:type_name -> google.cloud.bigquery.storage.v1alpha2.TableSchema
   299  	4, // [4:4] is the sub-list for method output_type
   300  	4, // [4:4] is the sub-list for method input_type
   301  	4, // [4:4] is the sub-list for extension type_name
   302  	4, // [4:4] is the sub-list for extension extendee
   303  	0, // [0:4] is the sub-list for field type_name
   304  }
   305  
   306  func init() { file_google_cloud_bigquery_storage_v1alpha2_stream_proto_init() }
   307  func file_google_cloud_bigquery_storage_v1alpha2_stream_proto_init() {
   308  	if File_google_cloud_bigquery_storage_v1alpha2_stream_proto != nil {
   309  		return
   310  	}
   311  	file_google_cloud_bigquery_storage_v1alpha2_table_proto_init()
   312  	if !protoimpl.UnsafeEnabled {
   313  		file_google_cloud_bigquery_storage_v1alpha2_stream_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   314  			switch v := v.(*WriteStream); i {
   315  			case 0:
   316  				return &v.state
   317  			case 1:
   318  				return &v.sizeCache
   319  			case 2:
   320  				return &v.unknownFields
   321  			default:
   322  				return nil
   323  			}
   324  		}
   325  	}
   326  	type x struct{}
   327  	out := protoimpl.TypeBuilder{
   328  		File: protoimpl.DescBuilder{
   329  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   330  			RawDescriptor: file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDesc,
   331  			NumEnums:      1,
   332  			NumMessages:   1,
   333  			NumExtensions: 0,
   334  			NumServices:   0,
   335  		},
   336  		GoTypes:           file_google_cloud_bigquery_storage_v1alpha2_stream_proto_goTypes,
   337  		DependencyIndexes: file_google_cloud_bigquery_storage_v1alpha2_stream_proto_depIdxs,
   338  		EnumInfos:         file_google_cloud_bigquery_storage_v1alpha2_stream_proto_enumTypes,
   339  		MessageInfos:      file_google_cloud_bigquery_storage_v1alpha2_stream_proto_msgTypes,
   340  	}.Build()
   341  	File_google_cloud_bigquery_storage_v1alpha2_stream_proto = out.File
   342  	file_google_cloud_bigquery_storage_v1alpha2_stream_proto_rawDesc = nil
   343  	file_google_cloud_bigquery_storage_v1alpha2_stream_proto_goTypes = nil
   344  	file_google_cloud_bigquery_storage_v1alpha2_stream_proto_depIdxs = nil
   345  }
   346
View as plain text