BrokerConnection

Undocumented in source.

Constructors

this
this(Client client, TCPConnection conn)
Undocumented in source.

Members

Functions

fetcherMain
void fetcherMain()
Undocumented in source. Be warned that the author may not have intended to support it.
getMetadata
Metadata getMetadata(string[] topics)
Undocumented in source. Be warned that the author may not have intended to support it.
getStartingOffset
long getStartingOffset(string topic, int partition, long offset)
Undocumented in source. Be warned that the author may not have intended to support it.
pusherMain
void pusherMain()
Undocumented in source. Be warned that the author may not have intended to support it.
receiverMain
void receiverMain()
Undocumented in source. Be warned that the author may not have intended to support it.

Properties

addr
NetworkAddress addr [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
consumerRequestBundler
RequestBundler consumerRequestBundler [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
producerRequestBundler
RequestBundler producerRequestBundler [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.

Variables

id
int id;
Undocumented in source.

Meta