Class: AWSCDK::KafkaConnect::CfnConnector::WorkerLogDeliveryProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kafka_connect/cfn_connector.rb

Overview

Workers can send worker logs to different destination types.

This configuration specifies the details of these destinations.

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(cloud_watch_logs: nil, firehose: nil, s3: nil) ⇒ WorkerLogDeliveryProperty

Returns a new instance of WorkerLogDeliveryProperty.

Parameters:



1415
1416
1417
1418
1419
1420
1421
1422
 
# File 'kafka_connect/cfn_connector.rb', line 1415

def initialize(cloud_watch_logs: nil, firehose: nil, s3: nil)
  @cloud_watch_logs = cloud_watch_logs.is_a?(Hash) ? ::AWSCDK::KafkaConnect::CfnConnector::CloudWatchLogsLogDeliveryProperty.new(**cloud_watch_logs.transform_keys(&:to_sym)) : cloud_watch_logs
  Jsii::Type.check_type(@cloud_watch_logs, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19rYWZrYWNvbm5lY3QuQ2ZuQ29ubmVjdG9yLkNsb3VkV2F0Y2hMb2dzTG9nRGVsaXZlcnlQcm9wZXJ0eSJ9XX19")), "cloudWatchLogs") unless @cloud_watch_logs.nil?
  @firehose = firehose.is_a?(Hash) ? ::AWSCDK::KafkaConnect::CfnConnector::FirehoseLogDeliveryProperty.new(**firehose.transform_keys(&:to_sym)) : firehose
  Jsii::Type.check_type(@firehose, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19rYWZrYWNvbm5lY3QuQ2ZuQ29ubmVjdG9yLkZpcmVob3NlTG9nRGVsaXZlcnlQcm9wZXJ0eSJ9XX19")), "firehose") unless @firehose.nil?
  @s3 = s3.is_a?(Hash) ? ::AWSCDK::KafkaConnect::CfnConnector::S3LogDeliveryProperty.new(**s3.transform_keys(&:to_sym)) : s3
  Jsii::Type.check_type(@s3, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19rYWZrYWNvbm5lY3QuQ2ZuQ29ubmVjdG9yLlMzTG9nRGVsaXZlcnlQcm9wZXJ0eSJ9XX19")), "s3") unless @s3.nil?
end

Instance Attribute Details

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

Details about delivering logs to Amazon CloudWatch Logs.

Returns:

See Also:



1428
1429
1430
 
# File 'kafka_connect/cfn_connector.rb', line 1428

def cloud_watch_logs
  @cloud_watch_logs
end

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

Details about delivering logs to Amazon Kinesis Data Firehose.

Returns:

See Also:



1433
1434
1435
 
# File 'kafka_connect/cfn_connector.rb', line 1433

def firehose
  @firehose
end

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

Details about delivering logs to Amazon S3.

Returns:

See Also:



1438
1439
1440
 
# File 'kafka_connect/cfn_connector.rb', line 1438

def s3
  @s3
end

Class Method Details

.jsii_properties ⇒ Object 



1440
1441
1442
1443
1444
1445
1446
 
# File 'kafka_connect/cfn_connector.rb', line 1440

def self.jsii_properties
  {
    :cloud_watch_logs => "cloudWatchLogs",
    :firehose => "firehose",
    :s3 => "s3",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



1448
1449
1450
1451
1452
1453
1454
1455
1456
 
# File 'kafka_connect/cfn_connector.rb', line 1448

def to_jsii
  result = {}
  result.merge!({
    "cloudWatchLogs" => @cloud_watch_logs,
    "firehose" => @firehose,
    "s3" => @s3,
  })
  result.compact
end