v1beta1

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=dli.flexibleengine.upbound.io +versionName=v1beta1

Index

Constants

View Source 
const (
	CRDGroup   = "dli.flexibleengine.upbound.io"
	CRDVersion = "v1beta1"
)

Package type metadata.

Variables

View Source 
var (
	Database_Kind             = "Database"
	Database_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Database_Kind}.String()
	Database_KindAPIVersion   = Database_Kind + "." + CRDGroupVersion.String()
	Database_GroupVersionKind = CRDGroupVersion.WithKind(Database_Kind)
)

Repository type metadata.

View Source 
var (
	DLIPackage_Kind             = "DLIPackage"
	DLIPackage_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: DLIPackage_Kind}.String()
	DLIPackage_KindAPIVersion   = DLIPackage_Kind + "." + CRDGroupVersion.String()
	DLIPackage_GroupVersionKind = CRDGroupVersion.WithKind(DLIPackage_Kind)
)

Repository type metadata.

View Source 
var (
	FlinksqlJob_Kind             = "FlinksqlJob"
	FlinksqlJob_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: FlinksqlJob_Kind}.String()
	FlinksqlJob_KindAPIVersion   = FlinksqlJob_Kind + "." + CRDGroupVersion.String()
	FlinksqlJob_GroupVersionKind = CRDGroupVersion.WithKind(FlinksqlJob_Kind)
)

Repository type metadata.

View Source 
var (
	// CRDGroupVersion is the API Group Version used to register the objects
	CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (
	Queue_Kind             = "Queue"
	Queue_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Queue_Kind}.String()
	Queue_KindAPIVersion   = Queue_Kind + "." + CRDGroupVersion.String()
	Queue_GroupVersionKind = CRDGroupVersion.WithKind(Queue_Kind)
)

Repository type metadata.

View Source 
var (
	SparkJob_Kind             = "SparkJob"
	SparkJob_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: SparkJob_Kind}.String()
	SparkJob_KindAPIVersion   = SparkJob_Kind + "." + CRDGroupVersion.String()
	SparkJob_GroupVersionKind = CRDGroupVersion.WithKind(SparkJob_Kind)
)

Repository type metadata.

View Source 
var (
	Table_Kind             = "Table"
	Table_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Table_Kind}.String()
	Table_KindAPIVersion   = Table_Kind + "." + CRDGroupVersion.String()
	Table_GroupVersionKind = CRDGroupVersion.WithKind(Table_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type ColumnsObservation 

type ColumnsObservation struct {
}

func (*ColumnsObservation) DeepCopy 

func (in *ColumnsObservation) DeepCopy() *ColumnsObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ColumnsObservation.

func (*ColumnsObservation) DeepCopyInto 

func (in *ColumnsObservation) DeepCopyInto(out *ColumnsObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ColumnsParameters 

type ColumnsParameters struct {

	// Specifies description of the table.
	// Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies whether the column is a partition column. The value
	// true indicates a partition column, and the value false indicates a non-partition column. The default value
	// is false. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	IsPartition *bool `json:"isPartition,omitempty" tf:"is_partition,omitempty"`

	// Specifies the table name. The name can contain only digits, letters,
	// and underscores, but cannot contain only digits or start with an underscore. Length range: 1 to 128 characters.
	// Changing this parameter will create a new resource.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies data type of column. Changing this parameter will create a new
	// resource.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*ColumnsParameters) DeepCopy 

func (in *ColumnsParameters) DeepCopy() *ColumnsParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ColumnsParameters.

func (*ColumnsParameters) DeepCopyInto 

func (in *ColumnsParameters) DeepCopyInto(out *ColumnsParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DLIPackage 

type DLIPackage struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DLIPackageSpec   `json:"spec"`
	Status            DLIPackageStatus `json:"status,omitempty"`
}

DLIPackage is the Schema for the DLIPackages API. ""page_title: "flexibleengine_dli_package" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,flexibleengine}

func (*DLIPackage) DeepCopy 

func (in *DLIPackage) DeepCopy() *DLIPackage

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DLIPackage.

func (*DLIPackage) DeepCopyInto 

func (in *DLIPackage) DeepCopyInto(out *DLIPackage)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DLIPackage) DeepCopyObject 

func (in *DLIPackage) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*DLIPackage) GetCondition 

func (mg *DLIPackage) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this DLIPackage.

func (*DLIPackage) GetConnectionDetailsMapping 

func (tr *DLIPackage) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this DLIPackage

func (*DLIPackage) GetDeletionPolicy 

func (mg *DLIPackage) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this DLIPackage.

func (*DLIPackage) GetID 

func (tr *DLIPackage) GetID() string

GetID returns ID of underlying Terraform resource of this DLIPackage

func (*DLIPackage) GetObservation 

func (tr *DLIPackage) GetObservation() (map[string]any, error)

GetObservation of this DLIPackage

func (*DLIPackage) GetParameters 

func (tr *DLIPackage) GetParameters() (map[string]any, error)

GetParameters of this DLIPackage

func (*DLIPackage) GetProviderConfigReference 

func (mg *DLIPackage) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this DLIPackage.

func (*DLIPackage) GetProviderReference 

func (mg *DLIPackage) GetProviderReference() *xpv1.Reference

GetProviderReference of this DLIPackage. Deprecated: Use GetProviderConfigReference.

func (*DLIPackage) GetPublishConnectionDetailsTo 

func (mg *DLIPackage) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this DLIPackage.

func (*DLIPackage) GetTerraformResourceType 

func (mg *DLIPackage) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this DLIPackage

func (*DLIPackage) GetTerraformSchemaVersion 

func (tr *DLIPackage) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*DLIPackage) GetWriteConnectionSecretToReference 

func (mg *DLIPackage) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this DLIPackage.

func (*DLIPackage) LateInitialize 

func (tr *DLIPackage) LateInitialize(attrs []byte) (bool, error)

LateInitialize this DLIPackage using its observed tfState. returns True if there are any spec changes for the resource.

func (*DLIPackage) SetConditions 

func (mg *DLIPackage) SetConditions(c ...xpv1.Condition)

SetConditions of this DLIPackage.

func (*DLIPackage) SetDeletionPolicy 

func (mg *DLIPackage) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this DLIPackage.

func (*DLIPackage) SetObservation 

func (tr *DLIPackage) SetObservation(obs map[string]any) error

SetObservation for this DLIPackage

func (*DLIPackage) SetParameters 

func (tr *DLIPackage) SetParameters(params map[string]any) error

SetParameters for this DLIPackage

func (*DLIPackage) SetProviderConfigReference 

func (mg *DLIPackage) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this DLIPackage.

func (*DLIPackage) SetProviderReference 

func (mg *DLIPackage) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this DLIPackage. Deprecated: Use SetProviderConfigReference.

func (*DLIPackage) SetPublishConnectionDetailsTo 

func (mg *DLIPackage) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this DLIPackage.

func (*DLIPackage) SetWriteConnectionSecretToReference 

func (mg *DLIPackage) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this DLIPackage.

type DLIPackageList 

type DLIPackageList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []DLIPackage `json:"items"`
}

DLIPackageList contains a list of DLIPackages

func (*DLIPackageList) DeepCopy 

