v1alpha1

Nov 16, 2022

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type Consumer struct

+ ConsumerCreationTimestamp *metav1.Time

+ func (in *Consumer) DeepCopy() *Consumer

+ func (in *Consumer) DeepCopyInto(out *Consumer)

+ type ConsumerDescription struct

+ ConsumerCreationTimestamp *metav1.Time

+ StreamARN *string

+ func (in *ConsumerDescription) DeepCopy() *ConsumerDescription

+ func (in *ConsumerDescription) DeepCopyInto(out *ConsumerDescription)

+ type ConsumerStatus string

+ const ConsumerStatus_ACTIVE

+ const ConsumerStatus_CREATING

+ const ConsumerStatus_DELETING

+ type EncryptionType string

+ const EncryptionType_KMS

+ const EncryptionType_NONE

+ type EnhancedMetrics struct

+ ShardLevelMetrics []*string

+ func (in *EnhancedMetrics) DeepCopy() *EnhancedMetrics

+ func (in *EnhancedMetrics) DeepCopyInto(out *EnhancedMetrics)

+ type MetricsName string

+ const MetricsName_ALL

+ const MetricsName_IncomingBytes

+ const MetricsName_IncomingRecords

+ const MetricsName_IteratorAgeMilliseconds

+ const MetricsName_OutgoingBytes

+ const MetricsName_OutgoingRecords

+ const MetricsName_ReadProvisionedThroughputExceeded

+ const MetricsName_WriteProvisionedThroughputExceeded

+ type Record struct

+ ApproximateArrivalTimestamp *metav1.Time

+ EncryptionType *string

+ func (in *Record) DeepCopy() *Record

+ func (in *Record) DeepCopyInto(out *Record)

+ type ScalingType string

+ const ScalingType_UNIFORM_SCALING

+ type ShardFilter struct

+ Timestamp *metav1.Time

+ func (in *ShardFilter) DeepCopy() *ShardFilter

+ func (in *ShardFilter) DeepCopyInto(out *ShardFilter)

+ type ShardFilterType string

+ const ShardFilterType_AFTER_SHARD_ID

+ const ShardFilterType_AT_LATEST

+ const ShardFilterType_AT_TIMESTAMP

+ const ShardFilterType_AT_TRIM_HORIZON

+ const ShardFilterType_FROM_TIMESTAMP

+ const ShardFilterType_FROM_TRIM_HORIZON

+ type ShardIteratorType string

+ const ShardIteratorType_AFTER_SEQUENCE_NUMBER

+ const ShardIteratorType_AT_SEQUENCE_NUMBER

+ const ShardIteratorType_AT_TIMESTAMP

+ const ShardIteratorType_LATEST

+ const ShardIteratorType_TRIM_HORIZON

+ type StartingPosition struct

+ Timestamp *metav1.Time

+ func (in *StartingPosition) DeepCopy() *StartingPosition

+ func (in *StartingPosition) DeepCopyInto(out *StartingPosition)

+ type Stream struct

+ Spec StreamSpec

+ Status StreamStatus

+ func (in *Stream) DeepCopy() *Stream

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

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

+ type StreamDescription struct

+ EncryptionType *string

+ EnhancedMonitoring []*EnhancedMetrics

+ HasMoreShards *bool

+ KeyID *string

+ RetentionPeriodHours *int64

+ StreamARN *string

+ StreamCreationTimestamp *metav1.Time

+ StreamModeDetails *StreamModeDetails

+ StreamName *string

+ StreamStatus *string

+ func (in *StreamDescription) DeepCopy() *StreamDescription

+ func (in *StreamDescription) DeepCopyInto(out *StreamDescription)

+ type StreamDescriptionSummary struct

+ ConsumerCount *int64

+ EncryptionType *string

+ EnhancedMonitoring []*EnhancedMetrics

+ KeyID *string

+ OpenShardCount *int64

+ RetentionPeriodHours *int64

+ StreamARN *string

+ StreamCreationTimestamp *metav1.Time

+ StreamModeDetails *StreamModeDetails

+ StreamName *string

+ StreamStatus *string

+ func (in *StreamDescriptionSummary) DeepCopy() *StreamDescriptionSummary

+ func (in *StreamDescriptionSummary) DeepCopyInto(out *StreamDescriptionSummary)

+ type StreamList struct

+ Items []Stream

+ func (in *StreamList) DeepCopy() *StreamList

+ func (in *StreamList) DeepCopyInto(out *StreamList)

+ func (in *StreamList) DeepCopyObject() runtime.Object

+ type StreamMode string

+ const StreamMode_ON_DEMAND

+ const StreamMode_PROVISIONED

+ type StreamModeDetails struct

+ StreamMode *string

+ func (in *StreamModeDetails) DeepCopy() *StreamModeDetails

+ func (in *StreamModeDetails) DeepCopyInto(out *StreamModeDetails)

+ type StreamSpec struct

+ Name *string

+ ShardCount *int64

+ StreamModeDetails *StreamModeDetails

+ func (in *StreamSpec) DeepCopy() *StreamSpec

+ func (in *StreamSpec) DeepCopyInto(out *StreamSpec)

+ type StreamStatus struct

+ ACKResourceMetadata *ackv1alpha1.ResourceMetadata

+ Conditions []*ackv1alpha1.Condition

+ ConsumerCount *int64

+ EncryptionType *string

+ EnhancedMonitoring []*EnhancedMetrics

+ KeyID *string

+ OpenShardCount *int64

+ RetentionPeriodHours *int64

+ StreamCreationTimestamp *metav1.Time

+ StreamStatus *string

+ func (in *StreamStatus) DeepCopy() *StreamStatus

+ func (in *StreamStatus) DeepCopyInto(out *StreamStatus)

+ type StreamStatus_SDK string

+ const StreamStatus_SDK_ACTIVE

+ const StreamStatus_SDK_CREATING

+ const StreamStatus_SDK_DELETING

+ const StreamStatus_SDK_UPDATING