v1alpha1

type AppV2 struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	Spec   AppV2Spec   `json:"spec"`
	Status AppV2Status `json:"status,omitempty"`
}

type AppV2InitParameters struct {

	// Name of the consumer application to be created
	// The application name contains 1 to 200 characters. Only letters, digits, hyphens (-), and underscores (_) are allowed.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`
}

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

type AppV2Observation struct {

	// List of associated streams.
	CommitCheckpointStreamNames []*string `json:"commitCheckpointStreamNames,omitempty" tf:"commit_checkpoint_stream_names,omitempty"`

	// Time when the app is created. The value is a timestamp.
	Created *float64 `json:"created,omitempty" tf:"created,omitempty"`

	// Unique identifier of the app.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Name of the consumer application to be created
	// The application name contains 1 to 200 characters. Only letters, digits, hyphens (-), and underscores (_) are allowed.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Associated partitions details.
	PartitionConsumingStates []PartitionConsumingStatesObservation `json:"partitionConsumingStates,omitempty" tf:"partition_consuming_states,omitempty"`
}

type AppV2Parameters struct {

	// Name of the consumer application to be created
	// The application name contains 1 to 200 characters. Only letters, digits, hyphens (-), and underscores (_) are allowed.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`
}

type AppV2Spec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     AppV2Parameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider AppV2InitParameters `json:"initProvider,omitempty"`
}

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

type CheckpointV2 struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.partitionId) || (has(self.initProvider) && has(self.initProvider.partitionId))",message="spec.forProvider.partitionId is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.sequenceNumber) || (has(self.initProvider) && has(self.initProvider.sequenceNumber))",message="spec.forProvider.sequenceNumber is a required parameter"
	Spec   CheckpointV2Spec   `json:"spec"`
	Status CheckpointV2Status `json:"status,omitempty"`
}

type CheckpointV2InitParameters struct {

	// Name of the consumer application to be created
	// The application name contains 1 to 200 characters. Only letters, digits, hyphens (-), and underscores (_) are allowed.
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/dis/v1alpha1.AppV2
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractDisAppName()
	AppName *string `json:"appName,omitempty" tf:"app_name,omitempty"`

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

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

	// Type of the checkpoint. LAST_READ: Only sequence numbers are recorded in databases.
	// Default value: LAST_READ
	CheckpointType *string `json:"checkpointType,omitempty" tf:"checkpoint_type,omitempty"`

	// Metadata information of the consumer application.
	// Maximum length: 1000
	Metadata *string `json:"metadata,omitempty" tf:"metadata,omitempty"`

	// Partition ID of the stream The value can be in either of the following formats:
	PartitionID *string `json:"partitionId,omitempty" tf:"partition_id,omitempty"`

	// Sequence number to be submitted, which is used to record the consumption
	// checkpoint of the stream. Ensure that the sequence number is within the valid range.
	SequenceNumber *string `json:"sequenceNumber,omitempty" tf:"sequence_number,omitempty"`

	// Name of the stream. The stream name can contain 1 to 64 characters,
	// including letters, digits, underscores (_), and hyphens (-).
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/dis/v1alpha1.StreamV2
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractDisStreamName()
	StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"`

	// Reference to a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameRef *v1.Reference `json:"streamNameRef,omitempty" tf:"-"`

	// Selector for a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameSelector *v1.Selector `json:"streamNameSelector,omitempty" tf:"-"`
}

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

type CheckpointV2Observation struct {

	// Name of the consumer application to be created
	// The application name contains 1 to 200 characters. Only letters, digits, hyphens (-), and underscores (_) are allowed.
	AppName *string `json:"appName,omitempty" tf:"app_name,omitempty"`

	// Type of the checkpoint. LAST_READ: Only sequence numbers are recorded in databases.
	// Default value: LAST_READ
	CheckpointType *string `json:"checkpointType,omitempty" tf:"checkpoint_type,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Metadata information of the consumer application.
	// Maximum length: 1000
	Metadata *string `json:"metadata,omitempty" tf:"metadata,omitempty"`

	// Partition ID of the stream The value can be in either of the following formats:
	PartitionID *string `json:"partitionId,omitempty" tf:"partition_id,omitempty"`

	// Sequence number to be submitted, which is used to record the consumption
	// checkpoint of the stream. Ensure that the sequence number is within the valid range.
	SequenceNumber *string `json:"sequenceNumber,omitempty" tf:"sequence_number,omitempty"`

	// Name of the stream. The stream name can contain 1 to 64 characters,
	// including letters, digits, underscores (_), and hyphens (-).
	StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"`
}

