[][src]Module rdkafka::util

Utility functions and types.

Structs

TokioRuntimefeature="tokio"

An AsyncRuntime implementation backed by Tokio.

Enums

Timeout

Specifies a timeout for a Kafka operation.

Traits

AsyncRuntime

An abstraction over asynchronous runtimes.

IntoOpaque

Converts Rust data to and from raw pointers.

Functions

bytes_cstr_to_owned

Converts a byte array representing a C string into a String.

cstr_to_owned

Converts a C string into a String.

current_time_millis

Returns the current time in milliseconds since the Unix epoch.

get_rdkafka_version

Returns a tuple representing the version of librdkafka in hexadecimal and string format.

millis_to_epoch

Converts the given time to the number of milliseconds since the Unix epoch.