kinesisanalyticsapplication

package
v0.0.0-...-964ba77 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 (clo CloudwatchLoggingOptionsAttributes) Id() terra.StringValue

func (CloudwatchLoggingOptionsAttributes) InternalRef 

func (clo CloudwatchLoggingOptionsAttributes) InternalRef() (terra.Reference, error)

func (CloudwatchLoggingOptionsAttributes) InternalTokens 

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

func (CloudwatchLoggingOptionsAttributes) InternalWithRef 

func (clo CloudwatchLoggingOptionsAttributes) InternalWithRef(ref terra.Reference) CloudwatchLoggingOptionsAttributes

func (CloudwatchLoggingOptionsAttributes) LogStreamArn 

func (clo CloudwatchLoggingOptionsAttributes) LogStreamArn() terra.StringValue

func (CloudwatchLoggingOptionsAttributes) RoleArn 

func (clo CloudwatchLoggingOptionsAttributes) RoleArn() terra.StringValue

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"`
	// Parallelism: optional
	Parallelism *Parallelism `hcl:"parallelism,block"`
	// ProcessingConfiguration: optional
	ProcessingConfiguration *ProcessingConfiguration `hcl:"processing_configuration,block"`
	// InputsSchema: required
	Schema *InputsSchema `hcl:"schema,block" validate:"required"`
	// StartingPositionConfiguration: min=0
	StartingPositionConfiguration []StartingPositionConfiguration `hcl:"starting_position_configuration,block" validate:"min=0"`
}

type InputsAttributes 

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

func (InputsAttributes) Id 

func (i InputsAttributes) Id() terra.StringValue

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 (i InputsAttributes) KinesisFirehose() terra.ListValue[InputsKinesisFirehoseAttributes]

func (InputsAttributes) KinesisStream 

func (i InputsAttributes) KinesisStream() terra.ListValue[InputsKinesisStreamAttributes]

func (InputsAttributes) NamePrefix 

func (i InputsAttributes) NamePrefix() terra.StringValue

func (InputsAttributes) Parallelism 

func (i InputsAttributes) Parallelism() terra.ListValue[ParallelismAttributes]

func (InputsAttributes) ProcessingConfiguration 

func (i InputsAttributes) ProcessingConfiguration() terra.ListValue[ProcessingConfigurationAttributes]

func (InputsAttributes) Schema 

func (i InputsAttributes) Schema() terra.ListValue[InputsSchemaAttributes]

func (InputsAttributes) StartingPositionConfiguration 

func (i InputsAttributes) StartingPositionConfiguration() terra.ListValue[StartingPositionConfigurationAttributes]

func (InputsAttributes) StreamNames 

func (i InputsAttributes) StreamNames() terra.ListValue[terra.StringValue]

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 (kf InputsKinesisFirehoseAttributes) InternalRef() (terra.Reference, error)

func (InputsKinesisFirehoseAttributes) InternalTokens 

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

func (InputsKinesisFirehoseAttributes) InternalWithRef 

func (kf InputsKinesisFirehoseAttributes) InternalWithRef(ref terra.Reference) InputsKinesisFirehoseAttributes

func (InputsKinesisFirehoseAttributes) ResourceArn 

func (kf InputsKinesisFirehoseAttributes) ResourceArn() terra.StringValue

func (InputsKinesisFirehoseAttributes) RoleArn 

func (kf InputsKinesisFirehoseAttributes) RoleArn() terra.StringValue

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 (ks InputsKinesisStreamAttributes) InternalWithRef(ref terra.Reference) InputsKinesisStreamAttributes

func (InputsKinesisStreamAttributes) ResourceArn 

func (ks InputsKinesisStreamAttributes) ResourceArn() terra.StringValue

func (InputsKinesisStreamAttributes) RoleArn 

func (ks InputsKinesisStreamAttributes) RoleArn() terra.StringValue

type InputsKinesisStreamState 

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

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 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 (s InputsSchemaAttributes) InternalWithRef(ref terra.Reference) InputsSchemaAttributes

func (InputsSchemaAttributes) RecordColumns 

func (s InputsSchemaAttributes) RecordColumns() terra.ListValue[InputsSchemaRecordColumnsAttributes]

func (InputsSchemaAttributes) RecordEncoding 

func (s InputsSchemaAttributes) RecordEncoding() terra.StringValue

func (InputsSchemaAttributes) RecordFormat 

func (s InputsSchemaAttributes) RecordFormat() terra.ListValue[InputsSchemaRecordFormatAttributes]

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 (rc InputsSchemaRecordColumnsAttributes) InternalRef() (terra.Reference, error)

func (InputsSchemaRecordColumnsAttributes) InternalTokens 

func (rc InputsSchemaRecordColumnsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsSchemaRecordColumnsAttributes) InternalWithRef 

func (rc InputsSchemaRecordColumnsAttributes) InternalWithRef(ref terra.Reference) InputsSchemaRecordColumnsAttributes

func (InputsSchemaRecordColumnsAttributes) Mapping 

func (rc InputsSchemaRecordColumnsAttributes) Mapping() terra.StringValue

func (InputsSchemaRecordColumnsAttributes) Name 

func (rc InputsSchemaRecordColumnsAttributes) Name() terra.StringValue

func (InputsSchemaRecordColumnsAttributes) SqlType 

func (rc InputsSchemaRecordColumnsAttributes) SqlType() terra.StringValue

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 (rf InputsSchemaRecordFormatAttributes) InternalRef() (terra.Reference, error)

func (InputsSchemaRecordFormatAttributes) InternalTokens 

func (rf InputsSchemaRecordFormatAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsSchemaRecordFormatAttributes) InternalWithRef 

func (rf InputsSchemaRecordFormatAttributes) InternalWithRef(ref terra.Reference) InputsSchemaRecordFormatAttributes

func (InputsSchemaRecordFormatAttributes) MappingParameters 

func (rf InputsSchemaRecordFormatAttributes) MappingParameters() terra.ListValue[InputsSchemaRecordFormatMappingParametersAttributes]

func (InputsSchemaRecordFormatAttributes) RecordFormatType 

func (rf InputsSchemaRecordFormatAttributes) RecordFormatType() terra.StringValue

type InputsSchemaRecordFormatMappingParameters 

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

type InputsSchemaRecordFormatMappingParametersAttributes 

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

func (InputsSchemaRecordFormatMappingParametersAttributes) Csv 

func (mp InputsSchemaRecordFormatMappingParametersAttributes) Csv() terra.ListValue[InputsSchemaRecordFormatMappingParametersCsvAttributes]

func (InputsSchemaRecordFormatMappingParametersAttributes) InternalRef 

func (mp InputsSchemaRecordFormatMappingParametersAttributes) InternalRef() (terra.Reference, error)

func (InputsSchemaRecordFormatMappingParametersAttributes) InternalTokens 

func (mp InputsSchemaRecordFormatMappingParametersAttributes) InternalTokens() (hclwrite.Tokens, error)

func (InputsSchemaRecordFormatMappingParametersAttributes) InternalWithRef 

func (mp InputsSchemaRecordFormatMappingParametersAttributes) InternalWithRef(ref terra.Reference) InputsSchemaRecordFormatMappingParametersAttributes

func (InputsSchemaRecordFormatMappingParametersAttributes) Json 

func (mp InputsSchemaRecordFormatMappingParametersAttributes) Json() terra.ListValue[InputsSchemaRecordFormatMappingParametersJsonAttributes]

type InputsSchemaRecordFormatMappingParametersCsv 

type InputsSchemaRecordFormatMappingParametersCsv 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 InputsSchemaRecordFormatMappingParametersCsvAttributes 

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

func (InputsSchemaRecordFormatMappingParametersCsvAttributes) InternalRef 

func (c InputsSchemaRecordFormatMappingParametersCsvAttributes) InternalRef() (terra.Reference, error)

func (InputsSchemaRecordFormatMappingParametersCsvAttributes) InternalTokens 

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

func (InputsSchemaRecordFormatMappingParametersCsvAttributes) InternalWithRef 

func (c InputsSchemaRecordFormatMappingParametersCsvAttributes) InternalWithRef(ref terra.Reference) InputsSchemaRecordFormatMappingParametersCsvAttributes

func (InputsSchemaRecordFormatMappingParametersCsvAttributes) RecordColumnDelimiter 

func (c InputsSchemaRecordFormatMappingParametersCsvAttributes) RecordColumnDelimiter() terra.StringValue

func (InputsSchemaRecordFormatMappingParametersCsvAttributes) RecordRowDelimiter 

func (c InputsSchemaRecordFormatMappingParametersCsvAttributes) RecordRowDelimiter() terra.StringValue

type InputsSchemaRecordFormatMappingParametersCsvState 

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

type InputsSchemaRecordFormatMappingParametersJson 

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

type InputsSchemaRecordFormatMappingParametersJsonAttributes 

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

func (InputsSchemaRecordFormatMappingParametersJsonAttributes) InternalRef 