func (in *DLIPackageList) DeepCopy() *DLIPackageList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DLIPackageList.

func (*DLIPackageList) DeepCopyInto 

func (in *DLIPackageList) DeepCopyInto(out *DLIPackageList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DLIPackageList) DeepCopyObject 

func (in *DLIPackageList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*DLIPackageList) GetItems 

func (l *DLIPackageList) GetItems() []resource.Managed

GetItems of this DLIPackageList.

type DLIPackageObservation 

type DLIPackageObservation struct {

	// Time when a queue is created.
	CreatedAt *string `json:"createdAt,omitempty" tf:"created_at,omitempty"`

	// Resource ID. The ID is constructed from the group_name and object_name, separated by slash.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The package name.
	ObjectName *string `json:"objectName,omitempty" tf:"object_name,omitempty"`

	// Status of a package group to be uploaded.
	Status *string `json:"status,omitempty" tf:"status,omitempty"`

	// The last time when the package configuration update has complated.
	UpdatedAt *string `json:"updatedAt,omitempty" tf:"updated_at,omitempty"`
}

func (*DLIPackageObservation) DeepCopy 

func (in *DLIPackageObservation) DeepCopy() *DLIPackageObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DLIPackageObservation.

func (*DLIPackageObservation) DeepCopyInto 

func (in *DLIPackageObservation) DeepCopyInto(out *DLIPackageObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DLIPackageParameters 

type DLIPackageParameters struct {

	// Specifies the group name which the package belongs to.
	// Changing this parameter will delete the current package and upload a new package.
	// +kubebuilder:validation:Required
	GroupName *string `json:"groupName" tf:"group_name,omitempty"`

	// Specifies whether to upload resource packages in asynchronous mode.
	// The default value is false. Changing this parameter will delete the current package and upload a new package.
	// +kubebuilder:validation:Optional
	IsAsync *bool `json:"isAsync,omitempty" tf:"is_async,omitempty"`

	// Specifies the OBS storage path where the package is located.
	// For example, https://{bucket_name}.oss.{region}.prod-cloud-ocb.orange-business.com/dli/packages/object_file.py.
	// Changing this parameter will delete the current package and upload a new package.
	// +kubebuilder:validation:Required
	ObjectPath *string `json:"objectPath" tf:"object_path,omitempty"`

	// Specifies the name of the package owner. The owner must be IAM user.
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" tf:"owner,omitempty"`

	// Specifies the region in which to upload packages.
	// If omitted, the provider-level region will be used.
	// Changing this parameter will delete the current package and upload a new package.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies the package type.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*DLIPackageParameters) DeepCopy 

func (in *DLIPackageParameters) DeepCopy() *DLIPackageParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DLIPackageParameters.

func (*DLIPackageParameters) DeepCopyInto 

func (in *DLIPackageParameters) DeepCopyInto(out *DLIPackageParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DLIPackageSpec 

type DLIPackageSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     DLIPackageParameters `json:"forProvider"`
}

DLIPackageSpec defines the desired state of DLIPackage

func (*DLIPackageSpec) DeepCopy 

func (in *DLIPackageSpec) DeepCopy() *DLIPackageSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DLIPackageSpec.

func (*DLIPackageSpec) DeepCopyInto 

func (in *DLIPackageSpec) DeepCopyInto(out *DLIPackageSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DLIPackageStatus 

type DLIPackageStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        DLIPackageObservation `json:"atProvider,omitempty"`
}

DLIPackageStatus defines the observed state of DLIPackage.

func (*DLIPackageStatus) DeepCopy 

func (in *DLIPackageStatus) DeepCopy() *DLIPackageStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DLIPackageStatus.

func (*DLIPackageStatus) DeepCopyInto 

func (in *DLIPackageStatus) DeepCopyInto(out *DLIPackageStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Database 

type Database struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DatabaseSpec   `json:"spec"`
	Status            DatabaseStatus `json:"status,omitempty"`
}

Database is the Schema for the Databases API. ""page_title: "flexibleengine_dli_database" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,flexibleengine}

func (*Database) DeepCopy 

func (in *Database) DeepCopy() *Database

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Database.

func (*Database) DeepCopyInto 

func (in *Database) DeepCopyInto(out *Database)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Database) DeepCopyObject 

func (in *Database) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Database) GetCondition 

func (mg *Database) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Database.

func (*Database) GetConnectionDetailsMapping 

func (tr *Database) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Database

func (*Database) GetDeletionPolicy 

func (mg *Database) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Database.

func (*Database) GetID 

func (tr *Database) GetID() string

GetID returns ID of underlying Terraform resource of this Database

func (*Database) GetObservation 

func (tr *Database) GetObservation() (map[string]any, error)

GetObservation of this Database

func (*Database) GetParameters 

func (tr *Database) GetParameters() (map[string]any, error)

GetParameters of this Database

func (*Database) GetProviderConfigReference 

func (mg *Database) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Database.

func (*Database) GetProviderReference 

func (mg *Database) GetProviderReference() *xpv1.Reference

GetProviderReference of this Database. Deprecated: Use GetProviderConfigReference.

func (*Database) GetPublishConnectionDetailsTo 

func (mg *Database) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Database.

func (*Database) GetTerraformResourceType 

func (mg *Database) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Database

func (*Database) GetTerraformSchemaVersion 

func (tr *Database) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Database) GetWriteConnectionSecretToReference 

func (mg *Database) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Database.

func (*Database) LateInitialize 

func (tr *Database) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Database using its observed tfState. returns True if there are any spec changes for the resource.

func (*Database) SetConditions 

func (mg *Database) SetConditions(c ...xpv1.Condition)

SetConditions of this Database.

func (*Database) SetDeletionPolicy 

func (mg *Database) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Database.

func (*Database) SetObservation 

func (tr *Database) SetObservation(obs map[string]any) error

SetObservation for this Database

func (*Database) SetParameters 

func (tr *Database) SetParameters(params map[string]any) error

SetParameters for this Database

func (*Database) SetProviderConfigReference 

func (mg *Database) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Database.

func (*Database) SetProviderReference 

func (mg *Database) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Database. Deprecated: Use SetProviderConfigReference.

func (*Database) SetPublishConnectionDetailsTo 

func (mg *Database) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Database.

func (*Database) SetWriteConnectionSecretToReference 

func (mg *Database) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Database.

type DatabaseList 

type DatabaseList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Database `json:"items"`
}

DatabaseList contains a list of Databases

func (*DatabaseList) DeepCopy 

func (in *DatabaseList) DeepCopy() *DatabaseList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseList.

func (*DatabaseList) DeepCopyInto 

func (in *DatabaseList) DeepCopyInto(out *DatabaseList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*DatabaseList) DeepCopyObject 

func (in *DatabaseList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*DatabaseList) GetItems 

func (l *DatabaseList) GetItems() []resource.Managed

GetItems of this DatabaseList.

type DatabaseObservation 

