QueueBuffer

Undocumented in source.

struct QueueBuffer {

ubyte* buffer;

size_t messageSetSize;

long requestedOffset;

QueueBuffer* next;

this(size_t size);

size_t filled [@property getter];

size_t remaining [@property getter];

ubyte[] filledSlice [@property getter];

void rewind();

long findNextOffset();

}

Constructors

this this(size_t size): Undocumented in source.

Members

Functions

findNextOffset long findNextOffset(): Undocumented in source. Be warned that the author may not have intended to support it.
rewind void rewind(): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

filled size_t filled [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
filledSlice ubyte[] filledSlice [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
remaining size_t remaining [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Variables

buffer ubyte* buffer;
end ubyte* end;: Undocumented in source.
messageSetSize size_t messageSetSize;: Undocumented in source.
next QueueBuffer* next;
p ubyte* p;: Undocumented in source.
requestedOffset long requestedOffset;: Undocumented in source.

Meta

Source

See Implementation

kafkad queue classes

Queue

enums

BufferType

structs

QueueBuffer