kinesis

package
v0.88.0 Latest Latest
Warning

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

Go to latest
Published: Nov 29, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StreamModeDetailsStreamModeOnDemand    = StreamModeDetailsStreamMode("ON_DEMAND")
	StreamModeDetailsStreamModeProvisioned = StreamModeDetailsStreamMode("PROVISIONED")
)
View Source
const (
	StreamEncryptionEncryptionTypeKms = StreamEncryptionEncryptionType("KMS")
)

Variables

This section is empty.

Functions

This section is empty.

Types

type LookupStreamArgs added in v0.12.0

type LookupStreamArgs struct {
	// The name of the Kinesis stream.
	Name string `pulumi:"name"`
}

type LookupStreamConsumerArgs added in v0.12.0

type LookupStreamConsumerArgs struct {
	Id string `pulumi:"id"`
}

type LookupStreamConsumerOutputArgs added in v0.12.0

type LookupStreamConsumerOutputArgs struct {
	Id pulumi.StringInput `pulumi:"id"`
}

func (LookupStreamConsumerOutputArgs) ElementType added in v0.12.0

type LookupStreamConsumerResult added in v0.12.0

type LookupStreamConsumerResult struct {
	ConsumerArn               *string `pulumi:"consumerArn"`
	ConsumerCreationTimestamp *string `pulumi:"consumerCreationTimestamp"`
	ConsumerStatus            *string `pulumi:"consumerStatus"`
	Id                        *string `pulumi:"id"`
}

func LookupStreamConsumer added in v0.12.0

func LookupStreamConsumer(ctx *pulumi.Context, args *LookupStreamConsumerArgs, opts ...pulumi.InvokeOption) (*LookupStreamConsumerResult, error)

Resource Type definition for AWS::Kinesis::StreamConsumer

type LookupStreamConsumerResultOutput added in v0.12.0

type LookupStreamConsumerResultOutput struct{ *pulumi.OutputState }

func LookupStreamConsumerOutput added in v0.12.0

func (LookupStreamConsumerResultOutput) ConsumerArn added in v0.72.0

func (LookupStreamConsumerResultOutput) ConsumerCreationTimestamp added in v0.12.0

func (o LookupStreamConsumerResultOutput) ConsumerCreationTimestamp() pulumi.StringPtrOutput

func (LookupStreamConsumerResultOutput) ConsumerStatus added in v0.12.0

func (LookupStreamConsumerResultOutput) ElementType added in v0.12.0

func (LookupStreamConsumerResultOutput) Id added in v0.12.0

func (LookupStreamConsumerResultOutput) ToLookupStreamConsumerResultOutput added in v0.12.0

func (o LookupStreamConsumerResultOutput) ToLookupStreamConsumerResultOutput() LookupStreamConsumerResultOutput

func (LookupStreamConsumerResultOutput) ToLookupStreamConsumerResultOutputWithContext added in v0.12.0

func (o LookupStreamConsumerResultOutput) ToLookupStreamConsumerResultOutputWithContext(ctx context.Context) LookupStreamConsumerResultOutput

func (LookupStreamConsumerResultOutput) ToOutput added in v0.76.0

type LookupStreamOutputArgs added in v0.12.0

type LookupStreamOutputArgs struct {
	// The name of the Kinesis stream.
	Name pulumi.StringInput `pulumi:"name"`
}

func (LookupStreamOutputArgs) ElementType added in v0.12.0

func (LookupStreamOutputArgs) ElementType() reflect.Type

type LookupStreamResult added in v0.12.0

type LookupStreamResult struct {
	// The Amazon resource name (ARN) of the Kinesis stream
	Arn *string `pulumi:"arn"`
	// The number of hours for the data records that are stored in shards to remain accessible.
	RetentionPeriodHours *int `pulumi:"retentionPeriodHours"`
	// The number of shards that the stream uses. Required when StreamMode = PROVISIONED is passed.
	ShardCount *int `pulumi:"shardCount"`
	// When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream.
	StreamEncryption *StreamEncryption `pulumi:"streamEncryption"`
	// The mode in which the stream is running.
	StreamModeDetails *StreamModeDetails `pulumi:"streamModeDetails"`
	// An arbitrary set of tags (key–value pairs) to associate with the Kinesis stream.
	Tags []StreamTag `pulumi:"tags"`
}

func LookupStream added in v0.12.0

func LookupStream(ctx *pulumi.Context, args *LookupStreamArgs, opts ...pulumi.InvokeOption) (*LookupStreamResult, error)

Resource Type definition for AWS::Kinesis::Stream

type LookupStreamResultOutput added in v0.12.0

type LookupStreamResultOutput struct{ *pulumi.OutputState }

func LookupStreamOutput added in v0.12.0

func LookupStreamOutput(ctx *pulumi.Context, args LookupStreamOutputArgs, opts ...pulumi.InvokeOption) LookupStreamResultOutput

func (LookupStreamResultOutput) Arn added in v0.12.0

The Amazon resource name (ARN) of the Kinesis stream

func (LookupStreamResultOutput) ElementType added in v0.12.0

func (LookupStreamResultOutput) ElementType() reflect.Type

func (LookupStreamResultOutput) RetentionPeriodHours added in v0.12.0