type CheckpointV2Parameters struct {

	// Name of the consumer application to be created
	// The application name contains 1 to 200 characters. Only letters, digits, hyphens (-), and underscores (_) are allowed.
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/dis/v1alpha1.AppV2
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractDisAppName()
	// +kubebuilder:validation:Optional
	AppName *string `json:"appName,omitempty" tf:"app_name,omitempty"`

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

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

	// Type of the checkpoint. LAST_READ: Only sequence numbers are recorded in databases.
	// Default value: LAST_READ
	// +kubebuilder:validation:Optional
	CheckpointType *string `json:"checkpointType,omitempty" tf:"checkpoint_type,omitempty"`

	// Metadata information of the consumer application.
	// Maximum length: 1000
	// +kubebuilder:validation:Optional
	Metadata *string `json:"metadata,omitempty" tf:"metadata,omitempty"`

	// Partition ID of the stream The value can be in either of the following formats:
	// +kubebuilder:validation:Optional
	PartitionID *string `json:"partitionId,omitempty" tf:"partition_id,omitempty"`

	// Sequence number to be submitted, which is used to record the consumption
	// checkpoint of the stream. Ensure that the sequence number is within the valid range.
	// +kubebuilder:validation:Optional
	SequenceNumber *string `json:"sequenceNumber,omitempty" tf:"sequence_number,omitempty"`

	// Name of the stream. The stream name can contain 1 to 64 characters,
	// including letters, digits, underscores (_), and hyphens (-).
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/dis/v1alpha1.StreamV2
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractDisStreamName()
	// +kubebuilder:validation:Optional
	StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"`

	// Reference to a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameRef *v1.Reference `json:"streamNameRef,omitempty" tf:"-"`

	// Selector for a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameSelector *v1.Selector `json:"streamNameSelector,omitempty" tf:"-"`
}

type CheckpointV2Spec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     CheckpointV2Parameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider CheckpointV2InitParameters `json:"initProvider,omitempty"`
}

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

type DumpTaskV2 struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DumpTaskV2Spec   `json:"spec"`
	Status            DumpTaskV2Status `json:"status,omitempty"`
}

type DumpTaskV2InitParameters struct {

	// Dump task operation. The value can only be start or stop.
	Action *string `json:"action,omitempty" tf:"action,omitempty"`

	// Dump destination. Possible values:
	// OBS: Data is dumped to OBS.
	Destination *string `json:"destination,omitempty" tf:"destination,omitempty"`

	// Parameter list of OBS to which data in the DIS stream will be dumped.
	ObsDestinationDescriptor []ObsDestinationDescriptorInitParameters `json:"obsDestinationDescriptor,omitempty" tf:"obs_destination_descriptor,omitempty"`

	// Dump time directory generated based on the timestamp
	// of the source data and the configured partition_format.
	// Directory structure of the object file written into OBS.
	// The directory structure is in the format of yyyy/MM/dd/HH/mm.
	ObsProcessingSchema []ObsProcessingSchemaInitParameters `json:"obsProcessingSchema,omitempty" tf:"obs_processing_schema,omitempty"`

	// Name of the stream.
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/dis/v1alpha1.StreamV2
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractDisStreamName()
	StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"`

	// Reference to a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameRef *v1.Reference `json:"streamNameRef,omitempty" tf:"-"`

	// Selector for a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameSelector *v1.Selector `json:"streamNameSelector,omitempty" tf:"-"`
}

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

