Class: AWSCDK::LambdaEventSources::ConfluentSchemaRegistryProps

Inherits:
AWSCDK::Lambda::SchemaRegistryProps
  • Object
show all
Defined in:
lambda_event_sources/confluent_schema_registry_props.rb

Overview

Properties for confluent schema registry configuration.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(event_record_format:, schema_validation_configs:, authentication_type:, schema_registry_uri:, secret:) ⇒ ConfluentSchemaRegistryProps

Returns a new instance of ConfluentSchemaRegistryProps.

Parameters:



12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 12

def initialize(event_record_format:, schema_validation_configs:, authentication_type:, schema_registry_uri:, secret:)
  @event_record_format = event_record_format
  Jsii::Type.check_type(@event_record_format, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkV2ZW50UmVjb3JkRm9ybWF0In0=")), "eventRecordFormat")
  @schema_validation_configs = schema_validation_configs.is_a?(Array) ? schema_validation_configs.map { |jsii_v0| jsii_v0.is_a?(Hash) ? ::AWSCDK::Lambda::KafkaSchemaValidationConfig.new(**jsii_v0.transform_keys(&:to_sym)) : jsii_v0 } : schema_validation_configs
  Jsii::Type.check_type(@schema_validation_configs, JSON.parse(Base64.strict_decode64("eyJjb2xsZWN0aW9uIjp7ImVsZW1lbnR0eXBlIjp7ImZxbiI6ImF3cy1jZGstbGliLmF3c19sYW1iZGEuS2Fma2FTY2hlbWFWYWxpZGF0aW9uQ29uZmlnIn0sImtpbmQiOiJhcnJheSJ9fQ==")), "schemaValidationConfigs")
  @authentication_type = authentication_type
  Jsii::Type.check_type(@authentication_type, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfbGFtYmRhLkthZmthU2NoZW1hUmVnaXN0cnlBY2Nlc3NDb25maWdUeXBlIn0=")), "authenticationType")
  @schema_registry_uri = schema_registry_uri
  Jsii::Type.check_type(@schema_registry_uri, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "schemaRegistryUri")
  @secret = secret
  Jsii::Type.check_type(@secret, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc2VjcmV0c21hbmFnZXIuSVNlY3JldCJ9")), "secret")
end

Instance Attribute Details

#authentication_type ⇒ AWSCDK::Lambda::KafkaSchemaRegistryAccessConfigType (readonly)

Note:

Default: none

The type of authentication for schema registry credentials.

Returns:



42
43
44
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 42

def authentication_type
  @authentication_type
end

#event_record_format ⇒ AWSCDK::Lambda::EventRecordFormat (readonly)

Note:

Default: - none

The record format that Lambda delivers to your function after schema validation.

  • Choose JSON to have Lambda deliver the record to your function as a standard JSON object.
  • Choose SOURCE to have Lambda deliver the record to your function in its original source format. Lambda removes all schema metadata, such as the schema ID, before sending the record to your function.

Returns:



32
33
34
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 32

def event_record_format
  @event_record_format
end

#schema_registry_uri ⇒ String (readonly)

Note:

Default: - none

The URI for your schema registry.

Returns:

  • (String) 


47
48
49
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 47

def schema_registry_uri
  @schema_registry_uri
end

#schema_validation_configs ⇒ Array<AWSCDK::Lambda::KafkaSchemaValidationConfig> (readonly)

Note:

Default: - none

An array of schema validation configuration objects, which tell Lambda the message attributes you want to validate and filter using your schema registry.

Returns:



37
38
39
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 37

def schema_validation_configs
  @schema_validation_configs
end

#secret ⇒ AWSCDK::SecretsManager::ISecret (readonly)

Note:

Default: none

The secret with the schema registry credentials.

Returns:



52
53
54
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 52

def secret
  @secret
end

Class Method Details

.jsii_properties ⇒ Object 



54
55
56
57
58
59
60
61
62
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 54

def self.jsii_properties
  {
    :event_record_format => "eventRecordFormat",
    :schema_validation_configs => "schemaValidationConfigs",
    :authentication_type => "authenticationType",
    :schema_registry_uri => "schemaRegistryUri",
    :secret => "secret",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lambda_event_sources/confluent_schema_registry_props.rb', line 64

def to_jsii
  result = {}
  result.merge!(super)
  result.merge!({
    "eventRecordFormat" => @event_record_format,
    "schemaValidationConfigs" => @schema_validation_configs,
    "authenticationType" => @authentication_type,
    "schemaRegistryUri" => @schema_registry_uri,
    "secret" => @secret,
  })
  result.compact
end