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
hash< DataProvider::DataProviderInfo >	getStaticInfoImpl ()
	Returns data provider static info.
auto	doRequestImpl (auto req, soft< hash< auto > > request_options)
	Makes a request and returns the response.
soft< AbstractDataProviderType >	getRequestTypeImpl ()
	Returns the description of a successful request message, if any.
soft< AbstractDataProviderType >	getResponseTypeImpl ()
	Returns the description of a response message, if this object represents a response message.
Public Member Methods inherited from KafkaDataProvider::KafkaDataProviderBase
void	constructor (KafkaConnection conn)
	Creates the object from a connection object.

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

Detailed Description

Message-based data provider for Kafka messages.

Member Function Documentation

doRequestImpl()

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

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()

soft< AbstractDataProviderType > KafkaDataProvider::KafkaProducerDataProvider::getRequestTypeImpl

(

)

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()

soft< AbstractDataProviderType > KafkaDataProvider::KafkaProducerDataProvider::getResponseTypeImpl

(

)

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