type DatabaseObservation struct {

	// Resource ID. For database resources, the ID is the database name.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*DatabaseObservation) DeepCopy 

func (in *DatabaseObservation) DeepCopy() *DatabaseObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseObservation.

func (*DatabaseObservation) DeepCopyInto 

func (in *DatabaseObservation) DeepCopyInto(out *DatabaseObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatabaseParameters 

type DatabaseParameters struct {

	// Specifies the description of a queue.
	// Changing this parameter will create a new database resource.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies the enterprise project ID.
	// The value 0 indicates the default enterprise project. Changing this parameter will create a new database resource.
	// +kubebuilder:validation:Optional
	EnterpriseProjectID *string `json:"enterpriseProjectId,omitempty" tf:"enterprise_project_id,omitempty"`

	// Specifies the database name. The name consists of 1 to 128 characters, starting
	// with a letter or digit. Only letters, digits and underscores (_) are allowed and the name cannot be all digits.
	// Changing this parameter will create a new database resource.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies the name of the SQL database owner.
	// The owner must be IAM user.
	// +kubebuilder:validation:Optional
	Owner *string `json:"owner,omitempty" tf:"owner,omitempty"`

	// Specifies the region in which to create the DLI database resource.
	// If omitted, the provider-level region will be used. Changing this parameter will create a new database resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`
}

func (*DatabaseParameters) DeepCopy 

func (in *DatabaseParameters) DeepCopy() *DatabaseParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseParameters.

func (*DatabaseParameters) DeepCopyInto 

func (in *DatabaseParameters) DeepCopyInto(out *DatabaseParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatabaseSpec 

type DatabaseSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     DatabaseParameters `json:"forProvider"`
}

DatabaseSpec defines the desired state of Database

func (*DatabaseSpec) DeepCopy 

func (in *DatabaseSpec) DeepCopy() *DatabaseSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseSpec.

func (*DatabaseSpec) DeepCopyInto 

func (in *DatabaseSpec) DeepCopyInto(out *DatabaseSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DatabaseStatus 

type DatabaseStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        DatabaseObservation `json:"atProvider,omitempty"`
}

DatabaseStatus defines the observed state of Database.

func (*DatabaseStatus) DeepCopy 

func (in *DatabaseStatus) DeepCopy() *DatabaseStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DatabaseStatus.

func (*DatabaseStatus) DeepCopyInto 

func (in *DatabaseStatus) DeepCopyInto(out *DatabaseStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DependentPackagesObservation 

type DependentPackagesObservation struct {
}

func (*DependentPackagesObservation) DeepCopy 

func (in *DependentPackagesObservation) DeepCopy() *DependentPackagesObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DependentPackagesObservation.

func (*DependentPackagesObservation) DeepCopyInto 

func (in *DependentPackagesObservation) DeepCopyInto(out *DependentPackagesObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type DependentPackagesParameters 

type DependentPackagesParameters struct {

	// Specifies the spark job name.
	// The value contains a maximum of 128 characters.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Required
	GroupName *string `json:"groupName" tf:"group_name,omitempty"`

	// +kubebuilder:validation:Required
	Packages []PackagesParameters `json:"packages" tf:"packages,omitempty"`
}

func (*DependentPackagesParameters) DeepCopy 

func (in *DependentPackagesParameters) DeepCopy() *DependentPackagesParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DependentPackagesParameters.

func (*DependentPackagesParameters) DeepCopyInto 

func (in *DependentPackagesParameters) DeepCopyInto(out *DependentPackagesParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FlinksqlJob 

type FlinksqlJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              FlinksqlJobSpec   `json:"spec"`
	Status            FlinksqlJobStatus `json:"status,omitempty"`
}

FlinksqlJob is the Schema for the FlinksqlJobs API. ""page_title: "flexibleengine_dli_flinksql_job" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,flexibleengine}

func (*FlinksqlJob) DeepCopy 

func (in *FlinksqlJob) DeepCopy() *FlinksqlJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlinksqlJob.

func (*FlinksqlJob) DeepCopyInto 

func (in *FlinksqlJob) DeepCopyInto(out *FlinksqlJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FlinksqlJob) DeepCopyObject 

func (in *FlinksqlJob) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*FlinksqlJob) GetCondition 

func (mg *FlinksqlJob) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this FlinksqlJob.

func (*FlinksqlJob) GetConnectionDetailsMapping 

func (tr *FlinksqlJob) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this FlinksqlJob

func (*FlinksqlJob) GetDeletionPolicy 

func (mg *FlinksqlJob) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this FlinksqlJob.

func (*FlinksqlJob) GetID 

func (tr *FlinksqlJob) GetID() string

GetID returns ID of underlying Terraform resource of this FlinksqlJob

func (*FlinksqlJob) GetObservation 

func (tr *FlinksqlJob) GetObservation() (map[string]any, error)

GetObservation of this FlinksqlJob

func (*FlinksqlJob) GetParameters 

func (tr *FlinksqlJob) GetParameters() (map[string]any, error)

GetParameters of this FlinksqlJob

func (*FlinksqlJob) GetProviderConfigReference 

func (mg *FlinksqlJob) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this FlinksqlJob.

func (*FlinksqlJob) GetProviderReference 

func (mg *FlinksqlJob) GetProviderReference() *xpv1.Reference

GetProviderReference of this FlinksqlJob. Deprecated: Use GetProviderConfigReference.

func (*FlinksqlJob) GetPublishConnectionDetailsTo 

func (mg *FlinksqlJob) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this FlinksqlJob.

func (*FlinksqlJob) GetTerraformResourceType 

func (mg *FlinksqlJob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this FlinksqlJob

func (*FlinksqlJob) GetTerraformSchemaVersion 

func (tr *FlinksqlJob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*FlinksqlJob) GetWriteConnectionSecretToReference 

func (mg *FlinksqlJob) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this FlinksqlJob.

func (*FlinksqlJob) LateInitialize 

func (tr *FlinksqlJob) LateInitialize(attrs []byte) (bool, error)

LateInitialize this FlinksqlJob using its observed tfState. returns True if there are any spec changes for the resource.

func (*FlinksqlJob) ResolveReferences 

func (mg *FlinksqlJob) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this FlinksqlJob.

func (*FlinksqlJob) SetConditions 

func (mg *FlinksqlJob) SetConditions(c ...xpv1.Condition)

SetConditions of this FlinksqlJob.

func (*FlinksqlJob) SetDeletionPolicy 

func (mg *FlinksqlJob) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this FlinksqlJob.

func (*FlinksqlJob) SetObservation 

func (tr *FlinksqlJob) SetObservation(obs map[string]any) error

SetObservation for this FlinksqlJob

func (*FlinksqlJob) SetParameters 

func (tr *FlinksqlJob) SetParameters(params map[string]any) error

SetParameters for this FlinksqlJob

func (*FlinksqlJob) SetProviderConfigReference 

func (mg *FlinksqlJob) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this FlinksqlJob.

func (*FlinksqlJob) SetProviderReference 

func (mg *FlinksqlJob) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this FlinksqlJob. Deprecated: Use SetProviderConfigReference.

func (*FlinksqlJob) SetPublishConnectionDetailsTo 

func (mg *FlinksqlJob) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this FlinksqlJob.

func (*FlinksqlJob) SetWriteConnectionSecretToReference 

func (mg *FlinksqlJob) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this FlinksqlJob.

type FlinksqlJobList 

type FlinksqlJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []FlinksqlJob `json:"items"`
}

FlinksqlJobList contains a list of FlinksqlJobs

func (*FlinksqlJobList) DeepCopy 

func (in *FlinksqlJobList) DeepCopy() *FlinksqlJobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlinksqlJobList.

func (*FlinksqlJobList) DeepCopyInto 

func (in *FlinksqlJobList) DeepCopyInto(out *FlinksqlJobList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*FlinksqlJobList) DeepCopyObject 

func (in *FlinksqlJobList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*FlinksqlJobList) GetItems 

func (l *FlinksqlJobList) GetItems() []resource.Managed

GetItems of this FlinksqlJobList.

type FlinksqlJobObservation 

type FlinksqlJobObservation struct {

	// The Job ID in Int format.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	Status *string `json:"status,omitempty" tf:"status,omitempty"`
}

func (*FlinksqlJobObservation) DeepCopy 

func (in *FlinksqlJobObservation) DeepCopy() *FlinksqlJobObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlinksqlJobObservation.

func (*FlinksqlJobObservation) DeepCopyInto 

func (in *FlinksqlJobObservation) DeepCopyInto(out *FlinksqlJobObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FlinksqlJobParameters 

type FlinksqlJobParameters struct {

	// Specifies whether to enable the automatic job snapshot function.
	// +kubebuilder:validation:Optional
	CheckpointEnabled *bool `json:"checkpointEnabled,omitempty" tf:"checkpoint_enabled,omitempty"`

	// Specifies snapshot interval. The unit is second.
	// The default value is 10.
	// +kubebuilder:validation:Optional
	CheckpointInterval *float64 `json:"checkpointInterval,omitempty" tf:"checkpoint_interval,omitempty"`

	// Specifies snapshot mode. There are two options:
	// +kubebuilder:validation:Optional
	CheckpointMode *string `json:"checkpointMode,omitempty" tf:"checkpoint_mode,omitempty"`

	// Specifies number of CUs selected for a job. The default value is 2.
	// +kubebuilder:validation:Optional
	CuNumber *float64 `json:"cuNumber,omitempty" tf:"cu_number,omitempty"`

	// Specifies job description. Length range: 1 to 512 characters.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies dirty data policy of a job.
	// +kubebuilder:validation:Optional
	DirtyDataStrategy *string `json:"dirtyDataStrategy,omitempty" tf:"dirty_data_strategy,omitempty"`

	// Specifies edge computing group IDs.
	// +kubebuilder:validation:Optional
	EdgeGroupIds []*string `json:"edgeGroupIds,omitempty" tf:"edge_group_ids,omitempty"`

	// Specifies retention time of the idle state. The unit is hour.
	// The default value is 1.
	// +kubebuilder:validation:Optional
	IdleStateRetention *float64 `json:"idleStateRetention,omitempty" tf:"idle_state_retention,omitempty"`

	// Specifies whether to enable the function of uploading job logs to
	// users' OBS buckets. The default value is false.
	// +kubebuilder:validation:Optional
	LogEnabled *bool `json:"logEnabled,omitempty" tf:"log_enabled,omitempty"`

	// Specifies number of CUs in the JobManager selected for a job.
	// The default value is 1.
	// +kubebuilder:validation:Optional
	ManagerCuNumber *float64 `json:"managerCuNumber,omitempty" tf:"manager_cu_number,omitempty"`

	// Specifies the name of the job. Length range: 1 to 57 characters.
	// which may consist of letters, digits, underscores (_) and hyphens (-).
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies OBS path. OBS path where users are authorized to save the
	// snapshot. This parameter is valid only when checkpoint_enabled is set to true. OBS path where users are authorized
	// to save the snapshot. This parameter is valid only when log_enabled is set to true.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/oss/v1beta1.OBSBucket
	// +kubebuilder:validation:Optional
	ObsBucket *string `json:"obsBucket,omitempty" tf:"obs_bucket,omitempty"`

	// Reference to a OBSBucket in oss to populate obsBucket.
	// +kubebuilder:validation:Optional
	ObsBucketRef *v1.Reference `json:"obsBucketRef,omitempty" tf:"-"`

	// Selector for a OBSBucket in oss to populate obsBucket.
	// +kubebuilder:validation:Optional
	ObsBucketSelector *v1.Selector `json:"obsBucketSelector,omitempty" tf:"-"`

	// Specifies number of parallel for a job. The default value is 1.
	// +kubebuilder:validation:Optional
	ParallelNumber *float64 `json:"parallelNumber,omitempty" tf:"parallel_number,omitempty"`

	// Specifies name of a queue.
	// +kubebuilder:validation:Optional
	QueueName *string `json:"queueName,omitempty" tf:"queue_name,omitempty"`

	// The region in which to create the DLI flink job resource. If omitted, the
	// provider-level region will be used. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies whether to enable the function of automatically
	// restarting a job upon job exceptions. The default value is false.
	// +kubebuilder:validation:Optional
	RestartWhenException *bool `json:"restartWhenException,omitempty" tf:"restart_when_exception,omitempty"`

	// Specifies whether the abnormal restart is recovered from the
	// checkpoint.
	// +kubebuilder:validation:Optional
	ResumeCheckpoint *bool `json:"resumeCheckpoint,omitempty" tf:"resume_checkpoint,omitempty"`

	// Specifies maximum number of retry times upon exceptions. The unit is
	// times/hour. Value range: -1 or greater than 0. The default value is -1, indicating that the number of times is
	// unlimited.
	// +kubebuilder:validation:Required
	ResumeMaxNum *float64 `json:"resumeMaxNum" tf:"resume_max_num,omitempty"`

	// Specifies job running mode. The options are as follows:
	// +kubebuilder:validation:Optional
	RunMode *string `json:"runMode,omitempty" tf:"run_mode,omitempty"`

	// Specifies customizes optimization parameters when a Flink job is
	// running.
	// +kubebuilder:validation:Optional
	RuntimeConfig map[string]*string `json:"runtimeConfig,omitempty" tf:"runtime_config,omitempty"`

	// Specifies stream SQL statement, which includes at least the following
	// three parts: source, query, and sink. Length range: 1024x1024 characters.
	// +kubebuilder:validation:Optional
	SQL *string `json:"sql,omitempty" tf:"sql,omitempty"`

	// Specifies SMN topic. If a job fails, the system will send a message to
	// users subscribed to the SMN topic.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/smn/v1beta1.Topic
	// +kubebuilder:validation:Optional
	SmnTopic *string `json:"smnTopic,omitempty" tf:"smn_topic,omitempty"`

	// Reference to a Topic in smn to populate smnTopic.
	// +kubebuilder:validation:Optional
	SmnTopicRef *v1.Reference `json:"smnTopicRef,omitempty" tf:"-"`

	// Selector for a Topic in smn to populate smnTopic.
	// +kubebuilder:validation:Optional
	SmnTopicSelector *v1.Selector `json:"smnTopicSelector,omitempty" tf:"-"`

	// Specifies the key/value pairs to associate with the resource.
	// +kubebuilder:validation:Optional
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Specifies number of CUs for each Task Manager. The default value is 1.
	// +kubebuilder:validation:Optional
	TmCus *float64 `json:"tmCus,omitempty" tf:"tm_cus,omitempty"`

	// Specifies number of slots in each Task Manager.
	// The default value is (parallel_number * tm_cus)/(cu_number - manager_cu_number).
	// +kubebuilder:validation:Optional
	TmSlotNum *float64 `json:"tmSlotNum,omitempty" tf:"tm_slot_num,omitempty"`

	// Specifies the type of the job. The valid values are flink_sql_job,
	// flink_opensource_sql_job and flink_sql_edge_job. Default value is flink_sql_job.
	// Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Type *string `json:"type,omitempty" tf:"type,omitempty"`

	// Specifies name of the resource package that has been uploaded to the
	// DLI resource management system. The UDF Jar file of the SQL job is specified by this parameter.
	// +kubebuilder:validation:Optional
	UdfJarURL *string `json:"udfJarUrl,omitempty" tf:"udf_jar_url,omitempty"`
}

func (*FlinksqlJobParameters) DeepCopy 

func (in *FlinksqlJobParameters) DeepCopy() *FlinksqlJobParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlinksqlJobParameters.

func (*FlinksqlJobParameters) DeepCopyInto 

func (in *FlinksqlJobParameters) DeepCopyInto(out *FlinksqlJobParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FlinksqlJobSpec 

type FlinksqlJobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     FlinksqlJobParameters `json:"forProvider"`
}

FlinksqlJobSpec defines the desired state of FlinksqlJob

func (*FlinksqlJobSpec) DeepCopy 

func (in *FlinksqlJobSpec) DeepCopy() *FlinksqlJobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlinksqlJobSpec.

func (*FlinksqlJobSpec) DeepCopyInto 

func (in *FlinksqlJobSpec) DeepCopyInto(out *FlinksqlJobSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type FlinksqlJobStatus 

type FlinksqlJobStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        FlinksqlJobObservation `json:"atProvider,omitempty"`
}

FlinksqlJobStatus defines the observed state of FlinksqlJob.

func (*FlinksqlJobStatus) DeepCopy 

func (in *FlinksqlJobStatus) DeepCopy() *FlinksqlJobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlinksqlJobStatus.

func (*FlinksqlJobStatus) DeepCopyInto 

func (in *FlinksqlJobStatus) DeepCopyInto(out *FlinksqlJobStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PackagesObservation 

type PackagesObservation struct {
}

func (*PackagesObservation) DeepCopy 

func (in *PackagesObservation) DeepCopy() *PackagesObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PackagesObservation.

func (*PackagesObservation) DeepCopyInto 

func (in *PackagesObservation) DeepCopyInto(out *PackagesObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type PackagesParameters 

type PackagesParameters struct {

	// Specifies the resource name of the package.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Required
	PackageName *string `json:"packageName" tf:"package_name,omitempty"`

	// Specifies the resource type of the package.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Required
	Type *string `json:"type" tf:"type,omitempty"`
}

func (*PackagesParameters) DeepCopy 

func (in *PackagesParameters) DeepCopy() *PackagesParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PackagesParameters.

func (*PackagesParameters) DeepCopyInto 

func (in *PackagesParameters) DeepCopyInto(out *PackagesParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Queue 

type Queue struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              QueueSpec   `json:"spec"`
	Status            QueueStatus `json:"status,omitempty"`
}

Queue is the Schema for the Queues API. ""page_title: "flexibleengine_dli_queue" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,flexibleengine}

func (*Queue) DeepCopy 

func (in *Queue) DeepCopy() *Queue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Queue.

func (*Queue) DeepCopyInto 

func (in *Queue) DeepCopyInto(out *Queue)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Queue) DeepCopyObject 

func (in *Queue) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Queue) GetCondition 

func (mg *Queue) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Queue.

func (*Queue) GetConnectionDetailsMapping 

func (tr *Queue) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Queue

func (*Queue) GetDeletionPolicy 

func (mg *Queue) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Queue.

func (*Queue) GetID 

func (tr *Queue) GetID() string

GetID returns ID of underlying Terraform resource of this Queue

func (*Queue) GetObservation 

func (tr *Queue) GetObservation() (map[string]any, error)

GetObservation of this Queue

func (*Queue) GetParameters 

func (tr *Queue) GetParameters() (map[string]any, error)

GetParameters of this Queue

func (*Queue) GetProviderConfigReference 

func (mg *Queue) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Queue.

func (*Queue) GetProviderReference 

func (mg *Queue) GetProviderReference() *xpv1.Reference

GetProviderReference of this Queue. Deprecated: Use GetProviderConfigReference.

func (*Queue) GetPublishConnectionDetailsTo 

func (mg *Queue) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Queue.

func (*Queue) GetTerraformResourceType 

func (mg *Queue) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Queue

func (*Queue) GetTerraformSchemaVersion 

func (tr *Queue) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Queue) GetWriteConnectionSecretToReference 

func (mg *Queue) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Queue.

func (*Queue) LateInitialize 

func (tr *Queue) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Queue using its observed tfState. returns True if there are any spec changes for the resource.

func (*Queue) SetConditions 

func (mg *Queue) SetConditions(c ...xpv1.Condition)

SetConditions of this Queue.

func (*Queue) SetDeletionPolicy 

func (mg *Queue) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Queue.

func (*Queue) SetObservation 

func (tr *Queue) SetObservation(obs map[string]any) error

SetObservation for this Queue

func (*Queue) SetParameters 

func (tr *Queue) SetParameters(params map[string]any) error

SetParameters for this Queue

func (*Queue) SetProviderConfigReference 

func (mg *Queue) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Queue.

func (*Queue) SetProviderReference 

func (mg *Queue) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Queue. Deprecated: Use SetProviderConfigReference.

func (*Queue) SetPublishConnectionDetailsTo 

func (mg *Queue) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Queue.

func (*Queue) SetWriteConnectionSecretToReference 

func (mg *Queue) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Queue.

type QueueList 

type QueueList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Queue `json:"items"`
}

