awskinesis

package
v1.98.1-devpreview Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CfnStreamConsumer_CFN_RESOURCE_TYPE_NAME 

func CfnStreamConsumer_CFN_RESOURCE_TYPE_NAME() *string

func CfnStreamConsumer_IsCfnElement 

func CfnStreamConsumer_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnStreamConsumer_IsCfnResource 

func CfnStreamConsumer_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnStreamConsumer_IsConstruct 

func CfnStreamConsumer_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func CfnStream_CFN_RESOURCE_TYPE_NAME 

func CfnStream_CFN_RESOURCE_TYPE_NAME() *string

func CfnStream_IsCfnElement 

func CfnStream_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnStream_IsCfnResource 

func CfnStream_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnStream_IsConstruct 

func CfnStream_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func NewCfnStreamConsumer_Override 

func NewCfnStreamConsumer_Override(c CfnStreamConsumer, scope awscdk.Construct, id *string, props *CfnStreamConsumerProps)

Create a new `AWS::Kinesis::StreamConsumer`.

func NewCfnStream_Override 

func NewCfnStream_Override(c CfnStream, scope awscdk.Construct, id *string, props *CfnStreamProps)

Create a new `AWS::Kinesis::Stream`.

func NewStream_Override 

func NewStream_Override(s Stream, scope constructs.Construct, id *string, props *StreamProps)

Experimental.

func Stream_IsConstruct 

func Stream_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func Stream_IsResource 

func Stream_IsResource(construct awscdk.IConstruct) *bool

Check whether the given construct is a Resource. Experimental.

Types

type CfnStream 

type CfnStream interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrArn() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	LogicalId() *string
	Name() *string
	SetName(val *string)
	Node() awscdk.ConstructNode
	Ref() *string
	RetentionPeriodHours() *float64
	SetRetentionPeriodHours(val *float64)
	ShardCount() *float64
	SetShardCount(val *float64)
	Stack() awscdk.Stack
	StreamEncryption() interface{}
	SetStreamEncryption(val interface{})
	Tags() awscdk.TagManager
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	OverrideLogicalId(newLogicalId *string)
	Prepare()
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::Kinesis::Stream`.

func NewCfnStream 

func NewCfnStream(scope awscdk.Construct, id *string, props *CfnStreamProps) CfnStream

Create a new `AWS::Kinesis::Stream`.

type CfnStreamConsumer 

type CfnStreamConsumer interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrConsumerArn() *string
	AttrConsumerCreationTimestamp() *string
	AttrConsumerName() *string
	AttrConsumerStatus() *string
	AttrStreamArn() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	ConsumerName() *string
	SetConsumerName(val *string)
	CreationStack() *[]*string
	LogicalId() *string
	Node() awscdk.ConstructNode
	Ref() *string
	Stack() awscdk.Stack
	StreamArn() *string
	SetStreamArn(val *string)
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	OverrideLogicalId(newLogicalId *string)
	Prepare()
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::Kinesis::StreamConsumer`.

func NewCfnStreamConsumer 

func NewCfnStreamConsumer(scope awscdk.Construct, id *string, props *CfnStreamConsumerProps) CfnStreamConsumer

Create a new `AWS::Kinesis::StreamConsumer`.

type CfnStreamConsumerProps 

type CfnStreamConsumerProps struct {
	// `AWS::Kinesis::StreamConsumer.ConsumerName`.
	ConsumerName *string `json:"consumerName"`
	// `AWS::Kinesis::StreamConsumer.StreamARN`.
	StreamArn *string `json:"streamArn"`
}

Properties for defining a `AWS::Kinesis::StreamConsumer`.

type CfnStreamProps 

type CfnStreamProps struct {
	// `AWS::Kinesis::Stream.ShardCount`.
	ShardCount *float64 `json:"shardCount"`
	// `AWS::Kinesis::Stream.Name`.
	Name *string `json:"name"`
	// `AWS::Kinesis::Stream.RetentionPeriodHours`.
	RetentionPeriodHours *float64 `json:"retentionPeriodHours"`
	// `AWS::Kinesis::Stream.StreamEncryption`.
	StreamEncryption interface{} `json:"streamEncryption"`
	// `AWS::Kinesis::Stream.Tags`.
	Tags *[]*awscdk.CfnTag `json:"tags"`
}

Properties for defining a `AWS::Kinesis::Stream`.

type CfnStream_StreamEncryptionProperty 

type CfnStream_StreamEncryptionProperty struct {
	// `CfnStream.StreamEncryptionProperty.EncryptionType`.
	EncryptionType *string `json:"encryptionType"`
	// `CfnStream.StreamEncryptionProperty.KeyId`.
	KeyId *string `json:"keyId"`
}

type IStream 

