mskconnectconnector

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 ApacheKafkaCluster

type ApacheKafkaCluster struct {
	// BootstrapServers: string, required
	BootstrapServers terra.StringValue `hcl:"bootstrap_servers,attr" validate:"required"`
	// Vpc: required
	Vpc *Vpc `hcl:"vpc,block" validate:"required"`
}

type ApacheKafkaClusterAttributes

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

func (ApacheKafkaClusterAttributes) BootstrapServers

func (akc ApacheKafkaClusterAttributes) BootstrapServers() terra.StringValue

func (ApacheKafkaClusterAttributes) InternalRef

func (akc ApacheKafkaClusterAttributes) InternalRef() (terra.Reference, error)

func (ApacheKafkaClusterAttributes) InternalTokens

func (akc ApacheKafkaClusterAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ApacheKafkaClusterAttributes) InternalWithRef

func (ApacheKafkaClusterAttributes) Vpc

type ApacheKafkaClusterState

type ApacheKafkaClusterState struct {
	BootstrapServers string     `json:"bootstrap_servers"`
	Vpc              []VpcState `json:"vpc"`
}

type Autoscaling

type Autoscaling struct {
	// MaxWorkerCount: number, required
	MaxWorkerCount terra.NumberValue `hcl:"max_worker_count,attr" validate:"required"`
	// McuCount: number, optional
	McuCount terra.NumberValue `hcl:"mcu_count,attr"`
	// MinWorkerCount: number, required
	MinWorkerCount terra.NumberValue `hcl:"min_worker_count,attr" validate:"required"`
	// ScaleInPolicy: optional
	ScaleInPolicy *ScaleInPolicy `hcl:"scale_in_policy,block"`
	// ScaleOutPolicy: optional
	ScaleOutPolicy *ScaleOutPolicy `hcl:"scale_out_policy,block"`
}

type AutoscalingAttributes

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

func (AutoscalingAttributes) InternalRef

func (a AutoscalingAttributes) InternalRef() (terra.Reference, error)

func (AutoscalingAttributes) InternalTokens

func (a AutoscalingAttributes) InternalTokens() (hclwrite.Tokens, error)

func (AutoscalingAttributes) InternalWithRef

func (AutoscalingAttributes) MaxWorkerCount

func (a AutoscalingAttributes) MaxWorkerCount() terra.NumberValue

func (AutoscalingAttributes) McuCount

func (AutoscalingAttributes) MinWorkerCount

func (a AutoscalingAttributes) MinWorkerCount() terra.NumberValue

func (AutoscalingAttributes) ScaleInPolicy

func (AutoscalingAttributes) ScaleOutPolicy

type AutoscalingState

type AutoscalingState struct {
	MaxWorkerCount float64               `json:"max_worker_count"`
	McuCount       float64               `json:"mcu_count"`
	MinWorkerCount float64               `json:"min_worker_count"`
	ScaleInPolicy  []ScaleInPolicyState  `json:"scale_in_policy"`
	ScaleOutPolicy []ScaleOutPolicyState `json:"scale_out_policy"`
}

type Capacity

type Capacity struct {
	// Autoscaling: optional
	Autoscaling *Autoscaling `hcl:"autoscaling,block"`
	// ProvisionedCapacity: optional
	ProvisionedCapacity *ProvisionedCapacity `hcl:"provisioned_capacity,block"`
}

type CapacityAttributes

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

func (CapacityAttributes) Autoscaling

func (CapacityAttributes) InternalRef

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

func (CapacityAttributes) InternalTokens

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

func (CapacityAttributes) InternalWithRef

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

func (CapacityAttributes) ProvisionedCapacity

type CapacityState

type CapacityState struct {
	Autoscaling         []AutoscalingState         `json:"autoscaling"`
	ProvisionedCapacity []ProvisionedCapacityState `json:"provisioned_capacity"`
}

type CloudwatchLogs

type CloudwatchLogs struct {
	// Enabled: bool, required
	Enabled terra.BoolValue `hcl:"enabled,attr" validate:"required"`
	// LogGroup: string, optional
	LogGroup terra.StringValue `hcl:"log_group,attr"`
}

type CloudwatchLogsAttributes

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

func (CloudwatchLogsAttributes) Enabled

func (CloudwatchLogsAttributes) InternalRef

func (cl CloudwatchLogsAttributes) InternalRef() (terra.Reference, error)

func (CloudwatchLogsAttributes) InternalTokens

