v1beta1

package
v1.18.0 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=qldb.aws.upbound.io +versionName=v1beta1

Index

Constants

View Source 
const (
	CRDGroup   = "qldb.aws.upbound.io"
	CRDVersion = "v1beta1"
)

Package type metadata.

Variables

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

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

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (
	Ledger_Kind             = "Ledger"
	Ledger_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Ledger_Kind}.String()
	Ledger_KindAPIVersion   = Ledger_Kind + "." + CRDGroupVersion.String()
	Ledger_GroupVersionKind = CRDGroupVersion.WithKind(Ledger_Kind)
)

Repository type metadata.

View Source 
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 added in v0.38.0 

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/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 (*KinesisConfigurationInitParameters) DeepCopy added in v0.38.0 

func (in *KinesisConfigurationInitParameters) DeepCopy() *KinesisConfigurationInitParameters

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

func (*KinesisConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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/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 (*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 Ledger 

type Ledger 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.permissionsMode) || (has(self.initProvider) && has(self.initProvider.permissionsMode))",message="spec.forProvider.permissionsMode is a required parameter"
	Spec   LedgerSpec   `json:"spec"`
	Status LedgerStatus `json:"status,omitempty"`
}

Ledger is the Schema for the Ledgers API. Provides an QLDB Resource 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 (*Ledger) DeepCopy 

func (in *Ledger) DeepCopy() *Ledger

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

func (*Ledger) DeepCopyInto 

func (in *Ledger) DeepCopyInto(out *Ledger)

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

func (*Ledger) DeepCopyObject 

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

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

func (*Ledger) GetCondition 

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

GetCondition of this Ledger.

func (*Ledger) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Ledger

func (*Ledger) GetDeletionPolicy 

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

GetDeletionPolicy of this Ledger.

func (*Ledger) GetID 

func (tr *Ledger) GetID() string

GetID returns ID of underlying Terraform resource of this Ledger

func (*Ledger) GetInitParameters added in v0.38.0 

func (tr *Ledger) GetInitParameters() (map[string]any, error)

GetInitParameters of this Ledger

func (*Ledger) GetManagementPolicies added in v0.38.0 

func (mg *Ledger) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Ledger.

func (*Ledger) GetMergedParameters added in v0.44.0 

func (tr *Ledger) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this Ledger

func (*Ledger) GetObservation 

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

GetObservation of this Ledger

func (*Ledger) GetParameters 

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

GetParameters of this Ledger

func (*Ledger) GetProviderConfigReference 

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

GetProviderConfigReference of this Ledger.

func (*Ledger) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Ledger.

func (*Ledger) GetTerraformResourceType 

func (mg *Ledger) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Ledger

func (*Ledger) GetTerraformSchemaVersion 

func (tr *Ledger) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Ledger) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Ledger.

func (*Ledger) Hub added in v0.47.2 

func (tr *Ledger) Hub()

Hub marks this type as a conversion hub.

func (*Ledger) LateInitialize 

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

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

func (*Ledger) ResolveReferences 

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

func (*Ledger) SetConditions 

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

SetConditions of this Ledger.

func (*Ledger) SetDeletionPolicy 

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

SetDeletionPolicy of this Ledger.

func (*Ledger) SetManagementPolicies added in v0.38.0 

func (mg *Ledger) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Ledger.

func (*Ledger) SetObservation 

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

SetObservation for this Ledger

func (*Ledger) SetParameters 

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

SetParameters for this Ledger

func (*Ledger) SetProviderConfigReference 

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

SetProviderConfigReference of this Ledger.

func (*Ledger) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Ledger.

func (*Ledger) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Ledger.

type LedgerInitParameters added in v0.38.0 

