1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25 package v1alpha1
26
27 import (
28 k8sv1alpha1 "github.com/GoogleCloudPlatform/k8s-config-connector/pkg/clients/generated/apis/k8s/v1alpha1"
29 runtime "k8s.io/apimachinery/pkg/runtime"
30 )
31
32
33 func (in *ConnectionprofileBigqueryProfile) DeepCopyInto(out *ConnectionprofileBigqueryProfile) {
34 *out = *in
35 return
36 }
37
38
39 func (in *ConnectionprofileBigqueryProfile) DeepCopy() *ConnectionprofileBigqueryProfile {
40 if in == nil {
41 return nil
42 }
43 out := new(ConnectionprofileBigqueryProfile)
44 in.DeepCopyInto(out)
45 return out
46 }
47
48
49 func (in *ConnectionprofileCaCertificate) DeepCopyInto(out *ConnectionprofileCaCertificate) {
50 *out = *in
51 if in.Value != nil {
52 in, out := &in.Value, &out.Value
53 *out = new(string)
54 **out = **in
55 }
56 if in.ValueFrom != nil {
57 in, out := &in.ValueFrom, &out.ValueFrom
58 *out = new(ConnectionprofileValueFrom)
59 (*in).DeepCopyInto(*out)
60 }
61 return
62 }
63
64
65 func (in *ConnectionprofileCaCertificate) DeepCopy() *ConnectionprofileCaCertificate {
66 if in == nil {
67 return nil
68 }
69 out := new(ConnectionprofileCaCertificate)
70 in.DeepCopyInto(out)
71 return out
72 }
73
74
75 func (in *ConnectionprofileClientCertificate) DeepCopyInto(out *ConnectionprofileClientCertificate) {
76 *out = *in
77 if in.Value != nil {
78 in, out := &in.Value, &out.Value
79 *out = new(string)
80 **out = **in
81 }
82 if in.ValueFrom != nil {
83 in, out := &in.ValueFrom, &out.ValueFrom
84 *out = new(ConnectionprofileValueFrom)
85 (*in).DeepCopyInto(*out)
86 }
87 return
88 }
89
90
91 func (in *ConnectionprofileClientCertificate) DeepCopy() *ConnectionprofileClientCertificate {
92 if in == nil {
93 return nil
94 }
95 out := new(ConnectionprofileClientCertificate)
96 in.DeepCopyInto(out)
97 return out
98 }
99
100
101 func (in *ConnectionprofileClientKey) DeepCopyInto(out *ConnectionprofileClientKey) {
102 *out = *in
103 if in.Value != nil {
104 in, out := &in.Value, &out.Value
105 *out = new(string)
106 **out = **in
107 }
108 if in.ValueFrom != nil {
109 in, out := &in.ValueFrom, &out.ValueFrom
110 *out = new(ConnectionprofileValueFrom)
111 (*in).DeepCopyInto(*out)
112 }
113 return
114 }
115
116
117 func (in *ConnectionprofileClientKey) DeepCopy() *ConnectionprofileClientKey {
118 if in == nil {
119 return nil
120 }
121 out := new(ConnectionprofileClientKey)
122 in.DeepCopyInto(out)
123 return out
124 }
125
126
127 func (in *ConnectionprofileForwardSshConnectivity) DeepCopyInto(out *ConnectionprofileForwardSshConnectivity) {
128 *out = *in
129 if in.Password != nil {
130 in, out := &in.Password, &out.Password
131 *out = new(ConnectionprofilePassword)
132 (*in).DeepCopyInto(*out)
133 }
134 if in.Port != nil {
135 in, out := &in.Port, &out.Port
136 *out = new(int)
137 **out = **in
138 }
139 if in.PrivateKey != nil {
140 in, out := &in.PrivateKey, &out.PrivateKey
141 *out = new(ConnectionprofilePrivateKey)
142 (*in).DeepCopyInto(*out)
143 }
144 return
145 }
146
147
148 func (in *ConnectionprofileForwardSshConnectivity) DeepCopy() *ConnectionprofileForwardSshConnectivity {
149 if in == nil {
150 return nil
151 }
152 out := new(ConnectionprofileForwardSshConnectivity)
153 in.DeepCopyInto(out)
154 return out
155 }
156
157
158 func (in *ConnectionprofileGcsProfile) DeepCopyInto(out *ConnectionprofileGcsProfile) {
159 *out = *in
160 if in.RootPath != nil {
161 in, out := &in.RootPath, &out.RootPath
162 *out = new(string)
163 **out = **in
164 }
165 return
166 }
167
168
169 func (in *ConnectionprofileGcsProfile) DeepCopy() *ConnectionprofileGcsProfile {
170 if in == nil {
171 return nil
172 }
173 out := new(ConnectionprofileGcsProfile)
174 in.DeepCopyInto(out)
175 return out
176 }
177
178
179 func (in *ConnectionprofileMysqlProfile) DeepCopyInto(out *ConnectionprofileMysqlProfile) {
180 *out = *in
181 in.Password.DeepCopyInto(&out.Password)
182 if in.Port != nil {
183 in, out := &in.Port, &out.Port
184 *out = new(int)
185 **out = **in
186 }
187 if in.SslConfig != nil {
188 in, out := &in.SslConfig, &out.SslConfig
189 *out = new(ConnectionprofileSslConfig)
190 (*in).DeepCopyInto(*out)
191 }
192 return
193 }
194
195
196 func (in *ConnectionprofileMysqlProfile) DeepCopy() *ConnectionprofileMysqlProfile {
197 if in == nil {
198 return nil
199 }
200 out := new(ConnectionprofileMysqlProfile)
201 in.DeepCopyInto(out)
202 return out
203 }
204
205
206 func (in *ConnectionprofileOracleProfile) DeepCopyInto(out *ConnectionprofileOracleProfile) {
207 *out = *in
208 if in.ConnectionAttributes != nil {
209 in, out := &in.ConnectionAttributes, &out.ConnectionAttributes
210 *out = make(map[string]string, len(*in))
211 for key, val := range *in {
212 (*out)[key] = val
213 }
214 }
215 in.Password.DeepCopyInto(&out.Password)
216 if in.Port != nil {
217 in, out := &in.Port, &out.Port
218 *out = new(int)
219 **out = **in
220 }
221 return
222 }
223
224
225 func (in *ConnectionprofileOracleProfile) DeepCopy() *ConnectionprofileOracleProfile {
226 if in == nil {
227 return nil
228 }
229 out := new(ConnectionprofileOracleProfile)
230 in.DeepCopyInto(out)
231 return out
232 }
233
234
235 func (in *ConnectionprofilePassword) DeepCopyInto(out *ConnectionprofilePassword) {
236 *out = *in
237 if in.Value != nil {
238 in, out := &in.Value, &out.Value
239 *out = new(string)
240 **out = **in
241 }
242 if in.ValueFrom != nil {
243 in, out := &in.ValueFrom, &out.ValueFrom
244 *out = new(ConnectionprofileValueFrom)
245 (*in).DeepCopyInto(*out)
246 }
247 return
248 }
249
250
251 func (in *ConnectionprofilePassword) DeepCopy() *ConnectionprofilePassword {
252 if in == nil {
253 return nil
254 }
255 out := new(ConnectionprofilePassword)
256 in.DeepCopyInto(out)
257 return out
258 }
259
260
261 func (in *ConnectionprofilePostgresqlProfile) DeepCopyInto(out *ConnectionprofilePostgresqlProfile) {
262 *out = *in
263 in.Password.DeepCopyInto(&out.Password)
264 if in.Port != nil {
265 in, out := &in.Port, &out.Port
266 *out = new(int)
267 **out = **in
268 }
269 return
270 }
271
272
273 func (in *ConnectionprofilePostgresqlProfile) DeepCopy() *ConnectionprofilePostgresqlProfile {
274 if in == nil {
275 return nil
276 }
277 out := new(ConnectionprofilePostgresqlProfile)
278 in.DeepCopyInto(out)
279 return out
280 }
281
282
283 func (in *ConnectionprofilePrivateConnectivity) DeepCopyInto(out *ConnectionprofilePrivateConnectivity) {
284 *out = *in
285 return
286 }
287
288
289 func (in *ConnectionprofilePrivateConnectivity) DeepCopy() *ConnectionprofilePrivateConnectivity {
290 if in == nil {
291 return nil
292 }
293 out := new(ConnectionprofilePrivateConnectivity)
294 in.DeepCopyInto(out)
295 return out
296 }
297
298
299 func (in *ConnectionprofilePrivateKey) DeepCopyInto(out *ConnectionprofilePrivateKey) {
300 *out = *in
301 if in.Value != nil {
302 in, out := &in.Value, &out.Value
303 *out = new(string)
304 **out = **in
305 }
306 if in.ValueFrom != nil {
307 in, out := &in.ValueFrom, &out.ValueFrom
308 *out = new(ConnectionprofileValueFrom)
309 (*in).DeepCopyInto(*out)
310 }
311 return
312 }
313
314
315 func (in *ConnectionprofilePrivateKey) DeepCopy() *ConnectionprofilePrivateKey {
316 if in == nil {
317 return nil
318 }
319 out := new(ConnectionprofilePrivateKey)
320 in.DeepCopyInto(out)
321 return out
322 }
323
324
325 func (in *ConnectionprofileSslConfig) DeepCopyInto(out *ConnectionprofileSslConfig) {
326 *out = *in
327 if in.CaCertificate != nil {
328 in, out := &in.CaCertificate, &out.CaCertificate
329 *out = new(ConnectionprofileCaCertificate)
330 (*in).DeepCopyInto(*out)
331 }
332 if in.CaCertificateSet != nil {
333 in, out := &in.CaCertificateSet, &out.CaCertificateSet
334 *out = new(bool)
335 **out = **in
336 }
337 if in.ClientCertificate != nil {
338 in, out := &in.ClientCertificate, &out.ClientCertificate
339 *out = new(ConnectionprofileClientCertificate)
340 (*in).DeepCopyInto(*out)
341 }
342 if in.ClientCertificateSet != nil {
343 in, out := &in.ClientCertificateSet, &out.ClientCertificateSet
344 *out = new(bool)
345 **out = **in
346 }
347 if in.ClientKey != nil {
348 in, out := &in.ClientKey, &out.ClientKey
349 *out = new(ConnectionprofileClientKey)
350 (*in).DeepCopyInto(*out)
351 }
352 if in.ClientKeySet != nil {
353 in, out := &in.ClientKeySet, &out.ClientKeySet
354 *out = new(bool)
355 **out = **in
356 }
357 return
358 }
359
360
361 func (in *ConnectionprofileSslConfig) DeepCopy() *ConnectionprofileSslConfig {
362 if in == nil {
363 return nil
364 }
365 out := new(ConnectionprofileSslConfig)
366 in.DeepCopyInto(out)
367 return out
368 }
369
370
371 func (in *ConnectionprofileValueFrom) DeepCopyInto(out *ConnectionprofileValueFrom) {
372 *out = *in
373 if in.SecretKeyRef != nil {
374 in, out := &in.SecretKeyRef, &out.SecretKeyRef
375 *out = new(k8sv1alpha1.ResourceRef)
376 **out = **in
377 }
378 return
379 }
380
381
382 func (in *ConnectionprofileValueFrom) DeepCopy() *ConnectionprofileValueFrom {
383 if in == nil {
384 return nil
385 }
386 out := new(ConnectionprofileValueFrom)
387 in.DeepCopyInto(out)
388 return out
389 }
390
391
392 func (in *DatastreamConnectionProfile) DeepCopyInto(out *DatastreamConnectionProfile) {
393 *out = *in
394 out.TypeMeta = in.TypeMeta
395 in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
396 in.Spec.DeepCopyInto(&out.Spec)
397 in.Status.DeepCopyInto(&out.Status)
398 return
399 }
400
401
402 func (in *DatastreamConnectionProfile) DeepCopy() *DatastreamConnectionProfile {
403 if in == nil {
404 return nil
405 }
406 out := new(DatastreamConnectionProfile)
407 in.DeepCopyInto(out)
408 return out
409 }
410
411
412 func (in *DatastreamConnectionProfile) DeepCopyObject() runtime.Object {
413 if c := in.DeepCopy(); c != nil {
414 return c
415 }
416 return nil
417 }
418
419
420 func (in *DatastreamConnectionProfileList) DeepCopyInto(out *DatastreamConnectionProfileList) {
421 *out = *in
422 out.TypeMeta = in.TypeMeta
423 in.ListMeta.DeepCopyInto(&out.ListMeta)
424 if in.Items != nil {
425 in, out := &in.Items, &out.Items
426 *out = make([]DatastreamConnectionProfile, len(*in))
427 for i := range *in {
428 (*in)[i].DeepCopyInto(&(*out)[i])
429 }
430 }
431 return
432 }
433
434
435 func (in *DatastreamConnectionProfileList) DeepCopy() *DatastreamConnectionProfileList {
436 if in == nil {
437 return nil
438 }
439 out := new(DatastreamConnectionProfileList)
440 in.DeepCopyInto(out)
441 return out
442 }
443
444
445 func (in *DatastreamConnectionProfileList) DeepCopyObject() runtime.Object {
446 if c := in.DeepCopy(); c != nil {
447 return c
448 }
449 return nil
450 }
451
452
453 func (in *DatastreamConnectionProfileSpec) DeepCopyInto(out *DatastreamConnectionProfileSpec) {
454 *out = *in
455 if in.BigqueryProfile != nil {
456 in, out := &in.BigqueryProfile, &out.BigqueryProfile
457 *out = new(ConnectionprofileBigqueryProfile)
458 **out = **in
459 }
460 if in.ForwardSshConnectivity != nil {
461 in, out := &in.ForwardSshConnectivity, &out.ForwardSshConnectivity
462 *out = new(ConnectionprofileForwardSshConnectivity)
463 (*in).DeepCopyInto(*out)
464 }
465 if in.GcsProfile != nil {
466 in, out := &in.GcsProfile, &out.GcsProfile
467 *out = new(ConnectionprofileGcsProfile)
468 (*in).DeepCopyInto(*out)
469 }
470 if in.MysqlProfile != nil {
471 in, out := &in.MysqlProfile, &out.MysqlProfile
472 *out = new(ConnectionprofileMysqlProfile)
473 (*in).DeepCopyInto(*out)
474 }
475 if in.OracleProfile != nil {
476 in, out := &in.OracleProfile, &out.OracleProfile
477 *out = new(ConnectionprofileOracleProfile)
478 (*in).DeepCopyInto(*out)
479 }
480 if in.PostgresqlProfile != nil {
481 in, out := &in.PostgresqlProfile, &out.PostgresqlProfile
482 *out = new(ConnectionprofilePostgresqlProfile)
483 (*in).DeepCopyInto(*out)
484 }
485 if in.PrivateConnectivity != nil {
486 in, out := &in.PrivateConnectivity, &out.PrivateConnectivity
487 *out = new(ConnectionprofilePrivateConnectivity)
488 **out = **in
489 }
490 out.ProjectRef = in.ProjectRef
491 if in.ResourceID != nil {
492 in, out := &in.ResourceID, &out.ResourceID
493 *out = new(string)
494 **out = **in
495 }
496 return
497 }
498
499
500 func (in *DatastreamConnectionProfileSpec) DeepCopy() *DatastreamConnectionProfileSpec {
501 if in == nil {
502 return nil
503 }
504 out := new(DatastreamConnectionProfileSpec)
505 in.DeepCopyInto(out)
506 return out
507 }
508
509
510 func (in *DatastreamConnectionProfileStatus) DeepCopyInto(out *DatastreamConnectionProfileStatus) {
511 *out = *in
512 if in.Conditions != nil {
513 in, out := &in.Conditions, &out.Conditions
514 *out = make([]k8sv1alpha1.Condition, len(*in))
515 copy(*out, *in)
516 }
517 if in.Name != nil {
518 in, out := &in.Name, &out.Name
519 *out = new(string)
520 **out = **in
521 }
522 if in.ObservedGeneration != nil {
523 in, out := &in.ObservedGeneration, &out.ObservedGeneration
524 *out = new(int)
525 **out = **in
526 }
527 return
528 }
529
530
531 func (in *DatastreamConnectionProfileStatus) DeepCopy() *DatastreamConnectionProfileStatus {
532 if in == nil {
533 return nil
534 }
535 out := new(DatastreamConnectionProfileStatus)
536 in.DeepCopyInto(out)
537 return out
538 }
539
540
541 func (in *DatastreamPrivateConnection) DeepCopyInto(out *DatastreamPrivateConnection) {
542 *out = *in
543 out.TypeMeta = in.TypeMeta
544 in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
545 in.Spec.DeepCopyInto(&out.Spec)
546 in.Status.DeepCopyInto(&out.Status)
547 return
548 }
549
550
551 func (in *DatastreamPrivateConnection) DeepCopy() *DatastreamPrivateConnection {
552 if in == nil {
553 return nil
554 }
555 out := new(DatastreamPrivateConnection)
556 in.DeepCopyInto(out)
557 return out
558 }
559
560
561 func (in *DatastreamPrivateConnection) DeepCopyObject() runtime.Object {
562 if c := in.DeepCopy(); c != nil {
563 return c
564 }
565 return nil
566 }
567
568
569 func (in *DatastreamPrivateConnectionList) DeepCopyInto(out *DatastreamPrivateConnectionList) {
570 *out = *in
571 out.TypeMeta = in.TypeMeta
572 in.ListMeta.DeepCopyInto(&out.ListMeta)
573 if in.Items != nil {
574 in, out := &in.Items, &out.Items
575 *out = make([]DatastreamPrivateConnection, len(*in))
576 for i := range *in {
577 (*in)[i].DeepCopyInto(&(*out)[i])
578 }
579 }
580 return
581 }
582
583
584 func (in *DatastreamPrivateConnectionList) DeepCopy() *DatastreamPrivateConnectionList {
585 if in == nil {
586 return nil
587 }
588 out := new(DatastreamPrivateConnectionList)
589 in.DeepCopyInto(out)
590 return out
591 }
592
593
594 func (in *DatastreamPrivateConnectionList) DeepCopyObject() runtime.Object {
595 if c := in.DeepCopy(); c != nil {
596 return c
597 }
598 return nil
599 }
600
601
602 func (in *DatastreamPrivateConnectionSpec) DeepCopyInto(out *DatastreamPrivateConnectionSpec) {
603 *out = *in
604 out.ProjectRef = in.ProjectRef
605 if in.ResourceID != nil {
606 in, out := &in.ResourceID, &out.ResourceID
607 *out = new(string)
608 **out = **in
609 }
610 out.VpcPeeringConfig = in.VpcPeeringConfig
611 return
612 }
613
614
615 func (in *DatastreamPrivateConnectionSpec) DeepCopy() *DatastreamPrivateConnectionSpec {
616 if in == nil {
617 return nil
618 }
619 out := new(DatastreamPrivateConnectionSpec)
620 in.DeepCopyInto(out)
621 return out
622 }
623
624
625 func (in *DatastreamPrivateConnectionStatus) DeepCopyInto(out *DatastreamPrivateConnectionStatus) {
626 *out = *in
627 if in.Conditions != nil {
628 in, out := &in.Conditions, &out.Conditions
629 *out = make([]k8sv1alpha1.Condition, len(*in))
630 copy(*out, *in)
631 }
632 if in.Error != nil {
633 in, out := &in.Error, &out.Error
634 *out = make([]PrivateconnectionErrorStatus, len(*in))
635 for i := range *in {
636 (*in)[i].DeepCopyInto(&(*out)[i])
637 }
638 }
639 if in.Name != nil {
640 in, out := &in.Name, &out.Name
641 *out = new(string)
642 **out = **in
643 }
644 if in.ObservedGeneration != nil {
645 in, out := &in.ObservedGeneration, &out.ObservedGeneration
646 *out = new(int)
647 **out = **in
648 }
649 if in.State != nil {
650 in, out := &in.State, &out.State
651 *out = new(string)
652 **out = **in
653 }
654 return
655 }
656
657
658 func (in *DatastreamPrivateConnectionStatus) DeepCopy() *DatastreamPrivateConnectionStatus {
659 if in == nil {
660 return nil
661 }
662 out := new(DatastreamPrivateConnectionStatus)
663 in.DeepCopyInto(out)
664 return out
665 }
666
667
668 func (in *DatastreamStream) DeepCopyInto(out *DatastreamStream) {
669 *out = *in
670 out.TypeMeta = in.TypeMeta
671 in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
672 in.Spec.DeepCopyInto(&out.Spec)
673 in.Status.DeepCopyInto(&out.Status)
674 return
675 }
676
677
678 func (in *DatastreamStream) DeepCopy() *DatastreamStream {
679 if in == nil {
680 return nil
681 }
682 out := new(DatastreamStream)
683 in.DeepCopyInto(out)
684 return out
685 }
686
687
688 func (in *DatastreamStream) DeepCopyObject() runtime.Object {
689 if c := in.DeepCopy(); c != nil {
690 return c
691 }
692 return nil
693 }
694
695
696 func (in *DatastreamStreamList) DeepCopyInto(out *DatastreamStreamList) {
697 *out = *in
698 out.TypeMeta = in.TypeMeta
699 in.ListMeta.DeepCopyInto(&out.ListMeta)
700 if in.Items != nil {
701 in, out := &in.Items, &out.Items
702 *out = make([]DatastreamStream, len(*in))
703 for i := range *in {
704 (*in)[i].DeepCopyInto(&(*out)[i])
705 }
706 }
707 return
708 }
709
710
711 func (in *DatastreamStreamList) DeepCopy() *DatastreamStreamList {
712 if in == nil {
713 return nil
714 }
715 out := new(DatastreamStreamList)
716 in.DeepCopyInto(out)
717 return out
718 }
719
720
721 func (in *DatastreamStreamList) DeepCopyObject() runtime.Object {
722 if c := in.DeepCopy(); c != nil {
723 return c
724 }
725 return nil
726 }
727
728
729 func (in *DatastreamStreamSpec) DeepCopyInto(out *DatastreamStreamSpec) {
730 *out = *in
731 if in.BackfillAll != nil {
732 in, out := &in.BackfillAll, &out.BackfillAll
733 *out = new(StreamBackfillAll)
734 (*in).DeepCopyInto(*out)
735 }
736 if in.BackfillNone != nil {
737 in, out := &in.BackfillNone, &out.BackfillNone
738 *out = new(StreamBackfillNone)
739 **out = **in
740 }
741 if in.CustomerManagedEncryptionKey != nil {
742 in, out := &in.CustomerManagedEncryptionKey, &out.CustomerManagedEncryptionKey
743 *out = new(string)
744 **out = **in
745 }
746 if in.DesiredState != nil {
747 in, out := &in.DesiredState, &out.DesiredState
748 *out = new(string)
749 **out = **in
750 }
751 in.DestinationConfig.DeepCopyInto(&out.DestinationConfig)
752 out.ProjectRef = in.ProjectRef
753 if in.ResourceID != nil {
754 in, out := &in.ResourceID, &out.ResourceID
755 *out = new(string)
756 **out = **in
757 }
758 in.SourceConfig.DeepCopyInto(&out.SourceConfig)
759 return
760 }
761
762
763 func (in *DatastreamStreamSpec) DeepCopy() *DatastreamStreamSpec {
764 if in == nil {
765 return nil
766 }
767 out := new(DatastreamStreamSpec)
768 in.DeepCopyInto(out)
769 return out
770 }
771
772
773 func (in *DatastreamStreamStatus) DeepCopyInto(out *DatastreamStreamStatus) {
774 *out = *in
775 if in.Conditions != nil {
776 in, out := &in.Conditions, &out.Conditions
777 *out = make([]k8sv1alpha1.Condition, len(*in))
778 copy(*out, *in)
779 }
780 if in.Name != nil {
781 in, out := &in.Name, &out.Name
782 *out = new(string)
783 **out = **in
784 }
785 if in.ObservedGeneration != nil {
786 in, out := &in.ObservedGeneration, &out.ObservedGeneration
787 *out = new(int)
788 **out = **in
789 }
790 if in.State != nil {
791 in, out := &in.State, &out.State
792 *out = new(string)
793 **out = **in
794 }
795 return
796 }
797
798
799 func (in *DatastreamStreamStatus) DeepCopy() *DatastreamStreamStatus {
800 if in == nil {
801 return nil
802 }
803 out := new(DatastreamStreamStatus)
804 in.DeepCopyInto(out)
805 return out
806 }
807
808
809 func (in *PrivateconnectionErrorStatus) DeepCopyInto(out *PrivateconnectionErrorStatus) {
810 *out = *in
811 if in.Details != nil {
812 in, out := &in.Details, &out.Details
813 *out = make(map[string]string, len(*in))
814 for key, val := range *in {
815 (*out)[key] = val
816 }
817 }
818 if in.Message != nil {
819 in, out := &in.Message, &out.Message
820 *out = new(string)
821 **out = **in
822 }
823 return
824 }
825
826
827 func (in *PrivateconnectionErrorStatus) DeepCopy() *PrivateconnectionErrorStatus {
828 if in == nil {
829 return nil
830 }
831 out := new(PrivateconnectionErrorStatus)
832 in.DeepCopyInto(out)
833 return out
834 }
835
836
837 func (in *PrivateconnectionVpcPeeringConfig) DeepCopyInto(out *PrivateconnectionVpcPeeringConfig) {
838 *out = *in
839 return
840 }
841
842
843 func (in *PrivateconnectionVpcPeeringConfig) DeepCopy() *PrivateconnectionVpcPeeringConfig {
844 if in == nil {
845 return nil
846 }
847 out := new(PrivateconnectionVpcPeeringConfig)
848 in.DeepCopyInto(out)
849 return out
850 }
851
852
853 func (in *StreamAvroFileFormat) DeepCopyInto(out *StreamAvroFileFormat) {
854 *out = *in
855 return
856 }
857
858
859 func (in *StreamAvroFileFormat) DeepCopy() *StreamAvroFileFormat {
860 if in == nil {
861 return nil
862 }
863 out := new(StreamAvroFileFormat)
864 in.DeepCopyInto(out)
865 return out
866 }
867
868
869 func (in *StreamBackfillAll) DeepCopyInto(out *StreamBackfillAll) {
870 *out = *in
871 if in.MysqlExcludedObjects != nil {
872 in, out := &in.MysqlExcludedObjects, &out.MysqlExcludedObjects
873 *out = new(StreamMysqlExcludedObjects)
874 (*in).DeepCopyInto(*out)
875 }
876 if in.OracleExcludedObjects != nil {
877 in, out := &in.OracleExcludedObjects, &out.OracleExcludedObjects
878 *out = new(StreamOracleExcludedObjects)
879 (*in).DeepCopyInto(*out)
880 }
881 if in.PostgresqlExcludedObjects != nil {
882 in, out := &in.PostgresqlExcludedObjects, &out.PostgresqlExcludedObjects
883 *out = new(StreamPostgresqlExcludedObjects)
884 (*in).DeepCopyInto(*out)
885 }
886 return
887 }
888
889
890 func (in *StreamBackfillAll) DeepCopy() *StreamBackfillAll {
891 if in == nil {
892 return nil
893 }
894 out := new(StreamBackfillAll)
895 in.DeepCopyInto(out)
896 return out
897 }
898
899
900 func (in *StreamBackfillNone) DeepCopyInto(out *StreamBackfillNone) {
901 *out = *in
902 return
903 }
904
905
906 func (in *StreamBackfillNone) DeepCopy() *StreamBackfillNone {
907 if in == nil {
908 return nil
909 }
910 out := new(StreamBackfillNone)
911 in.DeepCopyInto(out)
912 return out
913 }
914
915
916 func (in *StreamBigqueryDestinationConfig) DeepCopyInto(out *StreamBigqueryDestinationConfig) {
917 *out = *in
918 if in.DataFreshness != nil {
919 in, out := &in.DataFreshness, &out.DataFreshness
920 *out = new(string)
921 **out = **in
922 }
923 if in.SingleTargetDataset != nil {
924 in, out := &in.SingleTargetDataset, &out.SingleTargetDataset
925 *out = new(StreamSingleTargetDataset)
926 **out = **in
927 }
928 if in.SourceHierarchyDatasets != nil {
929 in, out := &in.SourceHierarchyDatasets, &out.SourceHierarchyDatasets
930 *out = new(StreamSourceHierarchyDatasets)
931 (*in).DeepCopyInto(*out)
932 }
933 return
934 }
935
936
937 func (in *StreamBigqueryDestinationConfig) DeepCopy() *StreamBigqueryDestinationConfig {
938 if in == nil {
939 return nil
940 }
941 out := new(StreamBigqueryDestinationConfig)
942 in.DeepCopyInto(out)
943 return out
944 }
945
946
947 func (in *StreamDatasetTemplate) DeepCopyInto(out *StreamDatasetTemplate) {
948 *out = *in
949 if in.DatasetIdPrefix != nil {
950 in, out := &in.DatasetIdPrefix, &out.DatasetIdPrefix
951 *out = new(string)
952 **out = **in
953 }
954 if in.KmsKeyName != nil {
955 in, out := &in.KmsKeyName, &out.KmsKeyName
956 *out = new(string)
957 **out = **in
958 }
959 return
960 }
961
962
963 func (in *StreamDatasetTemplate) DeepCopy() *StreamDatasetTemplate {
964 if in == nil {
965 return nil
966 }
967 out := new(StreamDatasetTemplate)
968 in.DeepCopyInto(out)
969 return out
970 }
971
972
973 func (in *StreamDestinationConfig) DeepCopyInto(out *StreamDestinationConfig) {
974 *out = *in
975 if in.BigqueryDestinationConfig != nil {
976 in, out := &in.BigqueryDestinationConfig, &out.BigqueryDestinationConfig
977 *out = new(StreamBigqueryDestinationConfig)
978 (*in).DeepCopyInto(*out)
979 }
980 if in.GcsDestinationConfig != nil {
981 in, out := &in.GcsDestinationConfig, &out.GcsDestinationConfig
982 *out = new(StreamGcsDestinationConfig)
983 (*in).DeepCopyInto(*out)
984 }
985 return
986 }
987
988
989 func (in *StreamDestinationConfig) DeepCopy() *StreamDestinationConfig {
990 if in == nil {
991 return nil
992 }
993 out := new(StreamDestinationConfig)
994 in.DeepCopyInto(out)
995 return out
996 }
997
998
999 func (in *StreamDropLargeObjects) DeepCopyInto(out *StreamDropLargeObjects) {
1000 *out = *in
1001 return
1002 }
1003
1004
1005 func (in *StreamDropLargeObjects) DeepCopy() *StreamDropLargeObjects {
1006 if in == nil {
1007 return nil
1008 }
1009 out := new(StreamDropLargeObjects)
1010 in.DeepCopyInto(out)
1011 return out
1012 }
1013
1014
1015 func (in *StreamExcludeObjects) DeepCopyInto(out *StreamExcludeObjects) {
1016 *out = *in
1017 if in.PostgresqlSchemas != nil {
1018 in, out := &in.PostgresqlSchemas, &out.PostgresqlSchemas
1019 *out = make([]StreamPostgresqlSchemas, len(*in))
1020 for i := range *in {
1021 (*in)[i].DeepCopyInto(&(*out)[i])
1022 }
1023 }
1024 return
1025 }
1026
1027
1028 func (in *StreamExcludeObjects) DeepCopy() *StreamExcludeObjects {
1029 if in == nil {
1030 return nil
1031 }
1032 out := new(StreamExcludeObjects)
1033 in.DeepCopyInto(out)
1034 return out
1035 }
1036
1037
1038 func (in *StreamGcsDestinationConfig) DeepCopyInto(out *StreamGcsDestinationConfig) {
1039 *out = *in
1040 if in.AvroFileFormat != nil {
1041 in, out := &in.AvroFileFormat, &out.AvroFileFormat
1042 *out = new(StreamAvroFileFormat)
1043 **out = **in
1044 }
1045 if in.FileRotationInterval != nil {
1046 in, out := &in.FileRotationInterval, &out.FileRotationInterval
1047 *out = new(string)
1048 **out = **in
1049 }
1050 if in.FileRotationMb != nil {
1051 in, out := &in.FileRotationMb, &out.FileRotationMb
1052 *out = new(int)
1053 **out = **in
1054 }
1055 if in.JsonFileFormat != nil {
1056 in, out := &in.JsonFileFormat, &out.JsonFileFormat
1057 *out = new(StreamJsonFileFormat)
1058 (*in).DeepCopyInto(*out)
1059 }
1060 if in.Path != nil {
1061 in, out := &in.Path, &out.Path
1062 *out = new(string)
1063 **out = **in
1064 }
1065 return
1066 }
1067
1068
1069 func (in *StreamGcsDestinationConfig) DeepCopy() *StreamGcsDestinationConfig {
1070 if in == nil {
1071 return nil
1072 }
1073 out := new(StreamGcsDestinationConfig)
1074 in.DeepCopyInto(out)
1075 return out
1076 }
1077
1078
1079 func (in *StreamIncludeObjects) DeepCopyInto(out *StreamIncludeObjects) {
1080 *out = *in
1081 if in.PostgresqlSchemas != nil {
1082 in, out := &in.PostgresqlSchemas, &out.PostgresqlSchemas
1083 *out = make([]StreamPostgresqlSchemas, len(*in))
1084 for i := range *in {
1085 (*in)[i].DeepCopyInto(&(*out)[i])
1086 }
1087 }
1088 return
1089 }
1090
1091
1092 func (in *StreamIncludeObjects) DeepCopy() *StreamIncludeObjects {
1093 if in == nil {
1094 return nil
1095 }
1096 out := new(StreamIncludeObjects)
1097 in.DeepCopyInto(out)
1098 return out
1099 }
1100
1101
1102 func (in *StreamJsonFileFormat) DeepCopyInto(out *StreamJsonFileFormat) {
1103 *out = *in
1104 if in.Compression != nil {
1105 in, out := &in.Compression, &out.Compression
1106 *out = new(string)
1107 **out = **in
1108 }
1109 if in.SchemaFileFormat != nil {
1110 in, out := &in.SchemaFileFormat, &out.SchemaFileFormat
1111 *out = new(string)
1112 **out = **in
1113 }
1114 return
1115 }
1116
1117
1118 func (in *StreamJsonFileFormat) DeepCopy() *StreamJsonFileFormat {
1119 if in == nil {
1120 return nil
1121 }
1122 out := new(StreamJsonFileFormat)
1123 in.DeepCopyInto(out)
1124 return out
1125 }
1126
1127
1128 func (in *StreamMysqlColumns) DeepCopyInto(out *StreamMysqlColumns) {
1129 *out = *in
1130 if in.Collation != nil {
1131 in, out := &in.Collation, &out.Collation
1132 *out = new(string)
1133 **out = **in
1134 }
1135 if in.Column != nil {
1136 in, out := &in.Column, &out.Column
1137 *out = new(string)
1138 **out = **in
1139 }
1140 if in.DataType != nil {
1141 in, out := &in.DataType, &out.DataType
1142 *out = new(string)
1143 **out = **in
1144 }
1145 if in.Length != nil {
1146 in, out := &in.Length, &out.Length
1147 *out = new(int)
1148 **out = **in
1149 }
1150 if in.Nullable != nil {
1151 in, out := &in.Nullable, &out.Nullable
1152 *out = new(bool)
1153 **out = **in
1154 }
1155 if in.OrdinalPosition != nil {
1156 in, out := &in.OrdinalPosition, &out.OrdinalPosition
1157 *out = new(int)
1158 **out = **in
1159 }
1160 if in.PrimaryKey != nil {
1161 in, out := &in.PrimaryKey, &out.PrimaryKey
1162 *out = new(bool)
1163 **out = **in
1164 }
1165 return
1166 }
1167
1168
1169 func (in *StreamMysqlColumns) DeepCopy() *StreamMysqlColumns {
1170 if in == nil {
1171 return nil
1172 }
1173 out := new(StreamMysqlColumns)
1174 in.DeepCopyInto(out)
1175 return out
1176 }
1177
1178
1179 func (in *StreamMysqlDatabases) DeepCopyInto(out *StreamMysqlDatabases) {
1180 *out = *in
1181 if in.MysqlTables != nil {
1182 in, out := &in.MysqlTables, &out.MysqlTables
1183 *out = make([]StreamMysqlTables, len(*in))
1184 for i := range *in {
1185 (*in)[i].DeepCopyInto(&(*out)[i])
1186 }
1187 }
1188 return
1189 }
1190
1191
1192 func (in *StreamMysqlDatabases) DeepCopy() *StreamMysqlDatabases {
1193 if in == nil {
1194 return nil
1195 }
1196 out := new(StreamMysqlDatabases)
1197 in.DeepCopyInto(out)
1198 return out
1199 }
1200
1201
1202 func (in *StreamMysqlExcludedObjects) DeepCopyInto(out *StreamMysqlExcludedObjects) {
1203 *out = *in
1204 if in.MysqlDatabases != nil {
1205 in, out := &in.MysqlDatabases, &out.MysqlDatabases
1206 *out = make([]StreamMysqlDatabases, len(*in))
1207 for i := range *in {
1208 (*in)[i].DeepCopyInto(&(*out)[i])
1209 }
1210 }
1211 return
1212 }
1213
1214
1215 func (in *StreamMysqlExcludedObjects) DeepCopy() *StreamMysqlExcludedObjects {
1216 if in == nil {
1217 return nil
1218 }
1219 out := new(StreamMysqlExcludedObjects)
1220 in.DeepCopyInto(out)
1221 return out
1222 }
1223
1224
1225 func (in *StreamMysqlSourceConfig) DeepCopyInto(out *StreamMysqlSourceConfig) {
1226 *out = *in
1227 if in.ExcludeObjects != nil {
1228 in, out := &in.ExcludeObjects, &out.ExcludeObjects
1229 *out = new(StreamExcludeObjects)
1230 (*in).DeepCopyInto(*out)
1231 }
1232 if in.IncludeObjects != nil {
1233 in, out := &in.IncludeObjects, &out.IncludeObjects
1234 *out = new(StreamIncludeObjects)
1235 (*in).DeepCopyInto(*out)
1236 }
1237 if in.MaxConcurrentBackfillTasks != nil {
1238 in, out := &in.MaxConcurrentBackfillTasks, &out.MaxConcurrentBackfillTasks
1239 *out = new(int)
1240 **out = **in
1241 }
1242 if in.MaxConcurrentCdcTasks != nil {
1243 in, out := &in.MaxConcurrentCdcTasks, &out.MaxConcurrentCdcTasks
1244 *out = new(int)
1245 **out = **in
1246 }
1247 return
1248 }
1249
1250
1251 func (in *StreamMysqlSourceConfig) DeepCopy() *StreamMysqlSourceConfig {
1252 if in == nil {
1253 return nil
1254 }
1255 out := new(StreamMysqlSourceConfig)
1256 in.DeepCopyInto(out)
1257 return out
1258 }
1259
1260
1261 func (in *StreamMysqlTables) DeepCopyInto(out *StreamMysqlTables) {
1262 *out = *in
1263 if in.MysqlColumns != nil {
1264 in, out := &in.MysqlColumns, &out.MysqlColumns
1265 *out = make([]StreamMysqlColumns, len(*in))
1266 for i := range *in {
1267 (*in)[i].DeepCopyInto(&(*out)[i])
1268 }
1269 }
1270 return
1271 }
1272
1273
1274 func (in *StreamMysqlTables) DeepCopy() *StreamMysqlTables {
1275 if in == nil {
1276 return nil
1277 }
1278 out := new(StreamMysqlTables)
1279 in.DeepCopyInto(out)
1280 return out
1281 }
1282
1283
1284 func (in *StreamOracleColumns) DeepCopyInto(out *StreamOracleColumns) {
1285 *out = *in
1286 if in.Column != nil {
1287 in, out := &in.Column, &out.Column
1288 *out = new(string)
1289 **out = **in
1290 }
1291 if in.DataType != nil {
1292 in, out := &in.DataType, &out.DataType
1293 *out = new(string)
1294 **out = **in
1295 }
1296 if in.Encoding != nil {
1297 in, out := &in.Encoding, &out.Encoding
1298 *out = new(string)
1299 **out = **in
1300 }
1301 if in.Length != nil {
1302 in, out := &in.Length, &out.Length
1303 *out = new(int)
1304 **out = **in
1305 }
1306 if in.Nullable != nil {
1307 in, out := &in.Nullable, &out.Nullable
1308 *out = new(bool)
1309 **out = **in
1310 }
1311 if in.OrdinalPosition != nil {
1312 in, out := &in.OrdinalPosition, &out.OrdinalPosition
1313 *out = new(int)
1314 **out = **in
1315 }
1316 if in.Precision != nil {
1317 in, out := &in.Precision, &out.Precision
1318 *out = new(int)
1319 **out = **in
1320 }
1321 if in.PrimaryKey != nil {
1322 in, out := &in.PrimaryKey, &out.PrimaryKey
1323 *out = new(bool)
1324 **out = **in
1325 }
1326 if in.Scale != nil {
1327 in, out := &in.Scale, &out.Scale
1328 *out = new(int)
1329 **out = **in
1330 }
1331 return
1332 }
1333
1334
1335 func (in *StreamOracleColumns) DeepCopy() *StreamOracleColumns {
1336 if in == nil {
1337 return nil
1338 }
1339 out := new(StreamOracleColumns)
1340 in.DeepCopyInto(out)
1341 return out
1342 }
1343
1344
1345 func (in *StreamOracleExcludedObjects) DeepCopyInto(out *StreamOracleExcludedObjects) {
1346 *out = *in
1347 if in.OracleSchemas != nil {
1348 in, out := &in.OracleSchemas, &out.OracleSchemas
1349 *out = make([]StreamOracleSchemas, len(*in))
1350 for i := range *in {
1351 (*in)[i].DeepCopyInto(&(*out)[i])
1352 }
1353 }
1354 return
1355 }
1356
1357
1358 func (in *StreamOracleExcludedObjects) DeepCopy() *StreamOracleExcludedObjects {
1359 if in == nil {
1360 return nil
1361 }
1362 out := new(StreamOracleExcludedObjects)
1363 in.DeepCopyInto(out)
1364 return out
1365 }
1366
1367
1368 func (in *StreamOracleSchemas) DeepCopyInto(out *StreamOracleSchemas) {
1369 *out = *in
1370 if in.OracleTables != nil {
1371 in, out := &in.OracleTables, &out.OracleTables
1372 *out = make([]StreamOracleTables, len(*in))
1373 for i := range *in {
1374 (*in)[i].DeepCopyInto(&(*out)[i])
1375 }
1376 }
1377 return
1378 }
1379
1380
1381 func (in *StreamOracleSchemas) DeepCopy() *StreamOracleSchemas {
1382 if in == nil {
1383 return nil
1384 }
1385 out := new(StreamOracleSchemas)
1386 in.DeepCopyInto(out)
1387 return out
1388 }
1389
1390
1391 func (in *StreamOracleSourceConfig) DeepCopyInto(out *StreamOracleSourceConfig) {
1392 *out = *in
1393 if in.DropLargeObjects != nil {
1394 in, out := &in.DropLargeObjects, &out.DropLargeObjects
1395 *out = new(StreamDropLargeObjects)
1396 **out = **in
1397 }
1398 if in.ExcludeObjects != nil {
1399 in, out := &in.ExcludeObjects, &out.ExcludeObjects
1400 *out = new(StreamExcludeObjects)
1401 (*in).DeepCopyInto(*out)
1402 }
1403 if in.IncludeObjects != nil {
1404 in, out := &in.IncludeObjects, &out.IncludeObjects
1405 *out = new(StreamIncludeObjects)
1406 (*in).DeepCopyInto(*out)
1407 }
1408 if in.MaxConcurrentBackfillTasks != nil {
1409 in, out := &in.MaxConcurrentBackfillTasks, &out.MaxConcurrentBackfillTasks
1410 *out = new(int)
1411 **out = **in
1412 }
1413 if in.MaxConcurrentCdcTasks != nil {
1414 in, out := &in.MaxConcurrentCdcTasks, &out.MaxConcurrentCdcTasks
1415 *out = new(int)
1416 **out = **in
1417 }
1418 if in.StreamLargeObjects != nil {
1419 in, out := &in.StreamLargeObjects, &out.StreamLargeObjects
1420 *out = new(StreamStreamLargeObjects)
1421 **out = **in
1422 }
1423 return
1424 }
1425
1426
1427 func (in *StreamOracleSourceConfig) DeepCopy() *StreamOracleSourceConfig {
1428 if in == nil {
1429 return nil
1430 }
1431 out := new(StreamOracleSourceConfig)
1432 in.DeepCopyInto(out)
1433 return out
1434 }
1435
1436
1437 func (in *StreamOracleTables) DeepCopyInto(out *StreamOracleTables) {
1438 *out = *in
1439 if in.OracleColumns != nil {
1440 in, out := &in.OracleColumns, &out.OracleColumns
1441 *out = make([]StreamOracleColumns, len(*in))
1442 for i := range *in {
1443 (*in)[i].DeepCopyInto(&(*out)[i])
1444 }
1445 }
1446 return
1447 }
1448
1449
1450 func (in *StreamOracleTables) DeepCopy() *StreamOracleTables {
1451 if in == nil {
1452 return nil
1453 }
1454 out := new(StreamOracleTables)
1455 in.DeepCopyInto(out)
1456 return out
1457 }
1458
1459
1460 func (in *StreamPostgresqlColumns) DeepCopyInto(out *StreamPostgresqlColumns) {
1461 *out = *in
1462 if in.Column != nil {
1463 in, out := &in.Column, &out.Column
1464 *out = new(string)
1465 **out = **in
1466 }
1467 if in.DataType != nil {
1468 in, out := &in.DataType, &out.DataType
1469 *out = new(string)
1470 **out = **in
1471 }
1472 if in.Length != nil {
1473 in, out := &in.Length, &out.Length
1474 *out = new(int)
1475 **out = **in
1476 }
1477 if in.Nullable != nil {
1478 in, out := &in.Nullable, &out.Nullable
1479 *out = new(bool)
1480 **out = **in
1481 }
1482 if in.OrdinalPosition != nil {
1483 in, out := &in.OrdinalPosition, &out.OrdinalPosition
1484 *out = new(int)
1485 **out = **in
1486 }
1487 if in.Precision != nil {
1488 in, out := &in.Precision, &out.Precision
1489 *out = new(int)
1490 **out = **in
1491 }
1492 if in.PrimaryKey != nil {
1493 in, out := &in.PrimaryKey, &out.PrimaryKey
1494 *out = new(bool)
1495 **out = **in
1496 }
1497 if in.Scale != nil {
1498 in, out := &in.Scale, &out.Scale
1499 *out = new(int)
1500 **out = **in
1501 }
1502 return
1503 }
1504
1505
1506 func (in *StreamPostgresqlColumns) DeepCopy() *StreamPostgresqlColumns {
1507 if in == nil {
1508 return nil
1509 }
1510 out := new(StreamPostgresqlColumns)
1511 in.DeepCopyInto(out)
1512 return out
1513 }
1514
1515
1516 func (in *StreamPostgresqlExcludedObjects) DeepCopyInto(out *StreamPostgresqlExcludedObjects) {
1517 *out = *in
1518 if in.PostgresqlSchemas != nil {
1519 in, out := &in.PostgresqlSchemas, &out.PostgresqlSchemas
1520 *out = make([]StreamPostgresqlSchemas, len(*in))
1521 for i := range *in {
1522 (*in)[i].DeepCopyInto(&(*out)[i])
1523 }
1524 }
1525 return
1526 }
1527
1528
1529 func (in *StreamPostgresqlExcludedObjects) DeepCopy() *StreamPostgresqlExcludedObjects {
1530 if in == nil {
1531 return nil
1532 }
1533 out := new(StreamPostgresqlExcludedObjects)
1534 in.DeepCopyInto(out)
1535 return out
1536 }
1537
1538
1539 func (in *StreamPostgresqlSchemas) DeepCopyInto(out *StreamPostgresqlSchemas) {
1540 *out = *in
1541 if in.PostgresqlTables != nil {
1542 in, out := &in.PostgresqlTables, &out.PostgresqlTables
1543 *out = make([]StreamPostgresqlTables, len(*in))
1544 for i := range *in {
1545 (*in)[i].DeepCopyInto(&(*out)[i])
1546 }
1547 }
1548 return
1549 }
1550
1551
1552 func (in *StreamPostgresqlSchemas) DeepCopy() *StreamPostgresqlSchemas {
1553 if in == nil {
1554 return nil
1555 }
1556 out := new(StreamPostgresqlSchemas)
1557 in.DeepCopyInto(out)
1558 return out
1559 }
1560
1561
1562 func (in *StreamPostgresqlSourceConfig) DeepCopyInto(out *StreamPostgresqlSourceConfig) {
1563 *out = *in
1564 if in.ExcludeObjects != nil {
1565 in, out := &in.ExcludeObjects, &out.ExcludeObjects
1566 *out = new(StreamExcludeObjects)
1567 (*in).DeepCopyInto(*out)
1568 }
1569 if in.IncludeObjects != nil {
1570 in, out := &in.IncludeObjects, &out.IncludeObjects
1571 *out = new(StreamIncludeObjects)
1572 (*in).DeepCopyInto(*out)
1573 }
1574 if in.MaxConcurrentBackfillTasks != nil {
1575 in, out := &in.MaxConcurrentBackfillTasks, &out.MaxConcurrentBackfillTasks
1576 *out = new(int)
1577 **out = **in
1578 }
1579 return
1580 }
1581
1582
1583 func (in *StreamPostgresqlSourceConfig) DeepCopy() *StreamPostgresqlSourceConfig {
1584 if in == nil {
1585 return nil
1586 }
1587 out := new(StreamPostgresqlSourceConfig)
1588 in.DeepCopyInto(out)
1589 return out
1590 }
1591
1592
1593 func (in *StreamPostgresqlTables) DeepCopyInto(out *StreamPostgresqlTables) {
1594 *out = *in
1595 if in.PostgresqlColumns != nil {
1596 in, out := &in.PostgresqlColumns, &out.PostgresqlColumns
1597 *out = make([]StreamPostgresqlColumns, len(*in))
1598 for i := range *in {
1599 (*in)[i].DeepCopyInto(&(*out)[i])
1600 }
1601 }
1602 return
1603 }
1604
1605
1606 func (in *StreamPostgresqlTables) DeepCopy() *StreamPostgresqlTables {
1607 if in == nil {
1608 return nil
1609 }
1610 out := new(StreamPostgresqlTables)
1611 in.DeepCopyInto(out)
1612 return out
1613 }
1614
1615
1616 func (in *StreamSingleTargetDataset) DeepCopyInto(out *StreamSingleTargetDataset) {
1617 *out = *in
1618 return
1619 }
1620
1621
1622 func (in *StreamSingleTargetDataset) DeepCopy() *StreamSingleTargetDataset {
1623 if in == nil {
1624 return nil
1625 }
1626 out := new(StreamSingleTargetDataset)
1627 in.DeepCopyInto(out)
1628 return out
1629 }
1630
1631
1632 func (in *StreamSourceConfig) DeepCopyInto(out *StreamSourceConfig) {
1633 *out = *in
1634 if in.MysqlSourceConfig != nil {
1635 in, out := &in.MysqlSourceConfig, &out.MysqlSourceConfig
1636 *out = new(StreamMysqlSourceConfig)
1637 (*in).DeepCopyInto(*out)
1638 }
1639 if in.OracleSourceConfig != nil {
1640 in, out := &in.OracleSourceConfig, &out.OracleSourceConfig
1641 *out = new(StreamOracleSourceConfig)
1642 (*in).DeepCopyInto(*out)
1643 }
1644 if in.PostgresqlSourceConfig != nil {
1645 in, out := &in.PostgresqlSourceConfig, &out.PostgresqlSourceConfig
1646 *out = new(StreamPostgresqlSourceConfig)
1647 (*in).DeepCopyInto(*out)
1648 }
1649 return
1650 }
1651
1652
1653 func (in *StreamSourceConfig) DeepCopy() *StreamSourceConfig {
1654 if in == nil {
1655 return nil
1656 }
1657 out := new(StreamSourceConfig)
1658 in.DeepCopyInto(out)
1659 return out
1660 }
1661
1662
1663 func (in *StreamSourceHierarchyDatasets) DeepCopyInto(out *StreamSourceHierarchyDatasets) {
1664 *out = *in
1665 in.DatasetTemplate.DeepCopyInto(&out.DatasetTemplate)
1666 return
1667 }
1668
1669
1670 func (in *StreamSourceHierarchyDatasets) DeepCopy() *StreamSourceHierarchyDatasets {
1671 if in == nil {
1672 return nil
1673 }
1674 out := new(StreamSourceHierarchyDatasets)
1675 in.DeepCopyInto(out)
1676 return out
1677 }
1678
1679
1680 func (in *StreamStreamLargeObjects) DeepCopyInto(out *StreamStreamLargeObjects) {
1681 *out = *in
1682 return
1683 }
1684
1685
1686 func (in *StreamStreamLargeObjects) DeepCopy() *StreamStreamLargeObjects {
1687 if in == nil {
1688 return nil
1689 }
1690 out := new(StreamStreamLargeObjects)
1691 in.DeepCopyInto(out)
1692 return out
1693 }
1694
View as plain text