Struct KafkaSchemaRegistryConfigBuilder

#[non_exhaustive]
pub struct KafkaSchemaRegistryConfigBuilder { /* private fields */ }

A builder for KafkaSchemaRegistryConfig.

Implementations

impl KafkaSchemaRegistryConfigBuilder

pub fn schema_registry_uri(self, input: impl Into<String>) -> Self

The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

• For Glue schema registries, use the ARN of the registry.

• For Confluent schema registries, use the URL of the registry.

pub fn set_schema_registry_uri(self, input: Option<String>) -> Self

The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

• For Glue schema registries, use the ARN of the registry.

• For Confluent schema registries, use the URL of the registry.

pub fn get_schema_registry_uri(&self) -> &Option<String>

The URI for your schema registry. The correct URI format depends on the type of schema registry you're using.

• For Glue schema registries, use the ARN of the registry.

• For Confluent schema registries, use the URL of the registry.

pub fn event_record_format(self, input: SchemaRegistryEventRecordFormat) -> Self

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.

pub fn set_event_record_format( self, input: Option<SchemaRegistryEventRecordFormat>, ) -> Self

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.

pub fn get_event_record_format( &self, ) -> &Option<SchemaRegistryEventRecordFormat>

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.

pub fn access_configs(self, input: KafkaSchemaRegistryAccessConfig) -> Self

Appends an item to access_configs.

To override the contents of this collection use set_access_configs.

An array of access configuration objects that tell Lambda how to authenticate with your schema registry.

pub fn set_access_configs( self, input: Option<Vec<KafkaSchemaRegistryAccessConfig>>, ) -> Self

An array of access configuration objects that tell Lambda how to authenticate with your schema registry.

pub fn get_access_configs( &self, ) -> &Option<Vec<KafkaSchemaRegistryAccessConfig>>

An array of access configuration objects that tell Lambda how to authenticate with your schema registry.

pub fn schema_validation_configs( self, input: KafkaSchemaValidationConfig, ) -> Self

Appends an item to schema_validation_configs.

To override the contents of this collection use set_schema_validation_configs.

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

pub fn set_schema_validation_configs( self, input: Option<Vec<KafkaSchemaValidationConfig>>, ) -> Self

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

pub fn get_schema_validation_configs( &self, ) -> &Option<Vec<KafkaSchemaValidationConfig>>

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

pub fn build(self) -> KafkaSchemaRegistryConfig

Consumes the builder and constructs a KafkaSchemaRegistryConfig.

Trait Implementations

impl Clone for KafkaSchemaRegistryConfigBuilder

fn clone(&self) -> KafkaSchemaRegistryConfigBuilder

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaSchemaRegistryConfigBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for KafkaSchemaRegistryConfigBuilder

fn default() -> KafkaSchemaRegistryConfigBuilder

Returns the “default value” for a type.

impl PartialEq for KafkaSchemaRegistryConfigBuilder

fn eq(&self, other: &KafkaSchemaRegistryConfigBuilder) -> bool

Tests for self and other values to be equal, and is used by ==.

const fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for KafkaSchemaRegistryConfigBuilder