QueueList contains a list of Queues

func (*QueueList) DeepCopy 

func (in *QueueList) DeepCopy() *QueueList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueList.

func (*QueueList) DeepCopyInto 

func (in *QueueList) DeepCopyInto(out *QueueList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueueList) DeepCopyObject 

func (in *QueueList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueueList) GetItems 

func (l *QueueList) GetItems() []resource.Managed

GetItems of this QueueList.

type QueueObservation 

type QueueObservation struct {

	// Time when a queue is created.
	CreateTime *float64 `json:"createTime,omitempty" tf:"create_time,omitempty"`

	// Specifies a resource ID in UUID format.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*QueueObservation) DeepCopy 

func (in *QueueObservation) DeepCopy() *QueueObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueObservation.

func (*QueueObservation) DeepCopyInto 

func (in *QueueObservation) DeepCopyInto(out *QueueObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueParameters 

type QueueParameters struct {

	// Minimum number of CUs that are bound to a queue. Initial value can be 16,
	// 64, or 256. When scale_out or scale_in, the number must be a multiple of 16
	// +kubebuilder:validation:Required
	CuCount *float64 `json:"cuCount" tf:"cu_count,omitempty"`

	// Description of a queue.
	// Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Name of a queue. Name of a newly created resource queue.
	// The name can contain only digits, letters, and underscores (_),
	// but cannot contain only digits or start with an underscore (_).
	// Length range: 1 to 128 characters. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Indicates the queue type.
	// Changing this parameter will create a new resource. The options are as follows:
	// +kubebuilder:validation:Optional
	QueueType *string `json:"queueType,omitempty" tf:"queue_type,omitempty"`

	// Queue resource mode.
	// Changing this parameter will create a new resource.
	// The options are as follows:
	// +kubebuilder:validation:Optional
	ResourceMode *float64 `json:"resourceMode,omitempty" tf:"resource_mode,omitempty"`

	// Label of a queue. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*QueueParameters) DeepCopy 

func (in *QueueParameters) DeepCopy() *QueueParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueParameters.

func (*QueueParameters) DeepCopyInto 

func (in *QueueParameters) DeepCopyInto(out *QueueParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueSpec 

type QueueSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     QueueParameters `json:"forProvider"`
}

QueueSpec defines the desired state of Queue

func (*QueueSpec) DeepCopy 

func (in *QueueSpec) DeepCopy() *QueueSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueSpec.

func (*QueueSpec) DeepCopyInto 

func (in *QueueSpec) DeepCopyInto(out *QueueSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueStatus 

type QueueStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        QueueObservation `json:"atProvider,omitempty"`
}

QueueStatus defines the observed state of Queue.

func (*QueueStatus) DeepCopy 

func (in *QueueStatus) DeepCopy() *QueueStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueStatus.

func (*QueueStatus) DeepCopyInto 

func (in *QueueStatus) DeepCopyInto(out *QueueStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkJob 

type SparkJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SparkJobSpec   `json:"spec"`
	Status            SparkJobStatus `json:"status,omitempty"`
}

SparkJob is the Schema for the SparkJobs API. ""page_title: "flexibleengine_dli_spark_job" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,flexibleengine}

func (*SparkJob) DeepCopy 

func (in *SparkJob) DeepCopy() *SparkJob

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkJob.

func (*SparkJob) DeepCopyInto 

func (in *SparkJob) DeepCopyInto(out *SparkJob)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SparkJob) DeepCopyObject 

func (in *SparkJob) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*SparkJob) GetCondition 