func (o LookupStreamResultOutput) RetentionPeriodHours() pulumi.IntPtrOutput

The number of hours for the data records that are stored in shards to remain accessible.

func (LookupStreamResultOutput) ShardCount added in v0.12.0

The number of shards that the stream uses. Required when StreamMode = PROVISIONED is passed.

func (LookupStreamResultOutput) StreamEncryption added in v0.12.0

When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream.

func (LookupStreamResultOutput) StreamModeDetails added in v0.12.0

The mode in which the stream is running.

func (LookupStreamResultOutput) Tags added in v0.12.0

An arbitrary set of tags (key–value pairs) to associate with the Kinesis stream.

func (LookupStreamResultOutput) ToLookupStreamResultOutput added in v0.12.0

func (o LookupStreamResultOutput) ToLookupStreamResultOutput() LookupStreamResultOutput

func (LookupStreamResultOutput) ToLookupStreamResultOutputWithContext added in v0.12.0

func (o LookupStreamResultOutput) ToLookupStreamResultOutputWithContext(ctx context.Context) LookupStreamResultOutput

func (LookupStreamResultOutput) ToOutput added in v0.76.0

type Stream

type Stream struct {
	pulumi.CustomResourceState

	// The Amazon resource name (ARN) of the Kinesis stream
	Arn pulumi.StringOutput `pulumi:"arn"`
	// The name of the Kinesis stream.
	Name pulumi.StringPtrOutput `pulumi:"name"`
	// The number of hours for the data records that are stored in shards to remain accessible.
	RetentionPeriodHours pulumi.IntPtrOutput `pulumi:"retentionPeriodHours"`
	// The number of shards that the stream uses. Required when StreamMode = PROVISIONED is passed.
	ShardCount pulumi.IntPtrOutput `pulumi:"shardCount"`
	// When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream.
	StreamEncryption StreamEncryptionPtrOutput `pulumi:"streamEncryption"`
	// The mode in which the stream is running.
	StreamModeDetails StreamModeDetailsPtrOutput `pulumi:"streamModeDetails"`
	// An arbitrary set of tags (key–value pairs) to associate with the Kinesis stream.
	Tags StreamTagArrayOutput `pulumi:"tags"`
}

Resource Type definition for AWS::Kinesis::Stream

func GetStream

func GetStream(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *StreamState, opts ...pulumi.ResourceOption) (*Stream, error)

GetStream gets an existing Stream resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewStream

func NewStream(ctx *pulumi.Context,
	name string, args *StreamArgs, opts ...pulumi.ResourceOption) (*Stream, error)

NewStream registers a new resource with the given unique name, arguments, and options.

func (*Stream) ElementType

func (*Stream) ElementType() reflect.Type

func (*Stream) ToOutput added in v0.76.0

func (i *Stream) ToOutput(ctx context.Context) pulumix.Output[*Stream]

func (*Stream) ToStreamOutput

func (i *Stream) ToStreamOutput() StreamOutput

func (*Stream) ToStreamOutputWithContext

func (i *Stream) ToStreamOutputWithContext(ctx context.Context) StreamOutput

type StreamArgs

type StreamArgs struct {
	// The name of the Kinesis stream.
	Name pulumi.StringPtrInput
	// The number of hours for the data records that are stored in shards to remain accessible.
	RetentionPeriodHours pulumi.IntPtrInput
	// The number of shards that the stream uses. Required when StreamMode = PROVISIONED is passed.
	ShardCount pulumi.IntPtrInput
	// When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream.
	StreamEncryption StreamEncryptionPtrInput
	// The mode in which the stream is running.
	StreamModeDetails StreamModeDetailsPtrInput
	// An arbitrary set of tags (key–value pairs) to associate with the Kinesis stream.
	Tags StreamTagArrayInput
}

The set of arguments for constructing a Stream resource.

func (StreamArgs) ElementType

func (StreamArgs) ElementType() reflect.Type

type StreamConsumer deprecated

type StreamConsumer struct {
	pulumi.CustomResourceState

	ConsumerArn               pulumi.StringOutput `pulumi:"consumerArn"`
	ConsumerCreationTimestamp pulumi.StringOutput `pulumi:"consumerCreationTimestamp"`
	ConsumerName              pulumi.StringOutput `pulumi:"consumerName"`
	ConsumerStatus            pulumi.StringOutput `pulumi:"consumerStatus"`
	StreamArn                 pulumi.StringOutput `pulumi:"streamArn"`
}

Resource Type definition for AWS::Kinesis::StreamConsumer

Deprecated: StreamConsumer is not yet supported by AWS Native, so its creation will currently fail. Please use the classic AWS provider, if possible.

func GetStreamConsumer

func GetStreamConsumer(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *StreamConsumerState, opts ...pulumi.ResourceOption) (*StreamConsumer, error)

GetStreamConsumer gets an existing StreamConsumer resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewStreamConsumer

func NewStreamConsumer(ctx *pulumi.Context,
	name string, args *StreamConsumerArgs, opts ...pulumi.ResourceOption) (*StreamConsumer, error)

NewStreamConsumer registers a new resource with the given unique name, arguments, and options.

func (*StreamConsumer) ElementType

func (*StreamConsumer) ElementType() reflect.Type

