rdkafkad.iodriver0

Members

Aliases

_IODelegate

alias _IODelegate = void delegate()

Undocumented in source.

Classes

_IODelegateClass

class _IODelegateClass

Undocumented in source.

Enums

IO

eponymoustemplate IO(string code)

Undocumented in source.

IO

eponymoustemplate IO(string code)

Undocumented in source.

Functions

_io_handler

void _io_handler()

Undocumented in source. Be warned that the author may not have intended to support it.

Imports

Isolated (from vibe.core.concurrency)

public import vibe.core.concurrency : receiveCompat, Isolated;

Undocumented in source.

Task (from vibe.core.task)

public import vibe.core.task : Task;

Undocumented in source.

receiveCompat (from vibe.core.concurrency)

public import vibe.core.concurrency : receiveCompat, Isolated;

Undocumented in source.

runWorkerTaskH (from vibe.core.core)

public import vibe.core.core : runWorkerTaskH;

Undocumented in source.

Static variables

_io_task

Task _io_task;

Undocumented in source.

Variables

have_vibed

enum bool have_vibed;

Undocumented in source.

have_vibed

enum bool have_vibed;

Undocumented in source.

have_vibed

enum bool have_vibed;

Undocumented in source.

• config
• handlers
• iodriver
• iodriver0
• metadata
• topic

• ConsumeCb
• DeliveryReportCb
• EventCb
• OffsetCommitCb
• PartitionerCb
• PartitionerKeyPointerCb
• RebalanceCb
• SocketCb

• ErrorCode

• err2str
• getDebugContexts
• versionStr
• version_
• waitDestroyed

• RD_KAFKA_VERSION

• Event
• Message