type DumpTaskV2Observation struct {

	// Dump task operation. The value can only be start or stop.
	Action *string `json:"action,omitempty" tf:"action,omitempty"`

	// Time when the dump task is created.
	CreatedAt *float64 `json:"createdAt,omitempty" tf:"created_at,omitempty"`

	// Dump destination. Possible values:
	// OBS: Data is dumped to OBS.
	Destination *string `json:"destination,omitempty" tf:"destination,omitempty"`

	// : Unique identifier of the partition.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Latest dump time of the dump task.
	LastTransferTimestamp *float64 `json:"lastTransferTimestamp,omitempty" tf:"last_transfer_timestamp,omitempty"`

	// Name of the dump task.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Parameter list of OBS to which data in the DIS stream will be dumped.
	ObsDestinationDescriptor []ObsDestinationDescriptorObservation `json:"obsDestinationDescriptor,omitempty" tf:"obs_destination_descriptor,omitempty"`

	// Dump time directory generated based on the timestamp
	// of the source data and the configured partition_format.
	// Directory structure of the object file written into OBS.
	// The directory structure is in the format of yyyy/MM/dd/HH/mm.
	ObsProcessingSchema []ObsProcessingSchemaObservation `json:"obsProcessingSchema,omitempty" tf:"obs_processing_schema,omitempty"`

	// List of partition dump details.
	Partitions []PartitionsObservation `json:"partitions,omitempty" tf:"partitions,omitempty"`

	// Current status of the stream, can be:
	Status *string `json:"status,omitempty" tf:"status,omitempty"`

	// Name of the stream.
	StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"`

	// ID of the dump task.
	TaskID *string `json:"taskId,omitempty" tf:"task_id,omitempty"`
}

type DumpTaskV2Parameters struct {

	// Dump task operation. The value can only be start or stop.
	// +kubebuilder:validation:Optional
	Action *string `json:"action,omitempty" tf:"action,omitempty"`

	// Dump destination. Possible values:
	// OBS: Data is dumped to OBS.
	// +kubebuilder:validation:Optional
	Destination *string `json:"destination,omitempty" tf:"destination,omitempty"`

	// Parameter list of OBS to which data in the DIS stream will be dumped.
	// +kubebuilder:validation:Optional
	ObsDestinationDescriptor []ObsDestinationDescriptorParameters `json:"obsDestinationDescriptor,omitempty" tf:"obs_destination_descriptor,omitempty"`

	// Dump time directory generated based on the timestamp
	// of the source data and the configured partition_format.
	// Directory structure of the object file written into OBS.
	// The directory structure is in the format of yyyy/MM/dd/HH/mm.
	// +kubebuilder:validation:Optional
	ObsProcessingSchema []ObsProcessingSchemaParameters `json:"obsProcessingSchema,omitempty" tf:"obs_processing_schema,omitempty"`

	// Name of the stream.
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/dis/v1alpha1.StreamV2
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractDisStreamName()
	// +kubebuilder:validation:Optional
	StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"`

	// Reference to a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameRef *v1.Reference `json:"streamNameRef,omitempty" tf:"-"`

	// Selector for a StreamV2 in dis to populate streamName.
	// +kubebuilder:validation:Optional
	StreamNameSelector *v1.Selector `json:"streamNameSelector,omitempty" tf:"-"`
}

type DumpTaskV2Spec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     DumpTaskV2Parameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider DumpTaskV2InitParameters `json:"initProvider,omitempty"`
}

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

type ObsDestinationDescriptorInitParameters struct {

	// Name of the agency created on IAM. DIS uses an agency to access your specified resources.
	// The parameters for creating an agency are as follows:
	AgencyName *string `json:"agencyName,omitempty" tf:"agency_name,omitempty"`

	// Offset.
	// LATEST: Maximum offset, indicating that the latest data will be extracted.
	// TRIM_HORIZON: Minimum offset, indicating that the earliest data will be extracted.
	ConsumerStrategy *string `json:"consumerStrategy,omitempty" tf:"consumer_strategy,omitempty"`

	// User-defined interval at which data is imported from the current DIS stream into OBS.
	// If no data is pushed to the DIS stream during the current interval, no dump file package will be generated. Value range: 30-900.
	DeliverTimeInterval *float64 `json:"deliverTimeInterval,omitempty" tf:"deliver_time_interval,omitempty"`

	// Dump file format. Possible values: text
	DestinationFileType *string `json:"destinationFileType,omitempty" tf:"destination_file_type,omitempty"`

	// Directory to store files that will be dumped to OBS.
	// Different directory levels are separated by slashes (/) and cannot start with slashes.
	FilePrefix *string `json:"filePrefix,omitempty" tf:"file_prefix,omitempty"`

	// Name of the OBS bucket used to store data from the DIS stream.
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/obs/v1alpha1.Bucket
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractObsBucket()
	ObsBucketPath *string `json:"obsBucketPath,omitempty" tf:"obs_bucket_path,omitempty"`

	// Reference to a Bucket in obs to populate obsBucketPath.
	// +kubebuilder:validation:Optional
	ObsBucketPathRef *v1.Reference `json:"obsBucketPathRef,omitempty" tf:"-"`

	// Selector for a Bucket in obs to populate obsBucketPath.
	// +kubebuilder:validation:Optional
	ObsBucketPathSelector *v1.Selector `json:"obsBucketPathSelector,omitempty" tf:"-"`

	// Directory structure of the object file written into OBS.
	// The directory structure is in the format of yyyy/MM/dd/HH/mm (time at which the dump task was created).
	// Possible values:
	PartitionFormat *string `json:"partitionFormat,omitempty" tf:"partition_format,omitempty"`

	// Delimiter for the dump file, which is used to separate the user data that is written into the dump file.
	RecordDelimiter *string `json:"recordDelimiter,omitempty" tf:"record_delimiter,omitempty"`

	// Name of the dump task. The task name consists of letters, digits, hyphens (-), and underscores (_). It must be a string of 1 to 64 characters.
	TaskName *string `json:"taskName,omitempty" tf:"task_name,omitempty"`
}