func (mg *SparkJob) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this SparkJob.

func (*SparkJob) GetConnectionDetailsMapping 

func (tr *SparkJob) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this SparkJob

func (*SparkJob) GetDeletionPolicy 

func (mg *SparkJob) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this SparkJob.

func (*SparkJob) GetID 

func (tr *SparkJob) GetID() string

GetID returns ID of underlying Terraform resource of this SparkJob

func (*SparkJob) GetObservation 

func (tr *SparkJob) GetObservation() (map[string]any, error)

GetObservation of this SparkJob

func (*SparkJob) GetParameters 

func (tr *SparkJob) GetParameters() (map[string]any, error)

GetParameters of this SparkJob

func (*SparkJob) GetProviderConfigReference 

func (mg *SparkJob) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this SparkJob.

func (*SparkJob) GetProviderReference 

func (mg *SparkJob) GetProviderReference() *xpv1.Reference

GetProviderReference of this SparkJob. Deprecated: Use GetProviderConfigReference.

func (*SparkJob) GetPublishConnectionDetailsTo 

func (mg *SparkJob) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this SparkJob.

func (*SparkJob) GetTerraformResourceType 

func (mg *SparkJob) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this SparkJob

func (*SparkJob) GetTerraformSchemaVersion 

func (tr *SparkJob) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*SparkJob) GetWriteConnectionSecretToReference 

