Documentation ¶
Index ¶
- Constants
- type AccessControlResponse
- type AllPurposeInstanceGroupDetailsResponse
- func (m *AllPurposeInstanceGroupDetailsResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *AllPurposeInstanceGroupDetailsResponse) MarshalBinary() ([]byte, error)
- func (m *AllPurposeInstanceGroupDetailsResponse) UnmarshalBinary(b []byte) error
- func (m *AllPurposeInstanceGroupDetailsResponse) Validate(formats strfmt.Registry) error
- type Backup
- type BackupContentOptions
- type CancelBackupRequest
- type CancelBackupResponse
- type ChartValueOverridesRequest
- func (m *ChartValueOverridesRequest) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *ChartValueOverridesRequest) MarshalBinary() ([]byte, error)
- func (m *ChartValueOverridesRequest) UnmarshalBinary(b []byte) error
- func (m *ChartValueOverridesRequest) Validate(formats strfmt.Registry) error
- type ChartValueOverridesResponse
- func (m *ChartValueOverridesResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *ChartValueOverridesResponse) MarshalBinary() ([]byte, error)
- func (m *ChartValueOverridesResponse) UnmarshalBinary(b []byte) error
- func (m *ChartValueOverridesResponse) Validate(formats strfmt.Registry) error
- type CreateBackupRequest
- type CreateBackupResponse
- type CreateVcRequest
- type CreateVcResponse
- type CustomAzureFilesConfigs
- func (m *CustomAzureFilesConfigs) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *CustomAzureFilesConfigs) MarshalBinary() ([]byte, error)
- func (m *CustomAzureFilesConfigs) UnmarshalBinary(b []byte) error
- func (m *CustomAzureFilesConfigs) Validate(formats strfmt.Registry) error
- type DeleteBackupRequest
- type DeleteBackupResponse
- type DeleteVcRequest
- type DeleteVcResponse
- type DescribeBackupRequest
- type DescribeBackupResponse
- func (m *DescribeBackupResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *DescribeBackupResponse) MarshalBinary() ([]byte, error)
- func (m *DescribeBackupResponse) UnmarshalBinary(b []byte) error
- func (m *DescribeBackupResponse) Validate(formats strfmt.Registry) error
- type DescribeServiceRequest
- func (m *DescribeServiceRequest) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *DescribeServiceRequest) MarshalBinary() ([]byte, error)
- func (m *DescribeServiceRequest) UnmarshalBinary(b []byte) error
- func (m *DescribeServiceRequest) Validate(formats strfmt.Registry) error
- type DescribeServiceResponse
- func (m *DescribeServiceResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *DescribeServiceResponse) MarshalBinary() ([]byte, error)
- func (m *DescribeServiceResponse) UnmarshalBinary(b []byte) error
- func (m *DescribeServiceResponse) Validate(formats strfmt.Registry) error
- type DescribeVcRequest
- type DescribeVcResponse
- type DisableServiceRequest
- type DisableServiceResponse
- func (m *DisableServiceResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *DisableServiceResponse) MarshalBinary() ([]byte, error)
- func (m *DisableServiceResponse) UnmarshalBinary(b []byte) error
- func (m *DisableServiceResponse) Validate(formats strfmt.Registry) error
- type EnableServiceRequest
- type EnableServiceResponse
- type Error
- type GetBackupLogsRequest
- type GetBackupLogsResponse
- type GetKubeconfigRequest
- type GetKubeconfigResponse
- type GetServiceInitLogsRequest
- func (m *GetServiceInitLogsRequest) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *GetServiceInitLogsRequest) MarshalBinary() ([]byte, error)
- func (m *GetServiceInitLogsRequest) UnmarshalBinary(b []byte) error
- func (m *GetServiceInitLogsRequest) Validate(formats strfmt.Registry) error
- type GetServiceInitLogsResponse
- func (m *GetServiceInitLogsResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *GetServiceInitLogsResponse) MarshalBinary() ([]byte, error)
- func (m *GetServiceInitLogsResponse) UnmarshalBinary(b []byte) error
- func (m *GetServiceInitLogsResponse) Validate(formats strfmt.Registry) error
- type ListBackupsRequest
- type ListBackupsResponse
- type ListServicesRequest
- type ListServicesResponse
- type ListVcsRequest
- type ListVcsResponse
- type Order
- type RestoreServiceRequest
- type RestoreServiceResponse
- func (m *RestoreServiceResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
- func (m *RestoreServiceResponse) MarshalBinary() ([]byte, error)
- func (m *RestoreServiceResponse) UnmarshalBinary(b []byte) error
- func (m *RestoreServiceResponse) Validate(formats strfmt.Registry) error
- type SMTPConfigRequest
- type SMTPConfigResponse
- type ServiceDescription
- type ServiceResources
- type ServiceSummary
- type UpdateServiceRequest
- type UpdateServiceResponse
- type UpdateVcRequest
- type UpdateVcResponse
- type VcDescription
- type VcResources
- type VcSummary
Constants ¶
const ( // CreateVcRequestRuntimeSpotComponentALL captures enum value "ALL" CreateVcRequestRuntimeSpotComponentALL string = "ALL" // CreateVcRequestRuntimeSpotComponentNONE captures enum value "NONE" CreateVcRequestRuntimeSpotComponentNONE string = "NONE" )
const ( // CreateVcRequestSparkVersionSPARK2 captures enum value "SPARK2" CreateVcRequestSparkVersionSPARK2 string = "SPARK2" // CreateVcRequestSparkVersionSPARK24 captures enum value "SPARK2_4" CreateVcRequestSparkVersionSPARK24 string = "SPARK2_4" // CreateVcRequestSparkVersionSPARK3 captures enum value "SPARK3" CreateVcRequestSparkVersionSPARK3 string = "SPARK3" // CreateVcRequestSparkVersionSPARK30 captures enum value "SPARK3_0" CreateVcRequestSparkVersionSPARK30 string = "SPARK3_0" // CreateVcRequestSparkVersionSPARK31 captures enum value "SPARK3_1" CreateVcRequestSparkVersionSPARK31 string = "SPARK3_1" // CreateVcRequestSparkVersionSPARK32 captures enum value "SPARK3_2" CreateVcRequestSparkVersionSPARK32 string = "SPARK3_2" // CreateVcRequestSparkVersionSPARK33 captures enum value "SPARK3_3" CreateVcRequestSparkVersionSPARK33 string = "SPARK3_3" // CreateVcRequestSparkVersionSPARK35 captures enum value "SPARK3_5" CreateVcRequestSparkVersionSPARK35 string = "SPARK3_5" )
const ( // CreateVcRequestVcTierALLP captures enum value "ALLP" CreateVcRequestVcTierALLP string = "ALLP" // CreateVcRequestVcTierCORE captures enum value "CORE" CreateVcRequestVcTierCORE string = "CORE" )
const ( // EnableServiceRequestNetworkOutboundTypeUDR captures enum value "UDR" EnableServiceRequestNetworkOutboundTypeUDR string = "UDR" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AccessControlResponse ¶
type AccessControlResponse struct { // Groups with full access. FullAccessGroups []string `json:"fullAccessGroups"` // Users with full access. FullAccessUsers []string `json:"fullAccessUsers"` // Workload usernames of CDP users granted access to the Virtual Cluster. Users []string `json:"users"` // Groups with view only access. ViewOnlyGroups []string `json:"viewOnlyGroups"` // Users with view only access. ViewOnlyUsers []string `json:"viewOnlyUsers"` }
AccessControlResponse Response object containing access control information for a Virtual Cluster.
swagger:model AccessControlResponse
func (*AccessControlResponse) ContextValidate ¶
ContextValidate validates this access control response based on context it is used
func (*AccessControlResponse) MarshalBinary ¶
func (m *AccessControlResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*AccessControlResponse) UnmarshalBinary ¶
func (m *AccessControlResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type AllPurposeInstanceGroupDetailsResponse ¶ added in v0.6.3
type AllPurposeInstanceGroupDetailsResponse struct { // Initial number of Instances when the service is enabled. InitialInstances string `json:"initial_instances,omitempty"` // Initial number of spot Instances when the service is enabled. InitialSpotInstances string `json:"initial_spot_instances,omitempty"` // Instance type of the cluster for CDE Service. InstanceType string `json:"instance_type,omitempty"` // Maximum number of Instances for the CDE Service. MaxInstances string `json:"max_instances,omitempty"` // Maximum number of Spot Instances for the CDE Service. MaxSpotInstances string `json:"max_spot_instances,omitempty"` // Minimum number of Instances for the CDE Service. MinInstances string `json:"min_instances,omitempty"` // Minimum number of Spot instances for the CDE Service. MinSpotInstances string `json:"min_spot_instances,omitempty"` // EBS volume size in GB. RootVolSize string `json:"root_vol_size,omitempty"` }
AllPurposeInstanceGroupDetailsResponse Instance group details for the All purpose Tier.
swagger:model AllPurposeInstanceGroupDetailsResponse
func (*AllPurposeInstanceGroupDetailsResponse) ContextValidate ¶ added in v0.6.3
func (m *AllPurposeInstanceGroupDetailsResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this all purpose instance group details response based on context it is used
func (*AllPurposeInstanceGroupDetailsResponse) MarshalBinary ¶ added in v0.6.3
func (m *AllPurposeInstanceGroupDetailsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*AllPurposeInstanceGroupDetailsResponse) UnmarshalBinary ¶ added in v0.6.3
func (m *AllPurposeInstanceGroupDetailsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type Backup ¶
type Backup struct { // The path to the base location where the backups are stored. ArchiveBasePath string `json:"archiveBasePath,omitempty"` // Archive location under the base path. ArchiveLocation string `json:"archiveLocation,omitempty"` // The cloud platform where a backed-up CDE service was enabled. // Required: true CloudPlatform *string `json:"cloudPlatform"` // The time when the backup was created. // Required: true Created *string `json:"created"` // The workload name of the user who created this backup. // Required: true Creator *string `json:"creator"` // CRN of of the user who created this backup. // Required: true CreatorCrn *string `json:"creatorCrn"` // Backup description. Description string `json:"description,omitempty"` // CRN of CDP environment with which a backed-up CDE service was associated. // Required: true EnvironmentCrn *string `json:"environmentCrn"` // Name of CDP environment with which a backed-up CDE service was associated. // Required: true EnvironmentName *string `json:"environmentName"` // Error message, only set when there is an error. ErrorMessage string `json:"errorMessage,omitempty"` // Backup ID. // Required: true ID *int64 `json:"id"` // Service ID of a backed-up CDE service. // Required: true ServiceID *string `json:"serviceID"` // Name of a backed-up CDE service. // Required: true ServiceName *string `json:"serviceName"` // Version of a backed-up CDE service. // Required: true ServiceVersion *string `json:"serviceVersion"` // Backup status. // Required: true Status *string `json:"status"` }
Backup Service backup object.
swagger:model Backup
func (*Backup) ContextValidate ¶
ContextValidate validates this backup based on context it is used
func (*Backup) MarshalBinary ¶
MarshalBinary interface implementation
func (*Backup) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type BackupContentOptions ¶
type BackupContentOptions struct { // Filter credentials for backup using 'fieldname(operator)argument' syntax. Here, 'fieldname' is one of the credential fields (e.g. name, type, etc.), and 'operator' is one of ('eq', 'noteq', 'lte', 'lt', 'gte', 'gt', 'in', 'notin', 'like', 'rlike', 'is', 'isnot'). Multiple filters are ANDed. For example, 'name(eq)test-credential'. This will only take effect if credentials are backed up, as controlled by the 'includeCredentials' option. CredentialFilter []string `json:"credentialFilter"` // Whether to backup credential secrets. Secrets are obfuscated while storing. By default, credential secrets are backed up. IncludeCredentialSecrets *bool `json:"includeCredentialSecrets,omitempty"` // Whether to backup credentials. By default, credentials are backed up. IncludeCredentials *bool `json:"includeCredentials,omitempty"` // Whether to backup job resources. By default, job resources are backed up. IncludeJobResources *bool `json:"includeJobResources,omitempty"` // Whether to backup jobs. By default, jobs are backed up. IncludeJobs *bool `json:"includeJobs,omitempty"` // Whether to backup resource credentials. By default, resource credentials are backed up. IncludeResourceCredentials *bool `json:"includeResourceCredentials,omitempty"` // Whether to backup resources. By default, resources are backed up. IncludeResources *bool `json:"includeResources,omitempty"` // Filter jobs for backup using 'fieldname(operator)argument' syntax. Here, 'fieldname' is one of the job fields (e.g. name, type, etc.), and 'operator' is one of ('eq', 'noteq', 'lte', 'lt', 'gte', 'gt', 'in', 'notin', 'like', 'rlike', 'is', 'isnot'). Multiple filters are ANDed. For example, 'name(eq)SparkPi'. This will only take effect if jobs are backed up, as controlled by the 'includeJobs' option. JobFilter []string `json:"jobFilter"` // Filter resources for backup using 'fieldname(operator)argument' syntax. Here, 'fieldname' is one of the resource fields (e.g. name, type, status, etc.), and 'operator' is one of ('eq', 'noteq', 'lte', 'lt', 'gte', 'gt', 'in', 'notin', 'like', 'rlike', 'is', 'isnot'). Multiple filters are ANDed. For example, 'name(eq)test-resource'. This will only take effect if resources are backed up, as controlled by the 'includeResources' option. ResourceFilter []string `json:"resourceFilter"` // Whether to validate backup archive. By default, backup archive is not validated. ValidateArchive *bool `json:"validateArchive,omitempty"` }
BackupContentOptions Backup virtual cluster content options.
swagger:model BackupContentOptions
func (*BackupContentOptions) ContextValidate ¶
ContextValidate validates this backup content options based on context it is used
func (*BackupContentOptions) MarshalBinary ¶
func (m *BackupContentOptions) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*BackupContentOptions) UnmarshalBinary ¶
func (m *BackupContentOptions) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type CancelBackupRequest ¶
type CancelBackupRequest struct { // The ID of the backup to cancel. // Required: true BackupID *int64 `json:"backupID"` }
CancelBackupRequest Request object for Cancel Backup command.
swagger:model CancelBackupRequest
func (*CancelBackupRequest) ContextValidate ¶
ContextValidate validates this cancel backup request based on context it is used
func (*CancelBackupRequest) MarshalBinary ¶
func (m *CancelBackupRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*CancelBackupRequest) UnmarshalBinary ¶
func (m *CancelBackupRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type CancelBackupResponse ¶
type CancelBackupResponse interface{}
CancelBackupResponse Response object for Cancel Backup command.
swagger:model CancelBackupResponse
type ChartValueOverridesRequest ¶
type ChartValueOverridesRequest struct { // Name of the chart that has to be overridden, for eg- "dex-app", "dex-base". ChartName string `json:"chartName,omitempty"` // Space separated key-value pairs for overriding chart values. The key and the value must be separated using a colon(:) For eg- "airflow.enabled:true safari.enabled:true". Overrides string `json:"overrides,omitempty"` }
ChartValueOverridesRequest Object containing chart value overrides for enabling a CDE service or creation of virtual clusters.
swagger:model ChartValueOverridesRequest
func (*ChartValueOverridesRequest) ContextValidate ¶
func (m *ChartValueOverridesRequest) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this chart value overrides request based on context it is used
func (*ChartValueOverridesRequest) MarshalBinary ¶
func (m *ChartValueOverridesRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ChartValueOverridesRequest) UnmarshalBinary ¶
func (m *ChartValueOverridesRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ChartValueOverridesResponse ¶
type ChartValueOverridesResponse struct { // Name of the chart that has to be overridden, for eg- "dex-app", "dex-base". ChartName string `json:"chartName,omitempty"` // Space separated key value-pairs for overriding chart values. The key and the value must be separated using a colon(:) For eg- "airflow.enabled:true safari.enabled:true". Overrides string `json:"overrides,omitempty"` }
ChartValueOverridesResponse Response object containing chart value overrides.
swagger:model ChartValueOverridesResponse
func (*ChartValueOverridesResponse) ContextValidate ¶
func (m *ChartValueOverridesResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this chart value overrides response based on context it is used
func (*ChartValueOverridesResponse) MarshalBinary ¶
func (m *ChartValueOverridesResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ChartValueOverridesResponse) UnmarshalBinary ¶
func (m *ChartValueOverridesResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type CreateBackupRequest ¶
type CreateBackupRequest struct { // Backup file relative path. The path should not include file name, and be relative to the service backup location. The service backup location can be found in the service description obtained via the 'describe-service' command. BackupPath string `json:"backupPath,omitempty"` // Backup virtual cluster content options. BackupVcContentOptions *BackupContentOptions `json:"backupVcContentOptions,omitempty"` // Backup description. Description string `json:"description,omitempty"` // Whether to backup service virtual clusters. By default, virtual clusters are backed up. IncludeVc *bool `json:"includeVc,omitempty"` // Service ID of the service to backup. // Required: true ServiceID *string `json:"serviceId"` // Backup operation timeout in seconds. Timeout int32 `json:"timeout,omitempty"` }
CreateBackupRequest Request object for Create Backup command.
swagger:model CreateBackupRequest
func (*CreateBackupRequest) ContextValidate ¶
ContextValidate validate this create backup request based on the context it is used
func (*CreateBackupRequest) MarshalBinary ¶
func (m *CreateBackupRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*CreateBackupRequest) UnmarshalBinary ¶
func (m *CreateBackupRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type CreateBackupResponse ¶
type CreateBackupResponse struct { // Backup ID, which can be used for log retrieval, restoration, deletion, and backup cancellation. // Required: true BackupID *int64 `json:"backupID"` }
CreateBackupResponse Response object for Create Backup command.
swagger:model CreateBackupResponse
func (*CreateBackupResponse) ContextValidate ¶
ContextValidate validates this create backup response based on context it is used
func (*CreateBackupResponse) MarshalBinary ¶
func (m *CreateBackupResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*CreateBackupResponse) UnmarshalBinary ¶
func (m *CreateBackupResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type CreateVcRequest ¶
type CreateVcRequest struct { // Comma-separated Workload usernames of CDP users to be granted access to the Virtual Cluster. ACLUsers string `json:"aclUsers,omitempty"` // Chart overrides for creating a virtual cluster. ChartValueOverrides []*ChartValueOverridesRequest `json:"chartValueOverrides"` // Cluster id of the CDE service where virtual cluster has to be created. // Required: true ClusterID *string `json:"clusterId"` // Cpu requests for autoscaling. // Required: true CPURequests *string `json:"cpuRequests"` // Groups with full access. FullAccessGroups []string `json:"fullAccessGroups"` // Users with full access. FullAccessUsers []string `json:"fullAccessUsers"` // GPU requests for autoscaling. GpuRequests string `json:"gpuRequests,omitempty"` // Guaranteed CPU requests for an Elastic Virtual Cluster. GuaranteedCPURequests string `json:"guaranteedCpuRequests,omitempty"` // Guaranteed GPU requests for an Elastic Virtual Cluster. GuaranteedGpuRequests string `json:"guaranteedGpuRequests,omitempty"` // Guaranteed Memory requests for an Elastic Virtual Cluster - eg. 30Gi. GuaranteedMemoryRequests string `json:"guaranteedMemoryRequests,omitempty"` // Memory requests for autoscaling - eg. 30Gi. // Required: true MemoryRequests *string `json:"memoryRequests"` // Name of the virtual cluster. // Required: true Name *string `json:"name"` // Used to describe where the Driver and the Executors would run. By default the Driver would run on on-demand instances and the Executors on spot instances. Setting it to ALL will run both the Driver and the Executors on spot instances whereas setting it to NONE should run both the Driver and the Executor on on-demand instances. Currently applicable for aws services only. Use this option only on services with spot instances enabled. // Enum: ["ALL","NONE"] RuntimeSpotComponent string `json:"runtimeSpotComponent,omitempty"` // Set a default timeout for your sessions. The default option is 8 hours. This option can be overridden when creating a new session. SessionTimeout string `json:"sessionTimeout,omitempty"` // SMTP Configurations for Airflow Email Alerts. SMTPConfigs *SMTPConfigRequest `json:"smtpConfigs,omitempty"` // Spark version for the virtual cluster. Currently supported Spark versions are SPARK2(deprecated), SPARK3, SPARK3_3 and SPARK3_5. This feature is only supported in CDE-1.7.0 and later. SPARK3_3 is supported in CDE-1.19 and later. SPARK3_5 is supported in CDE-1.21 and later. // Enum: ["SPARK2","SPARK2_4","SPARK3","SPARK3_0","SPARK3_1","SPARK3_2","SPARK3_3","SPARK3_5"] SparkVersion string `json:"sparkVersion,omitempty"` // Tier of the virtual cluster. Currently supported tiers are CORE and ALLP. CORE tiered virtual cluster enables operational deployment via batch jobs. ALLP virtual clusters are all-purpose virtual clusters supporting both operational batch jobs and interactive sessions. This feature is only supported in CDE-1.19.0 and beyond. // Enum: ["ALLP","CORE"] VcTier string `json:"vcTier,omitempty"` // Groups with view only access. ViewOnlyGroups []string `json:"viewOnlyGroups"` // Users with view only access. ViewOnlyUsers []string `json:"viewOnlyUsers"` }
CreateVcRequest Request object for CreateVc method.
swagger:model CreateVcRequest
func (*CreateVcRequest) ContextValidate ¶
ContextValidate validate this create vc request based on the context it is used
func (*CreateVcRequest) MarshalBinary ¶
func (m *CreateVcRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*CreateVcRequest) UnmarshalBinary ¶
func (m *CreateVcRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type CreateVcResponse ¶
type CreateVcResponse struct { // Created Virtual Cluster Vc *VcDescription `json:"Vc,omitempty"` }
CreateVcResponse Response object for CreateVc method.
swagger:model CreateVcResponse
func (*CreateVcResponse) ContextValidate ¶
ContextValidate validate this create vc response based on the context it is used
func (*CreateVcResponse) MarshalBinary ¶
func (m *CreateVcResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*CreateVcResponse) UnmarshalBinary ¶
func (m *CreateVcResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type CustomAzureFilesConfigs ¶
type CustomAzureFilesConfigs struct { // Azure File Share's server address. Defaults to '<storageaccount>.file.core.windows.net'. AzureFilesFQDN string `json:"azureFilesFQDN,omitempty"` // Resource Group of the Storage Account. // Required: true ResourceGroup *string `json:"resourceGroup"` // Azure Storage Account of the File Share. // Required: true StorageAccountName *string `json:"storageAccountName"` }
CustomAzureFilesConfigs Override Azure Files Configs.
swagger:model CustomAzureFilesConfigs
func (*CustomAzureFilesConfigs) ContextValidate ¶
func (m *CustomAzureFilesConfigs) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this custom azure files configs based on context it is used
func (*CustomAzureFilesConfigs) MarshalBinary ¶
func (m *CustomAzureFilesConfigs) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*CustomAzureFilesConfigs) UnmarshalBinary ¶
func (m *CustomAzureFilesConfigs) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DeleteBackupRequest ¶
type DeleteBackupRequest struct { // The ID of the backup to delete. // Required: true BackupID *int64 `json:"backupID"` }
DeleteBackupRequest Request object for Delete Backup command.
swagger:model DeleteBackupRequest
func (*DeleteBackupRequest) ContextValidate ¶
ContextValidate validates this delete backup request based on context it is used
func (*DeleteBackupRequest) MarshalBinary ¶
func (m *DeleteBackupRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DeleteBackupRequest) UnmarshalBinary ¶
func (m *DeleteBackupRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DeleteBackupResponse ¶
type DeleteBackupResponse interface{}
DeleteBackupResponse Response object for Delete Backup command.
swagger:model DeleteBackupResponse
type DeleteVcRequest ¶
type DeleteVcRequest struct { // Cluster id of the CDE service where virtual cluster was enabled. // Required: true ClusterID *string `json:"clusterId"` // Virtual cluster id // Required: true VcID *string `json:"vcId"` }
DeleteVcRequest Request object for DeleteVc method.
swagger:model DeleteVcRequest
func (*DeleteVcRequest) ContextValidate ¶
ContextValidate validates this delete vc request based on context it is used
func (*DeleteVcRequest) MarshalBinary ¶
func (m *DeleteVcRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DeleteVcRequest) UnmarshalBinary ¶
func (m *DeleteVcRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DeleteVcResponse ¶
type DeleteVcResponse struct { // status of virtual cluster deletion. Status string `json:"status,omitempty"` }
DeleteVcResponse Response object for DeleteVc method.
swagger:model DeleteVcResponse
func (*DeleteVcResponse) ContextValidate ¶
ContextValidate validates this delete vc response based on context it is used
func (*DeleteVcResponse) MarshalBinary ¶
func (m *DeleteVcResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DeleteVcResponse) UnmarshalBinary ¶
func (m *DeleteVcResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DescribeBackupRequest ¶
type DescribeBackupRequest struct { // The ID of the backup to describe. // Required: true BackupID *int64 `json:"backupID"` }
DescribeBackupRequest Request object for Describe Backup command.
swagger:model DescribeBackupRequest
func (*DescribeBackupRequest) ContextValidate ¶
ContextValidate validates this describe backup request based on context it is used
func (*DescribeBackupRequest) MarshalBinary ¶
func (m *DescribeBackupRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DescribeBackupRequest) UnmarshalBinary ¶
func (m *DescribeBackupRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DescribeBackupResponse ¶
type DescribeBackupResponse struct { // Service backup. // Required: true Backup *Backup `json:"backup"` }
DescribeBackupResponse Response object for Describe Backup command.
swagger:model DescribeBackupResponse
func (*DescribeBackupResponse) ContextValidate ¶
func (m *DescribeBackupResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validate this describe backup response based on the context it is used
func (*DescribeBackupResponse) MarshalBinary ¶
func (m *DescribeBackupResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DescribeBackupResponse) UnmarshalBinary ¶
func (m *DescribeBackupResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DescribeServiceRequest ¶
type DescribeServiceRequest struct { // Cluster id of the service to be described. // Required: true ClusterID *string `json:"clusterId"` }
DescribeServiceRequest Request object for DescribeService method.
swagger:model DescribeServiceRequest
func (*DescribeServiceRequest) ContextValidate ¶
func (m *DescribeServiceRequest) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this describe service request based on context it is used
func (*DescribeServiceRequest) MarshalBinary ¶
func (m *DescribeServiceRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DescribeServiceRequest) UnmarshalBinary ¶
func (m *DescribeServiceRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DescribeServiceResponse ¶
type DescribeServiceResponse struct { // Description of the service Service *ServiceDescription `json:"service,omitempty"` }
DescribeServiceResponse Response object for DescribeService method.
swagger:model DescribeServiceResponse
func (*DescribeServiceResponse) ContextValidate ¶
func (m *DescribeServiceResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validate this describe service response based on the context it is used
func (*DescribeServiceResponse) MarshalBinary ¶
func (m *DescribeServiceResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DescribeServiceResponse) UnmarshalBinary ¶
func (m *DescribeServiceResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DescribeVcRequest ¶
type DescribeVcRequest struct { // Cluster id of the CDE service where vc was created. // Required: true ClusterID *string `json:"clusterId"` // Virtual cluster id. // Required: true VcID *string `json:"vcId"` }
DescribeVcRequest DescribeVc request object.
swagger:model DescribeVcRequest
func (*DescribeVcRequest) ContextValidate ¶
ContextValidate validates this describe vc request based on context it is used
func (*DescribeVcRequest) MarshalBinary ¶
func (m *DescribeVcRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DescribeVcRequest) UnmarshalBinary ¶
func (m *DescribeVcRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DescribeVcResponse ¶
type DescribeVcResponse struct { // Description of the virtual cluster. Vc *VcDescription `json:"vc,omitempty"` }
DescribeVcResponse DescribeVc response object.
swagger:model DescribeVcResponse
func (*DescribeVcResponse) ContextValidate ¶
ContextValidate validate this describe vc response based on the context it is used
func (*DescribeVcResponse) MarshalBinary ¶
func (m *DescribeVcResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DescribeVcResponse) UnmarshalBinary ¶
func (m *DescribeVcResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DisableServiceRequest ¶
type DisableServiceRequest struct { // cluster Id of the service to disable. // Required: true ClusterID *string `json:"clusterId"` // Force disable cde service. Force *bool `json:"force,omitempty"` }
DisableServiceRequest DisableService request object.
swagger:model DisableServiceRequest
func (*DisableServiceRequest) ContextValidate ¶
ContextValidate validates this disable service request based on context it is used
func (*DisableServiceRequest) MarshalBinary ¶
func (m *DisableServiceRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DisableServiceRequest) UnmarshalBinary ¶
func (m *DisableServiceRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type DisableServiceResponse ¶
type DisableServiceResponse struct { // Status of deletion Status string `json:"status,omitempty"` }
DisableServiceResponse DisableService response object.
swagger:model DisableServiceResponse
func (*DisableServiceResponse) ContextValidate ¶
func (m *DisableServiceResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this disable service response based on context it is used
func (*DisableServiceResponse) MarshalBinary ¶
func (m *DisableServiceResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*DisableServiceResponse) UnmarshalBinary ¶
func (m *DisableServiceResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type EnableServiceRequest ¶
type EnableServiceRequest struct { // Initial Instances when the service is enabled for the All Purpose Instance Group. AllPurposeInitialInstances int32 `json:"allPurposeInitialInstances,omitempty"` // Initial spot Instances when the service is enabled for the All Purpose Instance Group. AllPurposeInitialSpotInstances int32 `json:"allPurposeInitialSpotInstances,omitempty"` // Instance type of the cluster for CDE Service for the All Purpose Instance Group. AllPurposeInstanceType string `json:"allPurposeInstanceType,omitempty"` // Maximum Instances for the CDE Service for the All Purpose Instance Group. AllPurposeMaximumInstances int32 `json:"allPurposeMaximumInstances,omitempty"` // Maximum Spot Instances for the CDE Service for the All Purpose Instance Group. AllPurposeMaximumSpotInstances int32 `json:"allPurposeMaximumSpotInstances,omitempty"` // Minimum Instances for the CDE Service for the All Purpose Instance Group. AllPurposeMinimumInstances int32 `json:"allPurposeMinimumInstances,omitempty"` // Minimum Spot instances for the CDE Service for the All Purpose Instance Group. AllPurposeMinimumSpotInstances int32 `json:"allPurposeMinimumSpotInstances,omitempty"` // EBS volume size in GB for the All Purpose Instance Group. AllPurposeRootVolumeSize int32 `json:"allPurposeRootVolumeSize,omitempty"` // Chart overrides for enabling a service. ChartValueOverrides []*ChartValueOverridesRequest `json:"chartValueOverrides"` // CPU Requests for the entire CDE service quota. CPURequests string `json:"cpuRequests,omitempty"` // CDE uses a default public File Shares storage provisioned by AKS. Enable this option to use your own public/private File Shares. CustomAzureFilesConfigs *CustomAzureFilesConfigs `json:"customAzureFilesConfigs,omitempty"` // If set to "true", the previous version of the CDE service will be deployed. DeployPreviousVersion *bool `json:"deployPreviousVersion,omitempty"` // Create a fully private CDE instance on either Amazon or Azure. This includes services such as Kubernetes, MySQL, etc. For Azure, this will also enable virtual network (VNet) access via private endpoints and private link. EnablePrivateNetwork bool `json:"enablePrivateNetwork,omitempty"` // Creates a CDE endpoint (Load Balancer) in a publicly accessible subnet. If set false, the endpoint will be created in a private subnet and you will need to setup access to the endpoint manually in your cloud account. EnablePublicEndpoint *bool `json:"enablePublicEndpoint,omitempty"` // If set false, diagnostic information about job and query execution is sent to Cloudera Workload Manager. Anonymization can be configured under Environments / Shared Resources / Telemetry. Refer documentation for more info at https://docs.cloudera.com/workload-manager/cloud/index.html. EnableWorkloadAnalytics *bool `json:"enableWorkloadAnalytics,omitempty"` // CDP environment where cde service should be enabled. // Required: true Env *string `json:"env"` // GPU requests for the entire CDE service quota. GpuRequests string `json:"gpuRequests,omitempty"` // Initial Instances when the service is enabled. InitialInstances int32 `json:"initialInstances,omitempty"` // Initial spot Instances when the service is enabled. InitialSpotInstances int32 `json:"initialSpotInstances,omitempty"` // Instance type of the cluster for CDE Service. // Required: true InstanceType *string `json:"instanceType"` // List of CIDRs that would be allowed to access the load balancer. LoadbalancerAllowlist []string `json:"loadbalancerAllowlist"` // Maximum Instances for the CDE Service. // Required: true MaximumInstances *int32 `json:"maximumInstances"` // Maximum Spot Instances for the CDE Service. MaximumSpotInstances int32 `json:"maximumSpotInstances,omitempty"` // Memory requests for the entire CDE service quota, eg. 100Gi. MemoryRequests string `json:"memoryRequests,omitempty"` // Minimum Instances for the CDE Service. // Required: true MinimumInstances *int32 `json:"minimumInstances"` // Minimum Spot instances for the CDE Service. MinimumSpotInstances int32 `json:"minimumSpotInstances,omitempty"` // Name of the CDE Service. // Required: true Name *string `json:"name"` // Network outbound type. Currently 'udr' is the only supported. // Enum: ["UDR"] NetworkOutboundType string `json:"networkOutboundType,omitempty"` // NFS Storage class to override the default storage class in private cloud. NfsStorageClass string `json:"nfsStorageClass,omitempty"` // Resource Pool for the CDE service. ResourcePool string `json:"resourcePool,omitempty"` // EBS volume size in GB. RootVolumeSize int32 `json:"rootVolumeSize,omitempty"` // Skip Validation check. SkipValidation *bool `json:"skipValidation,omitempty"` // List of Subnet IDs of CDP subnets to use for the kubernetes worker node. Subnets []string `json:"subnets"` // User defined labels that tag all provisioned cloud resources. Tags map[string]string `json:"tags,omitempty"` // Instance local storage (SSD) would be used for the workload filesystem (Example - spark local directory). In case the workload requires more space than what's available in the instance storage, please use an instance type with sufficient instance local storage or choose an instance type without SSD and configure the EBS volume size. Currently supported only for aws services. UseSsd bool `json:"useSsd,omitempty"` // List of CIDRs that would be allowed to access kubernetes master API server. WhitelistIps []string `json:"whitelistIps"` }
EnableServiceRequest Request object for Enable Service method.
swagger:model EnableServiceRequest
func (*EnableServiceRequest) ContextValidate ¶
ContextValidate validate this enable service request based on the context it is used
func (*EnableServiceRequest) MarshalBinary ¶
func (m *EnableServiceRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*EnableServiceRequest) UnmarshalBinary ¶
func (m *EnableServiceRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type EnableServiceResponse ¶
type EnableServiceResponse struct { // Service details of the created service. Service *ServiceDescription `json:"service,omitempty"` }
EnableServiceResponse Response object for EnableService request.
swagger:model EnableServiceResponse
func (*EnableServiceResponse) ContextValidate ¶
ContextValidate validate this enable service response based on the context it is used
func (*EnableServiceResponse) MarshalBinary ¶
func (m *EnableServiceResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*EnableServiceResponse) UnmarshalBinary ¶
func (m *EnableServiceResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type Error ¶
type Error struct { // The error code. Code string `json:"code,omitempty"` // The error message. Message string `json:"message,omitempty"` }
Error An object returned on an error.
swagger:model Error
func (*Error) ContextValidate ¶
ContextValidate validates this error based on context it is used
func (*Error) MarshalBinary ¶
MarshalBinary interface implementation
func (*Error) UnmarshalBinary ¶
UnmarshalBinary interface implementation
type GetBackupLogsRequest ¶
type GetBackupLogsRequest struct { // The ID of the backup. // Required: true BackupID *int64 `json:"backupID"` // The size of each page. // Maximum: 1000 // Minimum: 1 PageSize int32 `json:"pageSize,omitempty"` // A token to specify where to start paginating. This is the nextToken from a previously truncated response. StartingToken string `json:"startingToken,omitempty"` }
GetBackupLogsRequest Request object for Get Backup Logs command.
swagger:model GetBackupLogsRequest
func (*GetBackupLogsRequest) ContextValidate ¶
ContextValidate validates this get backup logs request based on context it is used
func (*GetBackupLogsRequest) MarshalBinary ¶
func (m *GetBackupLogsRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetBackupLogsRequest) UnmarshalBinary ¶
func (m *GetBackupLogsRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type GetBackupLogsResponse ¶
type GetBackupLogsResponse struct { // Contains the logs of the backup operation. // Required: true Logs []string `json:"logs"` // The token to use when requesting the next set of results. If there are no additional results, the string is empty. NextToken string `json:"nextToken,omitempty"` }
GetBackupLogsResponse Response object for the Get Backup Logs command.
swagger:model GetBackupLogsResponse
func (*GetBackupLogsResponse) ContextValidate ¶
ContextValidate validates this get backup logs response based on context it is used
func (*GetBackupLogsResponse) MarshalBinary ¶
func (m *GetBackupLogsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetBackupLogsResponse) UnmarshalBinary ¶
func (m *GetBackupLogsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type GetKubeconfigRequest ¶
type GetKubeconfigRequest struct { // cluster id of the cde service. // Required: true ClusterID *string `json:"clusterId"` }
GetKubeconfigRequest GetKubeconfig request object.
swagger:model GetKubeconfigRequest
func (*GetKubeconfigRequest) ContextValidate ¶
ContextValidate validates this get kubeconfig request based on context it is used
func (*GetKubeconfigRequest) MarshalBinary ¶
func (m *GetKubeconfigRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetKubeconfigRequest) UnmarshalBinary ¶
func (m *GetKubeconfigRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type GetKubeconfigResponse ¶
type GetKubeconfigResponse struct { // kubeconfig for the cluster. Kubeconfig string `json:"kubeconfig,omitempty"` }
GetKubeconfigResponse GetKubeconfig response object.
swagger:model GetKubeconfigResponse
func (*GetKubeconfigResponse) ContextValidate ¶
ContextValidate validates this get kubeconfig response based on context it is used
func (*GetKubeconfigResponse) MarshalBinary ¶
func (m *GetKubeconfigResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetKubeconfigResponse) UnmarshalBinary ¶
func (m *GetKubeconfigResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type GetServiceInitLogsRequest ¶
type GetServiceInitLogsRequest struct { // The size of each page. // Maximum: 500 // Minimum: 1 PageSize int32 `json:"pageSize,omitempty"` // The service ID of the service. // Required: true ServiceID *string `json:"serviceID"` // A token to specify where to start paginating. This is the nextToken from a previously truncated response. StartingToken string `json:"startingToken,omitempty"` }
GetServiceInitLogsRequest Request object for Get Service Init Logs command.
swagger:model GetServiceInitLogsRequest
func (*GetServiceInitLogsRequest) ContextValidate ¶
func (m *GetServiceInitLogsRequest) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this get service init logs request based on context it is used
func (*GetServiceInitLogsRequest) MarshalBinary ¶
func (m *GetServiceInitLogsRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetServiceInitLogsRequest) UnmarshalBinary ¶
func (m *GetServiceInitLogsRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type GetServiceInitLogsResponse ¶
type GetServiceInitLogsResponse struct { // Contains the logs of the service initialization operation. // Required: true Logs []string `json:"logs"` // The token to use when requesting the next set of results. If there are no additional results, the string is empty. NextToken string `json:"nextToken,omitempty"` }
GetServiceInitLogsResponse Response object for the Get Service Init Logs command.
swagger:model GetServiceInitLogsResponse
func (*GetServiceInitLogsResponse) ContextValidate ¶
func (m *GetServiceInitLogsResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this get service init logs response based on context it is used
func (*GetServiceInitLogsResponse) MarshalBinary ¶
func (m *GetServiceInitLogsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*GetServiceInitLogsResponse) UnmarshalBinary ¶
func (m *GetServiceInitLogsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ListBackupsRequest ¶
type ListBackupsRequest struct { // Filter backups using 'fieldname(operator)argument' syntax. Here 'fieldname' is one of ('id', 'clusterID', 'cdeVersion', 'environment', 'environmentCrn', 'created', 'status') and 'operator' is one of ('eq', 'noteq', 'lte', 'lt', 'gte', 'gt', 'in', 'notin', 'like', 'rlike', 'is', 'isnot'). Multiple filters are ANDed. For example, 'status(eq)failed'. Filter []string `json:"filter"` // Whether ordering is ascending ('ASC') or descending ('DESC'), default 'DESC'. Order Order `json:"order,omitempty"` // The 'fieldname' to order by, default "id". Here 'fieldname' is one of ('id', 'clusterID', 'cdeVersion', 'environment', 'environmentCrn', 'created', 'status'). OrderBy *string `json:"orderBy,omitempty"` // The size of each page. // Maximum: 500 // Minimum: 1 PageSize int32 `json:"pageSize,omitempty"` // A token to specify where to start paginating. This is the nextToken from a previously truncated response. StartingToken string `json:"startingToken,omitempty"` }
ListBackupsRequest Request object for List Backups command.
swagger:model ListBackupsRequest
func (*ListBackupsRequest) ContextValidate ¶
ContextValidate validate this list backups request based on the context it is used
func (*ListBackupsRequest) MarshalBinary ¶
func (m *ListBackupsRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ListBackupsRequest) UnmarshalBinary ¶
func (m *ListBackupsRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ListBackupsResponse ¶
type ListBackupsResponse struct { // The backups. // Required: true Backups []*Backup `json:"backups"` // The token to use when requesting the next set of results. If there are no additional results, the string is empty. NextToken string `json:"nextToken,omitempty"` }
ListBackupsResponse Response object for List Backups command.
swagger:model ListBackupsResponse
func (*ListBackupsResponse) ContextValidate ¶
ContextValidate validate this list backups response based on the context it is used
func (*ListBackupsResponse) MarshalBinary ¶
func (m *ListBackupsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ListBackupsResponse) UnmarshalBinary ¶
func (m *ListBackupsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ListServicesRequest ¶
type ListServicesRequest struct { // Filter out deleted CDE services from the list. RemoveDeleted *bool `json:"removeDeleted,omitempty"` }
ListServicesRequest Request object for ListServices method.
swagger:model ListServicesRequest
func (*ListServicesRequest) ContextValidate ¶
ContextValidate validates this list services request based on context it is used
func (*ListServicesRequest) MarshalBinary ¶
func (m *ListServicesRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ListServicesRequest) UnmarshalBinary ¶
func (m *ListServicesRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ListServicesResponse ¶
type ListServicesResponse struct { // List of services. Services []*ServiceSummary `json:"services"` }
ListServicesResponse Response object for ListServices method.
swagger:model ListServicesResponse
func (*ListServicesResponse) ContextValidate ¶
ContextValidate validate this list services response based on the context it is used
func (*ListServicesResponse) MarshalBinary ¶
func (m *ListServicesResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ListServicesResponse) UnmarshalBinary ¶
func (m *ListServicesResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ListVcsRequest ¶
type ListVcsRequest struct { // Cluster id of the service. // Required: true ClusterID *string `json:"clusterId"` }
ListVcsRequest ListVcs request object.
swagger:model ListVcsRequest
func (*ListVcsRequest) ContextValidate ¶
ContextValidate validates this list vcs request based on context it is used
func (*ListVcsRequest) MarshalBinary ¶
func (m *ListVcsRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ListVcsRequest) UnmarshalBinary ¶
func (m *ListVcsRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ListVcsResponse ¶
type ListVcsResponse struct { // List of virtual clusters. Vcs []*VcSummary `json:"vcs"` }
ListVcsResponse ListVcs response object.
swagger:model ListVcsResponse
func (*ListVcsResponse) ContextValidate ¶
ContextValidate validate this list vcs response based on the context it is used
func (*ListVcsResponse) MarshalBinary ¶
func (m *ListVcsResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ListVcsResponse) UnmarshalBinary ¶
func (m *ListVcsResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type Order ¶
type Order string
Order Order.
swagger:model Order
func (Order) ContextValidate ¶
ContextValidate validates this order based on context it is used
type RestoreServiceRequest ¶
type RestoreServiceRequest struct { // The ID of the backup to restore from. // Required: true BackupID *int64 `json:"backupID"` // CRN of the CDP environment with which a restored CDE service will be associated. Currently, CDE service can be restored only to the same CDP environment, with which a backed-up service was associated. // Required: true EnvironmentCrn *string `json:"environmentCrn"` // Specify the restored service ID. If not specified, the service ID from the backup will be reused. ServiceID string `json:"serviceId,omitempty"` // Specify the restored service name. If not specified, the service name from the backup will be reused. ServiceName string `json:"serviceName,omitempty"` }
RestoreServiceRequest Request object for Restore Service command.
swagger:model RestoreServiceRequest
func (*RestoreServiceRequest) ContextValidate ¶
ContextValidate validates this restore service request based on context it is used
func (*RestoreServiceRequest) MarshalBinary ¶
func (m *RestoreServiceRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*RestoreServiceRequest) UnmarshalBinary ¶
func (m *RestoreServiceRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type RestoreServiceResponse ¶
type RestoreServiceResponse struct { // The ID of the service being restored. // Required: true ServiceID *string `json:"serviceID"` }
RestoreServiceResponse Response object for Restore Service command.
swagger:model RestoreServiceResponse
func (*RestoreServiceResponse) ContextValidate ¶
func (m *RestoreServiceResponse) ContextValidate(ctx context.Context, formats strfmt.Registry) error
ContextValidate validates this restore service response based on context it is used
func (*RestoreServiceResponse) MarshalBinary ¶
func (m *RestoreServiceResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*RestoreServiceResponse) UnmarshalBinary ¶
func (m *RestoreServiceResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type SMTPConfigRequest ¶
type SMTPConfigRequest struct { // Sender's email address. // Required: true Email *string `json:"email"` // SMTP host. // Required: true Host *string `json:"host"` // SMTP password. Password string `json:"password,omitempty"` // SMTP port. Port *int32 `json:"port,omitempty"` // Use SSL to secure the connection to the email server. Ssl *bool `json:"ssl,omitempty"` // Use SMTP STARTTLS command to encrypt the mail. StartTLS *bool `json:"startTls,omitempty"` // SMTP username. Username string `json:"username,omitempty"` }
SMTPConfigRequest SMTP config request object.
swagger:model SmtpConfigRequest
func (*SMTPConfigRequest) ContextValidate ¶
ContextValidate validates this Smtp config request based on context it is used
func (*SMTPConfigRequest) MarshalBinary ¶
func (m *SMTPConfigRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*SMTPConfigRequest) UnmarshalBinary ¶
func (m *SMTPConfigRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type SMTPConfigResponse ¶
type SMTPConfigResponse struct { // Sender's email address. // Required: true Email *string `json:"email"` // SMTP host. // Required: true Host *string `json:"host"` // SMTP port. Port *int32 `json:"port,omitempty"` // Use SSL to secure the connection to the email server. Ssl *bool `json:"ssl,omitempty"` // Use SMTP STARTTLS command to encrypt the mail. StartTLS *bool `json:"startTls,omitempty"` // SMTP username. Username string `json:"username,omitempty"` }
SMTPConfigResponse SMTP config response object
swagger:model SmtpConfigResponse
func (*SMTPConfigResponse) ContextValidate ¶
ContextValidate validates this Smtp config response based on context it is used
func (*SMTPConfigResponse) MarshalBinary ¶
func (m *SMTPConfigResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*SMTPConfigResponse) UnmarshalBinary ¶
func (m *SMTPConfigResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ServiceDescription ¶
type ServiceDescription struct { // Base location for the service backup archives. BackupLocation string `json:"backupLocation,omitempty"` // Chart overrides for the Virtual Cluster. ChartValueOverrides []*ChartValueOverridesResponse `json:"chartValueOverrides"` // The cloud platform where the CDE service is enabled. CloudPlatform string `json:"cloudPlatform,omitempty"` // FQDN of the CDE service. ClusterFqdn string `json:"clusterFqdn,omitempty"` // Cluster Id of the CDE Service. // Required: true ClusterID *string `json:"clusterId"` // CRN of the creator. CreatorCrn string `json:"creatorCrn,omitempty"` // Email address of the creator of the CDE service. CreatorEmail string `json:"creatorEmail,omitempty"` // Endpoint of Data Lake Atlas. DataLakeAtlasUIEndpoint string `json:"dataLakeAtlasUIEndpoint,omitempty"` // The Data lake file system. DataLakeFileSystems string `json:"dataLakeFileSystems,omitempty"` // Timestamp of service enabling. EnablingTime string `json:"enablingTime,omitempty"` // CRN of the environment. EnvironmentCrn string `json:"environmentCrn,omitempty"` // CDP Environment Name. // Required: true EnvironmentName *string `json:"environmentName"` // Comma-separated CIDRs that would be allowed to access the load balancer. LoadbalancerAllowlist string `json:"loadbalancerAllowlist,omitempty"` // Location for the log files of jobs. LogLocation string `json:"logLocation,omitempty"` // Name of the CDE Service. // Required: true Name *string `json:"name"` // Network outbound type. Currently 'udr' is the only supported. NetworkOutboundType string `json:"networkOutboundType,omitempty"` // The "true" value indicates that the previous version of the CDE service was requested to be deployed. PreviousVersionDeployed bool `json:"previousVersionDeployed,omitempty"` // If true, the CDE service was created with fully private Azure services (AKS, MySQL, etc.). PrivateClusterEnabled bool `json:"privateClusterEnabled,omitempty"` // If true, the CDE endpoint was created in a publicly accessible subnet. PublicEndpointEnabled bool `json:"publicEndpointEnabled,omitempty"` // Resources details of CDE Service. Resources *ServiceResources `json:"resources,omitempty"` // If true, SSD would have been be used for workload filesystem. SsdUsed bool `json:"ssdUsed,omitempty"` // Status of the CDE service. Status string `json:"status,omitempty"` // List of Subnet IDs of the CDP subnets used by the kubernetes worker node. Subnets string `json:"subnets,omitempty"` // CDP tenant ID. TenantID string `json:"tenantId,omitempty"` // List of CIDRs that would be allowed to access kubernetes master API server. WhitelistIps string `json:"whitelistIps,omitempty"` // If true, diagnostic information about job and query execution is sent to Cloudera Workload Manager. WorkloadAnalyticsEnabled bool `json:"workloadAnalyticsEnabled,omitempty"` }
ServiceDescription Detailed description of a CDE service.
swagger:model ServiceDescription
func (*ServiceDescription) ContextValidate ¶
ContextValidate validate this service description based on the context it is used
func (*ServiceDescription) MarshalBinary ¶
func (m *ServiceDescription) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ServiceDescription) UnmarshalBinary ¶
func (m *ServiceDescription) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ServiceResources ¶
type ServiceResources struct { // Resource details for the nodes used in All Purpose Virtual Clusters. AllPurposeInstanceGroupDetails *AllPurposeInstanceGroupDetailsResponse `json:"allPurposeInstanceGroupDetails,omitempty"` // CPU Requests for the entire CDE service quota. CPURequests string `json:"cpuRequests,omitempty"` // GPU requests for the entire CDE service quota. GpuRequests string `json:"gpuRequests,omitempty"` // Initial instances for the CDE service. InitialInstances string `json:"initial_instances,omitempty"` // Initial Spot Instances for the CDE Service. InitialSpotInstances string `json:"initial_spot_instances,omitempty"` // Instance type of the CDE service. InstanceType string `json:"instance_type,omitempty"` // Maximum instances for the CDE service. MaxInstances string `json:"max_instances,omitempty"` // Maximum Number of Spot instances. MaxSpotInstances string `json:"max_spot_instances,omitempty"` // Memory requests for the entire CDE service quota, eg. 100Gi. MemoryRequests string `json:"memoryRequests,omitempty"` // Minimum Instances for the CDE service. MinInstances string `json:"min_instances,omitempty"` // Minimum number of spot instances for the CDE service. MinSpotInstances string `json:"min_spot_instances,omitempty"` // Resource Pool for the CDE service. ResourcePool string `json:"resourcePool,omitempty"` // Root Volume Size. RootVolSize string `json:"root_vol_size,omitempty"` }
ServiceResources Object to store resources for a CDE service.
swagger:model ServiceResources
func (*ServiceResources) ContextValidate ¶
ContextValidate validate this service resources based on the context it is used
func (*ServiceResources) MarshalBinary ¶
func (m *ServiceResources) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ServiceResources) UnmarshalBinary ¶
func (m *ServiceResources) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type ServiceSummary ¶
type ServiceSummary struct { // Cluster Id of the CDE Service. // Required: true ClusterID *string `json:"clusterId"` // Email Address of the CDE creator. CreatorEmail string `json:"creatorEmail,omitempty"` // Timestamp of service enabling. EnablingTime string `json:"enablingTime,omitempty"` // CDP Environment Name. // Required: true EnvironmentName *string `json:"environmentName"` // Name of the CDE Service. // Required: true Name *string `json:"name"` // Status of the CDE service. // Required: true Status *string `json:"status"` }
ServiceSummary Summary of a CDE service.
swagger:model ServiceSummary
func (*ServiceSummary) ContextValidate ¶
ContextValidate validates this service summary based on context it is used
func (*ServiceSummary) MarshalBinary ¶
func (m *ServiceSummary) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*ServiceSummary) UnmarshalBinary ¶
func (m *ServiceSummary) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type UpdateServiceRequest ¶
type UpdateServiceRequest struct { // Maximum number of instances for the CDE service for the All Purpose Instance Group. AllPurposeMaximumInstances int32 `json:"allPurposeMaximumInstances,omitempty"` // Maximum number of spot instances for the CDE service for the All Purpose Instance Group. AllPurposeMaximumSpotInstances int32 `json:"allPurposeMaximumSpotInstances,omitempty"` // Minimum number of instances for the CDE service for the All Purpose Instance Group. AllPurposeMinimumInstances int32 `json:"allPurposeMinimumInstances,omitempty"` // Minimum number of spot instances for the CDE service for the All Purpose Instance Group. AllPurposeMinimumSpotInstances int32 `json:"allPurposeMinimumSpotInstances,omitempty"` // Cluster ID of the service to update. // Required: true ClusterID *string `json:"clusterId"` // CPU Requests for the entire CDE service quota. CPURequests string `json:"cpuRequests,omitempty"` // GPU requests for the entire CDE service quota. GpuRequests string `json:"gpuRequests,omitempty"` // List of CIDRs that would be allowed to access the load balancer. LoadbalancerAllowlist []string `json:"loadbalancerAllowlist"` // Maximum number of instances for the CDE service. MaximumInstances int32 `json:"maximumInstances,omitempty"` // Maximum number of spot instances for the CDE service. MaximumSpotInstances int32 `json:"maximumSpotInstances,omitempty"` // Memory requests for the entire CDE service quota, eg. 100Gi. MemoryRequests string `json:"memoryRequests,omitempty"` // Minimum number of instances for the CDE service. MinimumInstances int32 `json:"minimumInstances,omitempty"` // Minimum number of spot instances for the CDE service. MinimumSpotInstances int32 `json:"minimumSpotInstances,omitempty"` // List of CIDRs that would be allowed to access kubernetes master API server. WhitelistIps []string `json:"whitelistIps"` }
UpdateServiceRequest Request object for UpdateService method.
swagger:model UpdateServiceRequest
func (*UpdateServiceRequest) ContextValidate ¶
ContextValidate validates this update service request based on context it is used
func (*UpdateServiceRequest) MarshalBinary ¶
func (m *UpdateServiceRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*UpdateServiceRequest) UnmarshalBinary ¶
func (m *UpdateServiceRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type UpdateServiceResponse ¶
type UpdateServiceResponse struct { // Deprecated. The operation ID of the update request. OperationID string `json:"operationId,omitempty"` // Status of update. Status string `json:"status,omitempty"` }
UpdateServiceResponse Response object for UpdateService request.
swagger:model UpdateServiceResponse
func (*UpdateServiceResponse) ContextValidate ¶
ContextValidate validates this update service response based on context it is used
func (*UpdateServiceResponse) MarshalBinary ¶
func (m *UpdateServiceResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*UpdateServiceResponse) UnmarshalBinary ¶
func (m *UpdateServiceResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type UpdateVcRequest ¶
type UpdateVcRequest struct { // Comma-separated Workload usernames of CDP users to be granted access to the Virtual Cluster. ACLUsers string `json:"aclUsers,omitempty"` // Cluster ID of the CDE service where Virtual Cluster was enabled. // Required: true ClusterID *string `json:"clusterId"` // Groups with full access. FullAccessGroups []string `json:"fullAccessGroups"` // Users with full access. FullAccessUsers []string `json:"fullAccessUsers"` // Virtual Cluster ID // Required: true VcID *string `json:"vcId"` // Groups with view only access. ViewOnlyGroups []string `json:"viewOnlyGroups"` // Users with view only access. ViewOnlyUsers []string `json:"viewOnlyUsers"` }
UpdateVcRequest Request object for updateVc method.
swagger:model UpdateVcRequest
func (*UpdateVcRequest) ContextValidate ¶
ContextValidate validates this update vc request based on context it is used
func (*UpdateVcRequest) MarshalBinary ¶
func (m *UpdateVcRequest) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*UpdateVcRequest) UnmarshalBinary ¶
func (m *UpdateVcRequest) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type UpdateVcResponse ¶
type UpdateVcResponse struct { // Updated Virtual Cluster. Vc *VcDescription `json:"Vc,omitempty"` }
UpdateVcResponse Response object for updateVc method.
swagger:model UpdateVcResponse
func (*UpdateVcResponse) ContextValidate ¶
ContextValidate validate this update vc response based on the context it is used
func (*UpdateVcResponse) MarshalBinary ¶
func (m *UpdateVcResponse) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*UpdateVcResponse) UnmarshalBinary ¶
func (m *UpdateVcResponse) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type VcDescription ¶
type VcDescription struct { // URL of the CDE Virtual Cluster UI. VcUIURL string `json:"VcUiUrl,omitempty"` // Access control object for the Virtual Cluster. AccessControl *AccessControlResponse `json:"accessControl,omitempty"` // Chart overrides for the Virtual Cluster. ChartValueOverrides []*ChartValueOverridesResponse `json:"chartValueOverrides"` // Cluster ID of the CDE service that contains the Virtual Cluster. // Required: true ClusterID *string `json:"clusterId"` // Time of creation of the virtual Cluster. CreationTime string `json:"creationTime,omitempty"` // Email address of the creator of Virtual Cluster. CreatorEmail string `json:"creatorEmail,omitempty"` // ID of the creator of Virtual Cluster. CreatorID string `json:"creatorID,omitempty"` // Name of the creator of the Virtual Cluster. CreatorName string `json:"creatorName,omitempty"` // Spark History Server URL for the Virtual Cluster. HistoryServerURL string `json:"historyServerUrl,omitempty"` // Livy Server URL for the Virtual Cluster. LivyServerURL string `json:"livyServerUrl,omitempty"` // Resources details of CDE Service. Resources *VcResources `json:"resources,omitempty"` // Safari URL for the Virtual Cluster. SafariURL string `json:"safariUrl,omitempty"` // Default timeout for Sessions. SessionTimeout string `json:"sessionTimeout,omitempty"` // SMTP Configurations for Airflow Email Alerts. SMTPConfig *SMTPConfigResponse `json:"smtpConfig,omitempty"` // Spark version for the virtual cluster. SparkVersion string `json:"sparkVersion,omitempty"` // Status of the Virtual Cluster. Status string `json:"status,omitempty"` // Url for the Virtual Cluster APIs. VcAPIURL string `json:"vcApiUrl,omitempty"` // Virtual Cluster ID. // Required: true VcID *string `json:"vcId"` // Name of the CDE Virtual Cluster. // Required: true VcName *string `json:"vcName"` // Tier of the Virtual Cluster. VcTier string `json:"vcTier,omitempty"` }
VcDescription CDE virtual cluster summary.
swagger:model VcDescription
func (*VcDescription) ContextValidate ¶
ContextValidate validate this vc description based on the context it is used
func (*VcDescription) MarshalBinary ¶
func (m *VcDescription) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*VcDescription) UnmarshalBinary ¶
func (m *VcDescription) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type VcResources ¶
type VcResources struct { // Actual CPU request for the VC. This accounts for other dex apps(eg. livy, airflow), that run in the virtual cluster. ActualCPURequests string `json:"actualCpuRequests,omitempty"` // Actual Memory request for the VC. This accounts for other dex apps(eg. livy, airflow), that run in the virtual cluster. ActualMemoryRequests string `json:"actualMemoryRequests,omitempty"` // The CPU requests for VC for running spark jobs. CPURequests string `json:"cpuRequests,omitempty"` // GPU requests for autoscaling. GpuRequests string `json:"gpuRequests,omitempty"` // Guaranteed CPU requests for an Elastic Virtual Cluster. GuaranteedCPURequests string `json:"guaranteedCpuRequests,omitempty"` // Guaranteed GPU requests for an Elastic Virtual Cluster. GuaranteedGpuRequests string `json:"guaranteedGpuRequests,omitempty"` // Guaranteed Memory requests for an Elastic Virtual Cluster - eg. 30Gi. GuaranteedMemoryRequests string `json:"guaranteedMemoryRequests,omitempty"` // The Memory requests for VC for running spark jobs. MemRequests string `json:"memRequests,omitempty"` }
VcResources Object to store resources for a CDE service
swagger:model VcResources
func (*VcResources) ContextValidate ¶
ContextValidate validates this vc resources based on context it is used
func (*VcResources) MarshalBinary ¶
func (m *VcResources) MarshalBinary() ([]byte, error)
MarshalBinary interface implementation
func (*VcResources) UnmarshalBinary ¶
func (m *VcResources) UnmarshalBinary(b []byte) error
UnmarshalBinary interface implementation
type VcSummary ¶
type VcSummary struct { // Url for the Virtual Cluster UI. VcUIURL string `json:"VcUiUrl,omitempty"` // Cluster ID of the CDE service that contains the virtual cluster. // Required: true ClusterID *string `json:"clusterId"` // Email Address of the Creator. CreatorEmail string `json:"creatorEmail,omitempty"` // Name of the Creator. CreatorName string `json:"creatorName,omitempty"` // Status of the Virtual Cluster. Status string `json:"status,omitempty"` // Virtual Cluster ID. // Required: true VcID *string `json:"vcId"` // Name of the CDE Virtual Cluster. // Required: true VcName *string `json:"vcName"` }
VcSummary CDE virtual cluster summary.
swagger:model VcSummary
func (*VcSummary) ContextValidate ¶
ContextValidate validates this vc summary based on context it is used
func (*VcSummary) MarshalBinary ¶
MarshalBinary interface implementation
func (*VcSummary) UnmarshalBinary ¶
UnmarshalBinary interface implementation
Source Files ¶
- access_control_response.go
- all_purpose_instance_group_details_response.go
- backup.go
- backup_content_options.go
- cancel_backup_request.go
- cancel_backup_response.go
- chart_value_overrides_request.go
- chart_value_overrides_response.go
- create_backup_request.go
- create_backup_response.go
- create_vc_request.go
- create_vc_response.go
- custom_azure_files_configs.go
- delete_backup_request.go
- delete_backup_response.go
- delete_vc_request.go
- delete_vc_response.go
- describe_backup_request.go
- describe_backup_response.go
- describe_service_request.go
- describe_service_response.go
- describe_vc_request.go
- describe_vc_response.go
- disable_service_request.go
- disable_service_response.go
- enable_service_request.go
- enable_service_response.go
- error.go
- get_backup_logs_request.go
- get_backup_logs_response.go
- get_kubeconfig_request.go
- get_kubeconfig_response.go
- get_service_init_logs_request.go
- get_service_init_logs_response.go
- list_backups_request.go
- list_backups_response.go
- list_services_request.go
- list_services_response.go
- list_vcs_request.go
- list_vcs_response.go
- order.go
- restore_service_request.go
- restore_service_response.go
- service_description.go
- service_resources.go
- service_summary.go
- smtp_config_request.go
- smtp_config_response.go
- update_service_request.go
- update_service_response.go
- update_vc_request.go
- update_vc_response.go
- vc_description.go
- vc_resources.go
- vc_summary.go