aws_kinesis_analytics_application

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 Args

type Args struct {
	// Code: string, optional
	Code terra.StringValue `hcl:"code,attr"`
	// Description: string, optional
	Description terra.StringValue `hcl:"description,attr"`
	// Id: string, optional
	Id terra.StringValue `hcl:"id,attr"`
	// Name: string, required
	Name terra.StringValue `hcl:"name,attr" validate:"required"`
	// StartApplication: bool, optional
	StartApplication terra.BoolValue `hcl:"start_application,attr"`
	// Tags: map of string, optional
	Tags terra.MapValue[terra.StringValue] `hcl:"tags,attr"`
	// TagsAll: map of string, optional
	TagsAll terra.MapValue[terra.StringValue] `hcl:"tags_all,attr"`
	// CloudwatchLoggingOptions: optional
	CloudwatchLoggingOptions *CloudwatchLoggingOptions `hcl:"cloudwatch_logging_options,block"`
	// Inputs: optional
	Inputs *Inputs `hcl:"inputs,block"`
	// Outputs: min=0,max=3
	Outputs []Outputs `hcl:"outputs,block" validate:"min=0,max=3"`
	// ReferenceDataSources: optional
	ReferenceDataSources *ReferenceDataSources `hcl:"reference_data_sources,block"`
}

Args contains the configurations for aws_kinesis_analytics_application.

type CloudwatchLoggingOptions

