kinesislambda

package

v0.5.0 Latest Latest Go to latest Published: Aug 7, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation ¶

Index ¶

func StreamFunctionLink(iamServiceFactory pluginutils.ServiceFactory[*aws.Config, iamservice.Service]) func(StreamToFunctionLinkDeps) provider.Link
type StreamToFunctionLinkDeps

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func StreamFunctionLink ¶

func StreamFunctionLink(
	iamServiceFactory pluginutils.ServiceFactory[*aws.Config, iamservice.Service],
) func(StreamToFunctionLinkDeps) provider.Link

StreamFunctionLink returns a link implementation for a link from a Kinesis data stream to a Lambda function. This creates an Event Source Mapping that triggers the Lambda function when records are written to the Kinesis stream. It also adds IAM permissions to the Lambda function's execution role to read from the stream.

Types ¶

type StreamToFunctionLinkDeps ¶

type StreamToFunctionLinkDeps pluginutils.LinkServiceDeps[
	*aws.Config,
	cloudcontrolservice.Service,
	*aws.Config,
	lambdaservice.Service,
]

StreamToFunctionLinkDeps is a type alias for the core dependencies for a link from a Kinesis data stream to a Lambda function (stream trigger). The stream is a Cloud Control–backed resource, so resource A's service is the Cloud Control service; the link only reads the stream ARN from state and does not call it.

Source Files ¶

View all Source files

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