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 v1beta1
26
27 import (
28 v1alpha1 "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 *PubSubSchema) DeepCopyInto(out *PubSubSchema) {
34 *out = *in
35 out.TypeMeta = in.TypeMeta
36 in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
37 in.Spec.DeepCopyInto(&out.Spec)
38 in.Status.DeepCopyInto(&out.Status)
39 return
40 }
41
42
43 func (in *PubSubSchema) DeepCopy() *PubSubSchema {
44 if in == nil {
45 return nil
46 }
47 out := new(PubSubSchema)
48 in.DeepCopyInto(out)
49 return out
50 }
51
52
53 func (in *PubSubSchema) DeepCopyObject() runtime.Object {
54 if c := in.DeepCopy(); c != nil {
55 return c
56 }
57 return nil
58 }
59
60
61 func (in *PubSubSchemaList) DeepCopyInto(out *PubSubSchemaList) {
62 *out = *in
63 out.TypeMeta = in.TypeMeta
64 in.ListMeta.DeepCopyInto(&out.ListMeta)
65 if in.Items != nil {
66 in, out := &in.Items, &out.Items
67 *out = make([]PubSubSchema, len(*in))
68 for i := range *in {
69 (*in)[i].DeepCopyInto(&(*out)[i])
70 }
71 }
72 return
73 }
74
75
76 func (in *PubSubSchemaList) DeepCopy() *PubSubSchemaList {
77 if in == nil {
78 return nil
79 }
80 out := new(PubSubSchemaList)
81 in.DeepCopyInto(out)
82 return out
83 }
84
85
86 func (in *PubSubSchemaList) DeepCopyObject() runtime.Object {
87 if c := in.DeepCopy(); c != nil {
88 return c
89 }
90 return nil
91 }
92
93
94 func (in *PubSubSchemaSpec) DeepCopyInto(out *PubSubSchemaSpec) {
95 *out = *in
96 if in.Definition != nil {
97 in, out := &in.Definition, &out.Definition
98 *out = new(string)
99 **out = **in
100 }
101 out.ProjectRef = in.ProjectRef
102 if in.ResourceID != nil {
103 in, out := &in.ResourceID, &out.ResourceID
104 *out = new(string)
105 **out = **in
106 }
107 if in.Type != nil {
108 in, out := &in.Type, &out.Type
109 *out = new(string)
110 **out = **in
111 }
112 return
113 }
114
115
116 func (in *PubSubSchemaSpec) DeepCopy() *PubSubSchemaSpec {
117 if in == nil {
118 return nil
119 }
120 out := new(PubSubSchemaSpec)
121 in.DeepCopyInto(out)
122 return out
123 }
124
125
126 func (in *PubSubSchemaStatus) DeepCopyInto(out *PubSubSchemaStatus) {
127 *out = *in
128 if in.Conditions != nil {
129 in, out := &in.Conditions, &out.Conditions
130 *out = make([]v1alpha1.Condition, len(*in))
131 copy(*out, *in)
132 }
133 if in.ObservedGeneration != nil {
134 in, out := &in.ObservedGeneration, &out.ObservedGeneration
135 *out = new(int)
136 **out = **in
137 }
138 return
139 }
140
141
142 func (in *PubSubSchemaStatus) DeepCopy() *PubSubSchemaStatus {
143 if in == nil {
144 return nil
145 }
146 out := new(PubSubSchemaStatus)
147 in.DeepCopyInto(out)
148 return out
149 }
150
151
152 func (in *PubSubSubscription) DeepCopyInto(out *PubSubSubscription) {
153 *out = *in
154 out.TypeMeta = in.TypeMeta
155 in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
156 in.Spec.DeepCopyInto(&out.Spec)
157 in.Status.DeepCopyInto(&out.Status)
158 return
159 }
160
161
162 func (in *PubSubSubscription) DeepCopy() *PubSubSubscription {
163 if in == nil {
164 return nil
165 }
166 out := new(PubSubSubscription)
167 in.DeepCopyInto(out)
168 return out
169 }
170
171
172 func (in *PubSubSubscription) DeepCopyObject() runtime.Object {
173 if c := in.DeepCopy(); c != nil {
174 return c
175 }
176 return nil
177 }
178
179
180 func (in *PubSubSubscriptionList) DeepCopyInto(out *PubSubSubscriptionList) {
181 *out = *in
182 out.TypeMeta = in.TypeMeta
183 in.ListMeta.DeepCopyInto(&out.ListMeta)
184 if in.Items != nil {
185 in, out := &in.Items, &out.Items
186 *out = make([]PubSubSubscription, len(*in))
187 for i := range *in {
188 (*in)[i].DeepCopyInto(&(*out)[i])
189 }
190 }
191 return
192 }
193
194
195 func (in *PubSubSubscriptionList) DeepCopy() *PubSubSubscriptionList {
196 if in == nil {
197 return nil
198 }
199 out := new(PubSubSubscriptionList)
200 in.DeepCopyInto(out)
201 return out
202 }
203
204
205 func (in *PubSubSubscriptionList) DeepCopyObject() runtime.Object {
206 if c := in.DeepCopy(); c != nil {
207 return c
208 }
209 return nil
210 }
211
212
213 func (in *PubSubSubscriptionSpec) DeepCopyInto(out *PubSubSubscriptionSpec) {
214 *out = *in
215 if in.AckDeadlineSeconds != nil {
216 in, out := &in.AckDeadlineSeconds, &out.AckDeadlineSeconds
217 *out = new(int)
218 **out = **in
219 }
220 if in.BigqueryConfig != nil {
221 in, out := &in.BigqueryConfig, &out.BigqueryConfig
222 *out = new(SubscriptionBigqueryConfig)
223 (*in).DeepCopyInto(*out)
224 }
225 if in.DeadLetterPolicy != nil {
226 in, out := &in.DeadLetterPolicy, &out.DeadLetterPolicy
227 *out = new(SubscriptionDeadLetterPolicy)
228 (*in).DeepCopyInto(*out)
229 }
230 if in.EnableExactlyOnceDelivery != nil {
231 in, out := &in.EnableExactlyOnceDelivery, &out.EnableExactlyOnceDelivery
232 *out = new(bool)
233 **out = **in
234 }
235 if in.EnableMessageOrdering != nil {
236 in, out := &in.EnableMessageOrdering, &out.EnableMessageOrdering
237 *out = new(bool)
238 **out = **in
239 }
240 if in.ExpirationPolicy != nil {
241 in, out := &in.ExpirationPolicy, &out.ExpirationPolicy
242 *out = new(SubscriptionExpirationPolicy)
243 **out = **in
244 }
245 if in.Filter != nil {
246 in, out := &in.Filter, &out.Filter
247 *out = new(string)
248 **out = **in
249 }
250 if in.MessageRetentionDuration != nil {
251 in, out := &in.MessageRetentionDuration, &out.MessageRetentionDuration
252 *out = new(string)
253 **out = **in
254 }
255 if in.PushConfig != nil {
256 in, out := &in.PushConfig, &out.PushConfig
257 *out = new(SubscriptionPushConfig)
258 (*in).DeepCopyInto(*out)
259 }
260 if in.ResourceID != nil {
261 in, out := &in.ResourceID, &out.ResourceID
262 *out = new(string)
263 **out = **in
264 }
265 if in.RetainAckedMessages != nil {
266 in, out := &in.RetainAckedMessages, &out.RetainAckedMessages
267 *out = new(bool)
268 **out = **in
269 }
270 if in.RetryPolicy != nil {
271 in, out := &in.RetryPolicy, &out.RetryPolicy
272 *out = new(SubscriptionRetryPolicy)
273 (*in).DeepCopyInto(*out)
274 }
275 out.TopicRef = in.TopicRef
276 return
277 }
278
279
280 func (in *PubSubSubscriptionSpec) DeepCopy() *PubSubSubscriptionSpec {
281 if in == nil {
282 return nil
283 }
284 out := new(PubSubSubscriptionSpec)
285 in.DeepCopyInto(out)
286 return out
287 }
288
289
290 func (in *PubSubSubscriptionStatus) DeepCopyInto(out *PubSubSubscriptionStatus) {
291 *out = *in
292 if in.Conditions != nil {
293 in, out := &in.Conditions, &out.Conditions
294 *out = make([]v1alpha1.Condition, len(*in))
295 copy(*out, *in)
296 }
297 if in.ObservedGeneration != nil {
298 in, out := &in.ObservedGeneration, &out.ObservedGeneration
299 *out = new(int)
300 **out = **in
301 }
302 return
303 }
304
305
306 func (in *PubSubSubscriptionStatus) DeepCopy() *PubSubSubscriptionStatus {
307 if in == nil {
308 return nil
309 }
310 out := new(PubSubSubscriptionStatus)
311 in.DeepCopyInto(out)
312 return out
313 }
314
315
316 func (in *PubSubTopic) DeepCopyInto(out *PubSubTopic) {
317 *out = *in
318 out.TypeMeta = in.TypeMeta
319 in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
320 in.Spec.DeepCopyInto(&out.Spec)
321 in.Status.DeepCopyInto(&out.Status)
322 return
323 }
324
325
326 func (in *PubSubTopic) DeepCopy() *PubSubTopic {
327 if in == nil {
328 return nil
329 }
330 out := new(PubSubTopic)
331 in.DeepCopyInto(out)
332 return out
333 }
334
335
336 func (in *PubSubTopic) DeepCopyObject() runtime.Object {
337 if c := in.DeepCopy(); c != nil {
338 return c
339 }
340 return nil
341 }
342
343
344 func (in *PubSubTopicList) DeepCopyInto(out *PubSubTopicList) {
345 *out = *in
346 out.TypeMeta = in.TypeMeta
347 in.ListMeta.DeepCopyInto(&out.ListMeta)
348 if in.Items != nil {
349 in, out := &in.Items, &out.Items
350 *out = make([]PubSubTopic, len(*in))
351 for i := range *in {
352 (*in)[i].DeepCopyInto(&(*out)[i])
353 }
354 }
355 return
356 }
357
358
359 func (in *PubSubTopicList) DeepCopy() *PubSubTopicList {
360 if in == nil {
361 return nil
362 }
363 out := new(PubSubTopicList)
364 in.DeepCopyInto(out)
365 return out
366 }
367
368
369 func (in *PubSubTopicList) DeepCopyObject() runtime.Object {
370 if c := in.DeepCopy(); c != nil {
371 return c
372 }
373 return nil
374 }
375
376
377 func (in *PubSubTopicSpec) DeepCopyInto(out *PubSubTopicSpec) {
378 *out = *in
379 if in.KmsKeyRef != nil {
380 in, out := &in.KmsKeyRef, &out.KmsKeyRef
381 *out = new(v1alpha1.ResourceRef)
382 **out = **in
383 }
384 if in.MessageRetentionDuration != nil {
385 in, out := &in.MessageRetentionDuration, &out.MessageRetentionDuration
386 *out = new(string)
387 **out = **in
388 }
389 if in.MessageStoragePolicy != nil {
390 in, out := &in.MessageStoragePolicy, &out.MessageStoragePolicy
391 *out = new(TopicMessageStoragePolicy)
392 (*in).DeepCopyInto(*out)
393 }
394 if in.ResourceID != nil {
395 in, out := &in.ResourceID, &out.ResourceID
396 *out = new(string)
397 **out = **in
398 }
399 if in.SchemaSettings != nil {
400 in, out := &in.SchemaSettings, &out.SchemaSettings
401 *out = new(TopicSchemaSettings)
402 (*in).DeepCopyInto(*out)
403 }
404 return
405 }
406
407
408 func (in *PubSubTopicSpec) DeepCopy() *PubSubTopicSpec {
409 if in == nil {
410 return nil
411 }
412 out := new(PubSubTopicSpec)
413 in.DeepCopyInto(out)
414 return out
415 }
416
417
418 func (in *PubSubTopicStatus) DeepCopyInto(out *PubSubTopicStatus) {
419 *out = *in
420 if in.Conditions != nil {
421 in, out := &in.Conditions, &out.Conditions
422 *out = make([]v1alpha1.Condition, len(*in))
423 copy(*out, *in)
424 }
425 if in.ObservedGeneration != nil {
426 in, out := &in.ObservedGeneration, &out.ObservedGeneration
427 *out = new(int)
428 **out = **in
429 }
430 return
431 }
432
433
434 func (in *PubSubTopicStatus) DeepCopy() *PubSubTopicStatus {
435 if in == nil {
436 return nil
437 }
438 out := new(PubSubTopicStatus)
439 in.DeepCopyInto(out)
440 return out
441 }
442
443
444 func (in *SubscriptionBigqueryConfig) DeepCopyInto(out *SubscriptionBigqueryConfig) {
445 *out = *in
446 if in.DropUnknownFields != nil {
447 in, out := &in.DropUnknownFields, &out.DropUnknownFields
448 *out = new(bool)
449 **out = **in
450 }
451 out.TableRef = in.TableRef
452 if in.UseTopicSchema != nil {
453 in, out := &in.UseTopicSchema, &out.UseTopicSchema
454 *out = new(bool)
455 **out = **in
456 }
457 if in.WriteMetadata != nil {
458 in, out := &in.WriteMetadata, &out.WriteMetadata
459 *out = new(bool)
460 **out = **in
461 }
462 return
463 }
464
465
466 func (in *SubscriptionBigqueryConfig) DeepCopy() *SubscriptionBigqueryConfig {
467 if in == nil {
468 return nil
469 }
470 out := new(SubscriptionBigqueryConfig)
471 in.DeepCopyInto(out)
472 return out
473 }
474
475
476 func (in *SubscriptionDeadLetterPolicy) DeepCopyInto(out *SubscriptionDeadLetterPolicy) {
477 *out = *in
478 if in.DeadLetterTopicRef != nil {
479 in, out := &in.DeadLetterTopicRef, &out.DeadLetterTopicRef
480 *out = new(v1alpha1.ResourceRef)
481 **out = **in
482 }
483 if in.MaxDeliveryAttempts != nil {
484 in, out := &in.MaxDeliveryAttempts, &out.MaxDeliveryAttempts
485 *out = new(int)
486 **out = **in
487 }
488 return
489 }
490
491
492 func (in *SubscriptionDeadLetterPolicy) DeepCopy() *SubscriptionDeadLetterPolicy {
493 if in == nil {
494 return nil
495 }
496 out := new(SubscriptionDeadLetterPolicy)
497 in.DeepCopyInto(out)
498 return out
499 }
500
501
502 func (in *SubscriptionExpirationPolicy) DeepCopyInto(out *SubscriptionExpirationPolicy) {
503 *out = *in
504 return
505 }
506
507
508 func (in *SubscriptionExpirationPolicy) DeepCopy() *SubscriptionExpirationPolicy {
509 if in == nil {
510 return nil
511 }
512 out := new(SubscriptionExpirationPolicy)
513 in.DeepCopyInto(out)
514 return out
515 }
516
517
518 func (in *SubscriptionOidcToken) DeepCopyInto(out *SubscriptionOidcToken) {
519 *out = *in
520 if in.Audience != nil {
521 in, out := &in.Audience, &out.Audience
522 *out = new(string)
523 **out = **in
524 }
525 return
526 }
527
528
529 func (in *SubscriptionOidcToken) DeepCopy() *SubscriptionOidcToken {
530 if in == nil {
531 return nil
532 }
533 out := new(SubscriptionOidcToken)
534 in.DeepCopyInto(out)
535 return out
536 }
537
538
539 func (in *SubscriptionPushConfig) DeepCopyInto(out *SubscriptionPushConfig) {
540 *out = *in
541 if in.Attributes != nil {
542 in, out := &in.Attributes, &out.Attributes
543 *out = make(map[string]string, len(*in))
544 for key, val := range *in {
545 (*out)[key] = val
546 }
547 }
548 if in.OidcToken != nil {
549 in, out := &in.OidcToken, &out.OidcToken
550 *out = new(SubscriptionOidcToken)
551 (*in).DeepCopyInto(*out)
552 }
553 return
554 }
555
556
557 func (in *SubscriptionPushConfig) DeepCopy() *SubscriptionPushConfig {
558 if in == nil {
559 return nil
560 }
561 out := new(SubscriptionPushConfig)
562 in.DeepCopyInto(out)
563 return out
564 }
565
566
567 func (in *SubscriptionRetryPolicy) DeepCopyInto(out *SubscriptionRetryPolicy) {
568 *out = *in
569 if in.MaximumBackoff != nil {
570 in, out := &in.MaximumBackoff, &out.MaximumBackoff
571 *out = new(string)
572 **out = **in
573 }
574 if in.MinimumBackoff != nil {
575 in, out := &in.MinimumBackoff, &out.MinimumBackoff
576 *out = new(string)
577 **out = **in
578 }
579 return
580 }
581
582
583 func (in *SubscriptionRetryPolicy) DeepCopy() *SubscriptionRetryPolicy {
584 if in == nil {
585 return nil
586 }
587 out := new(SubscriptionRetryPolicy)
588 in.DeepCopyInto(out)
589 return out
590 }
591
592
593 func (in *TopicMessageStoragePolicy) DeepCopyInto(out *TopicMessageStoragePolicy) {
594 *out = *in
595 if in.AllowedPersistenceRegions != nil {
596 in, out := &in.AllowedPersistenceRegions, &out.AllowedPersistenceRegions
597 *out = make([]string, len(*in))
598 copy(*out, *in)
599 }
600 return
601 }
602
603
604 func (in *TopicMessageStoragePolicy) DeepCopy() *TopicMessageStoragePolicy {
605 if in == nil {
606 return nil
607 }
608 out := new(TopicMessageStoragePolicy)
609 in.DeepCopyInto(out)
610 return out
611 }
612
613
614 func (in *TopicSchemaSettings) DeepCopyInto(out *TopicSchemaSettings) {
615 *out = *in
616 if in.Encoding != nil {
617 in, out := &in.Encoding, &out.Encoding
618 *out = new(string)
619 **out = **in
620 }
621 out.SchemaRef = in.SchemaRef
622 return
623 }
624
625
626 func (in *TopicSchemaSettings) DeepCopy() *TopicSchemaSettings {
627 if in == nil {
628 return nil
629 }
630 out := new(TopicSchemaSettings)
631 in.DeepCopyInto(out)
632 return out
633 }
634
View as plain text