List of all items

Structs

• client::KrabkaClient
• client::KrabkaClientBuilder
• connect_client::ConnectClient
• connect_client::ConnectTrailerError
• connect_client::EndStream
• messaging::CloudEvent
• messaging::Filter
• messaging::Inbound
• messaging::MessageStream
• messaging::MessagingClient
• messaging::PublishOptions
• messaging::RecordResult
• pb::ErrorInfo
• pb::Header
• pb::Inbound
• pb::QueueAckEntry
• pb::QueueAckResult
• pb::QueueAcknowledgeRequest
• pb::QueueAcknowledgeResponse
• pb::QueueAcquireRequest
• pb::QueueAcquireResponse
• pb::QueueRenewRequest
• pb::QueueRenewResponse
• pb::QueuedMessage
• pb::Record
• pb::RecordResult
• pb::SchemaSelector
• pb::SendAck
• pb::SendRequest
• pb::SendResponse
• pb::StructuredValue
• pb::SubscribeAck
• pb::SubscribeFrame
• pb::SubscribeStart
• stubs::AcquireOptions
• stubs::AuthClient
• stubs::BlobClient
• stubs::DatabaseClient
• stubs::QueueAckEntry
• stubs::QueueAckResult
• stubs::QueueAcquireResult
• stubs::QueueMessage
• stubs::QueueRenewEntry
• stubs::QueuesClient

Enums

• connect_client::ConnectClientError
• connect_client::envelope::Frame
• error::KrabkaError
• pb::Acks
• pb::QueueAckType
• pb::SchemaFormat
• pb::record::Body
• pb::subscribe_frame::Frame
• stubs::QueueAckType

Functions

• connect_client::envelope::decode_next
• connect_client::envelope::decode_one
• connect_client::envelope::encode

Constants

• connect_client::envelope::END_STREAM_FLAGS
• connect_client::envelope::MESSAGE_FLAGS