func (mg *SparkJob) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this SparkJob.

func (*SparkJob) LateInitialize 

func (tr *SparkJob) LateInitialize(attrs []byte) (bool, error)

LateInitialize this SparkJob using its observed tfState. returns True if there are any spec changes for the resource.

func (*SparkJob) ResolveReferences 

func (mg *SparkJob) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this SparkJob.

func (*SparkJob) SetConditions 

func (mg *SparkJob) SetConditions(c ...xpv1.Condition)

SetConditions of this SparkJob.

func (*SparkJob) SetDeletionPolicy 

func (mg *SparkJob) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this SparkJob.

func (*SparkJob) SetObservation 

func (tr *SparkJob) SetObservation(obs map[string]any) error

SetObservation for this SparkJob

func (*SparkJob) SetParameters 

func (tr *SparkJob) SetParameters(params map[string]any) error

SetParameters for this SparkJob

func (*SparkJob) SetProviderConfigReference 

func (mg *SparkJob) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this SparkJob.

func (*SparkJob) SetProviderReference 

func (mg *SparkJob) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this SparkJob. Deprecated: Use SetProviderConfigReference.

func (*SparkJob) SetPublishConnectionDetailsTo 

func (mg *SparkJob) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this SparkJob.

func (*SparkJob) SetWriteConnectionSecretToReference 

func (mg *SparkJob) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this SparkJob.

type SparkJobList 

type SparkJobList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []SparkJob `json:"items"`
}

SparkJobList contains a list of SparkJobs

func (*SparkJobList) DeepCopy 

func (in *SparkJobList) DeepCopy() *SparkJobList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkJobList.

func (*SparkJobList) DeepCopyInto 

func (in *SparkJobList) DeepCopyInto(out *SparkJobList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*SparkJobList) DeepCopyObject 

func (in *SparkJobList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*SparkJobList) GetItems 

func (l *SparkJobList) GetItems() []resource.Managed

GetItems of this SparkJobList.

type SparkJobObservation 

type SparkJobObservation struct {

	// Time of the DLI spark job submit.
	CreatedAt *string `json:"createdAt,omitempty" tf:"created_at,omitempty"`

	// ID of the spark job.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The owner of the spark job.
	Owner *string `json:"owner,omitempty" tf:"owner,omitempty"`
}

func (*SparkJobObservation) DeepCopy 

func (in *SparkJobObservation) DeepCopy() *SparkJobObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkJobObservation.

func (*SparkJobObservation) DeepCopyInto 

