aws_lambda_event_source_mapping

package
v0.0.0-...-4deecce Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AmazonManagedKafkaEventSourceConfig 

type AmazonManagedKafkaEventSourceConfig struct {
	// ConsumerGroupId: string, optional
	ConsumerGroupId terra.StringValue `hcl:"consumer_group_id,attr"`
}

type AmazonManagedKafkaEventSourceConfigAttributes 

type AmazonManagedKafkaEventSourceConfigAttributes struct {
	// contains filtered or unexported fields
}

func (AmazonManagedKafkaEventSourceConfigAttributes) ConsumerGroupId 

func (amkesc AmazonManagedKafkaEventSourceConfigAttributes) ConsumerGroupId() terra.StringValue

func (AmazonManagedKafkaEventSourceConfigAttributes) InternalRef 

func (amkesc AmazonManagedKafkaEventSourceConfigAttributes) InternalRef() (terra.Reference, error)

func (AmazonManagedKafkaEventSourceConfigAttributes) InternalTokens 

func (amkesc AmazonManagedKafkaEventSourceConfigAttributes) InternalTokens() (hclwrite.Tokens, error)

func (AmazonManagedKafkaEventSourceConfigAttributes) InternalWithRef 

func (amkesc AmazonManagedKafkaEventSourceConfigAttributes) InternalWithRef(ref terra.Reference) AmazonManagedKafkaEventSourceConfigAttributes

type AmazonManagedKafkaEventSourceConfigState 

type AmazonManagedKafkaEventSourceConfigState struct {
	ConsumerGroupId string `json:"consumer_group_id"`
}

type Args 

type Args struct {
	// BatchSize: number, optional
	BatchSize terra.NumberValue `hcl:"batch_size,attr"`
	// BisectBatchOnFunctionError: bool, optional
	BisectBatchOnFunctionError terra.BoolValue `hcl:"bisect_batch_on_function_error,attr"`
	// Enabled: bool, optional
	Enabled terra.BoolValue `hcl:"enabled,attr"`
	// EventSourceArn: string, optional
	EventSourceArn terra.StringValue `hcl:"event_source_arn,attr"`
	// FunctionName: string, required
	FunctionName terra.StringValue `hcl:"function_name,attr" validate:"required"`
	// FunctionResponseTypes: set of string, optional
	FunctionResponseTypes terra.SetValue[terra.StringValue] `hcl:"function_response_types,attr"`
	// Id: string, optional
	Id terra.StringValue `hcl:"id,attr"`
	// MaximumBatchingWindowInSeconds: number, optional
	MaximumBatchingWindowInSeconds terra.NumberValue `hcl:"maximum_batching_window_in_seconds,attr"`
	// MaximumRecordAgeInSeconds: number, optional
	MaximumRecordAgeInSeconds terra.NumberValue `hcl:"maximum_record_age_in_seconds,attr"`
	// MaximumRetryAttempts: number, optional
	MaximumRetryAttempts terra.NumberValue `hcl:"maximum_retry_attempts,attr"`
	// ParallelizationFactor: number, optional
	ParallelizationFactor terra.NumberValue `hcl:"parallelization_factor,attr"`
	// Queues: list of string, optional
	Queues terra.ListValue[terra.StringValue] `hcl:"queues,attr"`
	// StartingPosition: string, optional
	StartingPosition terra.StringValue `hcl:"starting_position,attr"`
	// StartingPositionTimestamp: string, optional
	StartingPositionTimestamp terra.StringValue `hcl:"starting_position_timestamp,attr"`
	// Topics: set of string, optional
	Topics terra.SetValue[terra.StringValue] `hcl:"topics,attr"`
	// TumblingWindowInSeconds: number, optional
	TumblingWindowInSeconds terra.NumberValue `hcl:"tumbling_window_in_seconds,attr"`
	// AmazonManagedKafkaEventSourceConfig: optional
	AmazonManagedKafkaEventSourceConfig *AmazonManagedKafkaEventSourceConfig `hcl:"amazon_managed_kafka_event_source_config,block"`
	// DestinationConfig: optional
	DestinationConfig *DestinationConfig `hcl:"destination_config,block"`
	// DocumentDbEventSourceConfig: optional
	DocumentDbEventSourceConfig *DocumentDbEventSourceConfig `hcl:"document_db_event_source_config,block"`
	// FilterCriteria: optional
	FilterCriteria *FilterCriteria `hcl:"filter_criteria,block"`
	// ScalingConfig: optional
	ScalingConfig *ScalingConfig `hcl:"scaling_config,block"`
	// SelfManagedEventSource: optional
	SelfManagedEventSource *SelfManagedEventSource `hcl:"self_managed_event_source,block"`
	// SelfManagedKafkaEventSourceConfig: optional
	SelfManagedKafkaEventSourceConfig *SelfManagedKafkaEventSourceConfig `hcl:"self_managed_kafka_event_source_config,block"`
	// SourceAccessConfiguration: min=0,max=22
	SourceAccessConfiguration []SourceAccessConfiguration `hcl:"source_access_configuration,block" validate:"min=0,max=22"`
}

