aws_msk_replicator

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 {
	// Description: string, optional
	Description terra.StringValue `hcl:"description,attr"`
	// Id: string, optional
	Id terra.StringValue `hcl:"id,attr"`
	// ReplicatorName: string, required
	ReplicatorName terra.StringValue `hcl:"replicator_name,attr" validate:"required"`
	// ServiceExecutionRoleArn: string, required
	ServiceExecutionRoleArn terra.StringValue `hcl:"service_execution_role_arn,attr" validate:"required"`
	// 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"`
	// KafkaCluster: min=2,max=2
	KafkaCluster []KafkaCluster `hcl:"kafka_cluster,block" validate:"min=2,max=2"`
	// ReplicationInfoList: required
	ReplicationInfoList *ReplicationInfoList `hcl:"replication_info_list,block" validate:"required"`
	// Timeouts: optional
	Timeouts *Timeouts `hcl:"timeouts,block"`
}

Args contains the configurations for aws_msk_replicator.

type KafkaCluster 

type KafkaCluster struct {
	// KafkaClusterAmazonMskCluster: required
	AmazonMskCluster *KafkaClusterAmazonMskCluster `hcl:"amazon_msk_cluster,block" validate:"required"`
	// KafkaClusterVpcConfig: required
	VpcConfig *KafkaClusterVpcConfig `hcl:"vpc_config,block" validate:"required"`
}

type KafkaClusterAmazonMskCluster 

type KafkaClusterAmazonMskCluster struct {
	// MskClusterArn: string, required
	MskClusterArn terra.StringValue `hcl:"msk_cluster_arn,attr" validate:"required"`
}

type KafkaClusterAmazonMskClusterAttributes 

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

func (KafkaClusterAmazonMskClusterAttributes) InternalRef 

func (amc KafkaClusterAmazonMskClusterAttributes) InternalRef() (terra.Reference, error)

func (KafkaClusterAmazonMskClusterAttributes) InternalTokens 

func (amc KafkaClusterAmazonMskClusterAttributes) InternalTokens() (hclwrite.Tokens, error)

func (KafkaClusterAmazonMskClusterAttributes) InternalWithRef 

func (amc KafkaClusterAmazonMskClusterAttributes) InternalWithRef(ref terra.Reference) KafkaClusterAmazonMskClusterAttributes

func (KafkaClusterAmazonMskClusterAttributes) MskClusterArn 

func (amc KafkaClusterAmazonMskClusterAttributes) MskClusterArn() terra.StringValue

type KafkaClusterAmazonMskClusterState 

type KafkaClusterAmazonMskClusterState struct {
	MskClusterArn string `json:"msk_cluster_arn"`
}

type KafkaClusterAttributes 

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

func (KafkaClusterAttributes) AmazonMskCluster 

func (kc KafkaClusterAttributes) AmazonMskCluster() terra.ListValue[KafkaClusterAmazonMskClusterAttributes]

func (KafkaClusterAttributes) InternalRef 

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

func (KafkaClusterAttributes) InternalTokens 

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

func (KafkaClusterAttributes) InternalWithRef 

func (kc KafkaClusterAttributes) InternalWithRef(ref terra.Reference) KafkaClusterAttributes

func (KafkaClusterAttributes) VpcConfig 

func (kc KafkaClusterAttributes) VpcConfig() terra.ListValue[KafkaClusterVpcConfigAttributes]

type KafkaClusterState 

type KafkaClusterState struct {
	AmazonMskCluster []KafkaClusterAmazonMskClusterState `json:"amazon_msk_cluster"`
	VpcConfig        []KafkaClusterVpcConfigState        `json:"vpc_config"`
}

type KafkaClusterVpcConfig 

type KafkaClusterVpcConfig struct {
	// SecurityGroupsIds: set of string, optional
	SecurityGroupsIds terra.SetValue[terra.StringValue] `hcl:"security_groups_ids,attr"`
	// SubnetIds: set of string, required
	SubnetIds terra.SetValue[terra.StringValue] `hcl:"subnet_ids,attr" validate:"required"`
}

type KafkaClusterVpcConfigAttributes 

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