func (cl CloudwatchLogsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (CloudwatchLogsAttributes) InternalWithRef

func (CloudwatchLogsAttributes) LogGroup

type CloudwatchLogsState

type CloudwatchLogsState struct {
	Enabled  bool   `json:"enabled"`
	LogGroup string `json:"log_group"`
}

type CustomPlugin

type CustomPlugin struct {
	// Arn: string, required
	Arn terra.StringValue `hcl:"arn,attr" validate:"required"`
	// Revision: number, required
	Revision terra.NumberValue `hcl:"revision,attr" validate:"required"`
}

type CustomPluginAttributes

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

func (CustomPluginAttributes) Arn

func (CustomPluginAttributes) InternalRef

func (cp CustomPluginAttributes) InternalRef() (terra.Reference, error)

func (CustomPluginAttributes) InternalTokens

func (cp CustomPluginAttributes) InternalTokens() (hclwrite.Tokens, error)

func (CustomPluginAttributes) InternalWithRef

func (CustomPluginAttributes) Revision

type CustomPluginState

type CustomPluginState struct {
	Arn      string  `json:"arn"`
	Revision float64 `json:"revision"`
}

type Firehose

type Firehose struct {
	// DeliveryStream: string, optional
	DeliveryStream terra.StringValue `hcl:"delivery_stream,attr"`
	// Enabled: bool, required
	Enabled terra.BoolValue `hcl:"enabled,attr" validate:"required"`
}

type FirehoseAttributes

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

func (FirehoseAttributes) DeliveryStream

func (f FirehoseAttributes) DeliveryStream() terra.StringValue

func (FirehoseAttributes) Enabled

func (f FirehoseAttributes) Enabled() terra.BoolValue

func (FirehoseAttributes) InternalRef

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

func (FirehoseAttributes) InternalTokens

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

func (FirehoseAttributes) InternalWithRef

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

type FirehoseState

type FirehoseState struct {
	DeliveryStream string `json:"delivery_stream"`
	Enabled        bool   `json:"enabled"`
}

type KafkaCluster

type KafkaCluster struct {
	// ApacheKafkaCluster: required
	ApacheKafkaCluster *ApacheKafkaCluster `hcl:"apache_kafka_cluster,block" validate:"required"`
}

type KafkaClusterAttributes

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

func (KafkaClusterAttributes) ApacheKafkaCluster

func (KafkaClusterAttributes) InternalRef

func (kc KafkaClusterAttributes) InternalRef() (terra.Reference, error)

func (KafkaClusterAttributes) InternalTokens

func (kc KafkaClusterAttributes) InternalTokens() (hclwrite.Tokens, error)

func (KafkaClusterAttributes) InternalWithRef

type KafkaClusterClientAuthentication

type KafkaClusterClientAuthentication struct {
	// AuthenticationType: string, optional
	AuthenticationType terra.StringValue `hcl:"authentication_type,attr"`
}

type KafkaClusterClientAuthenticationAttributes

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

func (KafkaClusterClientAuthenticationAttributes) AuthenticationType

func (KafkaClusterClientAuthenticationAttributes) InternalRef

func (KafkaClusterClientAuthenticationAttributes) InternalTokens

func (KafkaClusterClientAuthenticationAttributes) InternalWithRef

type KafkaClusterClientAuthenticationState

type KafkaClusterClientAuthenticationState struct {
	AuthenticationType string `json:"authentication_type"`
}

type KafkaClusterEncryptionInTransit

type KafkaClusterEncryptionInTransit struct {
	// EncryptionType: string, optional
	EncryptionType terra.StringValue `hcl:"encryption_type,attr"`
}

type KafkaClusterEncryptionInTransitAttributes

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

func (KafkaClusterEncryptionInTransitAttributes) EncryptionType

func (KafkaClusterEncryptionInTransitAttributes) InternalRef

func (KafkaClusterEncryptionInTransitAttributes) InternalTokens

func (KafkaClusterEncryptionInTransitAttributes) InternalWithRef

type KafkaClusterEncryptionInTransitState

type KafkaClusterEncryptionInTransitState struct {
	EncryptionType string `json:"encryption_type"`
}

type KafkaClusterState

type KafkaClusterState struct {
	ApacheKafkaCluster []ApacheKafkaClusterState `json:"apache_kafka_cluster"`
}

type LogDelivery

type LogDelivery struct {
	// WorkerLogDelivery: required
	WorkerLogDelivery *WorkerLogDelivery `hcl:"worker_log_delivery,block" validate:"required"`
}

type LogDeliveryAttributes

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

func (LogDeliveryAttributes) InternalRef

func (ld LogDeliveryAttributes) InternalRef() (terra.Reference, error)

func (LogDeliveryAttributes) InternalTokens

func (ld LogDeliveryAttributes) InternalTokens() (hclwrite.Tokens, error)

func (LogDeliveryAttributes) InternalWithRef

func (LogDeliveryAttributes) WorkerLogDelivery

type LogDeliveryState

type LogDeliveryState struct {
	WorkerLogDelivery []WorkerLogDeliveryState `json:"worker_log_delivery"`
}

type Plugin

type Plugin struct {
	// CustomPlugin: required
	CustomPlugin *CustomPlugin `hcl:"custom_plugin,block" validate:"required"`
}

type PluginAttributes

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

func (PluginAttributes) CustomPlugin

func (PluginAttributes) InternalRef

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

func (PluginAttributes) InternalTokens

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

func (PluginAttributes) InternalWithRef

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

type PluginState

type PluginState struct {
	CustomPlugin []CustomPluginState `json:"custom_plugin"`
}

type ProvisionedCapacity

type ProvisionedCapacity struct {
	// McuCount: number, optional
	McuCount terra.NumberValue `hcl:"mcu_count,attr"`
	// WorkerCount: number, required
	WorkerCount terra.NumberValue `hcl:"worker_count,attr" validate:"required"`
}

type ProvisionedCapacityAttributes

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

func (ProvisionedCapacityAttributes) InternalRef

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

func (ProvisionedCapacityAttributes) InternalTokens

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

func (ProvisionedCapacityAttributes) InternalWithRef

func (ProvisionedCapacityAttributes) McuCount

func (ProvisionedCapacityAttributes) WorkerCount

type ProvisionedCapacityState

type ProvisionedCapacityState struct {
	McuCount    float64 `json:"mcu_count"`
	WorkerCount float64 `json:"worker_count"`
}

type S3

type S3 struct {
	// Bucket: string, optional
	Bucket terra.StringValue `hcl:"bucket,attr"`
	// Enabled: bool, required
	Enabled terra.BoolValue `hcl:"enabled,attr" validate:"required"`
	// Prefix: string, optional
	Prefix terra.StringValue `hcl:"prefix,attr"`
}

type S3Attributes

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

func (S3Attributes) Bucket

func (s S3Attributes) Bucket() terra.StringValue

func (S3Attributes) Enabled

func (s S3Attributes) Enabled() terra.BoolValue

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) Prefix