Args contains the configurations for aws_lambda_event_source_mapping.

type DestinationConfig 

type DestinationConfig struct {
	// DestinationConfigOnFailure: optional
	OnFailure *DestinationConfigOnFailure `hcl:"on_failure,block"`
}

type DestinationConfigAttributes 

type DestinationConfigAttributes struct {
	// contains filtered or unexported fields
}

func (DestinationConfigAttributes) InternalRef 

func (dc DestinationConfigAttributes) InternalRef() (terra.Reference, error)

func (DestinationConfigAttributes) InternalTokens 

func (dc DestinationConfigAttributes) InternalTokens() (hclwrite.Tokens, error)

func (DestinationConfigAttributes) InternalWithRef 

func (dc DestinationConfigAttributes) InternalWithRef(ref terra.Reference) DestinationConfigAttributes

func (DestinationConfigAttributes) OnFailure 

func (dc DestinationConfigAttributes) OnFailure() terra.ListValue[DestinationConfigOnFailureAttributes]

type DestinationConfigOnFailure 

type DestinationConfigOnFailure struct {
	// DestinationArn: string, required
	DestinationArn terra.StringValue `hcl:"destination_arn,attr" validate:"required"`
}

type DestinationConfigOnFailureAttributes 

type DestinationConfigOnFailureAttributes struct {
	// contains filtered or unexported fields
}

func (DestinationConfigOnFailureAttributes) DestinationArn 

func (of DestinationConfigOnFailureAttributes) DestinationArn() terra.StringValue

func (DestinationConfigOnFailureAttributes) InternalRef 

func (of DestinationConfigOnFailureAttributes) InternalRef() (terra.Reference, error)

func (DestinationConfigOnFailureAttributes) InternalTokens 

func (of DestinationConfigOnFailureAttributes) InternalTokens() (hclwrite.Tokens, error)

func (DestinationConfigOnFailureAttributes) InternalWithRef 

func (of DestinationConfigOnFailureAttributes) InternalWithRef(ref terra.Reference) DestinationConfigOnFailureAttributes

type DestinationConfigOnFailureState 

type DestinationConfigOnFailureState struct {
	DestinationArn string `json:"destination_arn"`
}

type DestinationConfigState 

type DestinationConfigState struct {
	OnFailure []DestinationConfigOnFailureState `json:"on_failure"`
}

type DocumentDbEventSourceConfig 

type DocumentDbEventSourceConfig struct {
	// CollectionName: string, optional
	CollectionName terra.StringValue `hcl:"collection_name,attr"`
	// DatabaseName: string, required
	DatabaseName terra.StringValue `hcl:"database_name,attr" validate:"required"`
	// FullDocument: string, optional
	FullDocument terra.StringValue `hcl:"full_document,attr"`
}

type DocumentDbEventSourceConfigAttributes 

type DocumentDbEventSourceConfigAttributes struct {
	// contains filtered or unexported fields
}

func (DocumentDbEventSourceConfigAttributes) CollectionName 

func (ddesc DocumentDbEventSourceConfigAttributes) CollectionName() terra.StringValue

func (DocumentDbEventSourceConfigAttributes) DatabaseName 

func (ddesc DocumentDbEventSourceConfigAttributes) DatabaseName() terra.StringValue

func (DocumentDbEventSourceConfigAttributes) FullDocument 

func (ddesc DocumentDbEventSourceConfigAttributes) FullDocument() terra.StringValue

func (DocumentDbEventSourceConfigAttributes) InternalRef 

func (ddesc DocumentDbEventSourceConfigAttributes) InternalRef() (terra.Reference, error)

func (DocumentDbEventSourceConfigAttributes) InternalTokens 

func (ddesc DocumentDbEventSourceConfigAttributes) InternalTokens() (hclwrite.Tokens, error)

func (DocumentDbEventSourceConfigAttributes) InternalWithRef 

func (ddesc DocumentDbEventSourceConfigAttributes) InternalWithRef(ref terra.Reference) DocumentDbEventSourceConfigAttributes

