Serializer

Undocumented in source.

Constructors

this
this(TCPConnection stream, size_t chunkSize)
Undocumented in source.

Members

Functions

check
void check(size_t needed)
Undocumented in source. Be warned that the author may not have intended to support it.
fetchRequest_v0
void fetchRequest_v0(int correlationId, string clientId, Configuration config, RequestBundler requestBundler)
Undocumented in source. Be warned that the author may not have intended to support it.
flush
void flush()
Undocumented in source. Be warned that the author may not have intended to support it.
metadataRequest_v0
void metadataRequest_v0(int correlationId, string clientId, string[] topics)
Undocumented in source. Be warned that the author may not have intended to support it.
offsetRequest_v0
void offsetRequest_v0(int correlationId, string clientId, OffsetRequestParams_v0 params)
Undocumented in source. Be warned that the author may not have intended to support it.
produceRequest_v0
void produceRequest_v0(int correlationId, string clientId, Configuration config, RequestBundler requestBundler)
Undocumented in source. Be warned that the author may not have intended to support it.
serialize
void serialize(byte s)
Undocumented in source. Be warned that the author may not have intended to support it.
serialize
void serialize(T s)
Undocumented in source. Be warned that the author may not have intended to support it.
serialize
void serialize(string s)
Undocumented in source. Be warned that the author may not have intended to support it.
serialize
void serialize(const(ubyte)[] s)
Undocumented in source. Be warned that the author may not have intended to support it.
serialize
void serialize(T[] s)
Undocumented in source. Be warned that the author may not have intended to support it.
serialize
void serialize(T s)
Undocumented in source. Be warned that the author may not have intended to support it.
serializeSlice
void serializeSlice(const(ubyte)[] s)
Undocumented in source. Be warned that the author may not have intended to support it.

Meta