type LedgerInitParameters struct {

	// The deletion protection for the QLDB Ledger instance. By default it is true.
	DeletionProtection *bool `json:"deletionProtection,omitempty" tf:"deletion_protection,omitempty"`

	// The key in AWS Key Management Service (AWS KMS) to use for encryption of data at rest in the ledger. For more information, see the AWS documentation. Valid values are "AWS_OWNED_KMS_KEY" to use an AWS KMS key that is owned and managed by AWS on your behalf, or the ARN of a valid symmetric customer managed KMS key.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key
	KMSKey *string `json:"kmsKey,omitempty" tf:"kms_key,omitempty"`

	// Reference to a Key in kms to populate kmsKey.
	// +kubebuilder:validation:Optional
	KMSKeyRef *v1.Reference `json:"kmsKeyRef,omitempty" tf:"-"`

	// Selector for a Key in kms to populate kmsKey.
	// +kubebuilder:validation:Optional
	KMSKeySelector *v1.Selector `json:"kmsKeySelector,omitempty" tf:"-"`

	// The permissions mode for the QLDB ledger instance. Specify either ALLOW_ALL or STANDARD.
	PermissionsMode *string `json:"permissionsMode,omitempty" tf:"permissions_mode,omitempty"`

	// Key-value map of resource tags.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*LedgerInitParameters) DeepCopy added in v0.38.0 

func (in *LedgerInitParameters) DeepCopy() *LedgerInitParameters

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

func (*LedgerInitParameters) DeepCopyInto added in v0.38.0 

func (in *LedgerInitParameters) DeepCopyInto(out *LedgerInitParameters)

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

type LedgerList 

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

LedgerList contains a list of Ledgers

func (*LedgerList) DeepCopy 

func (in *LedgerList) DeepCopy() *LedgerList

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

func (*LedgerList) DeepCopyInto 

func (in *LedgerList) DeepCopyInto(out *LedgerList)

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

func (*LedgerList) DeepCopyObject 

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

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

func (*LedgerList) GetItems 

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

GetItems of this LedgerList.

type LedgerObservation 

type LedgerObservation struct {

	// The ARN of the QLDB Ledger
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// The deletion protection for the QLDB Ledger instance. By default it is true.
	DeletionProtection *bool `json:"deletionProtection,omitempty" tf:"deletion_protection,omitempty"`

	// The Name of the QLDB Ledger
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The key in AWS Key Management Service (AWS KMS) to use for encryption of data at rest in the ledger. For more information, see the AWS documentation. Valid values are "AWS_OWNED_KMS_KEY" to use an AWS KMS key that is owned and managed by AWS on your behalf, or the ARN of a valid symmetric customer managed KMS key.
	KMSKey *string `json:"kmsKey,omitempty" tf:"kms_key,omitempty"`

	// The permissions mode for the QLDB ledger instance. Specify either ALLOW_ALL or STANDARD.
	PermissionsMode *string `json:"permissionsMode,omitempty" tf:"permissions_mode,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 (*LedgerObservation) DeepCopy 

func (in *LedgerObservation) DeepCopy() *LedgerObservation

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

func (*LedgerObservation) DeepCopyInto 

func (in *LedgerObservation) DeepCopyInto(out *LedgerObservation)

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

type LedgerParameters 

type LedgerParameters struct {

	// The deletion protection for the QLDB Ledger instance. By default it is true.
	// +kubebuilder:validation:Optional
	DeletionProtection *bool `json:"deletionProtection,omitempty" tf:"deletion_protection,omitempty"`

	// The key in AWS Key Management Service (AWS KMS) to use for encryption of data at rest in the ledger. For more information, see the AWS documentation. Valid values are "AWS_OWNED_KMS_KEY" to use an AWS KMS key that is owned and managed by AWS on your behalf, or the ARN of a valid symmetric customer managed KMS key.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key
	// +kubebuilder:validation:Optional
	KMSKey *string `json:"kmsKey,omitempty" tf:"kms_key,omitempty"`

	// Reference to a Key in kms to populate kmsKey.
	// +kubebuilder:validation:Optional
	KMSKeyRef *v1.Reference `json:"kmsKeyRef,omitempty" tf:"-"`

	// Selector for a Key in kms to populate kmsKey.
	// +kubebuilder:validation:Optional
	KMSKeySelector *v1.Selector `json:"kmsKeySelector,omitempty" tf:"-"`

	// The permissions mode for the QLDB ledger instance. Specify either ALLOW_ALL or STANDARD.
	// +kubebuilder:validation:Optional
	PermissionsMode *string `json:"permissionsMode,omitempty" tf:"permissions_mode,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:"-"`

	// Key-value map of resource tags.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*LedgerParameters) DeepCopy 

func (in *LedgerParameters) DeepCopy() *LedgerParameters

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

func (*LedgerParameters) DeepCopyInto 

func (in *LedgerParameters) DeepCopyInto(out *LedgerParameters)

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

type LedgerSpec 

type LedgerSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     LedgerParameters `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 LedgerInitParameters `json:"initProvider,omitempty"`
}

LedgerSpec defines the desired state of Ledger

func (*LedgerSpec) DeepCopy 

func (in *LedgerSpec) DeepCopy() *LedgerSpec

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

func (*LedgerSpec) DeepCopyInto 

func (in *LedgerSpec) DeepCopyInto(out *LedgerSpec)

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

type LedgerStatus 

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

LedgerStatus defines the observed state of Ledger.

func (*LedgerStatus) DeepCopy 

func (in *LedgerStatus) DeepCopy() *LedgerStatus

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

func (*LedgerStatus) DeepCopyInto 

func (in *LedgerStatus) DeepCopyInto(out *LedgerStatus)

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) ConvertFrom added in v1.7.0 

func (tr *Stream) ConvertFrom(srcRaw conversion.Hub) error

ConvertFrom converts from the hub type to the Stream type.

func (*Stream) ConvertTo added in v1.7.0 

func (tr *Stream) ConvertTo(dstRaw conversion.Hub) error

ConvertTo converts this Stream to the hub type.

func (*Stream) DeepCopy 

func (in *Stream) DeepCopy() *Stream

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

func (*Stream) DeepCopyInto 

func (in *Stream) DeepCopyInto(out *Stream)

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

func (*Stream) DeepCopyObject 

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

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 

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

GetConnectionDetailsMapping for this Stream

func (*Stream) GetDeletionPolicy 

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

GetDeletionPolicy of this Stream.

func (*Stream) GetID 

func (tr *Stream) GetID() string

GetID returns ID of underlying Terraform resource of this Stream

func (*Stream) GetInitParameters added in v0.38.0 

func (tr *Stream) GetInitParameters() (map[string]any, error)

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 

func (tr *Stream) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this Stream

func (*Stream) GetObservation 

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

GetObservation of this Stream

func (*Stream) GetParameters 

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

GetParameters of this Stream

func (*Stream) GetProviderConfigReference 

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

GetProviderConfigReference of this Stream.

func (*Stream) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Stream.

func (*Stream) GetTerraformResourceType 

func (mg *Stream) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Stream

func (*Stream) GetTerraformSchemaVersion 

func (tr *Stream) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Stream) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Stream.

func (*Stream) LateInitialize 

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

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

func (*Stream) ResolveReferences 

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

ResolveReferences of this Stream.

func (*Stream) SetConditions 

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

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 

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

SetObservation for this Stream

func (*Stream) SetParameters 

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

SetParameters for this Stream

func (*Stream) SetProviderConfigReference 

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

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 added in v0.38.0 

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 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 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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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