v1alpha1

package
v0.0.0-...-bf43ebf Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Group   = "kinesis-stream.terraform-provider-aws.crossplane.io"
	Version = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	Kind                  = "KinesisStream"
	GroupKind             = schema.GroupKind{Group: Group, Kind: Kind}.String()
	KindAPIVersion        = Kind + "." + SchemeGroupVersion.String()
	GroupVersionKind      = SchemeGroupVersion.WithKind(Kind)
	TerraformResourceName = "aws_kinesis_stream"
)
View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version}
)

Functions

func DecodeKinesisStream 

func DecodeKinesisStream(prev *KinesisStream, ctyValue cty.Value) (resource.Managed, error)

func DecodeKinesisStream_Arn 

func DecodeKinesisStream_Arn(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_EncryptionType 

func DecodeKinesisStream_EncryptionType(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_EnforceConsumerDeletion 

func DecodeKinesisStream_EnforceConsumerDeletion(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_KmsKeyId 

func DecodeKinesisStream_KmsKeyId(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_Name 

func DecodeKinesisStream_Name(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_RetentionPeriod 

func DecodeKinesisStream_RetentionPeriod(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_ShardCount 

func DecodeKinesisStream_ShardCount(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_ShardLevelMetrics 

func DecodeKinesisStream_ShardLevelMetrics(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveCollectionTypeDecodeTemplate

func DecodeKinesisStream_Tags 

func DecodeKinesisStream_Tags(p *KinesisStreamParameters, vals map[string]cty.Value)

primitiveMapTypeDecodeTemplate

func DecodeKinesisStream_Timeouts 

func DecodeKinesisStream_Timeouts(p *Timeouts, vals map[string]cty.Value)

containerTypeDecodeTemplate

func DecodeKinesisStream_Timeouts_Create 

func DecodeKinesisStream_Timeouts_Create(p *Timeouts, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_Timeouts_Delete 

func DecodeKinesisStream_Timeouts_Delete(p *Timeouts, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func DecodeKinesisStream_Timeouts_Update 

func DecodeKinesisStream_Timeouts_Update(p *Timeouts, vals map[string]cty.Value)

primitiveTypeDecodeTemplate

func EncodeKinesisStream 

func EncodeKinesisStream(r KinesisStream) cty.Value

func EncodeKinesisStream_Arn 

func EncodeKinesisStream_Arn(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_EncryptionType 

func EncodeKinesisStream_EncryptionType(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_EnforceConsumerDeletion 

func EncodeKinesisStream_EnforceConsumerDeletion(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_KmsKeyId 

func EncodeKinesisStream_KmsKeyId(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_Name 

func EncodeKinesisStream_Name(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_RetentionPeriod 

func EncodeKinesisStream_RetentionPeriod(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_ShardCount 

func EncodeKinesisStream_ShardCount(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_ShardLevelMetrics 

func EncodeKinesisStream_ShardLevelMetrics(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_Tags 

func EncodeKinesisStream_Tags(p KinesisStreamParameters, vals map[string]cty.Value)

func EncodeKinesisStream_Timeouts 

func EncodeKinesisStream_Timeouts(p Timeouts, vals map[string]cty.Value)

func EncodeKinesisStream_Timeouts_Create 

func EncodeKinesisStream_Timeouts_Create(p Timeouts, vals map[string]cty.Value)

func EncodeKinesisStream_Timeouts_Delete 

func EncodeKinesisStream_Timeouts_Delete(p Timeouts, vals map[string]cty.Value)

func EncodeKinesisStream_Timeouts_Update 

func EncodeKinesisStream_Timeouts_Update(p Timeouts, vals map[string]cty.Value)

func Implementation 

func Implementation() *plugin.Implementation

func MergeKinesisStream_Arn 

func MergeKinesisStream_Arn(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_EncryptionType 

func MergeKinesisStream_EncryptionType(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_EnforceConsumerDeletion 

func MergeKinesisStream_EnforceConsumerDeletion(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_KmsKeyId 

func MergeKinesisStream_KmsKeyId(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_Name 

func MergeKinesisStream_Name(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_RetentionPeriod 

func MergeKinesisStream_RetentionPeriod(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_ShardCount 

func MergeKinesisStream_ShardCount(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_ShardLevelMetrics 

func MergeKinesisStream_ShardLevelMetrics(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveContainerTemplateSpec

func MergeKinesisStream_Tags 

func MergeKinesisStream_Tags(k *KinesisStreamParameters, p *KinesisStreamParameters, md *plugin.MergeDescription) bool

mergePrimitiveContainerTemplateSpec

func MergeKinesisStream_Timeouts 

func MergeKinesisStream_Timeouts(k *Timeouts, p *Timeouts, md *plugin.MergeDescription) bool

mergeStructTemplateSpec

func MergeKinesisStream_Timeouts_Create 

func MergeKinesisStream_Timeouts_Create(k *Timeouts, p *Timeouts, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_Timeouts_Delete 

func MergeKinesisStream_Timeouts_Delete(k *Timeouts, p *Timeouts, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

func MergeKinesisStream_Timeouts_Update 

func MergeKinesisStream_Timeouts_Update(k *Timeouts, p *Timeouts, md *plugin.MergeDescription) bool

mergePrimitiveTemplateSpec

Types

type KinesisStream 

type KinesisStream struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KinesisStreamSpec   `json:"spec"`
	Status KinesisStreamStatus `json:"status,omitempty"`
}

KinesisStream is a managed resource representing a resource mirrored in the cloud +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster

func (*KinesisStream) DeepCopy 

func (in *KinesisStream) DeepCopy() *KinesisStream

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

func (*KinesisStream) DeepCopyInto 

func (in *KinesisStream) DeepCopyInto(out *KinesisStream)

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

func (*KinesisStream) DeepCopyObject 

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

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

func (*KinesisStream) GetCondition 

func (mg *KinesisStream) GetCondition(ct runtimev1alpha1.ConditionType) runtimev1alpha1.Condition

GetCondition of this KinesisStream.

func (*KinesisStream) GetDeletionPolicy 

func (mg *KinesisStream) GetDeletionPolicy() runtimev1alpha1.DeletionPolicy

GetDeletionPolicy of this KinesisStream.

func (*KinesisStream) GetProviderConfigReference 

func (mg *KinesisStream) GetProviderConfigReference() *runtimev1alpha1.Reference

GetProviderConfigReference of this KinesisStream.

func (*KinesisStream) GetProviderReference 

func (mg *KinesisStream) GetProviderReference() *runtimev1alpha1.Reference

GetProviderReference of this KinesisStream. Deprecated: Use GetProviderConfigReference.

func (*KinesisStream) GetWriteConnectionSecretToReference 

func (mg *KinesisStream) GetWriteConnectionSecretToReference() *runtimev1alpha1.SecretReference

GetWriteConnectionSecretToReference of this KinesisStream.

func (*KinesisStream) SetConditions 

func (mg *KinesisStream) SetConditions(c ...runtimev1alpha1.Condition)

SetConditions of this KinesisStream.

func (*KinesisStream) SetDeletionPolicy 

func (mg *KinesisStream) SetDeletionPolicy(r runtimev1alpha1.DeletionPolicy)

SetDeletionPolicy of this KinesisStream.

func (*KinesisStream) SetProviderConfigReference 

func (mg *KinesisStream) SetProviderConfigReference(r *runtimev1alpha1.Reference)

SetProviderConfigReference of this KinesisStream.

func (*KinesisStream) SetProviderReference 

func (mg *KinesisStream) SetProviderReference(r *runtimev1alpha1.Reference)

SetProviderReference of this KinesisStream. Deprecated: Use SetProviderConfigReference.

func (*KinesisStream) SetWriteConnectionSecretToReference 

func (mg *KinesisStream) SetWriteConnectionSecretToReference(r *runtimev1alpha1.SecretReference)

SetWriteConnectionSecretToReference of this KinesisStream.

type KinesisStreamList 

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

KinesisStream contains a list of KinesisStreamList

func (*KinesisStreamList) DeepCopy 

func (in *KinesisStreamList) DeepCopy() *KinesisStreamList

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

func (*KinesisStreamList) DeepCopyInto 

func (in *KinesisStreamList) DeepCopyInto(out *KinesisStreamList)

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

func (*KinesisStreamList) DeepCopyObject 

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

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

func (*KinesisStreamList) GetItems 

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

GetItems of this KinesisStreamList.

type KinesisStreamObservation 

type KinesisStreamObservation struct{}

A KinesisStreamObservation records the observed state of a KinesisStream

func (*KinesisStreamObservation) DeepCopy 

func (in *KinesisStreamObservation) DeepCopy() *KinesisStreamObservation

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

func (*KinesisStreamObservation) DeepCopyInto 

func (in *KinesisStreamObservation) DeepCopyInto(out *KinesisStreamObservation)

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

type KinesisStreamParameters 

type KinesisStreamParameters struct {
	EncryptionType          string            `json:"encryption_type"`
	KmsKeyId                string            `json:"kms_key_id"`
	RetentionPeriod         int64             `json:"retention_period"`
	ShardLevelMetrics       []string          `json:"shard_level_metrics"`
	Tags                    map[string]string `json:"tags"`
	Arn                     string            `json:"arn"`
	Name                    string            `json:"name"`
	ShardCount              int64             `json:"shard_count"`
	EnforceConsumerDeletion bool              `json:"enforce_consumer_deletion"`
	Timeouts                Timeouts          `json:"timeouts"`
}

A KinesisStreamParameters defines the desired state of a KinesisStream

func (*KinesisStreamParameters) DeepCopy 

func (in *KinesisStreamParameters) DeepCopy() *KinesisStreamParameters

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

func (*KinesisStreamParameters) DeepCopyInto 

func (in *KinesisStreamParameters) DeepCopyInto(out *KinesisStreamParameters)

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

type KinesisStreamSpec 

type KinesisStreamSpec struct {
	runtimev1alpha1.ResourceSpec `json:",inline"`
	ForProvider                  KinesisStreamParameters `json:"forProvider"`
}

A KinesisStreamSpec defines the desired state of a KinesisStream

func (*KinesisStreamSpec) DeepCopy 

func (in *KinesisStreamSpec) DeepCopy() *KinesisStreamSpec

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

func (*KinesisStreamSpec) DeepCopyInto 

func (in *KinesisStreamSpec) DeepCopyInto(out *KinesisStreamSpec)

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

type KinesisStreamStatus 

type KinesisStreamStatus struct {
	runtimev1alpha1.ResourceStatus `json:",inline"`
	AtProvider                     KinesisStreamObservation `json:"atProvider"`
}

A KinesisStreamStatus defines the observed state of a KinesisStream

func (*KinesisStreamStatus) DeepCopy 

func (in *KinesisStreamStatus) DeepCopy() *KinesisStreamStatus

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

func (*KinesisStreamStatus) DeepCopyInto 

func (in *KinesisStreamStatus) DeepCopyInto(out *KinesisStreamStatus)

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

type Timeouts 

type Timeouts struct {
	Create string `json:"create"`
	Delete string `json:"delete"`
	Update string `json:"update"`
}

func (*Timeouts) DeepCopy 

func (in *Timeouts) DeepCopy() *Timeouts

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

func (*Timeouts) DeepCopyInto 

func (in *Timeouts) DeepCopyInto(out *Timeouts)

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.