...
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/apiv1alpha1/datastreampb"
27 grpc "google.golang.org/grpc"
28 )
29
30
31 const (
32 GcsFileFormat_AVRO = src.GcsFileFormat_AVRO
33 GcsFileFormat_GCS_FILE_FORMAT_UNSPECIFIED = src.GcsFileFormat_GCS_FILE_FORMAT_UNSPECIFIED
34 JsonFileFormat_GZIP = src.JsonFileFormat_GZIP
35 JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED = src.JsonFileFormat_JSON_COMPRESSION_UNSPECIFIED
36 JsonFileFormat_NO_COMPRESSION = src.JsonFileFormat_NO_COMPRESSION
37 PrivateConnection_CREATED = src.PrivateConnection_CREATED
38 PrivateConnection_CREATING = src.PrivateConnection_CREATING
39 PrivateConnection_FAILED = src.PrivateConnection_FAILED
40 PrivateConnection_STATE_UNSPECIFIED = src.PrivateConnection_STATE_UNSPECIFIED
41 SchemaFileFormat_AVRO_SCHEMA_FILE = src.SchemaFileFormat_AVRO_SCHEMA_FILE
42 SchemaFileFormat_NO_SCHEMA_FILE = src.SchemaFileFormat_NO_SCHEMA_FILE
43 SchemaFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED = src.SchemaFileFormat_SCHEMA_FILE_FORMAT_UNSPECIFIED
44 Stream_CREATED = src.Stream_CREATED
45 Stream_DRAINING = src.Stream_DRAINING
46 Stream_FAILED = src.Stream_FAILED
47 Stream_FAILED_PERMANENTLY = src.Stream_FAILED_PERMANENTLY
48 Stream_MAINTENANCE = src.Stream_MAINTENANCE
49 Stream_PAUSED = src.Stream_PAUSED
50 Stream_RUNNING = src.Stream_RUNNING
51 Stream_STARTING = src.Stream_STARTING
52 Stream_STATE_UNSPECIFIED = src.Stream_STATE_UNSPECIFIED
53 ValidationMessage_ERROR = src.ValidationMessage_ERROR
54 ValidationMessage_LEVEL_UNSPECIFIED = src.ValidationMessage_LEVEL_UNSPECIFIED
55 ValidationMessage_WARNING = src.ValidationMessage_WARNING
56 Validation_FAILED = src.Validation_FAILED
57 Validation_NOT_EXECUTED = src.Validation_NOT_EXECUTED
58 Validation_PASSED = src.Validation_PASSED
59 Validation_STATUS_UNSPECIFIED = src.Validation_STATUS_UNSPECIFIED
60 )
61
62
63 var (
64 File_google_cloud_datastream_v1alpha1_datastream_proto = src.File_google_cloud_datastream_v1alpha1_datastream_proto
65 File_google_cloud_datastream_v1alpha1_datastream_resources_proto = src.File_google_cloud_datastream_v1alpha1_datastream_resources_proto
66 GcsFileFormat_name = src.GcsFileFormat_name
67 GcsFileFormat_value = src.GcsFileFormat_value
68 JsonFileFormat_JsonCompression_name = src.JsonFileFormat_JsonCompression_name
69 JsonFileFormat_JsonCompression_value = src.JsonFileFormat_JsonCompression_value
70 PrivateConnection_State_name = src.PrivateConnection_State_name
71 PrivateConnection_State_value = src.PrivateConnection_State_value
72 SchemaFileFormat_name = src.SchemaFileFormat_name
73 SchemaFileFormat_value = src.SchemaFileFormat_value
74 Stream_State_name = src.Stream_State_name
75 Stream_State_value = src.Stream_State_value
76 ValidationMessage_Level_name = src.ValidationMessage_Level_name
77 ValidationMessage_Level_value = src.ValidationMessage_Level_value
78 Validation_Status_name = src.Validation_Status_name
79 Validation_Status_value = src.Validation_Status_value
80 )
81
82
83
84
85 type AvroFileFormat = src.AvroFileFormat
86 type ConnectionProfile = src.ConnectionProfile
87 type ConnectionProfile_ForwardSshConnectivity = src.ConnectionProfile_ForwardSshConnectivity
88 type ConnectionProfile_GcsProfile = src.ConnectionProfile_GcsProfile
89 type ConnectionProfile_MysqlProfile = src.ConnectionProfile_MysqlProfile
90 type ConnectionProfile_NoConnectivity = src.ConnectionProfile_NoConnectivity
91 type ConnectionProfile_OracleProfile = src.ConnectionProfile_OracleProfile
92 type ConnectionProfile_PrivateConnectivity = src.ConnectionProfile_PrivateConnectivity
93 type ConnectionProfile_StaticServiceIpConnectivity = src.ConnectionProfile_StaticServiceIpConnectivity
94 type CreateConnectionProfileRequest = src.CreateConnectionProfileRequest
95 type CreatePrivateConnectionRequest = src.CreatePrivateConnectionRequest
96
97
98
99
100 type CreateRouteRequest = src.CreateRouteRequest
101 type CreateStreamRequest = src.CreateStreamRequest
102
103
104
105
106
107
108 type DatastreamClient = src.DatastreamClient
109
110
111
112
113 type DatastreamServer = src.DatastreamServer
114 type DeleteConnectionProfileRequest = src.DeleteConnectionProfileRequest
115 type DeletePrivateConnectionRequest = src.DeletePrivateConnectionRequest
116
117
118
119
120 type DeleteRouteRequest = src.DeleteRouteRequest
121 type DeleteStreamRequest = src.DeleteStreamRequest
122
123
124
125
126 type DestinationConfig = src.DestinationConfig
127 type DestinationConfig_GcsDestinationConfig = src.DestinationConfig_GcsDestinationConfig
128
129
130
131
132 type DiscoverConnectionProfileRequest = src.DiscoverConnectionProfileRequest
133 type DiscoverConnectionProfileRequest_ConnectionProfile = src.DiscoverConnectionProfileRequest_ConnectionProfile
134 type DiscoverConnectionProfileRequest_ConnectionProfileName = src.DiscoverConnectionProfileRequest_ConnectionProfileName
135 type DiscoverConnectionProfileRequest_MysqlRdbms = src.DiscoverConnectionProfileRequest_MysqlRdbms
136 type DiscoverConnectionProfileRequest_OracleRdbms = src.DiscoverConnectionProfileRequest_OracleRdbms
137 type DiscoverConnectionProfileRequest_RecursionDepth = src.DiscoverConnectionProfileRequest_RecursionDepth
138 type DiscoverConnectionProfileRequest_Recursive = src.DiscoverConnectionProfileRequest_Recursive
139 type DiscoverConnectionProfileResponse = src.DiscoverConnectionProfileResponse
140 type DiscoverConnectionProfileResponse_MysqlRdbms = src.DiscoverConnectionProfileResponse_MysqlRdbms
141 type DiscoverConnectionProfileResponse_OracleRdbms = src.DiscoverConnectionProfileResponse_OracleRdbms
142
143
144
145
146 type Error = src.Error
147
148
149
150
151 type FetchErrorsRequest = src.FetchErrorsRequest
152
153
154
155
156 type FetchErrorsResponse = src.FetchErrorsResponse
157
158
159
160
161 type FetchStaticIpsRequest = src.FetchStaticIpsRequest
162
163
164
165
166 type FetchStaticIpsResponse = src.FetchStaticIpsResponse
167
168
169
170
171 type ForwardSshTunnelConnectivity = src.ForwardSshTunnelConnectivity
172 type ForwardSshTunnelConnectivity_Password = src.ForwardSshTunnelConnectivity_Password
173 type ForwardSshTunnelConnectivity_PrivateKey = src.ForwardSshTunnelConnectivity_PrivateKey
174
175
176
177
178 type GcsDestinationConfig = src.GcsDestinationConfig
179 type GcsDestinationConfig_AvroFileFormat = src.GcsDestinationConfig_AvroFileFormat
180 type GcsDestinationConfig_JsonFileFormat = src.GcsDestinationConfig_JsonFileFormat
181
182
183
184
185 type GcsFileFormat = src.GcsFileFormat
186
187
188
189
190 type GcsProfile = src.GcsProfile
191 type GetConnectionProfileRequest = src.GetConnectionProfileRequest
192 type GetPrivateConnectionRequest = src.GetPrivateConnectionRequest
193
194
195
196
197 type GetRouteRequest = src.GetRouteRequest
198 type GetStreamRequest = src.GetStreamRequest
199
200
201
202
203 type JsonFileFormat = src.JsonFileFormat
204
205
206
207
208 type JsonFileFormat_JsonCompression = src.JsonFileFormat_JsonCompression
209 type ListConnectionProfilesRequest = src.ListConnectionProfilesRequest
210 type ListConnectionProfilesResponse = src.ListConnectionProfilesResponse
211 type ListPrivateConnectionsRequest = src.ListPrivateConnectionsRequest
212 type ListPrivateConnectionsResponse = src.ListPrivateConnectionsResponse
213
214
215
216
217 type ListRoutesRequest = src.ListRoutesRequest
218
219
220
221
222 type ListRoutesResponse = src.ListRoutesResponse
223 type ListStreamsRequest = src.ListStreamsRequest
224 type ListStreamsResponse = src.ListStreamsResponse
225
226
227
228
229 type MysqlColumn = src.MysqlColumn
230
231
232
233
234 type MysqlDatabase = src.MysqlDatabase
235
236
237
238
239 type MysqlProfile = src.MysqlProfile
240
241
242
243
244 type MysqlRdbms = src.MysqlRdbms
245
246
247
248
249 type MysqlSourceConfig = src.MysqlSourceConfig
250
251
252
253
254 type MysqlSslConfig = src.MysqlSslConfig
255
256
257
258
259 type MysqlTable = src.MysqlTable
260
261
262
263
264 type NoConnectivitySettings = src.NoConnectivitySettings
265
266
267
268
269 type OperationMetadata = src.OperationMetadata
270
271
272
273
274 type OracleColumn = src.OracleColumn
275
276
277
278
279 type OracleProfile = src.OracleProfile
280
281
282
283
284 type OracleRdbms = src.OracleRdbms
285
286
287
288
289 type OracleSchema = src.OracleSchema
290
291
292
293
294 type OracleSourceConfig = src.OracleSourceConfig
295
296
297
298
299 type OracleTable = src.OracleTable
300
301
302
303
304
305 type PrivateConnection = src.PrivateConnection
306
307
308
309
310 type PrivateConnection_State = src.PrivateConnection_State
311
312
313
314
315 type PrivateConnectivity = src.PrivateConnectivity
316
317
318
319
320
321 type Route = src.Route
322
323
324
325
326 type SchemaFileFormat = src.SchemaFileFormat
327
328
329
330
331 type SourceConfig = src.SourceConfig
332 type SourceConfig_MysqlSourceConfig = src.SourceConfig_MysqlSourceConfig
333 type SourceConfig_OracleSourceConfig = src.SourceConfig_OracleSourceConfig
334
335
336
337
338 type StaticServiceIpConnectivity = src.StaticServiceIpConnectivity
339 type Stream = src.Stream
340 type Stream_BackfillAll = src.Stream_BackfillAll
341
342
343
344
345
346 type Stream_BackfillAllStrategy = src.Stream_BackfillAllStrategy
347 type Stream_BackfillAllStrategy_MysqlExcludedObjects = src.Stream_BackfillAllStrategy_MysqlExcludedObjects
348 type Stream_BackfillAllStrategy_OracleExcludedObjects = src.Stream_BackfillAllStrategy_OracleExcludedObjects
349 type Stream_BackfillNone = src.Stream_BackfillNone
350
351
352
353
354 type Stream_BackfillNoneStrategy = src.Stream_BackfillNoneStrategy
355
356
357
358
359 type Stream_State = src.Stream_State
360
361
362
363
364
365 type UnimplementedDatastreamServer = src.UnimplementedDatastreamServer
366 type UpdateConnectionProfileRequest = src.UpdateConnectionProfileRequest
367 type UpdateStreamRequest = src.UpdateStreamRequest
368 type Validation = src.Validation
369
370
371
372
373 type ValidationMessage = src.ValidationMessage
374
375
376
377
378 type ValidationMessage_Level = src.ValidationMessage_Level
379
380
381
382
383 type ValidationResult = src.ValidationResult
384
385
386
387
388 type Validation_Status = src.Validation_Status
389
390
391
392
393
394 type VpcPeeringConfig = src.VpcPeeringConfig
395
396
397 func NewDatastreamClient(cc grpc.ClientConnInterface) DatastreamClient {
398 return src.NewDatastreamClient(cc)
399 }
400
401
402 func RegisterDatastreamServer(s *grpc.Server, srv DatastreamServer) {
403 src.RegisterDatastreamServer(s, srv)
404 }
405
View as plain text