type IStream interface {
	awscdk.IResource
	// Grant the indicated permissions on this stream to the provided IAM principal.
	// Experimental.
	Grant(grantee awsiam.IGrantable, actions ...*string) awsiam.Grant
	// Grant read permissions for this stream and its contents to an IAM principal (Role/Group/User).
	//
	// If an encryption key is used, permission to ues the key to decrypt the
	// contents of the stream will also be granted.
	// Experimental.
	GrantRead(grantee awsiam.IGrantable) awsiam.Grant
	// Grants read/write permissions for this stream and its contents to an IAM principal (Role/Group/User).
	//
	// If an encryption key is used, permission to use the key for
	// encrypt/decrypt will also be granted.
	// Experimental.
	GrantReadWrite(grantee awsiam.IGrantable) awsiam.Grant
	// Grant write permissions for this stream and its contents to an IAM principal (Role/Group/User).
	//
	// If an encryption key is used, permission to ues the key to encrypt the
	// contents of the stream will also be granted.
	// Experimental.
	GrantWrite(grantee awsiam.IGrantable) awsiam.Grant
	// Optional KMS encryption key associated with this stream.
	// Experimental.
	EncryptionKey() awskms.IKey
	// The ARN of the stream.
	// Experimental.
	StreamArn() *string
	// The name of the stream.
	// Experimental.
	StreamName() *string
}

A Kinesis Stream. Experimental.

func Stream_FromStreamArn 

func Stream_FromStreamArn(scope constructs.Construct, id *string, streamArn *string) IStream

Import an existing Kinesis Stream provided an ARN. Experimental.

func Stream_FromStreamAttributes 

func Stream_FromStreamAttributes(scope constructs.Construct, id *string, attrs *StreamAttributes) IStream

Creates a Stream construct that represents an external stream. Experimental.

type Stream 

type Stream interface {
	awscdk.Resource
	IStream
	EncryptionKey() awskms.IKey
	Env() *awscdk.ResourceEnvironment
	Node() awscdk.ConstructNode
	PhysicalName() *string
	Stack() awscdk.Stack
	StreamArn() *string
	StreamName() *string
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy)
	GeneratePhysicalName() *string
	GetResourceArnAttribute(arnAttr *string, arnComponents *awscdk.ArnComponents) *string
	GetResourceNameAttribute(nameAttr *string) *string
	Grant(grantee awsiam.IGrantable, actions ...*string) awsiam.Grant
	GrantRead(grantee awsiam.IGrantable) awsiam.Grant
	GrantReadWrite(grantee awsiam.IGrantable) awsiam.Grant
	GrantWrite(grantee awsiam.IGrantable) awsiam.Grant
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	Prepare()
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
}

A Kinesis stream.

Can be encrypted with a KMS key. Experimental.

func NewStream 

func NewStream(scope constructs.Construct, id *string, props *StreamProps) Stream

Experimental.

type StreamAttributes 

type StreamAttributes struct {
	// The ARN of the stream.
	// Experimental.
	StreamArn *string `json:"streamArn"`
	// The KMS key securing the contents of the stream if encryption is enabled.
	// Experimental.
	EncryptionKey awskms.IKey `json:"encryptionKey"`
}

A reference to a stream.

The easiest way to instantiate is to call `stream.export()`. Then, the consumer can use `Stream.import(this, ref)` and get a `Stream`. Experimental.

type StreamEncryption 

type StreamEncryption string

What kind of server-side encryption to apply to this stream. Experimental. 

const (
	StreamEncryption_UNENCRYPTED StreamEncryption = "UNENCRYPTED"
	StreamEncryption_KMS         StreamEncryption = "KMS"
	StreamEncryption_MANAGED     StreamEncryption = "MANAGED"
)

type StreamProps 

type StreamProps struct {
	// The kind of server-side encryption to apply to this stream.
	//
	// If you choose KMS, you can specify a KMS key via `encryptionKey`. If
	// encryption key is not specified, a key will automatically be created.
	// Experimental.
	Encryption StreamEncryption `json:"encryption"`
	// External KMS key to use for stream encryption.
	//
	// The 'encryption' property must be set to "Kms".
	// Experimental.
	EncryptionKey awskms.IKey `json:"encryptionKey"`
	// The number of hours for the data records that are stored in shards to remain accessible.
	// Experimental.
	RetentionPeriod awscdk.Duration `json:"retentionPeriod"`
	// The number of shards for the stream.
	// Experimental.
	ShardCount *float64 `json:"shardCount"`
	// Enforces a particular physical stream name.
	// Experimental.
	StreamName *string `json:"streamName"`
}

Properties for a Kinesis Stream. Experimental.

Source Files

View all Source files

Directories

Path Synopsis

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.