type CloudwatchLoggingOptions struct {
	// LogStreamArn: string, required
	LogStreamArn terra.StringValue `hcl:"log_stream_arn,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type CloudwatchLoggingOptionsAttributes

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

func (CloudwatchLoggingOptionsAttributes) Id

func (CloudwatchLoggingOptionsAttributes) InternalRef

func (CloudwatchLoggingOptionsAttributes) InternalTokens

func (clo CloudwatchLoggingOptionsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (CloudwatchLoggingOptionsAttributes) InternalWithRef

func (CloudwatchLoggingOptionsAttributes) LogStreamArn

func (CloudwatchLoggingOptionsAttributes) RoleArn

type CloudwatchLoggingOptionsState

type CloudwatchLoggingOptionsState struct {
	Id           string `json:"id"`
	LogStreamArn string `json:"log_stream_arn"`
	RoleArn      string `json:"role_arn"`
}

type Inputs

type Inputs struct {
	// NamePrefix: string, required
	NamePrefix terra.StringValue `hcl:"name_prefix,attr" validate:"required"`
	// InputsKinesisFirehose: optional
	KinesisFirehose *InputsKinesisFirehose `hcl:"kinesis_firehose,block"`
	// InputsKinesisStream: optional
	KinesisStream *InputsKinesisStream `hcl:"kinesis_stream,block"`
	// InputsParallelism: optional
	Parallelism *InputsParallelism `hcl:"parallelism,block"`
	// InputsProcessingConfiguration: optional
	ProcessingConfiguration *InputsProcessingConfiguration `hcl:"processing_configuration,block"`
	// InputsSchema: required
	Schema *InputsSchema `hcl:"schema,block" validate:"required"`
	// InputsStartingPositionConfiguration: min=0
	StartingPositionConfiguration []InputsStartingPositionConfiguration `hcl:"starting_position_configuration,block" validate:"min=0"`
}

type InputsAttributes

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

func (InputsAttributes) Id

func (InputsAttributes) InternalRef

func (i InputsAttributes) InternalRef() (terra.Reference, error)

func (InputsAttributes) InternalTokens

func (i InputsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsAttributes) InternalWithRef

func (i InputsAttributes) InternalWithRef(ref terra.Reference) InputsAttributes

func (InputsAttributes) KinesisFirehose

func (InputsAttributes) KinesisStream

func (InputsAttributes) NamePrefix

func (i InputsAttributes) NamePrefix() terra.StringValue

func (InputsAttributes) Parallelism

func (InputsAttributes) ProcessingConfiguration

func (InputsAttributes) Schema

func (InputsAttributes) StartingPositionConfiguration

func (InputsAttributes) StreamNames

type InputsKinesisFirehose

type InputsKinesisFirehose struct {
	// ResourceArn: string, required
	ResourceArn terra.StringValue `hcl:"resource_arn,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type InputsKinesisFirehoseAttributes

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

func (InputsKinesisFirehoseAttributes) InternalRef

func (InputsKinesisFirehoseAttributes) InternalTokens

func (kf InputsKinesisFirehoseAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsKinesisFirehoseAttributes) InternalWithRef

func (InputsKinesisFirehoseAttributes) ResourceArn

func (InputsKinesisFirehoseAttributes) RoleArn

type InputsKinesisFirehoseState

type InputsKinesisFirehoseState struct {
	ResourceArn string `json:"resource_arn"`
	RoleArn     string `json:"role_arn"`
}

type InputsKinesisStream

type InputsKinesisStream struct {
	// ResourceArn: string, required
	ResourceArn terra.StringValue `hcl:"resource_arn,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type InputsKinesisStreamAttributes

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

func (InputsKinesisStreamAttributes) InternalRef

func (ks InputsKinesisStreamAttributes) InternalRef() (terra.Reference, error)

func (InputsKinesisStreamAttributes) InternalTokens

func (ks InputsKinesisStreamAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsKinesisStreamAttributes) InternalWithRef

func (InputsKinesisStreamAttributes) ResourceArn

func (InputsKinesisStreamAttributes) RoleArn

type InputsKinesisStreamState

type InputsKinesisStreamState struct {
	ResourceArn string `json:"resource_arn"`
	RoleArn     string `json:"role_arn"`
}

type InputsParallelism

type InputsParallelism struct {
	// Count: number, optional
	Count terra.NumberValue `hcl:"count,attr"`
}

type InputsParallelismAttributes

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

func (InputsParallelismAttributes) Count

func (InputsParallelismAttributes) InternalRef

func (p InputsParallelismAttributes) InternalRef() (terra.Reference, error)

func (InputsParallelismAttributes) InternalTokens

func (p InputsParallelismAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsParallelismAttributes) InternalWithRef

type InputsParallelismState

type InputsParallelismState struct {
	Count float64 `json:"count"`
}

type InputsProcessingConfiguration

type InputsProcessingConfiguration struct {
	// InputsProcessingConfigurationLambda: required
	Lambda *InputsProcessingConfigurationLambda `hcl:"lambda,block" validate:"required"`
}

type InputsProcessingConfigurationAttributes

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

func (InputsProcessingConfigurationAttributes) InternalRef

func (InputsProcessingConfigurationAttributes) InternalTokens

func (InputsProcessingConfigurationAttributes) InternalWithRef

func (InputsProcessingConfigurationAttributes) Lambda

type InputsProcessingConfigurationLambda

type InputsProcessingConfigurationLambda struct {
	// ResourceArn: string, required
	ResourceArn terra.StringValue `hcl:"resource_arn,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type InputsProcessingConfigurationLambdaAttributes

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

func (InputsProcessingConfigurationLambdaAttributes) InternalRef

func (InputsProcessingConfigurationLambdaAttributes) InternalTokens

func (InputsProcessingConfigurationLambdaAttributes) InternalWithRef

func (InputsProcessingConfigurationLambdaAttributes) ResourceArn

func (InputsProcessingConfigurationLambdaAttributes) RoleArn

type InputsProcessingConfigurationLambdaState

type InputsProcessingConfigurationLambdaState struct {
	ResourceArn string `json:"resource_arn"`
	RoleArn     string `json:"role_arn"`
}

type InputsProcessingConfigurationState

type InputsProcessingConfigurationState struct {
	Lambda []InputsProcessingConfigurationLambdaState `json:"lambda"`
}

type InputsSchema

type InputsSchema struct {
	// RecordEncoding: string, optional
	RecordEncoding terra.StringValue `hcl:"record_encoding,attr"`
	// InputsSchemaRecordColumns: min=1,max=1000
	RecordColumns []InputsSchemaRecordColumns `hcl:"record_columns,block" validate:"min=1,max=1000"`
	// InputsSchemaRecordFormat: required
	RecordFormat *InputsSchemaRecordFormat `hcl:"record_format,block" validate:"required"`
}

type InputsSchemaAa59C058

type InputsSchemaAa59C058 struct {
	// RecordColumnDelimiter: string, required
	RecordColumnDelimiter terra.StringValue `hcl:"record_column_delimiter,attr" validate:"required"`
	// RecordRowDelimiter: string, required
	RecordRowDelimiter terra.StringValue `hcl:"record_row_delimiter,attr" validate:"required"`
}

type InputsSchemaAa59C058Attributes

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

func (InputsSchemaAa59C058Attributes) InternalRef

func (InputsSchemaAa59C058Attributes) InternalTokens

func (c InputsSchemaAa59C058Attributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsSchemaAa59C058Attributes) InternalWithRef

func (InputsSchemaAa59C058Attributes) RecordColumnDelimiter

func (c InputsSchemaAa59C058Attributes) RecordColumnDelimiter() terra.StringValue

func (InputsSchemaAa59C058Attributes) RecordRowDelimiter

func (c InputsSchemaAa59C058Attributes) RecordRowDelimiter() terra.StringValue

type InputsSchemaAa59C058State

type InputsSchemaAa59C058State struct {
	RecordColumnDelimiter string `json:"record_column_delimiter"`
	RecordRowDelimiter    string `json:"record_row_delimiter"`
}

type InputsSchemaAttributes

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

func (InputsSchemaAttributes) InternalRef

func (s InputsSchemaAttributes) InternalRef() (terra.Reference, error)

func (InputsSchemaAttributes) InternalTokens

func (s InputsSchemaAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsSchemaAttributes) InternalWithRef

func (InputsSchemaAttributes) RecordColumns

func (InputsSchemaAttributes) RecordEncoding

func (s InputsSchemaAttributes) RecordEncoding() terra.StringValue

func (InputsSchemaAttributes) RecordFormat

type InputsSchemaFd3Ac257

type InputsSchemaFd3Ac257 struct {
	// RecordRowPath: string, required
	RecordRowPath terra.StringValue `hcl:"record_row_path,attr" validate:"required"`
}

type InputsSchemaFd3Ac257Attributes

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

func (InputsSchemaFd3Ac257Attributes) InternalRef

func (InputsSchemaFd3Ac257Attributes) InternalTokens

func (j InputsSchemaFd3Ac257Attributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsSchemaFd3Ac257Attributes) InternalWithRef

func (InputsSchemaFd3Ac257Attributes) RecordRowPath

type InputsSchemaFd3Ac257State

type InputsSchemaFd3Ac257State struct {
	RecordRowPath string `json:"record_row_path"`
}

type InputsSchemaRecordColumns

type InputsSchemaRecordColumns struct {
	// Mapping: string, optional
	Mapping terra.StringValue `hcl:"mapping,attr"`
	// Name: string, required
	Name terra.StringValue `hcl:"name,attr" validate:"required"`
	// SqlType: string, required
	SqlType terra.StringValue `hcl:"sql_type,attr" validate:"required"`
}

type InputsSchemaRecordColumnsAttributes

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

func (InputsSchemaRecordColumnsAttributes) InternalRef

func (InputsSchemaRecordColumnsAttributes) InternalTokens

func (InputsSchemaRecordColumnsAttributes) InternalWithRef

func (InputsSchemaRecordColumnsAttributes) Mapping

func (InputsSchemaRecordColumnsAttributes) Name

func (InputsSchemaRecordColumnsAttributes) SqlType

type InputsSchemaRecordColumnsState

type InputsSchemaRecordColumnsState struct {
	Mapping string `json:"mapping"`
	Name    string `json:"name"`
	SqlType string `json:"sql_type"`
}

type InputsSchemaRecordFormat

type InputsSchemaRecordFormat struct {
	// InputsSchemaRecordFormatMappingParameters: optional
	MappingParameters *InputsSchemaRecordFormatMappingParameters `hcl:"mapping_parameters,block"`
}

type InputsSchemaRecordFormatAttributes

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

func (InputsSchemaRecordFormatAttributes) InternalRef

func (InputsSchemaRecordFormatAttributes) InternalTokens

func (InputsSchemaRecordFormatAttributes) InternalWithRef

func (InputsSchemaRecordFormatAttributes) MappingParameters

func (InputsSchemaRecordFormatAttributes) RecordFormatType

type InputsSchemaRecordFormatMappingParameters

type InputsSchemaRecordFormatMappingParameters struct {
	// InputsSchemaAa59C058: optional
	Csv *InputsSchemaAa59C058 `hcl:"csv,block"`
	// InputsSchemaFd3Ac257: optional
	Json *InputsSchemaFd3Ac257 `hcl:"json,block"`
}

type InputsSchemaRecordFormatMappingParametersAttributes

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

func (InputsSchemaRecordFormatMappingParametersAttributes) Csv

func (InputsSchemaRecordFormatMappingParametersAttributes) InternalRef

func (InputsSchemaRecordFormatMappingParametersAttributes) InternalTokens

func (InputsSchemaRecordFormatMappingParametersAttributes) InternalWithRef

func (InputsSchemaRecordFormatMappingParametersAttributes) Json

type InputsSchemaRecordFormatMappingParametersState

type InputsSchemaRecordFormatMappingParametersState struct {
	Csv  []InputsSchemaAa59C058State `json:"csv"`
	Json []InputsSchemaFd3Ac257State `json:"json"`
}

type InputsSchemaRecordFormatState

type InputsSchemaRecordFormatState struct {
	RecordFormatType  string                                           `json:"record_format_type"`
	MappingParameters []InputsSchemaRecordFormatMappingParametersState `json:"mapping_parameters"`
}

type InputsSchemaState

type InputsSchemaState struct {
	RecordEncoding string                           `json:"record_encoding"`
	RecordColumns  []InputsSchemaRecordColumnsState `json:"record_columns"`
	RecordFormat   []InputsSchemaRecordFormatState  `json:"record_format"`
}

type InputsStartingPositionConfiguration

type InputsStartingPositionConfiguration struct {
	// StartingPosition: string, optional
	StartingPosition terra.StringValue `hcl:"starting_position,attr"`
}

type InputsStartingPositionConfigurationAttributes

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

func (InputsStartingPositionConfigurationAttributes) InternalRef

func (InputsStartingPositionConfigurationAttributes) InternalTokens

func (InputsStartingPositionConfigurationAttributes) InternalWithRef

func (InputsStartingPositionConfigurationAttributes) StartingPosition

type InputsStartingPositionConfigurationState

type InputsStartingPositionConfigurationState struct {
	StartingPosition string `json:"starting_position"`
}

type InputsState

type InputsState struct {
	Id                            string                                     `json:"id"`
	NamePrefix                    string                                     `json:"name_prefix"`
	StreamNames                   []string                                   `json:"stream_names"`
	KinesisFirehose               []InputsKinesisFirehoseState               `json:"kinesis_firehose"`
	KinesisStream                 []InputsKinesisStreamState                 `json:"kinesis_stream"`
	Parallelism                   []InputsParallelismState                   `json:"parallelism"`
	ProcessingConfiguration       []InputsProcessingConfigurationState       `json:"processing_configuration"`
	Schema                        []InputsSchemaState                        `json:"schema"`
	StartingPositionConfiguration []InputsStartingPositionConfigurationState `json:"starting_position_configuration"`
}

type Outputs

type Outputs struct {
	// Name: string, required
	Name terra.StringValue `hcl:"name,attr" validate:"required"`
	// OutputsKinesisFirehose: optional
	KinesisFirehose *OutputsKinesisFirehose `hcl:"kinesis_firehose,block"`
	// OutputsKinesisStream: optional
	KinesisStream *OutputsKinesisStream `hcl:"kinesis_stream,block"`
	// OutputsLambda: optional
	Lambda *OutputsLambda `hcl:"lambda,block"`
	// OutputsSchema: required
	Schema *OutputsSchema `hcl:"schema,block" validate:"required"`
}

type OutputsAttributes

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

func (OutputsAttributes) Id

func (OutputsAttributes) InternalRef

func (o OutputsAttributes) InternalRef() (terra.Reference, error)

func (OutputsAttributes) InternalTokens

func (o OutputsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (OutputsAttributes) InternalWithRef

func (o OutputsAttributes) InternalWithRef(ref terra.Reference) OutputsAttributes

func (OutputsAttributes) KinesisFirehose

func (OutputsAttributes) KinesisStream

func (OutputsAttributes) Lambda

func (OutputsAttributes) Name

func (OutputsAttributes) Schema

type OutputsKinesisFirehose

type OutputsKinesisFirehose struct {
	// ResourceArn: string, required
	ResourceArn terra.StringValue `hcl:"resource_arn,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type OutputsKinesisFirehoseAttributes

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

func (OutputsKinesisFirehoseAttributes) InternalRef

func (OutputsKinesisFirehoseAttributes) InternalTokens

func (kf OutputsKinesisFirehoseAttributes) InternalTokens() (hclwrite.Tokens, error)

func (OutputsKinesisFirehoseAttributes) InternalWithRef

func (OutputsKinesisFirehoseAttributes) ResourceArn

func (OutputsKinesisFirehoseAttributes) RoleArn

type OutputsKinesisFirehoseState

type OutputsKinesisFirehoseState struct {
	ResourceArn string `json:"resource_arn"`
	RoleArn     string `json:"role_arn"`
}

type OutputsKinesisStream

type OutputsKinesisStream struct {
	// ResourceArn: string, required
	ResourceArn terra.StringValue `hcl:"resource_arn,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type OutputsKinesisStreamAttributes

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

func (OutputsKinesisStreamAttributes) InternalRef

func (OutputsKinesisStreamAttributes) InternalTokens

func (ks OutputsKinesisStreamAttributes) InternalTokens() (hclwrite.Tokens, error)

func (OutputsKinesisStreamAttributes) InternalWithRef

func (OutputsKinesisStreamAttributes) ResourceArn

func (OutputsKinesisStreamAttributes) RoleArn

type OutputsKinesisStreamState

type OutputsKinesisStreamState struct {
	ResourceArn string `json:"resource_arn"`
	RoleArn     string `json:"role_arn"`
}

type OutputsLambda

type OutputsLambda struct {
	// ResourceArn: string, required
	ResourceArn terra.StringValue `hcl:"resource_arn,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type OutputsLambdaAttributes

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

func (OutputsLambdaAttributes) InternalRef

func (l OutputsLambdaAttributes) InternalRef() (terra.Reference, error)

func (OutputsLambdaAttributes) InternalTokens

func (l OutputsLambdaAttributes) InternalTokens() (hclwrite.Tokens, error)

func (OutputsLambdaAttributes) InternalWithRef

func (OutputsLambdaAttributes) ResourceArn

func (l OutputsLambdaAttributes) ResourceArn() terra.StringValue

func (OutputsLambdaAttributes) RoleArn

type OutputsLambdaState

type OutputsLambdaState struct {
	ResourceArn string `json:"resource_arn"`
	RoleArn     string `json:"role_arn"`
}

type OutputsSchema

type OutputsSchema struct {
	// RecordFormatType: string, required
	RecordFormatType terra.StringValue `hcl:"record_format_type,attr" validate:"required"`
}

type OutputsSchemaAttributes

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

func (OutputsSchemaAttributes) InternalRef

func (s OutputsSchemaAttributes) InternalRef() (terra.Reference, error)

func (OutputsSchemaAttributes) InternalTokens

func (s OutputsSchemaAttributes) InternalTokens() (hclwrite.Tokens, error)

func (OutputsSchemaAttributes) InternalWithRef

func (OutputsSchemaAttributes) RecordFormatType

func (s OutputsSchemaAttributes) RecordFormatType() terra.StringValue

type OutputsSchemaState

type OutputsSchemaState struct {
	RecordFormatType string `json:"record_format_type"`
}

type OutputsState

type OutputsState struct {
	Id              string                        `json:"id"`
	Name            string                        `json:"name"`
	KinesisFirehose []OutputsKinesisFirehoseState `json:"kinesis_firehose"`
	KinesisStream   []OutputsKinesisStreamState   `json:"kinesis_stream"`
	Lambda          []OutputsLambdaState          `json:"lambda"`
	Schema          []OutputsSchemaState          `json:"schema"`
}

type ReferenceDataSources

type ReferenceDataSources struct {
	// TableName: string, required
	TableName terra.StringValue `hcl:"table_name,attr" validate:"required"`
	// ReferenceDataSourcesS3: required
	S3 *ReferenceDataSourcesS3 `hcl:"s3,block" validate:"required"`
	// ReferenceDataSourcesSchema: required
	Schema *ReferenceDataSourcesSchema `hcl:"schema,block" validate:"required"`
}

type ReferenceDataSourcesAttributes

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

func (ReferenceDataSourcesAttributes) Id

func (ReferenceDataSourcesAttributes) InternalRef

func (rds ReferenceDataSourcesAttributes) InternalRef() (terra.Reference, error)

func (ReferenceDataSourcesAttributes) InternalTokens

func (rds ReferenceDataSourcesAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ReferenceDataSourcesAttributes) InternalWithRef

func (ReferenceDataSourcesAttributes) S3

func (ReferenceDataSourcesAttributes) Schema

func (ReferenceDataSourcesAttributes) TableName

type ReferenceDataSourcesS3

type ReferenceDataSourcesS3 struct {
	// BucketArn: string, required
	BucketArn terra.StringValue `hcl:"bucket_arn,attr" validate:"required"`
	// FileKey: string, required
	FileKey terra.StringValue `hcl:"file_key,attr" validate:"required"`
	// RoleArn: string, required
	RoleArn terra.StringValue `hcl:"role_arn,attr" validate:"required"`
}

type ReferenceDataSourcesS3Attributes

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

func (ReferenceDataSourcesS3Attributes) BucketArn

func (ReferenceDataSourcesS3Attributes) FileKey

func (ReferenceDataSourcesS3Attributes) InternalRef

func (ReferenceDataSourcesS3Attributes) InternalTokens

func (s ReferenceDataSourcesS3Attributes) InternalTokens() (hclwrite.Tokens, error)

func (ReferenceDataSourcesS3Attributes) InternalWithRef

func (ReferenceDataSourcesS3Attributes) RoleArn

type ReferenceDataSourcesS3State

type ReferenceDataSourcesS3State struct {
	BucketArn string `json:"bucket_arn"`
	FileKey   string `json:"file_key"`
	RoleArn   string `json:"role_arn"`
}

type ReferenceDataSourcesSchema

type ReferenceDataSourcesSchema struct {
	// RecordEncoding: string, optional
	RecordEncoding terra.StringValue `hcl:"record_encoding,attr"`
	// ReferenceDataSourcesSchemaRecordColumns: min=1,max=1000
	RecordColumns []ReferenceDataSourcesSchemaRecordColumns `hcl:"record_columns,block" validate:"min=1,max=1000"`
	// ReferenceDataSourcesSchemaRecordFormat: required
	RecordFormat *ReferenceDataSourcesSchemaRecordFormat `hcl:"record_format,block" validate:"required"`
}

type ReferenceDataSourcesSchemaAa59C058

type ReferenceDataSourcesSchemaAa59C058 struct {
	// RecordColumnDelimiter: string, required
	RecordColumnDelimiter terra.StringValue `hcl:"record_column_delimiter,attr" validate:"required"`
	// RecordRowDelimiter: string, required
	RecordRowDelimiter terra.StringValue `hcl:"record_row_delimiter,attr" validate:"required"`
}

type ReferenceDataSourcesSchemaAa59C058Attributes

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

func (ReferenceDataSourcesSchemaAa59C058Attributes) InternalRef

func (ReferenceDataSourcesSchemaAa59C058Attributes) InternalTokens

func (ReferenceDataSourcesSchemaAa59C058Attributes) InternalWithRef

func (ReferenceDataSourcesSchemaAa59C058Attributes) RecordColumnDelimiter

func (ReferenceDataSourcesSchemaAa59C058Attributes) RecordRowDelimiter

type ReferenceDataSourcesSchemaAa59C058State

type ReferenceDataSourcesSchemaAa59C058State struct {
	RecordColumnDelimiter string `json:"record_column_delimiter"`
	RecordRowDelimiter    string `json:"record_row_delimiter"`
}

type ReferenceDataSourcesSchemaAttributes

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

func (ReferenceDataSourcesSchemaAttributes) InternalRef

func (ReferenceDataSourcesSchemaAttributes) InternalTokens

func (ReferenceDataSourcesSchemaAttributes) InternalWithRef

func (ReferenceDataSourcesSchemaAttributes) RecordColumns

func (ReferenceDataSourcesSchemaAttributes) RecordEncoding

func (ReferenceDataSourcesSchemaAttributes) RecordFormat

type ReferenceDataSourcesSchemaFd3Ac257

type ReferenceDataSourcesSchemaFd3Ac257 struct {
	// RecordRowPath: string, required
	RecordRowPath terra.StringValue `hcl:"record_row_path,attr" validate:"required"`
}

type ReferenceDataSourcesSchemaFd3Ac257Attributes

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

func (ReferenceDataSourcesSchemaFd3Ac257Attributes) InternalRef

func (ReferenceDataSourcesSchemaFd3Ac257Attributes) InternalTokens

func (ReferenceDataSourcesSchemaFd3Ac257Attributes) InternalWithRef

func (ReferenceDataSourcesSchemaFd3Ac257Attributes) RecordRowPath

type ReferenceDataSourcesSchemaFd3Ac257State

type ReferenceDataSourcesSchemaFd3Ac257State struct {
	RecordRowPath string `json:"record_row_path"`
}

type ReferenceDataSourcesSchemaRecordColumns

type ReferenceDataSourcesSchemaRecordColumns struct {
	// Mapping: string, optional
	Mapping terra.StringValue `hcl:"mapping,attr"`
	// Name: string, required
	Name terra.StringValue `hcl:"name,attr" validate:"required"`
	// SqlType: string, required
	SqlType terra.StringValue `hcl:"sql_type,attr" validate:"required"`
}

type ReferenceDataSourcesSchemaRecordColumnsAttributes

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

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalRef

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalTokens

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalWithRef

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) Mapping

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) Name

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) SqlType

type ReferenceDataSourcesSchemaRecordColumnsState

type ReferenceDataSourcesSchemaRecordColumnsState struct {
	Mapping string `json:"mapping"`
	Name    string `json:"name"`
	SqlType string `json:"sql_type"`
}

type ReferenceDataSourcesSchemaRecordFormat

type ReferenceDataSourcesSchemaRecordFormat struct {
	// ReferenceDataSourcesSchemaRecordFormatMappingParameters: optional
	MappingParameters *ReferenceDataSourcesSchemaRecordFormatMappingParameters `hcl:"mapping_parameters,block"`
}

type ReferenceDataSourcesSchemaRecordFormatAttributes

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

func (ReferenceDataSourcesSchemaRecordFormatAttributes) InternalRef

func (ReferenceDataSourcesSchemaRecordFormatAttributes) InternalTokens

func (ReferenceDataSourcesSchemaRecordFormatAttributes) InternalWithRef

func (ReferenceDataSourcesSchemaRecordFormatAttributes) RecordFormatType

type ReferenceDataSourcesSchemaRecordFormatMappingParameters

type ReferenceDataSourcesSchemaRecordFormatMappingParameters struct {
	// ReferenceDataSourcesSchemaAa59C058: optional
	Csv *ReferenceDataSourcesSchemaAa59C058 `hcl:"csv,block"`
	// ReferenceDataSourcesSchemaFd3Ac257: optional
	Json *ReferenceDataSourcesSchemaFd3Ac257 `hcl:"json,block"`
}

type ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes

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

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) Csv

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalRef

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalTokens

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalWithRef

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) Json

type ReferenceDataSourcesSchemaRecordFormatMappingParametersState

type ReferenceDataSourcesSchemaRecordFormatMappingParametersState struct {
	Csv  []ReferenceDataSourcesSchemaAa59C058State `json:"csv"`
	Json []ReferenceDataSourcesSchemaFd3Ac257State `json:"json"`
}

type ReferenceDataSourcesSchemaRecordFormatState

type ReferenceDataSourcesSchemaRecordFormatState struct {
	RecordFormatType  string                                                         `json:"record_format_type"`
	MappingParameters []ReferenceDataSourcesSchemaRecordFormatMappingParametersState `json:"mapping_parameters"`
}

type ReferenceDataSourcesSchemaState

type ReferenceDataSourcesSchemaState struct {
	RecordEncoding string                                         `json:"record_encoding"`
	RecordColumns  []ReferenceDataSourcesSchemaRecordColumnsState `json:"record_columns"`
	RecordFormat   []ReferenceDataSourcesSchemaRecordFormatState  `json:"record_format"`
}

type ReferenceDataSourcesState

type ReferenceDataSourcesState struct {
	Id        string                            `json:"id"`
	TableName string                            `json:"table_name"`
	S3        []ReferenceDataSourcesS3State     `json:"s3"`
	Schema    []ReferenceDataSourcesSchemaState `json:"schema"`
}

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_kinesis_analytics_application.

func New

func New(name string, args Args) *Resource

New creates a new instance of Resource.

func (*Resource) Attributes

func (akaa *Resource) Attributes() awsKinesisAnalyticsApplicationAttributes

Attributes returns the attributes for Resource.

func (*Resource) Configuration

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

Configuration returns the configuration (args) for Resource.

func (*Resource) DependOn

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

DependOn is used for other resources to depend on Resource.

func (*Resource) Dependencies

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

Dependencies returns the list of resources Resource depends_on.

func (*Resource) ImportState

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

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

func (*Resource) LifecycleManagement

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

LifecycleManagement returns the lifecycle block for Resource.

func (*Resource) LocalName

func (akaa *Resource) LocalName() string

LocalName returns the local name for Resource.

func (*Resource) State

func (akaa *Resource) State() (*awsKinesisAnalyticsApplicationState, bool)

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

func (*Resource) StateMust

func (akaa *Resource) StateMust() *awsKinesisAnalyticsApplicationState

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

func (*Resource) Type

func (akaa *Resource) Type() string

Type returns the Terraform object type for Resource.

Jump to

Keyboard shortcuts

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