Documentation ¶
Overview ¶
+kubebuilder:object:generate=true +groupName=qldb.aws.upbound.io +versionName=v1beta2
Index ¶
- Constants
- Variables
- type KinesisConfigurationInitParameters
- type KinesisConfigurationObservation
- type KinesisConfigurationParameters
- type Stream
- func (in *Stream) DeepCopy() *Stream
- func (in *Stream) DeepCopyInto(out *Stream)
- func (in *Stream) DeepCopyObject() runtime.Object
- func (mg *Stream) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *Stream) GetConnectionDetailsMapping() map[string]string
- func (mg *Stream) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Stream) GetID() string
- func (tr *Stream) GetInitParameters() (map[string]any, error)
- func (mg *Stream) GetManagementPolicies() xpv1.ManagementPolicies
- func (tr *Stream) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
- func (tr *Stream) GetObservation() (map[string]any, error)
- func (tr *Stream) GetParameters() (map[string]any, error)
- func (mg *Stream) GetProviderConfigReference() *xpv1.Reference
- func (mg *Stream) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Stream) GetTerraformResourceType() string
- func (tr *Stream) GetTerraformSchemaVersion() int
- func (mg *Stream) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Stream) Hub()
- func (tr *Stream) LateInitialize(attrs []byte) (bool, error)
- func (mg *Stream) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *Stream) SetConditions(c ...xpv1.Condition)
- func (mg *Stream) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *Stream) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *Stream) SetObservation(obs map[string]any) error
- func (tr *Stream) SetParameters(params map[string]any) error
- func (mg *Stream) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Stream) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Stream) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type StreamInitParameters
- type StreamList
- type StreamObservation
- type StreamParameters
- type StreamSpec
- type StreamStatus
Constants ¶
const ( CRDGroup = "qldb.aws.upbound.io" CRDVersion = "v1beta2" )
Package type metadata.
Variables ¶
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 )
var ( Stream_Kind = "Stream" Stream_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Stream_Kind}.String() Stream_KindAPIVersion = Stream_Kind + "." + CRDGroupVersion.String() Stream_GroupVersionKind = CRDGroupVersion.WithKind(Stream_Kind) )
Repository type metadata.
Functions ¶
This section is empty.
Types ¶
type KinesisConfigurationInitParameters ¶
type KinesisConfigurationInitParameters struct { // Enables QLDB to publish multiple data records in a single Kinesis Data Streams record, increasing the number of records sent per API call. Default: true. AggregationEnabled *bool `json:"aggregationEnabled,omitempty" tf:"aggregation_enabled,omitempty"` // The Amazon Resource Name (ARN) of the Kinesis Data Streams resource. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesis/v1beta2.Stream // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.TerraformID() StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn,omitempty"` // Reference to a Stream in kinesis to populate streamArn. // +kubebuilder:validation:Optional StreamArnRef *v1.Reference `json:"streamArnRef,omitempty" tf:"-"` // Selector for a Stream in kinesis to populate streamArn. // +kubebuilder:validation:Optional StreamArnSelector *v1.Selector `json:"streamArnSelector,omitempty" tf:"-"` }
func (*KinesisConfigurationInitParameters) DeepCopy ¶
func (in *KinesisConfigurationInitParameters) DeepCopy() *KinesisConfigurationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KinesisConfigurationInitParameters.
func (*KinesisConfigurationInitParameters) DeepCopyInto ¶
func (in *KinesisConfigurationInitParameters) DeepCopyInto(out *KinesisConfigurationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KinesisConfigurationObservation ¶
type KinesisConfigurationObservation struct { // Enables QLDB to publish multiple data records in a single Kinesis Data Streams record, increasing the number of records sent per API call. Default: true. AggregationEnabled *bool `json:"aggregationEnabled,omitempty" tf:"aggregation_enabled,omitempty"` // The Amazon Resource Name (ARN) of the Kinesis Data Streams resource. StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn,omitempty"` }
func (*KinesisConfigurationObservation) DeepCopy ¶
func (in *KinesisConfigurationObservation) DeepCopy() *KinesisConfigurationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KinesisConfigurationObservation.
func (*KinesisConfigurationObservation) DeepCopyInto ¶
func (in *KinesisConfigurationObservation) DeepCopyInto(out *KinesisConfigurationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KinesisConfigurationParameters ¶
type KinesisConfigurationParameters struct { // Enables QLDB to publish multiple data records in a single Kinesis Data Streams record, increasing the number of records sent per API call. Default: true. // +kubebuilder:validation:Optional AggregationEnabled *bool `json:"aggregationEnabled,omitempty" tf:"aggregation_enabled,omitempty"` // The Amazon Resource Name (ARN) of the Kinesis Data Streams resource. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesis/v1beta2.Stream // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.TerraformID() // +kubebuilder:validation:Optional StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn,omitempty"` // Reference to a Stream in kinesis to populate streamArn. // +kubebuilder:validation:Optional StreamArnRef *v1.Reference `json:"streamArnRef,omitempty" tf:"-"` // Selector for a Stream in kinesis to populate streamArn. // +kubebuilder:validation:Optional StreamArnSelector *v1.Selector `json:"streamArnSelector,omitempty" tf:"-"` }
func (*KinesisConfigurationParameters) DeepCopy ¶
func (in *KinesisConfigurationParameters) DeepCopy() *KinesisConfigurationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KinesisConfigurationParameters.
func (*KinesisConfigurationParameters) DeepCopyInto ¶
func (in *KinesisConfigurationParameters) DeepCopyInto(out *KinesisConfigurationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Stream ¶
type Stream 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.inclusiveStartTime) || (has(self.initProvider) && has(self.initProvider.inclusiveStartTime))",message="spec.forProvider.inclusiveStartTime is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.kinesisConfiguration) || (has(self.initProvider) && has(self.initProvider.kinesisConfiguration))",message="spec.forProvider.kinesisConfiguration is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.streamName) || (has(self.initProvider) && has(self.initProvider.streamName))",message="spec.forProvider.streamName is a required parameter" Spec StreamSpec `json:"spec"` Status StreamStatus `json:"status,omitempty"` }
Stream is the Schema for the Streams API. Provides a QLDB Stream resource. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*Stream) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Stream.
func (*Stream) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Stream) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Stream) GetCondition ¶
func (mg *Stream) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Stream.
func (*Stream) GetConnectionDetailsMapping ¶
GetConnectionDetailsMapping for this Stream
func (*Stream) GetDeletionPolicy ¶
func (mg *Stream) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Stream.
func (*Stream) GetInitParameters ¶
GetInitParameters of this Stream
func (*Stream) GetManagementPolicies ¶
func (mg *Stream) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Stream.
func (*Stream) GetMergedParameters ¶
GetInitParameters of this Stream
func (*Stream) GetObservation ¶
GetObservation of this Stream
func (*Stream) GetParameters ¶
GetParameters of this Stream
func (*Stream) GetProviderConfigReference ¶
GetProviderConfigReference of this Stream.
func (*Stream) GetPublishConnectionDetailsTo ¶
func (mg *Stream) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Stream.
func (*Stream) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Stream
func (*Stream) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Stream) GetWriteConnectionSecretToReference ¶
func (mg *Stream) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Stream.
func (*Stream) LateInitialize ¶
LateInitialize this Stream using its observed tfState. returns True if there are any spec changes for the resource.
func (*Stream) ResolveReferences ¶
func (*Stream) SetConditions ¶
SetConditions of this Stream.
func (*Stream) SetDeletionPolicy ¶
func (mg *Stream) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Stream.
func (*Stream) SetManagementPolicies ¶
func (mg *Stream) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Stream.
func (*Stream) SetObservation ¶
SetObservation for this Stream
func (*Stream) SetParameters ¶
SetParameters for this Stream
func (*Stream) SetProviderConfigReference ¶
SetProviderConfigReference of this Stream.
func (*Stream) SetPublishConnectionDetailsTo ¶
func (mg *Stream) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Stream.
func (*Stream) SetWriteConnectionSecretToReference ¶
func (mg *Stream) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Stream.
type StreamInitParameters ¶
type StreamInitParameters struct { // The exclusive date and time that specifies when the stream ends. If you don't define this parameter, the stream runs indefinitely until you cancel it. It must be in ISO 8601 date and time format and in Universal Coordinated Time (UTC). For example: "2019-06-13T21:36:34Z". ExclusiveEndTime *string `json:"exclusiveEndTime,omitempty" tf:"exclusive_end_time,omitempty"` // The inclusive start date and time from which to start streaming journal data. This parameter must be in ISO 8601 date and time format and in Universal Coordinated Time (UTC). For example: "2019-06-13T21:36:34Z". This cannot be in the future and must be before exclusive_end_time. If you provide a value that is before the ledger's CreationDateTime, QLDB effectively defaults it to the ledger's CreationDateTime. InclusiveStartTime *string `json:"inclusiveStartTime,omitempty" tf:"inclusive_start_time,omitempty"` // The configuration settings of the Kinesis Data Streams destination for your stream request. Documented below. KinesisConfiguration *KinesisConfigurationInitParameters `json:"kinesisConfiguration,omitempty" tf:"kinesis_configuration,omitempty"` // The name of the QLDB ledger. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/qldb/v1beta1.Ledger // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.TerraformID() LedgerName *string `json:"ledgerName,omitempty" tf:"ledger_name,omitempty"` // Reference to a Ledger in qldb to populate ledgerName. // +kubebuilder:validation:Optional LedgerNameRef *v1.Reference `json:"ledgerNameRef,omitempty" tf:"-"` // Selector for a Ledger in qldb to populate ledgerName. // +kubebuilder:validation:Optional LedgerNameSelector *v1.Selector `json:"ledgerNameSelector,omitempty" tf:"-"` // The Amazon Resource Name (ARN) of the IAM role that grants QLDB permissions for a journal stream to write data records to a Kinesis Data Streams resource. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/iam/v1beta1.Role // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor() RoleArn *string `json:"roleArn,omitempty" tf:"role_arn,omitempty"` // Reference to a Role in iam to populate roleArn. // +kubebuilder:validation:Optional RoleArnRef *v1.Reference `json:"roleArnRef,omitempty" tf:"-"` // Selector for a Role in iam to populate roleArn. // +kubebuilder:validation:Optional RoleArnSelector *v1.Selector `json:"roleArnSelector,omitempty" tf:"-"` // The name that you want to assign to the QLDB journal stream. User-defined names can help identify and indicate the purpose of a stream. Your stream name must be unique among other active streams for a given ledger. Stream names have the same naming constraints as ledger names, as defined in the Amazon QLDB Developer Guide. StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"` // Key-value map of resource tags. // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` }
func (*StreamInitParameters) DeepCopy ¶
func (in *StreamInitParameters) DeepCopy() *StreamInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInitParameters.
func (*StreamInitParameters) DeepCopyInto ¶
func (in *StreamInitParameters) DeepCopyInto(out *StreamInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamList ¶
type StreamList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Stream `json:"items"` }
StreamList contains a list of Streams
func (*StreamList) DeepCopy ¶
func (in *StreamList) DeepCopy() *StreamList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamList.
func (*StreamList) DeepCopyInto ¶
func (in *StreamList) DeepCopyInto(out *StreamList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StreamList) DeepCopyObject ¶
func (in *StreamList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*StreamList) GetItems ¶
func (l *StreamList) GetItems() []resource.Managed
GetItems of this StreamList.
type StreamObservation ¶
type StreamObservation struct { // The ARN of the QLDB Stream. Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // The exclusive date and time that specifies when the stream ends. If you don't define this parameter, the stream runs indefinitely until you cancel it. It must be in ISO 8601 date and time format and in Universal Coordinated Time (UTC). For example: "2019-06-13T21:36:34Z". ExclusiveEndTime *string `json:"exclusiveEndTime,omitempty" tf:"exclusive_end_time,omitempty"` // The ID of the QLDB Stream. ID *string `json:"id,omitempty" tf:"id,omitempty"` // The inclusive start date and time from which to start streaming journal data. This parameter must be in ISO 8601 date and time format and in Universal Coordinated Time (UTC). For example: "2019-06-13T21:36:34Z". This cannot be in the future and must be before exclusive_end_time. If you provide a value that is before the ledger's CreationDateTime, QLDB effectively defaults it to the ledger's CreationDateTime. InclusiveStartTime *string `json:"inclusiveStartTime,omitempty" tf:"inclusive_start_time,omitempty"` // The configuration settings of the Kinesis Data Streams destination for your stream request. Documented below. KinesisConfiguration *KinesisConfigurationObservation `json:"kinesisConfiguration,omitempty" tf:"kinesis_configuration,omitempty"` // The name of the QLDB ledger. LedgerName *string `json:"ledgerName,omitempty" tf:"ledger_name,omitempty"` // The Amazon Resource Name (ARN) of the IAM role that grants QLDB permissions for a journal stream to write data records to a Kinesis Data Streams resource. RoleArn *string `json:"roleArn,omitempty" tf:"role_arn,omitempty"` // The name that you want to assign to the QLDB journal stream. User-defined names can help identify and indicate the purpose of a stream. Your stream name must be unique among other active streams for a given ledger. Stream names have the same naming constraints as ledger names, as defined in the Amazon QLDB Developer Guide. StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"` // Key-value map of resource tags. // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` // A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block. // +mapType=granular TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"` }
func (*StreamObservation) DeepCopy ¶
func (in *StreamObservation) DeepCopy() *StreamObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamObservation.
func (*StreamObservation) DeepCopyInto ¶
func (in *StreamObservation) DeepCopyInto(out *StreamObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamParameters ¶
type StreamParameters struct { // The exclusive date and time that specifies when the stream ends. If you don't define this parameter, the stream runs indefinitely until you cancel it. It must be in ISO 8601 date and time format and in Universal Coordinated Time (UTC). For example: "2019-06-13T21:36:34Z". // +kubebuilder:validation:Optional ExclusiveEndTime *string `json:"exclusiveEndTime,omitempty" tf:"exclusive_end_time,omitempty"` // The inclusive start date and time from which to start streaming journal data. This parameter must be in ISO 8601 date and time format and in Universal Coordinated Time (UTC). For example: "2019-06-13T21:36:34Z". This cannot be in the future and must be before exclusive_end_time. If you provide a value that is before the ledger's CreationDateTime, QLDB effectively defaults it to the ledger's CreationDateTime. // +kubebuilder:validation:Optional InclusiveStartTime *string `json:"inclusiveStartTime,omitempty" tf:"inclusive_start_time,omitempty"` // The configuration settings of the Kinesis Data Streams destination for your stream request. Documented below. // +kubebuilder:validation:Optional KinesisConfiguration *KinesisConfigurationParameters `json:"kinesisConfiguration,omitempty" tf:"kinesis_configuration,omitempty"` // The name of the QLDB ledger. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/qldb/v1beta1.Ledger // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.TerraformID() // +kubebuilder:validation:Optional LedgerName *string `json:"ledgerName,omitempty" tf:"ledger_name,omitempty"` // Reference to a Ledger in qldb to populate ledgerName. // +kubebuilder:validation:Optional LedgerNameRef *v1.Reference `json:"ledgerNameRef,omitempty" tf:"-"` // Selector for a Ledger in qldb to populate ledgerName. // +kubebuilder:validation:Optional LedgerNameSelector *v1.Selector `json:"ledgerNameSelector,omitempty" tf:"-"` // Region is the region you'd like your resource to be created in. // +upjet:crd:field:TFTag=- // +kubebuilder:validation:Required Region *string `json:"region" tf:"-"` // The Amazon Resource Name (ARN) of the IAM role that grants QLDB permissions for a journal stream to write data records to a Kinesis Data Streams resource. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/iam/v1beta1.Role // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor() // +kubebuilder:validation:Optional RoleArn *string `json:"roleArn,omitempty" tf:"role_arn,omitempty"` // Reference to a Role in iam to populate roleArn. // +kubebuilder:validation:Optional RoleArnRef *v1.Reference `json:"roleArnRef,omitempty" tf:"-"` // Selector for a Role in iam to populate roleArn. // +kubebuilder:validation:Optional RoleArnSelector *v1.Selector `json:"roleArnSelector,omitempty" tf:"-"` // The name that you want to assign to the QLDB journal stream. User-defined names can help identify and indicate the purpose of a stream. Your stream name must be unique among other active streams for a given ledger. Stream names have the same naming constraints as ledger names, as defined in the Amazon QLDB Developer Guide. // +kubebuilder:validation:Optional StreamName *string `json:"streamName,omitempty" tf:"stream_name,omitempty"` // Key-value map of resource tags. // +kubebuilder:validation:Optional // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` }
func (*StreamParameters) DeepCopy ¶
func (in *StreamParameters) DeepCopy() *StreamParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamParameters.
func (*StreamParameters) DeepCopyInto ¶
func (in *StreamParameters) DeepCopyInto(out *StreamParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamSpec ¶
type StreamSpec struct { v1.ResourceSpec `json:",inline"` ForProvider StreamParameters `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 StreamInitParameters `json:"initProvider,omitempty"` }
StreamSpec defines the desired state of Stream
func (*StreamSpec) DeepCopy ¶
func (in *StreamSpec) DeepCopy() *StreamSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamSpec.
func (*StreamSpec) DeepCopyInto ¶
func (in *StreamSpec) DeepCopyInto(out *StreamSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamStatus ¶
type StreamStatus struct { v1.ResourceStatus `json:",inline"` AtProvider StreamObservation `json:"atProvider,omitempty"` }
StreamStatus defines the observed state of Stream.
func (*StreamStatus) DeepCopy ¶
func (in *StreamStatus) DeepCopy() *StreamStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamStatus.
func (*StreamStatus) DeepCopyInto ¶
func (in *StreamStatus) DeepCopyInto(out *StreamStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.