type DocumentDbEventSourceConfigState 

type DocumentDbEventSourceConfigState struct {
	CollectionName string `json:"collection_name"`
	DatabaseName   string `json:"database_name"`
	FullDocument   string `json:"full_document"`
}

type FilterCriteria 

type FilterCriteria struct {
	// FilterCriteriaFilter: min=0,max=10
	Filter []FilterCriteriaFilter `hcl:"filter,block" validate:"min=0,max=10"`
}

type FilterCriteriaAttributes 

type FilterCriteriaAttributes struct {
	// contains filtered or unexported fields
}

func (FilterCriteriaAttributes) Filter 

func (fc FilterCriteriaAttributes) Filter() terra.SetValue[FilterCriteriaFilterAttributes]

func (FilterCriteriaAttributes) InternalRef 

func (fc FilterCriteriaAttributes) InternalRef() (terra.Reference, error)

func (FilterCriteriaAttributes) InternalTokens 

func (fc FilterCriteriaAttributes) InternalTokens() (hclwrite.Tokens, error)

func (FilterCriteriaAttributes) InternalWithRef 

func (fc FilterCriteriaAttributes) InternalWithRef(ref terra.Reference) FilterCriteriaAttributes

type FilterCriteriaFilter 

type FilterCriteriaFilter struct {
	// Pattern: string, optional
	Pattern terra.StringValue `hcl:"pattern,attr"`
}

type FilterCriteriaFilterAttributes 

type FilterCriteriaFilterAttributes struct {
	// contains filtered or unexported fields
}

func (FilterCriteriaFilterAttributes) InternalRef 

func (f FilterCriteriaFilterAttributes) InternalRef() (terra.Reference, error)

func (FilterCriteriaFilterAttributes) InternalTokens 

func (f FilterCriteriaFilterAttributes) InternalTokens() (hclwrite.Tokens, error)

func (FilterCriteriaFilterAttributes) InternalWithRef 

func (f FilterCriteriaFilterAttributes) InternalWithRef(ref terra.Reference) FilterCriteriaFilterAttributes

func (FilterCriteriaFilterAttributes) Pattern 

func (f FilterCriteriaFilterAttributes) Pattern() terra.StringValue

type FilterCriteriaFilterState 

type FilterCriteriaFilterState struct {
	Pattern string `json:"pattern"`
}

type FilterCriteriaState 

type FilterCriteriaState struct {
	Filter []FilterCriteriaFilterState `json:"filter"`
}

type Resource 

type Resource struct {
	Name string
	Args Args

	DependsOn terra.Dependencies
	Lifecycle *terra.Lifecycle
	// contains filtered or unexported fields
}

Resource represents the Terraform resource aws_lambda_event_source_mapping.

func New 

func New(name string, args Args) *Resource

New creates a new instance of Resource.

func (*Resource) Attributes 

func (alesm *Resource) Attributes() awsLambdaEventSourceMappingAttributes

Attributes returns the attributes for Resource.

func (*Resource) Configuration 

func (alesm *Resource) Configuration() interface{}

Configuration returns the configuration (args) for Resource.

func (*Resource) DependOn 

func (alesm *Resource) DependOn() terra.Reference

DependOn is used for other resources to depend on Resource.

func (*Resource) Dependencies 

func (alesm *Resource) Dependencies() terra.Dependencies

Dependencies returns the list of resources Resource depends_on.

func (*Resource) ImportState 

func (alesm *Resource) ImportState(state io.Reader) error

ImportState imports the given attribute values into Resource's state.

func (*Resource) LifecycleManagement 

func (alesm *Resource) LifecycleManagement() *terra.Lifecycle

LifecycleManagement returns the lifecycle block for Resource.

func (*Resource) LocalName 

func (alesm *Resource) LocalName() string

LocalName returns the local name for Resource.

func (*Resource) State 

func (alesm *Resource) State() (*awsLambdaEventSourceMappingState, bool)

State returns the state and a bool indicating if Resource has state.

func (*Resource) StateMust 

func (alesm *Resource) StateMust() *awsLambdaEventSourceMappingState

StateMust returns the state for Resource. Panics if the state is nil.

func (*Resource) Type 

func (alesm *Resource) Type() string

Type returns the Terraform object type for Resource.

type ScalingConfig 

type ScalingConfig struct {
	// MaximumConcurrency: number, optional
	MaximumConcurrency terra.NumberValue `hcl:"maximum_concurrency,attr"`
}

type ScalingConfigAttributes 

type ScalingConfigAttributes struct {
	// contains filtered or unexported fields
}

