...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23 package datastream
24
25 import (
26 src "cloud.google.com/go/datastream/apiv1/datastreampb"
27 grpc "google.golang.org/grpc"
28 )
29
30
31 const (
32 BackfillJob_ACTIVE = src.BackfillJob_ACTIVE
33 BackfillJob_AUTOMATIC = src.BackfillJob_AUTOMATIC
34 BackfillJob_COMPLETED = src.BackfillJob_COMPLETED
35 BackfillJob_FAILED = src.BackfillJob_FAILED
36 BackfillJob_MANUAL = src.BackfillJob_MANUAL
37 BackfillJob_NOT_STARTED = src.BackfillJob_NOT_STARTED
38 BackfillJob_PENDING = src.BackfillJob_PENDING
39 BackfillJob_STATE_UNSPECIFIED = src.BackfillJob_STATE_UNSPECIFIED
40 BackfillJob_STOPPED = src.BackfillJob_STOPPED
41 BackfillJob_TRIGGER_UNSPECIFIED = src.BackfillJob_TRIGGER_UNSPECIFIED
42 BackfillJob_UNSUPPORTED = src.BackfillJob_UNSUPPORTED
43 JsonFileFormat_AVRO_SCHEMA_FILE = src.JsonFileFormat_AVRO_SCHEMA_FILE
44 JsonFileFormat_GZIP = src.JsonFileFormat_GZIP
45 JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED = src.JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED
46 JsonFileFormat_NO_COMPRESSION = src.JsonFileFormat_NO_COMPRESSION
47 JsonFileFormat_NO_SCHEMA_FILE = src.JsonFileFormat_NO_SCHEMA_FILE
48 JsonFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED = src.JsonFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED
49 PrivateConnection_CREATED = src.PrivateConnection_CREATED
50 PrivateConnection_CREATING = src.PrivateConnection_CREATING
51 PrivateConnection_DELETING = src.PrivateConnection_DELETING
52 PrivateConnection_FAILED = src.PrivateConnection_FAILED
53 PrivateConnection_FAILED_TO_DELETE = src.PrivateConnection_FAILED_TO_DELETE
54 PrivateConnection_STATE_UNSPECIFIED = src.PrivateConnection_STATE_UNSPECIFIED
55 Stream_DRAINING = src.Stream_DRAINING
56 Stream_FAILED = src.Stream_FAILED
57 Stream_FAILED_PERMANENTLY = src.Stream_FAILED_PERMANENTLY
58 Stream_MAINTENANCE = src.Stream_MAINTENANCE
59 Stream_NOT_STARTED = src.Stream_NOT_STARTED
60 Stream_PAUSED = src.Stream_PAUSED
61 Stream_RUNNING = src.Stream_RUNNING
62 Stream_STARTING = src.Stream_STARTING
63 Stream_STATE_UNSPECIFIED = src.Stream_STATE_UNSPECIFIED
64 ValidationMessage_ERROR = src.ValidationMessage_ERROR
65 ValidationMessage_LEVEL_UNSPECIFIED = src.ValidationMessage_LEVEL_UNSPECIFIED
66 ValidationMessage_WARNING = src.ValidationMessage_WARNING
67 Validation_FAILED = src.Validation_FAILED
68 Validation_NOT_EXECUTED = src.Validation_NOT_EXECUTED
69 Validation_PASSED = src.Validation_PASSED
70 Validation_STATE_UNSPECIFIED = src.Validation_STATE_UNSPECIFIED
71 )
72
73
74 var (
75 BackfillJob_State_name = src.BackfillJob_State_name
76 BackfillJob_State_value = src.BackfillJob_State_value
77 BackfillJob_Trigger_name = src.BackfillJob_Trigger_name
78 BackfillJob_Trigger_value = src.BackfillJob_Trigger_value
79 File_google_cloud_datastream_v1_datastream_proto = src.File_google_cloud_datastream_v1_datastream_proto
80 File_google_cloud_datastream_v1_datastream_resources_proto = src.File_google_cloud_datastream_v1_datastream_resources_proto
81 JsonFileFormat_JsonCompression_name = src.JsonFileFormat_JsonCompression_name
82 JsonFileFormat_JsonCompression_value = src.JsonFileFormat_JsonCompression_value
83 JsonFileFormat_SchemaFileFormat_name = src.JsonFileFormat_SchemaFileFormat_name
84 JsonFileFormat_SchemaFileFormat_value = src.JsonFileFormat_SchemaFileFormat_value
85 PrivateConnection_State_name = src.PrivateConnection_State_name
86 PrivateConnection_State_value = src.PrivateConnection_State_value
87 Stream_State_name = src.Stream_State_name
88 Stream_State_value = src.Stream_State_value
89 ValidationMessage_Level_name = src.ValidationMessage_Level_name
90 ValidationMessage_Level_value = src.ValidationMessage_Level_value
91 Validation_State_name = src.Validation_State_name
92 Validation_State_value = src.Validation_State_value
93 )
94
95
96
97
98 type AvroFileFormat = src.AvroFileFormat
99
100
101
102
103 type BackfillJob = src.BackfillJob
104
105
106
107
108 type BackfillJob_State = src.BackfillJob_State
109
110
111
112
113 type BackfillJob_Trigger = src.BackfillJob_Trigger
114 type BigQueryDestinationConfig = src.BigQueryDestinationConfig
115
116
117
118
119 type BigQueryDestinationConfig_SingleTargetDataset = src.BigQueryDestinationConfig_SingleTargetDataset
120 type BigQueryDestinationConfig_SingleTargetDataset_ = src.BigQueryDestinationConfig_SingleTargetDataset_
121
122
123
124
125
126 type BigQueryDestinationConfig_SourceHierarchyDatasets = src.BigQueryDestinationConfig_SourceHierarchyDatasets
127 type BigQueryDestinationConfig_SourceHierarchyDatasets_ = src.BigQueryDestinationConfig_SourceHierarchyDatasets_
128
129
130
131
132 type BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate = src.BigQueryDestinationConfig_SourceHierarchyDatasets_DatasetTemplate
133
134
135
136
137 type BigQueryProfile = src.BigQueryProfile
138
139
140
141
142
143 type ConnectionProfile = src.ConnectionProfile
144 type ConnectionProfile_BigqueryProfile = src.ConnectionProfile_BigqueryProfile
145 type ConnectionProfile_ForwardSshConnectivity = src.ConnectionProfile_ForwardSshConnectivity
146 type ConnectionProfile_GcsProfile = src.ConnectionProfile_GcsProfile
147 type ConnectionProfile_MysqlProfile = src.ConnectionProfile_MysqlProfile
148 type ConnectionProfile_OracleProfile = src.ConnectionProfile_OracleProfile
149 type ConnectionProfile_PostgresqlProfile = src.ConnectionProfile_PostgresqlProfile
150 type ConnectionProfile_PrivateConnectivity = src.ConnectionProfile_PrivateConnectivity
151 type ConnectionProfile_StaticServiceIpConnectivity = src.ConnectionProfile_StaticServiceIpConnectivity
152
153
154
155
156 type CreateConnectionProfileRequest = src.CreateConnectionProfileRequest
157
158
159
160
161 type CreatePrivateConnectionRequest = src.CreatePrivateConnectionRequest
162
163
164
165
166 type CreateRouteRequest = src.CreateRouteRequest
167
168
169
170
171 type CreateStreamRequest = src.CreateStreamRequest
172
173
174
175
176
177
178 type DatastreamClient = src.DatastreamClient
179
180
181
182
183 type DatastreamServer = src.DatastreamServer
184
185
186
187
188 type DeleteConnectionProfileRequest = src.DeleteConnectionProfileRequest
189
190
191
192
193 type DeletePrivateConnectionRequest = src.DeletePrivateConnectionRequest
194
195
196
197
198 type DeleteRouteRequest = src.DeleteRouteRequest
199
200
201
202
203 type DeleteStreamRequest = src.DeleteStreamRequest
204
205
206
207
208 type DestinationConfig = src.DestinationConfig
209 type DestinationConfig_BigqueryDestinationConfig = src.DestinationConfig_BigqueryDestinationConfig
210 type DestinationConfig_GcsDestinationConfig = src.DestinationConfig_GcsDestinationConfig
211
212
213
214
215 type DiscoverConnectionProfileRequest = src.DiscoverConnectionProfileRequest
216 type DiscoverConnectionProfileRequest_ConnectionProfile = src.DiscoverConnectionProfileRequest_ConnectionProfile
217 type DiscoverConnectionProfileRequest_ConnectionProfileName = src.DiscoverConnectionProfileRequest_ConnectionProfileName
218 type DiscoverConnectionProfileRequest_FullHierarchy = src.DiscoverConnectionProfileRequest_FullHierarchy
219 type DiscoverConnectionProfileRequest_HierarchyDepth = src.DiscoverConnectionProfileRequest_HierarchyDepth
220 type DiscoverConnectionProfileRequest_MysqlRdbms = src.DiscoverConnectionProfileRequest_MysqlRdbms
221 type DiscoverConnectionProfileRequest_OracleRdbms = src.DiscoverConnectionProfileRequest_OracleRdbms
222 type DiscoverConnectionProfileRequest_PostgresqlRdbms = src.DiscoverConnectionProfileRequest_PostgresqlRdbms
223
224
225
226
227 type DiscoverConnectionProfileResponse = src.DiscoverConnectionProfileResponse
228 type DiscoverConnectionProfileResponse_MysqlRdbms = src.DiscoverConnectionProfileResponse_MysqlRdbms
229 type DiscoverConnectionProfileResponse_OracleRdbms = src.DiscoverConnectionProfileResponse_OracleRdbms
230 type DiscoverConnectionProfileResponse_PostgresqlRdbms = src.DiscoverConnectionProfileResponse_PostgresqlRdbms
231
232
233
234
235 type Error = src.Error
236
237
238
239
240 type FetchStaticIpsRequest = src.FetchStaticIpsRequest
241
242
243
244
245 type FetchStaticIpsResponse = src.FetchStaticIpsResponse
246
247
248
249
250 type ForwardSshTunnelConnectivity = src.ForwardSshTunnelConnectivity
251 type ForwardSshTunnelConnectivity_Password = src.ForwardSshTunnelConnectivity_Password
252 type ForwardSshTunnelConnectivity_PrivateKey = src.ForwardSshTunnelConnectivity_PrivateKey
253
254
255
256
257 type GcsDestinationConfig = src.GcsDestinationConfig
258 type GcsDestinationConfig_AvroFileFormat = src.GcsDestinationConfig_AvroFileFormat
259 type GcsDestinationConfig_JsonFileFormat = src.GcsDestinationConfig_JsonFileFormat
260
261
262
263
264 type GcsProfile = src.GcsProfile
265
266
267
268
269 type GetConnectionProfileRequest = src.GetConnectionProfileRequest
270
271
272
273
274 type GetPrivateConnectionRequest = src.GetPrivateConnectionRequest
275
276
277
278
279 type GetRouteRequest = src.GetRouteRequest
280
281
282
283
284 type GetStreamObjectRequest = src.GetStreamObjectRequest
285
286
287
288
289 type GetStreamRequest = src.GetStreamRequest
290
291
292
293
294 type JsonFileFormat = src.JsonFileFormat
295
296
297
298
299 type JsonFileFormat_JsonCompression = src.JsonFileFormat_JsonCompression
300
301
302
303
304 type JsonFileFormat_SchemaFileFormat = src.JsonFileFormat_SchemaFileFormat
305
306
307
308
309 type ListConnectionProfilesRequest = src.ListConnectionProfilesRequest
310
311
312
313
314 type ListConnectionProfilesResponse = src.ListConnectionProfilesResponse
315
316
317
318
319 type ListPrivateConnectionsRequest = src.ListPrivateConnectionsRequest
320
321
322
323
324 type ListPrivateConnectionsResponse = src.ListPrivateConnectionsResponse
325
326
327
328
329 type ListRoutesRequest = src.ListRoutesRequest
330
331
332
333
334 type ListRoutesResponse = src.ListRoutesResponse
335
336
337
338
339 type ListStreamObjectsRequest = src.ListStreamObjectsRequest
340
341
342
343
344 type ListStreamObjectsResponse = src.ListStreamObjectsResponse
345
346
347
348
349 type ListStreamsRequest = src.ListStreamsRequest
350
351
352
353
354 type ListStreamsResponse = src.ListStreamsResponse
355
356
357
358
359
360 type LookupStreamObjectRequest = src.LookupStreamObjectRequest
361
362
363
364
365 type MysqlColumn = src.MysqlColumn
366
367
368
369
370 type MysqlDatabase = src.MysqlDatabase
371
372
373
374
375 type MysqlProfile = src.MysqlProfile
376
377
378
379
380 type MysqlRdbms = src.MysqlRdbms
381
382
383
384
385 type MysqlSourceConfig = src.MysqlSourceConfig
386
387
388
389
390 type MysqlSslConfig = src.MysqlSslConfig
391
392
393
394
395 type MysqlTable = src.MysqlTable
396
397
398
399
400 type OperationMetadata = src.OperationMetadata
401
402
403
404
405 type OracleColumn = src.OracleColumn
406
407
408
409
410 type OracleProfile = src.OracleProfile
411
412
413
414
415 type OracleRdbms = src.OracleRdbms
416
417
418
419
420 type OracleSchema = src.OracleSchema
421
422
423
424
425 type OracleSourceConfig = src.OracleSourceConfig
426
427
428
429
430 type OracleSourceConfig_DropLargeObjects = src.OracleSourceConfig_DropLargeObjects
431 type OracleSourceConfig_DropLargeObjects_ = src.OracleSourceConfig_DropLargeObjects_
432
433
434
435
436 type OracleSourceConfig_StreamLargeObjects = src.OracleSourceConfig_StreamLargeObjects
437 type OracleSourceConfig_StreamLargeObjects_ = src.OracleSourceConfig_StreamLargeObjects_
438
439
440
441
442 type OracleTable = src.OracleTable
443
444
445
446
447 type PostgresqlColumn = src.PostgresqlColumn
448
449
450
451
452 type PostgresqlProfile = src.PostgresqlProfile
453
454
455
456
457 type PostgresqlRdbms = src.PostgresqlRdbms
458
459
460
461
462 type PostgresqlSchema = src.PostgresqlSchema
463
464
465
466
467 type PostgresqlSourceConfig = src.PostgresqlSourceConfig
468
469
470
471
472 type PostgresqlTable = src.PostgresqlTable
473
474
475
476
477
478 type PrivateConnection = src.PrivateConnection
479
480
481
482
483 type PrivateConnection_State = src.PrivateConnection_State
484
485
486
487
488 type PrivateConnectivity = src.PrivateConnectivity
489
490
491
492
493
494 type Route = src.Route
495
496
497
498
499 type SourceConfig = src.SourceConfig
500 type SourceConfig_MysqlSourceConfig = src.SourceConfig_MysqlSourceConfig
501 type SourceConfig_OracleSourceConfig = src.SourceConfig_OracleSourceConfig
502 type SourceConfig_PostgresqlSourceConfig = src.SourceConfig_PostgresqlSourceConfig
503
504
505
506
507 type SourceObjectIdentifier = src.SourceObjectIdentifier
508 type SourceObjectIdentifier_MysqlIdentifier = src.SourceObjectIdentifier_MysqlIdentifier
509
510
511
512
513 type SourceObjectIdentifier_MysqlObjectIdentifier = src.SourceObjectIdentifier_MysqlObjectIdentifier
514 type SourceObjectIdentifier_OracleIdentifier = src.SourceObjectIdentifier_OracleIdentifier
515
516
517
518
519 type SourceObjectIdentifier_OracleObjectIdentifier = src.SourceObjectIdentifier_OracleObjectIdentifier
520 type SourceObjectIdentifier_PostgresqlIdentifier = src.SourceObjectIdentifier_PostgresqlIdentifier
521
522
523
524
525 type SourceObjectIdentifier_PostgresqlObjectIdentifier = src.SourceObjectIdentifier_PostgresqlObjectIdentifier
526
527
528
529
530
531 type StartBackfillJobRequest = src.StartBackfillJobRequest
532
533
534
535
536
537 type StartBackfillJobResponse = src.StartBackfillJobResponse
538
539
540
541
542 type StaticServiceIpConnectivity = src.StaticServiceIpConnectivity
543
544
545
546
547
548 type StopBackfillJobRequest = src.StopBackfillJobRequest
549
550
551
552
553 type StopBackfillJobResponse = src.StopBackfillJobResponse
554
555
556
557
558 type Stream = src.Stream
559
560
561
562
563 type StreamObject = src.StreamObject
564 type Stream_BackfillAll = src.Stream_BackfillAll
565
566
567
568
569
570 type Stream_BackfillAllStrategy = src.Stream_BackfillAllStrategy
571 type Stream_BackfillAllStrategy_MysqlExcludedObjects = src.Stream_BackfillAllStrategy_MysqlExcludedObjects
572 type Stream_BackfillAllStrategy_OracleExcludedObjects = src.Stream_BackfillAllStrategy_OracleExcludedObjects
573 type Stream_BackfillAllStrategy_PostgresqlExcludedObjects = src.Stream_BackfillAllStrategy_PostgresqlExcludedObjects
574 type Stream_BackfillNone = src.Stream_BackfillNone
575
576
577
578
579 type Stream_BackfillNoneStrategy = src.Stream_BackfillNoneStrategy
580
581
582
583
584 type Stream_State = src.Stream_State
585
586
587
588
589
590 type UnimplementedDatastreamServer = src.UnimplementedDatastreamServer
591
592
593
594
595 type UpdateConnectionProfileRequest = src.UpdateConnectionProfileRequest
596
597
598
599
600 type UpdateStreamRequest = src.UpdateStreamRequest
601
602
603
604
605 type Validation = src.Validation
606
607
608
609
610 type ValidationMessage = src.ValidationMessage
611
612
613
614
615 type ValidationMessage_Level = src.ValidationMessage_Level
616
617
618
619
620 type ValidationResult = src.ValidationResult
621
622
623
624
625 type Validation_State = src.Validation_State
626
627
628
629
630
631 type VpcPeeringConfig = src.VpcPeeringConfig
632
633
634 func NewDatastreamClient(cc grpc.ClientConnInterface) DatastreamClient {
635 return src.NewDatastreamClient(cc)
636 }
637
638
639 func RegisterDatastreamServer(s *grpc.Server, srv DatastreamServer) {
640 src.RegisterDatastreamServer(s, srv)
641 }
642
View as plain text