func (s S3Attributes) Prefix() terra.StringValue

type S3State

type S3State struct {
	Bucket  string `json:"bucket"`
	Enabled bool   `json:"enabled"`
	Prefix  string `json:"prefix"`
}

type ScaleInPolicy

type ScaleInPolicy struct {
	// CpuUtilizationPercentage: number, optional
	CpuUtilizationPercentage terra.NumberValue `hcl:"cpu_utilization_percentage,attr"`
}

type ScaleInPolicyAttributes

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

func (ScaleInPolicyAttributes) CpuUtilizationPercentage

func (sip ScaleInPolicyAttributes) CpuUtilizationPercentage() terra.NumberValue

func (ScaleInPolicyAttributes) InternalRef

func (sip ScaleInPolicyAttributes) InternalRef() (terra.Reference, error)

func (ScaleInPolicyAttributes) InternalTokens

func (sip ScaleInPolicyAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ScaleInPolicyAttributes) InternalWithRef

type ScaleInPolicyState

type ScaleInPolicyState struct {
	CpuUtilizationPercentage float64 `json:"cpu_utilization_percentage"`
}

type ScaleOutPolicy

type ScaleOutPolicy struct {
	// CpuUtilizationPercentage: number, optional
	CpuUtilizationPercentage terra.NumberValue `hcl:"cpu_utilization_percentage,attr"`
}

type ScaleOutPolicyAttributes

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

func (ScaleOutPolicyAttributes) CpuUtilizationPercentage

func (sop ScaleOutPolicyAttributes) CpuUtilizationPercentage() terra.NumberValue

func (ScaleOutPolicyAttributes) InternalRef

func (sop ScaleOutPolicyAttributes) InternalRef() (terra.Reference, error)

func (ScaleOutPolicyAttributes) InternalTokens

