/** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #pragma once #include #include #include #include #include #include namespace Aws { namespace Utils { namespace Json { class JsonValue; class JsonView; } // namespace Json } // namespace Utils namespace Lambda { namespace Model { /** *

The self-managed Apache Kafka cluster for your event source.

See * Also:

AWS * API Reference

*/ class SelfManagedEventSource { public: AWS_LAMBDA_API SelfManagedEventSource(); AWS_LAMBDA_API SelfManagedEventSource(Aws::Utils::Json::JsonView jsonValue); AWS_LAMBDA_API SelfManagedEventSource& operator=(Aws::Utils::Json::JsonView jsonValue); AWS_LAMBDA_API Aws::Utils::Json::JsonValue Jsonize() const; /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline const Aws::Map>& GetEndpoints() const{ return m_endpoints; } /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline bool EndpointsHasBeenSet() const { return m_endpointsHasBeenSet; } /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline void SetEndpoints(const Aws::Map>& value) { m_endpointsHasBeenSet = true; m_endpoints = value; } /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline void SetEndpoints(Aws::Map>&& value) { m_endpointsHasBeenSet = true; m_endpoints = std::move(value); } /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline SelfManagedEventSource& WithEndpoints(const Aws::Map>& value) { SetEndpoints(value); return *this;} /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline SelfManagedEventSource& WithEndpoints(Aws::Map>&& value) { SetEndpoints(std::move(value)); return *this;} /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline SelfManagedEventSource& AddEndpoints(const EndPointType& key, const Aws::Vector& value) { m_endpointsHasBeenSet = true; m_endpoints.emplace(key, value); return *this; } /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline SelfManagedEventSource& AddEndpoints(EndPointType&& key, const Aws::Vector& value) { m_endpointsHasBeenSet = true; m_endpoints.emplace(std::move(key), value); return *this; } /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline SelfManagedEventSource& AddEndpoints(const EndPointType& key, Aws::Vector&& value) { m_endpointsHasBeenSet = true; m_endpoints.emplace(key, std::move(value)); return *this; } /** *

The list of bootstrap servers for your Kafka brokers in the following format: * "KAFKA_BOOTSTRAP_SERVERS": * ["abc.xyz.com:xxxx","abc2.xyz.com:xxxx"].

*/ inline SelfManagedEventSource& AddEndpoints(EndPointType&& key, Aws::Vector&& value) { m_endpointsHasBeenSet = true; m_endpoints.emplace(std::move(key), std::move(value)); return *this; } private: Aws::Map> m_endpoints; bool m_endpointsHasBeenSet = false; }; } // namespace Model } // namespace Lambda } // namespace Aws