type ObsDestinationDescriptorObservation struct {

	// Name of the agency created on IAM. DIS uses an agency to access your specified resources.
	// The parameters for creating an agency are as follows:
	AgencyName *string `json:"agencyName,omitempty" tf:"agency_name,omitempty"`

	// Offset.
	// LATEST: Maximum offset, indicating that the latest data will be extracted.
	// TRIM_HORIZON: Minimum offset, indicating that the earliest data will be extracted.
	ConsumerStrategy *string `json:"consumerStrategy,omitempty" tf:"consumer_strategy,omitempty"`

	// User-defined interval at which data is imported from the current DIS stream into OBS.
	// If no data is pushed to the DIS stream during the current interval, no dump file package will be generated. Value range: 30-900.
	DeliverTimeInterval *float64 `json:"deliverTimeInterval,omitempty" tf:"deliver_time_interval,omitempty"`

	// Dump file format. Possible values: text
	DestinationFileType *string `json:"destinationFileType,omitempty" tf:"destination_file_type,omitempty"`

	// Directory to store files that will be dumped to OBS.
	// Different directory levels are separated by slashes (/) and cannot start with slashes.
	FilePrefix *string `json:"filePrefix,omitempty" tf:"file_prefix,omitempty"`

	// Name of the OBS bucket used to store data from the DIS stream.
	ObsBucketPath *string `json:"obsBucketPath,omitempty" tf:"obs_bucket_path,omitempty"`

	// Directory structure of the object file written into OBS.
	// The directory structure is in the format of yyyy/MM/dd/HH/mm (time at which the dump task was created).
	// Possible values:
	PartitionFormat *string `json:"partitionFormat,omitempty" tf:"partition_format,omitempty"`

	// Delimiter for the dump file, which is used to separate the user data that is written into the dump file.
	RecordDelimiter *string `json:"recordDelimiter,omitempty" tf:"record_delimiter,omitempty"`

	// Name of the dump task. The task name consists of letters, digits, hyphens (-), and underscores (_). It must be a string of 1 to 64 characters.
	TaskName *string `json:"taskName,omitempty" tf:"task_name,omitempty"`
}