func (in *SparkJobObservation) DeepCopyInto(out *SparkJobObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkJobParameters 

type SparkJobParameters struct {

	// Specifies the name of the package that is of the JAR or python file type and
	// has been uploaded to the DLI resource management system.
	// The OBS paths are allowed, for example, obs://<bucket name>/<package name>.
	// Changing this parameter will submit a new spark job.
	// +crossplane:generate:reference:type=DLIPackage
	// +kubebuilder:validation:Optional
	AppName *string `json:"appName,omitempty" tf:"app_name,omitempty"`

	// Reference to a DLIPackage to populate appName.
	// +kubebuilder:validation:Optional
	AppNameRef *v1.Reference `json:"appNameRef,omitempty" tf:"-"`

	// Selector for a DLIPackage to populate appName.
	// +kubebuilder:validation:Optional
	AppNameSelector *v1.Selector `json:"appNameSelector,omitempty" tf:"-"`

	// Specifies the input parameters of the main class.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	AppParameters *string `json:"appParameters,omitempty" tf:"app_parameters,omitempty"`

	// Specifies the configuration items of the DLI spark.
	// Please following the document of Spark configurations for
	// this argument. If you want to enable the access metadata of DLI spark in Flexibleengine, please set
	// spark.dli.metaAccess.enable to true. Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	Configurations map[string]*string `json:"configurations,omitempty" tf:"configurations,omitempty"`

	// Specifies a list of package resource objects.
	// The object structure is documented below.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	DependentPackages []DependentPackagesParameters `json:"dependentPackages,omitempty" tf:"dependent_packages,omitempty"`

	// Specifies the number of CPU cores of the Spark application driver.
	// The default value of this value corresponds to the configuration of the selected specification.
	// If you set this value instead of the default value, specification will be invalid.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	DriverCores *float64 `json:"driverCores,omitempty" tf:"driver_cores,omitempty"`

	// Specifies the driver memory of the spark application.
	// The default value of this value corresponds to the configuration of the selected specification.
	// If you set this value instead of the default value, specification will be invalid.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	DriverMemory *string `json:"driverMemory,omitempty" tf:"driver_memory,omitempty"`

	// Specifies the number of CPU cores of each executor in the Spark
	// application. The default value of this value corresponds to the configuration of the selected specification.
	// If you set this value instead of the default value, specification will be invalid.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	ExecutorCores *float64 `json:"executorCores,omitempty" tf:"executor_cores,omitempty"`

	// Specifies the executor memory of the spark application.
	// application. The default value of this value corresponds to the configuration of the selected specification.
	// If you set this value instead of the default value, specification will be invalid.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	ExecutorMemory *string `json:"executorMemory,omitempty" tf:"executor_memory,omitempty"`

	// Specifies the number of executors in a spark application.
	// The default value of this value corresponds to the configuration of the selected specification.
	// If you set this value instead of the default value, specification will be invalid.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	Executors *float64 `json:"executors,omitempty" tf:"executors,omitempty"`

	// Specifies a list of the other dependencies name which has been uploaded to the
	// DLI resource management system. The OBS paths are allowed, for example, obs://<bucket name>/<dependent files>.
	// Changing this parameter will submit a new spark job.
	// +crossplane:generate:reference:type=DLIPackage
	// +kubebuilder:validation:Optional
	Files []*string `json:"files,omitempty" tf:"files,omitempty"`

	// References to DLIPackage to populate files.
	// +kubebuilder:validation:Optional
	FilesRefs []v1.Reference `json:"filesRefs,omitempty" tf:"-"`

	// Selector for a list of DLIPackage to populate files.
	// +kubebuilder:validation:Optional
	FilesSelector *v1.Selector `json:"filesSelector,omitempty" tf:"-"`

	// Specifies a list of the jar package name which has been uploaded to the DLI
	// resource management system. The OBS paths are allowed, for example, obs://<bucket name>/<package name>.
	// Changing this parameter will submit a new spark job.
	// +crossplane:generate:reference:type=DLIPackage
	// +kubebuilder:validation:Optional
	Jars []*string `json:"jars,omitempty" tf:"jars,omitempty"`

	// References to DLIPackage to populate jars.
	// +kubebuilder:validation:Optional
	JarsRefs []v1.Reference `json:"jarsRefs,omitempty" tf:"-"`

	// Selector for a list of DLIPackage to populate jars.
	// +kubebuilder:validation:Optional
	JarsSelector *v1.Selector `json:"jarsSelector,omitempty" tf:"-"`

	// Specifies the main class of the spark job.
	// Required if the app_name is the JAR type.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	MainClass *string `json:"mainClass,omitempty" tf:"main_class,omitempty"`

	// Specifies the maximum retry times.
	// The default value of this value corresponds to the configuration of the selected specification.
	// If you set this value instead of the default value, specification will be invalid.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	MaxRetries *float64 `json:"maxRetries,omitempty" tf:"max_retries,omitempty"`

	// Specifies a list of modules that depend on system resources.
	// The dependent modules and corresponding services are as follows.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	Modules []*string `json:"modules,omitempty" tf:"modules,omitempty"`

	// Specifies the spark job name.
	// The value contains a maximum of 128 characters.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies a list of the python file name which has been uploaded to the
	// DLI resource management system. The OBS paths are allowed, for example, obs://<bucket name>/<python file name>.
	// Changing this parameter will submit a new spark job.
	// +crossplane:generate:reference:type=DLIPackage
	// +kubebuilder:validation:Optional
	PythonFiles []*string `json:"pythonFiles,omitempty" tf:"python_files,omitempty"`

	// References to DLIPackage to populate pythonFiles.
	// +kubebuilder:validation:Optional
	PythonFilesRefs []v1.Reference `json:"pythonFilesRefs,omitempty" tf:"-"`

	// Selector for a list of DLIPackage to populate pythonFiles.
	// +kubebuilder:validation:Optional
	PythonFilesSelector *v1.Selector `json:"pythonFilesSelector,omitempty" tf:"-"`

	// Specifies the DLI queue name.
	// Changing this parameter will submit a new spark job.
	// +crossplane:generate:reference:type=Queue
	// +kubebuilder:validation:Optional
	QueueName *string `json:"queueName,omitempty" tf:"queue_name,omitempty"`

	// Reference to a Queue to populate queueName.
	// +kubebuilder:validation:Optional
	QueueNameRef *v1.Reference `json:"queueNameRef,omitempty" tf:"-"`

	// Selector for a Queue to populate queueName.
	// +kubebuilder:validation:Optional
	QueueNameSelector *v1.Selector `json:"queueNameSelector,omitempty" tf:"-"`

	// Specifies the region in which to submit a spark job.
	// If omitted, the provider-level region will be used.
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies the compute resource type for spark application.
	// The available types and related specifications are as follows, default to minimum configuration (type A).
	// Changing this parameter will submit a new spark job.
	// +kubebuilder:validation:Optional
	Specification *string `json:"specification,omitempty" tf:"specification,omitempty"`
}

func (*SparkJobParameters) DeepCopy 

func (in *SparkJobParameters) DeepCopy() *SparkJobParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkJobParameters.

func (*SparkJobParameters) DeepCopyInto 

func (in *SparkJobParameters) DeepCopyInto(out *SparkJobParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkJobSpec 

type SparkJobSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SparkJobParameters `json:"forProvider"`
}

SparkJobSpec defines the desired state of SparkJob

func (*SparkJobSpec) DeepCopy 

func (in *SparkJobSpec) DeepCopy() *SparkJobSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkJobSpec.

func (*SparkJobSpec) DeepCopyInto 

func (in *SparkJobSpec) DeepCopyInto(out *SparkJobSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type SparkJobStatus 

type SparkJobStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        SparkJobObservation `json:"atProvider,omitempty"`
}

SparkJobStatus defines the observed state of SparkJob.

func (*SparkJobStatus) DeepCopy 

func (in *SparkJobStatus) DeepCopy() *SparkJobStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkJobStatus.

func (*SparkJobStatus) DeepCopyInto 

func (in *SparkJobStatus) DeepCopyInto(out *SparkJobStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Table 

type Table struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TableSpec   `json:"spec"`
	Status            TableStatus `json:"status,omitempty"`
}

Table is the Schema for the Tables API. ""page_title: "flexibleengine_dli_table" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,flexibleengine}

func (*Table) DeepCopy 

func (in *Table) DeepCopy() *Table

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Table.

func (*Table) DeepCopyInto 

func (in *Table) DeepCopyInto(out *Table)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Table) DeepCopyObject 