func (KafkaClusterVpcConfigAttributes) InternalRef 

func (vc KafkaClusterVpcConfigAttributes) InternalRef() (terra.Reference, error)

func (KafkaClusterVpcConfigAttributes) InternalTokens 

func (vc KafkaClusterVpcConfigAttributes) InternalTokens() (hclwrite.Tokens, error)

func (KafkaClusterVpcConfigAttributes) InternalWithRef 

func (vc KafkaClusterVpcConfigAttributes) InternalWithRef(ref terra.Reference) KafkaClusterVpcConfigAttributes

func (KafkaClusterVpcConfigAttributes) SecurityGroupsIds 

func (vc KafkaClusterVpcConfigAttributes) SecurityGroupsIds() terra.SetValue[terra.StringValue]

func (KafkaClusterVpcConfigAttributes) SubnetIds 

func (vc KafkaClusterVpcConfigAttributes) SubnetIds() terra.SetValue[terra.StringValue]

type KafkaClusterVpcConfigState 

type KafkaClusterVpcConfigState struct {
	SecurityGroupsIds []string `json:"security_groups_ids"`
	SubnetIds         []string `json:"subnet_ids"`
}

type ReplicationInfoList 

type ReplicationInfoList struct {
	// SourceKafkaClusterArn: string, required
	SourceKafkaClusterArn terra.StringValue `hcl:"source_kafka_cluster_arn,attr" validate:"required"`
	// TargetCompressionType: string, required
	TargetCompressionType terra.StringValue `hcl:"target_compression_type,attr" validate:"required"`
	// TargetKafkaClusterArn: string, required
	TargetKafkaClusterArn terra.StringValue `hcl:"target_kafka_cluster_arn,attr" validate:"required"`
	// ReplicationInfoListConsumerGroupReplication: min=1
	ConsumerGroupReplication []ReplicationInfoListConsumerGroupReplication `hcl:"consumer_group_replication,block" validate:"min=1"`
	// ReplicationInfoListTopicReplication: min=1
	TopicReplication []ReplicationInfoListTopicReplication `hcl:"topic_replication,block" validate:"min=1"`
}

type ReplicationInfoListAttributes 

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

func (ReplicationInfoListAttributes) ConsumerGroupReplication 

func (ril ReplicationInfoListAttributes) ConsumerGroupReplication() terra.ListValue[ReplicationInfoListConsumerGroupReplicationAttributes]

func (ReplicationInfoListAttributes) InternalRef 

func (ril ReplicationInfoListAttributes) InternalRef() (terra.Reference, error)

func (ReplicationInfoListAttributes) InternalTokens 

func (ril ReplicationInfoListAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ReplicationInfoListAttributes) InternalWithRef 

func (ril ReplicationInfoListAttributes) InternalWithRef(ref terra.Reference) ReplicationInfoListAttributes

func (ReplicationInfoListAttributes) SourceKafkaClusterAlias 

func (ril ReplicationInfoListAttributes) SourceKafkaClusterAlias() terra.StringValue

func (ReplicationInfoListAttributes) SourceKafkaClusterArn 

func (ril ReplicationInfoListAttributes) SourceKafkaClusterArn() terra.StringValue

func (ReplicationInfoListAttributes) TargetCompressionType 

func (ril ReplicationInfoListAttributes) TargetCompressionType() terra.StringValue

func (ReplicationInfoListAttributes) TargetKafkaClusterAlias 

func (ril ReplicationInfoListAttributes) TargetKafkaClusterAlias() terra.StringValue

func (ReplicationInfoListAttributes) TargetKafkaClusterArn 

func (ril ReplicationInfoListAttributes) TargetKafkaClusterArn() terra.StringValue

func (ReplicationInfoListAttributes) TopicReplication 

func (ril ReplicationInfoListAttributes) TopicReplication() terra.ListValue[ReplicationInfoListTopicReplicationAttributes]

type ReplicationInfoListConsumerGroupReplication 