func (*StreamConsumer) ToOutput added in v0.76.0

func (*StreamConsumer) ToStreamConsumerOutput

func (i *StreamConsumer) ToStreamConsumerOutput() StreamConsumerOutput

func (*StreamConsumer) ToStreamConsumerOutputWithContext

func (i *StreamConsumer) ToStreamConsumerOutputWithContext(ctx context.Context) StreamConsumerOutput

type StreamConsumerArgs

type StreamConsumerArgs struct {
	ConsumerName pulumi.StringInput
	StreamArn    pulumi.StringInput
}

The set of arguments for constructing a StreamConsumer resource.

func (StreamConsumerArgs) ElementType

func (StreamConsumerArgs) ElementType() reflect.Type

type StreamConsumerInput

type StreamConsumerInput interface {
	pulumi.Input

	ToStreamConsumerOutput() StreamConsumerOutput
	ToStreamConsumerOutputWithContext(ctx context.Context) StreamConsumerOutput
}

type StreamConsumerOutput

type StreamConsumerOutput struct{ *pulumi.OutputState }

func (StreamConsumerOutput) ConsumerArn added in v0.72.0

func (o StreamConsumerOutput) ConsumerArn() pulumi.StringOutput

func (StreamConsumerOutput) ConsumerCreationTimestamp added in v0.17.0

func (o StreamConsumerOutput) ConsumerCreationTimestamp() pulumi.StringOutput

func (StreamConsumerOutput) ConsumerName added in v0.17.0

func (o StreamConsumerOutput) ConsumerName() pulumi.StringOutput

func (StreamConsumerOutput) ConsumerStatus added in v0.17.0

func (o StreamConsumerOutput) ConsumerStatus() pulumi.StringOutput

func (StreamConsumerOutput) ElementType

func (StreamConsumerOutput) ElementType() reflect.Type

func (StreamConsumerOutput) StreamArn added in v0.72.0

func (StreamConsumerOutput) ToOutput added in v0.76.0

func (StreamConsumerOutput) ToStreamConsumerOutput

func (o StreamConsumerOutput) ToStreamConsumerOutput() StreamConsumerOutput

func (StreamConsumerOutput) ToStreamConsumerOutputWithContext

func (o StreamConsumerOutput) ToStreamConsumerOutputWithContext(ctx context.Context) StreamConsumerOutput

type StreamConsumerState

type StreamConsumerState struct {
}

func (StreamConsumerState) ElementType

func (StreamConsumerState) ElementType() reflect.Type

type StreamEncryption added in v0.2.0

type StreamEncryption struct {
	// The encryption type to use. The only valid value is KMS.
	EncryptionType StreamEncryptionEncryptionType `pulumi:"encryptionType"`
	// The GUID for the customer-managed AWS KMS key to use for encryption. This value can be a globally unique identifier, a fully specified Amazon Resource Name (ARN) to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.
	KeyId string `pulumi:"keyId"`
}

When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream. Removing this property from your stack template and updating your stack disables encryption.

type StreamEncryptionArgs added in v0.2.0

type StreamEncryptionArgs struct {
	// The encryption type to use. The only valid value is KMS.
	EncryptionType StreamEncryptionEncryptionTypeInput `pulumi:"encryptionType"`
	// The GUID for the customer-managed AWS KMS key to use for encryption. This value can be a globally unique identifier, a fully specified Amazon Resource Name (ARN) to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.
	KeyId pulumi.StringInput `pulumi:"keyId"`
}

When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream. Removing this property from your stack template and updating your stack disables encryption.

func (StreamEncryptionArgs) ElementType added in v0.2.0

func (StreamEncryptionArgs) ElementType() reflect.Type

func (StreamEncryptionArgs) ToOutput added in v0.76.0

func (StreamEncryptionArgs) ToStreamEncryptionOutput added in v0.2.0

func (i StreamEncryptionArgs) ToStreamEncryptionOutput() StreamEncryptionOutput

func (StreamEncryptionArgs) ToStreamEncryptionOutputWithContext added in v0.2.0

func (i StreamEncryptionArgs) ToStreamEncryptionOutputWithContext(ctx context.Context) StreamEncryptionOutput

func (StreamEncryptionArgs) ToStreamEncryptionPtrOutput added in v0.2.0

func (i StreamEncryptionArgs) ToStreamEncryptionPtrOutput() StreamEncryptionPtrOutput

func (StreamEncryptionArgs) ToStreamEncryptionPtrOutputWithContext added in v0.2.0

func (i StreamEncryptionArgs) ToStreamEncryptionPtrOutputWithContext(ctx context.Context) StreamEncryptionPtrOutput

type StreamEncryptionEncryptionType added in v0.2.0

type StreamEncryptionEncryptionType string

The encryption type to use. The only valid value is KMS.

func (StreamEncryptionEncryptionType) ElementType added in v0.2.0

