mooncakes.io

README
- ::is_retriableBrokerError::is_retriable
- ::nameBrokerError::name
E
ProtocolError
E
SaslError
E
TransportError
- ::newBackoff::new
- ::next_msBackoff::next_ms
- ::resetBackoff::reset
- ::newBootstrapServers::new
- ::nextBootstrapServers::next
- ::authenticateBrokerConnection::authenticate
- ::check_api_versionsBrokerConnection::check_api_versions
- ::closeBrokerConnection::close
- ::connectBrokerConnection::connect
- ::fetchBrokerConnection::fetch
- ::fetch_metadataBrokerConnection::fetch_metadata
- ::list_offsetsBrokerConnection::list_offsets
- ::note_throttleBrokerConnection::note_throttle
- ::produceBrokerConnection::produce
- ::requestBrokerConnection::request
- ::request_rawBrokerConnection::request_raw
T
BrokerInfo
- ::read_exactlyBrokerStream::read_exactly
- ::shutdownBrokerStream::shutdown
- ::writeBrokerStream::write
- ::bootstrap_addressesCommonConfig::bootstrap_addresses
- ::newCommonConfig::new
- ::validateCommonConfig::validate
- ::closeConsumer::close
- ::connectConsumer::connect
- ::connect_with_configConsumer::connect_with_config
- ::pollConsumer::poll
- ::newConsumerConfig::new
- ::after_msDeadline::after_ms
- ::expiredDeadline::expired
- ::remaining_msDeadline::remaining_ms
T
FetchPartitionResult
- ::parseHostPort::parse
T
Metadata
T
PartitionInfo
T
PartitionState
T
ProducePartitionResult
- ::closeProducer::close
- ::connectProducer::connect
- ::connect_with_configProducer::connect_with_config
- ::sendProducer::send
- ::newProducerConfig::new
T
Record
T
SaslAuthenticateResult
T
SaslConfig
T
SaslHandshakeResult
T
SaslMechanism
- ::parseScramServerFirst::parse
T
SecurityProtocol
T
StartFrom
- ::newTlsClientOptions::new
T
TopicMetadata
- ::from_bytesUuid::from_bytes
- ::parseUuid::parse
- ::to_bytesUuid::to_bytes
- ::zeroUuid::zero
V
API_API_VERSIONS
V
API_FETCH
V
API_LIST_OFFSETS
V
API_METADATA
V
API_PRODUCE
V
backoff_ms
V
connect_bootstrap
V
decode_api_versions_response
V
decode_fetch_response
V
decode_list_offsets_response
V
decode_metadata_response
V
decode_produce_response
V
decode_record_batches
V
decode_sasl_authenticate_response
V
decode_sasl_handshake_response
V
encode_api_versions_request
V
encode_fetch_request
V
encode_list_offsets_request
V
encode_metadata_request
V
encode_produce_request
V
encode_record_batch
V
encode_request
V
encode_sasl_authenticate_request
V
encode_sasl_handshake_request
V
error_name
V
error_retriable
V
scram_auth_message
V
scram_client_proof_b64
V
scram_escape_username
V
scram_pbkdf2_hmac
V
scram_salted_password
V
scram_server_final
V
scram_server_signature_b64
V
scram_verify_client_proof

daqing/moonkafka/buf does not have a README file

DecodeError

pub(all) suberror DecodeError {
  UnexpectedEof
  Malformed(String)
}

Decoder

source

pub struct Decoder {
  data : Bytes
  pos : Int
}

Decoder::new

source

fn Decoder::new(data : Bytes, start? : Int) -> Decoder

Decoder::read_bool

source

fn Decoder::read_bool(self : Decoder) -> Bool raise DecodeError

Decoder::read_byte

source

fn Decoder::read_byte(self : Decoder) -> Byte raise DecodeError

Decoder::read_bytes

source

fn Decoder::read_bytes(self : Decoder, n : Int) -> Bytes raise DecodeError

Decoder::read_compact_len

source

fn Decoder::read_compact_len(self : Decoder) -> Int raise DecodeError

Compact length prefix (value + 1); returns -1 for the null marker.

Decoder::read_compact_nullable_string

source

fn Decoder::read_compact_nullable_string(self : Decoder) -> String? raise DecodeError

Decoder::read_compact_string

source

fn Decoder::read_compact_string(self : Decoder) -> String raise DecodeError

Decoder::read_i16

source

fn Decoder::read_i16(self : Decoder) -> Int raise DecodeError

Decoder::read_i32

source

fn Decoder::read_i32(self : Decoder) -> Int raise DecodeError