type ObsDestinationDescriptorParameters struct {

	// Name of the agency created on IAM. DIS uses an agency to access your specified resources.
	// The parameters for creating an agency are as follows:
	// +kubebuilder:validation:Optional
	AgencyName *string `json:"agencyName" tf:"agency_name,omitempty"`

	// Offset.
	// LATEST: Maximum offset, indicating that the latest data will be extracted.
	// TRIM_HORIZON: Minimum offset, indicating that the earliest data will be extracted.
	// +kubebuilder:validation:Optional
	ConsumerStrategy *string `json:"consumerStrategy,omitempty" tf:"consumer_strategy,omitempty"`

	// User-defined interval at which data is imported from the current DIS stream into OBS.
	// If no data is pushed to the DIS stream during the current interval, no dump file package will be generated. Value range: 30-900.
	// +kubebuilder:validation:Optional
	DeliverTimeInterval *float64 `json:"deliverTimeInterval" tf:"deliver_time_interval,omitempty"`

	// Dump file format. Possible values: text
	// +kubebuilder:validation:Optional
	DestinationFileType *string `json:"destinationFileType,omitempty" tf:"destination_file_type,omitempty"`

	// Directory to store files that will be dumped to OBS.
	// Different directory levels are separated by slashes (/) and cannot start with slashes.
	// +kubebuilder:validation:Optional
	FilePrefix *string `json:"filePrefix,omitempty" tf:"file_prefix,omitempty"`

	// Name of the OBS bucket used to store data from the DIS stream.
	// +crossplane:generate:reference:type=github.com/opentelekomcloud/provider-opentelekomcloud/apis/obs/v1alpha1.Bucket
	// +crossplane:generate:reference:extractor=github.com/opentelekomcloud/provider-opentelekomcloud/config/common.ExtractObsBucket()
	// +kubebuilder:validation:Optional
	ObsBucketPath *string `json:"obsBucketPath,omitempty" tf:"obs_bucket_path,omitempty"`

	// Reference to a Bucket in obs to populate obsBucketPath.
	// +kubebuilder:validation:Optional
	ObsBucketPathRef *v1.Reference `json:"obsBucketPathRef,omitempty" tf:"-"`

	// Selector for a Bucket in obs to populate obsBucketPath.
	// +kubebuilder:validation:Optional
	ObsBucketPathSelector *v1.Selector `json:"obsBucketPathSelector,omitempty" tf:"-"`

	// Directory structure of the object file written into OBS.
	// The directory structure is in the format of yyyy/MM/dd/HH/mm (time at which the dump task was created).
	// Possible values:
	// +kubebuilder:validation:Optional
	PartitionFormat *string `json:"partitionFormat,omitempty" tf:"partition_format,omitempty"`

	// Delimiter for the dump file, which is used to separate the user data that is written into the dump file.
	// +kubebuilder:validation:Optional
	RecordDelimiter *string `json:"recordDelimiter,omitempty" tf:"record_delimiter,omitempty"`

	// Name of the dump task. The task name consists of letters, digits, hyphens (-), and underscores (_). It must be a string of 1 to 64 characters.
	// +kubebuilder:validation:Optional
	TaskName *string `json:"taskName" tf:"task_name,omitempty"`
}

type ObsProcessingSchemaInitParameters struct {

	// OBS directory generated based on the timestamp format.
	// This parameter is mandatory when the timestamp type of the source data is String.
	TimestampFormat *string `json:"timestampFormat,omitempty" tf:"timestamp_format,omitempty"`

	// Attribute name of the source data timestamp.
	TimestampName *string `json:"timestampName,omitempty" tf:"timestamp_name,omitempty"`

	// Type of the source data timestamp.
	// Possible values:
	TimestampType *string `json:"timestampType,omitempty" tf:"timestamp_type,omitempty"`
}

type ObsProcessingSchemaObservation struct {

	// OBS directory generated based on the timestamp format.
	// This parameter is mandatory when the timestamp type of the source data is String.
	TimestampFormat *string `json:"timestampFormat,omitempty" tf:"timestamp_format,omitempty"`

	// Attribute name of the source data timestamp.
	TimestampName *string `json:"timestampName,omitempty" tf:"timestamp_name,omitempty"`

	// Type of the source data timestamp.
	// Possible values:
	TimestampType *string `json:"timestampType,omitempty" tf:"timestamp_type,omitempty"`
}

type ObsProcessingSchemaParameters struct {

	// OBS directory generated based on the timestamp format.
	// This parameter is mandatory when the timestamp type of the source data is String.
	// +kubebuilder:validation:Optional
	TimestampFormat *string `json:"timestampFormat,omitempty" tf:"timestamp_format,omitempty"`

	// Attribute name of the source data timestamp.
	// +kubebuilder:validation:Optional
	TimestampName *string `json:"timestampName" tf:"timestamp_name,omitempty"`

	// Type of the source data timestamp.
	// Possible values:
	// +kubebuilder:validation:Optional
	TimestampType *string `json:"timestampType" tf:"timestamp_type,omitempty"`
}

type PartitionConsumingStatesInitParameters struct {
}

type PartitionConsumingStatesObservation struct {

	// : Type of the checkpoint.
	CheckpointType *string `json:"checkpointType,omitempty" tf:"checkpoint_type,omitempty"`

	// : Partition data earliest offset
	EarliestOffset *float64 `json:"earliestOffset,omitempty" tf:"earliest_offset,omitempty"`

	// Unique identifier of the app.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// : Partition data latest offset
	LatestOffset *float64 `json:"latestOffset,omitempty" tf:"latest_offset,omitempty"`

	// : Partition Sequence Number
	SequenceNumber *string `json:"sequenceNumber,omitempty" tf:"sequence_number,omitempty"`

	// : Partition Status, can be:
	Status *string `json:"status,omitempty" tf:"status,omitempty"`
}