func (StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypeOutput added in v0.2.0

func (e StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypeOutput() StreamEncryptionEncryptionTypeOutput

func (StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypeOutputWithContext added in v0.2.0

func (e StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypeOutputWithContext(ctx context.Context) StreamEncryptionEncryptionTypeOutput

func (StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypePtrOutput added in v0.2.0

func (e StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypePtrOutput() StreamEncryptionEncryptionTypePtrOutput

func (StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypePtrOutputWithContext added in v0.2.0

func (e StreamEncryptionEncryptionType) ToStreamEncryptionEncryptionTypePtrOutputWithContext(ctx context.Context) StreamEncryptionEncryptionTypePtrOutput

func (StreamEncryptionEncryptionType) ToStringOutput added in v0.2.0

func (StreamEncryptionEncryptionType) ToStringOutputWithContext added in v0.2.0

func (e StreamEncryptionEncryptionType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (StreamEncryptionEncryptionType) ToStringPtrOutput added in v0.2.0

func (StreamEncryptionEncryptionType) ToStringPtrOutputWithContext added in v0.2.0

func (e StreamEncryptionEncryptionType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type StreamEncryptionEncryptionTypeInput added in v0.2.0

type StreamEncryptionEncryptionTypeInput interface {
	pulumi.Input

	ToStreamEncryptionEncryptionTypeOutput() StreamEncryptionEncryptionTypeOutput
	ToStreamEncryptionEncryptionTypeOutputWithContext(context.Context) StreamEncryptionEncryptionTypeOutput
}

StreamEncryptionEncryptionTypeInput is an input type that accepts StreamEncryptionEncryptionTypeArgs and StreamEncryptionEncryptionTypeOutput values. You can construct a concrete instance of `StreamEncryptionEncryptionTypeInput` via:

StreamEncryptionEncryptionTypeArgs{...}

type StreamEncryptionEncryptionTypeOutput added in v0.2.0

type StreamEncryptionEncryptionTypeOutput struct{ *pulumi.OutputState }

func (StreamEncryptionEncryptionTypeOutput) ElementType added in v0.2.0

func (StreamEncryptionEncryptionTypeOutput) ToOutput added in v0.76.0

func (StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypeOutput added in v0.2.0

func (o StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypeOutput() StreamEncryptionEncryptionTypeOutput

func (StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypeOutputWithContext added in v0.2.0

func (o StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypeOutputWithContext(ctx context.Context) StreamEncryptionEncryptionTypeOutput

func (StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypePtrOutput added in v0.2.0

func (o StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypePtrOutput() StreamEncryptionEncryptionTypePtrOutput

func (StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypePtrOutputWithContext added in v0.2.0

func (o StreamEncryptionEncryptionTypeOutput) ToStreamEncryptionEncryptionTypePtrOutputWithContext(ctx context.Context) StreamEncryptionEncryptionTypePtrOutput

func (StreamEncryptionEncryptionTypeOutput) ToStringOutput added in v0.2.0

func (StreamEncryptionEncryptionTypeOutput) ToStringOutputWithContext added in v0.2.0

func (o StreamEncryptionEncryptionTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (StreamEncryptionEncryptionTypeOutput) ToStringPtrOutput added in v0.2.0

func (StreamEncryptionEncryptionTypeOutput) ToStringPtrOutputWithContext added in v0.2.0

func (o StreamEncryptionEncryptionTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type StreamEncryptionEncryptionTypePtrInput added in v0.2.0

type StreamEncryptionEncryptionTypePtrInput interface {
	pulumi.Input

	ToStreamEncryptionEncryptionTypePtrOutput() StreamEncryptionEncryptionTypePtrOutput
	ToStreamEncryptionEncryptionTypePtrOutputWithContext(context.Context) StreamEncryptionEncryptionTypePtrOutput
}

func StreamEncryptionEncryptionTypePtr added in v0.2.0

func StreamEncryptionEncryptionTypePtr(v string) StreamEncryptionEncryptionTypePtrInput

type StreamEncryptionEncryptionTypePtrOutput added in v0.2.0

type StreamEncryptionEncryptionTypePtrOutput struct{ *pulumi.OutputState }

func (StreamEncryptionEncryptionTypePtrOutput) Elem added in v0.2.0

func (StreamEncryptionEncryptionTypePtrOutput) ElementType added in v0.2.0

func (StreamEncryptionEncryptionTypePtrOutput) ToOutput added in v0.76.0

func (StreamEncryptionEncryptionTypePtrOutput) ToStreamEncryptionEncryptionTypePtrOutput added in v0.2.0

func (o StreamEncryptionEncryptionTypePtrOutput) ToStreamEncryptionEncryptionTypePtrOutput() StreamEncryptionEncryptionTypePtrOutput

func (StreamEncryptionEncryptionTypePtrOutput) ToStreamEncryptionEncryptionTypePtrOutputWithContext added in v0.2.0

func (o StreamEncryptionEncryptionTypePtrOutput) ToStreamEncryptionEncryptionTypePtrOutputWithContext(ctx context.Context) StreamEncryptionEncryptionTypePtrOutput

func (StreamEncryptionEncryptionTypePtrOutput) ToStringPtrOutput added in v0.2.0

func (StreamEncryptionEncryptionTypePtrOutput) ToStringPtrOutputWithContext added in v0.2.0

type StreamEncryptionInput added in v0.2.0

type StreamEncryptionInput interface {
	pulumi.Input

	ToStreamEncryptionOutput() StreamEncryptionOutput
	ToStreamEncryptionOutputWithContext(context.Context) StreamEncryptionOutput
}

StreamEncryptionInput is an input type that accepts StreamEncryptionArgs and StreamEncryptionOutput values. You can construct a concrete instance of `StreamEncryptionInput` via:

StreamEncryptionArgs{...}

type StreamEncryptionOutput added in v0.2.0

type StreamEncryptionOutput struct{ *pulumi.OutputState }

When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream. Removing this property from your stack template and updating your stack disables encryption.

func (StreamEncryptionOutput) ElementType added in v0.2.0

func (StreamEncryptionOutput) ElementType() reflect.Type

func (StreamEncryptionOutput) EncryptionType added in v0.2.0

The encryption type to use. The only valid value is KMS.

func (StreamEncryptionOutput) KeyId added in v0.2.0

The GUID for the customer-managed AWS KMS key to use for encryption. This value can be a globally unique identifier, a fully specified Amazon Resource Name (ARN) to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.

func (StreamEncryptionOutput) ToOutput added in v0.76.0

func (StreamEncryptionOutput) ToStreamEncryptionOutput added in v0.2.0

func (o StreamEncryptionOutput) ToStreamEncryptionOutput() StreamEncryptionOutput

func (StreamEncryptionOutput) ToStreamEncryptionOutputWithContext added in v0.2.0

func (o StreamEncryptionOutput) ToStreamEncryptionOutputWithContext(ctx context.Context) StreamEncryptionOutput

func (StreamEncryptionOutput) ToStreamEncryptionPtrOutput added in v0.2.0

func (o StreamEncryptionOutput) ToStreamEncryptionPtrOutput() StreamEncryptionPtrOutput

func (StreamEncryptionOutput) ToStreamEncryptionPtrOutputWithContext added in v0.2.0

func (o StreamEncryptionOutput) ToStreamEncryptionPtrOutputWithContext(ctx context.Context) StreamEncryptionPtrOutput

type StreamEncryptionPtrInput added in v0.2.0

type StreamEncryptionPtrInput interface {
	pulumi.Input

	ToStreamEncryptionPtrOutput() StreamEncryptionPtrOutput
	ToStreamEncryptionPtrOutputWithContext(context.Context) StreamEncryptionPtrOutput
}

StreamEncryptionPtrInput is an input type that accepts StreamEncryptionArgs, StreamEncryptionPtr and StreamEncryptionPtrOutput values. You can construct a concrete instance of `StreamEncryptionPtrInput` via:

        StreamEncryptionArgs{...}

or:

        nil

func StreamEncryptionPtr added in v0.2.0

func StreamEncryptionPtr(v *StreamEncryptionArgs) StreamEncryptionPtrInput

type StreamEncryptionPtrOutput added in v0.2.0

type StreamEncryptionPtrOutput struct{ *pulumi.OutputState }

func (StreamEncryptionPtrOutput) Elem added in v0.2.0

func (StreamEncryptionPtrOutput) ElementType added in v0.2.0

func (StreamEncryptionPtrOutput) ElementType() reflect.Type

func (StreamEncryptionPtrOutput) EncryptionType added in v0.2.0

The encryption type to use. The only valid value is KMS.

func (StreamEncryptionPtrOutput) KeyId added in v0.2.0

The GUID for the customer-managed AWS KMS key to use for encryption. This value can be a globally unique identifier, a fully specified Amazon Resource Name (ARN) to either an alias or a key, or an alias name prefixed by "alias/".You can also use a master key owned by Kinesis Data Streams by specifying the alias aws/kinesis.

func (StreamEncryptionPtrOutput) ToOutput added in v0.76.0

func (StreamEncryptionPtrOutput) ToStreamEncryptionPtrOutput added in v0.2.0

func (o StreamEncryptionPtrOutput) ToStreamEncryptionPtrOutput() StreamEncryptionPtrOutput

func (StreamEncryptionPtrOutput) ToStreamEncryptionPtrOutputWithContext added in v0.2.0

func (o StreamEncryptionPtrOutput) ToStreamEncryptionPtrOutputWithContext(ctx context.Context) StreamEncryptionPtrOutput

type StreamInput

type StreamInput interface {
	pulumi.Input

	ToStreamOutput() StreamOutput
	ToStreamOutputWithContext(ctx context.Context) StreamOutput
}

type StreamModeDetails added in v0.9.0

type StreamModeDetails struct {
	// The mode of the stream
	StreamMode StreamModeDetailsStreamMode `pulumi:"streamMode"`
}

When specified, enables or updates the mode of stream. Default is PROVISIONED.

type StreamModeDetailsArgs added in v0.9.0

type StreamModeDetailsArgs struct {
	// The mode of the stream
	StreamMode StreamModeDetailsStreamModeInput `pulumi:"streamMode"`
}

When specified, enables or updates the mode of stream. Default is PROVISIONED.

func (StreamModeDetailsArgs) ElementType added in v0.9.0

func (StreamModeDetailsArgs) ElementType() reflect.Type

func (StreamModeDetailsArgs) ToOutput added in v0.76.0

func (StreamModeDetailsArgs) ToStreamModeDetailsOutput added in v0.9.0

func (i StreamModeDetailsArgs) ToStreamModeDetailsOutput() StreamModeDetailsOutput

func (StreamModeDetailsArgs) ToStreamModeDetailsOutputWithContext added in v0.9.0

func (i StreamModeDetailsArgs) ToStreamModeDetailsOutputWithContext(ctx context.Context) StreamModeDetailsOutput

func (StreamModeDetailsArgs) ToStreamModeDetailsPtrOutput added in v0.9.0

func (i StreamModeDetailsArgs) ToStreamModeDetailsPtrOutput() StreamModeDetailsPtrOutput

func (StreamModeDetailsArgs) ToStreamModeDetailsPtrOutputWithContext added in v0.9.0

func (i StreamModeDetailsArgs) ToStreamModeDetailsPtrOutputWithContext(ctx context.Context) StreamModeDetailsPtrOutput

type StreamModeDetailsInput added in v0.9.0

type StreamModeDetailsInput interface {
	pulumi.Input

	ToStreamModeDetailsOutput() StreamModeDetailsOutput
	ToStreamModeDetailsOutputWithContext(context.Context) StreamModeDetailsOutput
}

StreamModeDetailsInput is an input type that accepts StreamModeDetailsArgs and StreamModeDetailsOutput values. You can construct a concrete instance of `StreamModeDetailsInput` via:

StreamModeDetailsArgs{...}

type StreamModeDetailsOutput added in v0.9.0

type StreamModeDetailsOutput struct{ *pulumi.OutputState }

When specified, enables or updates the mode of stream. Default is PROVISIONED.

func (StreamModeDetailsOutput) ElementType added in v0.9.0

func (StreamModeDetailsOutput) ElementType() reflect.Type

func (StreamModeDetailsOutput) StreamMode added in v0.9.0

The mode of the stream

func (StreamModeDetailsOutput) ToOutput added in v0.76.0

func (StreamModeDetailsOutput) ToStreamModeDetailsOutput added in v0.9.0

func (o StreamModeDetailsOutput) ToStreamModeDetailsOutput() StreamModeDetailsOutput

func (StreamModeDetailsOutput) ToStreamModeDetailsOutputWithContext added in v0.9.0

func (o StreamModeDetailsOutput) ToStreamModeDetailsOutputWithContext(ctx context.Context) StreamModeDetailsOutput

func (StreamModeDetailsOutput) ToStreamModeDetailsPtrOutput added in v0.9.0

func (o StreamModeDetailsOutput) ToStreamModeDetailsPtrOutput() StreamModeDetailsPtrOutput

func (StreamModeDetailsOutput) ToStreamModeDetailsPtrOutputWithContext added in v0.9.0

func (o StreamModeDetailsOutput) ToStreamModeDetailsPtrOutputWithContext(ctx context.Context) StreamModeDetailsPtrOutput

type StreamModeDetailsPtrInput added in v0.9.0

type StreamModeDetailsPtrInput interface {
	pulumi.Input

	ToStreamModeDetailsPtrOutput() StreamModeDetailsPtrOutput
	ToStreamModeDetailsPtrOutputWithContext(context.Context) StreamModeDetailsPtrOutput
}

StreamModeDetailsPtrInput is an input type that accepts StreamModeDetailsArgs, StreamModeDetailsPtr and StreamModeDetailsPtrOutput values. You can construct a concrete instance of `StreamModeDetailsPtrInput` via:

        StreamModeDetailsArgs{...}

or:

        nil

func StreamModeDetailsPtr added in v0.9.0

func StreamModeDetailsPtr(v *StreamModeDetailsArgs) StreamModeDetailsPtrInput

type StreamModeDetailsPtrOutput added in v0.9.0

type StreamModeDetailsPtrOutput struct{ *pulumi.OutputState }

func (StreamModeDetailsPtrOutput) Elem added in v0.9.0

func (StreamModeDetailsPtrOutput) ElementType added in v0.9.0

func (StreamModeDetailsPtrOutput) ElementType() reflect.Type

func (StreamModeDetailsPtrOutput) StreamMode added in v0.9.0

The mode of the stream

func (StreamModeDetailsPtrOutput) ToOutput added in v0.76.0

func (StreamModeDetailsPtrOutput) ToStreamModeDetailsPtrOutput added in v0.9.0

func (o StreamModeDetailsPtrOutput) ToStreamModeDetailsPtrOutput() StreamModeDetailsPtrOutput

func (StreamModeDetailsPtrOutput) ToStreamModeDetailsPtrOutputWithContext added in v0.9.0

func (o StreamModeDetailsPtrOutput) ToStreamModeDetailsPtrOutputWithContext(ctx context.Context) StreamModeDetailsPtrOutput

type StreamModeDetailsStreamMode added in v0.9.0

type StreamModeDetailsStreamMode string

The mode of the stream

func (StreamModeDetailsStreamMode) ElementType added in v0.9.0

func (StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModeOutput added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModeOutput() StreamModeDetailsStreamModeOutput

func (StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModeOutputWithContext added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModeOutputWithContext(ctx context.Context) StreamModeDetailsStreamModeOutput

func (StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModePtrOutput added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModePtrOutput() StreamModeDetailsStreamModePtrOutput

func (StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModePtrOutputWithContext added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStreamModeDetailsStreamModePtrOutputWithContext(ctx context.Context) StreamModeDetailsStreamModePtrOutput

func (StreamModeDetailsStreamMode) ToStringOutput added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStringOutput() pulumi.StringOutput

func (StreamModeDetailsStreamMode) ToStringOutputWithContext added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (StreamModeDetailsStreamMode) ToStringPtrOutput added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStringPtrOutput() pulumi.StringPtrOutput

func (StreamModeDetailsStreamMode) ToStringPtrOutputWithContext added in v0.9.0

func (e StreamModeDetailsStreamMode) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type StreamModeDetailsStreamModeInput added in v0.9.0

type StreamModeDetailsStreamModeInput interface {
	pulumi.Input

	ToStreamModeDetailsStreamModeOutput() StreamModeDetailsStreamModeOutput
	ToStreamModeDetailsStreamModeOutputWithContext(context.Context) StreamModeDetailsStreamModeOutput
}

StreamModeDetailsStreamModeInput is an input type that accepts StreamModeDetailsStreamModeArgs and StreamModeDetailsStreamModeOutput values. You can construct a concrete instance of `StreamModeDetailsStreamModeInput` via:

StreamModeDetailsStreamModeArgs{...}

type StreamModeDetailsStreamModeOutput added in v0.9.0

type StreamModeDetailsStreamModeOutput struct{ *pulumi.OutputState }

func (StreamModeDetailsStreamModeOutput) ElementType added in v0.9.0

func (StreamModeDetailsStreamModeOutput) ToOutput added in v0.76.0

func (StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModeOutput added in v0.9.0

func (o StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModeOutput() StreamModeDetailsStreamModeOutput

func (StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModeOutputWithContext added in v0.9.0

func (o StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModeOutputWithContext(ctx context.Context) StreamModeDetailsStreamModeOutput

func (StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModePtrOutput added in v0.9.0

func (o StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModePtrOutput() StreamModeDetailsStreamModePtrOutput

func (StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModePtrOutputWithContext added in v0.9.0

func (o StreamModeDetailsStreamModeOutput) ToStreamModeDetailsStreamModePtrOutputWithContext(ctx context.Context) StreamModeDetailsStreamModePtrOutput

func (StreamModeDetailsStreamModeOutput) ToStringOutput added in v0.9.0

func (StreamModeDetailsStreamModeOutput) ToStringOutputWithContext added in v0.9.0

func (o StreamModeDetailsStreamModeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (StreamModeDetailsStreamModeOutput) ToStringPtrOutput added in v0.9.0

func (StreamModeDetailsStreamModeOutput) ToStringPtrOutputWithContext added in v0.9.0

func (o StreamModeDetailsStreamModeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type StreamModeDetailsStreamModePtrInput added in v0.9.0

type StreamModeDetailsStreamModePtrInput interface {
	pulumi.Input

	ToStreamModeDetailsStreamModePtrOutput() StreamModeDetailsStreamModePtrOutput
	ToStreamModeDetailsStreamModePtrOutputWithContext(context.Context) StreamModeDetailsStreamModePtrOutput
}

func StreamModeDetailsStreamModePtr added in v0.9.0

func StreamModeDetailsStreamModePtr(v string) StreamModeDetailsStreamModePtrInput

type StreamModeDetailsStreamModePtrOutput added in v0.9.0

type StreamModeDetailsStreamModePtrOutput struct{ *pulumi.OutputState }

func (StreamModeDetailsStreamModePtrOutput) Elem added in v0.9.0

func (StreamModeDetailsStreamModePtrOutput) ElementType added in v0.9.0

func (StreamModeDetailsStreamModePtrOutput) ToOutput added in v0.76.0

func (StreamModeDetailsStreamModePtrOutput) ToStreamModeDetailsStreamModePtrOutput added in v0.9.0

func (o StreamModeDetailsStreamModePtrOutput) ToStreamModeDetailsStreamModePtrOutput() StreamModeDetailsStreamModePtrOutput

func (StreamModeDetailsStreamModePtrOutput) ToStreamModeDetailsStreamModePtrOutputWithContext added in v0.9.0

func (o StreamModeDetailsStreamModePtrOutput) ToStreamModeDetailsStreamModePtrOutputWithContext(ctx context.Context) StreamModeDetailsStreamModePtrOutput

func (StreamModeDetailsStreamModePtrOutput) ToStringPtrOutput added in v0.9.0

func (StreamModeDetailsStreamModePtrOutput) ToStringPtrOutputWithContext added in v0.9.0

func (o StreamModeDetailsStreamModePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type StreamOutput

type StreamOutput struct{ *pulumi.OutputState }

func (StreamOutput) Arn added in v0.17.0

The Amazon resource name (ARN) of the Kinesis stream

func (StreamOutput) ElementType

func (StreamOutput) ElementType() reflect.Type

func (StreamOutput) Name added in v0.17.0

The name of the Kinesis stream.

func (StreamOutput) RetentionPeriodHours added in v0.17.0

func (o StreamOutput) RetentionPeriodHours() pulumi.IntPtrOutput

The number of hours for the data records that are stored in shards to remain accessible.

func (StreamOutput) ShardCount added in v0.17.0

func (o StreamOutput) ShardCount() pulumi.IntPtrOutput

The number of shards that the stream uses. Required when StreamMode = PROVISIONED is passed.

func (StreamOutput) StreamEncryption added in v0.17.0

func (o StreamOutput) StreamEncryption() StreamEncryptionPtrOutput

When specified, enables or updates server-side encryption using an AWS KMS key for a specified stream.

func (StreamOutput) StreamModeDetails added in v0.17.0

func (o StreamOutput) StreamModeDetails() StreamModeDetailsPtrOutput

The mode in which the stream is running.

func (StreamOutput) Tags added in v0.17.0

An arbitrary set of tags (key–value pairs) to associate with the Kinesis stream.

func (StreamOutput) ToOutput added in v0.76.0

func (o StreamOutput) ToOutput(ctx context.Context) pulumix.Output[*Stream]

func (StreamOutput) ToStreamOutput

func (o StreamOutput) ToStreamOutput() StreamOutput

func (StreamOutput) ToStreamOutputWithContext

func (o StreamOutput) ToStreamOutputWithContext(ctx context.Context) StreamOutput

type StreamState

type StreamState struct {
}

func (StreamState) ElementType

func (StreamState) ElementType() reflect.Type

type StreamTag

type StreamTag struct {
	// The key name of the tag. You can specify a value that is 1 to 128 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Key string `pulumi:"key"`
	// The value for the tag. You can specify a value that is 0 to 255 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Value string `pulumi:"value"`
}

An arbitrary set of tags (key-value pairs) to associate with the Kinesis stream.

type StreamTagArgs

type StreamTagArgs struct {
	// The key name of the tag. You can specify a value that is 1 to 128 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Key pulumi.StringInput `pulumi:"key"`
	// The value for the tag. You can specify a value that is 0 to 255 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Value pulumi.StringInput `pulumi:"value"`
}

An arbitrary set of tags (key-value pairs) to associate with the Kinesis stream.

func (StreamTagArgs) ElementType

func (StreamTagArgs) ElementType() reflect.Type

func (StreamTagArgs) ToOutput added in v0.76.0

func (StreamTagArgs) ToStreamTagOutput

func (i StreamTagArgs) ToStreamTagOutput() StreamTagOutput

func (StreamTagArgs) ToStreamTagOutputWithContext

func (i StreamTagArgs) ToStreamTagOutputWithContext(ctx context.Context) StreamTagOutput

type StreamTagArray

type StreamTagArray []StreamTagInput

func (StreamTagArray) ElementType

func (StreamTagArray) ElementType() reflect.Type

func (StreamTagArray) ToOutput added in v0.76.0

func (StreamTagArray) ToStreamTagArrayOutput

func (i StreamTagArray) ToStreamTagArrayOutput() StreamTagArrayOutput

func (StreamTagArray) ToStreamTagArrayOutputWithContext

func (i StreamTagArray) ToStreamTagArrayOutputWithContext(ctx context.Context) StreamTagArrayOutput

type StreamTagArrayInput

type StreamTagArrayInput interface {
	pulumi.Input

	ToStreamTagArrayOutput() StreamTagArrayOutput
	ToStreamTagArrayOutputWithContext(context.Context) StreamTagArrayOutput
}

StreamTagArrayInput is an input type that accepts StreamTagArray and StreamTagArrayOutput values. You can construct a concrete instance of `StreamTagArrayInput` via:

StreamTagArray{ StreamTagArgs{...} }

type StreamTagArrayOutput

type StreamTagArrayOutput struct{ *pulumi.OutputState }

func (StreamTagArrayOutput) ElementType

func (StreamTagArrayOutput) ElementType() reflect.Type

func (StreamTagArrayOutput) Index

func (StreamTagArrayOutput) ToOutput added in v0.76.0

func (StreamTagArrayOutput) ToStreamTagArrayOutput

func (o StreamTagArrayOutput) ToStreamTagArrayOutput() StreamTagArrayOutput

func (StreamTagArrayOutput) ToStreamTagArrayOutputWithContext

func (o StreamTagArrayOutput) ToStreamTagArrayOutputWithContext(ctx context.Context) StreamTagArrayOutput

type StreamTagInput

type StreamTagInput interface {
	pulumi.Input

	ToStreamTagOutput() StreamTagOutput
	ToStreamTagOutputWithContext(context.Context) StreamTagOutput
}

StreamTagInput is an input type that accepts StreamTagArgs and StreamTagOutput values. You can construct a concrete instance of `StreamTagInput` via:

StreamTagArgs{...}

type StreamTagOutput

type StreamTagOutput struct{ *pulumi.OutputState }

An arbitrary set of tags (key-value pairs) to associate with the Kinesis stream.

func (StreamTagOutput) ElementType

func (StreamTagOutput) ElementType() reflect.Type

func (StreamTagOutput) Key

The key name of the tag. You can specify a value that is 1 to 128 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.

func (StreamTagOutput) ToOutput added in v0.76.0

func (StreamTagOutput) ToStreamTagOutput

func (o StreamTagOutput) ToStreamTagOutput() StreamTagOutput

func (StreamTagOutput) ToStreamTagOutputWithContext

func (o StreamTagOutput) ToStreamTagOutputWithContext(ctx context.Context) StreamTagOutput

func (StreamTagOutput) Value

The value for the tag. You can specify a value that is 0 to 255 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL