datadmsendpoint

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 ElasticsearchSettings 

type ElasticsearchSettings struct{}

type ElasticsearchSettingsAttributes 

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

func (ElasticsearchSettingsAttributes) EndpointUri 

func (es ElasticsearchSettingsAttributes) EndpointUri() terra.StringValue

func (ElasticsearchSettingsAttributes) ErrorRetryDuration 

func (es ElasticsearchSettingsAttributes) ErrorRetryDuration() terra.NumberValue

func (ElasticsearchSettingsAttributes) FullLoadErrorPercentage 

func (es ElasticsearchSettingsAttributes) FullLoadErrorPercentage() terra.NumberValue

func (ElasticsearchSettingsAttributes) InternalRef 

func (es ElasticsearchSettingsAttributes) InternalRef() (terra.Reference, error)

func (ElasticsearchSettingsAttributes) InternalTokens 

func (es ElasticsearchSettingsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ElasticsearchSettingsAttributes) InternalWithRef 

func (es ElasticsearchSettingsAttributes) InternalWithRef(ref terra.Reference) ElasticsearchSettingsAttributes

func (ElasticsearchSettingsAttributes) ServiceAccessRoleArn 

func (es ElasticsearchSettingsAttributes) ServiceAccessRoleArn() terra.StringValue

type ElasticsearchSettingsState 

type ElasticsearchSettingsState struct {
	EndpointUri             string  `json:"endpoint_uri"`
	ErrorRetryDuration      float64 `json:"error_retry_duration"`
	FullLoadErrorPercentage float64 `json:"full_load_error_percentage"`
	ServiceAccessRoleArn    string  `json:"service_access_role_arn"`
}

type KafkaSettings 

type KafkaSettings struct{}

type KafkaSettingsAttributes 

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

func (KafkaSettingsAttributes) Broker 

func (ks KafkaSettingsAttributes) Broker() terra.StringValue

func (KafkaSettingsAttributes) IncludeControlDetails 

func (ks KafkaSettingsAttributes) IncludeControlDetails() terra.BoolValue

func (KafkaSettingsAttributes) IncludeNullAndEmpty 

func (ks KafkaSettingsAttributes) IncludeNullAndEmpty() terra.BoolValue

func (KafkaSettingsAttributes) IncludePartitionValue 

func (ks KafkaSettingsAttributes) IncludePartitionValue() terra.BoolValue

func (KafkaSettingsAttributes) IncludeTableAlterOperations 

func (ks KafkaSettingsAttributes) IncludeTableAlterOperations() terra.BoolValue

func (KafkaSettingsAttributes) IncludeTransactionDetails 

func (ks KafkaSettingsAttributes) IncludeTransactionDetails() terra.BoolValue

func (KafkaSettingsAttributes) InternalRef 

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

func (KafkaSettingsAttributes) InternalTokens 

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

func (KafkaSettingsAttributes) InternalWithRef 

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

func (KafkaSettingsAttributes) MessageFormat 

func (ks KafkaSettingsAttributes) MessageFormat() terra.StringValue

func (KafkaSettingsAttributes) MessageMaxBytes 

func (ks KafkaSettingsAttributes) MessageMaxBytes() terra.NumberValue

func (KafkaSettingsAttributes) NoHexPrefix 

func (ks KafkaSettingsAttributes) NoHexPrefix() terra.BoolValue

func (KafkaSettingsAttributes) PartitionIncludeSchemaTable 

func (ks KafkaSettingsAttributes) PartitionIncludeSchemaTable() terra.BoolValue

func (KafkaSettingsAttributes) SaslPassword 

func (ks KafkaSettingsAttributes) SaslPassword() terra.StringValue

func (KafkaSettingsAttributes) SaslUsername 

func (ks KafkaSettingsAttributes) SaslUsername() terra.StringValue

func (KafkaSettingsAttributes) SecurityProtocol 

func (ks KafkaSettingsAttributes) SecurityProtocol() terra.StringValue

func (KafkaSettingsAttributes) SslCaCertificateArn 

func (ks KafkaSettingsAttributes) SslCaCertificateArn() terra.StringValue

func (KafkaSettingsAttributes) SslClientCertificateArn 

func (ks KafkaSettingsAttributes) SslClientCertificateArn() terra.StringValue

func (KafkaSettingsAttributes) SslClientKeyArn 

func (ks KafkaSettingsAttributes) SslClientKeyArn() terra.StringValue

func (KafkaSettingsAttributes) SslClientKeyPassword 

func (ks KafkaSettingsAttributes) SslClientKeyPassword() terra.StringValue

func (KafkaSettingsAttributes) Topic 

func (ks KafkaSettingsAttributes) Topic() terra.StringValue

type KafkaSettingsState 

type KafkaSettingsState struct {
	Broker                      string  `json:"broker"`
	IncludeControlDetails       bool    `json:"include_control_details"`
	IncludeNullAndEmpty         bool    `json:"include_null_and_empty"`
	IncludePartitionValue       bool    `json:"include_partition_value"`
	IncludeTableAlterOperations bool    `json:"include_table_alter_operations"`
	IncludeTransactionDetails   bool    `json:"include_transaction_details"`
	MessageFormat               string  `json:"message_format"`
	MessageMaxBytes             float64 `json:"message_max_bytes"`
	NoHexPrefix                 bool    `json:"no_hex_prefix"`
	PartitionIncludeSchemaTable bool    `json:"partition_include_schema_table"`
	SaslPassword                string  `json:"sasl_password"`
	SaslUsername                string  `json:"sasl_username"`
	SecurityProtocol            string  `json:"security_protocol"`
	SslCaCertificateArn         string  `json:"ssl_ca_certificate_arn"`
	SslClientCertificateArn     string  `json:"ssl_client_certificate_arn"`
	SslClientKeyArn             string  `json:"ssl_client_key_arn"`
	SslClientKeyPassword        string  `json:"ssl_client_key_password"`
	Topic                       string  `json:"topic"`
}

type KinesisSettings 

type KinesisSettings struct{}

type KinesisSettingsAttributes 

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

func (KinesisSettingsAttributes) IncludeControlDetails 

func (ks KinesisSettingsAttributes) IncludeControlDetails() terra.BoolValue

func (KinesisSettingsAttributes) IncludeNullAndEmpty 

func (ks KinesisSettingsAttributes) IncludeNullAndEmpty() terra.BoolValue

func (KinesisSettingsAttributes) IncludePartitionValue 

func (ks KinesisSettingsAttributes) IncludePartitionValue() terra.BoolValue

func (KinesisSettingsAttributes) IncludeTableAlterOperations 

func (ks KinesisSettingsAttributes) IncludeTableAlterOperations() terra.BoolValue

func (KinesisSettingsAttributes) IncludeTransactionDetails 

func (ks KinesisSettingsAttributes) IncludeTransactionDetails() terra.BoolValue

func (KinesisSettingsAttributes) InternalRef 

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

func (KinesisSettingsAttributes) InternalTokens 

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

func (KinesisSettingsAttributes) InternalWithRef 

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

func (KinesisSettingsAttributes) MessageFormat 

func (ks KinesisSettingsAttributes) MessageFormat() terra.StringValue

func (KinesisSettingsAttributes) PartitionIncludeSchemaTable 

func (ks KinesisSettingsAttributes) PartitionIncludeSchemaTable() terra.BoolValue

func (KinesisSettingsAttributes) ServiceAccessRoleArn 

func (ks KinesisSettingsAttributes) ServiceAccessRoleArn() terra.StringValue

func (KinesisSettingsAttributes) StreamArn 

func (ks KinesisSettingsAttributes) StreamArn() terra.StringValue

type KinesisSettingsState 

type KinesisSettingsState struct {
	IncludeControlDetails       bool   `json:"include_control_details"`
	IncludeNullAndEmpty         bool   `json:"include_null_and_empty"`
	IncludePartitionValue       bool   `json:"include_partition_value"`
	IncludeTableAlterOperations bool   `json:"include_table_alter_operations"`
	IncludeTransactionDetails   bool   `json:"include_transaction_details"`
	MessageFormat               string `json:"message_format"`
	PartitionIncludeSchemaTable bool   `json:"partition_include_schema_table"`
	ServiceAccessRoleArn        string `json:"service_access_role_arn"`
	StreamArn                   string `json:"stream_arn"`
}

type MongodbSettings 

type MongodbSettings struct{}

type MongodbSettingsAttributes 

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

func (MongodbSettingsAttributes) AuthMechanism 

func (ms MongodbSettingsAttributes) AuthMechanism() terra.StringValue

func (MongodbSettingsAttributes) AuthSource 

func (ms MongodbSettingsAttributes) AuthSource() terra.StringValue

func (MongodbSettingsAttributes) AuthType 

func (ms MongodbSettingsAttributes) AuthType() terra.StringValue

func (MongodbSettingsAttributes) DocsToInvestigate 

func (ms MongodbSettingsAttributes) DocsToInvestigate() terra.StringValue

func (MongodbSettingsAttributes) ExtractDocId 

func (ms MongodbSettingsAttributes) ExtractDocId() terra.StringValue

func (MongodbSettingsAttributes) InternalRef 

func (ms MongodbSettingsAttributes) InternalRef() (terra.Reference, error)

func (MongodbSettingsAttributes) InternalTokens 

func (ms MongodbSettingsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (MongodbSettingsAttributes) InternalWithRef 

func (ms MongodbSettingsAttributes) InternalWithRef(ref terra.Reference) MongodbSettingsAttributes

func (MongodbSettingsAttributes) NestingLevel 

func (ms MongodbSettingsAttributes) NestingLevel() terra.StringValue

type MongodbSettingsState 

type MongodbSettingsState struct {
	AuthMechanism     string `json:"auth_mechanism"`
	AuthSource        string `json:"auth_source"`
	AuthType          string `json:"auth_type"`
	DocsToInvestigate string `json:"docs_to_investigate"`
	ExtractDocId      string `json:"extract_doc_id"`
	NestingLevel      string `json:"nesting_level"`
}

type RedisSettings 

type RedisSettings struct{}

type RedisSettingsAttributes 

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

func (RedisSettingsAttributes) AuthPassword 

func (rs RedisSettingsAttributes) AuthPassword() terra.StringValue

func (RedisSettingsAttributes) AuthType 

func (rs RedisSettingsAttributes) AuthType() terra.StringValue

func (RedisSettingsAttributes) AuthUserName 

func (rs RedisSettingsAttributes) AuthUserName() terra.StringValue

func (RedisSettingsAttributes) InternalRef 

func (rs RedisSettingsAttributes) InternalRef() (terra.Reference, error)

func (RedisSettingsAttributes) InternalTokens 

func (rs RedisSettingsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (RedisSettingsAttributes) InternalWithRef 

func (rs RedisSettingsAttributes) InternalWithRef(ref terra.Reference) RedisSettingsAttributes

func (RedisSettingsAttributes) Port 

func (rs RedisSettingsAttributes) Port() terra.NumberValue

func (RedisSettingsAttributes) ServerName 

func (rs RedisSettingsAttributes) ServerName() terra.StringValue

func (RedisSettingsAttributes) SslCaCertificateArn 

func (rs RedisSettingsAttributes) SslCaCertificateArn() terra.StringValue

func (RedisSettingsAttributes) SslSecurityProtocol 

func (rs RedisSettingsAttributes) SslSecurityProtocol() terra.StringValue

type RedisSettingsState 

type RedisSettingsState struct {
	AuthPassword        string  `json:"auth_password"`
	AuthType            string  `json:"auth_type"`
	AuthUserName        string  `json:"auth_user_name"`
	Port                float64 `json:"port"`
	ServerName          string  `json:"server_name"`
	SslCaCertificateArn string  `json:"ssl_ca_certificate_arn"`
	SslSecurityProtocol string  `json:"ssl_security_protocol"`
}

type RedshiftSettings 

type RedshiftSettings struct{}

type RedshiftSettingsAttributes 

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

func (RedshiftSettingsAttributes) BucketFolder 

func (rs RedshiftSettingsAttributes) BucketFolder() terra.StringValue

func (RedshiftSettingsAttributes) BucketName 

func (rs RedshiftSettingsAttributes) BucketName() terra.StringValue

func (RedshiftSettingsAttributes) EncryptionMode 

func (rs RedshiftSettingsAttributes) EncryptionMode() terra.StringValue

func (RedshiftSettingsAttributes) InternalRef 

func (rs RedshiftSettingsAttributes) InternalRef() (terra.Reference, error)

func (RedshiftSettingsAttributes) InternalTokens 

func (rs RedshiftSettingsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (RedshiftSettingsAttributes) InternalWithRef 

func (rs RedshiftSettingsAttributes) InternalWithRef(ref terra.Reference) RedshiftSettingsAttributes

func (RedshiftSettingsAttributes) ServerSideEncryptionKmsKeyId 

func (rs RedshiftSettingsAttributes) ServerSideEncryptionKmsKeyId() terra.StringValue

func (RedshiftSettingsAttributes) ServiceAccessRoleArn 

func (rs RedshiftSettingsAttributes) ServiceAccessRoleArn() terra.StringValue

type RedshiftSettingsState 

type RedshiftSettingsState struct {
	BucketFolder                 string `json:"bucket_folder"`
	BucketName                   string `json:"bucket_name"`
	EncryptionMode               string `json:"encryption_mode"`
	ServerSideEncryptionKmsKeyId string `json:"server_side_encryption_kms_key_id"`
	ServiceAccessRoleArn         string `json:"service_access_role_arn"`
}

type S3Settings 

type S3Settings struct{}

type S3SettingsAttributes 

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

func (S3SettingsAttributes) AddColumnName 

func (ss S3SettingsAttributes) AddColumnName() terra.BoolValue

func (S3SettingsAttributes) BucketFolder 

func (ss S3SettingsAttributes) BucketFolder() terra.StringValue

func (S3SettingsAttributes) BucketName 

func (ss S3SettingsAttributes) BucketName() terra.StringValue

func (S3SettingsAttributes) CannedAclForObjects 

func (ss S3SettingsAttributes) CannedAclForObjects() terra.StringValue

func (S3SettingsAttributes) CdcInsertsAndUpdates 

func (ss S3SettingsAttributes) CdcInsertsAndUpdates() terra.BoolValue

func (S3SettingsAttributes) CdcInsertsOnly 

func (ss S3SettingsAttributes) CdcInsertsOnly() terra.BoolValue

func (S3SettingsAttributes) CdcMaxBatchInterval 

func (ss S3SettingsAttributes) CdcMaxBatchInterval() terra.NumberValue

func (S3SettingsAttributes) CdcMinFileSize 

func (ss S3SettingsAttributes) CdcMinFileSize() terra.NumberValue

func (S3SettingsAttributes) CdcPath 

func (ss S3SettingsAttributes) CdcPath() terra.StringValue

func (S3SettingsAttributes) CompressionType 

func (ss S3SettingsAttributes) CompressionType() terra.StringValue

func (S3SettingsAttributes) CsvDelimiter 

func (ss S3SettingsAttributes) CsvDelimiter() terra.StringValue

func (S3SettingsAttributes) CsvNoSupValue 

func (ss S3SettingsAttributes) CsvNoSupValue() terra.StringValue

func (S3SettingsAttributes) CsvNullValue 

func (ss S3SettingsAttributes) CsvNullValue() terra.StringValue

func (S3SettingsAttributes) CsvRowDelimiter 

func (ss S3SettingsAttributes) CsvRowDelimiter() terra.StringValue

func (S3SettingsAttributes) DataFormat 

func (ss S3SettingsAttributes) DataFormat() terra.StringValue

func (S3SettingsAttributes) DataPageSize 

func (ss S3SettingsAttributes) DataPageSize() terra.NumberValue

func (S3SettingsAttributes) DatePartitionDelimiter 

func (ss S3SettingsAttributes) DatePartitionDelimiter() terra.StringValue

func (S3SettingsAttributes) DatePartitionEnabled 

func (ss S3SettingsAttributes) DatePartitionEnabled() terra.BoolValue

func (S3SettingsAttributes) DatePartitionSequence 

func (ss S3SettingsAttributes) DatePartitionSequence() terra.StringValue

func (S3SettingsAttributes) DictPageSizeLimit 

func (ss S3SettingsAttributes) DictPageSizeLimit() terra.NumberValue

func (S3SettingsAttributes) EnableStatistics 

func (ss S3SettingsAttributes) EnableStatistics() terra.BoolValue

func (S3SettingsAttributes) EncodingType 

func (ss S3SettingsAttributes) EncodingType() terra.StringValue

func (S3SettingsAttributes) EncryptionMode 

func (ss S3SettingsAttributes) EncryptionMode() terra.StringValue

func (S3SettingsAttributes) ExternalTableDefinition 

func (ss S3SettingsAttributes) ExternalTableDefinition() terra.StringValue

func (S3SettingsAttributes) IgnoreHeaderRows 

func (ss S3SettingsAttributes) IgnoreHeaderRows() terra.NumberValue

func (S3SettingsAttributes) IgnoreHeadersRow 

func (ss S3SettingsAttributes) IgnoreHeadersRow() terra.NumberValue

func (S3SettingsAttributes) IncludeOpForFullLoad 

func (ss S3SettingsAttributes) IncludeOpForFullLoad() terra.BoolValue

func (S3SettingsAttributes) InternalRef 

func (ss S3SettingsAttributes) InternalRef() (terra.Reference, error)

func (S3SettingsAttributes) InternalTokens 

func (ss S3SettingsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (S3SettingsAttributes) InternalWithRef 

func (ss S3SettingsAttributes) InternalWithRef(ref terra.Reference) S3SettingsAttributes

func (S3SettingsAttributes) MaxFileSize 

func (ss S3SettingsAttributes) MaxFileSize() terra.NumberValue

func (S3SettingsAttributes) ParquetTimestampInMillisecond 

func (ss S3SettingsAttributes) ParquetTimestampInMillisecond() terra.BoolValue

func (S3SettingsAttributes) ParquetVersion 

func (ss S3SettingsAttributes) ParquetVersion() terra.StringValue

func (S3SettingsAttributes) PreserveTransactions 

func (ss S3SettingsAttributes) PreserveTransactions() terra.BoolValue

func (S3SettingsAttributes) Rfc4180 

func (ss S3SettingsAttributes) Rfc4180() terra.BoolValue

func (S3SettingsAttributes) RowGroupLength 

func (ss S3SettingsAttributes) RowGroupLength() terra.NumberValue

func (S3SettingsAttributes) ServerSideEncryptionKmsKeyId 

func (ss S3SettingsAttributes) ServerSideEncryptionKmsKeyId() terra.StringValue

func (S3SettingsAttributes) ServiceAccessRoleArn 

func (ss S3SettingsAttributes) ServiceAccessRoleArn() terra.StringValue

func (S3SettingsAttributes) TimestampColumnName 

func (ss S3SettingsAttributes) TimestampColumnName() terra.StringValue

func (S3SettingsAttributes) UseCsvNoSupValue 

func (ss S3SettingsAttributes) UseCsvNoSupValue() terra.BoolValue

func (S3SettingsAttributes) UseTaskStartTimeForFullLoadTimestamp 

func (ss S3SettingsAttributes) UseTaskStartTimeForFullLoadTimestamp() terra.BoolValue

type S3SettingsState 

type S3SettingsState struct {
	AddColumnName                        bool    `json:"add_column_name"`
	BucketFolder                         string  `json:"bucket_folder"`
	BucketName                           string  `json:"bucket_name"`
	CannedAclForObjects                  string  `json:"canned_acl_for_objects"`
	CdcInsertsAndUpdates                 bool    `json:"cdc_inserts_and_updates"`
	CdcInsertsOnly                       bool    `json:"cdc_inserts_only"`
	CdcMaxBatchInterval                  float64 `json:"cdc_max_batch_interval"`
	CdcMinFileSize                       float64 `json:"cdc_min_file_size"`
	CdcPath                              string  `json:"cdc_path"`
	CompressionType                      string  `json:"compression_type"`
	CsvDelimiter                         string  `json:"csv_delimiter"`
	CsvNoSupValue                        string  `json:"csv_no_sup_value"`
	CsvNullValue                         string  `json:"csv_null_value"`
	CsvRowDelimiter                      string  `json:"csv_row_delimiter"`
	DataFormat                           string  `json:"data_format"`
	DataPageSize                         float64 `json:"data_page_size"`
	DatePartitionDelimiter               string  `json:"date_partition_delimiter"`
	DatePartitionEnabled                 bool    `json:"date_partition_enabled"`
	DatePartitionSequence                string  `json:"date_partition_sequence"`
	DictPageSizeLimit                    float64 `json:"dict_page_size_limit"`
	EnableStatistics                     bool    `json:"enable_statistics"`
	EncodingType                         string  `json:"encoding_type"`
	EncryptionMode                       string  `json:"encryption_mode"`
	ExternalTableDefinition              string  `json:"external_table_definition"`
	IgnoreHeaderRows                     float64 `json:"ignore_header_rows"`
	IgnoreHeadersRow                     float64 `json:"ignore_headers_row"`
	IncludeOpForFullLoad                 bool    `json:"include_op_for_full_load"`
	MaxFileSize                          float64 `json:"max_file_size"`
	ParquetTimestampInMillisecond        bool    `json:"parquet_timestamp_in_millisecond"`
	ParquetVersion                       string  `json:"parquet_version"`
	PreserveTransactions                 bool    `json:"preserve_transactions"`
	Rfc4180                              bool    `json:"rfc_4180"`
	RowGroupLength                       float64 `json:"row_group_length"`
	ServerSideEncryptionKmsKeyId         string  `json:"server_side_encryption_kms_key_id"`
	ServiceAccessRoleArn                 string  `json:"service_access_role_arn"`
	TimestampColumnName                  string  `json:"timestamp_column_name"`
	UseCsvNoSupValue                     bool    `json:"use_csv_no_sup_value"`
	UseTaskStartTimeForFullLoadTimestamp bool    `json:"use_task_start_time_for_full_load_timestamp"`
}

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.