Decoder::read_i64

source

fn Decoder::read_i64(self : Decoder) -> Int64 raise DecodeError

Decoder::read_i8

source

fn Decoder::read_i8(self : Decoder) -> Int raise DecodeError

Decoder::read_uvarint

source

fn Decoder::read_uvarint(self : Decoder) -> Int raise DecodeError

Unsigned LEB128 varint.

Decoder::read_varint

source

fn Decoder::read_varint(self : Decoder) -> Int raise DecodeError

Zig-zag varint.

Decoder::read_varlong

source

fn Decoder::read_varlong(self : Decoder) -> Int64 raise DecodeError

Zig-zag varlong.

Decoder::remaining

source

fn Decoder::remaining(self : Decoder) -> Int

Decoder::skip

source

fn Decoder::skip(self : Decoder, n : Int) -> Unit raise DecodeError

Skip n bytes, raising on overrun.

Decoder::skip_tag_buffer

source

fn Decoder::skip_tag_buffer(self : Decoder) -> Unit raise DecodeError

Read and discard a tag buffer.

Encoder

source

pub struct Encoder {
  buf : Array[Byte]
}

Encoder::new

source

fn Encoder::new() -> Encoder

Encoder::to_bytes

source

fn Encoder::to_bytes(self : Encoder) -> Bytes

Encoder::write_bool

source

fn Encoder::write_bool(self : Encoder, v : Bool) -> Unit

Encoder::write_byte

source

fn Encoder::write_byte(self : Encoder, b : Byte) -> Unit

Encoder::write_bytes

source

fn Encoder::write_bytes(self : Encoder, b : Bytes) -> Unit

Encoder::write_compact_len

source

fn Encoder::write_compact_len(self : Encoder, n : Int) -> Unit

Compact array/bytes length: count + 1 as unsigned varint.

Encoder::write_compact_nullable_string

source

fn Encoder::write_compact_nullable_string(self : Encoder, s : String?) -> Unit

Encoder::write_compact_string

source

fn Encoder::write_compact_string(self : Encoder, s : String) -> Unit

Encoder::write_i16

source

fn Encoder::write_i16(self : Encoder, v : Int) -> Unit

Encoder::write_i32

source

fn Encoder::write_i32(self : Encoder, v : Int) -> Unit

Encoder::write_i64

source

fn Encoder::write_i64(self : Encoder, v : Int64) -> Unit

Encoder::write_i8

source

fn Encoder::write_i8(self : Encoder, v : Int) -> Unit

Encoder::write_nullable_string

source

fn Encoder::write_nullable_string(self : Encoder, s : String?) -> Unit

Legacy NULLABLE_STRING: INT16 length, -1 = null.

Encoder::write_tag_buffer

source

fn Encoder::write_tag_buffer(self : Encoder) -> Unit

Empty tag buffer.

Encoder::write_tagged_fields

source

fn Encoder::write_tagged_fields(self : Encoder, tags : Array[(Int, Bytes)]) -> Unit

Tag buffer with the given tagged fields. Count, tag numbers, and payload sizes are plain unsigned varints (not compact +1). Fields are written in ascending tag order as the protocol requires; tag numbers must be unique.

Encoder::write_uvarint

source

fn Encoder::write_uvarint(self : Encoder, v : UInt) -> Unit

Unsigned LEB128 varint.

Encoder::write_varint

source

fn Encoder::write_varint(self : Encoder, v : Int) -> Unit

Zig-zag varint (used inside record batches).

Encoder::write_varlong

source

fn Encoder::write_varlong(self : Encoder, v : Int64) -> Unit

Zig-zag varlong (used inside record batches).

Source Files

buf.mbt

