Documentation
¶
Overview ¶
+kubebuilder:object:generate=true +groupName=kinesis.aws.upbound.io +versionName=v1beta1
Index ¶
- Constants
- Variables
- 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 StreamConsumer
- func (in *StreamConsumer) DeepCopy() *StreamConsumer
- func (in *StreamConsumer) DeepCopyInto(out *StreamConsumer)
- func (in *StreamConsumer) DeepCopyObject() runtime.Object
- func (mg *StreamConsumer) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *StreamConsumer) GetConnectionDetailsMapping() map[string]string
- func (mg *StreamConsumer) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *StreamConsumer) GetID() string
- func (tr *StreamConsumer) GetInitParameters() (map[string]any, error)
- func (mg *StreamConsumer) GetManagementPolicies() xpv1.ManagementPolicies
- func (tr *StreamConsumer) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
- func (tr *StreamConsumer) GetObservation() (map[string]any, error)
- func (tr *StreamConsumer) GetParameters() (map[string]any, error)
- func (mg *StreamConsumer) GetProviderConfigReference() *xpv1.Reference
- func (mg *StreamConsumer) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *StreamConsumer) GetTerraformResourceType() string
- func (tr *StreamConsumer) GetTerraformSchemaVersion() int
- func (mg *StreamConsumer) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *StreamConsumer) Hub()
- func (tr *StreamConsumer) LateInitialize(attrs []byte) (bool, error)
- func (mg *StreamConsumer) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *StreamConsumer) SetConditions(c ...xpv1.Condition)
- func (mg *StreamConsumer) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *StreamConsumer) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *StreamConsumer) SetObservation(obs map[string]any) error
- func (tr *StreamConsumer) SetParameters(params map[string]any) error
- func (mg *StreamConsumer) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *StreamConsumer) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *StreamConsumer) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type StreamConsumerInitParameters
- type StreamConsumerList
- type StreamConsumerObservation
- type StreamConsumerParameters
- type StreamConsumerSpec
- type StreamConsumerStatus
- type StreamInitParameters
- type StreamList
- type StreamModeDetailsInitParameters
- type StreamModeDetailsObservation
- type StreamModeDetailsParameters
- type StreamObservation
- type StreamParameters
- type StreamSpec
- type StreamStatus
Constants ¶
const ( CRDGroup = "kinesis.aws.upbound.io" CRDVersion = "v1beta1" )
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.
var ( StreamConsumer_Kind = "StreamConsumer" StreamConsumer_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: StreamConsumer_Kind}.String() StreamConsumer_KindAPIVersion = StreamConsumer_Kind + "." + CRDGroupVersion.String() StreamConsumer_GroupVersionKind = CRDGroupVersion.WithKind(StreamConsumer_Kind) )
Repository type metadata.
Functions ¶
This section is empty.
Types ¶
type Stream ¶
type Stream struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec StreamSpec `json:"spec"` Status StreamStatus `json:"status,omitempty"` }
Stream is the Schema for the Streams API. Provides a AWS Kinesis Stream +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: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 ¶ added in v0.38.0
GetInitParameters of this Stream
func (*Stream) GetManagementPolicies ¶ added in v0.38.0
func (mg *Stream) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Stream.
func (*Stream) GetMergedParameters ¶ added in v0.44.0
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) Hub ¶ added in v0.47.2
func (tr *Stream) Hub()
Hub marks this type as a conversion hub.
func (*Stream) LateInitialize ¶
LateInitialize this Stream using its observed tfState. returns True if there are any spec changes for the resource.
func (*Stream) ResolveReferences ¶
ResolveReferences of this Stream.
func (*Stream) SetConditions ¶
SetConditions of this Stream.
func (*Stream) SetDeletionPolicy ¶
func (mg *Stream) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Stream.
func (*Stream) SetManagementPolicies ¶ added in v0.38.0
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 StreamConsumer ¶
type StreamConsumer 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 StreamConsumerSpec `json:"spec"` Status StreamConsumerStatus `json:"status,omitempty"` }
StreamConsumer is the Schema for the StreamConsumers API. Manages a Kinesis Stream Consumer. +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:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*StreamConsumer) DeepCopy ¶
func (in *StreamConsumer) DeepCopy() *StreamConsumer
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConsumer.
func (*StreamConsumer) DeepCopyInto ¶
func (in *StreamConsumer) DeepCopyInto(out *StreamConsumer)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StreamConsumer) DeepCopyObject ¶
func (in *StreamConsumer) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*StreamConsumer) GetCondition ¶
func (mg *StreamConsumer) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this StreamConsumer.
func (*StreamConsumer) GetConnectionDetailsMapping ¶
func (tr *StreamConsumer) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this StreamConsumer
func (*StreamConsumer) GetDeletionPolicy ¶
func (mg *StreamConsumer) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this StreamConsumer.
func (*StreamConsumer) GetID ¶
func (tr *StreamConsumer) GetID() string
GetID returns ID of underlying Terraform resource of this StreamConsumer
func (*StreamConsumer) GetInitParameters ¶ added in v0.38.0
func (tr *StreamConsumer) GetInitParameters() (map[string]any, error)
GetInitParameters of this StreamConsumer
func (*StreamConsumer) GetManagementPolicies ¶ added in v0.38.0
func (mg *StreamConsumer) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this StreamConsumer.
func (*StreamConsumer) GetMergedParameters ¶ added in v0.44.0
func (tr *StreamConsumer) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this StreamConsumer
func (*StreamConsumer) GetObservation ¶
func (tr *StreamConsumer) GetObservation() (map[string]any, error)
GetObservation of this StreamConsumer
func (*StreamConsumer) GetParameters ¶
func (tr *StreamConsumer) GetParameters() (map[string]any, error)
GetParameters of this StreamConsumer
func (*StreamConsumer) GetProviderConfigReference ¶
func (mg *StreamConsumer) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this StreamConsumer.
func (*StreamConsumer) GetPublishConnectionDetailsTo ¶
func (mg *StreamConsumer) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this StreamConsumer.
func (*StreamConsumer) GetTerraformResourceType ¶
func (mg *StreamConsumer) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this StreamConsumer
func (*StreamConsumer) GetTerraformSchemaVersion ¶
func (tr *StreamConsumer) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*StreamConsumer) GetWriteConnectionSecretToReference ¶
func (mg *StreamConsumer) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this StreamConsumer.
func (*StreamConsumer) Hub ¶ added in v0.47.2
func (tr *StreamConsumer) Hub()
Hub marks this type as a conversion hub.
func (*StreamConsumer) LateInitialize ¶
func (tr *StreamConsumer) LateInitialize(attrs []byte) (bool, error)
LateInitialize this StreamConsumer using its observed tfState. returns True if there are any spec changes for the resource.
func (*StreamConsumer) ResolveReferences ¶
ResolveReferences of this StreamConsumer.
func (*StreamConsumer) SetConditions ¶
func (mg *StreamConsumer) SetConditions(c ...xpv1.Condition)
SetConditions of this StreamConsumer.
func (*StreamConsumer) SetDeletionPolicy ¶
func (mg *StreamConsumer) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this StreamConsumer.
func (*StreamConsumer) SetManagementPolicies ¶ added in v0.38.0
func (mg *StreamConsumer) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this StreamConsumer.
func (*StreamConsumer) SetObservation ¶
func (tr *StreamConsumer) SetObservation(obs map[string]any) error
SetObservation for this StreamConsumer
func (*StreamConsumer) SetParameters ¶
func (tr *StreamConsumer) SetParameters(params map[string]any) error
SetParameters for this StreamConsumer
func (*StreamConsumer) SetProviderConfigReference ¶
func (mg *StreamConsumer) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this StreamConsumer.
func (*StreamConsumer) SetPublishConnectionDetailsTo ¶
func (mg *StreamConsumer) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this StreamConsumer.
func (*StreamConsumer) SetWriteConnectionSecretToReference ¶
func (mg *StreamConsumer) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this StreamConsumer.
type StreamConsumerInitParameters ¶ added in v0.38.0
type StreamConsumerInitParameters struct { // Name of the stream consumer. Name *string `json:"name,omitempty" tf:"name,omitempty"` // – Amazon Resource Name (ARN) of the data stream the consumer is registered with. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesis/v1beta1.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 (*StreamConsumerInitParameters) DeepCopy ¶ added in v0.38.0
func (in *StreamConsumerInitParameters) DeepCopy() *StreamConsumerInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConsumerInitParameters.
func (*StreamConsumerInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *StreamConsumerInitParameters) DeepCopyInto(out *StreamConsumerInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamConsumerList ¶
type StreamConsumerList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []StreamConsumer `json:"items"` }
StreamConsumerList contains a list of StreamConsumers
func (*StreamConsumerList) DeepCopy ¶
func (in *StreamConsumerList) DeepCopy() *StreamConsumerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConsumerList.
func (*StreamConsumerList) DeepCopyInto ¶
func (in *StreamConsumerList) DeepCopyInto(out *StreamConsumerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StreamConsumerList) DeepCopyObject ¶
func (in *StreamConsumerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*StreamConsumerList) GetItems ¶
func (l *StreamConsumerList) GetItems() []resource.Managed
GetItems of this StreamConsumerList.
type StreamConsumerObservation ¶
type StreamConsumerObservation struct { // Amazon Resource Name (ARN) of the stream consumer. Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // Approximate timestamp in RFC3339 format of when the stream consumer was created. CreationTimestamp *string `json:"creationTimestamp,omitempty" tf:"creation_timestamp,omitempty"` // Amazon Resource Name (ARN) of the stream consumer. ID *string `json:"id,omitempty" tf:"id,omitempty"` // Name of the stream consumer. Name *string `json:"name,omitempty" tf:"name,omitempty"` // – Amazon Resource Name (ARN) of the data stream the consumer is registered with. StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn,omitempty"` }
func (*StreamConsumerObservation) DeepCopy ¶
func (in *StreamConsumerObservation) DeepCopy() *StreamConsumerObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConsumerObservation.
func (*StreamConsumerObservation) DeepCopyInto ¶
func (in *StreamConsumerObservation) DeepCopyInto(out *StreamConsumerObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamConsumerParameters ¶
type StreamConsumerParameters struct { // Name of the stream consumer. // +kubebuilder:validation:Optional Name *string `json:"name,omitempty" tf:"name,omitempty"` // 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:"-"` // – Amazon Resource Name (ARN) of the data stream the consumer is registered with. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesis/v1beta1.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 (*StreamConsumerParameters) DeepCopy ¶
func (in *StreamConsumerParameters) DeepCopy() *StreamConsumerParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConsumerParameters.
func (*StreamConsumerParameters) DeepCopyInto ¶
func (in *StreamConsumerParameters) DeepCopyInto(out *StreamConsumerParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamConsumerSpec ¶
type StreamConsumerSpec struct { v1.ResourceSpec `json:",inline"` ForProvider StreamConsumerParameters `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 StreamConsumerInitParameters `json:"initProvider,omitempty"` }
StreamConsumerSpec defines the desired state of StreamConsumer
func (*StreamConsumerSpec) DeepCopy ¶
func (in *StreamConsumerSpec) DeepCopy() *StreamConsumerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConsumerSpec.
func (*StreamConsumerSpec) DeepCopyInto ¶
func (in *StreamConsumerSpec) DeepCopyInto(out *StreamConsumerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamConsumerStatus ¶
type StreamConsumerStatus struct { v1.ResourceStatus `json:",inline"` AtProvider StreamConsumerObservation `json:"atProvider,omitempty"` }
StreamConsumerStatus defines the observed state of StreamConsumer.
func (*StreamConsumerStatus) DeepCopy ¶
func (in *StreamConsumerStatus) DeepCopy() *StreamConsumerStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamConsumerStatus.
func (*StreamConsumerStatus) DeepCopyInto ¶
func (in *StreamConsumerStatus) DeepCopyInto(out *StreamConsumerStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamInitParameters ¶ added in v0.38.0
type StreamInitParameters struct { // The encryption type to use. The only acceptable values are NONE or KMS. The default value is NONE. EncryptionType *string `json:"encryptionType,omitempty" tf:"encryption_type,omitempty"` // A boolean that indicates all registered consumers should be deregistered from the stream so that the stream can be destroyed without error. The default value is false. EnforceConsumerDeletion *bool `json:"enforceConsumerDeletion,omitempty" tf:"enforce_consumer_deletion,omitempty"` // The GUID for the customer-managed KMS key to use for encryption. You can also use a Kinesis-owned master key by specifying the alias alias/aws/kinesis. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key KMSKeyID *string `json:"kmsKeyId,omitempty" tf:"kms_key_id,omitempty"` // Reference to a Key in kms to populate kmsKeyId. // +kubebuilder:validation:Optional KMSKeyIDRef *v1.Reference `json:"kmsKeyIdRef,omitempty" tf:"-"` // Selector for a Key in kms to populate kmsKeyId. // +kubebuilder:validation:Optional KMSKeyIDSelector *v1.Selector `json:"kmsKeyIdSelector,omitempty" tf:"-"` // Length of time data records are accessible after they are added to the stream. The maximum value of a stream's retention period is 8760 hours. Minimum value is 24. Default is 24. RetentionPeriod *float64 `json:"retentionPeriod,omitempty" tf:"retention_period,omitempty"` // – The number of shards that the stream will use. If the stream_mode is PROVISIONED, this field is required. // Amazon has guidelines for specifying the Stream size that should be referenced when creating a Kinesis stream. See Amazon Kinesis Streams for more. ShardCount *float64 `json:"shardCount,omitempty" tf:"shard_count,omitempty"` // A list of shard-level CloudWatch metrics which can be enabled for the stream. See Monitoring with CloudWatch for more. Note that the value ALL should not be used; instead you should provide an explicit list of metrics you wish to enable. // +listType=set ShardLevelMetrics []*string `json:"shardLevelMetrics,omitempty" tf:"shard_level_metrics,omitempty"` // Indicates the capacity mode of the data stream. Detailed below. StreamModeDetails []StreamModeDetailsInitParameters `json:"streamModeDetails,omitempty" tf:"stream_mode_details,omitempty"` // Key-value map of resource tags. // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` }
func (*StreamInitParameters) DeepCopy ¶ added in v0.38.0
func (in *StreamInitParameters) DeepCopy() *StreamInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamInitParameters.
func (*StreamInitParameters) DeepCopyInto ¶ added in v0.38.0
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 StreamModeDetailsInitParameters ¶ added in v0.38.0
type StreamModeDetailsInitParameters struct { // Specifies the capacity mode of the stream. Must be either PROVISIONED or ON_DEMAND. StreamMode *string `json:"streamMode,omitempty" tf:"stream_mode,omitempty"` }
func (*StreamModeDetailsInitParameters) DeepCopy ¶ added in v0.38.0
func (in *StreamModeDetailsInitParameters) DeepCopy() *StreamModeDetailsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamModeDetailsInitParameters.
func (*StreamModeDetailsInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *StreamModeDetailsInitParameters) DeepCopyInto(out *StreamModeDetailsInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamModeDetailsObservation ¶
type StreamModeDetailsObservation struct { // Specifies the capacity mode of the stream. Must be either PROVISIONED or ON_DEMAND. StreamMode *string `json:"streamMode,omitempty" tf:"stream_mode,omitempty"` }
func (*StreamModeDetailsObservation) DeepCopy ¶
func (in *StreamModeDetailsObservation) DeepCopy() *StreamModeDetailsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamModeDetailsObservation.
func (*StreamModeDetailsObservation) DeepCopyInto ¶
func (in *StreamModeDetailsObservation) DeepCopyInto(out *StreamModeDetailsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamModeDetailsParameters ¶
type StreamModeDetailsParameters struct { // Specifies the capacity mode of the stream. Must be either PROVISIONED or ON_DEMAND. // +kubebuilder:validation:Optional StreamMode *string `json:"streamMode" tf:"stream_mode,omitempty"` }
func (*StreamModeDetailsParameters) DeepCopy ¶
func (in *StreamModeDetailsParameters) DeepCopy() *StreamModeDetailsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StreamModeDetailsParameters.
func (*StreamModeDetailsParameters) DeepCopyInto ¶
func (in *StreamModeDetailsParameters) DeepCopyInto(out *StreamModeDetailsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StreamObservation ¶
type StreamObservation struct { // The Amazon Resource Name (ARN) specifying the Stream (same as id) Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // The encryption type to use. The only acceptable values are NONE or KMS. The default value is NONE. EncryptionType *string `json:"encryptionType,omitempty" tf:"encryption_type,omitempty"` // A boolean that indicates all registered consumers should be deregistered from the stream so that the stream can be destroyed without error. The default value is false. EnforceConsumerDeletion *bool `json:"enforceConsumerDeletion,omitempty" tf:"enforce_consumer_deletion,omitempty"` // The unique Stream id ID *string `json:"id,omitempty" tf:"id,omitempty"` // The GUID for the customer-managed KMS key to use for encryption. You can also use a Kinesis-owned master key by specifying the alias alias/aws/kinesis. KMSKeyID *string `json:"kmsKeyId,omitempty" tf:"kms_key_id,omitempty"` // Length of time data records are accessible after they are added to the stream. The maximum value of a stream's retention period is 8760 hours. Minimum value is 24. Default is 24. RetentionPeriod *float64 `json:"retentionPeriod,omitempty" tf:"retention_period,omitempty"` // – The number of shards that the stream will use. If the stream_mode is PROVISIONED, this field is required. // Amazon has guidelines for specifying the Stream size that should be referenced when creating a Kinesis stream. See Amazon Kinesis Streams for more. ShardCount *float64 `json:"shardCount,omitempty" tf:"shard_count,omitempty"` // A list of shard-level CloudWatch metrics which can be enabled for the stream. See Monitoring with CloudWatch for more. Note that the value ALL should not be used; instead you should provide an explicit list of metrics you wish to enable. // +listType=set ShardLevelMetrics []*string `json:"shardLevelMetrics,omitempty" tf:"shard_level_metrics,omitempty"` // Indicates the capacity mode of the data stream. Detailed below. StreamModeDetails []StreamModeDetailsObservation `json:"streamModeDetails,omitempty" tf:"stream_mode_details,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 encryption type to use. The only acceptable values are NONE or KMS. The default value is NONE. // +kubebuilder:validation:Optional EncryptionType *string `json:"encryptionType,omitempty" tf:"encryption_type,omitempty"` // A boolean that indicates all registered consumers should be deregistered from the stream so that the stream can be destroyed without error. The default value is false. // +kubebuilder:validation:Optional EnforceConsumerDeletion *bool `json:"enforceConsumerDeletion,omitempty" tf:"enforce_consumer_deletion,omitempty"` // The GUID for the customer-managed KMS key to use for encryption. You can also use a Kinesis-owned master key by specifying the alias alias/aws/kinesis. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key // +kubebuilder:validation:Optional KMSKeyID *string `json:"kmsKeyId,omitempty" tf:"kms_key_id,omitempty"` // Reference to a Key in kms to populate kmsKeyId. // +kubebuilder:validation:Optional KMSKeyIDRef *v1.Reference `json:"kmsKeyIdRef,omitempty" tf:"-"` // Selector for a Key in kms to populate kmsKeyId. // +kubebuilder:validation:Optional KMSKeyIDSelector *v1.Selector `json:"kmsKeyIdSelector,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:"-"` // Length of time data records are accessible after they are added to the stream. The maximum value of a stream's retention period is 8760 hours. Minimum value is 24. Default is 24. // +kubebuilder:validation:Optional RetentionPeriod *float64 `json:"retentionPeriod,omitempty" tf:"retention_period,omitempty"` // – The number of shards that the stream will use. If the stream_mode is PROVISIONED, this field is required. // Amazon has guidelines for specifying the Stream size that should be referenced when creating a Kinesis stream. See Amazon Kinesis Streams for more. // +kubebuilder:validation:Optional ShardCount *float64 `json:"shardCount,omitempty" tf:"shard_count,omitempty"` // A list of shard-level CloudWatch metrics which can be enabled for the stream. See Monitoring with CloudWatch for more. Note that the value ALL should not be used; instead you should provide an explicit list of metrics you wish to enable. // +kubebuilder:validation:Optional // +listType=set ShardLevelMetrics []*string `json:"shardLevelMetrics,omitempty" tf:"shard_level_metrics,omitempty"` // Indicates the capacity mode of the data stream. Detailed below. // +kubebuilder:validation:Optional StreamModeDetails []StreamModeDetailsParameters `json:"streamModeDetails,omitempty" tf:"stream_mode_details,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.