Class: AWSCDK::MSK::CfnReplicator::KafkaClusterProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
msk/cfn_replicator.rb

Overview

Information about Kafka Cluster to be used as source / target for replication.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(amazon_msk_cluster: nil, apache_kafka_cluster: nil, client_authentication: nil, encryption_in_transit: nil, vpc_config: nil) ⇒ KafkaClusterProperty

Returns a new instance of KafkaClusterProperty.

Parameters:



1007
1008
1009
1010
1011
1012
1013
1014
1015
1016
1017
1018
 
# File 'msk/cfn_replicator.rb', line 1007

def initialize(amazon_msk_cluster: nil, apache_kafka_cluster: nil, client_authentication: nil, encryption_in_transit: nil, vpc_config: nil)
  @amazon_msk_cluster = amazon_msk_cluster.is_a?(Hash) ? ::AWSCDK::MSK::CfnReplicator::AmazonMSKClusterProperty.new(**amazon_msk_cluster.transform_keys(&:to_sym)) : amazon_msk_cluster
  Jsii::Type.check_type(@amazon_msk_cluster, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19tc2suQ2ZuUmVwbGljYXRvci5BbWF6b25Nc2tDbHVzdGVyUHJvcGVydHkifV19fQ==")), "amazonMskCluster") unless @amazon_msk_cluster.nil?
  @apache_kafka_cluster = apache_kafka_cluster.is_a?(Hash) ? ::AWSCDK::MSK::CfnReplicator::ApacheKafkaClusterProperty.new(**apache_kafka_cluster.transform_keys(&:to_sym)) : apache_kafka_cluster
  Jsii::Type.check_type(@apache_kafka_cluster, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19tc2suQ2ZuUmVwbGljYXRvci5BcGFjaGVLYWZrYUNsdXN0ZXJQcm9wZXJ0eSJ9XX19")), "apacheKafkaCluster") unless @apache_kafka_cluster.nil?
  @client_authentication = client_authentication.is_a?(Hash) ? ::AWSCDK::MSK::CfnReplicator::KafkaClusterClientAuthenticationProperty.new(**client_authentication.transform_keys(&:to_sym)) : client_authentication
  Jsii::Type.check_type(@client_authentication, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19tc2suQ2ZuUmVwbGljYXRvci5LYWZrYUNsdXN0ZXJDbGllbnRBdXRoZW50aWNhdGlvblByb3BlcnR5In1dfX0=")), "clientAuthentication") unless @client_authentication.nil?
  @encryption_in_transit = encryption_in_transit.is_a?(Hash) ? ::AWSCDK::MSK::CfnReplicator::KafkaClusterEncryptionInTransitProperty.new(**encryption_in_transit.transform_keys(&:to_sym)) : encryption_in_transit
  Jsii::Type.check_type(@encryption_in_transit, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19tc2suQ2ZuUmVwbGljYXRvci5LYWZrYUNsdXN0ZXJFbmNyeXB0aW9uSW5UcmFuc2l0UHJvcGVydHkifV19fQ==")), "encryptionInTransit") unless @encryption_in_transit.nil?
  @vpc_config = vpc_config.is_a?(Hash) ? ::AWSCDK::MSK::CfnReplicator::KafkaClusterClientVPCConfigProperty.new(**vpc_config.transform_keys(&:to_sym)) : vpc_config
  Jsii::Type.check_type(@vpc_config, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19tc2suQ2ZuUmVwbGljYXRvci5LYWZrYUNsdXN0ZXJDbGllbnRWcGNDb25maWdQcm9wZXJ0eSJ9XX19")), "vpcConfig") unless @vpc_config.nil?
end

Instance Attribute Details

#amazon_msk_cluster ⇒ AWSCDK::IResolvable, ... (readonly)

Details of an Amazon MSK Cluster.

Returns:

See Also:



1024
1025
1026
 
# File 'msk/cfn_replicator.rb', line 1024

def amazon_msk_cluster
  @amazon_msk_cluster
end

#apache_kafka_cluster ⇒ AWSCDK::IResolvable, ... (readonly)

Details of an Apache Kafka cluster.

Returns:

See Also:



1029
1030
1031
 
# File 'msk/cfn_replicator.rb', line 1029

def apache_kafka_cluster
  @apache_kafka_cluster
end

#client_authentication ⇒ AWSCDK::IResolvable, ... (readonly)

Details of the client authentication used by the Apache Kafka cluster.

Returns:

See Also:



1034
1035
1036
 
# File 'msk/cfn_replicator.rb', line 1034

def client_authentication
  @client_authentication
end

#encryption_in_transit ⇒ AWSCDK::IResolvable, ... (readonly)

Details of encryption in transit to the Apache Kafka cluster.

Returns:

See Also:



1039
1040
1041
 
# File 'msk/cfn_replicator.rb', line 1039

def encryption_in_transit
  @encryption_in_transit
end

#vpc_config ⇒ AWSCDK::IResolvable, ... (readonly)

Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

Returns:

See Also:



1044
1045
1046
 
# File 'msk/cfn_replicator.rb', line 1044

def vpc_config
  @vpc_config
end

Class Method Details

.jsii_properties ⇒ Object 



1046
1047
1048
1049
1050
1051
1052
1053
1054
 
# File 'msk/cfn_replicator.rb', line 1046

def self.jsii_properties
  {
    :amazon_msk_cluster => "amazonMskCluster",
    :apache_kafka_cluster => "apacheKafkaCluster",
    :client_authentication => "clientAuthentication",
    :encryption_in_transit => "encryptionInTransit",
    :vpc_config => "vpcConfig",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



1056
1057
1058
1059
1060
1061
1062
1063
1064
1065
1066
 
# File 'msk/cfn_replicator.rb', line 1056

def to_jsii
  result = {}
  result.merge!({
    "amazonMskCluster" => @amazon_msk_cluster,
    "apacheKafkaCluster" => @apache_kafka_cluster,
    "clientAuthentication" => @client_authentication,
    "encryptionInTransit" => @encryption_in_transit,
    "vpcConfig" => @vpc_config,
  })
  result.compact
end