type PartitionConsumingStatesParameters struct {
}

type PartitionsInitParameters struct {
}

type PartitionsObservation struct {

	// : Possible value range of the hash key used by the partition.
	HashRange *string `json:"hashRange,omitempty" tf:"hash_range,omitempty"`

	// : Unique identifier of the partition.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// : Parent partition.
	ParentPartitions *string `json:"parentPartitions,omitempty" tf:"parent_partitions,omitempty"`

	// : Sequence number range of the partition.
	SequenceNumberRange *string `json:"sequenceNumberRange,omitempty" tf:"sequence_number_range,omitempty"`

	// Current status of the stream, can be:
	Status *string `json:"status,omitempty" tf:"status,omitempty"`
}

type PartitionsParameters struct {
}

type StreamV2 struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.partitionCount) || (has(self.initProvider) && has(self.initProvider.partitionCount))",message="spec.forProvider.partitionCount is a required parameter"
	Spec   StreamV2Spec   `json:"spec"`
	Status StreamV2Status `json:"status,omitempty"`
}

type StreamV2InitParameters struct {

	// Maximum number of partitions for automatic scale-up when auto-scaling is enabled.
	AutoScaleMaxPartitionCount *float64 `json:"autoScaleMaxPartitionCount,omitempty" tf:"auto_scale_max_partition_count,omitempty"`

	// Minimum number of partitions for automatic scale-down
	// when auto-scaling is enabled. Minimum: 1.
	AutoScaleMinPartitionCount *float64 `json:"autoScaleMinPartitionCount,omitempty" tf:"auto_scale_min_partition_count,omitempty"`

	// Data compression type. The following types are available:
	// snappy, gzip, zip. Data is not compressed by default.
	CompressionFormat *string `json:"compressionFormat,omitempty" tf:"compression_format,omitempty"`

	// Source data type.
	// BLOB: a collection of binary data stored as a single entity in a database management system.
	// Default value: BLOB.
	DataType *string `json:"dataType,omitempty" tf:"data_type,omitempty"`

	// Name of the stream. The stream name can contain 1 to 64 characters,
	// including letters, digits, underscores (_), and hyphens (-).
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Number of partitions. Partitions are the base throughput unit of a DIS stream.
	PartitionCount *float64 `json:"partitionCount,omitempty" tf:"partition_count,omitempty"`

	// Period of time for which data is retained in the stream.
	// Value range: 24-72 Unit: hour. If this parameter is left blank, the default value is used.
	// Maximum: 72
	// Default: 24
	RetentionPeriod *float64 `json:"retentionPeriod,omitempty" tf:"retention_period,omitempty"`

	// Stream type.
	StreamType *string `json:"streamType,omitempty" tf:"stream_type,omitempty"`

	// Tags key/value pairs to associate with the instance.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

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

type StreamV2Observation struct {

	// Maximum number of partitions for automatic scale-up when auto-scaling is enabled.
	AutoScaleMaxPartitionCount *float64 `json:"autoScaleMaxPartitionCount,omitempty" tf:"auto_scale_max_partition_count,omitempty"`

	// Minimum number of partitions for automatic scale-down
	// when auto-scaling is enabled. Minimum: 1.
	AutoScaleMinPartitionCount *float64 `json:"autoScaleMinPartitionCount,omitempty" tf:"auto_scale_min_partition_count,omitempty"`

	// Data compression type. The following types are available:
	// snappy, gzip, zip. Data is not compressed by default.
	CompressionFormat *string `json:"compressionFormat,omitempty" tf:"compression_format,omitempty"`

	// Time when the stream is created. The value is a timestamp.
	Created *float64 `json:"created,omitempty" tf:"created,omitempty"`

	// Source data type.
	// BLOB: a collection of binary data stored as a single entity in a database management system.
	// Default value: BLOB.
	DataType *string `json:"dataType,omitempty" tf:"data_type,omitempty"`

	// : Unique identifier of the partition.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Name of the stream. The stream name can contain 1 to 64 characters,
	// including letters, digits, underscores (_), and hyphens (-).
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Number of partitions. Partitions are the base throughput unit of a DIS stream.
	PartitionCount *float64 `json:"partitionCount,omitempty" tf:"partition_count,omitempty"`

	// Stream partitions details.
	Partitions []StreamV2PartitionsObservation `json:"partitions,omitempty" tf:"partitions,omitempty"`

	// Total number of readable partitions (including partitions in ACTIVE and DELETED state).
	ReadablePartitionCount *float64 `json:"readablePartitionCount,omitempty" tf:"readable_partition_count,omitempty"`

	// Period of time for which data is retained in the stream.
	// Value range: 24-72 Unit: hour. If this parameter is left blank, the default value is used.
	// Maximum: 72
	// Default: 24
	RetentionPeriod *float64 `json:"retentionPeriod,omitempty" tf:"retention_period,omitempty"`

	// Current status of the stream, can be:
	Status *string `json:"status,omitempty" tf:"status,omitempty"`

	// Unique identifier of the stream.
	StreamID *string `json:"streamId,omitempty" tf:"stream_id,omitempty"`

	// Stream type.
	StreamType *string `json:"streamType,omitempty" tf:"stream_type,omitempty"`

	// Tags key/value pairs to associate with the instance.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Total number of writable partitions (including partitions in ACTIVE state only).
	WritablePartitionCount *float64 `json:"writablePartitionCount,omitempty" tf:"writable_partition_count,omitempty"`
}

type StreamV2Parameters struct {

	// Maximum number of partitions for automatic scale-up when auto-scaling is enabled.
	// +kubebuilder:validation:Optional
	AutoScaleMaxPartitionCount *float64 `json:"autoScaleMaxPartitionCount,omitempty" tf:"auto_scale_max_partition_count,omitempty"`

	// Minimum number of partitions for automatic scale-down
	// when auto-scaling is enabled. Minimum: 1.
	// +kubebuilder:validation:Optional
	AutoScaleMinPartitionCount *float64 `json:"autoScaleMinPartitionCount,omitempty" tf:"auto_scale_min_partition_count,omitempty"`

	// Data compression type. The following types are available:
	// snappy, gzip, zip. Data is not compressed by default.
	// +kubebuilder:validation:Optional
	CompressionFormat *string `json:"compressionFormat,omitempty" tf:"compression_format,omitempty"`

	// Source data type.
	// BLOB: a collection of binary data stored as a single entity in a database management system.
	// Default value: BLOB.
	// +kubebuilder:validation:Optional
	DataType *string `json:"dataType,omitempty" tf:"data_type,omitempty"`

	// Name of the stream. The stream name can contain 1 to 64 characters,
	// including letters, digits, underscores (_), and hyphens (-).
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Number of partitions. Partitions are the base throughput unit of a DIS stream.
	// +kubebuilder:validation:Optional
	PartitionCount *float64 `json:"partitionCount,omitempty" tf:"partition_count,omitempty"`

	// Period of time for which data is retained in the stream.
	// Value range: 24-72 Unit: hour. If this parameter is left blank, the default value is used.
	// Maximum: 72
	// Default: 24
	// +kubebuilder:validation:Optional
	RetentionPeriod *float64 `json:"retentionPeriod,omitempty" tf:"retention_period,omitempty"`

	// Stream type.
	// +kubebuilder:validation:Optional
	StreamType *string `json:"streamType,omitempty" tf:"stream_type,omitempty"`

	// Tags key/value pairs to associate with the instance.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

type StreamV2PartitionsInitParameters struct {
}

type StreamV2PartitionsObservation struct {

	// : Possible value range of the hash key used by the partition.
	HashRange *string `json:"hashRange,omitempty" tf:"hash_range,omitempty"`

	// : Unique identifier of the partition.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// : Parent partition.
	ParentPartitions *string `json:"parentPartitions,omitempty" tf:"parent_partitions,omitempty"`

	// : Sequence number range of the partition.
	SequenceNumberRange *string `json:"sequenceNumberRange,omitempty" tf:"sequence_number_range,omitempty"`

	// Current status of the stream, can be:
	Status *string `json:"status,omitempty" tf:"status,omitempty"`
}

type StreamV2PartitionsParameters struct {
}

type StreamV2Spec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     StreamV2Parameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider StreamV2InitParameters `json:"initProvider,omitempty"`
}

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