type ReplicationInfoListConsumerGroupReplication struct {
	// ConsumerGroupsToExclude: set of string, optional
	ConsumerGroupsToExclude terra.SetValue[terra.StringValue] `hcl:"consumer_groups_to_exclude,attr"`
	// ConsumerGroupsToReplicate: set of string, required
	ConsumerGroupsToReplicate terra.SetValue[terra.StringValue] `hcl:"consumer_groups_to_replicate,attr" validate:"required"`
	// DetectAndCopyNewConsumerGroups: bool, optional
	DetectAndCopyNewConsumerGroups terra.BoolValue `hcl:"detect_and_copy_new_consumer_groups,attr"`
	// SynchroniseConsumerGroupOffsets: bool, optional
	SynchroniseConsumerGroupOffsets terra.BoolValue `hcl:"synchronise_consumer_group_offsets,attr"`
}

type ReplicationInfoListConsumerGroupReplicationAttributes 

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

func (ReplicationInfoListConsumerGroupReplicationAttributes) ConsumerGroupsToExclude 

func (cgr ReplicationInfoListConsumerGroupReplicationAttributes) ConsumerGroupsToExclude() terra.SetValue[terra.StringValue]

func (ReplicationInfoListConsumerGroupReplicationAttributes) ConsumerGroupsToReplicate 

func (cgr ReplicationInfoListConsumerGroupReplicationAttributes) ConsumerGroupsToReplicate() terra.SetValue[terra.StringValue]

func (ReplicationInfoListConsumerGroupReplicationAttributes) DetectAndCopyNewConsumerGroups 

func (cgr ReplicationInfoListConsumerGroupReplicationAttributes) DetectAndCopyNewConsumerGroups() terra.BoolValue

func (ReplicationInfoListConsumerGroupReplicationAttributes) InternalRef 

func (cgr ReplicationInfoListConsumerGroupReplicationAttributes) InternalRef() (terra.Reference, error)

func (ReplicationInfoListConsumerGroupReplicationAttributes) InternalTokens 

func (cgr ReplicationInfoListConsumerGroupReplicationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ReplicationInfoListConsumerGroupReplicationAttributes) InternalWithRef 

func (cgr ReplicationInfoListConsumerGroupReplicationAttributes) InternalWithRef(ref terra.Reference) ReplicationInfoListConsumerGroupReplicationAttributes

func (ReplicationInfoListConsumerGroupReplicationAttributes) SynchroniseConsumerGroupOffsets 

func (cgr ReplicationInfoListConsumerGroupReplicationAttributes) SynchroniseConsumerGroupOffsets() terra.BoolValue

type ReplicationInfoListConsumerGroupReplicationState 

type ReplicationInfoListConsumerGroupReplicationState struct {
	ConsumerGroupsToExclude         []string `json:"consumer_groups_to_exclude"`
	ConsumerGroupsToReplicate       []string `json:"consumer_groups_to_replicate"`
	DetectAndCopyNewConsumerGroups  bool     `json:"detect_and_copy_new_consumer_groups"`
	SynchroniseConsumerGroupOffsets bool     `json:"synchronise_consumer_group_offsets"`
}

type ReplicationInfoListState 

type ReplicationInfoListState struct {
	SourceKafkaClusterAlias  string                                             `json:"source_kafka_cluster_alias"`
	SourceKafkaClusterArn    string                                             `json:"source_kafka_cluster_arn"`
	TargetCompressionType    string                                             `json:"target_compression_type"`
	TargetKafkaClusterAlias  string                                             `json:"target_kafka_cluster_alias"`
	TargetKafkaClusterArn    string                                             `json:"target_kafka_cluster_arn"`
	ConsumerGroupReplication []ReplicationInfoListConsumerGroupReplicationState `json:"consumer_group_replication"`
	TopicReplication         []ReplicationInfoListTopicReplicationState         `json:"topic_replication"`
}

type ReplicationInfoListTopicReplication 