func (ScalingConfigAttributes) InternalRef 

func (sc ScalingConfigAttributes) InternalRef() (terra.Reference, error)

func (ScalingConfigAttributes) InternalTokens 

func (sc ScalingConfigAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ScalingConfigAttributes) InternalWithRef 

func (sc ScalingConfigAttributes) InternalWithRef(ref terra.Reference) ScalingConfigAttributes

func (ScalingConfigAttributes) MaximumConcurrency 

func (sc ScalingConfigAttributes) MaximumConcurrency() terra.NumberValue

type ScalingConfigState 

type ScalingConfigState struct {
	MaximumConcurrency float64 `json:"maximum_concurrency"`
}

type SelfManagedEventSource 

type SelfManagedEventSource struct {
	// Endpoints: map of string, required
	Endpoints terra.MapValue[terra.StringValue] `hcl:"endpoints,attr" validate:"required"`
}

type SelfManagedEventSourceAttributes 

type SelfManagedEventSourceAttributes struct {
	// contains filtered or unexported fields
}

func (SelfManagedEventSourceAttributes) Endpoints 

func (smes SelfManagedEventSourceAttributes) Endpoints() terra.MapValue[terra.StringValue]

func (SelfManagedEventSourceAttributes) InternalRef 

func (smes SelfManagedEventSourceAttributes) InternalRef() (terra.Reference, error)

func (SelfManagedEventSourceAttributes) InternalTokens 

func (smes SelfManagedEventSourceAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SelfManagedEventSourceAttributes) InternalWithRef 

func (smes SelfManagedEventSourceAttributes) InternalWithRef(ref terra.Reference) SelfManagedEventSourceAttributes

type SelfManagedEventSourceState 

type SelfManagedEventSourceState struct {
	Endpoints map[string]string `json:"endpoints"`
}

type SelfManagedKafkaEventSourceConfig 

type SelfManagedKafkaEventSourceConfig struct {
	// ConsumerGroupId: string, optional
	ConsumerGroupId terra.StringValue `hcl:"consumer_group_id,attr"`
}

type SelfManagedKafkaEventSourceConfigAttributes 

type SelfManagedKafkaEventSourceConfigAttributes struct {
	// contains filtered or unexported fields
}

func (SelfManagedKafkaEventSourceConfigAttributes) ConsumerGroupId 

func (smkesc SelfManagedKafkaEventSourceConfigAttributes) ConsumerGroupId() terra.StringValue

func (SelfManagedKafkaEventSourceConfigAttributes) InternalRef 

func (smkesc SelfManagedKafkaEventSourceConfigAttributes) InternalRef() (terra.Reference, error)

func (SelfManagedKafkaEventSourceConfigAttributes) InternalTokens 

func (smkesc SelfManagedKafkaEventSourceConfigAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SelfManagedKafkaEventSourceConfigAttributes) InternalWithRef 

func (smkesc SelfManagedKafkaEventSourceConfigAttributes) InternalWithRef(ref terra.Reference) SelfManagedKafkaEventSourceConfigAttributes

type SelfManagedKafkaEventSourceConfigState 

type SelfManagedKafkaEventSourceConfigState struct {
	ConsumerGroupId string `json:"consumer_group_id"`
}

type SourceAccessConfiguration 

type SourceAccessConfiguration struct {
	// Type: string, required
	Type terra.StringValue `hcl:"type,attr" validate:"required"`
	// Uri: string, required
	Uri terra.StringValue `hcl:"uri,attr" validate:"required"`
}

type SourceAccessConfigurationAttributes 

type SourceAccessConfigurationAttributes struct {
	// contains filtered or unexported fields
}

func (SourceAccessConfigurationAttributes) InternalRef 

func (sac SourceAccessConfigurationAttributes) InternalRef() (terra.Reference, error)

func (SourceAccessConfigurationAttributes) InternalTokens 

func (sac SourceAccessConfigurationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SourceAccessConfigurationAttributes) InternalWithRef 

func (sac SourceAccessConfigurationAttributes) InternalWithRef(ref terra.Reference) SourceAccessConfigurationAttributes

func (SourceAccessConfigurationAttributes) Type 

func (sac SourceAccessConfigurationAttributes) Type() terra.StringValue

func (SourceAccessConfigurationAttributes) Uri 

func (sac SourceAccessConfigurationAttributes) Uri() terra.StringValue

type SourceAccessConfigurationState 

type SourceAccessConfigurationState struct {
	Type string `json:"type"`
	Uri  string `json:"uri"`
}

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.