KafkaDataProvider::KafkaProducerDataProvider Class Reference

Message-based data provider for Kafka messages. More...

#include <KafkaProducerDataProvider.qc.dox.h>

Inheritance diagram for KafkaDataProvider::KafkaProducerDataProvider:

Public Member Methods
	constructor (KafkaConnection conn, *hash< auto > options)
	Creates the object from constructor options.
hash< DataProvider::DataProviderInfo >	getStaticInfoImpl ()
	Returns data provider static info.
Public Member Methods inherited from KafkaDataProvider::KafkaDataProviderBase
	constructor (KafkaConnection conn)
	Creates the object from a connection object.

Public Attributes
const	ProviderInfo = ...
	Provider info.
const	ConstructorOptions = ...
	Constructor options.

Private Member Methods
auto	doRequestImpl (auto req, *hash< auto > request_options)
	Makes a request and returns the response.
*AbstractDataProviderType	getRequestTypeImpl ()
	Returns the description of a successful request message, if any.
*AbstractDataProviderType	getResponseTypeImpl ()
	Returns the description of a response message, if this object represents a response message.

Detailed Description

Message-based data provider for Kafka messages.

Member Function Documentation

doRequestImpl()

auto KafkaDataProvider::KafkaProducerDataProvider::doRequestImpl ( auto  req, *hash< auto >  request_options  )

private

Makes a request and returns the response.

Parameters

req	the request to serialize and make according to the request type
request_options	the request options; will be processed by validateRequestOptions()

Returns

the response to the request

getRequestTypeImpl()

*AbstractDataProviderType KafkaDataProvider::KafkaProducerDataProvider::getRequestTypeImpl ( )

private

Returns the description of a successful request message, if any.

Returns

the request type for this provider

Note

only called if the provider supports the request / response API

getResponseTypeImpl()

*AbstractDataProviderType KafkaDataProvider::KafkaProducerDataProvider::getResponseTypeImpl ( )

private

Returns the description of a response message, if this object represents a response message.

Returns

the response type for this response message

Note

only called if the provider supports the request / response API

---

The documentation for this class was generated from the following file:

• doxygen/qlib/KafkaDataProvider/KafkaProducerDataProvider.qc.dox.h