README
- ::is_retriableBrokerError::is_retriable
- ::nameBrokerError::name
E
ProtocolError
E
SaslError
E
TransportError
- ::newBackoff::new
- ::next_msBackoff::next_ms
- ::resetBackoff::reset
- ::newBootstrapServers::new
- ::nextBootstrapServers::next
- ::authenticateBrokerConnection::authenticate
- ::check_api_versionsBrokerConnection::check_api_versions
- ::closeBrokerConnection::close
- ::connectBrokerConnection::connect
- ::fetchBrokerConnection::fetch
- ::fetch_metadataBrokerConnection::fetch_metadata
- ::list_offsetsBrokerConnection::list_offsets
- ::note_throttleBrokerConnection::note_throttle
- ::produceBrokerConnection::produce
- ::requestBrokerConnection::request
- ::request_rawBrokerConnection::request_raw
T
BrokerInfo
- ::read_exactlyBrokerStream::read_exactly
- ::shutdownBrokerStream::shutdown
- ::writeBrokerStream::write
- ::bootstrap_addressesCommonConfig::bootstrap_addresses
- ::newCommonConfig::new
- ::validateCommonConfig::validate
- ::closeConsumer::close
- ::connectConsumer::connect
- ::connect_with_configConsumer::connect_with_config
- ::pollConsumer::poll
- ::newConsumerConfig::new
- ::after_msDeadline::after_ms
- ::expiredDeadline::expired
- ::remaining_msDeadline::remaining_ms
T
FetchPartitionResult
- ::parseHostPort::parse
T
Metadata
T
PartitionInfo
T
PartitionState
T
ProducePartitionResult
- ::closeProducer::close
- ::connectProducer::connect
- ::connect_with_configProducer::connect_with_config
- ::sendProducer::send
- ::newProducerConfig::new
T
Record
T
SaslAuthenticateResult
T
SaslConfig
T
SaslHandshakeResult
T
SaslMechanism
- ::parseScramServerFirst::parse
T
SecurityProtocol
T
StartFrom
- ::newTlsClientOptions::new
T
TopicMetadata
- ::from_bytesUuid::from_bytes
- ::parseUuid::parse
- ::to_bytesUuid::to_bytes
- ::zeroUuid::zero
V
API_API_VERSIONS
V
API_FETCH
V
API_LIST_OFFSETS
V
API_METADATA
V
API_PRODUCE
V
backoff_ms
V
connect_bootstrap
V
decode_api_versions_response
V
decode_fetch_response
V
decode_list_offsets_response
V
decode_metadata_response
V
decode_produce_response
V
decode_record_batches
V
decode_sasl_authenticate_response
V
decode_sasl_handshake_response
V
encode_api_versions_request
V
encode_fetch_request
V
encode_list_offsets_request
V
encode_metadata_request
V
encode_produce_request
V
encode_record_batch
V
encode_request
V
encode_sasl_authenticate_request
V
encode_sasl_handshake_request
V
error_name
V
error_retriable
V
scram_auth_message
V
scram_client_proof_b64
V
scram_escape_username
V
scram_pbkdf2_hmac
V
scram_salted_password
V
scram_server_final
V
scram_server_signature_b64
V
scram_verify_client_proof

Site source Report issue Packages Build queue Skills Statistics

#DecodeError

#Decoder

#Decoder::new

#Decoder::read_bool

#Decoder::read_byte

#Decoder::read_bytes

#Decoder::read_compact_len

#Decoder::read_compact_nullable_string

#Decoder::read_compact_string

#Decoder::read_i16

#Decoder::read_i32

#Decoder::read_i64

#Decoder::read_i8

#Decoder::read_uvarint

#Decoder::read_varint

#Decoder::read_varlong

#Decoder::remaining

#Decoder::skip

#Decoder::skip_tag_buffer

#Encoder

#Encoder::new

#Encoder::to_bytes

#Encoder::write_bool

#Encoder::write_byte

#Encoder::write_bytes

#Encoder::write_compact_len

#Encoder::write_compact_nullable_string

#Encoder::write_compact_string

#Encoder::write_i16

#Encoder::write_i32

#Encoder::write_i64

#Encoder::write_i8

#Encoder::write_nullable_string

#Encoder::write_tag_buffer

#Encoder::write_tagged_fields

#Encoder::write_uvarint

#Encoder::write_varint

#Encoder::write_varlong

Source Files

DecodeError

Decoder

Decoder::new

Decoder::read_bool

Decoder::read_byte

Decoder::read_bytes

Decoder::read_compact_len

Decoder::read_compact_nullable_string

Decoder::read_compact_string

Decoder::read_i16

Decoder::read_i32

Decoder::read_i64

Decoder::read_i8

Decoder::read_uvarint

Decoder::read_varint

Decoder::read_varlong

Decoder::remaining

Decoder::skip

Decoder::skip_tag_buffer

Encoder

Encoder::new

Encoder::to_bytes

Encoder::write_bool

Encoder::write_byte

Encoder::write_bytes

Encoder::write_compact_len

Encoder::write_compact_nullable_string

Encoder::write_compact_string

Encoder::write_i16

Encoder::write_i32

Encoder::write_i64

Encoder::write_i8

Encoder::write_nullable_string

Encoder::write_tag_buffer

Encoder::write_tagged_fields

Encoder::write_uvarint

Encoder::write_varint

Encoder::write_varlong