diff --git a/astro-client-core/api.gen.go b/astro-client-core/api.gen.go index 15baf3f92..374a217f0 100644 --- a/astro-client-core/api.gen.go +++ b/astro-client-core/api.gen.go @@ -232,6 +232,11 @@ const ( DeployTypeIMAGE DeployType = "IMAGE" ) +// Defines values for DeployGitProvider. +const ( + GITHUB DeployGitProvider = "GITHUB" +) + // Defines values for DeploymentClusterCloudProvider. const ( DeploymentClusterCloudProviderAWS DeploymentClusterCloudProvider = "AWS" @@ -286,11 +291,14 @@ const ( const ( EntitlementRequiredPlanAZUREMANAGEDPREVIEW EntitlementRequiredPlan = "AZURE_MANAGED_PREVIEW" EntitlementRequiredPlanBASIC EntitlementRequiredPlan = "BASIC" + EntitlementRequiredPlanBUSINESS EntitlementRequiredPlan = "BUSINESS" EntitlementRequiredPlanBUSINESSCRITICAL EntitlementRequiredPlan = "BUSINESS_CRITICAL" + EntitlementRequiredPlanENTERPRISE EntitlementRequiredPlan = "ENTERPRISE" EntitlementRequiredPlanINTERNAL EntitlementRequiredPlan = "INTERNAL" EntitlementRequiredPlanPOV EntitlementRequiredPlan = "POV" EntitlementRequiredPlanPREMIUM EntitlementRequiredPlan = "PREMIUM" EntitlementRequiredPlanSTANDARD EntitlementRequiredPlan = "STANDARD" + EntitlementRequiredPlanTEAM EntitlementRequiredPlan = "TEAM" EntitlementRequiredPlanTRIAL EntitlementRequiredPlan = "TRIAL" ) @@ -311,6 +319,12 @@ const ( EnvironmentObjectLinkScopeDEPLOYMENT EnvironmentObjectLinkScope = "DEPLOYMENT" ) +// Defines values for GitHubAccountAccountType. +const ( + ORGANIZATION GitHubAccountAccountType = "ORGANIZATION" + PERSONAL GitHubAccountAccountType = "PERSONAL" +) + // Defines values for ManagedDomainStatus. const ( PENDING ManagedDomainStatus = "PENDING" @@ -319,11 +333,13 @@ const ( // Defines values for MutateWorkerQueueRequestAstroMachine. const ( - MutateWorkerQueueRequestAstroMachineA10 MutateWorkerQueueRequestAstroMachine = "A10" - MutateWorkerQueueRequestAstroMachineA20 MutateWorkerQueueRequestAstroMachine = "A20" - MutateWorkerQueueRequestAstroMachineA40 MutateWorkerQueueRequestAstroMachine = "A40" - MutateWorkerQueueRequestAstroMachineA5 MutateWorkerQueueRequestAstroMachine = "A5" - MutateWorkerQueueRequestAstroMachineA60 MutateWorkerQueueRequestAstroMachine = "A60" + MutateWorkerQueueRequestAstroMachineA10 MutateWorkerQueueRequestAstroMachine = "A10" + MutateWorkerQueueRequestAstroMachineA120 MutateWorkerQueueRequestAstroMachine = "A120" + MutateWorkerQueueRequestAstroMachineA160 MutateWorkerQueueRequestAstroMachine = "A160" + MutateWorkerQueueRequestAstroMachineA20 MutateWorkerQueueRequestAstroMachine = "A20" + MutateWorkerQueueRequestAstroMachineA40 MutateWorkerQueueRequestAstroMachine = "A40" + MutateWorkerQueueRequestAstroMachineA5 MutateWorkerQueueRequestAstroMachine = "A5" + MutateWorkerQueueRequestAstroMachineA60 MutateWorkerQueueRequestAstroMachine = "A60" ) // Defines values for OrganizationPaymentMethod. @@ -353,11 +369,14 @@ const ( OrganizationSupportPlanAZUREMANAGEDPREVIEW OrganizationSupportPlan = "AZURE_MANAGED_PREVIEW" OrganizationSupportPlanBASIC OrganizationSupportPlan = "BASIC" OrganizationSupportPlanBASICPAYGO OrganizationSupportPlan = "BASIC_PAYGO" + OrganizationSupportPlanBUSINESS OrganizationSupportPlan = "BUSINESS" OrganizationSupportPlanBUSINESSCRITICAL OrganizationSupportPlan = "BUSINESS_CRITICAL" + OrganizationSupportPlanENTERPRISE OrganizationSupportPlan = "ENTERPRISE" OrganizationSupportPlanINTERNAL OrganizationSupportPlan = "INTERNAL" OrganizationSupportPlanPOV OrganizationSupportPlan = "POV" OrganizationSupportPlanPREMIUM OrganizationSupportPlan = "PREMIUM" OrganizationSupportPlanSTANDARD OrganizationSupportPlan = "STANDARD" + OrganizationSupportPlanTEAM OrganizationSupportPlan = "TEAM" OrganizationSupportPlanTRIAL OrganizationSupportPlan = "TRIAL" ) @@ -458,11 +477,13 @@ const ( // Defines values for WorkerMachineName. const ( - WorkerMachineNameA10 WorkerMachineName = "A10" - WorkerMachineNameA20 WorkerMachineName = "A20" - WorkerMachineNameA40 WorkerMachineName = "A40" - WorkerMachineNameA5 WorkerMachineName = "A5" - WorkerMachineNameA60 WorkerMachineName = "A60" + WorkerMachineNameA10 WorkerMachineName = "A10" + WorkerMachineNameA120 WorkerMachineName = "A120" + WorkerMachineNameA160 WorkerMachineName = "A160" + WorkerMachineNameA20 WorkerMachineName = "A20" + WorkerMachineNameA40 WorkerMachineName = "A40" + WorkerMachineNameA5 WorkerMachineName = "A5" + WorkerMachineNameA60 WorkerMachineName = "A60" ) // Defines values for GetSharedClusterParamsCloudProvider. @@ -696,6 +717,36 @@ const ( GetDeploymentLogsParamsSourcesWorker GetDeploymentLogsParamsSources = "worker" ) +// Defines values for ListDeploymentTeamsParamsSorts. +const ( + ListDeploymentTeamsParamsSortsCreatedAtAsc ListDeploymentTeamsParamsSorts = "createdAt:asc" + ListDeploymentTeamsParamsSortsCreatedAtDesc ListDeploymentTeamsParamsSorts = "createdAt:desc" + ListDeploymentTeamsParamsSortsDeploymentRolesAsc ListDeploymentTeamsParamsSorts = "deploymentRoles:asc" + ListDeploymentTeamsParamsSortsDeploymentRolesDesc ListDeploymentTeamsParamsSorts = "deploymentRoles:desc" + ListDeploymentTeamsParamsSortsDescriptionAsc ListDeploymentTeamsParamsSorts = "description:asc" + ListDeploymentTeamsParamsSortsDescriptionDesc ListDeploymentTeamsParamsSorts = "description:desc" + ListDeploymentTeamsParamsSortsNameAsc ListDeploymentTeamsParamsSorts = "name:asc" + ListDeploymentTeamsParamsSortsNameDesc ListDeploymentTeamsParamsSorts = "name:desc" + ListDeploymentTeamsParamsSortsUpdatedAtAsc ListDeploymentTeamsParamsSorts = "updatedAt:asc" + ListDeploymentTeamsParamsSortsUpdatedAtDesc ListDeploymentTeamsParamsSorts = "updatedAt:desc" +) + +// Defines values for ListDeploymentUsersParamsSorts. +const ( + ListDeploymentUsersParamsSortsCreatedAtAsc ListDeploymentUsersParamsSorts = "createdAt:asc" + ListDeploymentUsersParamsSortsCreatedAtDesc ListDeploymentUsersParamsSorts = "createdAt:desc" + ListDeploymentUsersParamsSortsDeploymentRoleAsc ListDeploymentUsersParamsSorts = "deploymentRole:asc" + ListDeploymentUsersParamsSortsDeploymentRoleDesc ListDeploymentUsersParamsSorts = "deploymentRole:desc" + ListDeploymentUsersParamsSortsFullNameAsc ListDeploymentUsersParamsSorts = "fullName:asc" + ListDeploymentUsersParamsSortsFullNameDesc ListDeploymentUsersParamsSorts = "fullName:desc" + ListDeploymentUsersParamsSortsStatusAsc ListDeploymentUsersParamsSorts = "status:asc" + ListDeploymentUsersParamsSortsStatusDesc ListDeploymentUsersParamsSorts = "status:desc" + ListDeploymentUsersParamsSortsUpdatedAtAsc ListDeploymentUsersParamsSorts = "updatedAt:asc" + ListDeploymentUsersParamsSortsUpdatedAtDesc ListDeploymentUsersParamsSorts = "updatedAt:desc" + ListDeploymentUsersParamsSortsUsernameAsc ListDeploymentUsersParamsSorts = "username:asc" + ListDeploymentUsersParamsSortsUsernameDesc ListDeploymentUsersParamsSorts = "username:desc" +) + // Defines values for ListEnvironmentObjectsParamsSorts. const ( ListEnvironmentObjectsParamsSortsCreatedAtAsc ListEnvironmentObjectsParamsSorts = "createdAt:asc" @@ -720,8 +771,6 @@ const ( ListOrganizationTeamsParamsSortsCreatedAtDesc ListOrganizationTeamsParamsSorts = "createdAt:desc" ListOrganizationTeamsParamsSortsDescriptionAsc ListOrganizationTeamsParamsSorts = "description:asc" ListOrganizationTeamsParamsSortsDescriptionDesc ListOrganizationTeamsParamsSorts = "description:desc" - ListOrganizationTeamsParamsSortsIdAsc ListOrganizationTeamsParamsSorts = "id:asc" - ListOrganizationTeamsParamsSortsIdDesc ListOrganizationTeamsParamsSorts = "id:desc" ListOrganizationTeamsParamsSortsMembersCountAsc ListOrganizationTeamsParamsSorts = "membersCount:asc" ListOrganizationTeamsParamsSortsMembersCountDesc ListOrganizationTeamsParamsSorts = "membersCount:desc" ListOrganizationTeamsParamsSortsNameAsc ListOrganizationTeamsParamsSorts = "name:asc" @@ -794,8 +843,6 @@ const ( ListWorkspaceTeamsParamsSortsCreatedAtDesc ListWorkspaceTeamsParamsSorts = "createdAt:desc" ListWorkspaceTeamsParamsSortsDescriptionAsc ListWorkspaceTeamsParamsSorts = "description:asc" ListWorkspaceTeamsParamsSortsDescriptionDesc ListWorkspaceTeamsParamsSorts = "description:desc" - ListWorkspaceTeamsParamsSortsIdAsc ListWorkspaceTeamsParamsSorts = "id:asc" - ListWorkspaceTeamsParamsSortsIdDesc ListWorkspaceTeamsParamsSorts = "id:desc" ListWorkspaceTeamsParamsSortsNameAsc ListWorkspaceTeamsParamsSorts = "name:asc" ListWorkspaceTeamsParamsSortsNameDesc ListWorkspaceTeamsParamsSorts = "name:desc" ListWorkspaceTeamsParamsSortsUpdatedAtAsc ListWorkspaceTeamsParamsSorts = "updatedAt:asc" @@ -810,8 +857,6 @@ const ( CreatedAtDesc ListWorkspaceUsersParamsSorts = "createdAt:desc" FullNameAsc ListWorkspaceUsersParamsSorts = "fullName:asc" FullNameDesc ListWorkspaceUsersParamsSorts = "fullName:desc" - IdAsc ListWorkspaceUsersParamsSorts = "id:asc" - IdDesc ListWorkspaceUsersParamsSorts = "id:desc" StatusAsc ListWorkspaceUsersParamsSorts = "status:asc" StatusDesc ListWorkspaceUsersParamsSorts = "status:desc" UpdatedAtAsc ListWorkspaceUsersParamsSorts = "updatedAt:asc" @@ -854,6 +899,12 @@ type ApiToken struct { // ApiTokenType defines model for ApiToken.Type. type ApiTokenType string +// ApiTokenDeploymentRoleRequest defines model for ApiTokenDeploymentRoleRequest. +type ApiTokenDeploymentRoleRequest struct { + EntityId string `json:"entityId"` + Role string `json:"role"` +} + // ApiTokenRole defines model for ApiTokenRole. type ApiTokenRole struct { EntityId string `json:"entityId"` @@ -1003,6 +1054,7 @@ type ClusterOptions struct { // ClusterRoute defines model for ClusterRoute. type ClusterRoute struct { + ConnectionId *string `json:"connectionId,omitempty"` CreatedAt time.Time `json:"createdAt"` CreatedById string `json:"createdById"` Description *string `json:"description,omitempty"` @@ -1104,11 +1156,12 @@ type CreateAzureClusterRequestType string // CreateClusterRouteRequest defines model for CreateClusterRouteRequest. type CreateClusterRouteRequest struct { + ConnectionId *string `json:"connectionId,omitempty"` Description *string `json:"description,omitempty"` DestinationCidr string `json:"destinationCidr"` Name string `json:"name"` Source CreateClusterRouteRequestSource `json:"source"` - Target string `json:"target"` + Target *string `json:"target,omitempty"` TargetType CreateClusterRouteRequestTargetType `json:"targetType"` } @@ -1158,8 +1211,8 @@ type CreateDedicatedDeploymentRequest struct { ResourceQuotaCpu string `json:"resourceQuotaCpu"` // ResourceQuotaMemory Must be valid kubernetes memory resource string, at least 2Gi in terms of Gibibytes (GiB) - ResourceQuotaMemory string `json:"resourceQuotaMemory"` - ScalingSpec *DeploymentScalingSpec `json:"scalingSpec,omitempty"` + ResourceQuotaMemory string `json:"resourceQuotaMemory"` + ScalingSpec *DeploymentScalingSpecRequest `json:"scalingSpec,omitempty"` // SchedulerSize Size of scheduler, one of: SMALL, MEDIUM, LARGE SchedulerSize CreateDedicatedDeploymentRequestSchedulerSize `json:"schedulerSize"` @@ -1409,8 +1462,8 @@ type CreateStandardDeploymentRequest struct { ResourceQuotaCpu string `json:"resourceQuotaCpu"` // ResourceQuotaMemory Must be valid kubernetes memory resource string, at least 2Gi in terms of Gibibytes (GiB) - ResourceQuotaMemory string `json:"resourceQuotaMemory"` - ScalingSpec *DeploymentScalingSpec `json:"scalingSpec,omitempty"` + ResourceQuotaMemory string `json:"resourceQuotaMemory"` + ScalingSpec *DeploymentScalingSpecRequest `json:"scalingSpec,omitempty"` // SchedulerSize Size of scheduler, one of: SMALL, MEDIUM, LARGE SchedulerSize CreateStandardDeploymentRequestSchedulerSize `json:"schedulerSize"` @@ -1466,6 +1519,11 @@ type CreateWorkspaceRequest struct { Name string `json:"name"` } +// CronExpressionSchema defines model for CronExpressionSchema. +type CronExpressionSchema struct { + Value string `json:"value"` +} + // DagFilters defines model for DagFilters. type DagFilters struct { Deployments map[string]string `json:"deployments"` @@ -1476,9 +1534,9 @@ type DagFilters struct { // DagSchedule defines model for DagSchedule. type DagSchedule struct { - CronExpression *InternalScheduleIntervalCronExpression `json:"CronExpression,omitempty"` - RelativeDelta *InternalScheduleIntervalRelativeDelta `json:"RelativeDelta,omitempty"` - TimeDelta *InternalScheduleIntervalTimeDelta `json:"TimeDelta,omitempty"` + CronExpression *CronExpressionSchema `json:"CronExpression,omitempty"` + RelativeDelta *RelativeDeltaSchema `json:"RelativeDelta,omitempty"` + TimeDelta *TimeDeltaSchema `json:"TimeDelta,omitempty"` } // DefaultPodSizeOption defines model for DefaultPodSizeOption. @@ -1503,6 +1561,7 @@ type Deploy struct { DagsUploadUrl *string `json:"dagsUploadUrl,omitempty"` DeploymentId string `json:"deploymentId"` Description *string `json:"description,omitempty"` + Git *DeployGit `json:"git,omitempty"` Id string `json:"id"` ImageRepository string `json:"imageRepository"` ImageTag string `json:"imageTag"` @@ -1521,6 +1580,23 @@ type DeployStatus string // DeployType defines model for Deploy.Type. type DeployType string +// DeployGit defines model for DeployGit. +type DeployGit struct { + Account string `json:"account"` + AuthorName string `json:"authorName"` + AuthorUrl string `json:"authorUrl"` + AuthorUsername string `json:"authorUsername"` + Branch string `json:"branch"` + CommitSha string `json:"commitSha"` + CommitUrl string `json:"commitUrl"` + Path string `json:"path"` + Provider DeployGitProvider `json:"provider"` + Repo string `json:"repo"` +} + +// DeployGitProvider defines model for DeployGit.Provider. +type DeployGitProvider string + // DeployRollbackRequest defines model for DeployRollbackRequest. type DeployRollbackRequest struct { DeployId string `json:"deployId"` @@ -1536,7 +1612,7 @@ type Deployment struct { ClusterRegion *string `json:"clusterRegion,omitempty"` ContactEmails []string `json:"contactEmails"` CreatedAt time.Time `json:"createdAt"` - CreatedBy BasicSubjectProfile `json:"createdBy"` + CreatedBy *BasicSubjectProfile `json:"createdBy,omitempty"` CurrentDagTarballVersion *string `json:"currentDagTarballVersion,omitempty"` CurrentEnvironmentSignatures *EnvironmentSignatures `json:"currentEnvironmentSignatures,omitempty"` CurrentImageVersion *string `json:"currentImageVersion,omitempty"` @@ -1581,7 +1657,7 @@ type Deployment struct { TaskPodNodePoolId *string `json:"taskPodNodePoolId,omitempty"` Type *DeploymentType `json:"type,omitempty"` UpdatedAt time.Time `json:"updatedAt"` - UpdatedBy BasicSubjectProfile `json:"updatedBy"` + UpdatedBy *BasicSubjectProfile `json:"updatedBy,omitempty"` // WebServerAirflowApiUrl The Deployment's webserver's base url to directly access the Airflow api. WebServerAirflowApiUrl string `json:"webServerAirflowApiUrl"` @@ -1658,6 +1734,14 @@ type DeploymentHibernationSpec struct { Schedules *[]DeploymentHibernationSchedule `json:"schedules,omitempty"` } +// DeploymentHibernationSpecRequest defines model for DeploymentHibernationSpecRequest. +type DeploymentHibernationSpecRequest struct { + Override *DeploymentHibernationOverride `json:"override,omitempty"` + + // Schedules The list of schedules for the hibernation spec + Schedules *[]DeploymentHibernationSchedule `json:"schedules,omitempty"` +} + // DeploymentHibernationStatus defines model for DeploymentHibernationStatus. type DeploymentHibernationStatus struct { // IsHibernating If the deployment is currently in hibernating state or not @@ -1720,6 +1804,11 @@ type DeploymentScalingSpec struct { HibernationSpec *DeploymentHibernationSpec `json:"hibernationSpec,omitempty"` } +// DeploymentScalingSpecRequest defines model for DeploymentScalingSpecRequest. +type DeploymentScalingSpecRequest struct { + HibernationSpec *DeploymentHibernationSpecRequest `json:"hibernationSpec,omitempty"` +} + // DeploymentScalingStatus defines model for DeploymentScalingStatus. type DeploymentScalingStatus struct { HibernationStatus *DeploymentHibernationStatus `json:"hibernationStatus,omitempty"` @@ -1848,6 +1937,18 @@ type FeatureFlag struct { // GenericJSON defines model for GenericJSON. type GenericJSON map[string]interface{} +// GitHubAccount defines model for GitHubAccount. +type GitHubAccount struct { + AccountName string `json:"accountName"` + AccountType GitHubAccountAccountType `json:"accountType"` + AvatarUrl *string `json:"avatarUrl,omitempty"` + Company *string `json:"company,omitempty"` + DisplayName *string `json:"displayName,omitempty"` +} + +// GitHubAccountAccountType defines model for GitHubAccount.AccountType. +type GitHubAccountAccountType string + // Invite defines model for Invite. type Invite struct { ExpiresAt string `json:"expiresAt"` @@ -2054,6 +2155,31 @@ type Range struct { Floor float32 `json:"floor"` } +// RelativeDeltaSchema defines model for RelativeDeltaSchema. +type RelativeDeltaSchema struct { + Day *int32 `json:"day,omitempty"` + Days *int32 `json:"days,omitempty"` + Dt1 *string `json:"dt1,omitempty"` + Dt2 *string `json:"dt2,omitempty"` + Hour *int32 `json:"hour,omitempty"` + Hours *int32 `json:"hours,omitempty"` + Leapdays *int32 `json:"leapdays,omitempty"` + Microsecond *int32 `json:"microsecond,omitempty"` + Microseconds *int32 `json:"microseconds,omitempty"` + Minute *int32 `json:"minute,omitempty"` + Minutes *int32 `json:"minutes,omitempty"` + Month *int32 `json:"month,omitempty"` + Months *int32 `json:"months,omitempty"` + Nlyearday *int32 `json:"nlyearday,omitempty"` + Second *int32 `json:"second,omitempty"` + Seconds *int32 `json:"seconds,omitempty"` + Weekday *Weekday `json:"weekday,omitempty"` + Weeks *int32 `json:"weeks,omitempty"` + Year *int32 `json:"year,omitempty"` + Yearday *int32 `json:"yearday,omitempty"` + Years *int32 `json:"years,omitempty"` +} + // ResourceOption defines model for ResourceOption. type ResourceOption struct { Cpu ResourceRange `json:"cpu"` @@ -2101,21 +2227,22 @@ type Scope struct { // Self defines model for Self. type Self struct { - AvatarUrl string `json:"avatarUrl"` - ColorModePreference *string `json:"colorModePreference,omitempty"` - CreatedAt time.Time `json:"createdAt"` - FeatureFlags *[]FeatureFlag `json:"featureFlags,omitempty"` - FullName string `json:"fullName"` - Id string `json:"id"` - IntercomUserHash *string `json:"intercomUserHash,omitempty"` - Invites *[]Invite `json:"invites,omitempty"` - OrganizationId *string `json:"organizationId,omitempty"` - Roles *[]UserRole `json:"roles,omitempty"` - SignupType *SelfSignupType `json:"signupType,omitempty"` - Status string `json:"status"` - SystemRole *string `json:"systemRole,omitempty"` - UpdatedAt time.Time `json:"updatedAt"` - Username string `json:"username"` + AvatarUrl string `json:"avatarUrl"` + ColorModePreference *string `json:"colorModePreference,omitempty"` + CreatedAt time.Time `json:"createdAt"` + FeatureFlags *[]FeatureFlag `json:"featureFlags,omitempty"` + FullName string `json:"fullName"` + GitHubAccounts *[]GitHubAccount `json:"gitHubAccounts,omitempty"` + Id string `json:"id"` + IntercomUserHash *string `json:"intercomUserHash,omitempty"` + Invites *[]Invite `json:"invites,omitempty"` + OrganizationId *string `json:"organizationId,omitempty"` + Roles *[]UserRole `json:"roles,omitempty"` + SignupType *SelfSignupType `json:"signupType,omitempty"` + Status string `json:"status"` + SystemRole *string `json:"systemRole,omitempty"` + UpdatedAt time.Time `json:"updatedAt"` + Username string `json:"username"` } // SelfSignupType defines model for Self.SignupType. @@ -2155,21 +2282,28 @@ type Subject struct { // Team defines model for Team. type Team struct { - CreatedAt time.Time `json:"createdAt"` - CreatedBy *BasicSubjectProfile `json:"createdBy,omitempty"` - Description *string `json:"description,omitempty"` - Id string `json:"id"` - IsIdpManaged bool `json:"isIdpManaged"` - Members *[]TeamMember `json:"members,omitempty"` - MembersCount *int `json:"membersCount,omitempty"` - Name string `json:"name"` - OrganizationId string `json:"organizationId"` - OrganizationName *string `json:"organizationName,omitempty"` - OrganizationRole string `json:"organizationRole"` - Roles *[]TeamRole `json:"roles,omitempty"` - RolesCount *int `json:"rolesCount,omitempty"` - UpdatedAt time.Time `json:"updatedAt"` - UpdatedBy *BasicSubjectProfile `json:"updatedBy,omitempty"` + CreatedAt time.Time `json:"createdAt"` + CreatedBy *BasicSubjectProfile `json:"createdBy,omitempty"` + DeploymentRoles *[]TeamDeploymentRole `json:"deploymentRoles,omitempty"` + Description *string `json:"description,omitempty"` + Id string `json:"id"` + IsIdpManaged bool `json:"isIdpManaged"` + Members *[]TeamMember `json:"members,omitempty"` + MembersCount *int `json:"membersCount,omitempty"` + Name string `json:"name"` + OrganizationId string `json:"organizationId"` + OrganizationName *string `json:"organizationName,omitempty"` + OrganizationRole string `json:"organizationRole"` + Roles *[]TeamRole `json:"roles,omitempty"` + UpdatedAt time.Time `json:"updatedAt"` + UpdatedBy *BasicSubjectProfile `json:"updatedBy,omitempty"` + WorkspaceRoles *[]TeamWorkspaceRole `json:"workspaceRoles,omitempty"` +} + +// TeamDeploymentRole defines model for TeamDeploymentRole. +type TeamDeploymentRole struct { + DeploymentId string `json:"deploymentId"` + Role string `json:"role"` } // TeamMember defines model for TeamMember. @@ -2188,6 +2322,12 @@ type TeamRole struct { Role string `json:"role"` } +// TeamWorkspaceRole defines model for TeamWorkspaceRole. +type TeamWorkspaceRole struct { + Role string `json:"role"` + WorkspaceId string `json:"workspaceId"` +} + // TeamsPaginated defines model for TeamsPaginated. type TeamsPaginated struct { Limit int `json:"limit"` @@ -2202,10 +2342,16 @@ type TemplateVersion struct { Version string `json:"version"` } +// TimeDeltaSchema defines model for TimeDeltaSchema. +type TimeDeltaSchema struct { + Days int32 `json:"days"` + Microseconds int32 `json:"microseconds"` + Seconds int32 `json:"seconds"` +} + // TransferDeploymentRequest defines model for TransferDeploymentRequest. type TransferDeploymentRequest struct { - CurrentWorkspaceId string `json:"currentWorkspaceId"` - TargetWorkspaceId string `json:"targetWorkspaceId"` + TargetWorkspaceId string `json:"targetWorkspaceId"` } // UpdateAwsClusterRequest defines model for UpdateAwsClusterRequest. @@ -2350,8 +2496,8 @@ type UpdateHostedDeploymentRequest struct { ResourceQuotaCpu string `json:"resourceQuotaCpu"` // ResourceQuotaMemory Must be valid kubernetes memory resource string, at least 2Gi in terms of Gibibytes (GiB) - ResourceQuotaMemory string `json:"resourceQuotaMemory"` - ScalingSpec *DeploymentScalingSpec `json:"scalingSpec,omitempty"` + ResourceQuotaMemory string `json:"resourceQuotaMemory"` + ScalingSpec *DeploymentScalingSpecRequest `json:"scalingSpec,omitempty"` // SchedulerSize Size of scheduler, one of: SMALL, MEDIUM, LARGE SchedulerSize UpdateHostedDeploymentRequestSchedulerSize `json:"schedulerSize"` @@ -2429,8 +2575,9 @@ type UpdateOrganizationApiTokenRequest struct { // UpdateOrganizationApiTokenRolesRequest defines model for UpdateOrganizationApiTokenRolesRequest. type UpdateOrganizationApiTokenRolesRequest struct { - Organization string `json:"organization"` - Workspace *[]ApiTokenWorkspaceRoleRequest `json:"workspace,omitempty"` + Deployment *[]ApiTokenDeploymentRoleRequest `json:"deployment,omitempty"` + Organization string `json:"organization"` + Workspace *[]ApiTokenWorkspaceRoleRequest `json:"workspace,omitempty"` } // UpdateOrganizationRequest defines model for UpdateOrganizationRequest. @@ -2449,9 +2596,15 @@ type UpdateTeamRequest struct { // UpdateWorkspaceApiTokenRequest defines model for UpdateWorkspaceApiTokenRequest. type UpdateWorkspaceApiTokenRequest struct { - Description string `json:"description"` - Name string `json:"name"` - Role string `json:"role"` + Description string `json:"description"` + Name string `json:"name"` + Roles *UpdateWorkspaceApiTokenRolesRequest `json:"roles,omitempty"` +} + +// UpdateWorkspaceApiTokenRolesRequest defines model for UpdateWorkspaceApiTokenRolesRequest. +type UpdateWorkspaceApiTokenRolesRequest struct { + Deployment *[]ApiTokenDeploymentRoleRequest `json:"deployment,omitempty"` + Workspace *string `json:"workspace,omitempty"` } // UpdateWorkspaceRequest defines model for UpdateWorkspaceRequest. @@ -2466,9 +2619,16 @@ type User struct { AvatarUrl string `json:"avatarUrl"` ColorModePreference *string `json:"colorModePreference,omitempty"` CreatedAt time.Time `json:"createdAt"` - FullName string `json:"fullName"` - Id string `json:"id"` - Invites *[]Invite `json:"invites,omitempty"` + + // DeploymentCount Only shown if admin listing users + DeploymentCount *int `json:"deploymentCount,omitempty"` + + // DeploymentRole Only shown if listing deployment users + DeploymentRole *string `json:"deploymentRole,omitempty"` + FullName string `json:"fullName"` + GitHubUsername *string `json:"gitHubUsername,omitempty"` + Id string `json:"id"` + Invites *[]Invite `json:"invites,omitempty"` // LastLogin Only shown if admin listing users LastLogin *string `json:"lastLogin,omitempty"` @@ -2526,6 +2686,20 @@ type UsersPaginated struct { Users []User `json:"users"` } +// Weekday defines model for Weekday. +type Weekday struct { + union json.RawMessage +} + +// Weekday1 defines model for . +type Weekday1 = int32 + +// WeekdaySchema defines model for WeekdaySchema. +type WeekdaySchema struct { + N *int32 `json:"n,omitempty"` + Weekday int32 `json:"weekday"` +} + // WorkerMachine defines model for WorkerMachine. type WorkerMachine struct { Concurrency Range `json:"concurrency"` @@ -2592,7 +2766,7 @@ type WorkspaceDag struct { DeploymentId string `json:"deploymentId"` IsActive *bool `json:"isActive,omitempty"` IsPaused bool `json:"isPaused"` - NextRunAt *string `json:"nextRunAt,omitempty"` + NextRunAt *time.Time `json:"nextRunAt,omitempty"` Owners *[]string `json:"owners,omitempty"` Runs *[]WorkspaceDagRun `json:"runs,omitempty"` Schedule *DagSchedule `json:"schedule,omitempty"` @@ -2602,14 +2776,14 @@ type WorkspaceDag struct { // WorkspaceDagRun defines model for WorkspaceDagRun. type WorkspaceDagRun struct { - DataIntervalEnd *string `json:"dataIntervalEnd,omitempty"` - DataIntervalStart *string `json:"dataIntervalStart,omitempty"` - EndDate *string `json:"endDate,omitempty"` - LogicalDate *string `json:"logicalDate,omitempty"` - RunId *string `json:"runId,omitempty"` - RunType *string `json:"runType,omitempty"` - StartDate *string `json:"startDate,omitempty"` - State *string `json:"state,omitempty"` + DataIntervalEnd *time.Time `json:"dataIntervalEnd"` + DataIntervalStart *time.Time `json:"dataIntervalStart"` + EndDate *time.Time `json:"endDate"` + LogicalDate time.Time `json:"logicalDate"` + RunId string `json:"runId"` + RunType string `json:"runType"` + StartDate *time.Time `json:"startDate"` + State string `json:"state"` } // WorkspacesPaginated defines model for WorkspacesPaginated. @@ -2620,55 +2794,6 @@ type WorkspacesPaginated struct { Workspaces []Workspace `json:"workspaces"` } -// InternalRelativeDeltaSchemaWeekday defines model for internal_RelativeDeltaSchemaWeekday. -type InternalRelativeDeltaSchemaWeekday struct { - Int32 *int `json:"int32,omitempty"` - WeekdaySchema *InternalWeekdaySchema `json:"weekdaySchema,omitempty"` -} - -// InternalScheduleIntervalCronExpression defines model for internal_ScheduleIntervalCronExpression. -type InternalScheduleIntervalCronExpression struct { - Value *string `json:"value,omitempty"` -} - -// InternalScheduleIntervalRelativeDelta defines model for internal_ScheduleIntervalRelativeDelta. -type InternalScheduleIntervalRelativeDelta struct { - Day *int `json:"day,omitempty"` - Days *int `json:"days,omitempty"` - Dt1 *string `json:"dt1,omitempty"` - Dt2 *string `json:"dt2,omitempty"` - Hour *int `json:"hour,omitempty"` - Hours *int `json:"hours,omitempty"` - Leapdays *int `json:"leapdays,omitempty"` - Microsecond *int `json:"microsecond,omitempty"` - Microseconds *int `json:"microseconds,omitempty"` - Minute *int `json:"minute,omitempty"` - Minutes *int `json:"minutes,omitempty"` - Month *int `json:"month,omitempty"` - Months *int `json:"months,omitempty"` - Nlyearday *int `json:"nlyearday,omitempty"` - Second *int `json:"second,omitempty"` - Seconds *int `json:"seconds,omitempty"` - Weekday *InternalRelativeDeltaSchemaWeekday `json:"weekday,omitempty"` - Weeks *int `json:"weeks,omitempty"` - Year *int `json:"year,omitempty"` - Yearday *int `json:"yearday,omitempty"` - Years *int `json:"years,omitempty"` -} - -// InternalScheduleIntervalTimeDelta defines model for internal_ScheduleIntervalTimeDelta. -type InternalScheduleIntervalTimeDelta struct { - Days *int `json:"days,omitempty"` - Microseconds *int `json:"microseconds,omitempty"` - Seconds *int `json:"seconds,omitempty"` -} - -// InternalWeekdaySchema defines model for internal_WeekdaySchema. -type InternalWeekdaySchema struct { - N *int `json:"n,omitempty"` - Weekday *int `json:"weekday,omitempty"` -} - // GetSharedClusterParams defines parameters for GetSharedCluster. type GetSharedClusterParams struct { // Region region @@ -2906,6 +3031,48 @@ type GetDeploymentLogsParams struct { // GetDeploymentLogsParamsSources defines parameters for GetDeploymentLogs. type GetDeploymentLogsParamsSources string +// ListDeploymentTeamsParams defines parameters for ListDeploymentTeams. +type ListDeploymentTeamsParams struct { + // IncludeDeploymentRoles include details about the teams deployment roles + IncludeDeploymentRoles *bool `form:"includeDeploymentRoles,omitempty" json:"includeDeploymentRoles,omitempty"` + + // Offset offset for pagination + Offset *int `form:"offset,omitempty" json:"offset,omitempty"` + + // Limit limit for pagination + Limit *int `form:"limit,omitempty" json:"limit,omitempty"` + + // Sorts sorting criteria, each criterion should conform to format 'fieldName:asc' or 'fieldName:desc' + Sorts *[]ListDeploymentTeamsParamsSorts `form:"sorts,omitempty" json:"sorts,omitempty"` + + // Search string to search for when listing teams + Search *string `form:"search,omitempty" json:"search,omitempty"` +} + +// ListDeploymentTeamsParamsSorts defines parameters for ListDeploymentTeams. +type ListDeploymentTeamsParamsSorts string + +// ListDeploymentUsersParams defines parameters for ListDeploymentUsers. +type ListDeploymentUsersParams struct { + // IncludeDeploymentRoles include details about the teams deployment roles + IncludeDeploymentRoles *bool `form:"includeDeploymentRoles,omitempty" json:"includeDeploymentRoles,omitempty"` + + // Offset offset for pagination + Offset *int `form:"offset,omitempty" json:"offset,omitempty"` + + // Limit limit for pagination + Limit *int `form:"limit,omitempty" json:"limit,omitempty"` + + // Sorts sorting criteria, each criterion should conform to format 'fieldName:asc' or 'fieldName:desc' + Sorts *[]ListDeploymentUsersParamsSorts `form:"sorts,omitempty" json:"sorts,omitempty"` + + // Search string to search for when listing users + Search *string `form:"search,omitempty" json:"search,omitempty"` +} + +// ListDeploymentUsersParamsSorts defines parameters for ListDeploymentUsers. +type ListDeploymentUsersParamsSorts string + // ListEnvironmentObjectsParams defines parameters for ListEnvironmentObjects. type ListEnvironmentObjectsParams struct { // Offset offset for pagination @@ -2947,8 +3114,11 @@ type ListOrganizationTeamsParams struct { // IncludeMembers includes details about the teams members IncludeMembers *bool `form:"includeMembers,omitempty" json:"includeMembers,omitempty"` - // IncludeRoles include details about the teams roles - IncludeRoles *bool `form:"includeRoles,omitempty" json:"includeRoles,omitempty"` + // IncludeWorkspaceRoles include details about the teams workspace roles + IncludeWorkspaceRoles *bool `form:"includeWorkspaceRoles,omitempty" json:"includeWorkspaceRoles,omitempty"` + + // IncludeDeploymentRoles include details about the teams deployment roles + IncludeDeploymentRoles *bool `form:"includeDeploymentRoles,omitempty" json:"includeDeploymentRoles,omitempty"` // IncludeSubjectInfo include details about who created or updated the team entry IncludeSubjectInfo *bool `form:"includeSubjectInfo,omitempty" json:"includeSubjectInfo,omitempty"` @@ -2971,6 +3141,12 @@ type ListOrganizationTeamsParamsSorts string // ListOrgUsersParams defines parameters for ListOrgUsers. type ListOrgUsersParams struct { + // IncludeDeploymentRoles include details about the teams deployment roles + IncludeDeploymentRoles *bool `form:"includeDeploymentRoles,omitempty" json:"includeDeploymentRoles,omitempty"` + + // IncludeWorkspaceRoles include details about the teams workspace roles + IncludeWorkspaceRoles *bool `form:"includeWorkspaceRoles,omitempty" json:"includeWorkspaceRoles,omitempty"` + // Offset offset for pagination Offset *int `form:"offset,omitempty" json:"offset,omitempty"` @@ -3046,22 +3222,22 @@ type ListWorkspaceDagsParams struct { // NameLike filter by pattern for name of DAG (dagId), SQL syntax NameLike *string `form:"name__like,omitempty" json:"name__like,omitempty"` - // Owner filter by an owner of the dag + // Owner filter by an owner of the DAG Owner *string `form:"owner,omitempty" json:"owner,omitempty"` - // IsPaused filter by paused dags + // IsPaused filter by paused DAGs IsPaused *bool `form:"isPaused,omitempty" json:"isPaused,omitempty"` - // IsActive filter by active dags + // IsActive filter by active DAGs IsActive *bool `form:"isActive,omitempty" json:"isActive,omitempty"` - // LastRunStateIn filter by dag runs with any of these run states for its last run + // LastRunStateIn filter by DAG runs with any of these run states for its last run LastRunStateIn *[]string `form:"lastRunState__in,omitempty" json:"lastRunState__in,omitempty"` - // RunStateIn filter by dag runs with any of these run states + // RunStateIn filter by DAG runs with any of these run states RunStateIn *[]string `form:"runState__in,omitempty" json:"runState__in,omitempty"` - // RunAfter filter by dag run after specified datetime (RFC3339 format) + // RunAfter filter by DAG run after specified datetime RunAfter *time.Time `form:"runAfter,omitempty" json:"runAfter,omitempty"` // TagIn filter by any of these tags @@ -3111,6 +3287,9 @@ type ListWorkspaceUsersParamsSorts string type GetSelfUserParams struct { // CreateIfNotExist create self user if it does not already exist CreateIfNotExist *bool `form:"createIfNotExist,omitempty" json:"createIfNotExist,omitempty"` + + // IncludeGitHubAccounts determines if GitHub accounts affiliated with the user are included in the response + IncludeGitHubAccounts *bool `form:"includeGitHubAccounts,omitempty" json:"includeGitHubAccounts,omitempty"` } // CreateOrganizationJSONRequestBody defines body for CreateOrganization for application/json ContentType. @@ -3170,9 +3349,6 @@ type UpdateDeployJSONRequestBody = UpdateDeployRequest // MutateDeploymentTeamRoleJSONRequestBody defines body for MutateDeploymentTeamRole for application/json ContentType. type MutateDeploymentTeamRoleJSONRequestBody = MutateDeploymentTeamRoleRequest -// TransferDeploymentJSONRequestBody defines body for TransferDeployment for application/json ContentType. -type TransferDeploymentJSONRequestBody = TransferDeploymentRequest - // MutateDeploymentUserRoleJSONRequestBody defines body for MutateDeploymentUserRole for application/json ContentType. type MutateDeploymentUserRoleJSONRequestBody = MutateDeploymentUserRoleRequest @@ -3212,6 +3388,9 @@ type CreateWorkspaceApiTokenJSONRequestBody = CreateWorkspaceApiTokenRequest // UpdateWorkspaceApiTokenJSONRequestBody defines body for UpdateWorkspaceApiToken for application/json ContentType. type UpdateWorkspaceApiTokenJSONRequestBody = UpdateWorkspaceApiTokenRequest +// TransferDeploymentJSONRequestBody defines body for TransferDeployment for application/json ContentType. +type TransferDeploymentJSONRequestBody = TransferDeploymentRequest + // MutateWorkspaceTeamRoleJSONRequestBody defines body for MutateWorkspaceTeamRole for application/json ContentType. type MutateWorkspaceTeamRoleJSONRequestBody = MutateWorkspaceTeamRoleRequest @@ -3371,6 +3550,68 @@ func (t *UpdateDeploymentRequest) UnmarshalJSON(b []byte) error { return err } +// AsWeekdaySchema returns the union data inside the Weekday as a WeekdaySchema +func (t Weekday) AsWeekdaySchema() (WeekdaySchema, error) { + var body WeekdaySchema + err := json.Unmarshal(t.union, &body) + return body, err +} + +// FromWeekdaySchema overwrites any union data inside the Weekday as the provided WeekdaySchema +func (t *Weekday) FromWeekdaySchema(v WeekdaySchema) error { + b, err := json.Marshal(v) + t.union = b + return err +} + +// MergeWeekdaySchema performs a merge with any union data inside the Weekday, using the provided WeekdaySchema +func (t *Weekday) MergeWeekdaySchema(v WeekdaySchema) error { + b, err := json.Marshal(v) + if err != nil { + return err + } + + merged, err := runtime.JsonMerge(b, t.union) + t.union = merged + return err +} + +// AsWeekday1 returns the union data inside the Weekday as a Weekday1 +func (t Weekday) AsWeekday1() (Weekday1, error) { + var body Weekday1 + err := json.Unmarshal(t.union, &body) + return body, err +} + +// FromWeekday1 overwrites any union data inside the Weekday as the provided Weekday1 +func (t *Weekday) FromWeekday1(v Weekday1) error { + b, err := json.Marshal(v) + t.union = b + return err +} + +// MergeWeekday1 performs a merge with any union data inside the Weekday, using the provided Weekday1 +func (t *Weekday) MergeWeekday1(v Weekday1) error { + b, err := json.Marshal(v) + if err != nil { + return err + } + + merged, err := runtime.JsonMerge(b, t.union) + t.union = merged + return err +} + +func (t Weekday) MarshalJSON() ([]byte, error) { + b, err := t.union.MarshalJSON() + return b, err +} + +func (t *Weekday) UnmarshalJSON(b []byte) error { + err := t.union.UnmarshalJSON(b) + return err +} + // RequestEditorFn is the function signature for the RequestEditor callback function type RequestEditorFn func(ctx context.Context, req *http.Request) error @@ -3612,6 +3853,9 @@ type ClientInterface interface { // GetDeploymentLogs request GetDeploymentLogs(ctx context.Context, organizationId string, deploymentId string, params *GetDeploymentLogsParams, reqEditors ...RequestEditorFn) (*http.Response, error) + // ListDeploymentTeams request + ListDeploymentTeams(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentTeamsParams, reqEditors ...RequestEditorFn) (*http.Response, error) + // DeleteDeploymentTeam request DeleteDeploymentTeam(ctx context.Context, organizationId string, deploymentId string, teamId string, reqEditors ...RequestEditorFn) (*http.Response, error) @@ -3620,10 +3864,8 @@ type ClientInterface interface { MutateDeploymentTeamRole(ctx context.Context, organizationId string, deploymentId string, teamId string, body MutateDeploymentTeamRoleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error) - // TransferDeployment request with any body - TransferDeploymentWithBody(ctx context.Context, organizationId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) - - TransferDeployment(ctx context.Context, organizationId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error) + // ListDeploymentUsers request + ListDeploymentUsers(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentUsersParams, reqEditors ...RequestEditorFn) (*http.Response, error) // DeleteDeploymentUser request DeleteDeploymentUser(ctx context.Context, organizationId string, deploymentId string, userId string, reqEditors ...RequestEditorFn) (*http.Response, error) @@ -3753,6 +3995,11 @@ type ClientInterface interface { // ListWorkspaceDags request ListWorkspaceDags(ctx context.Context, organizationId string, workspaceId string, params *ListWorkspaceDagsParams, reqEditors ...RequestEditorFn) (*http.Response, error) + // TransferDeployment request with any body + TransferDeploymentWithBody(ctx context.Context, organizationId string, workspaceId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) + + TransferDeployment(ctx context.Context, organizationId string, workspaceId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error) + // ListWorkspaceTeams request ListWorkspaceTeams(ctx context.Context, organizationId string, workspaceId string, params *ListWorkspaceTeamsParams, reqEditors ...RequestEditorFn) (*http.Response, error) @@ -4528,8 +4775,8 @@ func (c *Client) GetDeploymentLogs(ctx context.Context, organizationId string, d return c.Client.Do(req) } -func (c *Client) DeleteDeploymentTeam(ctx context.Context, organizationId string, deploymentId string, teamId string, reqEditors ...RequestEditorFn) (*http.Response, error) { - req, err := NewDeleteDeploymentTeamRequest(c.Server, organizationId, deploymentId, teamId) +func (c *Client) ListDeploymentTeams(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentTeamsParams, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewListDeploymentTeamsRequest(c.Server, organizationId, deploymentId, params) if err != nil { return nil, err } @@ -4540,8 +4787,8 @@ func (c *Client) DeleteDeploymentTeam(ctx context.Context, organizationId string return c.Client.Do(req) } -func (c *Client) MutateDeploymentTeamRoleWithBody(ctx context.Context, organizationId string, deploymentId string, teamId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) { - req, err := NewMutateDeploymentTeamRoleRequestWithBody(c.Server, organizationId, deploymentId, teamId, contentType, body) +func (c *Client) DeleteDeploymentTeam(ctx context.Context, organizationId string, deploymentId string, teamId string, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewDeleteDeploymentTeamRequest(c.Server, organizationId, deploymentId, teamId) if err != nil { return nil, err } @@ -4552,8 +4799,8 @@ func (c *Client) MutateDeploymentTeamRoleWithBody(ctx context.Context, organizat return c.Client.Do(req) } -func (c *Client) MutateDeploymentTeamRole(ctx context.Context, organizationId string, deploymentId string, teamId string, body MutateDeploymentTeamRoleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error) { - req, err := NewMutateDeploymentTeamRoleRequest(c.Server, organizationId, deploymentId, teamId, body) +func (c *Client) MutateDeploymentTeamRoleWithBody(ctx context.Context, organizationId string, deploymentId string, teamId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewMutateDeploymentTeamRoleRequestWithBody(c.Server, organizationId, deploymentId, teamId, contentType, body) if err != nil { return nil, err } @@ -4564,8 +4811,8 @@ func (c *Client) MutateDeploymentTeamRole(ctx context.Context, organizationId st return c.Client.Do(req) } -func (c *Client) TransferDeploymentWithBody(ctx context.Context, organizationId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) { - req, err := NewTransferDeploymentRequestWithBody(c.Server, organizationId, deploymentId, contentType, body) +func (c *Client) MutateDeploymentTeamRole(ctx context.Context, organizationId string, deploymentId string, teamId string, body MutateDeploymentTeamRoleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewMutateDeploymentTeamRoleRequest(c.Server, organizationId, deploymentId, teamId, body) if err != nil { return nil, err } @@ -4576,8 +4823,8 @@ func (c *Client) TransferDeploymentWithBody(ctx context.Context, organizationId return c.Client.Do(req) } -func (c *Client) TransferDeployment(ctx context.Context, organizationId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error) { - req, err := NewTransferDeploymentRequest(c.Server, organizationId, deploymentId, body) +func (c *Client) ListDeploymentUsers(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentUsersParams, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewListDeploymentUsersRequest(c.Server, organizationId, deploymentId, params) if err != nil { return nil, err } @@ -5152,6 +5399,30 @@ func (c *Client) ListWorkspaceDags(ctx context.Context, organizationId string, w return c.Client.Do(req) } +func (c *Client) TransferDeploymentWithBody(ctx context.Context, organizationId string, workspaceId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewTransferDeploymentRequestWithBody(c.Server, organizationId, workspaceId, deploymentId, contentType, body) + if err != nil { + return nil, err + } + req = req.WithContext(ctx) + if err := c.applyEditors(ctx, req, reqEditors); err != nil { + return nil, err + } + return c.Client.Do(req) +} + +func (c *Client) TransferDeployment(ctx context.Context, organizationId string, workspaceId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error) { + req, err := NewTransferDeploymentRequest(c.Server, organizationId, workspaceId, deploymentId, body) + if err != nil { + return nil, err + } + req = req.WithContext(ctx) + if err := c.applyEditors(ctx, req, reqEditors); err != nil { + return nil, err + } + return c.Client.Do(req) +} + func (c *Client) ListWorkspaceTeams(ctx context.Context, organizationId string, workspaceId string, params *ListWorkspaceTeamsParams, reqEditors ...RequestEditorFn) (*http.Response, error) { req, err := NewListWorkspaceTeamsRequest(c.Server, organizationId, workspaceId, params) if err != nil { @@ -8005,6 +8276,131 @@ func NewGetDeploymentLogsRequest(server string, organizationId string, deploymen return req, nil } +// NewListDeploymentTeamsRequest generates requests for ListDeploymentTeams +func NewListDeploymentTeamsRequest(server string, organizationId string, deploymentId string, params *ListDeploymentTeamsParams) (*http.Request, error) { + var err error + + var pathParam0 string + + pathParam0, err = runtime.StyleParamWithLocation("simple", false, "organizationId", runtime.ParamLocationPath, organizationId) + if err != nil { + return nil, err + } + + var pathParam1 string + + pathParam1, err = runtime.StyleParamWithLocation("simple", false, "deploymentId", runtime.ParamLocationPath, deploymentId) + if err != nil { + return nil, err + } + + serverURL, err := url.Parse(server) + if err != nil { + return nil, err + } + + operationPath := fmt.Sprintf("/organizations/%s/deployments/%s/teams", pathParam0, pathParam1) + if operationPath[0] == '/' { + operationPath = "." + operationPath + } + + queryURL, err := serverURL.Parse(operationPath) + if err != nil { + return nil, err + } + + queryValues := queryURL.Query() + + if params.IncludeDeploymentRoles != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeDeploymentRoles", runtime.ParamLocationQuery, *params.IncludeDeploymentRoles); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Offset != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "offset", runtime.ParamLocationQuery, *params.Offset); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Limit != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "limit", runtime.ParamLocationQuery, *params.Limit); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Sorts != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "sorts", runtime.ParamLocationQuery, *params.Sorts); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Search != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "search", runtime.ParamLocationQuery, *params.Search); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + queryURL.RawQuery = queryValues.Encode() + + req, err := http.NewRequest("GET", queryURL.String(), nil) + if err != nil { + return nil, err + } + + return req, nil +} + // NewDeleteDeploymentTeamRequest generates requests for DeleteDeploymentTeam func NewDeleteDeploymentTeamRequest(server string, organizationId string, deploymentId string, teamId string) (*http.Request, error) { var err error @@ -8114,19 +8510,8 @@ func NewMutateDeploymentTeamRoleRequestWithBody(server string, organizationId st return req, nil } -// NewTransferDeploymentRequest calls the generic TransferDeployment builder with application/json body -func NewTransferDeploymentRequest(server string, organizationId string, deploymentId string, body TransferDeploymentJSONRequestBody) (*http.Request, error) { - var bodyReader io.Reader - buf, err := json.Marshal(body) - if err != nil { - return nil, err - } - bodyReader = bytes.NewReader(buf) - return NewTransferDeploymentRequestWithBody(server, organizationId, deploymentId, "application/json", bodyReader) -} - -// NewTransferDeploymentRequestWithBody generates requests for TransferDeployment with any type of body -func NewTransferDeploymentRequestWithBody(server string, organizationId string, deploymentId string, contentType string, body io.Reader) (*http.Request, error) { +// NewListDeploymentUsersRequest generates requests for ListDeploymentUsers +func NewListDeploymentUsersRequest(server string, organizationId string, deploymentId string, params *ListDeploymentUsersParams) (*http.Request, error) { var err error var pathParam0 string @@ -8148,7 +8533,7 @@ func NewTransferDeploymentRequestWithBody(server string, organizationId string, return nil, err } - operationPath := fmt.Sprintf("/organizations/%s/deployments/%s/transfer", pathParam0, pathParam1) + operationPath := fmt.Sprintf("/organizations/%s/deployments/%s/users", pathParam0, pathParam1) if operationPath[0] == '/' { operationPath = "." + operationPath } @@ -8158,13 +8543,95 @@ func NewTransferDeploymentRequestWithBody(server string, organizationId string, return nil, err } - req, err := http.NewRequest("POST", queryURL.String(), body) + queryValues := queryURL.Query() + + if params.IncludeDeploymentRoles != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeDeploymentRoles", runtime.ParamLocationQuery, *params.IncludeDeploymentRoles); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Offset != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "offset", runtime.ParamLocationQuery, *params.Offset); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Limit != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "limit", runtime.ParamLocationQuery, *params.Limit); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Sorts != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "sorts", runtime.ParamLocationQuery, *params.Sorts); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.Search != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "search", runtime.ParamLocationQuery, *params.Search); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + queryURL.RawQuery = queryValues.Encode() + + req, err := http.NewRequest("GET", queryURL.String(), nil) if err != nil { return nil, err } - req.Header.Add("Content-Type", contentType) - return req, nil } @@ -8774,9 +9241,25 @@ func NewListOrganizationTeamsRequest(server string, organizationId string, param } - if params.IncludeRoles != nil { + if params.IncludeWorkspaceRoles != nil { - if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeRoles", runtime.ParamLocationQuery, *params.IncludeRoles); err != nil { + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeWorkspaceRoles", runtime.ParamLocationQuery, *params.IncludeWorkspaceRoles); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.IncludeDeploymentRoles != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeDeploymentRoles", runtime.ParamLocationQuery, *params.IncludeDeploymentRoles); err != nil { return nil, err } else if parsed, err := url.ParseQuery(queryFrag); err != nil { return nil, err @@ -9247,6 +9730,38 @@ func NewListOrgUsersRequest(server string, organizationId string, params *ListOr queryValues := queryURL.Query() + if params.IncludeDeploymentRoles != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeDeploymentRoles", runtime.ParamLocationQuery, *params.IncludeDeploymentRoles); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.IncludeWorkspaceRoles != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeWorkspaceRoles", runtime.ParamLocationQuery, *params.IncludeWorkspaceRoles); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + if params.Offset != nil { if queryFrag, err := runtime.StyleParamWithLocation("form", true, "offset", runtime.ParamLocationQuery, *params.Offset); err != nil { @@ -10220,7 +10735,7 @@ func NewListWorkspaceDagsRequest(server string, organizationId string, workspace if params.OrderBy != nil { - if queryFrag, err := runtime.StyleParamWithLocation("form", true, "orderBy", runtime.ParamLocationQuery, *params.OrderBy); err != nil { + if queryFrag, err := runtime.StyleParamWithLocation("form", false, "orderBy", runtime.ParamLocationQuery, *params.OrderBy); err != nil { return nil, err } else if parsed, err := url.ParseQuery(queryFrag); err != nil { return nil, err @@ -10348,7 +10863,7 @@ func NewListWorkspaceDagsRequest(server string, organizationId string, workspace if params.LastRunStateIn != nil { - if queryFrag, err := runtime.StyleParamWithLocation("form", true, "lastRunState__in", runtime.ParamLocationQuery, *params.LastRunStateIn); err != nil { + if queryFrag, err := runtime.StyleParamWithLocation("form", false, "lastRunState__in", runtime.ParamLocationQuery, *params.LastRunStateIn); err != nil { return nil, err } else if parsed, err := url.ParseQuery(queryFrag); err != nil { return nil, err @@ -10364,7 +10879,7 @@ func NewListWorkspaceDagsRequest(server string, organizationId string, workspace if params.RunStateIn != nil { - if queryFrag, err := runtime.StyleParamWithLocation("form", true, "runState__in", runtime.ParamLocationQuery, *params.RunStateIn); err != nil { + if queryFrag, err := runtime.StyleParamWithLocation("form", false, "runState__in", runtime.ParamLocationQuery, *params.RunStateIn); err != nil { return nil, err } else if parsed, err := url.ParseQuery(queryFrag); err != nil { return nil, err @@ -10394,45 +10909,106 @@ func NewListWorkspaceDagsRequest(server string, organizationId string, workspace } - if params.TagIn != nil { - - if queryFrag, err := runtime.StyleParamWithLocation("form", true, "tag__in", runtime.ParamLocationQuery, *params.TagIn); err != nil { - return nil, err - } else if parsed, err := url.ParseQuery(queryFrag); err != nil { - return nil, err - } else { - for k, v := range parsed { - for _, v2 := range v { - queryValues.Add(k, v2) - } - } - } + if params.TagIn != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", false, "tag__in", runtime.ParamLocationQuery, *params.TagIn); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + if params.DeploymentIdIn != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", false, "deploymentId__in", runtime.ParamLocationQuery, *params.DeploymentIdIn); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + + queryURL.RawQuery = queryValues.Encode() + + req, err := http.NewRequest("GET", queryURL.String(), nil) + if err != nil { + return nil, err + } + + return req, nil +} + +// NewTransferDeploymentRequest calls the generic TransferDeployment builder with application/json body +func NewTransferDeploymentRequest(server string, organizationId string, workspaceId string, deploymentId string, body TransferDeploymentJSONRequestBody) (*http.Request, error) { + var bodyReader io.Reader + buf, err := json.Marshal(body) + if err != nil { + return nil, err + } + bodyReader = bytes.NewReader(buf) + return NewTransferDeploymentRequestWithBody(server, organizationId, workspaceId, deploymentId, "application/json", bodyReader) +} + +// NewTransferDeploymentRequestWithBody generates requests for TransferDeployment with any type of body +func NewTransferDeploymentRequestWithBody(server string, organizationId string, workspaceId string, deploymentId string, contentType string, body io.Reader) (*http.Request, error) { + var err error + + var pathParam0 string + + pathParam0, err = runtime.StyleParamWithLocation("simple", false, "organizationId", runtime.ParamLocationPath, organizationId) + if err != nil { + return nil, err + } + + var pathParam1 string + pathParam1, err = runtime.StyleParamWithLocation("simple", false, "workspaceId", runtime.ParamLocationPath, workspaceId) + if err != nil { + return nil, err } - if params.DeploymentIdIn != nil { + var pathParam2 string - if queryFrag, err := runtime.StyleParamWithLocation("form", true, "deploymentId__in", runtime.ParamLocationQuery, *params.DeploymentIdIn); err != nil { - return nil, err - } else if parsed, err := url.ParseQuery(queryFrag); err != nil { - return nil, err - } else { - for k, v := range parsed { - for _, v2 := range v { - queryValues.Add(k, v2) - } - } - } + pathParam2, err = runtime.StyleParamWithLocation("simple", false, "deploymentId", runtime.ParamLocationPath, deploymentId) + if err != nil { + return nil, err + } + serverURL, err := url.Parse(server) + if err != nil { + return nil, err } - queryURL.RawQuery = queryValues.Encode() + operationPath := fmt.Sprintf("/organizations/%s/workspaces/%s/deployments/%s/transfer", pathParam0, pathParam1, pathParam2) + if operationPath[0] == '/' { + operationPath = "." + operationPath + } - req, err := http.NewRequest("GET", queryURL.String(), nil) + queryURL, err := serverURL.Parse(operationPath) + if err != nil { + return nil, err + } + + req, err := http.NewRequest("POST", queryURL.String(), body) if err != nil { return nil, err } + req.Header.Add("Content-Type", contentType) + return req, nil } @@ -10909,6 +11485,22 @@ func NewGetSelfUserRequest(server string, params *GetSelfUserParams) (*http.Requ } + if params.IncludeGitHubAccounts != nil { + + if queryFrag, err := runtime.StyleParamWithLocation("form", true, "includeGitHubAccounts", runtime.ParamLocationQuery, *params.IncludeGitHubAccounts); err != nil { + return nil, err + } else if parsed, err := url.ParseQuery(queryFrag); err != nil { + return nil, err + } else { + for k, v := range parsed { + for _, v2 := range v { + queryValues.Add(k, v2) + } + } + } + + } + queryURL.RawQuery = queryValues.Encode() req, err := http.NewRequest("GET", queryURL.String(), nil) @@ -11177,6 +11769,9 @@ type ClientWithResponsesInterface interface { // GetDeploymentLogs request GetDeploymentLogsWithResponse(ctx context.Context, organizationId string, deploymentId string, params *GetDeploymentLogsParams, reqEditors ...RequestEditorFn) (*GetDeploymentLogsResponse, error) + // ListDeploymentTeams request + ListDeploymentTeamsWithResponse(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentTeamsParams, reqEditors ...RequestEditorFn) (*ListDeploymentTeamsResponse, error) + // DeleteDeploymentTeam request DeleteDeploymentTeamWithResponse(ctx context.Context, organizationId string, deploymentId string, teamId string, reqEditors ...RequestEditorFn) (*DeleteDeploymentTeamResponse, error) @@ -11185,10 +11780,8 @@ type ClientWithResponsesInterface interface { MutateDeploymentTeamRoleWithResponse(ctx context.Context, organizationId string, deploymentId string, teamId string, body MutateDeploymentTeamRoleJSONRequestBody, reqEditors ...RequestEditorFn) (*MutateDeploymentTeamRoleResponse, error) - // TransferDeployment request with any body - TransferDeploymentWithBodyWithResponse(ctx context.Context, organizationId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) - - TransferDeploymentWithResponse(ctx context.Context, organizationId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) + // ListDeploymentUsers request + ListDeploymentUsersWithResponse(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentUsersParams, reqEditors ...RequestEditorFn) (*ListDeploymentUsersResponse, error) // DeleteDeploymentUser request DeleteDeploymentUserWithResponse(ctx context.Context, organizationId string, deploymentId string, userId string, reqEditors ...RequestEditorFn) (*DeleteDeploymentUserResponse, error) @@ -11318,6 +11911,11 @@ type ClientWithResponsesInterface interface { // ListWorkspaceDags request ListWorkspaceDagsWithResponse(ctx context.Context, organizationId string, workspaceId string, params *ListWorkspaceDagsParams, reqEditors ...RequestEditorFn) (*ListWorkspaceDagsResponse, error) + // TransferDeployment request with any body + TransferDeploymentWithBodyWithResponse(ctx context.Context, organizationId string, workspaceId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) + + TransferDeploymentWithResponse(ctx context.Context, organizationId string, workspaceId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) + // ListWorkspaceTeams request ListWorkspaceTeamsWithResponse(ctx context.Context, organizationId string, workspaceId string, params *ListWorkspaceTeamsParams, reqEditors ...RequestEditorFn) (*ListWorkspaceTeamsResponse, error) @@ -12526,6 +13124,33 @@ func (r GetDeploymentLogsResponse) StatusCode() int { return 0 } +type ListDeploymentTeamsResponse struct { + Body []byte + HTTPResponse *http.Response + JSON200 *TeamsPaginated + JSON400 *Error + JSON401 *Error + JSON403 *Error + JSON404 *Error + JSON500 *Error +} + +// Status returns HTTPResponse.Status +func (r ListDeploymentTeamsResponse) Status() string { + if r.HTTPResponse != nil { + return r.HTTPResponse.Status + } + return http.StatusText(0) +} + +// StatusCode returns HTTPResponse.StatusCode +func (r ListDeploymentTeamsResponse) StatusCode() int { + if r.HTTPResponse != nil { + return r.HTTPResponse.StatusCode + } + return 0 +} + type DeleteDeploymentTeamResponse struct { Body []byte HTTPResponse *http.Response @@ -12579,19 +13204,18 @@ func (r MutateDeploymentTeamRoleResponse) StatusCode() int { return 0 } -type TransferDeploymentResponse struct { +type ListDeploymentUsersResponse struct { Body []byte HTTPResponse *http.Response - JSON200 *Deployment + JSON200 *UsersPaginated JSON400 *Error JSON401 *Error JSON403 *Error - JSON404 *Error JSON500 *Error } // Status returns HTTPResponse.Status -func (r TransferDeploymentResponse) Status() string { +func (r ListDeploymentUsersResponse) Status() string { if r.HTTPResponse != nil { return r.HTTPResponse.Status } @@ -12599,7 +13223,7 @@ func (r TransferDeploymentResponse) Status() string { } // StatusCode returns HTTPResponse.StatusCode -func (r TransferDeploymentResponse) StatusCode() int { +func (r ListDeploymentUsersResponse) StatusCode() int { if r.HTTPResponse != nil { return r.HTTPResponse.StatusCode } @@ -13493,6 +14117,30 @@ type ListWorkspaceDagsResponse struct { Body []byte HTTPResponse *http.Response JSON200 *ListWorkspaceDags + JSON4XX *Error + JSON5XX *Error +} + +// Status returns HTTPResponse.Status +func (r ListWorkspaceDagsResponse) Status() string { + if r.HTTPResponse != nil { + return r.HTTPResponse.Status + } + return http.StatusText(0) +} + +// StatusCode returns HTTPResponse.StatusCode +func (r ListWorkspaceDagsResponse) StatusCode() int { + if r.HTTPResponse != nil { + return r.HTTPResponse.StatusCode + } + return 0 +} + +type TransferDeploymentResponse struct { + Body []byte + HTTPResponse *http.Response + JSON200 *Deployment JSON400 *Error JSON401 *Error JSON403 *Error @@ -13501,7 +14149,7 @@ type ListWorkspaceDagsResponse struct { } // Status returns HTTPResponse.Status -func (r ListWorkspaceDagsResponse) Status() string { +func (r TransferDeploymentResponse) Status() string { if r.HTTPResponse != nil { return r.HTTPResponse.Status } @@ -13509,7 +14157,7 @@ func (r ListWorkspaceDagsResponse) Status() string { } // StatusCode returns HTTPResponse.StatusCode -func (r ListWorkspaceDagsResponse) StatusCode() int { +func (r TransferDeploymentResponse) StatusCode() int { if r.HTTPResponse != nil { return r.HTTPResponse.StatusCode } @@ -14269,6 +14917,15 @@ func (c *ClientWithResponses) GetDeploymentLogsWithResponse(ctx context.Context, return ParseGetDeploymentLogsResponse(rsp) } +// ListDeploymentTeamsWithResponse request returning *ListDeploymentTeamsResponse +func (c *ClientWithResponses) ListDeploymentTeamsWithResponse(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentTeamsParams, reqEditors ...RequestEditorFn) (*ListDeploymentTeamsResponse, error) { + rsp, err := c.ListDeploymentTeams(ctx, organizationId, deploymentId, params, reqEditors...) + if err != nil { + return nil, err + } + return ParseListDeploymentTeamsResponse(rsp) +} + // DeleteDeploymentTeamWithResponse request returning *DeleteDeploymentTeamResponse func (c *ClientWithResponses) DeleteDeploymentTeamWithResponse(ctx context.Context, organizationId string, deploymentId string, teamId string, reqEditors ...RequestEditorFn) (*DeleteDeploymentTeamResponse, error) { rsp, err := c.DeleteDeploymentTeam(ctx, organizationId, deploymentId, teamId, reqEditors...) @@ -14295,21 +14952,13 @@ func (c *ClientWithResponses) MutateDeploymentTeamRoleWithResponse(ctx context.C return ParseMutateDeploymentTeamRoleResponse(rsp) } -// TransferDeploymentWithBodyWithResponse request with arbitrary body returning *TransferDeploymentResponse -func (c *ClientWithResponses) TransferDeploymentWithBodyWithResponse(ctx context.Context, organizationId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) { - rsp, err := c.TransferDeploymentWithBody(ctx, organizationId, deploymentId, contentType, body, reqEditors...) - if err != nil { - return nil, err - } - return ParseTransferDeploymentResponse(rsp) -} - -func (c *ClientWithResponses) TransferDeploymentWithResponse(ctx context.Context, organizationId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) { - rsp, err := c.TransferDeployment(ctx, organizationId, deploymentId, body, reqEditors...) +// ListDeploymentUsersWithResponse request returning *ListDeploymentUsersResponse +func (c *ClientWithResponses) ListDeploymentUsersWithResponse(ctx context.Context, organizationId string, deploymentId string, params *ListDeploymentUsersParams, reqEditors ...RequestEditorFn) (*ListDeploymentUsersResponse, error) { + rsp, err := c.ListDeploymentUsers(ctx, organizationId, deploymentId, params, reqEditors...) if err != nil { return nil, err } - return ParseTransferDeploymentResponse(rsp) + return ParseListDeploymentUsersResponse(rsp) } // DeleteDeploymentUserWithResponse request returning *DeleteDeploymentUserResponse @@ -14722,6 +15371,23 @@ func (c *ClientWithResponses) ListWorkspaceDagsWithResponse(ctx context.Context, return ParseListWorkspaceDagsResponse(rsp) } +// TransferDeploymentWithBodyWithResponse request with arbitrary body returning *TransferDeploymentResponse +func (c *ClientWithResponses) TransferDeploymentWithBodyWithResponse(ctx context.Context, organizationId string, workspaceId string, deploymentId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) { + rsp, err := c.TransferDeploymentWithBody(ctx, organizationId, workspaceId, deploymentId, contentType, body, reqEditors...) + if err != nil { + return nil, err + } + return ParseTransferDeploymentResponse(rsp) +} + +func (c *ClientWithResponses) TransferDeploymentWithResponse(ctx context.Context, organizationId string, workspaceId string, deploymentId string, body TransferDeploymentJSONRequestBody, reqEditors ...RequestEditorFn) (*TransferDeploymentResponse, error) { + rsp, err := c.TransferDeployment(ctx, organizationId, workspaceId, deploymentId, body, reqEditors...) + if err != nil { + return nil, err + } + return ParseTransferDeploymentResponse(rsp) +} + // ListWorkspaceTeamsWithResponse request returning *ListWorkspaceTeamsResponse func (c *ClientWithResponses) ListWorkspaceTeamsWithResponse(ctx context.Context, organizationId string, workspaceId string, params *ListWorkspaceTeamsParams, reqEditors ...RequestEditorFn) (*ListWorkspaceTeamsResponse, error) { rsp, err := c.ListWorkspaceTeams(ctx, organizationId, workspaceId, params, reqEditors...) @@ -17425,6 +18091,67 @@ func ParseGetDeploymentLogsResponse(rsp *http.Response) (*GetDeploymentLogsRespo return response, nil } +// ParseListDeploymentTeamsResponse parses an HTTP response from a ListDeploymentTeamsWithResponse call +func ParseListDeploymentTeamsResponse(rsp *http.Response) (*ListDeploymentTeamsResponse, error) { + bodyBytes, err := io.ReadAll(rsp.Body) + defer func() { _ = rsp.Body.Close() }() + if err != nil { + return nil, err + } + + response := &ListDeploymentTeamsResponse{ + Body: bodyBytes, + HTTPResponse: rsp, + } + + switch { + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 200: + var dest TeamsPaginated + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON200 = &dest + + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 400: + var dest Error + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON400 = &dest + + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 401: + var dest Error + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON401 = &dest + + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 403: + var dest Error + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON403 = &dest + + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 404: + var dest Error + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON404 = &dest + + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 500: + var dest Error + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON500 = &dest + + } + + return response, nil +} + // ParseDeleteDeploymentTeamResponse parses an HTTP response from a DeleteDeploymentTeamWithResponse call func ParseDeleteDeploymentTeamResponse(rsp *http.Response) (*DeleteDeploymentTeamResponse, error) { bodyBytes, err := io.ReadAll(rsp.Body) @@ -17540,22 +18267,22 @@ func ParseMutateDeploymentTeamRoleResponse(rsp *http.Response) (*MutateDeploymen return response, nil } -// ParseTransferDeploymentResponse parses an HTTP response from a TransferDeploymentWithResponse call -func ParseTransferDeploymentResponse(rsp *http.Response) (*TransferDeploymentResponse, error) { +// ParseListDeploymentUsersResponse parses an HTTP response from a ListDeploymentUsersWithResponse call +func ParseListDeploymentUsersResponse(rsp *http.Response) (*ListDeploymentUsersResponse, error) { bodyBytes, err := io.ReadAll(rsp.Body) defer func() { _ = rsp.Body.Close() }() if err != nil { return nil, err } - response := &TransferDeploymentResponse{ + response := &ListDeploymentUsersResponse{ Body: bodyBytes, HTTPResponse: rsp, } switch { case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 200: - var dest Deployment + var dest UsersPaginated if err := json.Unmarshal(bodyBytes, &dest); err != nil { return nil, err } @@ -17582,13 +18309,6 @@ func ParseTransferDeploymentResponse(rsp *http.Response) (*TransferDeploymentRes } response.JSON403 = &dest - case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 404: - var dest Error - if err := json.Unmarshal(bodyBytes, &dest); err != nil { - return nil, err - } - response.JSON404 = &dest - case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 500: var dest Error if err := json.Unmarshal(bodyBytes, &dest); err != nil { @@ -19579,6 +20299,46 @@ func ParseListWorkspaceDagsResponse(rsp *http.Response) (*ListWorkspaceDagsRespo } response.JSON200 = &dest + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode/100 == 4: + var dest Error + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON4XX = &dest + + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode/100 == 5: + var dest Error + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON5XX = &dest + + } + + return response, nil +} + +// ParseTransferDeploymentResponse parses an HTTP response from a TransferDeploymentWithResponse call +func ParseTransferDeploymentResponse(rsp *http.Response) (*TransferDeploymentResponse, error) { + bodyBytes, err := io.ReadAll(rsp.Body) + defer func() { _ = rsp.Body.Close() }() + if err != nil { + return nil, err + } + + response := &TransferDeploymentResponse{ + Body: bodyBytes, + HTTPResponse: rsp, + } + + switch { + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 200: + var dest Deployment + if err := json.Unmarshal(bodyBytes, &dest); err != nil { + return nil, err + } + response.JSON200 = &dest + case strings.Contains(rsp.Header.Get("Content-Type"), "json") && rsp.StatusCode == 400: var dest Error if err := json.Unmarshal(bodyBytes, &dest); err != nil { diff --git a/astro-client-core/mocks/client.go b/astro-client-core/mocks/client.go index fcb3ff26b..eda969efc 100644 --- a/astro-client-core/mocks/client.go +++ b/astro-client-core/mocks/client.go @@ -2261,6 +2261,72 @@ func (_m *ClientWithResponsesInterface) ListDeploymentApiTokensWithResponse(ctx return r0, r1 } +// ListDeploymentTeamsWithResponse provides a mock function with given fields: ctx, organizationId, deploymentId, params, reqEditors +func (_m *ClientWithResponsesInterface) ListDeploymentTeamsWithResponse(ctx context.Context, organizationId string, deploymentId string, params *astrocore.ListDeploymentTeamsParams, reqEditors ...astrocore.RequestEditorFn) (*astrocore.ListDeploymentTeamsResponse, error) { + _va := make([]interface{}, len(reqEditors)) + for _i := range reqEditors { + _va[_i] = reqEditors[_i] + } + var _ca []interface{} + _ca = append(_ca, ctx, organizationId, deploymentId, params) + _ca = append(_ca, _va...) + ret := _m.Called(_ca...) + + var r0 *astrocore.ListDeploymentTeamsResponse + var r1 error + if rf, ok := ret.Get(0).(func(context.Context, string, string, *astrocore.ListDeploymentTeamsParams, ...astrocore.RequestEditorFn) (*astrocore.ListDeploymentTeamsResponse, error)); ok { + return rf(ctx, organizationId, deploymentId, params, reqEditors...) + } + if rf, ok := ret.Get(0).(func(context.Context, string, string, *astrocore.ListDeploymentTeamsParams, ...astrocore.RequestEditorFn) *astrocore.ListDeploymentTeamsResponse); ok { + r0 = rf(ctx, organizationId, deploymentId, params, reqEditors...) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*astrocore.ListDeploymentTeamsResponse) + } + } + + if rf, ok := ret.Get(1).(func(context.Context, string, string, *astrocore.ListDeploymentTeamsParams, ...astrocore.RequestEditorFn) error); ok { + r1 = rf(ctx, organizationId, deploymentId, params, reqEditors...) + } else { + r1 = ret.Error(1) + } + + return r0, r1 +} + +// ListDeploymentUsersWithResponse provides a mock function with given fields: ctx, organizationId, deploymentId, params, reqEditors +func (_m *ClientWithResponsesInterface) ListDeploymentUsersWithResponse(ctx context.Context, organizationId string, deploymentId string, params *astrocore.ListDeploymentUsersParams, reqEditors ...astrocore.RequestEditorFn) (*astrocore.ListDeploymentUsersResponse, error) { + _va := make([]interface{}, len(reqEditors)) + for _i := range reqEditors { + _va[_i] = reqEditors[_i] + } + var _ca []interface{} + _ca = append(_ca, ctx, organizationId, deploymentId, params) + _ca = append(_ca, _va...) + ret := _m.Called(_ca...) + + var r0 *astrocore.ListDeploymentUsersResponse + var r1 error + if rf, ok := ret.Get(0).(func(context.Context, string, string, *astrocore.ListDeploymentUsersParams, ...astrocore.RequestEditorFn) (*astrocore.ListDeploymentUsersResponse, error)); ok { + return rf(ctx, organizationId, deploymentId, params, reqEditors...) + } + if rf, ok := ret.Get(0).(func(context.Context, string, string, *astrocore.ListDeploymentUsersParams, ...astrocore.RequestEditorFn) *astrocore.ListDeploymentUsersResponse); ok { + r0 = rf(ctx, organizationId, deploymentId, params, reqEditors...) + } else { + if ret.Get(0) != nil { + r0 = ret.Get(0).(*astrocore.ListDeploymentUsersResponse) + } + } + + if rf, ok := ret.Get(1).(func(context.Context, string, string, *astrocore.ListDeploymentUsersParams, ...astrocore.RequestEditorFn) error); ok { + r1 = rf(ctx, organizationId, deploymentId, params, reqEditors...) + } else { + r1 = ret.Error(1) + } + + return r0, r1 +} + // ListDeploymentsWithResponse provides a mock function with given fields: ctx, organizationId, params, reqEditors func (_m *ClientWithResponsesInterface) ListDeploymentsWithResponse(ctx context.Context, organizationId string, params *astrocore.ListDeploymentsParams, reqEditors ...astrocore.RequestEditorFn) (*astrocore.ListDeploymentsResponse, error) { _va := make([]interface{}, len(reqEditors)) @@ -3218,32 +3284,32 @@ func (_m *ClientWithResponsesInterface) RotateWorkspaceApiTokenWithResponse(ctx return r0, r1 } -// TransferDeploymentWithBodyWithResponse provides a mock function with given fields: ctx, organizationId, deploymentId, contentType, body, reqEditors -func (_m *ClientWithResponsesInterface) TransferDeploymentWithBodyWithResponse(ctx context.Context, organizationId string, deploymentId string, contentType string, body io.Reader, reqEditors ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error) { +// TransferDeploymentWithBodyWithResponse provides a mock function with given fields: ctx, organizationId, workspaceId, deploymentId, contentType, body, reqEditors +func (_m *ClientWithResponsesInterface) TransferDeploymentWithBodyWithResponse(ctx context.Context, organizationId string, workspaceId string, deploymentId string, contentType string, body io.Reader, reqEditors ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error) { _va := make([]interface{}, len(reqEditors)) for _i := range reqEditors { _va[_i] = reqEditors[_i] } var _ca []interface{} - _ca = append(_ca, ctx, organizationId, deploymentId, contentType, body) + _ca = append(_ca, ctx, organizationId, workspaceId, deploymentId, contentType, body) _ca = append(_ca, _va...) ret := _m.Called(_ca...) var r0 *astrocore.TransferDeploymentResponse var r1 error - if rf, ok := ret.Get(0).(func(context.Context, string, string, string, io.Reader, ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error)); ok { - return rf(ctx, organizationId, deploymentId, contentType, body, reqEditors...) + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, io.Reader, ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error)); ok { + return rf(ctx, organizationId, workspaceId, deploymentId, contentType, body, reqEditors...) } - if rf, ok := ret.Get(0).(func(context.Context, string, string, string, io.Reader, ...astrocore.RequestEditorFn) *astrocore.TransferDeploymentResponse); ok { - r0 = rf(ctx, organizationId, deploymentId, contentType, body, reqEditors...) + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, string, io.Reader, ...astrocore.RequestEditorFn) *astrocore.TransferDeploymentResponse); ok { + r0 = rf(ctx, organizationId, workspaceId, deploymentId, contentType, body, reqEditors...) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*astrocore.TransferDeploymentResponse) } } - if rf, ok := ret.Get(1).(func(context.Context, string, string, string, io.Reader, ...astrocore.RequestEditorFn) error); ok { - r1 = rf(ctx, organizationId, deploymentId, contentType, body, reqEditors...) + if rf, ok := ret.Get(1).(func(context.Context, string, string, string, string, io.Reader, ...astrocore.RequestEditorFn) error); ok { + r1 = rf(ctx, organizationId, workspaceId, deploymentId, contentType, body, reqEditors...) } else { r1 = ret.Error(1) } @@ -3251,32 +3317,32 @@ func (_m *ClientWithResponsesInterface) TransferDeploymentWithBodyWithResponse(c return r0, r1 } -// TransferDeploymentWithResponse provides a mock function with given fields: ctx, organizationId, deploymentId, body, reqEditors -func (_m *ClientWithResponsesInterface) TransferDeploymentWithResponse(ctx context.Context, organizationId string, deploymentId string, body astrocore.TransferDeploymentRequest, reqEditors ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error) { +// TransferDeploymentWithResponse provides a mock function with given fields: ctx, organizationId, workspaceId, deploymentId, body, reqEditors +func (_m *ClientWithResponsesInterface) TransferDeploymentWithResponse(ctx context.Context, organizationId string, workspaceId string, deploymentId string, body astrocore.TransferDeploymentRequest, reqEditors ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error) { _va := make([]interface{}, len(reqEditors)) for _i := range reqEditors { _va[_i] = reqEditors[_i] } var _ca []interface{} - _ca = append(_ca, ctx, organizationId, deploymentId, body) + _ca = append(_ca, ctx, organizationId, workspaceId, deploymentId, body) _ca = append(_ca, _va...) ret := _m.Called(_ca...) var r0 *astrocore.TransferDeploymentResponse var r1 error - if rf, ok := ret.Get(0).(func(context.Context, string, string, astrocore.TransferDeploymentRequest, ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error)); ok { - return rf(ctx, organizationId, deploymentId, body, reqEditors...) + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, astrocore.TransferDeploymentRequest, ...astrocore.RequestEditorFn) (*astrocore.TransferDeploymentResponse, error)); ok { + return rf(ctx, organizationId, workspaceId, deploymentId, body, reqEditors...) } - if rf, ok := ret.Get(0).(func(context.Context, string, string, astrocore.TransferDeploymentRequest, ...astrocore.RequestEditorFn) *astrocore.TransferDeploymentResponse); ok { - r0 = rf(ctx, organizationId, deploymentId, body, reqEditors...) + if rf, ok := ret.Get(0).(func(context.Context, string, string, string, astrocore.TransferDeploymentRequest, ...astrocore.RequestEditorFn) *astrocore.TransferDeploymentResponse); ok { + r0 = rf(ctx, organizationId, workspaceId, deploymentId, body, reqEditors...) } else { if ret.Get(0) != nil { r0 = ret.Get(0).(*astrocore.TransferDeploymentResponse) } } - if rf, ok := ret.Get(1).(func(context.Context, string, string, astrocore.TransferDeploymentRequest, ...astrocore.RequestEditorFn) error); ok { - r1 = rf(ctx, organizationId, deploymentId, body, reqEditors...) + if rf, ok := ret.Get(1).(func(context.Context, string, string, string, astrocore.TransferDeploymentRequest, ...astrocore.RequestEditorFn) error); ok { + r1 = rf(ctx, organizationId, workspaceId, deploymentId, body, reqEditors...) } else { r1 = ret.Error(1) } diff --git a/astro-client-iam-core/api.gen.go b/astro-client-iam-core/api.gen.go index e98bc6dbb..2be808996 100644 --- a/astro-client-iam-core/api.gen.go +++ b/astro-client-iam-core/api.gen.go @@ -41,6 +41,19 @@ const ( USER BasicSubjectProfileSubjectType = "USER" ) +// Defines values for CreateApiTokenRequestRole. +const ( + CreateApiTokenRequestRoleDEPLOYMENTADMIN CreateApiTokenRequestRole = "DEPLOYMENT_ADMIN" + CreateApiTokenRequestRoleORGANIZATIONBILLINGADMIN CreateApiTokenRequestRole = "ORGANIZATION_BILLING_ADMIN" + CreateApiTokenRequestRoleORGANIZATIONMEMBER CreateApiTokenRequestRole = "ORGANIZATION_MEMBER" + CreateApiTokenRequestRoleORGANIZATIONOWNER CreateApiTokenRequestRole = "ORGANIZATION_OWNER" + CreateApiTokenRequestRoleWORKSPACEACCESSOR CreateApiTokenRequestRole = "WORKSPACE_ACCESSOR" + CreateApiTokenRequestRoleWORKSPACEAUTHOR CreateApiTokenRequestRole = "WORKSPACE_AUTHOR" + CreateApiTokenRequestRoleWORKSPACEMEMBER CreateApiTokenRequestRole = "WORKSPACE_MEMBER" + CreateApiTokenRequestRoleWORKSPACEOPERATOR CreateApiTokenRequestRole = "WORKSPACE_OPERATOR" + CreateApiTokenRequestRoleWORKSPACEOWNER CreateApiTokenRequestRole = "WORKSPACE_OWNER" +) + // Defines values for CreateApiTokenRequestType. const ( DEPLOYMENT CreateApiTokenRequestType = "DEPLOYMENT" @@ -112,6 +125,7 @@ const ( // Defines values for WorkspaceRoleRole. const ( + WORKSPACEACCESSOR WorkspaceRoleRole = "WORKSPACE_ACCESSOR" WORKSPACEAUTHOR WorkspaceRoleRole = "WORKSPACE_AUTHOR" WORKSPACEMEMBER WorkspaceRoleRole = "WORKSPACE_MEMBER" WORKSPACEOPERATOR WorkspaceRoleRole = "WORKSPACE_OPERATOR" @@ -289,7 +303,7 @@ type CreateApiTokenRequest struct { Name string `json:"name"` // Role The role of the API token. - Role string `json:"role"` + Role CreateApiTokenRequestRole `json:"role"` // TokenExpiryPeriodInDays The expiry period of the API token in days. If not specified, the token will never expire. TokenExpiryPeriodInDays *int `json:"tokenExpiryPeriodInDays,omitempty"` @@ -298,6 +312,9 @@ type CreateApiTokenRequest struct { Type CreateApiTokenRequestType `json:"type"` } +// CreateApiTokenRequestRole The role of the API token. +type CreateApiTokenRequestRole string + // CreateApiTokenRequestType The scope of the API token. type CreateApiTokenRequestType string diff --git a/astro-client-platform-core/api.gen.go b/astro-client-platform-core/api.gen.go index 742eec439..1b0c8d830 100644 --- a/astro-client-platform-core/api.gen.go +++ b/astro-client-platform-core/api.gen.go @@ -301,20 +301,24 @@ const ( // Defines values for WorkerMachineName. const ( - WorkerMachineNameA10 WorkerMachineName = "A10" - WorkerMachineNameA20 WorkerMachineName = "A20" - WorkerMachineNameA40 WorkerMachineName = "A40" - WorkerMachineNameA5 WorkerMachineName = "A5" - WorkerMachineNameA60 WorkerMachineName = "A60" + WorkerMachineNameA10 WorkerMachineName = "A10" + WorkerMachineNameA120 WorkerMachineName = "A120" + WorkerMachineNameA160 WorkerMachineName = "A160" + WorkerMachineNameA20 WorkerMachineName = "A20" + WorkerMachineNameA40 WorkerMachineName = "A40" + WorkerMachineNameA5 WorkerMachineName = "A5" + WorkerMachineNameA60 WorkerMachineName = "A60" ) // Defines values for WorkerQueueRequestAstroMachine. const ( - WorkerQueueRequestAstroMachineA10 WorkerQueueRequestAstroMachine = "A10" - WorkerQueueRequestAstroMachineA20 WorkerQueueRequestAstroMachine = "A20" - WorkerQueueRequestAstroMachineA40 WorkerQueueRequestAstroMachine = "A40" - WorkerQueueRequestAstroMachineA5 WorkerQueueRequestAstroMachine = "A5" - WorkerQueueRequestAstroMachineA60 WorkerQueueRequestAstroMachine = "A60" + WorkerQueueRequestAstroMachineA10 WorkerQueueRequestAstroMachine = "A10" + WorkerQueueRequestAstroMachineA120 WorkerQueueRequestAstroMachine = "A120" + WorkerQueueRequestAstroMachineA160 WorkerQueueRequestAstroMachine = "A160" + WorkerQueueRequestAstroMachineA20 WorkerQueueRequestAstroMachine = "A20" + WorkerQueueRequestAstroMachineA40 WorkerQueueRequestAstroMachine = "A40" + WorkerQueueRequestAstroMachineA5 WorkerQueueRequestAstroMachine = "A5" + WorkerQueueRequestAstroMachineA60 WorkerQueueRequestAstroMachine = "A60" ) // Defines values for ListOrganizationsParamsSupportPlan. @@ -678,6 +682,9 @@ type CreateDedicatedDeploymentRequest struct { // ClusterId The ID of the cluster where the Deployment will be created. ClusterId string `json:"clusterId"` + // ContactEmails A list of contact emails for the Deployment. + ContactEmails *[]string `json:"contactEmails,omitempty"` + // DefaultTaskPodCpu The default CPU resource usage for a worker Pod when running the Kubernetes executor or KubernetesPodOperator. Units are in number of CPU cores. DefaultTaskPodCpu string `json:"defaultTaskPodCpu"` @@ -687,6 +694,9 @@ type CreateDedicatedDeploymentRequest struct { // Description The Deployment's description. Description *string `json:"description,omitempty"` + // EnvironmentVariables List of environment variables to add to the Deployment. + EnvironmentVariables *[]DeploymentEnvironmentVariableRequest `json:"environmentVariables,omitempty"` + // Executor The Deployment's executor type. Executor CreateDedicatedDeploymentRequestExecutor `json:"executor"` @@ -791,9 +801,15 @@ type CreateHybridDeploymentRequest struct { // ClusterId The ID of the cluster where the Deployment will be created. ClusterId string `json:"clusterId"` + // ContactEmails A list of contact emails for the Deployment. + ContactEmails *[]string `json:"contactEmails,omitempty"` + // Description The Deployment's description. Description *string `json:"description,omitempty"` + // EnvironmentVariables List of environment variables to add to the Deployment. + EnvironmentVariables *[]DeploymentEnvironmentVariableRequest `json:"environmentVariables,omitempty"` + // Executor The Deployment's executor type. Executor CreateHybridDeploymentRequestExecutor `json:"executor"` @@ -852,6 +868,9 @@ type CreateStandardDeploymentRequest struct { // ClusterId The ID of the cluster to which the Deployment will be created in. Optional if cloud provider and region is specified. ClusterId *string `json:"clusterId,omitempty"` + // ContactEmails A list of contact emails for the Deployment. + ContactEmails *[]string `json:"contactEmails,omitempty"` + // DefaultTaskPodCpu The default CPU resource usage for a worker Pod when running the Kubernetes executor or KubernetesPodOperator. Units are in number of CPU cores. DefaultTaskPodCpu string `json:"defaultTaskPodCpu"` @@ -861,6 +880,9 @@ type CreateStandardDeploymentRequest struct { // Description The Deployment's description. Description *string `json:"description,omitempty"` + // EnvironmentVariables List of environment variables to add to the Deployment. + EnvironmentVariables *[]DeploymentEnvironmentVariableRequest `json:"environmentVariables,omitempty"` + // Executor The Deployment's executor type. Executor CreateStandardDeploymentRequestExecutor `json:"executor"` @@ -924,9 +946,12 @@ type CreateWorkspaceRequest struct { // Deployment defines model for Deployment. type Deployment struct { - // AirflowVersion The Deployment's Astro Runtime version. + // AirflowVersion The Deployment's Airflow version. AirflowVersion string `json:"airflowVersion"` + // AstroRuntimeVersion The Deployment's Astro Runtime version. + AstroRuntimeVersion string `json:"astroRuntimeVersion"` + // CloudProvider The cloud provider of the cluster. Only for Standard Deployment. CloudProvider *string `json:"cloudProvider,omitempty"` @@ -1009,7 +1034,7 @@ type Deployment struct { // ResourceQuotaMemory The memory quota for worker Pods when running the Kubernetes executor or KubernetesPodOperator. If current memory usage across all workers exceeds the quota, no new worker Pods can be scheduled. Units are in `Gi`. This value must always be twice the value of `ResourceQuotaCpu`. ResourceQuotaMemory *string `json:"resourceQuotaMemory,omitempty"` - // RuntimeVersion The Deployment's Astro Runtime version. + // RuntimeVersion Deprecated: runtimeVersion has been replaced with astroRuntimeVersion RuntimeVersion string `json:"runtimeVersion"` // SchedulerAu The number of Astronomer units (AU) for the Deployment's scheduler. Applies only to Deployments hosted on Hybrid clusters. diff --git a/cloud/workspace/workspace_token.go b/cloud/workspace/workspace_token.go index a565e3b43..ce58b6a5c 100644 --- a/cloud/workspace/workspace_token.go +++ b/cloud/workspace/workspace_token.go @@ -156,7 +156,9 @@ func UpdateToken(id, name, newName, description, role, workspace string, out io. apiTokenID := token.Id - UpdateWorkspaceAPITokenRequest := astrocore.UpdateWorkspaceApiTokenJSONRequestBody{} + UpdateWorkspaceAPITokenRequest := astrocore.UpdateWorkspaceApiTokenJSONRequestBody{ + Roles: &astrocore.UpdateWorkspaceApiTokenRolesRequest{}, + } if newName == "" { UpdateWorkspaceAPITokenRequest.Name = token.Name @@ -180,13 +182,13 @@ func UpdateToken(id, name, newName, description, role, workspace string, out io. if err != nil { return err } - UpdateWorkspaceAPITokenRequest.Role = role + UpdateWorkspaceAPITokenRequest.Roles.Workspace = &role } else { err := user.IsWorkspaceRoleValid(role) if err != nil { return err } - UpdateWorkspaceAPITokenRequest.Role = role + UpdateWorkspaceAPITokenRequest.Roles.Workspace = &role } resp, err := client.UpdateWorkspaceApiTokenWithResponse(httpContext.Background(), ctx.Organization, workspace, apiTokenID, UpdateWorkspaceAPITokenRequest) diff --git a/go.mod b/go.mod index 4b32e3094..d5ca93a29 100644 --- a/go.mod +++ b/go.mod @@ -14,7 +14,7 @@ require ( github.com/iancoleman/strcase v0.2.0 github.com/logrusorgru/aurora v2.0.3+incompatible github.com/lucsky/cuid v1.2.1 - github.com/mattn/go-isatty v0.0.16 + github.com/mattn/go-isatty v0.0.20 github.com/mitchellh/go-homedir v1.1.0 github.com/moby/buildkit v0.8.2-0.20210401015549-df49b648c8bf github.com/pkg/browser v0.0.0-20210911075715-681adbf594b8 @@ -24,19 +24,20 @@ require ( github.com/spf13/cobra v1.6.1 github.com/spf13/viper v1.9.0 github.com/stretchr/testify v1.8.4 - golang.org/x/net v0.17.0 + golang.org/x/net v0.19.0 golang.org/x/sys v0.15.0 ) require ( github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v0.4.1 - github.com/deepmap/oapi-codegen v1.12.2 + github.com/deepmap/oapi-codegen v1.12.4 github.com/docker/distribution v2.7.1+incompatible github.com/fatih/camelcase v1.0.0 github.com/ghodss/yaml v1.0.0 github.com/golang-jwt/jwt/v4 v4.5.0 github.com/google/go-github/v48 v48.2.0 github.com/mitchellh/mapstructure v1.4.2 + github.com/oapi-codegen/runtime v1.1.1 github.com/opencontainers/image-spec v1.1.0-rc2.0.20221005185240-3a7f492d3f1b github.com/whilp/git-urls v1.0.0 golang.org/x/exp v0.0.0-20240119083558-1b970713d09a @@ -96,7 +97,7 @@ require ( github.com/google/go-querystring v1.1.0 // indirect github.com/google/gofuzz v1.2.0 // indirect github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510 // indirect - github.com/google/uuid v1.3.0 // indirect + github.com/google/uuid v1.5.0 // indirect github.com/gorilla/mux v1.8.0 // indirect github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 // indirect github.com/grpc-ecosystem/grpc-opentracing v0.0.0-20180507213350-8e809c8a8645 // indirect @@ -109,7 +110,7 @@ require ( github.com/jinzhu/gorm v1.9.11 // indirect github.com/json-iterator/go v1.1.12 // indirect github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 // indirect - github.com/klauspost/compress v1.15.9 // indirect + github.com/klauspost/compress v1.16.7 // indirect github.com/magiconair/properties v1.8.5 // indirect github.com/manifoldco/promptui v0.9.0 github.com/mattn/go-colorable v0.1.13 // indirect @@ -151,12 +152,12 @@ require ( golang.org/x/oauth2 v0.10.0 // indirect golang.org/x/sync v0.3.0 // indirect golang.org/x/text v0.14.0 // indirect - golang.org/x/time v0.0.0-20220411224347-583f2d630306 // indirect + golang.org/x/time v0.5.0 // indirect google.golang.org/appengine v1.6.7 // indirect google.golang.org/grpc v1.58.3 // indirect google.golang.org/protobuf v1.31.0 // indirect gopkg.in/inf.v0 v0.9.1 // indirect - gopkg.in/ini.v1 v1.63.2 // indirect + gopkg.in/ini.v1 v1.67.0 // indirect gopkg.in/yaml.v2 v2.4.0 // indirect k8s.io/apimachinery v0.22.5 // indirect k8s.io/client-go v0.22.5 // indirect diff --git a/go.sum b/go.sum index 948db7224..8e8ca2f0d 100644 --- a/go.sum +++ b/go.sum @@ -53,6 +53,7 @@ github.com/Azure/azure-sdk-for-go v16.2.1+incompatible/go.mod h1:9XXNKU+eRnpl9mo github.com/Azure/azure-sdk-for-go/sdk/azcore v1.1.0 h1:Ut0ZGdOwJDw0npYEg+TLlPls3Pq6JiZaP2/aGKir7Zw= github.com/Azure/azure-sdk-for-go/sdk/azcore v1.1.0/go.mod h1:uGG2W01BaETf0Ozp+QxxKJdMBNRWPdstHG0Fmdwn1/U= github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.0.0 h1:Yoicul8bnVdQrhDMTHxdEckRGX01XvwXDHUT9zYZ3k0= +github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.0.0/go.mod h1:+6sju8gk8FRmSajX3Oz4G5Gm7P+mbqE9FVaXXFYTkCM= github.com/Azure/azure-sdk-for-go/sdk/internal v1.0.0 h1:jp0dGvZ7ZK0mgqnTSClMxa5xuRL7NZgHameVYF6BurY= github.com/Azure/azure-sdk-for-go/sdk/internal v1.0.0/go.mod h1:eWRD7oawr1Mu1sLCawqVc0CUiF43ia3qQMxLscsKQ9w= github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v0.4.1 h1:QSdcrd/UFJv6Bp/CfoVf2SrENpFn9P6Yh8yb+xNhYMM= @@ -74,6 +75,7 @@ github.com/Azure/go-autorest/logger v0.2.0/go.mod h1:T9E3cAhj2VqvPOtCYAvby9aBXkZ github.com/Azure/go-autorest/logger v0.2.1/go.mod h1:T9E3cAhj2VqvPOtCYAvby9aBXkZmbF5NWuPV8+WeEW8= github.com/Azure/go-autorest/tracing v0.6.0/go.mod h1:+vhtPC754Xsa23ID7GlGsrdKBpUA79WCAKPPZVC2DeU= github.com/AzureAD/microsoft-authentication-library-for-go v0.4.0 h1:WVsrXCnHlDDX8ls+tootqRE87/hL9S/g4ewig9RsD/c= +github.com/AzureAD/microsoft-authentication-library-for-go v0.4.0/go.mod h1:Vt9sXTKwMyGcOxSmLDMnGPgqsUg7m8pe215qMLrDXw4= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo= github.com/GeertJohan/go.incremental v1.0.0/go.mod h1:6fAjUhbVuX1KcMD3c8TEgVUqmo4seqhv0i0kdATSkM0= @@ -298,6 +300,7 @@ github.com/containerd/ttrpc v1.0.1/go.mod h1:UAxOpgT9ziI0gJrmKvgcZivgxOp8iFPSk8h github.com/containerd/ttrpc v1.0.2/go.mod h1:UAxOpgT9ziI0gJrmKvgcZivgxOp8iFPSk8httJEt98Y= github.com/containerd/ttrpc v1.1.0/go.mod h1:XX4ZTnoOId4HklF4edwc4DcqskFZuvXB1Evzy5KFQpQ= github.com/containerd/ttrpc v1.1.2 h1:4jH6OQDQqjfVD2b5TJS5TxmGuLGmp5WW7KtW2TWOP7c= +github.com/containerd/ttrpc v1.1.2/go.mod h1:XX4ZTnoOId4HklF4edwc4DcqskFZuvXB1Evzy5KFQpQ= github.com/containerd/typeurl v0.0.0-20180627222232-a93fcdb778cd/go.mod h1:Cm3kwCdlkCfMSHURc+r6fwoGH6/F1hH3S4sg0rLFWPc= github.com/containerd/typeurl v0.0.0-20190911142611-5eb25027c9fd/go.mod h1:GeKYzf2pQcqv7tJ0AoCuuhtnqhva5LNU3U+OyKxxJpk= github.com/containerd/typeurl v1.0.1/go.mod h1:TB1hUtrpaiO88KEK56ijojHS1+NeF0izUACaJW2mdXg= @@ -352,6 +355,8 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/deepmap/oapi-codegen v1.12.2 h1:F7SMEn0UMpJV6kWwDYqfDmnnOYHIcU7ETV8qTVFdyI0= github.com/deepmap/oapi-codegen v1.12.2/go.mod h1:ao2aFwsl/muMHbez870+KelJ1yusV01RznwAFFrVjDc= +github.com/deepmap/oapi-codegen v1.12.4 h1:pPmn6qI9MuOtCz82WY2Xaw46EQjgvxednXXrP7g5Q2s= +github.com/deepmap/oapi-codegen v1.12.4/go.mod h1:3lgHGMu6myQ2vqbbTXH2H1o4eXFTGnFiDaOaKKl5yas= github.com/denisenkom/go-mssqldb v0.0.0-20190315220205-a8ed825ac853/go.mod h1:xN/JuLBIz4bjkxNmByTiV1IbhfnYb6oo99phBn4Eqhc= github.com/denisenkom/go-mssqldb v0.0.0-20190515213511-eb9f6a1743f3/go.mod h1:zAg7JM8CkOJ43xKXIj7eRO9kmWm/TW578qo+oDO6tuM= github.com/denverdino/aliyungo v0.0.0-20190125010748-a747050bb1ba/go.mod h1:dV8lFg6daOBZbT6/BDGIz6Y3WFGn8juu6G+CQ6LHtl0= @@ -362,6 +367,7 @@ github.com/distribution/distribution/v3 v3.0.0-20210316161203-a01c71e2477e h1:n8 github.com/distribution/distribution/v3 v3.0.0-20210316161203-a01c71e2477e/go.mod h1:xpWTC2KnJMiDLkoawhsPQcXjvwATEBcbq0xevG2YR9M= github.com/dnaeon/go-vcr v1.0.1/go.mod h1:aBB1+wY4s93YsC3HHjMBMrwTj2R9FHDzUr9KyGc8n1E= github.com/dnaeon/go-vcr v1.1.0 h1:ReYa/UBrRyQdant9B4fNHGoCNKw6qh6P0fsdGmZpR7c= +github.com/dnaeon/go-vcr v1.1.0/go.mod h1:M7tiix8f0r6mKKJ3Yq/kqU1OYf3MnfmBWVbPx/yU9ko= github.com/docker/buildx v0.5.2-0.20210422185057-908a856079fc h1:oqPGOy23wxFCyOMSfdZTk02F7qvPi7kUEEeKrExKtfw= github.com/docker/buildx v0.5.2-0.20210422185057-908a856079fc/go.mod h1:T5sa7xGu8G7dLXwaLLj6dRbJ5mxugPFDfELGnO2B5lQ= github.com/docker/cli v0.0.0-20191017083524-a8ff7f821017/go.mod h1:JLrzqnKDaYBop7H2jaqPtU4hHvMKP+vjCwu2uszcLI8= @@ -503,6 +509,7 @@ github.com/gogo/protobuf v1.3.1/go.mod h1:SlYgWuQ5SjCEi6WLHjHCa1yvBfUnHcTbrrZtXP github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q= github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q= github.com/golang-jwt/jwt v3.2.2+incompatible h1:IfV12K8xAKAnZqdXVzCZ+TOjboZ2keLg81eXfW3O+oY= +github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I= github.com/golang-jwt/jwt/v4 v4.5.0 h1:7cYmW1XlMY7h7ii7UhUyChSgS5wUJEnm9uZVTGqOWzg= github.com/golang-jwt/jwt/v4 v4.5.0/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0= github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q= @@ -599,8 +606,8 @@ github.com/google/uuid v1.0.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+ github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/google/uuid v1.2.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= -github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I= -github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/google/uuid v1.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU= +github.com/google/uuid v1.5.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/googleapis/gax-go/v2 v2.0.4/go.mod h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+vpHVxEJEs9eg= github.com/googleapis/gax-go/v2 v2.0.5/go.mod h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk= github.com/googleapis/gax-go/v2 v2.1.0/go.mod h1:Q3nei7sK6ybPYH7twZdmQpAd1MKb7pfu6SK+H1/DsU0= @@ -738,8 +745,8 @@ github.com/kisielk/sqlstruct v0.0.0-20150923205031-648daed35d49/go.mod h1:yyMNCy github.com/kisom/goutils v1.1.0/go.mod h1:+UBTfd78habUYWFbNWTJNG+jNG/i/lGURakr4A/yNRw= github.com/klauspost/compress v1.11.3/go.mod h1:aoV0uJVorq1K+umq18yTdKaF57EivdYsUV+/s2qKfXs= github.com/klauspost/compress v1.11.13/go.mod h1:aoV0uJVorq1K+umq18yTdKaF57EivdYsUV+/s2qKfXs= -github.com/klauspost/compress v1.15.9 h1:wKRjX6JRtDdrE9qwa4b/Cip7ACOshUI4smpCQanqjSY= -github.com/klauspost/compress v1.15.9/go.mod h1:PhcZ0MbTNciWF3rruxRgKxI5NkcHHrHUDtV4Yw2GlzU= +github.com/klauspost/compress v1.16.7 h1:2mk3MPGNzKyxErAw8YaohYh69+pa4sIQSC0fPGCFR9I= +github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE= github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= github.com/konsorten/go-windows-terminal-sequences v1.0.2/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= github.com/konsorten/go-windows-terminal-sequences v1.0.3/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ= @@ -752,12 +759,14 @@ github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= github.com/kr/pty v1.1.4/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= github.com/kr/pty v1.1.5/go.mod h1:9r2w37qlBe7rQ6e1fg1S/9xpWHSnaqNdHD3WcMdbPDA= github.com/kr/pty v1.1.8 h1:AkaSdXYQOWeaO3neb8EM634ahkXXe3jYbVh/F9lq+GI= +github.com/kr/pty v1.1.8/go.mod h1:O1sed60cT9XZ5uDucP5qwvh+TE3NnUj51EiZO/lmSfw= github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/kylelemons/go-gypsy v0.0.0-20160905020020-08cad365cd28/go.mod h1:T/T7jsxVqf9k/zYOqbgNAsANsjxTd1Yq3htjDhQ1H0c= github.com/kylelemons/godebug v0.0.0-20170820004349-d65d576e9348/go.mod h1:B69LEHPfb2qLo0BaaOLcbitczOKLWTsrBG9LczfCD4k= github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc= +github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw= github.com/lib/pq v0.0.0-20180201184707-88edab080323/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo= github.com/lib/pq v1.1.1/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo= github.com/lib/pq v1.10.0/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o= @@ -789,8 +798,9 @@ github.com/mattn/go-isatty v0.0.8/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hd github.com/mattn/go-isatty v0.0.10/go.mod h1:qgIWMr58cqv1PHHyhnkY9lrL7etaEgOFcMEpPG5Rm84= github.com/mattn/go-isatty v0.0.11/go.mod h1:PhnuNfih5lzO57/f3n+odYbM4JtupLOxQOAqxQCu2WE= github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU= -github.com/mattn/go-isatty v0.0.16 h1:bq3VjFmv/sOjHtdEhmkEV4x1AJtvUvOJ2PFAZ5+peKQ= github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM= +github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= +github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= github.com/mattn/go-runewidth v0.0.2/go.mod h1:LwmH8dsx7+W8Uxz3IHJYH5QSwggIsqBzpuz5H//U1FU= github.com/mattn/go-shellwords v1.0.3/go.mod h1:3xCvwCdWdlDJUrvuMn7Wuy9eWs4pE8vqg+NOMyg4B2o= github.com/mattn/go-shellwords v1.0.6/go.mod h1:3xCvwCdWdlDJUrvuMn7Wuy9eWs4pE8vqg+NOMyg4B2o= @@ -842,6 +852,7 @@ github.com/moby/sys/mountinfo v0.5.0/go.mod h1:3bMD3Rg+zkqx8MRYPi7Pyb0Ie97QEBmdx github.com/moby/sys/mountinfo v0.6.2 h1:BzJjoreD5BMFNmD9Rus6gdd1pLuecOFPt8wC+Vygl78= github.com/moby/sys/mountinfo v0.6.2/go.mod h1:IJb6JQeOklcdMU9F5xQ8ZALD+CUr5VlGpwtX+VE0rpI= github.com/moby/sys/signal v0.6.0 h1:aDpY94H8VlhTGa9sNYUFCFsMZIUh5wm0B6XkIoJj/iY= +github.com/moby/sys/signal v0.6.0/go.mod h1:GQ6ObYZfqacOwTtlXvcmh9A26dVRul/hbOZn88Kg8Tg= github.com/moby/sys/symlink v0.1.0/go.mod h1:GGDODQmbFOjFsXvfLVn3+ZRxkch54RkSiGqsZeMYowQ= github.com/moby/sys/symlink v0.2.0 h1:tk1rOM+Ljp0nFmfOIBtlV3rTDlWOwFRhjEeAhZB0nZc= github.com/moby/sys/symlink v0.2.0/go.mod h1:7uZVF2dqJjG/NsClqul95CqKOBRQyYSNnJ6BMgR/gFs= @@ -871,6 +882,8 @@ github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWb github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno= github.com/nkovacs/streamquote v0.0.0-20170412213628-49af9bddb229/go.mod h1:0aYXnNPJ8l7uZxf45rWW1a/uME32OF0rhiYGNQ2oF2E= github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A= +github.com/oapi-codegen/runtime v1.1.1 h1:EXLHh0DXIJnWhdRPN2w4MXAzFyE4CskzhNLUmtpMYro= +github.com/oapi-codegen/runtime v1.1.1/go.mod h1:SK9X900oXmPWilYR5/WKPzt3Kqxn/uS/+lbpREv+eCg= github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U= github.com/olekukonko/tablewriter v0.0.0-20170122224234-a0225b3f23b5/go.mod h1:vsDQFd/mU46D+Z4whnwzcISnGGzXWMclvtLoiIKAKIo= github.com/onsi/ginkgo v0.0.0-20151202141238-7f8ab55aaf3b/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE= @@ -928,6 +941,7 @@ github.com/opencontainers/selinux v1.8.0/go.mod h1:RScLhm78qiWa2gbVCcGkC7tCGdgk3 github.com/opencontainers/selinux v1.8.2/go.mod h1:MUIHuUEvKB1wtJjQdOyYRgOnLD2xAPP8dBsCoU0KuF8= github.com/opencontainers/selinux v1.10.0/go.mod h1:2i0OySw99QjzBBQByd1Gr9gSjvuho1lHsJxIJ3gGbJI= github.com/opencontainers/selinux v1.10.1 h1:09LIPVRP3uuZGQvgR+SgMSNBd1Eb3vlRbGqQpoHsF8w= +github.com/opencontainers/selinux v1.10.1/go.mod h1:2i0OySw99QjzBBQByd1Gr9gSjvuho1lHsJxIJ3gGbJI= github.com/opentracing-contrib/go-stdlib v1.0.0/go.mod h1:qtI1ogk+2JhVPIXVc6q+NHziSmy2W5GbdQZFUHADCBU= github.com/opentracing/opentracing-go v1.1.0/go.mod h1:UkNAQd3GIcIGf0SeVgPpRdFStlNbqXla1AfSYxPUl2o= github.com/opentracing/opentracing-go v1.2.0 h1:uEJPy/1a5RIPAJ0Ov+OIO8OxWu77jEv+1B0VhjKrZUs= @@ -1301,8 +1315,8 @@ golang.org/x/net v0.0.0-20210503060351-7fd8e65b6420/go.mod h1:9nx3DQGgdP8bBQD5qx golang.org/x/net v0.0.0-20210525063256-abc453219eb5/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20210825183410-e898025ed96a/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20211209124913-491a49abca63/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= -golang.org/x/net v0.17.0 h1:pVaXccu2ozPjCXewfr1S7xza/zcXTity9cCdXQYSjIM= -golang.org/x/net v0.17.0/go.mod h1:NxSsAGuq816PNPmqtQdLE42eU2Fs7NoRIZrHJAlaCOE= +golang.org/x/net v0.19.0 h1:zTwKpTd2XuCqf8huc7Fo2iSy+4RHPd10s4KzeTnVr1c= +golang.org/x/net v0.19.0/go.mod h1:CfAk/cbD4CthTvqiEl8NpboMuiuOYsAr/7NOjZJtv1U= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= golang.org/x/oauth2 v0.0.0-20190604053449-0f29369cfe45/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= @@ -1443,6 +1457,7 @@ golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= +golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.15.0 h1:h48lPFYpsTvQJZF4EKyI4aLHaev3CxivZmv7yZig9pc= golang.org/x/sys v0.15.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw= @@ -1467,8 +1482,8 @@ golang.org/x/time v0.0.0-20191024005414-555d28b269f0/go.mod h1:tRJNPiyCQ0inRvYxb golang.org/x/time v0.0.0-20200416051211-89c76fbcd5d1/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= -golang.org/x/time v0.0.0-20220411224347-583f2d630306 h1:+gHMid33q6pen7kv9xvT+JRinntgeXO2AeZVd0AWD3w= -golang.org/x/time v0.0.0-20220411224347-583f2d630306/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ= +golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk= +golang.org/x/time v0.5.0/go.mod h1:3BpzKBy/shNhVucY/MWOyx10tF3SFh9QdLuxbVysPQM= golang.org/x/tools v0.0.0-20180221164845-07fd8470d635/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20180828015842-6cd1fcedba52/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= @@ -1707,8 +1722,9 @@ gopkg.in/gorethink/gorethink.v3 v3.0.5/go.mod h1:+3yIIHJUGMBK+wyPH+iN5TP+88ikFDf gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc= gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw= gopkg.in/ini.v1 v1.51.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= -gopkg.in/ini.v1 v1.63.2 h1:tGK/CyBg7SMzb60vP1M03vNZ3VDu3wGQJwn7Sxi9r3c= gopkg.in/ini.v1 v1.63.2/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= +gopkg.in/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA= +gopkg.in/ini.v1 v1.67.0/go.mod h1:pNLf8WUiyNEtQjuu5G5vTm06TEv9tsIgeAvK8hOrP4k= gopkg.in/natefinch/lumberjack.v2 v2.0.0/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k= gopkg.in/resty.v1 v1.12.0/go.mod h1:mDo4pnntr5jdWRML875a/NmxYqAlA73dVijT2AXvQQo= gopkg.in/square/go-jose.v2 v2.2.2/go.mod h1:M9dMgbHiYLoDGQrXy7OpJDJWiKiU//h+vD76mk0e1AI= @@ -1735,6 +1751,7 @@ gotest.tools v2.2.0+incompatible/go.mod h1:DsYFclhRJ6vuDpmuTbkuFWG+y2sxOXAzmJt81 gotest.tools/v3 v3.0.2/go.mod h1:3SzNCllyD9/Y+b5r9JIKQ474KzkZyqLqEfYqMsX94Bk= gotest.tools/v3 v3.0.3/go.mod h1:Z7Lb0S5l+klDB31fvDQX8ss/FlKDxtlFlw3Oa8Ymbl8= gotest.tools/v3 v3.5.0 h1:Ljk6PdHdOhAb5aDMWXjDLMMhph+BpztA4v1QdqEW2eY= +gotest.tools/v3 v3.5.0/go.mod h1:isy3WKz7GK6uNw/sbHzfKBLvlvXwUyV06n6brMxxopU= honnef.co/go/tools v0.0.0-20180728063816-88497007e858/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=