type ReplicationInfoListTopicReplication struct {
	// CopyAccessControlListsForTopics: bool, optional
	CopyAccessControlListsForTopics terra.BoolValue `hcl:"copy_access_control_lists_for_topics,attr"`
	// CopyTopicConfigurations: bool, optional
	CopyTopicConfigurations terra.BoolValue `hcl:"copy_topic_configurations,attr"`
	// DetectAndCopyNewTopics: bool, optional
	DetectAndCopyNewTopics terra.BoolValue `hcl:"detect_and_copy_new_topics,attr"`
	// TopicsToExclude: set of string, optional
	TopicsToExclude terra.SetValue[terra.StringValue] `hcl:"topics_to_exclude,attr"`
	// TopicsToReplicate: set of string, required
	TopicsToReplicate terra.SetValue[terra.StringValue] `hcl:"topics_to_replicate,attr" validate:"required"`
}

type ReplicationInfoListTopicReplicationAttributes 

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

func (ReplicationInfoListTopicReplicationAttributes) CopyAccessControlListsForTopics 

func (tr ReplicationInfoListTopicReplicationAttributes) CopyAccessControlListsForTopics() terra.BoolValue

func (ReplicationInfoListTopicReplicationAttributes) CopyTopicConfigurations 

func (tr ReplicationInfoListTopicReplicationAttributes) CopyTopicConfigurations() terra.BoolValue

func (ReplicationInfoListTopicReplicationAttributes) DetectAndCopyNewTopics 

func (tr ReplicationInfoListTopicReplicationAttributes) DetectAndCopyNewTopics() terra.BoolValue

func (ReplicationInfoListTopicReplicationAttributes) InternalRef 

func (tr ReplicationInfoListTopicReplicationAttributes) InternalRef() (terra.Reference, error)

func (ReplicationInfoListTopicReplicationAttributes) InternalTokens 

func (tr ReplicationInfoListTopicReplicationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ReplicationInfoListTopicReplicationAttributes) InternalWithRef 

func (tr ReplicationInfoListTopicReplicationAttributes) InternalWithRef(ref terra.Reference) ReplicationInfoListTopicReplicationAttributes

func (ReplicationInfoListTopicReplicationAttributes) TopicsToExclude 

func (tr ReplicationInfoListTopicReplicationAttributes) TopicsToExclude() terra.SetValue[terra.StringValue]

func (ReplicationInfoListTopicReplicationAttributes) TopicsToReplicate 

func (tr ReplicationInfoListTopicReplicationAttributes) TopicsToReplicate() terra.SetValue[terra.StringValue]

type ReplicationInfoListTopicReplicationState 

type ReplicationInfoListTopicReplicationState struct {
	CopyAccessControlListsForTopics bool     `json:"copy_access_control_lists_for_topics"`
	CopyTopicConfigurations         bool     `json:"copy_topic_configurations"`
	DetectAndCopyNewTopics          bool     `json:"detect_and_copy_new_topics"`
	TopicsToExclude                 []string `json:"topics_to_exclude"`
	TopicsToReplicate               []string `json:"topics_to_replicate"`
}

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

func New 

func New(name string, args Args) *Resource

New creates a new instance of Resource.

func (*Resource) Attributes 

func (amr *Resource) Attributes() awsMskReplicatorAttributes

Attributes returns the attributes for Resource.

func (*Resource) Configuration 

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

Configuration returns the configuration (args) for Resource.

func (*Resource) DependOn 

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

DependOn is used for other resources to depend on Resource.

func (*Resource) Dependencies 

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

Dependencies returns the list of resources Resource depends_on.

func (*Resource) ImportState 

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

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

func (*Resource) LifecycleManagement 

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

LifecycleManagement returns the lifecycle block for Resource.

func (*Resource) LocalName 

func (amr *Resource) LocalName() string

LocalName returns the local name for Resource.

func (*Resource) State 

func (amr *Resource) State() (*awsMskReplicatorState, bool)

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

func (*Resource) StateMust 

func (amr *Resource) StateMust() *awsMskReplicatorState

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

func (*Resource) Type 

func (amr *Resource) Type() string

Type returns the Terraform object type for Resource.

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 (t TimeoutsAttributes) Create() terra.StringValue

func (TimeoutsAttributes) Delete 

func (t TimeoutsAttributes) Delete() terra.StringValue

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 

func (t TimeoutsAttributes) Update() terra.StringValue

type TimeoutsState 

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

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.