func (in *Table) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Table) GetCondition 

func (mg *Table) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Table.

func (*Table) GetConnectionDetailsMapping 

func (tr *Table) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Table

func (*Table) GetDeletionPolicy 

func (mg *Table) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Table.

func (*Table) GetID 

func (tr *Table) GetID() string

GetID returns ID of underlying Terraform resource of this Table

func (*Table) GetObservation 

func (tr *Table) GetObservation() (map[string]any, error)

GetObservation of this Table

func (*Table) GetParameters 

func (tr *Table) GetParameters() (map[string]any, error)

GetParameters of this Table

func (*Table) GetProviderConfigReference 

func (mg *Table) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Table.

func (*Table) GetProviderReference 

func (mg *Table) GetProviderReference() *xpv1.Reference

GetProviderReference of this Table. Deprecated: Use GetProviderConfigReference.

func (*Table) GetPublishConnectionDetailsTo 

func (mg *Table) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Table.

func (*Table) GetTerraformResourceType 

func (mg *Table) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Table

func (*Table) GetTerraformSchemaVersion 

func (tr *Table) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Table) GetWriteConnectionSecretToReference 

func (mg *Table) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Table.

func (*Table) LateInitialize 

func (tr *Table) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Table using its observed tfState. returns True if there are any spec changes for the resource.

func (*Table) ResolveReferences 

func (mg *Table) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this Table.

func (*Table) SetConditions 

func (mg *Table) SetConditions(c ...xpv1.Condition)

SetConditions of this Table.

func (*Table) SetDeletionPolicy 

func (mg *Table) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Table.

func (*Table) SetObservation 

func (tr *Table) SetObservation(obs map[string]any) error

SetObservation for this Table

func (*Table) SetParameters 

func (tr *Table) SetParameters(params map[string]any) error

SetParameters for this Table

func (*Table) SetProviderConfigReference 

func (mg *Table) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Table.

func (*Table) SetProviderReference 

func (mg *Table) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Table. Deprecated: Use SetProviderConfigReference.

func (*Table) SetPublishConnectionDetailsTo 

func (mg *Table) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Table.

func (*Table) SetWriteConnectionSecretToReference 

func (mg *Table) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Table.

type TableList 

type TableList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Table `json:"items"`
}

TableList contains a list of Tables

func (*TableList) DeepCopy 

func (in *TableList) DeepCopy() *TableList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TableList.

func (*TableList) DeepCopyInto 

func (in *TableList) DeepCopyInto(out *TableList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*TableList) DeepCopyObject 

func (in *TableList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*TableList) GetItems 

func (l *TableList) GetItems() []resource.Managed

GetItems of this TableList.

type TableObservation 

type TableObservation struct {

	// A resource ID in format of database_name/table_name. It is composed of the name of database which table
	// belongs and the name of table, separated by a slash.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*TableObservation) DeepCopy 

func (in *TableObservation) DeepCopy() *TableObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TableObservation.

func (*TableObservation) DeepCopyInto 

func (in *TableObservation) DeepCopyInto(out *TableObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TableParameters 

type TableParameters struct {

	// Specifies storage path of data which will be import to the OBS table.
	// Changing this parameter will create a new resource.
	// -> If you need to import data stored in OBS to the OBS table, set this parameter to the path of a folder. If the table
	// creation path is a file, data fails to be imported. which must be a path on OBS and must begin with obs.
	// +kubebuilder:validation:Optional
	BucketLocation *string `json:"bucketLocation,omitempty" tf:"bucket_location,omitempty"`

	// Specifies Columns of the new table. Structure is documented below.
	// Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Columns []ColumnsParameters `json:"columns,omitempty" tf:"columns,omitempty"`

	// Specifies type of the data to be added to the OBS table.
	// The options: parquet, orc, csv, json, carbon, and avro. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	DataFormat *string `json:"dataFormat,omitempty" tf:"data_format,omitempty"`

	// Specifies data storage location. Changing this parameter will create
	// a newresource. The options are as follows:
	// +kubebuilder:validation:Required
	DataLocation *string `json:"dataLocation" tf:"data_location,omitempty"`

	// Specifies the database name which the table belongs to.
	// Changing this parameter will create a new resource.
	// +crossplane:generate:reference:type=Database
	// +kubebuilder:validation:Optional
	DatabaseName *string `json:"databaseName,omitempty" tf:"database_name,omitempty"`

	// Reference to a Database to populate databaseName.
	// +kubebuilder:validation:Optional
	DatabaseNameRef *v1.Reference `json:"databaseNameRef,omitempty" tf:"-"`

	// Selector for a Database to populate databaseName.
	// +kubebuilder:validation:Optional
	DatabaseNameSelector *v1.Selector `json:"databaseNameSelector,omitempty" tf:"-"`

	// Specifies date type. yyyy-MM-dd is used by default. Only
	// data in CSV and JSON files has this attribute. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	DateFormat *string `json:"dateFormat,omitempty" tf:"date_format,omitempty"`

	// Specifies data delimiter. Only data in CSV files has this
	// attribute. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Delimiter *string `json:"delimiter,omitempty" tf:"delimiter,omitempty"`

	// Specifies description of the table.
	// Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies escape character. Backslashes (\\) are used by
	// default. Only data in CSV files has this attribute. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	EscapeChar *string `json:"escapeChar,omitempty" tf:"escape_char,omitempty"`

	// Specifies the table name. The name can contain only digits, letters,
	// and underscores, but cannot contain only digits or start with an underscore. Length range: 1 to 128 characters.
	// Changing this parameter will create a new resource.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies reference character. Double quotation marks (\)
	// are used by default. Only data in CSV files has this attribute. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	QuoteChar *string `json:"quoteChar,omitempty" tf:"quote_char,omitempty"`

	// Specifies the region in which to create the dli table resource. If omitted,
	// the provider-level region will be used. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies timestamp type. yyyy-MM-dd HH:mm:ss is used by default.
	// Only data in CSV and JSON files has this attribute. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	TimestampFormat *string `json:"timestampFormat,omitempty" tf:"timestamp_format,omitempty"`

	// Specifies whether the table header is included in the data file.
	// Only data in CSV files has this attribute. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	WithColumnHeader *bool `json:"withColumnHeader,omitempty" tf:"with_column_header,omitempty"`
}

func (*TableParameters) DeepCopy 

func (in *TableParameters) DeepCopy() *TableParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TableParameters.

func (*TableParameters) DeepCopyInto 

func (in *TableParameters) DeepCopyInto(out *TableParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TableSpec 

type TableSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     TableParameters `json:"forProvider"`
}

TableSpec defines the desired state of Table

func (*TableSpec) DeepCopy 

func (in *TableSpec) DeepCopy() *TableSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TableSpec.

func (*TableSpec) DeepCopyInto 

func (in *TableSpec) DeepCopyInto(out *TableSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type TableStatus 

type TableStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        TableObservation `json:"atProvider,omitempty"`
}

TableStatus defines the observed state of Table.

func (*TableStatus) DeepCopy 

func (in *TableStatus) DeepCopy() *TableStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TableStatus.

func (*TableStatus) DeepCopyInto 

func (in *TableStatus) DeepCopyInto(out *TableStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.