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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51 package composer
52
53 import (
54 "bytes"
55 "context"
56 "encoding/json"
57 "errors"
58 "fmt"
59 "io"
60 "net/http"
61 "net/url"
62 "strconv"
63 "strings"
64
65 googleapi "google.golang.org/api/googleapi"
66 internal "google.golang.org/api/internal"
67 gensupport "google.golang.org/api/internal/gensupport"
68 option "google.golang.org/api/option"
69 internaloption "google.golang.org/api/option/internaloption"
70 htransport "google.golang.org/api/transport/http"
71 )
72
73
74
75 var _ = bytes.NewBuffer
76 var _ = strconv.Itoa
77 var _ = fmt.Sprintf
78 var _ = json.NewDecoder
79 var _ = io.Copy
80 var _ = url.Parse
81 var _ = gensupport.MarshalJSON
82 var _ = googleapi.Version
83 var _ = errors.New
84 var _ = strings.Replace
85 var _ = context.Canceled
86 var _ = internaloption.WithDefaultEndpoint
87 var _ = internal.Version
88
89 const apiId = "composer:v1beta1"
90 const apiName = "composer"
91 const apiVersion = "v1beta1"
92 const basePath = "https://composer.googleapis.com/"
93 const basePathTemplate = "https://composer.UNIVERSE_DOMAIN/"
94 const mtlsBasePath = "https://composer.mtls.googleapis.com/"
95
96
97 const (
98
99
100 CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform"
101 )
102
103
104 func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error) {
105 scopesOption := internaloption.WithDefaultScopes(
106 "https://www.googleapis.com/auth/cloud-platform",
107 )
108
109 opts = append([]option.ClientOption{scopesOption}, opts...)
110 opts = append(opts, internaloption.WithDefaultEndpoint(basePath))
111 opts = append(opts, internaloption.WithDefaultEndpointTemplate(basePathTemplate))
112 opts = append(opts, internaloption.WithDefaultMTLSEndpoint(mtlsBasePath))
113 opts = append(opts, internaloption.EnableNewAuthLibrary())
114 client, endpoint, err := htransport.NewClient(ctx, opts...)
115 if err != nil {
116 return nil, err
117 }
118 s, err := New(client)
119 if err != nil {
120 return nil, err
121 }
122 if endpoint != "" {
123 s.BasePath = endpoint
124 }
125 return s, nil
126 }
127
128
129
130
131
132
133 func New(client *http.Client) (*Service, error) {
134 if client == nil {
135 return nil, errors.New("client is nil")
136 }
137 s := &Service{client: client, BasePath: basePath}
138 s.Projects = NewProjectsService(s)
139 return s, nil
140 }
141
142 type Service struct {
143 client *http.Client
144 BasePath string
145 UserAgent string
146
147 Projects *ProjectsService
148 }
149
150 func (s *Service) userAgent() string {
151 if s.UserAgent == "" {
152 return googleapi.UserAgent
153 }
154 return googleapi.UserAgent + " " + s.UserAgent
155 }
156
157 func NewProjectsService(s *Service) *ProjectsService {
158 rs := &ProjectsService{s: s}
159 rs.Locations = NewProjectsLocationsService(s)
160 return rs
161 }
162
163 type ProjectsService struct {
164 s *Service
165
166 Locations *ProjectsLocationsService
167 }
168
169 func NewProjectsLocationsService(s *Service) *ProjectsLocationsService {
170 rs := &ProjectsLocationsService{s: s}
171 rs.Environments = NewProjectsLocationsEnvironmentsService(s)
172 rs.ImageVersions = NewProjectsLocationsImageVersionsService(s)
173 rs.Operations = NewProjectsLocationsOperationsService(s)
174 return rs
175 }
176
177 type ProjectsLocationsService struct {
178 s *Service
179
180 Environments *ProjectsLocationsEnvironmentsService
181
182 ImageVersions *ProjectsLocationsImageVersionsService
183
184 Operations *ProjectsLocationsOperationsService
185 }
186
187 func NewProjectsLocationsEnvironmentsService(s *Service) *ProjectsLocationsEnvironmentsService {
188 rs := &ProjectsLocationsEnvironmentsService{s: s}
189 rs.UserWorkloadsConfigMaps = NewProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService(s)
190 rs.UserWorkloadsSecrets = NewProjectsLocationsEnvironmentsUserWorkloadsSecretsService(s)
191 rs.Workloads = NewProjectsLocationsEnvironmentsWorkloadsService(s)
192 return rs
193 }
194
195 type ProjectsLocationsEnvironmentsService struct {
196 s *Service
197
198 UserWorkloadsConfigMaps *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService
199
200 UserWorkloadsSecrets *ProjectsLocationsEnvironmentsUserWorkloadsSecretsService
201
202 Workloads *ProjectsLocationsEnvironmentsWorkloadsService
203 }
204
205 func NewProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService(s *Service) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService {
206 rs := &ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService{s: s}
207 return rs
208 }
209
210 type ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService struct {
211 s *Service
212 }
213
214 func NewProjectsLocationsEnvironmentsUserWorkloadsSecretsService(s *Service) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsService {
215 rs := &ProjectsLocationsEnvironmentsUserWorkloadsSecretsService{s: s}
216 return rs
217 }
218
219 type ProjectsLocationsEnvironmentsUserWorkloadsSecretsService struct {
220 s *Service
221 }
222
223 func NewProjectsLocationsEnvironmentsWorkloadsService(s *Service) *ProjectsLocationsEnvironmentsWorkloadsService {
224 rs := &ProjectsLocationsEnvironmentsWorkloadsService{s: s}
225 return rs
226 }
227
228 type ProjectsLocationsEnvironmentsWorkloadsService struct {
229 s *Service
230 }
231
232 func NewProjectsLocationsImageVersionsService(s *Service) *ProjectsLocationsImageVersionsService {
233 rs := &ProjectsLocationsImageVersionsService{s: s}
234 return rs
235 }
236
237 type ProjectsLocationsImageVersionsService struct {
238 s *Service
239 }
240
241 func NewProjectsLocationsOperationsService(s *Service) *ProjectsLocationsOperationsService {
242 rs := &ProjectsLocationsOperationsService{s: s}
243 return rs
244 }
245
246 type ProjectsLocationsOperationsService struct {
247 s *Service
248 }
249
250
251
252 type AirflowMetadataRetentionPolicyConfig struct {
253
254 RetentionDays int64 `json:"retentionDays,omitempty"`
255
256
257
258
259
260
261
262 RetentionMode string `json:"retentionMode,omitempty"`
263
264
265
266
267
268 ForceSendFields []string `json:"-"`
269
270
271
272
273 NullFields []string `json:"-"`
274 }
275
276 func (s *AirflowMetadataRetentionPolicyConfig) MarshalJSON() ([]byte, error) {
277 type NoMethod AirflowMetadataRetentionPolicyConfig
278 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
279 }
280
281
282 type AllowedIpRange struct {
283
284
285 Description string `json:"description,omitempty"`
286
287
288
289
290
291
292 Value string `json:"value,omitempty"`
293
294
295
296
297
298 ForceSendFields []string `json:"-"`
299
300
301
302
303 NullFields []string `json:"-"`
304 }
305
306 func (s *AllowedIpRange) MarshalJSON() ([]byte, error) {
307 type NoMethod AllowedIpRange
308 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
309 }
310
311
312 type CheckUpgradeRequest struct {
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331 ImageVersion string `json:"imageVersion,omitempty"`
332
333
334
335
336
337 ForceSendFields []string `json:"-"`
338
339
340
341
342 NullFields []string `json:"-"`
343 }
344
345 func (s *CheckUpgradeRequest) MarshalJSON() ([]byte, error) {
346 type NoMethod CheckUpgradeRequest
347 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
348 }
349
350
351
352 type CheckUpgradeResponse struct {
353
354 BuildLogUri string `json:"buildLogUri,omitempty"`
355
356
357
358
359
360
361
362
363 ContainsPypiModulesConflict string `json:"containsPypiModulesConflict,omitempty"`
364
365 ImageVersion string `json:"imageVersion,omitempty"`
366
367
368 PypiConflictBuildLogExtract string `json:"pypiConflictBuildLogExtract,omitempty"`
369
370
371 PypiDependencies map[string]string `json:"pypiDependencies,omitempty"`
372
373
374
375
376
377 ForceSendFields []string `json:"-"`
378
379
380
381
382 NullFields []string `json:"-"`
383 }
384
385 func (s *CheckUpgradeResponse) MarshalJSON() ([]byte, error) {
386 type NoMethod CheckUpgradeResponse
387 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
388 }
389
390
391 type CidrBlock struct {
392
393 CidrBlock string `json:"cidrBlock,omitempty"`
394
395 DisplayName string `json:"displayName,omitempty"`
396
397
398
399
400
401 ForceSendFields []string `json:"-"`
402
403
404
405
406 NullFields []string `json:"-"`
407 }
408
409 func (s *CidrBlock) MarshalJSON() ([]byte, error) {
410 type NoMethod CidrBlock
411 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
412 }
413
414
415
416 type CloudDataLineageIntegration struct {
417
418 Enabled bool `json:"enabled,omitempty"`
419
420
421
422
423
424 ForceSendFields []string `json:"-"`
425
426
427
428
429 NullFields []string `json:"-"`
430 }
431
432 func (s *CloudDataLineageIntegration) MarshalJSON() ([]byte, error) {
433 type NoMethod CloudDataLineageIntegration
434 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
435 }
436
437
438 type ComposerWorkload struct {
439
440 Name string `json:"name,omitempty"`
441
442 Status *ComposerWorkloadStatus `json:"status,omitempty"`
443
444
445
446
447
448
449
450
451
452
453
454
455
456 Type string `json:"type,omitempty"`
457
458
459
460
461
462 ForceSendFields []string `json:"-"`
463
464
465
466
467 NullFields []string `json:"-"`
468 }
469
470 func (s *ComposerWorkload) MarshalJSON() ([]byte, error) {
471 type NoMethod ComposerWorkload
472 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
473 }
474
475
476 type ComposerWorkloadStatus struct {
477
478 DetailedStatusMessage string `json:"detailedStatusMessage,omitempty"`
479
480
481
482
483
484
485
486
487
488
489
490 State string `json:"state,omitempty"`
491
492 StatusMessage string `json:"statusMessage,omitempty"`
493
494
495
496
497
498 ForceSendFields []string `json:"-"`
499
500
501
502
503 NullFields []string `json:"-"`
504 }
505
506 func (s *ComposerWorkloadStatus) MarshalJSON() ([]byte, error) {
507 type NoMethod ComposerWorkloadStatus
508 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
509 }
510
511
512
513
514 type DagProcessorResource struct {
515
516
517 Count int64 `json:"count,omitempty"`
518
519
520 Cpu float64 `json:"cpu,omitempty"`
521
522
523 MemoryGb float64 `json:"memoryGb,omitempty"`
524
525
526 StorageGb float64 `json:"storageGb,omitempty"`
527
528
529
530
531
532 ForceSendFields []string `json:"-"`
533
534
535
536
537 NullFields []string `json:"-"`
538 }
539
540 func (s *DagProcessorResource) MarshalJSON() ([]byte, error) {
541 type NoMethod DagProcessorResource
542 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
543 }
544
545 func (s *DagProcessorResource) UnmarshalJSON(data []byte) error {
546 type NoMethod DagProcessorResource
547 var s1 struct {
548 Cpu gensupport.JSONFloat64 `json:"cpu"`
549 MemoryGb gensupport.JSONFloat64 `json:"memoryGb"`
550 StorageGb gensupport.JSONFloat64 `json:"storageGb"`
551 *NoMethod
552 }
553 s1.NoMethod = (*NoMethod)(s)
554 if err := json.Unmarshal(data, &s1); err != nil {
555 return err
556 }
557 s.Cpu = float64(s1.Cpu)
558 s.MemoryGb = float64(s1.MemoryGb)
559 s.StorageGb = float64(s1.StorageGb)
560 return nil
561 }
562
563
564
565 type DataRetentionConfig struct {
566
567
568
569
570 AirflowDatabaseRetentionDays int64 `json:"airflowDatabaseRetentionDays,omitempty"`
571
572
573 AirflowMetadataRetentionConfig *AirflowMetadataRetentionPolicyConfig `json:"airflowMetadataRetentionConfig,omitempty"`
574
575
576 TaskLogsRetentionConfig *TaskLogsRetentionConfig `json:"taskLogsRetentionConfig,omitempty"`
577
578
579
580
581
582 ForceSendFields []string `json:"-"`
583
584
585
586
587 NullFields []string `json:"-"`
588 }
589
590 func (s *DataRetentionConfig) MarshalJSON() ([]byte, error) {
591 type NoMethod DataRetentionConfig
592 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
593 }
594
595
596
597 type DatabaseConfig struct {
598
599
600
601
602
603 MachineType string `json:"machineType,omitempty"`
604
605
606
607
608
609 Zone string `json:"zone,omitempty"`
610
611
612
613
614
615 ForceSendFields []string `json:"-"`
616
617
618
619
620 NullFields []string `json:"-"`
621 }
622
623 func (s *DatabaseConfig) MarshalJSON() ([]byte, error) {
624 type NoMethod DatabaseConfig
625 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
626 }
627
628
629
630 type DatabaseFailoverRequest struct {
631 }
632
633
634 type DatabaseFailoverResponse struct {
635 }
636
637
638
639
640
641
642
643
644
645
646 type Date struct {
647
648
649
650 Day int64 `json:"day,omitempty"`
651
652
653 Month int64 `json:"month,omitempty"`
654
655
656 Year int64 `json:"year,omitempty"`
657
658
659
660
661
662 ForceSendFields []string `json:"-"`
663
664
665
666
667 NullFields []string `json:"-"`
668 }
669
670 func (s *Date) MarshalJSON() ([]byte, error) {
671 type NoMethod Date
672 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
673 }
674
675
676
677
678
679 type Empty struct {
680
681 googleapi.ServerResponse `json:"-"`
682 }
683
684
685
686
687 type EncryptionConfig struct {
688
689
690
691 KmsKeyName string `json:"kmsKeyName,omitempty"`
692
693
694
695
696
697 ForceSendFields []string `json:"-"`
698
699
700
701
702 NullFields []string `json:"-"`
703 }
704
705 func (s *EncryptionConfig) MarshalJSON() ([]byte, error) {
706 type NoMethod EncryptionConfig
707 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
708 }
709
710
711 type Environment struct {
712
713 Config *EnvironmentConfig `json:"config,omitempty"`
714
715 CreateTime string `json:"createTime,omitempty"`
716
717
718
719
720
721
722 Labels map[string]string `json:"labels,omitempty"`
723
724
725
726
727 Name string `json:"name,omitempty"`
728
729 SatisfiesPzs bool `json:"satisfiesPzs,omitempty"`
730
731
732
733
734
735
736
737
738
739
740
741 State string `json:"state,omitempty"`
742
743 StorageConfig *StorageConfig `json:"storageConfig,omitempty"`
744
745
746 UpdateTime string `json:"updateTime,omitempty"`
747
748
749 Uuid string `json:"uuid,omitempty"`
750
751
752 googleapi.ServerResponse `json:"-"`
753
754
755
756
757
758 ForceSendFields []string `json:"-"`
759
760
761
762
763 NullFields []string `json:"-"`
764 }
765
766 func (s *Environment) MarshalJSON() ([]byte, error) {
767 type NoMethod Environment
768 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
769 }
770
771
772 type EnvironmentConfig struct {
773
774
775
776
777
778
779 AirflowByoidUri string `json:"airflowByoidUri,omitempty"`
780
781
782
783 AirflowUri string `json:"airflowUri,omitempty"`
784
785
786
787
788
789 DagGcsPrefix string `json:"dagGcsPrefix,omitempty"`
790
791
792 DataRetentionConfig *DataRetentionConfig `json:"dataRetentionConfig,omitempty"`
793
794
795 DatabaseConfig *DatabaseConfig `json:"databaseConfig,omitempty"`
796
797
798 EncryptionConfig *EncryptionConfig `json:"encryptionConfig,omitempty"`
799
800
801
802
803
804
805
806
807
808
809 EnvironmentSize string `json:"environmentSize,omitempty"`
810
811
812 GkeCluster string `json:"gkeCluster,omitempty"`
813
814
815
816
817
818
819
820
821
822
823 MaintenanceWindow *MaintenanceWindow `json:"maintenanceWindow,omitempty"`
824
825
826
827
828 MasterAuthorizedNetworksConfig *MasterAuthorizedNetworksConfig `json:"masterAuthorizedNetworksConfig,omitempty"`
829
830 NodeConfig *NodeConfig `json:"nodeConfig,omitempty"`
831
832
833
834 NodeCount int64 `json:"nodeCount,omitempty"`
835
836
837 PrivateEnvironmentConfig *PrivateEnvironmentConfig `json:"privateEnvironmentConfig,omitempty"`
838
839
840
841 RecoveryConfig *RecoveryConfig `json:"recoveryConfig,omitempty"`
842
843
844
845
846
847
848
849
850 ResilienceMode string `json:"resilienceMode,omitempty"`
851
852
853 SoftwareConfig *SoftwareConfig `json:"softwareConfig,omitempty"`
854
855
856
857 WebServerConfig *WebServerConfig `json:"webServerConfig,omitempty"`
858
859
860
861 WebServerNetworkAccessControl *WebServerNetworkAccessControl `json:"webServerNetworkAccessControl,omitempty"`
862
863
864
865
866
867 WorkloadsConfig *WorkloadsConfig `json:"workloadsConfig,omitempty"`
868
869
870
871
872
873 ForceSendFields []string `json:"-"`
874
875
876
877
878 NullFields []string `json:"-"`
879 }
880
881 func (s *EnvironmentConfig) MarshalJSON() ([]byte, error) {
882 type NoMethod EnvironmentConfig
883 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
884 }
885
886
887 type ExecuteAirflowCommandRequest struct {
888
889 Command string `json:"command,omitempty"`
890
891
892
893
894 Parameters []string `json:"parameters,omitempty"`
895
896 Subcommand string `json:"subcommand,omitempty"`
897
898
899
900
901
902 ForceSendFields []string `json:"-"`
903
904
905
906
907 NullFields []string `json:"-"`
908 }
909
910 func (s *ExecuteAirflowCommandRequest) MarshalJSON() ([]byte, error) {
911 type NoMethod ExecuteAirflowCommandRequest
912 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
913 }
914
915
916 type ExecuteAirflowCommandResponse struct {
917
918 Error string `json:"error,omitempty"`
919
920 ExecutionId string `json:"executionId,omitempty"`
921
922 Pod string `json:"pod,omitempty"`
923
924 PodNamespace string `json:"podNamespace,omitempty"`
925
926
927 googleapi.ServerResponse `json:"-"`
928
929
930
931
932
933 ForceSendFields []string `json:"-"`
934
935
936
937
938 NullFields []string `json:"-"`
939 }
940
941 func (s *ExecuteAirflowCommandResponse) MarshalJSON() ([]byte, error) {
942 type NoMethod ExecuteAirflowCommandResponse
943 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
944 }
945
946
947 type ExitInfo struct {
948
949 Error string `json:"error,omitempty"`
950
951 ExitCode int64 `json:"exitCode,omitempty"`
952
953
954
955
956
957 ForceSendFields []string `json:"-"`
958
959
960
961
962 NullFields []string `json:"-"`
963 }
964
965 func (s *ExitInfo) MarshalJSON() ([]byte, error) {
966 type NoMethod ExitInfo
967 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
968 }
969
970
971
972 type FetchDatabasePropertiesResponse struct {
973
974
975
976
977 IsFailoverReplicaAvailable bool `json:"isFailoverReplicaAvailable,omitempty"`
978
979
980 PrimaryGceZone string `json:"primaryGceZone,omitempty"`
981
982
983 SecondaryGceZone string `json:"secondaryGceZone,omitempty"`
984
985
986 googleapi.ServerResponse `json:"-"`
987
988
989
990
991
992 ForceSendFields []string `json:"-"`
993
994
995
996
997 NullFields []string `json:"-"`
998 }
999
1000 func (s *FetchDatabasePropertiesResponse) MarshalJSON() ([]byte, error) {
1001 type NoMethod FetchDatabasePropertiesResponse
1002 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1003 }
1004
1005
1006
1007 type IPAllocationPolicy struct {
1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018 ClusterIpv4CidrBlock string `json:"clusterIpv4CidrBlock,omitempty"`
1019
1020
1021
1022
1023
1024 ClusterSecondaryRangeName string `json:"clusterSecondaryRangeName,omitempty"`
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035 ServicesIpv4CidrBlock string `json:"servicesIpv4CidrBlock,omitempty"`
1036
1037
1038
1039
1040
1041 ServicesSecondaryRangeName string `json:"servicesSecondaryRangeName,omitempty"`
1042
1043
1044
1045
1046
1047 UseIpAliases bool `json:"useIpAliases,omitempty"`
1048
1049
1050
1051
1052
1053 ForceSendFields []string `json:"-"`
1054
1055
1056
1057
1058 NullFields []string `json:"-"`
1059 }
1060
1061 func (s *IPAllocationPolicy) MarshalJSON() ([]byte, error) {
1062 type NoMethod IPAllocationPolicy
1063 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1064 }
1065
1066
1067 type ImageVersion struct {
1068
1069
1070 CreationDisabled bool `json:"creationDisabled,omitempty"`
1071
1072
1073 ImageVersionId string `json:"imageVersionId,omitempty"`
1074
1075
1076 IsDefault bool `json:"isDefault,omitempty"`
1077
1078 ReleaseDate *Date `json:"releaseDate,omitempty"`
1079
1080 SupportedPythonVersions []string `json:"supportedPythonVersions,omitempty"`
1081
1082
1083 UpgradeDisabled bool `json:"upgradeDisabled,omitempty"`
1084
1085
1086
1087
1088
1089 ForceSendFields []string `json:"-"`
1090
1091
1092
1093
1094 NullFields []string `json:"-"`
1095 }
1096
1097 func (s *ImageVersion) MarshalJSON() ([]byte, error) {
1098 type NoMethod ImageVersion
1099 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1100 }
1101
1102
1103 type Line struct {
1104
1105 Content string `json:"content,omitempty"`
1106
1107 LineNumber int64 `json:"lineNumber,omitempty"`
1108
1109
1110
1111
1112
1113 ForceSendFields []string `json:"-"`
1114
1115
1116
1117
1118 NullFields []string `json:"-"`
1119 }
1120
1121 func (s *Line) MarshalJSON() ([]byte, error) {
1122 type NoMethod Line
1123 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1124 }
1125
1126
1127 type ListEnvironmentsResponse struct {
1128
1129
1130 Environments []*Environment `json:"environments,omitempty"`
1131
1132 NextPageToken string `json:"nextPageToken,omitempty"`
1133
1134
1135 googleapi.ServerResponse `json:"-"`
1136
1137
1138
1139
1140
1141 ForceSendFields []string `json:"-"`
1142
1143
1144
1145
1146 NullFields []string `json:"-"`
1147 }
1148
1149 func (s *ListEnvironmentsResponse) MarshalJSON() ([]byte, error) {
1150 type NoMethod ListEnvironmentsResponse
1151 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1152 }
1153
1154
1155 type ListImageVersionsResponse struct {
1156
1157 ImageVersions []*ImageVersion `json:"imageVersions,omitempty"`
1158
1159 NextPageToken string `json:"nextPageToken,omitempty"`
1160
1161
1162 googleapi.ServerResponse `json:"-"`
1163
1164
1165
1166
1167
1168 ForceSendFields []string `json:"-"`
1169
1170
1171
1172
1173 NullFields []string `json:"-"`
1174 }
1175
1176 func (s *ListImageVersionsResponse) MarshalJSON() ([]byte, error) {
1177 type NoMethod ListImageVersionsResponse
1178 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1179 }
1180
1181
1182 type ListOperationsResponse struct {
1183
1184 NextPageToken string `json:"nextPageToken,omitempty"`
1185
1186
1187 Operations []*Operation `json:"operations,omitempty"`
1188
1189
1190 googleapi.ServerResponse `json:"-"`
1191
1192
1193
1194
1195
1196 ForceSendFields []string `json:"-"`
1197
1198
1199
1200
1201 NullFields []string `json:"-"`
1202 }
1203
1204 func (s *ListOperationsResponse) MarshalJSON() ([]byte, error) {
1205 type NoMethod ListOperationsResponse
1206 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1207 }
1208
1209
1210
1211 type ListUserWorkloadsConfigMapsResponse struct {
1212
1213 NextPageToken string `json:"nextPageToken,omitempty"`
1214
1215
1216 UserWorkloadsConfigMaps []*UserWorkloadsConfigMap `json:"userWorkloadsConfigMaps,omitempty"`
1217
1218
1219 googleapi.ServerResponse `json:"-"`
1220
1221
1222
1223
1224
1225 ForceSendFields []string `json:"-"`
1226
1227
1228
1229
1230 NullFields []string `json:"-"`
1231 }
1232
1233 func (s *ListUserWorkloadsConfigMapsResponse) MarshalJSON() ([]byte, error) {
1234 type NoMethod ListUserWorkloadsConfigMapsResponse
1235 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1236 }
1237
1238
1239
1240 type ListUserWorkloadsSecretsResponse struct {
1241
1242 NextPageToken string `json:"nextPageToken,omitempty"`
1243
1244
1245 UserWorkloadsSecrets []*UserWorkloadsSecret `json:"userWorkloadsSecrets,omitempty"`
1246
1247
1248 googleapi.ServerResponse `json:"-"`
1249
1250
1251
1252
1253
1254 ForceSendFields []string `json:"-"`
1255
1256
1257
1258
1259 NullFields []string `json:"-"`
1260 }
1261
1262 func (s *ListUserWorkloadsSecretsResponse) MarshalJSON() ([]byte, error) {
1263 type NoMethod ListUserWorkloadsSecretsResponse
1264 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1265 }
1266
1267
1268 type ListWorkloadsResponse struct {
1269
1270 NextPageToken string `json:"nextPageToken,omitempty"`
1271
1272 Workloads []*ComposerWorkload `json:"workloads,omitempty"`
1273
1274
1275 googleapi.ServerResponse `json:"-"`
1276
1277
1278
1279
1280
1281 ForceSendFields []string `json:"-"`
1282
1283
1284
1285
1286 NullFields []string `json:"-"`
1287 }
1288
1289 func (s *ListWorkloadsResponse) MarshalJSON() ([]byte, error) {
1290 type NoMethod ListWorkloadsResponse
1291 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1292 }
1293
1294
1295
1296 type LoadSnapshotRequest struct {
1297
1298
1299 SkipAirflowOverridesSetting bool `json:"skipAirflowOverridesSetting,omitempty"`
1300
1301
1302 SkipEnvironmentVariablesSetting bool `json:"skipEnvironmentVariablesSetting,omitempty"`
1303
1304
1305 SkipGcsDataCopying bool `json:"skipGcsDataCopying,omitempty"`
1306
1307
1308 SkipPypiPackagesInstallation bool `json:"skipPypiPackagesInstallation,omitempty"`
1309
1310
1311 SnapshotPath string `json:"snapshotPath,omitempty"`
1312
1313
1314
1315
1316
1317 ForceSendFields []string `json:"-"`
1318
1319
1320
1321
1322 NullFields []string `json:"-"`
1323 }
1324
1325 func (s *LoadSnapshotRequest) MarshalJSON() ([]byte, error) {
1326 type NoMethod LoadSnapshotRequest
1327 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1328 }
1329
1330
1331 type LoadSnapshotResponse struct {
1332 }
1333
1334
1335
1336
1337
1338
1339 type MaintenanceWindow struct {
1340
1341
1342
1343 EndTime string `json:"endTime,omitempty"`
1344
1345
1346
1347
1348 Recurrence string `json:"recurrence,omitempty"`
1349
1350
1351 StartTime string `json:"startTime,omitempty"`
1352
1353
1354
1355
1356
1357 ForceSendFields []string `json:"-"`
1358
1359
1360
1361
1362 NullFields []string `json:"-"`
1363 }
1364
1365 func (s *MaintenanceWindow) MarshalJSON() ([]byte, error) {
1366 type NoMethod MaintenanceWindow
1367 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1368 }
1369
1370
1371
1372
1373
1374
1375 type MasterAuthorizedNetworksConfig struct {
1376
1377
1378 CidrBlocks []*CidrBlock `json:"cidrBlocks,omitempty"`
1379
1380 Enabled bool `json:"enabled,omitempty"`
1381
1382
1383
1384
1385
1386 ForceSendFields []string `json:"-"`
1387
1388
1389
1390
1391 NullFields []string `json:"-"`
1392 }
1393
1394 func (s *MasterAuthorizedNetworksConfig) MarshalJSON() ([]byte, error) {
1395 type NoMethod MasterAuthorizedNetworksConfig
1396 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1397 }
1398
1399
1400
1401 type NetworkingConfig struct {
1402
1403
1404
1405
1406
1407
1408
1409
1410
1411
1412
1413
1414 ConnectionType string `json:"connectionType,omitempty"`
1415
1416
1417
1418
1419
1420 ForceSendFields []string `json:"-"`
1421
1422
1423
1424
1425 NullFields []string `json:"-"`
1426 }
1427
1428 func (s *NetworkingConfig) MarshalJSON() ([]byte, error) {
1429 type NoMethod NetworkingConfig
1430 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1431 }
1432
1433
1434
1435 type NodeConfig struct {
1436
1437
1438
1439
1440
1441
1442
1443 ComposerInternalIpv4CidrBlock string `json:"composerInternalIpv4CidrBlock,omitempty"`
1444
1445
1446
1447
1448
1449
1450
1451
1452
1453
1454 ComposerNetworkAttachment string `json:"composerNetworkAttachment,omitempty"`
1455
1456
1457
1458
1459 DiskSizeGb int64 `json:"diskSizeGb,omitempty"`
1460
1461
1462
1463
1464
1465 EnableIpMasqAgent bool `json:"enableIpMasqAgent,omitempty"`
1466
1467
1468 IpAllocationPolicy *IPAllocationPolicy `json:"ipAllocationPolicy,omitempty"`
1469
1470
1471
1472
1473
1474
1475
1476
1477
1478
1479
1480
1481
1482
1483 Location string `json:"location,omitempty"`
1484
1485
1486
1487
1488
1489
1490
1491
1492
1493
1494
1495
1496
1497
1498
1499
1500
1501 MachineType string `json:"machineType,omitempty"`
1502
1503
1504
1505
1506
1507
1508
1509
1510
1511
1512
1513 MaxPodsPerNode int64 `json:"maxPodsPerNode,omitempty"`
1514
1515
1516
1517
1518
1519
1520
1521
1522 Network string `json:"network,omitempty"`
1523
1524
1525
1526
1527
1528 OauthScopes []string `json:"oauthScopes,omitempty"`
1529
1530
1531
1532 ServiceAccount string `json:"serviceAccount,omitempty"`
1533
1534
1535
1536
1537
1538
1539 Subnetwork string `json:"subnetwork,omitempty"`
1540
1541
1542
1543
1544 Tags []string `json:"tags,omitempty"`
1545
1546
1547
1548
1549
1550 ForceSendFields []string `json:"-"`
1551
1552
1553
1554
1555 NullFields []string `json:"-"`
1556 }
1557
1558 func (s *NodeConfig) MarshalJSON() ([]byte, error) {
1559 type NoMethod NodeConfig
1560 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1561 }
1562
1563
1564
1565 type Operation struct {
1566
1567
1568
1569 Done bool `json:"done,omitempty"`
1570
1571 Error *Status `json:"error,omitempty"`
1572
1573
1574
1575
1576 Metadata googleapi.RawMessage `json:"metadata,omitempty"`
1577
1578
1579
1580 Name string `json:"name,omitempty"`
1581
1582
1583
1584
1585
1586
1587
1588 Response googleapi.RawMessage `json:"response,omitempty"`
1589
1590
1591 googleapi.ServerResponse `json:"-"`
1592
1593
1594
1595
1596
1597 ForceSendFields []string `json:"-"`
1598
1599
1600
1601
1602 NullFields []string `json:"-"`
1603 }
1604
1605 func (s *Operation) MarshalJSON() ([]byte, error) {
1606 type NoMethod Operation
1607 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1608 }
1609
1610
1611 type OperationMetadata struct {
1612
1613 CreateTime string `json:"createTime,omitempty"`
1614
1615
1616 EndTime string `json:"endTime,omitempty"`
1617
1618
1619
1620
1621
1622
1623
1624
1625
1626
1627
1628
1629 OperationType string `json:"operationType,omitempty"`
1630
1631
1632 Resource string `json:"resource,omitempty"`
1633
1634 ResourceUuid string `json:"resourceUuid,omitempty"`
1635
1636
1637
1638
1639
1640
1641
1642
1643 State string `json:"state,omitempty"`
1644
1645
1646
1647
1648
1649 ForceSendFields []string `json:"-"`
1650
1651
1652
1653
1654 NullFields []string `json:"-"`
1655 }
1656
1657 func (s *OperationMetadata) MarshalJSON() ([]byte, error) {
1658 type NoMethod OperationMetadata
1659 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1660 }
1661
1662
1663 type PollAirflowCommandRequest struct {
1664
1665 ExecutionId string `json:"executionId,omitempty"`
1666
1667 NextLineNumber int64 `json:"nextLineNumber,omitempty"`
1668
1669 Pod string `json:"pod,omitempty"`
1670
1671 PodNamespace string `json:"podNamespace,omitempty"`
1672
1673
1674
1675
1676
1677 ForceSendFields []string `json:"-"`
1678
1679
1680
1681
1682 NullFields []string `json:"-"`
1683 }
1684
1685 func (s *PollAirflowCommandRequest) MarshalJSON() ([]byte, error) {
1686 type NoMethod PollAirflowCommandRequest
1687 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1688 }
1689
1690
1691 type PollAirflowCommandResponse struct {
1692
1693 ExitInfo *ExitInfo `json:"exitInfo,omitempty"`
1694
1695
1696 Output []*Line `json:"output,omitempty"`
1697
1698
1699 OutputEnd bool `json:"outputEnd,omitempty"`
1700
1701
1702 googleapi.ServerResponse `json:"-"`
1703
1704
1705
1706
1707
1708 ForceSendFields []string `json:"-"`
1709
1710
1711
1712
1713 NullFields []string `json:"-"`
1714 }
1715
1716 func (s *PollAirflowCommandResponse) MarshalJSON() ([]byte, error) {
1717 type NoMethod PollAirflowCommandResponse
1718 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1719 }
1720
1721
1722
1723 type PrivateClusterConfig struct {
1724
1725
1726 EnablePrivateEndpoint bool `json:"enablePrivateEndpoint,omitempty"`
1727
1728
1729
1730 MasterIpv4CidrBlock string `json:"masterIpv4CidrBlock,omitempty"`
1731
1732
1733
1734
1735
1736 MasterIpv4ReservedRange string `json:"masterIpv4ReservedRange,omitempty"`
1737
1738
1739
1740
1741
1742 ForceSendFields []string `json:"-"`
1743
1744
1745
1746
1747 NullFields []string `json:"-"`
1748 }
1749
1750 func (s *PrivateClusterConfig) MarshalJSON() ([]byte, error) {
1751 type NoMethod PrivateClusterConfig
1752 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1753 }
1754
1755
1756
1757 type PrivateEnvironmentConfig struct {
1758
1759
1760
1761
1762 CloudComposerConnectionSubnetwork string `json:"cloudComposerConnectionSubnetwork,omitempty"`
1763
1764
1765
1766
1767
1768 CloudComposerNetworkIpv4CidrBlock string `json:"cloudComposerNetworkIpv4CidrBlock,omitempty"`
1769
1770
1771
1772
1773 CloudComposerNetworkIpv4ReservedRange string `json:"cloudComposerNetworkIpv4ReservedRange,omitempty"`
1774
1775
1776
1777 CloudSqlIpv4CidrBlock string `json:"cloudSqlIpv4CidrBlock,omitempty"`
1778
1779
1780
1781
1782
1783
1784
1785
1786 EnablePrivateBuildsOnly bool `json:"enablePrivateBuildsOnly,omitempty"`
1787
1788
1789
1790
1791 EnablePrivateEnvironment bool `json:"enablePrivateEnvironment,omitempty"`
1792
1793
1794
1795
1796 EnablePrivatelyUsedPublicIps bool `json:"enablePrivatelyUsedPublicIps,omitempty"`
1797
1798
1799 NetworkingConfig *NetworkingConfig `json:"networkingConfig,omitempty"`
1800
1801
1802 PrivateClusterConfig *PrivateClusterConfig `json:"privateClusterConfig,omitempty"`
1803
1804
1805
1806
1807
1808 WebServerIpv4CidrBlock string `json:"webServerIpv4CidrBlock,omitempty"`
1809
1810
1811
1812 WebServerIpv4ReservedRange string `json:"webServerIpv4ReservedRange,omitempty"`
1813
1814
1815
1816
1817
1818
1819 ForceSendFields []string `json:"-"`
1820
1821
1822
1823
1824
1825 NullFields []string `json:"-"`
1826 }
1827
1828 func (s *PrivateEnvironmentConfig) MarshalJSON() ([]byte, error) {
1829 type NoMethod PrivateEnvironmentConfig
1830 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1831 }
1832
1833
1834 type RecoveryConfig struct {
1835
1836
1837 ScheduledSnapshotsConfig *ScheduledSnapshotsConfig `json:"scheduledSnapshotsConfig,omitempty"`
1838
1839
1840
1841
1842
1843 ForceSendFields []string `json:"-"`
1844
1845
1846
1847
1848 NullFields []string `json:"-"`
1849 }
1850
1851 func (s *RecoveryConfig) MarshalJSON() ([]byte, error) {
1852 type NoMethod RecoveryConfig
1853 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1854 }
1855
1856
1857 type RestartWebServerRequest struct {
1858 }
1859
1860
1861
1862 type SaveSnapshotRequest struct {
1863
1864
1865 SnapshotLocation string `json:"snapshotLocation,omitempty"`
1866
1867
1868
1869
1870
1871 ForceSendFields []string `json:"-"`
1872
1873
1874
1875
1876 NullFields []string `json:"-"`
1877 }
1878
1879 func (s *SaveSnapshotRequest) MarshalJSON() ([]byte, error) {
1880 type NoMethod SaveSnapshotRequest
1881 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1882 }
1883
1884
1885 type SaveSnapshotResponse struct {
1886
1887
1888
1889 SnapshotPath string `json:"snapshotPath,omitempty"`
1890
1891
1892
1893
1894
1895 ForceSendFields []string `json:"-"`
1896
1897
1898
1899
1900 NullFields []string `json:"-"`
1901 }
1902
1903 func (s *SaveSnapshotResponse) MarshalJSON() ([]byte, error) {
1904 type NoMethod SaveSnapshotResponse
1905 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1906 }
1907
1908
1909
1910 type ScheduledSnapshotsConfig struct {
1911
1912 Enabled bool `json:"enabled,omitempty"`
1913
1914
1915
1916 SnapshotCreationSchedule string `json:"snapshotCreationSchedule,omitempty"`
1917
1918
1919 SnapshotLocation string `json:"snapshotLocation,omitempty"`
1920
1921
1922 TimeZone string `json:"timeZone,omitempty"`
1923
1924
1925
1926
1927
1928 ForceSendFields []string `json:"-"`
1929
1930
1931
1932
1933 NullFields []string `json:"-"`
1934 }
1935
1936 func (s *ScheduledSnapshotsConfig) MarshalJSON() ([]byte, error) {
1937 type NoMethod ScheduledSnapshotsConfig
1938 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1939 }
1940
1941
1942 type SchedulerResource struct {
1943
1944 Count int64 `json:"count,omitempty"`
1945
1946 Cpu float64 `json:"cpu,omitempty"`
1947
1948
1949 MemoryGb float64 `json:"memoryGb,omitempty"`
1950
1951
1952 StorageGb float64 `json:"storageGb,omitempty"`
1953
1954
1955
1956
1957
1958 ForceSendFields []string `json:"-"`
1959
1960
1961
1962
1963 NullFields []string `json:"-"`
1964 }
1965
1966 func (s *SchedulerResource) MarshalJSON() ([]byte, error) {
1967 type NoMethod SchedulerResource
1968 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
1969 }
1970
1971 func (s *SchedulerResource) UnmarshalJSON(data []byte) error {
1972 type NoMethod SchedulerResource
1973 var s1 struct {
1974 Cpu gensupport.JSONFloat64 `json:"cpu"`
1975 MemoryGb gensupport.JSONFloat64 `json:"memoryGb"`
1976 StorageGb gensupport.JSONFloat64 `json:"storageGb"`
1977 *NoMethod
1978 }
1979 s1.NoMethod = (*NoMethod)(s)
1980 if err := json.Unmarshal(data, &s1); err != nil {
1981 return err
1982 }
1983 s.Cpu = float64(s1.Cpu)
1984 s.MemoryGb = float64(s1.MemoryGb)
1985 s.StorageGb = float64(s1.StorageGb)
1986 return nil
1987 }
1988
1989
1990
1991 type SoftwareConfig struct {
1992
1993
1994
1995
1996
1997
1998
1999
2000
2001
2002
2003 AirflowConfigOverrides map[string]string `json:"airflowConfigOverrides,omitempty"`
2004
2005
2006 CloudDataLineageIntegration *CloudDataLineageIntegration `json:"cloudDataLineageIntegration,omitempty"`
2007
2008
2009
2010
2011
2012
2013
2014
2015
2016 EnvVariables map[string]string `json:"envVariables,omitempty"`
2017
2018
2019
2020
2021
2022
2023
2024
2025
2026
2027
2028
2029
2030
2031
2032
2033
2034
2035 ImageVersion string `json:"imageVersion,omitempty"`
2036
2037
2038
2039
2040
2041
2042 PypiPackages map[string]string `json:"pypiPackages,omitempty"`
2043
2044
2045
2046
2047
2048
2049 PythonVersion string `json:"pythonVersion,omitempty"`
2050
2051
2052
2053 SchedulerCount int64 `json:"schedulerCount,omitempty"`
2054
2055
2056
2057
2058
2059
2060
2061
2062
2063 WebServerPluginsMode string `json:"webServerPluginsMode,omitempty"`
2064
2065
2066
2067
2068
2069 ForceSendFields []string `json:"-"`
2070
2071
2072
2073
2074 NullFields []string `json:"-"`
2075 }
2076
2077 func (s *SoftwareConfig) MarshalJSON() ([]byte, error) {
2078 type NoMethod SoftwareConfig
2079 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2080 }
2081
2082
2083
2084
2085
2086
2087
2088 type Status struct {
2089
2090 Code int64 `json:"code,omitempty"`
2091
2092
2093 Details []googleapi.RawMessage `json:"details,omitempty"`
2094
2095
2096
2097 Message string `json:"message,omitempty"`
2098
2099
2100
2101
2102
2103 ForceSendFields []string `json:"-"`
2104
2105
2106
2107
2108 NullFields []string `json:"-"`
2109 }
2110
2111 func (s *Status) MarshalJSON() ([]byte, error) {
2112 type NoMethod Status
2113 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2114 }
2115
2116
2117 type StopAirflowCommandRequest struct {
2118
2119 ExecutionId string `json:"executionId,omitempty"`
2120
2121
2122 Force bool `json:"force,omitempty"`
2123
2124 Pod string `json:"pod,omitempty"`
2125
2126 PodNamespace string `json:"podNamespace,omitempty"`
2127
2128
2129
2130
2131
2132 ForceSendFields []string `json:"-"`
2133
2134
2135
2136
2137 NullFields []string `json:"-"`
2138 }
2139
2140 func (s *StopAirflowCommandRequest) MarshalJSON() ([]byte, error) {
2141 type NoMethod StopAirflowCommandRequest
2142 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2143 }
2144
2145
2146 type StopAirflowCommandResponse struct {
2147
2148 IsDone bool `json:"isDone,omitempty"`
2149
2150 Output []string `json:"output,omitempty"`
2151
2152
2153 googleapi.ServerResponse `json:"-"`
2154
2155
2156
2157
2158
2159 ForceSendFields []string `json:"-"`
2160
2161
2162
2163
2164 NullFields []string `json:"-"`
2165 }
2166
2167 func (s *StopAirflowCommandResponse) MarshalJSON() ([]byte, error) {
2168 type NoMethod StopAirflowCommandResponse
2169 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2170 }
2171
2172
2173 type StorageConfig struct {
2174
2175
2176 Bucket string `json:"bucket,omitempty"`
2177
2178
2179
2180
2181
2182 ForceSendFields []string `json:"-"`
2183
2184
2185
2186
2187 NullFields []string `json:"-"`
2188 }
2189
2190 func (s *StorageConfig) MarshalJSON() ([]byte, error) {
2191 type NoMethod StorageConfig
2192 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2193 }
2194
2195
2196 type TaskLogsRetentionConfig struct {
2197
2198
2199
2200
2201
2202
2203
2204
2205 StorageMode string `json:"storageMode,omitempty"`
2206
2207
2208
2209
2210
2211 ForceSendFields []string `json:"-"`
2212
2213
2214
2215
2216 NullFields []string `json:"-"`
2217 }
2218
2219 func (s *TaskLogsRetentionConfig) MarshalJSON() ([]byte, error) {
2220 type NoMethod TaskLogsRetentionConfig
2221 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2222 }
2223
2224
2225 type TriggererResource struct {
2226
2227 Count int64 `json:"count,omitempty"`
2228
2229 Cpu float64 `json:"cpu,omitempty"`
2230
2231
2232 MemoryGb float64 `json:"memoryGb,omitempty"`
2233
2234
2235
2236
2237
2238 ForceSendFields []string `json:"-"`
2239
2240
2241
2242
2243 NullFields []string `json:"-"`
2244 }
2245
2246 func (s *TriggererResource) MarshalJSON() ([]byte, error) {
2247 type NoMethod TriggererResource
2248 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2249 }
2250
2251 func (s *TriggererResource) UnmarshalJSON(data []byte) error {
2252 type NoMethod TriggererResource
2253 var s1 struct {
2254 Cpu gensupport.JSONFloat64 `json:"cpu"`
2255 MemoryGb gensupport.JSONFloat64 `json:"memoryGb"`
2256 *NoMethod
2257 }
2258 s1.NoMethod = (*NoMethod)(s)
2259 if err := json.Unmarshal(data, &s1); err != nil {
2260 return err
2261 }
2262 s.Cpu = float64(s1.Cpu)
2263 s.MemoryGb = float64(s1.MemoryGb)
2264 return nil
2265 }
2266
2267
2268
2269 type UserWorkloadsConfigMap struct {
2270
2271
2272
2273 Data map[string]string `json:"data,omitempty"`
2274
2275
2276
2277 Name string `json:"name,omitempty"`
2278
2279
2280 googleapi.ServerResponse `json:"-"`
2281
2282
2283
2284
2285
2286 ForceSendFields []string `json:"-"`
2287
2288
2289
2290
2291 NullFields []string `json:"-"`
2292 }
2293
2294 func (s *UserWorkloadsConfigMap) MarshalJSON() ([]byte, error) {
2295 type NoMethod UserWorkloadsConfigMap
2296 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2297 }
2298
2299
2300
2301 type UserWorkloadsSecret struct {
2302
2303
2304
2305
2306 Data map[string]string `json:"data,omitempty"`
2307
2308
2309
2310 Name string `json:"name,omitempty"`
2311
2312
2313 googleapi.ServerResponse `json:"-"`
2314
2315
2316
2317
2318
2319 ForceSendFields []string `json:"-"`
2320
2321
2322
2323
2324 NullFields []string `json:"-"`
2325 }
2326
2327 func (s *UserWorkloadsSecret) MarshalJSON() ([]byte, error) {
2328 type NoMethod UserWorkloadsSecret
2329 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2330 }
2331
2332
2333
2334
2335 type WebServerConfig struct {
2336
2337
2338
2339
2340
2341 MachineType string `json:"machineType,omitempty"`
2342
2343
2344
2345
2346
2347 ForceSendFields []string `json:"-"`
2348
2349
2350
2351
2352 NullFields []string `json:"-"`
2353 }
2354
2355 func (s *WebServerConfig) MarshalJSON() ([]byte, error) {
2356 type NoMethod WebServerConfig
2357 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2358 }
2359
2360
2361
2362 type WebServerNetworkAccessControl struct {
2363
2364 AllowedIpRanges []*AllowedIpRange `json:"allowedIpRanges,omitempty"`
2365
2366
2367
2368
2369
2370 ForceSendFields []string `json:"-"`
2371
2372
2373
2374
2375 NullFields []string `json:"-"`
2376 }
2377
2378 func (s *WebServerNetworkAccessControl) MarshalJSON() ([]byte, error) {
2379 type NoMethod WebServerNetworkAccessControl
2380 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2381 }
2382
2383
2384 type WebServerResource struct {
2385
2386 Cpu float64 `json:"cpu,omitempty"`
2387
2388 MemoryGb float64 `json:"memoryGb,omitempty"`
2389
2390 StorageGb float64 `json:"storageGb,omitempty"`
2391
2392
2393
2394
2395
2396 ForceSendFields []string `json:"-"`
2397
2398
2399
2400
2401 NullFields []string `json:"-"`
2402 }
2403
2404 func (s *WebServerResource) MarshalJSON() ([]byte, error) {
2405 type NoMethod WebServerResource
2406 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2407 }
2408
2409 func (s *WebServerResource) UnmarshalJSON(data []byte) error {
2410 type NoMethod WebServerResource
2411 var s1 struct {
2412 Cpu gensupport.JSONFloat64 `json:"cpu"`
2413 MemoryGb gensupport.JSONFloat64 `json:"memoryGb"`
2414 StorageGb gensupport.JSONFloat64 `json:"storageGb"`
2415 *NoMethod
2416 }
2417 s1.NoMethod = (*NoMethod)(s)
2418 if err := json.Unmarshal(data, &s1); err != nil {
2419 return err
2420 }
2421 s.Cpu = float64(s1.Cpu)
2422 s.MemoryGb = float64(s1.MemoryGb)
2423 s.StorageGb = float64(s1.StorageGb)
2424 return nil
2425 }
2426
2427
2428 type WorkerResource struct {
2429
2430 Cpu float64 `json:"cpu,omitempty"`
2431
2432 MaxCount int64 `json:"maxCount,omitempty"`
2433
2434
2435 MemoryGb float64 `json:"memoryGb,omitempty"`
2436
2437 MinCount int64 `json:"minCount,omitempty"`
2438
2439
2440 StorageGb float64 `json:"storageGb,omitempty"`
2441
2442
2443
2444
2445
2446 ForceSendFields []string `json:"-"`
2447
2448
2449
2450
2451 NullFields []string `json:"-"`
2452 }
2453
2454 func (s *WorkerResource) MarshalJSON() ([]byte, error) {
2455 type NoMethod WorkerResource
2456 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2457 }
2458
2459 func (s *WorkerResource) UnmarshalJSON(data []byte) error {
2460 type NoMethod WorkerResource
2461 var s1 struct {
2462 Cpu gensupport.JSONFloat64 `json:"cpu"`
2463 MemoryGb gensupport.JSONFloat64 `json:"memoryGb"`
2464 StorageGb gensupport.JSONFloat64 `json:"storageGb"`
2465 *NoMethod
2466 }
2467 s1.NoMethod = (*NoMethod)(s)
2468 if err := json.Unmarshal(data, &s1); err != nil {
2469 return err
2470 }
2471 s.Cpu = float64(s1.Cpu)
2472 s.MemoryGb = float64(s1.MemoryGb)
2473 s.StorageGb = float64(s1.StorageGb)
2474 return nil
2475 }
2476
2477
2478
2479
2480 type WorkloadsConfig struct {
2481
2482
2483
2484 DagProcessor *DagProcessorResource `json:"dagProcessor,omitempty"`
2485
2486 Scheduler *SchedulerResource `json:"scheduler,omitempty"`
2487
2488 Triggerer *TriggererResource `json:"triggerer,omitempty"`
2489
2490 WebServer *WebServerResource `json:"webServer,omitempty"`
2491
2492 Worker *WorkerResource `json:"worker,omitempty"`
2493
2494
2495
2496
2497
2498 ForceSendFields []string `json:"-"`
2499
2500
2501
2502
2503 NullFields []string `json:"-"`
2504 }
2505
2506 func (s *WorkloadsConfig) MarshalJSON() ([]byte, error) {
2507 type NoMethod WorkloadsConfig
2508 return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields)
2509 }
2510
2511 type ProjectsLocationsEnvironmentsCheckUpgradeCall struct {
2512 s *Service
2513 environment string
2514 checkupgraderequest *CheckUpgradeRequest
2515 urlParams_ gensupport.URLParams
2516 ctx_ context.Context
2517 header_ http.Header
2518 }
2519
2520
2521
2522
2523
2524
2525
2526 func (r *ProjectsLocationsEnvironmentsService) CheckUpgrade(environment string, checkupgraderequest *CheckUpgradeRequest) *ProjectsLocationsEnvironmentsCheckUpgradeCall {
2527 c := &ProjectsLocationsEnvironmentsCheckUpgradeCall{s: r.s, urlParams_: make(gensupport.URLParams)}
2528 c.environment = environment
2529 c.checkupgraderequest = checkupgraderequest
2530 return c
2531 }
2532
2533
2534
2535
2536 func (c *ProjectsLocationsEnvironmentsCheckUpgradeCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsCheckUpgradeCall {
2537 c.urlParams_.Set("fields", googleapi.CombineFields(s))
2538 return c
2539 }
2540
2541
2542 func (c *ProjectsLocationsEnvironmentsCheckUpgradeCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsCheckUpgradeCall {
2543 c.ctx_ = ctx
2544 return c
2545 }
2546
2547
2548
2549 func (c *ProjectsLocationsEnvironmentsCheckUpgradeCall) Header() http.Header {
2550 if c.header_ == nil {
2551 c.header_ = make(http.Header)
2552 }
2553 return c.header_
2554 }
2555
2556 func (c *ProjectsLocationsEnvironmentsCheckUpgradeCall) doRequest(alt string) (*http.Response, error) {
2557 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
2558 var body io.Reader = nil
2559 body, err := googleapi.WithoutDataWrapper.JSONReader(c.checkupgraderequest)
2560 if err != nil {
2561 return nil, err
2562 }
2563 c.urlParams_.Set("alt", alt)
2564 c.urlParams_.Set("prettyPrint", "false")
2565 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:checkUpgrade")
2566 urls += "?" + c.urlParams_.Encode()
2567 req, err := http.NewRequest("POST", urls, body)
2568 if err != nil {
2569 return nil, err
2570 }
2571 req.Header = reqHeaders
2572 googleapi.Expand(req.URL, map[string]string{
2573 "environment": c.environment,
2574 })
2575 return gensupport.SendRequest(c.ctx_, c.s.client, req)
2576 }
2577
2578
2579
2580
2581
2582
2583 func (c *ProjectsLocationsEnvironmentsCheckUpgradeCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
2584 gensupport.SetOptions(c.urlParams_, opts...)
2585 res, err := c.doRequest("json")
2586 if res != nil && res.StatusCode == http.StatusNotModified {
2587 if res.Body != nil {
2588 res.Body.Close()
2589 }
2590 return nil, gensupport.WrapError(&googleapi.Error{
2591 Code: res.StatusCode,
2592 Header: res.Header,
2593 })
2594 }
2595 if err != nil {
2596 return nil, err
2597 }
2598 defer googleapi.CloseBody(res)
2599 if err := googleapi.CheckResponse(res); err != nil {
2600 return nil, gensupport.WrapError(err)
2601 }
2602 ret := &Operation{
2603 ServerResponse: googleapi.ServerResponse{
2604 Header: res.Header,
2605 HTTPStatusCode: res.StatusCode,
2606 },
2607 }
2608 target := &ret
2609 if err := gensupport.DecodeResponse(target, res); err != nil {
2610 return nil, err
2611 }
2612 return ret, nil
2613 }
2614
2615 type ProjectsLocationsEnvironmentsCreateCall struct {
2616 s *Service
2617 parent string
2618 environment *Environment
2619 urlParams_ gensupport.URLParams
2620 ctx_ context.Context
2621 header_ http.Header
2622 }
2623
2624
2625
2626
2627
2628 func (r *ProjectsLocationsEnvironmentsService) Create(parent string, environment *Environment) *ProjectsLocationsEnvironmentsCreateCall {
2629 c := &ProjectsLocationsEnvironmentsCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
2630 c.parent = parent
2631 c.environment = environment
2632 return c
2633 }
2634
2635
2636
2637
2638 func (c *ProjectsLocationsEnvironmentsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsCreateCall {
2639 c.urlParams_.Set("fields", googleapi.CombineFields(s))
2640 return c
2641 }
2642
2643
2644 func (c *ProjectsLocationsEnvironmentsCreateCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsCreateCall {
2645 c.ctx_ = ctx
2646 return c
2647 }
2648
2649
2650
2651 func (c *ProjectsLocationsEnvironmentsCreateCall) Header() http.Header {
2652 if c.header_ == nil {
2653 c.header_ = make(http.Header)
2654 }
2655 return c.header_
2656 }
2657
2658 func (c *ProjectsLocationsEnvironmentsCreateCall) doRequest(alt string) (*http.Response, error) {
2659 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
2660 var body io.Reader = nil
2661 body, err := googleapi.WithoutDataWrapper.JSONReader(c.environment)
2662 if err != nil {
2663 return nil, err
2664 }
2665 c.urlParams_.Set("alt", alt)
2666 c.urlParams_.Set("prettyPrint", "false")
2667 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/environments")
2668 urls += "?" + c.urlParams_.Encode()
2669 req, err := http.NewRequest("POST", urls, body)
2670 if err != nil {
2671 return nil, err
2672 }
2673 req.Header = reqHeaders
2674 googleapi.Expand(req.URL, map[string]string{
2675 "parent": c.parent,
2676 })
2677 return gensupport.SendRequest(c.ctx_, c.s.client, req)
2678 }
2679
2680
2681
2682
2683
2684
2685 func (c *ProjectsLocationsEnvironmentsCreateCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
2686 gensupport.SetOptions(c.urlParams_, opts...)
2687 res, err := c.doRequest("json")
2688 if res != nil && res.StatusCode == http.StatusNotModified {
2689 if res.Body != nil {
2690 res.Body.Close()
2691 }
2692 return nil, gensupport.WrapError(&googleapi.Error{
2693 Code: res.StatusCode,
2694 Header: res.Header,
2695 })
2696 }
2697 if err != nil {
2698 return nil, err
2699 }
2700 defer googleapi.CloseBody(res)
2701 if err := googleapi.CheckResponse(res); err != nil {
2702 return nil, gensupport.WrapError(err)
2703 }
2704 ret := &Operation{
2705 ServerResponse: googleapi.ServerResponse{
2706 Header: res.Header,
2707 HTTPStatusCode: res.StatusCode,
2708 },
2709 }
2710 target := &ret
2711 if err := gensupport.DecodeResponse(target, res); err != nil {
2712 return nil, err
2713 }
2714 return ret, nil
2715 }
2716
2717 type ProjectsLocationsEnvironmentsDatabaseFailoverCall struct {
2718 s *Service
2719 environment string
2720 databasefailoverrequest *DatabaseFailoverRequest
2721 urlParams_ gensupport.URLParams
2722 ctx_ context.Context
2723 header_ http.Header
2724 }
2725
2726
2727
2728
2729
2730
2731 func (r *ProjectsLocationsEnvironmentsService) DatabaseFailover(environment string, databasefailoverrequest *DatabaseFailoverRequest) *ProjectsLocationsEnvironmentsDatabaseFailoverCall {
2732 c := &ProjectsLocationsEnvironmentsDatabaseFailoverCall{s: r.s, urlParams_: make(gensupport.URLParams)}
2733 c.environment = environment
2734 c.databasefailoverrequest = databasefailoverrequest
2735 return c
2736 }
2737
2738
2739
2740
2741 func (c *ProjectsLocationsEnvironmentsDatabaseFailoverCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsDatabaseFailoverCall {
2742 c.urlParams_.Set("fields", googleapi.CombineFields(s))
2743 return c
2744 }
2745
2746
2747 func (c *ProjectsLocationsEnvironmentsDatabaseFailoverCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsDatabaseFailoverCall {
2748 c.ctx_ = ctx
2749 return c
2750 }
2751
2752
2753
2754 func (c *ProjectsLocationsEnvironmentsDatabaseFailoverCall) Header() http.Header {
2755 if c.header_ == nil {
2756 c.header_ = make(http.Header)
2757 }
2758 return c.header_
2759 }
2760
2761 func (c *ProjectsLocationsEnvironmentsDatabaseFailoverCall) doRequest(alt string) (*http.Response, error) {
2762 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
2763 var body io.Reader = nil
2764 body, err := googleapi.WithoutDataWrapper.JSONReader(c.databasefailoverrequest)
2765 if err != nil {
2766 return nil, err
2767 }
2768 c.urlParams_.Set("alt", alt)
2769 c.urlParams_.Set("prettyPrint", "false")
2770 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:databaseFailover")
2771 urls += "?" + c.urlParams_.Encode()
2772 req, err := http.NewRequest("POST", urls, body)
2773 if err != nil {
2774 return nil, err
2775 }
2776 req.Header = reqHeaders
2777 googleapi.Expand(req.URL, map[string]string{
2778 "environment": c.environment,
2779 })
2780 return gensupport.SendRequest(c.ctx_, c.s.client, req)
2781 }
2782
2783
2784
2785
2786
2787
2788 func (c *ProjectsLocationsEnvironmentsDatabaseFailoverCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
2789 gensupport.SetOptions(c.urlParams_, opts...)
2790 res, err := c.doRequest("json")
2791 if res != nil && res.StatusCode == http.StatusNotModified {
2792 if res.Body != nil {
2793 res.Body.Close()
2794 }
2795 return nil, gensupport.WrapError(&googleapi.Error{
2796 Code: res.StatusCode,
2797 Header: res.Header,
2798 })
2799 }
2800 if err != nil {
2801 return nil, err
2802 }
2803 defer googleapi.CloseBody(res)
2804 if err := googleapi.CheckResponse(res); err != nil {
2805 return nil, gensupport.WrapError(err)
2806 }
2807 ret := &Operation{
2808 ServerResponse: googleapi.ServerResponse{
2809 Header: res.Header,
2810 HTTPStatusCode: res.StatusCode,
2811 },
2812 }
2813 target := &ret
2814 if err := gensupport.DecodeResponse(target, res); err != nil {
2815 return nil, err
2816 }
2817 return ret, nil
2818 }
2819
2820 type ProjectsLocationsEnvironmentsDeleteCall struct {
2821 s *Service
2822 name string
2823 urlParams_ gensupport.URLParams
2824 ctx_ context.Context
2825 header_ http.Header
2826 }
2827
2828
2829
2830
2831
2832 func (r *ProjectsLocationsEnvironmentsService) Delete(name string) *ProjectsLocationsEnvironmentsDeleteCall {
2833 c := &ProjectsLocationsEnvironmentsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
2834 c.name = name
2835 return c
2836 }
2837
2838
2839
2840
2841 func (c *ProjectsLocationsEnvironmentsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsDeleteCall {
2842 c.urlParams_.Set("fields", googleapi.CombineFields(s))
2843 return c
2844 }
2845
2846
2847 func (c *ProjectsLocationsEnvironmentsDeleteCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsDeleteCall {
2848 c.ctx_ = ctx
2849 return c
2850 }
2851
2852
2853
2854 func (c *ProjectsLocationsEnvironmentsDeleteCall) Header() http.Header {
2855 if c.header_ == nil {
2856 c.header_ = make(http.Header)
2857 }
2858 return c.header_
2859 }
2860
2861 func (c *ProjectsLocationsEnvironmentsDeleteCall) doRequest(alt string) (*http.Response, error) {
2862 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
2863 var body io.Reader = nil
2864 c.urlParams_.Set("alt", alt)
2865 c.urlParams_.Set("prettyPrint", "false")
2866 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
2867 urls += "?" + c.urlParams_.Encode()
2868 req, err := http.NewRequest("DELETE", urls, body)
2869 if err != nil {
2870 return nil, err
2871 }
2872 req.Header = reqHeaders
2873 googleapi.Expand(req.URL, map[string]string{
2874 "name": c.name,
2875 })
2876 return gensupport.SendRequest(c.ctx_, c.s.client, req)
2877 }
2878
2879
2880
2881
2882
2883
2884 func (c *ProjectsLocationsEnvironmentsDeleteCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
2885 gensupport.SetOptions(c.urlParams_, opts...)
2886 res, err := c.doRequest("json")
2887 if res != nil && res.StatusCode == http.StatusNotModified {
2888 if res.Body != nil {
2889 res.Body.Close()
2890 }
2891 return nil, gensupport.WrapError(&googleapi.Error{
2892 Code: res.StatusCode,
2893 Header: res.Header,
2894 })
2895 }
2896 if err != nil {
2897 return nil, err
2898 }
2899 defer googleapi.CloseBody(res)
2900 if err := googleapi.CheckResponse(res); err != nil {
2901 return nil, gensupport.WrapError(err)
2902 }
2903 ret := &Operation{
2904 ServerResponse: googleapi.ServerResponse{
2905 Header: res.Header,
2906 HTTPStatusCode: res.StatusCode,
2907 },
2908 }
2909 target := &ret
2910 if err := gensupport.DecodeResponse(target, res); err != nil {
2911 return nil, err
2912 }
2913 return ret, nil
2914 }
2915
2916 type ProjectsLocationsEnvironmentsExecuteAirflowCommandCall struct {
2917 s *Service
2918 environment string
2919 executeairflowcommandrequest *ExecuteAirflowCommandRequest
2920 urlParams_ gensupport.URLParams
2921 ctx_ context.Context
2922 header_ http.Header
2923 }
2924
2925
2926
2927
2928
2929 func (r *ProjectsLocationsEnvironmentsService) ExecuteAirflowCommand(environment string, executeairflowcommandrequest *ExecuteAirflowCommandRequest) *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall {
2930 c := &ProjectsLocationsEnvironmentsExecuteAirflowCommandCall{s: r.s, urlParams_: make(gensupport.URLParams)}
2931 c.environment = environment
2932 c.executeairflowcommandrequest = executeairflowcommandrequest
2933 return c
2934 }
2935
2936
2937
2938
2939 func (c *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall {
2940 c.urlParams_.Set("fields", googleapi.CombineFields(s))
2941 return c
2942 }
2943
2944
2945 func (c *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall {
2946 c.ctx_ = ctx
2947 return c
2948 }
2949
2950
2951
2952 func (c *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall) Header() http.Header {
2953 if c.header_ == nil {
2954 c.header_ = make(http.Header)
2955 }
2956 return c.header_
2957 }
2958
2959 func (c *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall) doRequest(alt string) (*http.Response, error) {
2960 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
2961 var body io.Reader = nil
2962 body, err := googleapi.WithoutDataWrapper.JSONReader(c.executeairflowcommandrequest)
2963 if err != nil {
2964 return nil, err
2965 }
2966 c.urlParams_.Set("alt", alt)
2967 c.urlParams_.Set("prettyPrint", "false")
2968 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:executeAirflowCommand")
2969 urls += "?" + c.urlParams_.Encode()
2970 req, err := http.NewRequest("POST", urls, body)
2971 if err != nil {
2972 return nil, err
2973 }
2974 req.Header = reqHeaders
2975 googleapi.Expand(req.URL, map[string]string{
2976 "environment": c.environment,
2977 })
2978 return gensupport.SendRequest(c.ctx_, c.s.client, req)
2979 }
2980
2981
2982
2983
2984
2985
2986
2987 func (c *ProjectsLocationsEnvironmentsExecuteAirflowCommandCall) Do(opts ...googleapi.CallOption) (*ExecuteAirflowCommandResponse, error) {
2988 gensupport.SetOptions(c.urlParams_, opts...)
2989 res, err := c.doRequest("json")
2990 if res != nil && res.StatusCode == http.StatusNotModified {
2991 if res.Body != nil {
2992 res.Body.Close()
2993 }
2994 return nil, gensupport.WrapError(&googleapi.Error{
2995 Code: res.StatusCode,
2996 Header: res.Header,
2997 })
2998 }
2999 if err != nil {
3000 return nil, err
3001 }
3002 defer googleapi.CloseBody(res)
3003 if err := googleapi.CheckResponse(res); err != nil {
3004 return nil, gensupport.WrapError(err)
3005 }
3006 ret := &ExecuteAirflowCommandResponse{
3007 ServerResponse: googleapi.ServerResponse{
3008 Header: res.Header,
3009 HTTPStatusCode: res.StatusCode,
3010 },
3011 }
3012 target := &ret
3013 if err := gensupport.DecodeResponse(target, res); err != nil {
3014 return nil, err
3015 }
3016 return ret, nil
3017 }
3018
3019 type ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall struct {
3020 s *Service
3021 environment string
3022 urlParams_ gensupport.URLParams
3023 ifNoneMatch_ string
3024 ctx_ context.Context
3025 header_ http.Header
3026 }
3027
3028
3029
3030
3031
3032 func (r *ProjectsLocationsEnvironmentsService) FetchDatabaseProperties(environment string) *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall {
3033 c := &ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3034 c.environment = environment
3035 return c
3036 }
3037
3038
3039
3040
3041 func (c *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall {
3042 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3043 return c
3044 }
3045
3046
3047
3048
3049 func (c *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall {
3050 c.ifNoneMatch_ = entityTag
3051 return c
3052 }
3053
3054
3055 func (c *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall {
3056 c.ctx_ = ctx
3057 return c
3058 }
3059
3060
3061
3062 func (c *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall) Header() http.Header {
3063 if c.header_ == nil {
3064 c.header_ = make(http.Header)
3065 }
3066 return c.header_
3067 }
3068
3069 func (c *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall) doRequest(alt string) (*http.Response, error) {
3070 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
3071 if c.ifNoneMatch_ != "" {
3072 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
3073 }
3074 var body io.Reader = nil
3075 c.urlParams_.Set("alt", alt)
3076 c.urlParams_.Set("prettyPrint", "false")
3077 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:fetchDatabaseProperties")
3078 urls += "?" + c.urlParams_.Encode()
3079 req, err := http.NewRequest("GET", urls, body)
3080 if err != nil {
3081 return nil, err
3082 }
3083 req.Header = reqHeaders
3084 googleapi.Expand(req.URL, map[string]string{
3085 "environment": c.environment,
3086 })
3087 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3088 }
3089
3090
3091
3092
3093
3094
3095
3096 func (c *ProjectsLocationsEnvironmentsFetchDatabasePropertiesCall) Do(opts ...googleapi.CallOption) (*FetchDatabasePropertiesResponse, error) {
3097 gensupport.SetOptions(c.urlParams_, opts...)
3098 res, err := c.doRequest("json")
3099 if res != nil && res.StatusCode == http.StatusNotModified {
3100 if res.Body != nil {
3101 res.Body.Close()
3102 }
3103 return nil, gensupport.WrapError(&googleapi.Error{
3104 Code: res.StatusCode,
3105 Header: res.Header,
3106 })
3107 }
3108 if err != nil {
3109 return nil, err
3110 }
3111 defer googleapi.CloseBody(res)
3112 if err := googleapi.CheckResponse(res); err != nil {
3113 return nil, gensupport.WrapError(err)
3114 }
3115 ret := &FetchDatabasePropertiesResponse{
3116 ServerResponse: googleapi.ServerResponse{
3117 Header: res.Header,
3118 HTTPStatusCode: res.StatusCode,
3119 },
3120 }
3121 target := &ret
3122 if err := gensupport.DecodeResponse(target, res); err != nil {
3123 return nil, err
3124 }
3125 return ret, nil
3126 }
3127
3128 type ProjectsLocationsEnvironmentsGetCall struct {
3129 s *Service
3130 name string
3131 urlParams_ gensupport.URLParams
3132 ifNoneMatch_ string
3133 ctx_ context.Context
3134 header_ http.Header
3135 }
3136
3137
3138
3139
3140
3141 func (r *ProjectsLocationsEnvironmentsService) Get(name string) *ProjectsLocationsEnvironmentsGetCall {
3142 c := &ProjectsLocationsEnvironmentsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3143 c.name = name
3144 return c
3145 }
3146
3147
3148
3149
3150 func (c *ProjectsLocationsEnvironmentsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsGetCall {
3151 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3152 return c
3153 }
3154
3155
3156
3157
3158 func (c *ProjectsLocationsEnvironmentsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsGetCall {
3159 c.ifNoneMatch_ = entityTag
3160 return c
3161 }
3162
3163
3164 func (c *ProjectsLocationsEnvironmentsGetCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsGetCall {
3165 c.ctx_ = ctx
3166 return c
3167 }
3168
3169
3170
3171 func (c *ProjectsLocationsEnvironmentsGetCall) Header() http.Header {
3172 if c.header_ == nil {
3173 c.header_ = make(http.Header)
3174 }
3175 return c.header_
3176 }
3177
3178 func (c *ProjectsLocationsEnvironmentsGetCall) doRequest(alt string) (*http.Response, error) {
3179 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
3180 if c.ifNoneMatch_ != "" {
3181 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
3182 }
3183 var body io.Reader = nil
3184 c.urlParams_.Set("alt", alt)
3185 c.urlParams_.Set("prettyPrint", "false")
3186 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
3187 urls += "?" + c.urlParams_.Encode()
3188 req, err := http.NewRequest("GET", urls, body)
3189 if err != nil {
3190 return nil, err
3191 }
3192 req.Header = reqHeaders
3193 googleapi.Expand(req.URL, map[string]string{
3194 "name": c.name,
3195 })
3196 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3197 }
3198
3199
3200
3201
3202
3203
3204 func (c *ProjectsLocationsEnvironmentsGetCall) Do(opts ...googleapi.CallOption) (*Environment, error) {
3205 gensupport.SetOptions(c.urlParams_, opts...)
3206 res, err := c.doRequest("json")
3207 if res != nil && res.StatusCode == http.StatusNotModified {
3208 if res.Body != nil {
3209 res.Body.Close()
3210 }
3211 return nil, gensupport.WrapError(&googleapi.Error{
3212 Code: res.StatusCode,
3213 Header: res.Header,
3214 })
3215 }
3216 if err != nil {
3217 return nil, err
3218 }
3219 defer googleapi.CloseBody(res)
3220 if err := googleapi.CheckResponse(res); err != nil {
3221 return nil, gensupport.WrapError(err)
3222 }
3223 ret := &Environment{
3224 ServerResponse: googleapi.ServerResponse{
3225 Header: res.Header,
3226 HTTPStatusCode: res.StatusCode,
3227 },
3228 }
3229 target := &ret
3230 if err := gensupport.DecodeResponse(target, res); err != nil {
3231 return nil, err
3232 }
3233 return ret, nil
3234 }
3235
3236 type ProjectsLocationsEnvironmentsListCall struct {
3237 s *Service
3238 parent string
3239 urlParams_ gensupport.URLParams
3240 ifNoneMatch_ string
3241 ctx_ context.Context
3242 header_ http.Header
3243 }
3244
3245
3246
3247
3248
3249 func (r *ProjectsLocationsEnvironmentsService) List(parent string) *ProjectsLocationsEnvironmentsListCall {
3250 c := &ProjectsLocationsEnvironmentsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3251 c.parent = parent
3252 return c
3253 }
3254
3255
3256
3257 func (c *ProjectsLocationsEnvironmentsListCall) PageSize(pageSize int64) *ProjectsLocationsEnvironmentsListCall {
3258 c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
3259 return c
3260 }
3261
3262
3263
3264 func (c *ProjectsLocationsEnvironmentsListCall) PageToken(pageToken string) *ProjectsLocationsEnvironmentsListCall {
3265 c.urlParams_.Set("pageToken", pageToken)
3266 return c
3267 }
3268
3269
3270
3271
3272 func (c *ProjectsLocationsEnvironmentsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsListCall {
3273 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3274 return c
3275 }
3276
3277
3278
3279
3280 func (c *ProjectsLocationsEnvironmentsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsListCall {
3281 c.ifNoneMatch_ = entityTag
3282 return c
3283 }
3284
3285
3286 func (c *ProjectsLocationsEnvironmentsListCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsListCall {
3287 c.ctx_ = ctx
3288 return c
3289 }
3290
3291
3292
3293 func (c *ProjectsLocationsEnvironmentsListCall) Header() http.Header {
3294 if c.header_ == nil {
3295 c.header_ = make(http.Header)
3296 }
3297 return c.header_
3298 }
3299
3300 func (c *ProjectsLocationsEnvironmentsListCall) doRequest(alt string) (*http.Response, error) {
3301 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
3302 if c.ifNoneMatch_ != "" {
3303 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
3304 }
3305 var body io.Reader = nil
3306 c.urlParams_.Set("alt", alt)
3307 c.urlParams_.Set("prettyPrint", "false")
3308 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/environments")
3309 urls += "?" + c.urlParams_.Encode()
3310 req, err := http.NewRequest("GET", urls, body)
3311 if err != nil {
3312 return nil, err
3313 }
3314 req.Header = reqHeaders
3315 googleapi.Expand(req.URL, map[string]string{
3316 "parent": c.parent,
3317 })
3318 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3319 }
3320
3321
3322
3323
3324
3325
3326
3327 func (c *ProjectsLocationsEnvironmentsListCall) Do(opts ...googleapi.CallOption) (*ListEnvironmentsResponse, error) {
3328 gensupport.SetOptions(c.urlParams_, opts...)
3329 res, err := c.doRequest("json")
3330 if res != nil && res.StatusCode == http.StatusNotModified {
3331 if res.Body != nil {
3332 res.Body.Close()
3333 }
3334 return nil, gensupport.WrapError(&googleapi.Error{
3335 Code: res.StatusCode,
3336 Header: res.Header,
3337 })
3338 }
3339 if err != nil {
3340 return nil, err
3341 }
3342 defer googleapi.CloseBody(res)
3343 if err := googleapi.CheckResponse(res); err != nil {
3344 return nil, gensupport.WrapError(err)
3345 }
3346 ret := &ListEnvironmentsResponse{
3347 ServerResponse: googleapi.ServerResponse{
3348 Header: res.Header,
3349 HTTPStatusCode: res.StatusCode,
3350 },
3351 }
3352 target := &ret
3353 if err := gensupport.DecodeResponse(target, res); err != nil {
3354 return nil, err
3355 }
3356 return ret, nil
3357 }
3358
3359
3360
3361
3362 func (c *ProjectsLocationsEnvironmentsListCall) Pages(ctx context.Context, f func(*ListEnvironmentsResponse) error) error {
3363 c.ctx_ = ctx
3364 defer c.PageToken(c.urlParams_.Get("pageToken"))
3365 for {
3366 x, err := c.Do()
3367 if err != nil {
3368 return err
3369 }
3370 if err := f(x); err != nil {
3371 return err
3372 }
3373 if x.NextPageToken == "" {
3374 return nil
3375 }
3376 c.PageToken(x.NextPageToken)
3377 }
3378 }
3379
3380 type ProjectsLocationsEnvironmentsLoadSnapshotCall struct {
3381 s *Service
3382 environment string
3383 loadsnapshotrequest *LoadSnapshotRequest
3384 urlParams_ gensupport.URLParams
3385 ctx_ context.Context
3386 header_ http.Header
3387 }
3388
3389
3390
3391
3392
3393
3394
3395 func (r *ProjectsLocationsEnvironmentsService) LoadSnapshot(environment string, loadsnapshotrequest *LoadSnapshotRequest) *ProjectsLocationsEnvironmentsLoadSnapshotCall {
3396 c := &ProjectsLocationsEnvironmentsLoadSnapshotCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3397 c.environment = environment
3398 c.loadsnapshotrequest = loadsnapshotrequest
3399 return c
3400 }
3401
3402
3403
3404
3405 func (c *ProjectsLocationsEnvironmentsLoadSnapshotCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsLoadSnapshotCall {
3406 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3407 return c
3408 }
3409
3410
3411 func (c *ProjectsLocationsEnvironmentsLoadSnapshotCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsLoadSnapshotCall {
3412 c.ctx_ = ctx
3413 return c
3414 }
3415
3416
3417
3418 func (c *ProjectsLocationsEnvironmentsLoadSnapshotCall) Header() http.Header {
3419 if c.header_ == nil {
3420 c.header_ = make(http.Header)
3421 }
3422 return c.header_
3423 }
3424
3425 func (c *ProjectsLocationsEnvironmentsLoadSnapshotCall) doRequest(alt string) (*http.Response, error) {
3426 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
3427 var body io.Reader = nil
3428 body, err := googleapi.WithoutDataWrapper.JSONReader(c.loadsnapshotrequest)
3429 if err != nil {
3430 return nil, err
3431 }
3432 c.urlParams_.Set("alt", alt)
3433 c.urlParams_.Set("prettyPrint", "false")
3434 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:loadSnapshot")
3435 urls += "?" + c.urlParams_.Encode()
3436 req, err := http.NewRequest("POST", urls, body)
3437 if err != nil {
3438 return nil, err
3439 }
3440 req.Header = reqHeaders
3441 googleapi.Expand(req.URL, map[string]string{
3442 "environment": c.environment,
3443 })
3444 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3445 }
3446
3447
3448
3449
3450
3451
3452 func (c *ProjectsLocationsEnvironmentsLoadSnapshotCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
3453 gensupport.SetOptions(c.urlParams_, opts...)
3454 res, err := c.doRequest("json")
3455 if res != nil && res.StatusCode == http.StatusNotModified {
3456 if res.Body != nil {
3457 res.Body.Close()
3458 }
3459 return nil, gensupport.WrapError(&googleapi.Error{
3460 Code: res.StatusCode,
3461 Header: res.Header,
3462 })
3463 }
3464 if err != nil {
3465 return nil, err
3466 }
3467 defer googleapi.CloseBody(res)
3468 if err := googleapi.CheckResponse(res); err != nil {
3469 return nil, gensupport.WrapError(err)
3470 }
3471 ret := &Operation{
3472 ServerResponse: googleapi.ServerResponse{
3473 Header: res.Header,
3474 HTTPStatusCode: res.StatusCode,
3475 },
3476 }
3477 target := &ret
3478 if err := gensupport.DecodeResponse(target, res); err != nil {
3479 return nil, err
3480 }
3481 return ret, nil
3482 }
3483
3484 type ProjectsLocationsEnvironmentsPatchCall struct {
3485 s *Service
3486 name string
3487 environment *Environment
3488 urlParams_ gensupport.URLParams
3489 ctx_ context.Context
3490 header_ http.Header
3491 }
3492
3493
3494
3495
3496
3497
3498 func (r *ProjectsLocationsEnvironmentsService) Patch(name string, environment *Environment) *ProjectsLocationsEnvironmentsPatchCall {
3499 c := &ProjectsLocationsEnvironmentsPatchCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3500 c.name = name
3501 c.environment = environment
3502 return c
3503 }
3504
3505
3506
3507
3508
3509
3510
3511
3512
3513
3514
3515
3516
3517
3518
3519
3520
3521
3522
3523
3524
3525
3526
3527
3528
3529
3530
3531
3532
3533
3534
3535
3536
3537
3538
3539
3540
3541
3542
3543
3544
3545
3546
3547
3548
3549
3550
3551
3552
3553
3554
3555
3556
3557
3558
3559
3560
3561
3562
3563
3564
3565
3566
3567
3568
3569
3570
3571
3572
3573
3574
3575
3576
3577
3578
3579
3580
3581
3582
3583
3584
3585
3586
3587
3588
3589
3590
3591
3592
3593
3594
3595
3596 func (c *ProjectsLocationsEnvironmentsPatchCall) UpdateMask(updateMask string) *ProjectsLocationsEnvironmentsPatchCall {
3597 c.urlParams_.Set("updateMask", updateMask)
3598 return c
3599 }
3600
3601
3602
3603
3604 func (c *ProjectsLocationsEnvironmentsPatchCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsPatchCall {
3605 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3606 return c
3607 }
3608
3609
3610 func (c *ProjectsLocationsEnvironmentsPatchCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsPatchCall {
3611 c.ctx_ = ctx
3612 return c
3613 }
3614
3615
3616
3617 func (c *ProjectsLocationsEnvironmentsPatchCall) Header() http.Header {
3618 if c.header_ == nil {
3619 c.header_ = make(http.Header)
3620 }
3621 return c.header_
3622 }
3623
3624 func (c *ProjectsLocationsEnvironmentsPatchCall) doRequest(alt string) (*http.Response, error) {
3625 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
3626 var body io.Reader = nil
3627 body, err := googleapi.WithoutDataWrapper.JSONReader(c.environment)
3628 if err != nil {
3629 return nil, err
3630 }
3631 c.urlParams_.Set("alt", alt)
3632 c.urlParams_.Set("prettyPrint", "false")
3633 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
3634 urls += "?" + c.urlParams_.Encode()
3635 req, err := http.NewRequest("PATCH", urls, body)
3636 if err != nil {
3637 return nil, err
3638 }
3639 req.Header = reqHeaders
3640 googleapi.Expand(req.URL, map[string]string{
3641 "name": c.name,
3642 })
3643 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3644 }
3645
3646
3647
3648
3649
3650
3651 func (c *ProjectsLocationsEnvironmentsPatchCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
3652 gensupport.SetOptions(c.urlParams_, opts...)
3653 res, err := c.doRequest("json")
3654 if res != nil && res.StatusCode == http.StatusNotModified {
3655 if res.Body != nil {
3656 res.Body.Close()
3657 }
3658 return nil, gensupport.WrapError(&googleapi.Error{
3659 Code: res.StatusCode,
3660 Header: res.Header,
3661 })
3662 }
3663 if err != nil {
3664 return nil, err
3665 }
3666 defer googleapi.CloseBody(res)
3667 if err := googleapi.CheckResponse(res); err != nil {
3668 return nil, gensupport.WrapError(err)
3669 }
3670 ret := &Operation{
3671 ServerResponse: googleapi.ServerResponse{
3672 Header: res.Header,
3673 HTTPStatusCode: res.StatusCode,
3674 },
3675 }
3676 target := &ret
3677 if err := gensupport.DecodeResponse(target, res); err != nil {
3678 return nil, err
3679 }
3680 return ret, nil
3681 }
3682
3683 type ProjectsLocationsEnvironmentsPollAirflowCommandCall struct {
3684 s *Service
3685 environment string
3686 pollairflowcommandrequest *PollAirflowCommandRequest
3687 urlParams_ gensupport.URLParams
3688 ctx_ context.Context
3689 header_ http.Header
3690 }
3691
3692
3693
3694
3695
3696 func (r *ProjectsLocationsEnvironmentsService) PollAirflowCommand(environment string, pollairflowcommandrequest *PollAirflowCommandRequest) *ProjectsLocationsEnvironmentsPollAirflowCommandCall {
3697 c := &ProjectsLocationsEnvironmentsPollAirflowCommandCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3698 c.environment = environment
3699 c.pollairflowcommandrequest = pollairflowcommandrequest
3700 return c
3701 }
3702
3703
3704
3705
3706 func (c *ProjectsLocationsEnvironmentsPollAirflowCommandCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsPollAirflowCommandCall {
3707 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3708 return c
3709 }
3710
3711
3712 func (c *ProjectsLocationsEnvironmentsPollAirflowCommandCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsPollAirflowCommandCall {
3713 c.ctx_ = ctx
3714 return c
3715 }
3716
3717
3718
3719 func (c *ProjectsLocationsEnvironmentsPollAirflowCommandCall) Header() http.Header {
3720 if c.header_ == nil {
3721 c.header_ = make(http.Header)
3722 }
3723 return c.header_
3724 }
3725
3726 func (c *ProjectsLocationsEnvironmentsPollAirflowCommandCall) doRequest(alt string) (*http.Response, error) {
3727 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
3728 var body io.Reader = nil
3729 body, err := googleapi.WithoutDataWrapper.JSONReader(c.pollairflowcommandrequest)
3730 if err != nil {
3731 return nil, err
3732 }
3733 c.urlParams_.Set("alt", alt)
3734 c.urlParams_.Set("prettyPrint", "false")
3735 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:pollAirflowCommand")
3736 urls += "?" + c.urlParams_.Encode()
3737 req, err := http.NewRequest("POST", urls, body)
3738 if err != nil {
3739 return nil, err
3740 }
3741 req.Header = reqHeaders
3742 googleapi.Expand(req.URL, map[string]string{
3743 "environment": c.environment,
3744 })
3745 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3746 }
3747
3748
3749
3750
3751
3752
3753
3754 func (c *ProjectsLocationsEnvironmentsPollAirflowCommandCall) Do(opts ...googleapi.CallOption) (*PollAirflowCommandResponse, error) {
3755 gensupport.SetOptions(c.urlParams_, opts...)
3756 res, err := c.doRequest("json")
3757 if res != nil && res.StatusCode == http.StatusNotModified {
3758 if res.Body != nil {
3759 res.Body.Close()
3760 }
3761 return nil, gensupport.WrapError(&googleapi.Error{
3762 Code: res.StatusCode,
3763 Header: res.Header,
3764 })
3765 }
3766 if err != nil {
3767 return nil, err
3768 }
3769 defer googleapi.CloseBody(res)
3770 if err := googleapi.CheckResponse(res); err != nil {
3771 return nil, gensupport.WrapError(err)
3772 }
3773 ret := &PollAirflowCommandResponse{
3774 ServerResponse: googleapi.ServerResponse{
3775 Header: res.Header,
3776 HTTPStatusCode: res.StatusCode,
3777 },
3778 }
3779 target := &ret
3780 if err := gensupport.DecodeResponse(target, res); err != nil {
3781 return nil, err
3782 }
3783 return ret, nil
3784 }
3785
3786 type ProjectsLocationsEnvironmentsRestartWebServerCall struct {
3787 s *Service
3788 name string
3789 restartwebserverrequest *RestartWebServerRequest
3790 urlParams_ gensupport.URLParams
3791 ctx_ context.Context
3792 header_ http.Header
3793 }
3794
3795
3796
3797
3798
3799
3800 func (r *ProjectsLocationsEnvironmentsService) RestartWebServer(name string, restartwebserverrequest *RestartWebServerRequest) *ProjectsLocationsEnvironmentsRestartWebServerCall {
3801 c := &ProjectsLocationsEnvironmentsRestartWebServerCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3802 c.name = name
3803 c.restartwebserverrequest = restartwebserverrequest
3804 return c
3805 }
3806
3807
3808
3809
3810 func (c *ProjectsLocationsEnvironmentsRestartWebServerCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsRestartWebServerCall {
3811 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3812 return c
3813 }
3814
3815
3816 func (c *ProjectsLocationsEnvironmentsRestartWebServerCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsRestartWebServerCall {
3817 c.ctx_ = ctx
3818 return c
3819 }
3820
3821
3822
3823 func (c *ProjectsLocationsEnvironmentsRestartWebServerCall) Header() http.Header {
3824 if c.header_ == nil {
3825 c.header_ = make(http.Header)
3826 }
3827 return c.header_
3828 }
3829
3830 func (c *ProjectsLocationsEnvironmentsRestartWebServerCall) doRequest(alt string) (*http.Response, error) {
3831 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
3832 var body io.Reader = nil
3833 body, err := googleapi.WithoutDataWrapper.JSONReader(c.restartwebserverrequest)
3834 if err != nil {
3835 return nil, err
3836 }
3837 c.urlParams_.Set("alt", alt)
3838 c.urlParams_.Set("prettyPrint", "false")
3839 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}:restartWebServer")
3840 urls += "?" + c.urlParams_.Encode()
3841 req, err := http.NewRequest("POST", urls, body)
3842 if err != nil {
3843 return nil, err
3844 }
3845 req.Header = reqHeaders
3846 googleapi.Expand(req.URL, map[string]string{
3847 "name": c.name,
3848 })
3849 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3850 }
3851
3852
3853
3854
3855
3856
3857 func (c *ProjectsLocationsEnvironmentsRestartWebServerCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
3858 gensupport.SetOptions(c.urlParams_, opts...)
3859 res, err := c.doRequest("json")
3860 if res != nil && res.StatusCode == http.StatusNotModified {
3861 if res.Body != nil {
3862 res.Body.Close()
3863 }
3864 return nil, gensupport.WrapError(&googleapi.Error{
3865 Code: res.StatusCode,
3866 Header: res.Header,
3867 })
3868 }
3869 if err != nil {
3870 return nil, err
3871 }
3872 defer googleapi.CloseBody(res)
3873 if err := googleapi.CheckResponse(res); err != nil {
3874 return nil, gensupport.WrapError(err)
3875 }
3876 ret := &Operation{
3877 ServerResponse: googleapi.ServerResponse{
3878 Header: res.Header,
3879 HTTPStatusCode: res.StatusCode,
3880 },
3881 }
3882 target := &ret
3883 if err := gensupport.DecodeResponse(target, res); err != nil {
3884 return nil, err
3885 }
3886 return ret, nil
3887 }
3888
3889 type ProjectsLocationsEnvironmentsSaveSnapshotCall struct {
3890 s *Service
3891 environment string
3892 savesnapshotrequest *SaveSnapshotRequest
3893 urlParams_ gensupport.URLParams
3894 ctx_ context.Context
3895 header_ http.Header
3896 }
3897
3898
3899
3900
3901
3902
3903
3904 func (r *ProjectsLocationsEnvironmentsService) SaveSnapshot(environment string, savesnapshotrequest *SaveSnapshotRequest) *ProjectsLocationsEnvironmentsSaveSnapshotCall {
3905 c := &ProjectsLocationsEnvironmentsSaveSnapshotCall{s: r.s, urlParams_: make(gensupport.URLParams)}
3906 c.environment = environment
3907 c.savesnapshotrequest = savesnapshotrequest
3908 return c
3909 }
3910
3911
3912
3913
3914 func (c *ProjectsLocationsEnvironmentsSaveSnapshotCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsSaveSnapshotCall {
3915 c.urlParams_.Set("fields", googleapi.CombineFields(s))
3916 return c
3917 }
3918
3919
3920 func (c *ProjectsLocationsEnvironmentsSaveSnapshotCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsSaveSnapshotCall {
3921 c.ctx_ = ctx
3922 return c
3923 }
3924
3925
3926
3927 func (c *ProjectsLocationsEnvironmentsSaveSnapshotCall) Header() http.Header {
3928 if c.header_ == nil {
3929 c.header_ = make(http.Header)
3930 }
3931 return c.header_
3932 }
3933
3934 func (c *ProjectsLocationsEnvironmentsSaveSnapshotCall) doRequest(alt string) (*http.Response, error) {
3935 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
3936 var body io.Reader = nil
3937 body, err := googleapi.WithoutDataWrapper.JSONReader(c.savesnapshotrequest)
3938 if err != nil {
3939 return nil, err
3940 }
3941 c.urlParams_.Set("alt", alt)
3942 c.urlParams_.Set("prettyPrint", "false")
3943 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:saveSnapshot")
3944 urls += "?" + c.urlParams_.Encode()
3945 req, err := http.NewRequest("POST", urls, body)
3946 if err != nil {
3947 return nil, err
3948 }
3949 req.Header = reqHeaders
3950 googleapi.Expand(req.URL, map[string]string{
3951 "environment": c.environment,
3952 })
3953 return gensupport.SendRequest(c.ctx_, c.s.client, req)
3954 }
3955
3956
3957
3958
3959
3960
3961 func (c *ProjectsLocationsEnvironmentsSaveSnapshotCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
3962 gensupport.SetOptions(c.urlParams_, opts...)
3963 res, err := c.doRequest("json")
3964 if res != nil && res.StatusCode == http.StatusNotModified {
3965 if res.Body != nil {
3966 res.Body.Close()
3967 }
3968 return nil, gensupport.WrapError(&googleapi.Error{
3969 Code: res.StatusCode,
3970 Header: res.Header,
3971 })
3972 }
3973 if err != nil {
3974 return nil, err
3975 }
3976 defer googleapi.CloseBody(res)
3977 if err := googleapi.CheckResponse(res); err != nil {
3978 return nil, gensupport.WrapError(err)
3979 }
3980 ret := &Operation{
3981 ServerResponse: googleapi.ServerResponse{
3982 Header: res.Header,
3983 HTTPStatusCode: res.StatusCode,
3984 },
3985 }
3986 target := &ret
3987 if err := gensupport.DecodeResponse(target, res); err != nil {
3988 return nil, err
3989 }
3990 return ret, nil
3991 }
3992
3993 type ProjectsLocationsEnvironmentsStopAirflowCommandCall struct {
3994 s *Service
3995 environment string
3996 stopairflowcommandrequest *StopAirflowCommandRequest
3997 urlParams_ gensupport.URLParams
3998 ctx_ context.Context
3999 header_ http.Header
4000 }
4001
4002
4003
4004
4005
4006 func (r *ProjectsLocationsEnvironmentsService) StopAirflowCommand(environment string, stopairflowcommandrequest *StopAirflowCommandRequest) *ProjectsLocationsEnvironmentsStopAirflowCommandCall {
4007 c := &ProjectsLocationsEnvironmentsStopAirflowCommandCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4008 c.environment = environment
4009 c.stopairflowcommandrequest = stopairflowcommandrequest
4010 return c
4011 }
4012
4013
4014
4015
4016 func (c *ProjectsLocationsEnvironmentsStopAirflowCommandCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsStopAirflowCommandCall {
4017 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4018 return c
4019 }
4020
4021
4022 func (c *ProjectsLocationsEnvironmentsStopAirflowCommandCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsStopAirflowCommandCall {
4023 c.ctx_ = ctx
4024 return c
4025 }
4026
4027
4028
4029 func (c *ProjectsLocationsEnvironmentsStopAirflowCommandCall) Header() http.Header {
4030 if c.header_ == nil {
4031 c.header_ = make(http.Header)
4032 }
4033 return c.header_
4034 }
4035
4036 func (c *ProjectsLocationsEnvironmentsStopAirflowCommandCall) doRequest(alt string) (*http.Response, error) {
4037 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
4038 var body io.Reader = nil
4039 body, err := googleapi.WithoutDataWrapper.JSONReader(c.stopairflowcommandrequest)
4040 if err != nil {
4041 return nil, err
4042 }
4043 c.urlParams_.Set("alt", alt)
4044 c.urlParams_.Set("prettyPrint", "false")
4045 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+environment}:stopAirflowCommand")
4046 urls += "?" + c.urlParams_.Encode()
4047 req, err := http.NewRequest("POST", urls, body)
4048 if err != nil {
4049 return nil, err
4050 }
4051 req.Header = reqHeaders
4052 googleapi.Expand(req.URL, map[string]string{
4053 "environment": c.environment,
4054 })
4055 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4056 }
4057
4058
4059
4060
4061
4062
4063
4064 func (c *ProjectsLocationsEnvironmentsStopAirflowCommandCall) Do(opts ...googleapi.CallOption) (*StopAirflowCommandResponse, error) {
4065 gensupport.SetOptions(c.urlParams_, opts...)
4066 res, err := c.doRequest("json")
4067 if res != nil && res.StatusCode == http.StatusNotModified {
4068 if res.Body != nil {
4069 res.Body.Close()
4070 }
4071 return nil, gensupport.WrapError(&googleapi.Error{
4072 Code: res.StatusCode,
4073 Header: res.Header,
4074 })
4075 }
4076 if err != nil {
4077 return nil, err
4078 }
4079 defer googleapi.CloseBody(res)
4080 if err := googleapi.CheckResponse(res); err != nil {
4081 return nil, gensupport.WrapError(err)
4082 }
4083 ret := &StopAirflowCommandResponse{
4084 ServerResponse: googleapi.ServerResponse{
4085 Header: res.Header,
4086 HTTPStatusCode: res.StatusCode,
4087 },
4088 }
4089 target := &ret
4090 if err := gensupport.DecodeResponse(target, res); err != nil {
4091 return nil, err
4092 }
4093 return ret, nil
4094 }
4095
4096 type ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall struct {
4097 s *Service
4098 parent string
4099 userworkloadsconfigmap *UserWorkloadsConfigMap
4100 urlParams_ gensupport.URLParams
4101 ctx_ context.Context
4102 header_ http.Header
4103 }
4104
4105
4106
4107
4108
4109
4110
4111 func (r *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService) Create(parent string, userworkloadsconfigmap *UserWorkloadsConfigMap) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall {
4112 c := &ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4113 c.parent = parent
4114 c.userworkloadsconfigmap = userworkloadsconfigmap
4115 return c
4116 }
4117
4118
4119
4120
4121 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall {
4122 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4123 return c
4124 }
4125
4126
4127 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall {
4128 c.ctx_ = ctx
4129 return c
4130 }
4131
4132
4133
4134 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall) Header() http.Header {
4135 if c.header_ == nil {
4136 c.header_ = make(http.Header)
4137 }
4138 return c.header_
4139 }
4140
4141 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall) doRequest(alt string) (*http.Response, error) {
4142 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
4143 var body io.Reader = nil
4144 body, err := googleapi.WithoutDataWrapper.JSONReader(c.userworkloadsconfigmap)
4145 if err != nil {
4146 return nil, err
4147 }
4148 c.urlParams_.Set("alt", alt)
4149 c.urlParams_.Set("prettyPrint", "false")
4150 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/userWorkloadsConfigMaps")
4151 urls += "?" + c.urlParams_.Encode()
4152 req, err := http.NewRequest("POST", urls, body)
4153 if err != nil {
4154 return nil, err
4155 }
4156 req.Header = reqHeaders
4157 googleapi.Expand(req.URL, map[string]string{
4158 "parent": c.parent,
4159 })
4160 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4161 }
4162
4163
4164
4165
4166
4167
4168
4169 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsCreateCall) Do(opts ...googleapi.CallOption) (*UserWorkloadsConfigMap, error) {
4170 gensupport.SetOptions(c.urlParams_, opts...)
4171 res, err := c.doRequest("json")
4172 if res != nil && res.StatusCode == http.StatusNotModified {
4173 if res.Body != nil {
4174 res.Body.Close()
4175 }
4176 return nil, gensupport.WrapError(&googleapi.Error{
4177 Code: res.StatusCode,
4178 Header: res.Header,
4179 })
4180 }
4181 if err != nil {
4182 return nil, err
4183 }
4184 defer googleapi.CloseBody(res)
4185 if err := googleapi.CheckResponse(res); err != nil {
4186 return nil, gensupport.WrapError(err)
4187 }
4188 ret := &UserWorkloadsConfigMap{
4189 ServerResponse: googleapi.ServerResponse{
4190 Header: res.Header,
4191 HTTPStatusCode: res.StatusCode,
4192 },
4193 }
4194 target := &ret
4195 if err := gensupport.DecodeResponse(target, res); err != nil {
4196 return nil, err
4197 }
4198 return ret, nil
4199 }
4200
4201 type ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall struct {
4202 s *Service
4203 name string
4204 urlParams_ gensupport.URLParams
4205 ctx_ context.Context
4206 header_ http.Header
4207 }
4208
4209
4210
4211
4212
4213
4214
4215
4216 func (r *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService) Delete(name string) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall {
4217 c := &ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4218 c.name = name
4219 return c
4220 }
4221
4222
4223
4224
4225 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall {
4226 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4227 return c
4228 }
4229
4230
4231 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall {
4232 c.ctx_ = ctx
4233 return c
4234 }
4235
4236
4237
4238 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall) Header() http.Header {
4239 if c.header_ == nil {
4240 c.header_ = make(http.Header)
4241 }
4242 return c.header_
4243 }
4244
4245 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall) doRequest(alt string) (*http.Response, error) {
4246 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
4247 var body io.Reader = nil
4248 c.urlParams_.Set("alt", alt)
4249 c.urlParams_.Set("prettyPrint", "false")
4250 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
4251 urls += "?" + c.urlParams_.Encode()
4252 req, err := http.NewRequest("DELETE", urls, body)
4253 if err != nil {
4254 return nil, err
4255 }
4256 req.Header = reqHeaders
4257 googleapi.Expand(req.URL, map[string]string{
4258 "name": c.name,
4259 })
4260 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4261 }
4262
4263
4264
4265
4266
4267
4268 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
4269 gensupport.SetOptions(c.urlParams_, opts...)
4270 res, err := c.doRequest("json")
4271 if res != nil && res.StatusCode == http.StatusNotModified {
4272 if res.Body != nil {
4273 res.Body.Close()
4274 }
4275 return nil, gensupport.WrapError(&googleapi.Error{
4276 Code: res.StatusCode,
4277 Header: res.Header,
4278 })
4279 }
4280 if err != nil {
4281 return nil, err
4282 }
4283 defer googleapi.CloseBody(res)
4284 if err := googleapi.CheckResponse(res); err != nil {
4285 return nil, gensupport.WrapError(err)
4286 }
4287 ret := &Empty{
4288 ServerResponse: googleapi.ServerResponse{
4289 Header: res.Header,
4290 HTTPStatusCode: res.StatusCode,
4291 },
4292 }
4293 target := &ret
4294 if err := gensupport.DecodeResponse(target, res); err != nil {
4295 return nil, err
4296 }
4297 return ret, nil
4298 }
4299
4300 type ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall struct {
4301 s *Service
4302 name string
4303 urlParams_ gensupport.URLParams
4304 ifNoneMatch_ string
4305 ctx_ context.Context
4306 header_ http.Header
4307 }
4308
4309
4310
4311
4312
4313
4314
4315
4316 func (r *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService) Get(name string) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall {
4317 c := &ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4318 c.name = name
4319 return c
4320 }
4321
4322
4323
4324
4325 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall {
4326 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4327 return c
4328 }
4329
4330
4331
4332
4333 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall {
4334 c.ifNoneMatch_ = entityTag
4335 return c
4336 }
4337
4338
4339 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall {
4340 c.ctx_ = ctx
4341 return c
4342 }
4343
4344
4345
4346 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall) Header() http.Header {
4347 if c.header_ == nil {
4348 c.header_ = make(http.Header)
4349 }
4350 return c.header_
4351 }
4352
4353 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall) doRequest(alt string) (*http.Response, error) {
4354 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
4355 if c.ifNoneMatch_ != "" {
4356 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
4357 }
4358 var body io.Reader = nil
4359 c.urlParams_.Set("alt", alt)
4360 c.urlParams_.Set("prettyPrint", "false")
4361 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
4362 urls += "?" + c.urlParams_.Encode()
4363 req, err := http.NewRequest("GET", urls, body)
4364 if err != nil {
4365 return nil, err
4366 }
4367 req.Header = reqHeaders
4368 googleapi.Expand(req.URL, map[string]string{
4369 "name": c.name,
4370 })
4371 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4372 }
4373
4374
4375
4376
4377
4378
4379
4380 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsGetCall) Do(opts ...googleapi.CallOption) (*UserWorkloadsConfigMap, error) {
4381 gensupport.SetOptions(c.urlParams_, opts...)
4382 res, err := c.doRequest("json")
4383 if res != nil && res.StatusCode == http.StatusNotModified {
4384 if res.Body != nil {
4385 res.Body.Close()
4386 }
4387 return nil, gensupport.WrapError(&googleapi.Error{
4388 Code: res.StatusCode,
4389 Header: res.Header,
4390 })
4391 }
4392 if err != nil {
4393 return nil, err
4394 }
4395 defer googleapi.CloseBody(res)
4396 if err := googleapi.CheckResponse(res); err != nil {
4397 return nil, gensupport.WrapError(err)
4398 }
4399 ret := &UserWorkloadsConfigMap{
4400 ServerResponse: googleapi.ServerResponse{
4401 Header: res.Header,
4402 HTTPStatusCode: res.StatusCode,
4403 },
4404 }
4405 target := &ret
4406 if err := gensupport.DecodeResponse(target, res); err != nil {
4407 return nil, err
4408 }
4409 return ret, nil
4410 }
4411
4412 type ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall struct {
4413 s *Service
4414 parent string
4415 urlParams_ gensupport.URLParams
4416 ifNoneMatch_ string
4417 ctx_ context.Context
4418 header_ http.Header
4419 }
4420
4421
4422
4423
4424
4425
4426 func (r *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService) List(parent string) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall {
4427 c := &ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4428 c.parent = parent
4429 return c
4430 }
4431
4432
4433
4434 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) PageSize(pageSize int64) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall {
4435 c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
4436 return c
4437 }
4438
4439
4440
4441 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) PageToken(pageToken string) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall {
4442 c.urlParams_.Set("pageToken", pageToken)
4443 return c
4444 }
4445
4446
4447
4448
4449 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall {
4450 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4451 return c
4452 }
4453
4454
4455
4456
4457 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall {
4458 c.ifNoneMatch_ = entityTag
4459 return c
4460 }
4461
4462
4463 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall {
4464 c.ctx_ = ctx
4465 return c
4466 }
4467
4468
4469
4470 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) Header() http.Header {
4471 if c.header_ == nil {
4472 c.header_ = make(http.Header)
4473 }
4474 return c.header_
4475 }
4476
4477 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) doRequest(alt string) (*http.Response, error) {
4478 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
4479 if c.ifNoneMatch_ != "" {
4480 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
4481 }
4482 var body io.Reader = nil
4483 c.urlParams_.Set("alt", alt)
4484 c.urlParams_.Set("prettyPrint", "false")
4485 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/userWorkloadsConfigMaps")
4486 urls += "?" + c.urlParams_.Encode()
4487 req, err := http.NewRequest("GET", urls, body)
4488 if err != nil {
4489 return nil, err
4490 }
4491 req.Header = reqHeaders
4492 googleapi.Expand(req.URL, map[string]string{
4493 "parent": c.parent,
4494 })
4495 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4496 }
4497
4498
4499
4500
4501
4502
4503
4504 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) Do(opts ...googleapi.CallOption) (*ListUserWorkloadsConfigMapsResponse, error) {
4505 gensupport.SetOptions(c.urlParams_, opts...)
4506 res, err := c.doRequest("json")
4507 if res != nil && res.StatusCode == http.StatusNotModified {
4508 if res.Body != nil {
4509 res.Body.Close()
4510 }
4511 return nil, gensupport.WrapError(&googleapi.Error{
4512 Code: res.StatusCode,
4513 Header: res.Header,
4514 })
4515 }
4516 if err != nil {
4517 return nil, err
4518 }
4519 defer googleapi.CloseBody(res)
4520 if err := googleapi.CheckResponse(res); err != nil {
4521 return nil, gensupport.WrapError(err)
4522 }
4523 ret := &ListUserWorkloadsConfigMapsResponse{
4524 ServerResponse: googleapi.ServerResponse{
4525 Header: res.Header,
4526 HTTPStatusCode: res.StatusCode,
4527 },
4528 }
4529 target := &ret
4530 if err := gensupport.DecodeResponse(target, res); err != nil {
4531 return nil, err
4532 }
4533 return ret, nil
4534 }
4535
4536
4537
4538
4539 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsListCall) Pages(ctx context.Context, f func(*ListUserWorkloadsConfigMapsResponse) error) error {
4540 c.ctx_ = ctx
4541 defer c.PageToken(c.urlParams_.Get("pageToken"))
4542 for {
4543 x, err := c.Do()
4544 if err != nil {
4545 return err
4546 }
4547 if err := f(x); err != nil {
4548 return err
4549 }
4550 if x.NextPageToken == "" {
4551 return nil
4552 }
4553 c.PageToken(x.NextPageToken)
4554 }
4555 }
4556
4557 type ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall struct {
4558 s *Service
4559 name string
4560 userworkloadsconfigmap *UserWorkloadsConfigMap
4561 urlParams_ gensupport.URLParams
4562 ctx_ context.Context
4563 header_ http.Header
4564 }
4565
4566
4567
4568
4569
4570
4571
4572
4573 func (r *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsService) Update(name string, userworkloadsconfigmap *UserWorkloadsConfigMap) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall {
4574 c := &ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4575 c.name = name
4576 c.userworkloadsconfigmap = userworkloadsconfigmap
4577 return c
4578 }
4579
4580
4581
4582
4583 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall {
4584 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4585 return c
4586 }
4587
4588
4589 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall {
4590 c.ctx_ = ctx
4591 return c
4592 }
4593
4594
4595
4596 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall) Header() http.Header {
4597 if c.header_ == nil {
4598 c.header_ = make(http.Header)
4599 }
4600 return c.header_
4601 }
4602
4603 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall) doRequest(alt string) (*http.Response, error) {
4604 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
4605 var body io.Reader = nil
4606 body, err := googleapi.WithoutDataWrapper.JSONReader(c.userworkloadsconfigmap)
4607 if err != nil {
4608 return nil, err
4609 }
4610 c.urlParams_.Set("alt", alt)
4611 c.urlParams_.Set("prettyPrint", "false")
4612 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
4613 urls += "?" + c.urlParams_.Encode()
4614 req, err := http.NewRequest("PUT", urls, body)
4615 if err != nil {
4616 return nil, err
4617 }
4618 req.Header = reqHeaders
4619 googleapi.Expand(req.URL, map[string]string{
4620 "name": c.name,
4621 })
4622 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4623 }
4624
4625
4626
4627
4628
4629
4630
4631 func (c *ProjectsLocationsEnvironmentsUserWorkloadsConfigMapsUpdateCall) Do(opts ...googleapi.CallOption) (*UserWorkloadsConfigMap, error) {
4632 gensupport.SetOptions(c.urlParams_, opts...)
4633 res, err := c.doRequest("json")
4634 if res != nil && res.StatusCode == http.StatusNotModified {
4635 if res.Body != nil {
4636 res.Body.Close()
4637 }
4638 return nil, gensupport.WrapError(&googleapi.Error{
4639 Code: res.StatusCode,
4640 Header: res.Header,
4641 })
4642 }
4643 if err != nil {
4644 return nil, err
4645 }
4646 defer googleapi.CloseBody(res)
4647 if err := googleapi.CheckResponse(res); err != nil {
4648 return nil, gensupport.WrapError(err)
4649 }
4650 ret := &UserWorkloadsConfigMap{
4651 ServerResponse: googleapi.ServerResponse{
4652 Header: res.Header,
4653 HTTPStatusCode: res.StatusCode,
4654 },
4655 }
4656 target := &ret
4657 if err := gensupport.DecodeResponse(target, res); err != nil {
4658 return nil, err
4659 }
4660 return ret, nil
4661 }
4662
4663 type ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall struct {
4664 s *Service
4665 parent string
4666 userworkloadssecret *UserWorkloadsSecret
4667 urlParams_ gensupport.URLParams
4668 ctx_ context.Context
4669 header_ http.Header
4670 }
4671
4672
4673
4674
4675
4676
4677 func (r *ProjectsLocationsEnvironmentsUserWorkloadsSecretsService) Create(parent string, userworkloadssecret *UserWorkloadsSecret) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall {
4678 c := &ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4679 c.parent = parent
4680 c.userworkloadssecret = userworkloadssecret
4681 return c
4682 }
4683
4684
4685
4686
4687 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall {
4688 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4689 return c
4690 }
4691
4692
4693 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall {
4694 c.ctx_ = ctx
4695 return c
4696 }
4697
4698
4699
4700 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall) Header() http.Header {
4701 if c.header_ == nil {
4702 c.header_ = make(http.Header)
4703 }
4704 return c.header_
4705 }
4706
4707 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall) doRequest(alt string) (*http.Response, error) {
4708 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
4709 var body io.Reader = nil
4710 body, err := googleapi.WithoutDataWrapper.JSONReader(c.userworkloadssecret)
4711 if err != nil {
4712 return nil, err
4713 }
4714 c.urlParams_.Set("alt", alt)
4715 c.urlParams_.Set("prettyPrint", "false")
4716 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/userWorkloadsSecrets")
4717 urls += "?" + c.urlParams_.Encode()
4718 req, err := http.NewRequest("POST", urls, body)
4719 if err != nil {
4720 return nil, err
4721 }
4722 req.Header = reqHeaders
4723 googleapi.Expand(req.URL, map[string]string{
4724 "parent": c.parent,
4725 })
4726 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4727 }
4728
4729
4730
4731
4732
4733
4734
4735 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsCreateCall) Do(opts ...googleapi.CallOption) (*UserWorkloadsSecret, error) {
4736 gensupport.SetOptions(c.urlParams_, opts...)
4737 res, err := c.doRequest("json")
4738 if res != nil && res.StatusCode == http.StatusNotModified {
4739 if res.Body != nil {
4740 res.Body.Close()
4741 }
4742 return nil, gensupport.WrapError(&googleapi.Error{
4743 Code: res.StatusCode,
4744 Header: res.Header,
4745 })
4746 }
4747 if err != nil {
4748 return nil, err
4749 }
4750 defer googleapi.CloseBody(res)
4751 if err := googleapi.CheckResponse(res); err != nil {
4752 return nil, gensupport.WrapError(err)
4753 }
4754 ret := &UserWorkloadsSecret{
4755 ServerResponse: googleapi.ServerResponse{
4756 Header: res.Header,
4757 HTTPStatusCode: res.StatusCode,
4758 },
4759 }
4760 target := &ret
4761 if err := gensupport.DecodeResponse(target, res); err != nil {
4762 return nil, err
4763 }
4764 return ret, nil
4765 }
4766
4767 type ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall struct {
4768 s *Service
4769 name string
4770 urlParams_ gensupport.URLParams
4771 ctx_ context.Context
4772 header_ http.Header
4773 }
4774
4775
4776
4777
4778
4779
4780
4781 func (r *ProjectsLocationsEnvironmentsUserWorkloadsSecretsService) Delete(name string) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall {
4782 c := &ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4783 c.name = name
4784 return c
4785 }
4786
4787
4788
4789
4790 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall {
4791 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4792 return c
4793 }
4794
4795
4796 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall {
4797 c.ctx_ = ctx
4798 return c
4799 }
4800
4801
4802
4803 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall) Header() http.Header {
4804 if c.header_ == nil {
4805 c.header_ = make(http.Header)
4806 }
4807 return c.header_
4808 }
4809
4810 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall) doRequest(alt string) (*http.Response, error) {
4811 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
4812 var body io.Reader = nil
4813 c.urlParams_.Set("alt", alt)
4814 c.urlParams_.Set("prettyPrint", "false")
4815 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
4816 urls += "?" + c.urlParams_.Encode()
4817 req, err := http.NewRequest("DELETE", urls, body)
4818 if err != nil {
4819 return nil, err
4820 }
4821 req.Header = reqHeaders
4822 googleapi.Expand(req.URL, map[string]string{
4823 "name": c.name,
4824 })
4825 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4826 }
4827
4828
4829
4830
4831
4832
4833 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
4834 gensupport.SetOptions(c.urlParams_, opts...)
4835 res, err := c.doRequest("json")
4836 if res != nil && res.StatusCode == http.StatusNotModified {
4837 if res.Body != nil {
4838 res.Body.Close()
4839 }
4840 return nil, gensupport.WrapError(&googleapi.Error{
4841 Code: res.StatusCode,
4842 Header: res.Header,
4843 })
4844 }
4845 if err != nil {
4846 return nil, err
4847 }
4848 defer googleapi.CloseBody(res)
4849 if err := googleapi.CheckResponse(res); err != nil {
4850 return nil, gensupport.WrapError(err)
4851 }
4852 ret := &Empty{
4853 ServerResponse: googleapi.ServerResponse{
4854 Header: res.Header,
4855 HTTPStatusCode: res.StatusCode,
4856 },
4857 }
4858 target := &ret
4859 if err := gensupport.DecodeResponse(target, res); err != nil {
4860 return nil, err
4861 }
4862 return ret, nil
4863 }
4864
4865 type ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall struct {
4866 s *Service
4867 name string
4868 urlParams_ gensupport.URLParams
4869 ifNoneMatch_ string
4870 ctx_ context.Context
4871 header_ http.Header
4872 }
4873
4874
4875
4876
4877
4878
4879
4880
4881 func (r *ProjectsLocationsEnvironmentsUserWorkloadsSecretsService) Get(name string) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall {
4882 c := &ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4883 c.name = name
4884 return c
4885 }
4886
4887
4888
4889
4890 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall {
4891 c.urlParams_.Set("fields", googleapi.CombineFields(s))
4892 return c
4893 }
4894
4895
4896
4897
4898 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall {
4899 c.ifNoneMatch_ = entityTag
4900 return c
4901 }
4902
4903
4904 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall {
4905 c.ctx_ = ctx
4906 return c
4907 }
4908
4909
4910
4911 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall) Header() http.Header {
4912 if c.header_ == nil {
4913 c.header_ = make(http.Header)
4914 }
4915 return c.header_
4916 }
4917
4918 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall) doRequest(alt string) (*http.Response, error) {
4919 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
4920 if c.ifNoneMatch_ != "" {
4921 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
4922 }
4923 var body io.Reader = nil
4924 c.urlParams_.Set("alt", alt)
4925 c.urlParams_.Set("prettyPrint", "false")
4926 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
4927 urls += "?" + c.urlParams_.Encode()
4928 req, err := http.NewRequest("GET", urls, body)
4929 if err != nil {
4930 return nil, err
4931 }
4932 req.Header = reqHeaders
4933 googleapi.Expand(req.URL, map[string]string{
4934 "name": c.name,
4935 })
4936 return gensupport.SendRequest(c.ctx_, c.s.client, req)
4937 }
4938
4939
4940
4941
4942
4943
4944
4945 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsGetCall) Do(opts ...googleapi.CallOption) (*UserWorkloadsSecret, error) {
4946 gensupport.SetOptions(c.urlParams_, opts...)
4947 res, err := c.doRequest("json")
4948 if res != nil && res.StatusCode == http.StatusNotModified {
4949 if res.Body != nil {
4950 res.Body.Close()
4951 }
4952 return nil, gensupport.WrapError(&googleapi.Error{
4953 Code: res.StatusCode,
4954 Header: res.Header,
4955 })
4956 }
4957 if err != nil {
4958 return nil, err
4959 }
4960 defer googleapi.CloseBody(res)
4961 if err := googleapi.CheckResponse(res); err != nil {
4962 return nil, gensupport.WrapError(err)
4963 }
4964 ret := &UserWorkloadsSecret{
4965 ServerResponse: googleapi.ServerResponse{
4966 Header: res.Header,
4967 HTTPStatusCode: res.StatusCode,
4968 },
4969 }
4970 target := &ret
4971 if err := gensupport.DecodeResponse(target, res); err != nil {
4972 return nil, err
4973 }
4974 return ret, nil
4975 }
4976
4977 type ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall struct {
4978 s *Service
4979 parent string
4980 urlParams_ gensupport.URLParams
4981 ifNoneMatch_ string
4982 ctx_ context.Context
4983 header_ http.Header
4984 }
4985
4986
4987
4988
4989
4990
4991 func (r *ProjectsLocationsEnvironmentsUserWorkloadsSecretsService) List(parent string) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall {
4992 c := &ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
4993 c.parent = parent
4994 return c
4995 }
4996
4997
4998
4999 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) PageSize(pageSize int64) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall {
5000 c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
5001 return c
5002 }
5003
5004
5005
5006 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) PageToken(pageToken string) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall {
5007 c.urlParams_.Set("pageToken", pageToken)
5008 return c
5009 }
5010
5011
5012
5013
5014 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall {
5015 c.urlParams_.Set("fields", googleapi.CombineFields(s))
5016 return c
5017 }
5018
5019
5020
5021
5022 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall {
5023 c.ifNoneMatch_ = entityTag
5024 return c
5025 }
5026
5027
5028 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall {
5029 c.ctx_ = ctx
5030 return c
5031 }
5032
5033
5034
5035 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) Header() http.Header {
5036 if c.header_ == nil {
5037 c.header_ = make(http.Header)
5038 }
5039 return c.header_
5040 }
5041
5042 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) doRequest(alt string) (*http.Response, error) {
5043 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
5044 if c.ifNoneMatch_ != "" {
5045 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
5046 }
5047 var body io.Reader = nil
5048 c.urlParams_.Set("alt", alt)
5049 c.urlParams_.Set("prettyPrint", "false")
5050 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/userWorkloadsSecrets")
5051 urls += "?" + c.urlParams_.Encode()
5052 req, err := http.NewRequest("GET", urls, body)
5053 if err != nil {
5054 return nil, err
5055 }
5056 req.Header = reqHeaders
5057 googleapi.Expand(req.URL, map[string]string{
5058 "parent": c.parent,
5059 })
5060 return gensupport.SendRequest(c.ctx_, c.s.client, req)
5061 }
5062
5063
5064
5065
5066
5067
5068
5069 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) Do(opts ...googleapi.CallOption) (*ListUserWorkloadsSecretsResponse, error) {
5070 gensupport.SetOptions(c.urlParams_, opts...)
5071 res, err := c.doRequest("json")
5072 if res != nil && res.StatusCode == http.StatusNotModified {
5073 if res.Body != nil {
5074 res.Body.Close()
5075 }
5076 return nil, gensupport.WrapError(&googleapi.Error{
5077 Code: res.StatusCode,
5078 Header: res.Header,
5079 })
5080 }
5081 if err != nil {
5082 return nil, err
5083 }
5084 defer googleapi.CloseBody(res)
5085 if err := googleapi.CheckResponse(res); err != nil {
5086 return nil, gensupport.WrapError(err)
5087 }
5088 ret := &ListUserWorkloadsSecretsResponse{
5089 ServerResponse: googleapi.ServerResponse{
5090 Header: res.Header,
5091 HTTPStatusCode: res.StatusCode,
5092 },
5093 }
5094 target := &ret
5095 if err := gensupport.DecodeResponse(target, res); err != nil {
5096 return nil, err
5097 }
5098 return ret, nil
5099 }
5100
5101
5102
5103
5104 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsListCall) Pages(ctx context.Context, f func(*ListUserWorkloadsSecretsResponse) error) error {
5105 c.ctx_ = ctx
5106 defer c.PageToken(c.urlParams_.Get("pageToken"))
5107 for {
5108 x, err := c.Do()
5109 if err != nil {
5110 return err
5111 }
5112 if err := f(x); err != nil {
5113 return err
5114 }
5115 if x.NextPageToken == "" {
5116 return nil
5117 }
5118 c.PageToken(x.NextPageToken)
5119 }
5120 }
5121
5122 type ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall struct {
5123 s *Service
5124 name string
5125 userworkloadssecret *UserWorkloadsSecret
5126 urlParams_ gensupport.URLParams
5127 ctx_ context.Context
5128 header_ http.Header
5129 }
5130
5131
5132
5133
5134
5135
5136
5137 func (r *ProjectsLocationsEnvironmentsUserWorkloadsSecretsService) Update(name string, userworkloadssecret *UserWorkloadsSecret) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall {
5138 c := &ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall{s: r.s, urlParams_: make(gensupport.URLParams)}
5139 c.name = name
5140 c.userworkloadssecret = userworkloadssecret
5141 return c
5142 }
5143
5144
5145
5146
5147 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall {
5148 c.urlParams_.Set("fields", googleapi.CombineFields(s))
5149 return c
5150 }
5151
5152
5153 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall {
5154 c.ctx_ = ctx
5155 return c
5156 }
5157
5158
5159
5160 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall) Header() http.Header {
5161 if c.header_ == nil {
5162 c.header_ = make(http.Header)
5163 }
5164 return c.header_
5165 }
5166
5167 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall) doRequest(alt string) (*http.Response, error) {
5168 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_)
5169 var body io.Reader = nil
5170 body, err := googleapi.WithoutDataWrapper.JSONReader(c.userworkloadssecret)
5171 if err != nil {
5172 return nil, err
5173 }
5174 c.urlParams_.Set("alt", alt)
5175 c.urlParams_.Set("prettyPrint", "false")
5176 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
5177 urls += "?" + c.urlParams_.Encode()
5178 req, err := http.NewRequest("PUT", urls, body)
5179 if err != nil {
5180 return nil, err
5181 }
5182 req.Header = reqHeaders
5183 googleapi.Expand(req.URL, map[string]string{
5184 "name": c.name,
5185 })
5186 return gensupport.SendRequest(c.ctx_, c.s.client, req)
5187 }
5188
5189
5190
5191
5192
5193
5194
5195 func (c *ProjectsLocationsEnvironmentsUserWorkloadsSecretsUpdateCall) Do(opts ...googleapi.CallOption) (*UserWorkloadsSecret, error) {
5196 gensupport.SetOptions(c.urlParams_, opts...)
5197 res, err := c.doRequest("json")
5198 if res != nil && res.StatusCode == http.StatusNotModified {
5199 if res.Body != nil {
5200 res.Body.Close()
5201 }
5202 return nil, gensupport.WrapError(&googleapi.Error{
5203 Code: res.StatusCode,
5204 Header: res.Header,
5205 })
5206 }
5207 if err != nil {
5208 return nil, err
5209 }
5210 defer googleapi.CloseBody(res)
5211 if err := googleapi.CheckResponse(res); err != nil {
5212 return nil, gensupport.WrapError(err)
5213 }
5214 ret := &UserWorkloadsSecret{
5215 ServerResponse: googleapi.ServerResponse{
5216 Header: res.Header,
5217 HTTPStatusCode: res.StatusCode,
5218 },
5219 }
5220 target := &ret
5221 if err := gensupport.DecodeResponse(target, res); err != nil {
5222 return nil, err
5223 }
5224 return ret, nil
5225 }
5226
5227 type ProjectsLocationsEnvironmentsWorkloadsListCall struct {
5228 s *Service
5229 parent string
5230 urlParams_ gensupport.URLParams
5231 ifNoneMatch_ string
5232 ctx_ context.Context
5233 header_ http.Header
5234 }
5235
5236
5237
5238
5239
5240
5241
5242 func (r *ProjectsLocationsEnvironmentsWorkloadsService) List(parent string) *ProjectsLocationsEnvironmentsWorkloadsListCall {
5243 c := &ProjectsLocationsEnvironmentsWorkloadsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
5244 c.parent = parent
5245 return c
5246 }
5247
5248
5249
5250
5251
5252
5253 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) Filter(filter string) *ProjectsLocationsEnvironmentsWorkloadsListCall {
5254 c.urlParams_.Set("filter", filter)
5255 return c
5256 }
5257
5258
5259
5260 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) PageSize(pageSize int64) *ProjectsLocationsEnvironmentsWorkloadsListCall {
5261 c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
5262 return c
5263 }
5264
5265
5266
5267 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) PageToken(pageToken string) *ProjectsLocationsEnvironmentsWorkloadsListCall {
5268 c.urlParams_.Set("pageToken", pageToken)
5269 return c
5270 }
5271
5272
5273
5274
5275 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsEnvironmentsWorkloadsListCall {
5276 c.urlParams_.Set("fields", googleapi.CombineFields(s))
5277 return c
5278 }
5279
5280
5281
5282
5283 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsEnvironmentsWorkloadsListCall {
5284 c.ifNoneMatch_ = entityTag
5285 return c
5286 }
5287
5288
5289 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) Context(ctx context.Context) *ProjectsLocationsEnvironmentsWorkloadsListCall {
5290 c.ctx_ = ctx
5291 return c
5292 }
5293
5294
5295
5296 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) Header() http.Header {
5297 if c.header_ == nil {
5298 c.header_ = make(http.Header)
5299 }
5300 return c.header_
5301 }
5302
5303 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) doRequest(alt string) (*http.Response, error) {
5304 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
5305 if c.ifNoneMatch_ != "" {
5306 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
5307 }
5308 var body io.Reader = nil
5309 c.urlParams_.Set("alt", alt)
5310 c.urlParams_.Set("prettyPrint", "false")
5311 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/workloads")
5312 urls += "?" + c.urlParams_.Encode()
5313 req, err := http.NewRequest("GET", urls, body)
5314 if err != nil {
5315 return nil, err
5316 }
5317 req.Header = reqHeaders
5318 googleapi.Expand(req.URL, map[string]string{
5319 "parent": c.parent,
5320 })
5321 return gensupport.SendRequest(c.ctx_, c.s.client, req)
5322 }
5323
5324
5325
5326
5327
5328
5329
5330 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) Do(opts ...googleapi.CallOption) (*ListWorkloadsResponse, error) {
5331 gensupport.SetOptions(c.urlParams_, opts...)
5332 res, err := c.doRequest("json")
5333 if res != nil && res.StatusCode == http.StatusNotModified {
5334 if res.Body != nil {
5335 res.Body.Close()
5336 }
5337 return nil, gensupport.WrapError(&googleapi.Error{
5338 Code: res.StatusCode,
5339 Header: res.Header,
5340 })
5341 }
5342 if err != nil {
5343 return nil, err
5344 }
5345 defer googleapi.CloseBody(res)
5346 if err := googleapi.CheckResponse(res); err != nil {
5347 return nil, gensupport.WrapError(err)
5348 }
5349 ret := &ListWorkloadsResponse{
5350 ServerResponse: googleapi.ServerResponse{
5351 Header: res.Header,
5352 HTTPStatusCode: res.StatusCode,
5353 },
5354 }
5355 target := &ret
5356 if err := gensupport.DecodeResponse(target, res); err != nil {
5357 return nil, err
5358 }
5359 return ret, nil
5360 }
5361
5362
5363
5364
5365 func (c *ProjectsLocationsEnvironmentsWorkloadsListCall) Pages(ctx context.Context, f func(*ListWorkloadsResponse) error) error {
5366 c.ctx_ = ctx
5367 defer c.PageToken(c.urlParams_.Get("pageToken"))
5368 for {
5369 x, err := c.Do()
5370 if err != nil {
5371 return err
5372 }
5373 if err := f(x); err != nil {
5374 return err
5375 }
5376 if x.NextPageToken == "" {
5377 return nil
5378 }
5379 c.PageToken(x.NextPageToken)
5380 }
5381 }
5382
5383 type ProjectsLocationsImageVersionsListCall struct {
5384 s *Service
5385 parent string
5386 urlParams_ gensupport.URLParams
5387 ifNoneMatch_ string
5388 ctx_ context.Context
5389 header_ http.Header
5390 }
5391
5392
5393
5394
5395
5396 func (r *ProjectsLocationsImageVersionsService) List(parent string) *ProjectsLocationsImageVersionsListCall {
5397 c := &ProjectsLocationsImageVersionsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
5398 c.parent = parent
5399 return c
5400 }
5401
5402
5403
5404 func (c *ProjectsLocationsImageVersionsListCall) IncludePastReleases(includePastReleases bool) *ProjectsLocationsImageVersionsListCall {
5405 c.urlParams_.Set("includePastReleases", fmt.Sprint(includePastReleases))
5406 return c
5407 }
5408
5409
5410
5411 func (c *ProjectsLocationsImageVersionsListCall) PageSize(pageSize int64) *ProjectsLocationsImageVersionsListCall {
5412 c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
5413 return c
5414 }
5415
5416
5417
5418 func (c *ProjectsLocationsImageVersionsListCall) PageToken(pageToken string) *ProjectsLocationsImageVersionsListCall {
5419 c.urlParams_.Set("pageToken", pageToken)
5420 return c
5421 }
5422
5423
5424
5425
5426 func (c *ProjectsLocationsImageVersionsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsImageVersionsListCall {
5427 c.urlParams_.Set("fields", googleapi.CombineFields(s))
5428 return c
5429 }
5430
5431
5432
5433
5434 func (c *ProjectsLocationsImageVersionsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsImageVersionsListCall {
5435 c.ifNoneMatch_ = entityTag
5436 return c
5437 }
5438
5439
5440 func (c *ProjectsLocationsImageVersionsListCall) Context(ctx context.Context) *ProjectsLocationsImageVersionsListCall {
5441 c.ctx_ = ctx
5442 return c
5443 }
5444
5445
5446
5447 func (c *ProjectsLocationsImageVersionsListCall) Header() http.Header {
5448 if c.header_ == nil {
5449 c.header_ = make(http.Header)
5450 }
5451 return c.header_
5452 }
5453
5454 func (c *ProjectsLocationsImageVersionsListCall) doRequest(alt string) (*http.Response, error) {
5455 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
5456 if c.ifNoneMatch_ != "" {
5457 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
5458 }
5459 var body io.Reader = nil
5460 c.urlParams_.Set("alt", alt)
5461 c.urlParams_.Set("prettyPrint", "false")
5462 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+parent}/imageVersions")
5463 urls += "?" + c.urlParams_.Encode()
5464 req, err := http.NewRequest("GET", urls, body)
5465 if err != nil {
5466 return nil, err
5467 }
5468 req.Header = reqHeaders
5469 googleapi.Expand(req.URL, map[string]string{
5470 "parent": c.parent,
5471 })
5472 return gensupport.SendRequest(c.ctx_, c.s.client, req)
5473 }
5474
5475
5476
5477
5478
5479
5480
5481 func (c *ProjectsLocationsImageVersionsListCall) Do(opts ...googleapi.CallOption) (*ListImageVersionsResponse, error) {
5482 gensupport.SetOptions(c.urlParams_, opts...)
5483 res, err := c.doRequest("json")
5484 if res != nil && res.StatusCode == http.StatusNotModified {
5485 if res.Body != nil {
5486 res.Body.Close()
5487 }
5488 return nil, gensupport.WrapError(&googleapi.Error{
5489 Code: res.StatusCode,
5490 Header: res.Header,
5491 })
5492 }
5493 if err != nil {
5494 return nil, err
5495 }
5496 defer googleapi.CloseBody(res)
5497 if err := googleapi.CheckResponse(res); err != nil {
5498 return nil, gensupport.WrapError(err)
5499 }
5500 ret := &ListImageVersionsResponse{
5501 ServerResponse: googleapi.ServerResponse{
5502 Header: res.Header,
5503 HTTPStatusCode: res.StatusCode,
5504 },
5505 }
5506 target := &ret
5507 if err := gensupport.DecodeResponse(target, res); err != nil {
5508 return nil, err
5509 }
5510 return ret, nil
5511 }
5512
5513
5514
5515
5516 func (c *ProjectsLocationsImageVersionsListCall) Pages(ctx context.Context, f func(*ListImageVersionsResponse) error) error {
5517 c.ctx_ = ctx
5518 defer c.PageToken(c.urlParams_.Get("pageToken"))
5519 for {
5520 x, err := c.Do()
5521 if err != nil {
5522 return err
5523 }
5524 if err := f(x); err != nil {
5525 return err
5526 }
5527 if x.NextPageToken == "" {
5528 return nil
5529 }
5530 c.PageToken(x.NextPageToken)
5531 }
5532 }
5533
5534 type ProjectsLocationsOperationsDeleteCall struct {
5535 s *Service
5536 name string
5537 urlParams_ gensupport.URLParams
5538 ctx_ context.Context
5539 header_ http.Header
5540 }
5541
5542
5543
5544
5545
5546
5547
5548 func (r *ProjectsLocationsOperationsService) Delete(name string) *ProjectsLocationsOperationsDeleteCall {
5549 c := &ProjectsLocationsOperationsDeleteCall{s: r.s, urlParams_: make(gensupport.URLParams)}
5550 c.name = name
5551 return c
5552 }
5553
5554
5555
5556
5557 func (c *ProjectsLocationsOperationsDeleteCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsDeleteCall {
5558 c.urlParams_.Set("fields", googleapi.CombineFields(s))
5559 return c
5560 }
5561
5562
5563 func (c *ProjectsLocationsOperationsDeleteCall) Context(ctx context.Context) *ProjectsLocationsOperationsDeleteCall {
5564 c.ctx_ = ctx
5565 return c
5566 }
5567
5568
5569
5570 func (c *ProjectsLocationsOperationsDeleteCall) Header() http.Header {
5571 if c.header_ == nil {
5572 c.header_ = make(http.Header)
5573 }
5574 return c.header_
5575 }
5576
5577 func (c *ProjectsLocationsOperationsDeleteCall) doRequest(alt string) (*http.Response, error) {
5578 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
5579 var body io.Reader = nil
5580 c.urlParams_.Set("alt", alt)
5581 c.urlParams_.Set("prettyPrint", "false")
5582 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
5583 urls += "?" + c.urlParams_.Encode()
5584 req, err := http.NewRequest("DELETE", urls, body)
5585 if err != nil {
5586 return nil, err
5587 }
5588 req.Header = reqHeaders
5589 googleapi.Expand(req.URL, map[string]string{
5590 "name": c.name,
5591 })
5592 return gensupport.SendRequest(c.ctx_, c.s.client, req)
5593 }
5594
5595
5596
5597
5598
5599
5600 func (c *ProjectsLocationsOperationsDeleteCall) Do(opts ...googleapi.CallOption) (*Empty, error) {
5601 gensupport.SetOptions(c.urlParams_, opts...)
5602 res, err := c.doRequest("json")
5603 if res != nil && res.StatusCode == http.StatusNotModified {
5604 if res.Body != nil {
5605 res.Body.Close()
5606 }
5607 return nil, gensupport.WrapError(&googleapi.Error{
5608 Code: res.StatusCode,
5609 Header: res.Header,
5610 })
5611 }
5612 if err != nil {
5613 return nil, err
5614 }
5615 defer googleapi.CloseBody(res)
5616 if err := googleapi.CheckResponse(res); err != nil {
5617 return nil, gensupport.WrapError(err)
5618 }
5619 ret := &Empty{
5620 ServerResponse: googleapi.ServerResponse{
5621 Header: res.Header,
5622 HTTPStatusCode: res.StatusCode,
5623 },
5624 }
5625 target := &ret
5626 if err := gensupport.DecodeResponse(target, res); err != nil {
5627 return nil, err
5628 }
5629 return ret, nil
5630 }
5631
5632 type ProjectsLocationsOperationsGetCall struct {
5633 s *Service
5634 name string
5635 urlParams_ gensupport.URLParams
5636 ifNoneMatch_ string
5637 ctx_ context.Context
5638 header_ http.Header
5639 }
5640
5641
5642
5643
5644
5645
5646 func (r *ProjectsLocationsOperationsService) Get(name string) *ProjectsLocationsOperationsGetCall {
5647 c := &ProjectsLocationsOperationsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)}
5648 c.name = name
5649 return c
5650 }
5651
5652
5653
5654
5655 func (c *ProjectsLocationsOperationsGetCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsGetCall {
5656 c.urlParams_.Set("fields", googleapi.CombineFields(s))
5657 return c
5658 }
5659
5660
5661
5662
5663 func (c *ProjectsLocationsOperationsGetCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsGetCall {
5664 c.ifNoneMatch_ = entityTag
5665 return c
5666 }
5667
5668
5669 func (c *ProjectsLocationsOperationsGetCall) Context(ctx context.Context) *ProjectsLocationsOperationsGetCall {
5670 c.ctx_ = ctx
5671 return c
5672 }
5673
5674
5675
5676 func (c *ProjectsLocationsOperationsGetCall) Header() http.Header {
5677 if c.header_ == nil {
5678 c.header_ = make(http.Header)
5679 }
5680 return c.header_
5681 }
5682
5683 func (c *ProjectsLocationsOperationsGetCall) doRequest(alt string) (*http.Response, error) {
5684 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
5685 if c.ifNoneMatch_ != "" {
5686 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
5687 }
5688 var body io.Reader = nil
5689 c.urlParams_.Set("alt", alt)
5690 c.urlParams_.Set("prettyPrint", "false")
5691 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}")
5692 urls += "?" + c.urlParams_.Encode()
5693 req, err := http.NewRequest("GET", urls, body)
5694 if err != nil {
5695 return nil, err
5696 }
5697 req.Header = reqHeaders
5698 googleapi.Expand(req.URL, map[string]string{
5699 "name": c.name,
5700 })
5701 return gensupport.SendRequest(c.ctx_, c.s.client, req)
5702 }
5703
5704
5705
5706
5707
5708
5709 func (c *ProjectsLocationsOperationsGetCall) Do(opts ...googleapi.CallOption) (*Operation, error) {
5710 gensupport.SetOptions(c.urlParams_, opts...)
5711 res, err := c.doRequest("json")
5712 if res != nil && res.StatusCode == http.StatusNotModified {
5713 if res.Body != nil {
5714 res.Body.Close()
5715 }
5716 return nil, gensupport.WrapError(&googleapi.Error{
5717 Code: res.StatusCode,
5718 Header: res.Header,
5719 })
5720 }
5721 if err != nil {
5722 return nil, err
5723 }
5724 defer googleapi.CloseBody(res)
5725 if err := googleapi.CheckResponse(res); err != nil {
5726 return nil, gensupport.WrapError(err)
5727 }
5728 ret := &Operation{
5729 ServerResponse: googleapi.ServerResponse{
5730 Header: res.Header,
5731 HTTPStatusCode: res.StatusCode,
5732 },
5733 }
5734 target := &ret
5735 if err := gensupport.DecodeResponse(target, res); err != nil {
5736 return nil, err
5737 }
5738 return ret, nil
5739 }
5740
5741 type ProjectsLocationsOperationsListCall struct {
5742 s *Service
5743 name string
5744 urlParams_ gensupport.URLParams
5745 ifNoneMatch_ string
5746 ctx_ context.Context
5747 header_ http.Header
5748 }
5749
5750
5751
5752
5753
5754 func (r *ProjectsLocationsOperationsService) List(name string) *ProjectsLocationsOperationsListCall {
5755 c := &ProjectsLocationsOperationsListCall{s: r.s, urlParams_: make(gensupport.URLParams)}
5756 c.name = name
5757 return c
5758 }
5759
5760
5761 func (c *ProjectsLocationsOperationsListCall) Filter(filter string) *ProjectsLocationsOperationsListCall {
5762 c.urlParams_.Set("filter", filter)
5763 return c
5764 }
5765
5766
5767
5768 func (c *ProjectsLocationsOperationsListCall) PageSize(pageSize int64) *ProjectsLocationsOperationsListCall {
5769 c.urlParams_.Set("pageSize", fmt.Sprint(pageSize))
5770 return c
5771 }
5772
5773
5774
5775 func (c *ProjectsLocationsOperationsListCall) PageToken(pageToken string) *ProjectsLocationsOperationsListCall {
5776 c.urlParams_.Set("pageToken", pageToken)
5777 return c
5778 }
5779
5780
5781
5782
5783 func (c *ProjectsLocationsOperationsListCall) Fields(s ...googleapi.Field) *ProjectsLocationsOperationsListCall {
5784 c.urlParams_.Set("fields", googleapi.CombineFields(s))
5785 return c
5786 }
5787
5788
5789
5790
5791 func (c *ProjectsLocationsOperationsListCall) IfNoneMatch(entityTag string) *ProjectsLocationsOperationsListCall {
5792 c.ifNoneMatch_ = entityTag
5793 return c
5794 }
5795
5796
5797 func (c *ProjectsLocationsOperationsListCall) Context(ctx context.Context) *ProjectsLocationsOperationsListCall {
5798 c.ctx_ = ctx
5799 return c
5800 }
5801
5802
5803
5804 func (c *ProjectsLocationsOperationsListCall) Header() http.Header {
5805 if c.header_ == nil {
5806 c.header_ = make(http.Header)
5807 }
5808 return c.header_
5809 }
5810
5811 func (c *ProjectsLocationsOperationsListCall) doRequest(alt string) (*http.Response, error) {
5812 reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_)
5813 if c.ifNoneMatch_ != "" {
5814 reqHeaders.Set("If-None-Match", c.ifNoneMatch_)
5815 }
5816 var body io.Reader = nil
5817 c.urlParams_.Set("alt", alt)
5818 c.urlParams_.Set("prettyPrint", "false")
5819 urls := googleapi.ResolveRelative(c.s.BasePath, "v1beta1/{+name}/operations")
5820 urls += "?" + c.urlParams_.Encode()
5821 req, err := http.NewRequest("GET", urls, body)
5822 if err != nil {
5823 return nil, err
5824 }
5825 req.Header = reqHeaders
5826 googleapi.Expand(req.URL, map[string]string{
5827 "name": c.name,
5828 })
5829 return gensupport.SendRequest(c.ctx_, c.s.client, req)
5830 }
5831
5832
5833
5834
5835
5836
5837
5838 func (c *ProjectsLocationsOperationsListCall) Do(opts ...googleapi.CallOption) (*ListOperationsResponse, error) {
5839 gensupport.SetOptions(c.urlParams_, opts...)
5840 res, err := c.doRequest("json")
5841 if res != nil && res.StatusCode == http.StatusNotModified {
5842 if res.Body != nil {
5843 res.Body.Close()
5844 }
5845 return nil, gensupport.WrapError(&googleapi.Error{
5846 Code: res.StatusCode,
5847 Header: res.Header,
5848 })
5849 }
5850 if err != nil {
5851 return nil, err
5852 }
5853 defer googleapi.CloseBody(res)
5854 if err := googleapi.CheckResponse(res); err != nil {
5855 return nil, gensupport.WrapError(err)
5856 }
5857 ret := &ListOperationsResponse{
5858 ServerResponse: googleapi.ServerResponse{
5859 Header: res.Header,
5860 HTTPStatusCode: res.StatusCode,
5861 },
5862 }
5863 target := &ret
5864 if err := gensupport.DecodeResponse(target, res); err != nil {
5865 return nil, err
5866 }
5867 return ret, nil
5868 }
5869
5870
5871
5872
5873 func (c *ProjectsLocationsOperationsListCall) Pages(ctx context.Context, f func(*ListOperationsResponse) error) error {
5874 c.ctx_ = ctx
5875 defer c.PageToken(c.urlParams_.Get("pageToken"))
5876 for {
5877 x, err := c.Do()
5878 if err != nil {
5879 return err
5880 }
5881 if err := f(x); err != nil {
5882 return err
5883 }
5884 if x.NextPageToken == "" {
5885 return nil
5886 }
5887 c.PageToken(x.NextPageToken)
5888 }
5889 }
5890
View as plain text