func (j InputsSchemaRecordFormatMappingParametersJsonAttributes) InternalRef() (terra.Reference, error)

func (InputsSchemaRecordFormatMappingParametersJsonAttributes) InternalTokens 

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

func (InputsSchemaRecordFormatMappingParametersJsonAttributes) InternalWithRef 

func (j InputsSchemaRecordFormatMappingParametersJsonAttributes) InternalWithRef(ref terra.Reference) InputsSchemaRecordFormatMappingParametersJsonAttributes

func (InputsSchemaRecordFormatMappingParametersJsonAttributes) RecordRowPath 

func (j InputsSchemaRecordFormatMappingParametersJsonAttributes) RecordRowPath() terra.StringValue

type InputsSchemaRecordFormatMappingParametersJsonState 

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

type InputsSchemaRecordFormatMappingParametersState 

type InputsSchemaRecordFormatMappingParametersState struct {
	Csv  []InputsSchemaRecordFormatMappingParametersCsvState  `json:"csv"`
	Json []InputsSchemaRecordFormatMappingParametersJsonState `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 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                   []ParallelismState                   `json:"parallelism"`
	ProcessingConfiguration       []ProcessingConfigurationState       `json:"processing_configuration"`
	Schema                        []InputsSchemaState                  `json:"schema"`
	StartingPositionConfiguration []StartingPositionConfigurationState `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 (o OutputsAttributes) Id() terra.StringValue

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 (o OutputsAttributes) KinesisFirehose() terra.ListValue[OutputsKinesisFirehoseAttributes]

func (OutputsAttributes) KinesisStream 

func (o OutputsAttributes) KinesisStream() terra.ListValue[OutputsKinesisStreamAttributes]

func (OutputsAttributes) Lambda 

func (o OutputsAttributes) Lambda() terra.ListValue[OutputsLambdaAttributes]

func (OutputsAttributes) Name 

func (o OutputsAttributes) Name() terra.StringValue

func (OutputsAttributes) Schema 

func (o OutputsAttributes) Schema() terra.ListValue[OutputsSchemaAttributes]

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 (kf OutputsKinesisFirehoseAttributes) InternalRef() (terra.Reference, error)

func (OutputsKinesisFirehoseAttributes) InternalTokens 

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

func (OutputsKinesisFirehoseAttributes) InternalWithRef 

func (kf OutputsKinesisFirehoseAttributes) InternalWithRef(ref terra.Reference) OutputsKinesisFirehoseAttributes

func (OutputsKinesisFirehoseAttributes) ResourceArn 

func (kf OutputsKinesisFirehoseAttributes) ResourceArn() terra.StringValue

func (OutputsKinesisFirehoseAttributes) RoleArn 

func (kf OutputsKinesisFirehoseAttributes) RoleArn() terra.StringValue

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 (ks OutputsKinesisStreamAttributes) InternalRef() (terra.Reference, error)

func (OutputsKinesisStreamAttributes) InternalTokens 

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

func (OutputsKinesisStreamAttributes) InternalWithRef 

func (ks OutputsKinesisStreamAttributes) InternalWithRef(ref terra.Reference) OutputsKinesisStreamAttributes

func (OutputsKinesisStreamAttributes) ResourceArn 

func (ks OutputsKinesisStreamAttributes) ResourceArn() terra.StringValue

func (OutputsKinesisStreamAttributes) RoleArn 

func (ks OutputsKinesisStreamAttributes) RoleArn() terra.StringValue

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 (l OutputsLambdaAttributes) InternalWithRef(ref terra.Reference) OutputsLambdaAttributes

func (OutputsLambdaAttributes) ResourceArn 

func (l OutputsLambdaAttributes) ResourceArn() terra.StringValue

func (OutputsLambdaAttributes) RoleArn 

func (l OutputsLambdaAttributes) RoleArn() terra.StringValue

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 (s OutputsSchemaAttributes) InternalWithRef(ref terra.Reference) OutputsSchemaAttributes

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 Parallelism 

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

type ParallelismAttributes 

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

func (ParallelismAttributes) Count 

func (p ParallelismAttributes) Count() terra.NumberValue

func (ParallelismAttributes) InternalRef 

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

func (ParallelismAttributes) InternalTokens 

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

func (ParallelismAttributes) InternalWithRef 

func (p ParallelismAttributes) InternalWithRef(ref terra.Reference) ParallelismAttributes

type ParallelismState 

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

type ProcessingConfiguration 

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

type ProcessingConfigurationAttributes 

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

func (ProcessingConfigurationAttributes) InternalRef 

func (pc ProcessingConfigurationAttributes) InternalRef() (terra.Reference, error)

func (ProcessingConfigurationAttributes) InternalTokens 

func (pc ProcessingConfigurationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ProcessingConfigurationAttributes) InternalWithRef 

func (pc ProcessingConfigurationAttributes) InternalWithRef(ref terra.Reference) ProcessingConfigurationAttributes

func (ProcessingConfigurationAttributes) Lambda 

func (pc ProcessingConfigurationAttributes) Lambda() terra.ListValue[ProcessingConfigurationLambdaAttributes]

type ProcessingConfigurationLambda 

type ProcessingConfigurationLambda 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 ProcessingConfigurationLambdaAttributes 

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

func (ProcessingConfigurationLambdaAttributes) InternalRef 

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

func (ProcessingConfigurationLambdaAttributes) InternalTokens 

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

func (ProcessingConfigurationLambdaAttributes) InternalWithRef 

func (l ProcessingConfigurationLambdaAttributes) InternalWithRef(ref terra.Reference) ProcessingConfigurationLambdaAttributes

func (ProcessingConfigurationLambdaAttributes) ResourceArn 

func (l ProcessingConfigurationLambdaAttributes) ResourceArn() terra.StringValue

func (ProcessingConfigurationLambdaAttributes) RoleArn 

func (l ProcessingConfigurationLambdaAttributes) RoleArn() terra.StringValue

type ProcessingConfigurationLambdaState 

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

type ProcessingConfigurationState 

type ProcessingConfigurationState struct {
	Lambda []ProcessingConfigurationLambdaState `json:"lambda"`
}

type ReferenceDataSources 

type ReferenceDataSources struct {
	// TableName: string, required
	TableName terra.StringValue `hcl:"table_name,attr" validate:"required"`
	// S3: required
	S3 *S3 `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 (rds ReferenceDataSourcesAttributes) Id() terra.StringValue

func (ReferenceDataSourcesAttributes) InternalRef 

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

func (ReferenceDataSourcesAttributes) InternalTokens 

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

func (ReferenceDataSourcesAttributes) InternalWithRef 

func (rds ReferenceDataSourcesAttributes) InternalWithRef(ref terra.Reference) ReferenceDataSourcesAttributes

func (ReferenceDataSourcesAttributes) S3 

func (rds ReferenceDataSourcesAttributes) S3() terra.ListValue[S3Attributes]

func (ReferenceDataSourcesAttributes) Schema 

func (rds ReferenceDataSourcesAttributes) Schema() terra.ListValue[ReferenceDataSourcesSchemaAttributes]

func (ReferenceDataSourcesAttributes) TableName 

func (rds ReferenceDataSourcesAttributes) TableName() terra.StringValue

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 ReferenceDataSourcesSchemaAttributes 

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

func (ReferenceDataSourcesSchemaAttributes) InternalRef 

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

func (ReferenceDataSourcesSchemaAttributes) InternalTokens 

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

func (ReferenceDataSourcesSchemaAttributes) InternalWithRef 

func (s ReferenceDataSourcesSchemaAttributes) InternalWithRef(ref terra.Reference) ReferenceDataSourcesSchemaAttributes

func (ReferenceDataSourcesSchemaAttributes) RecordColumns 

func (s ReferenceDataSourcesSchemaAttributes) RecordColumns() terra.ListValue[ReferenceDataSourcesSchemaRecordColumnsAttributes]

func (ReferenceDataSourcesSchemaAttributes) RecordEncoding 

func (s ReferenceDataSourcesSchemaAttributes) RecordEncoding() terra.StringValue

func (ReferenceDataSourcesSchemaAttributes) RecordFormat 

func (s ReferenceDataSourcesSchemaAttributes) RecordFormat() terra.ListValue[ReferenceDataSourcesSchemaRecordFormatAttributes]

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 (rc ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalRef() (terra.Reference, error)

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalTokens 

func (rc ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalWithRef 

func (rc ReferenceDataSourcesSchemaRecordColumnsAttributes) InternalWithRef(ref terra.Reference) ReferenceDataSourcesSchemaRecordColumnsAttributes

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) Mapping 

func (rc ReferenceDataSourcesSchemaRecordColumnsAttributes) Mapping() terra.StringValue

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) Name 

func (rc ReferenceDataSourcesSchemaRecordColumnsAttributes) Name() terra.StringValue

func (ReferenceDataSourcesSchemaRecordColumnsAttributes) SqlType 

func (rc ReferenceDataSourcesSchemaRecordColumnsAttributes) SqlType() terra.StringValue

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 (rf ReferenceDataSourcesSchemaRecordFormatAttributes) InternalRef() (terra.Reference, error)

func (ReferenceDataSourcesSchemaRecordFormatAttributes) InternalTokens 

func (rf ReferenceDataSourcesSchemaRecordFormatAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ReferenceDataSourcesSchemaRecordFormatAttributes) InternalWithRef 

func (rf ReferenceDataSourcesSchemaRecordFormatAttributes) InternalWithRef(ref terra.Reference) ReferenceDataSourcesSchemaRecordFormatAttributes

func (ReferenceDataSourcesSchemaRecordFormatAttributes) MappingParameters 

func (rf ReferenceDataSourcesSchemaRecordFormatAttributes) MappingParameters() terra.ListValue[ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes]

func (ReferenceDataSourcesSchemaRecordFormatAttributes) RecordFormatType 

func (rf ReferenceDataSourcesSchemaRecordFormatAttributes) RecordFormatType() terra.StringValue

type ReferenceDataSourcesSchemaRecordFormatMappingParameters 

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

type ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes 

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

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) Csv 

func (mp ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) Csv() terra.ListValue[ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes]

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalRef 

func (mp ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalRef() (terra.Reference, error)

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalTokens 

func (mp ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalWithRef 

func (mp ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) InternalWithRef(ref terra.Reference) ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) Json 

func (mp ReferenceDataSourcesSchemaRecordFormatMappingParametersAttributes) Json() terra.ListValue[ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes]

type ReferenceDataSourcesSchemaRecordFormatMappingParametersCsv 

type ReferenceDataSourcesSchemaRecordFormatMappingParametersCsv 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 ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes 

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

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) InternalRef 

func (c ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) InternalRef() (terra.Reference, error)

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) InternalTokens 

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

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) InternalWithRef 

func (c ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) InternalWithRef(ref terra.Reference) ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) RecordColumnDelimiter 

func (c ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) RecordColumnDelimiter() terra.StringValue

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) RecordRowDelimiter 

func (c ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvAttributes) RecordRowDelimiter() terra.StringValue

type ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvState 

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

type ReferenceDataSourcesSchemaRecordFormatMappingParametersJson 

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

type ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes 

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

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes) InternalRef 

func (j ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes) InternalRef() (terra.Reference, error)

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes) InternalTokens 

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

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes) InternalWithRef 

func (j ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes) InternalWithRef(ref terra.Reference) ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes

func (ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes) RecordRowPath 

func (j ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonAttributes) RecordRowPath() terra.StringValue

type ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonState 

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

type ReferenceDataSourcesSchemaRecordFormatMappingParametersState 

type ReferenceDataSourcesSchemaRecordFormatMappingParametersState struct {
	Csv  []ReferenceDataSourcesSchemaRecordFormatMappingParametersCsvState  `json:"csv"`
	Json []ReferenceDataSourcesSchemaRecordFormatMappingParametersJsonState `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        []S3State                         `json:"s3"`
	Schema    []ReferenceDataSourcesSchemaState `json:"schema"`
}

type S3 

type S3 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 S3Attributes 

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

func (S3Attributes) BucketArn 

func (s S3Attributes) BucketArn() terra.StringValue

func (S3Attributes) FileKey 

func (s S3Attributes) FileKey() terra.StringValue

func (S3Attributes) InternalRef 

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

func (S3Attributes) InternalTokens 

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

func (S3Attributes) InternalWithRef 

func (s S3Attributes) InternalWithRef(ref terra.Reference) S3Attributes

func (S3Attributes) RoleArn 

func (s S3Attributes) RoleArn() terra.StringValue

type S3State 

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

type StartingPositionConfiguration 

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

type StartingPositionConfigurationAttributes 

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

func (StartingPositionConfigurationAttributes) InternalRef 

func (spc StartingPositionConfigurationAttributes) InternalRef() (terra.Reference, error)

func (StartingPositionConfigurationAttributes) InternalTokens 

func (spc StartingPositionConfigurationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (StartingPositionConfigurationAttributes) InternalWithRef 

func (spc StartingPositionConfigurationAttributes) InternalWithRef(ref terra.Reference) StartingPositionConfigurationAttributes

func (StartingPositionConfigurationAttributes) StartingPosition 

func (spc StartingPositionConfigurationAttributes) StartingPosition() terra.StringValue

type StartingPositionConfigurationState 

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

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.