func (sop ScaleOutPolicyAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ScaleOutPolicyAttributes) InternalWithRef

type ScaleOutPolicyState

type ScaleOutPolicyState struct {
	CpuUtilizationPercentage float64 `json:"cpu_utilization_percentage"`
}

type Timeouts

type Timeouts struct {
	// Create: string, optional
	Create terra.StringValue `hcl:"create,attr"`
	// Delete: string, optional
	Delete terra.StringValue `hcl:"delete,attr"`
	// Update: string, optional
	Update terra.StringValue `hcl:"update,attr"`
}

type TimeoutsAttributes

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

func (TimeoutsAttributes) Create

func (TimeoutsAttributes) Delete

func (TimeoutsAttributes) InternalRef

func (t TimeoutsAttributes) InternalRef() (terra.Reference, error)

func (TimeoutsAttributes) InternalTokens

func (t TimeoutsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (TimeoutsAttributes) InternalWithRef

func (t TimeoutsAttributes) InternalWithRef(ref terra.Reference) TimeoutsAttributes

func (TimeoutsAttributes) Update

type TimeoutsState

type TimeoutsState struct {
	Create string `json:"create"`
	Delete string `json:"delete"`
	Update string `json:"update"`
}

type Vpc

type Vpc struct {
	// SecurityGroups: set of string, required
	SecurityGroups terra.SetValue[terra.StringValue] `hcl:"security_groups,attr" validate:"required"`
	// Subnets: set of string, required
	Subnets terra.SetValue[terra.StringValue] `hcl:"subnets,attr" validate:"required"`
}

type VpcAttributes

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

func (VpcAttributes) InternalRef

func (v VpcAttributes) InternalRef() (terra.Reference, error)

func (VpcAttributes) InternalTokens

func (v VpcAttributes) InternalTokens() (hclwrite.Tokens, error)

func (VpcAttributes) InternalWithRef

func (v VpcAttributes) InternalWithRef(ref terra.Reference) VpcAttributes

func (VpcAttributes) SecurityGroups

func (v VpcAttributes) SecurityGroups() terra.SetValue[terra.StringValue]

func (VpcAttributes) Subnets

type VpcState

type VpcState struct {
	SecurityGroups []string `json:"security_groups"`
	Subnets        []string `json:"subnets"`
}

type WorkerConfiguration

type WorkerConfiguration struct {
	// Arn: string, required
	Arn terra.StringValue `hcl:"arn,attr" validate:"required"`
	// Revision: number, required
	Revision terra.NumberValue `hcl:"revision,attr" validate:"required"`
}

type WorkerConfigurationAttributes

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

func (WorkerConfigurationAttributes) Arn

func (WorkerConfigurationAttributes) InternalRef

func (wc WorkerConfigurationAttributes) InternalRef() (terra.Reference, error)

func (WorkerConfigurationAttributes) InternalTokens

func (wc WorkerConfigurationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (WorkerConfigurationAttributes) InternalWithRef

func (WorkerConfigurationAttributes) Revision

type WorkerConfigurationState

type WorkerConfigurationState struct {
	Arn      string  `json:"arn"`
	Revision float64 `json:"revision"`
}

type WorkerLogDelivery

type WorkerLogDelivery struct {
	// CloudwatchLogs: optional
	CloudwatchLogs *CloudwatchLogs `hcl:"cloudwatch_logs,block"`
	// Firehose: optional
	Firehose *Firehose `hcl:"firehose,block"`
	// S3: optional
	S3 *S3 `hcl:"s3,block"`
}

type WorkerLogDeliveryAttributes

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

func (WorkerLogDeliveryAttributes) CloudwatchLogs

func (WorkerLogDeliveryAttributes) Firehose

func (WorkerLogDeliveryAttributes) InternalRef

func (wld WorkerLogDeliveryAttributes) InternalRef() (terra.Reference, error)

func (WorkerLogDeliveryAttributes) InternalTokens

func (wld WorkerLogDeliveryAttributes) InternalTokens() (hclwrite.Tokens, error)

func (WorkerLogDeliveryAttributes) InternalWithRef

func (WorkerLogDeliveryAttributes) S3

type WorkerLogDeliveryState

type WorkerLogDeliveryState struct {
	CloudwatchLogs []CloudwatchLogsState `json:"cloudwatch_logs"`
	Firehose       []FirehoseState       `json:"firehose"`
	S3             []S3State             `json:"s3"`
}

Jump to

Keyboard shortcuts

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