List of all items

Structs

• batch::BatchHeader
• batch::BatchIterator
• batch::BatchIteratorWithOffsets
• batch::BatchMessageHeader
• batch::BatchMessageView
• batch::BatchMessageViewWithOffsets
• batch::BatchRef
• consensus::CommitHeader
• consensus::DoViewChangeHeader
• consensus::EvictionHeader
• consensus::ForwardLogoutHeader
• consensus::ForwardLogoutResultHeader
• consensus::ForwardRegisterHeader
• consensus::ForwardRegisterResultHeader
• consensus::GenericHeader
• consensus::PrepareHeader
• consensus::PrepareOkHeader
• consensus::RepairPrepareHeader
• consensus::RepairRangeReplyHeader
• consensus::ReplyHeader
• consensus::RequestHeader
• consensus::RequestPreparesHeader
• consensus::RequestStartViewHeader
• consensus::RequestStateChunkHeader
• consensus::RequestStateTransferHeader
• consensus::RoutedRequestHeader
• consensus::StartViewChangeHeader
• consensus::StartViewHeader
• consensus::StateChunkHeader
• consensus::StateTransferTargetHeader
• dispatch::CommandMeta
• framing::RequestFrame
• framing::ResponseFrame
• primitives::consumer::WireConsumer
• primitives::identifier::WireName
• primitives::options::WireOptions
• primitives::partition_assignment::CreatedPartitionAssignment
• primitives::permissions::WireGlobalPermissions
• primitives::permissions::WirePermissions
• primitives::permissions::WireStreamPermissions
• primitives::permissions::WireTopicPermissions
• primitives::polling_strategy::WirePollingStrategy
• primitives::user_headers::WireHeaderKind
• primitives::user_headers::WireUserHeaderEntry
• primitives::user_headers::WireUserHeaderIterator
• primitives::user_headers::WireUserHeaders
• requests::consumer_groups::create_consumer_group::CreateConsumerGroupRequest
• requests::consumer_groups::delete_consumer_group::DeleteConsumerGroupRequest
• requests::consumer_groups::get_consumer_group::GetConsumerGroupRequest
• requests::consumer_groups::get_consumer_groups::GetConsumerGroupsRequest
• requests::consumer_groups::join_consumer_group::JoinConsumerGroupRequest
• requests::consumer_groups::leave_consumer_group::LeaveConsumerGroupRequest
• requests::consumer_groups::sync_consumer_group::SyncConsumerGroupRequest
• requests::consumer_offsets::delete_consumer_offset::DeleteConsumerOffsetRequest
• requests::consumer_offsets::get_consumer_offset::GetConsumerOffsetRequest
• requests::consumer_offsets::store_consumer_offset::StoreConsumerOffsetRequest
• requests::messages::flush_unsaved_buffer::FlushUnsavedBufferRequest
• requests::messages::poll_messages::PollMessagesRequest
• requests::messages::send_messages::RawMessage
• requests::messages::send_messages::SendMessagesEncoder
• requests::messages::send_messages::SendMessagesHeader
• requests::partitions::create_partitions::CreatePartitionsRequest
• requests::partitions::create_partitions_with_assignments::CreatePartitionsWithAssignmentsRequest
• requests::partitions::delete_partitions::DeletePartitionsRequest
• requests::personal_access_tokens::create_personal_access_token::CreatePersonalAccessTokenRequest
• requests::personal_access_tokens::delete_personal_access_token::DeletePersonalAccessTokenRequest
• requests::personal_access_tokens::get_personal_access_tokens::GetPersonalAccessTokensRequest
• requests::personal_access_tokens::login_with_personal_access_token::LoginWithPersonalAccessTokenRequest
• requests::segments::delete_segments::DeleteSegmentsRequest
• requests::streams::create_stream::CreateStreamRequest
• requests::streams::delete_stream::DeleteStreamRequest
• requests::streams::get_stream::GetStreamRequest
• requests::streams::get_streams::GetStreamsRequest
• requests::streams::purge_stream::PurgeStreamRequest
• requests::streams::update_stream::UpdateStreamRequest
• requests::system::attach_consumer_session::AttachConsumerSessionRequest
• requests::system::describe_options::DescribeOptionsRequest
• requests::system::get_client::GetClientRequest
• requests::system::get_clients::GetClientsRequest
• requests::system::get_cluster_metadata::GetClusterMetadataRequest
• requests::system::get_me::GetMeRequest
• requests::system::get_snapshot::GetSnapshotRequest
• requests::system::get_stats::GetStatsRequest
• requests::system::ping::PingRequest
• requests::topics::create_topic::CreateTopicRequest
• requests::topics::create_topic_with_assignments::CreateTopicWithAssignmentsRequest
• requests::topics::delete_topic::DeleteTopicRequest
• requests::topics::get_topic::GetTopicRequest
• requests::topics::get_topics::GetTopicsRequest
• requests::topics::purge_topic::PurgeTopicRequest
• requests::topics::update_topic::UpdateTopicRequest
• requests::users::change_password::ChangePasswordRequest
• requests::users::create_user::CreateUserRequest
• requests::users::delete_user::DeleteUserRequest
• requests::users::get_user::GetUserRequest
• requests::users::get_users::GetUsersRequest
• requests::users::login_register::LoginRegisterRequest
• requests::users::login_register_with_pat::LoginRegisterWithPatRequest
• requests::users::login_user::LoginUserRequest
• requests::users::logout_user::LogoutUserRequest
• requests::users::update_permissions::UpdatePermissionsRequest
• requests::users::update_user::UpdateUserRequest
• responses::EmptyResponse
• responses::clients::client_response::ClientResponse
• responses::clients::client_response::ConsumerGroupInfoResponse
• responses::clients::get_client::ClientDetailsResponse
• responses::clients::get_clients::GetClientsResponse
• responses::consumer_groups::consumer_group_response::ConsumerGroupResponse
• responses::consumer_groups::get_consumer_group::ConsumerGroupDetailsResponse
• responses::consumer_groups::get_consumer_group::ConsumerGroupMemberResponse
• responses::consumer_groups::get_consumer_groups::GetConsumerGroupsResponse
• responses::consumer_groups::sync_consumer_group::SyncConsumerGroupResponse
• responses::consumer_offsets::get_consumer_offset::ConsumerOffsetResponse
• responses::messages::poll_messages::PollMessagesResponse
• responses::messages::poll_messages::PollMessagesResponseHeader
• responses::messages::poll_messages::PolledBatchesIterator
• responses::messages::poll_messages::PolledMessageView
• responses::messages::poll_routing::PollRoutingResponse
• responses::messages::send_messages::SendMessagesConfirmationResponse
• responses::messages::send_messages::SendMessagesResponse
• responses::personal_access_tokens::create_personal_access_token::RawPersonalAccessTokenResponse
• responses::personal_access_tokens::get_personal_access_tokens::GetPersonalAccessTokensResponse
• responses::personal_access_tokens::get_personal_access_tokens::PersonalAccessTokenResponse
• responses::streams::StreamResponse
• responses::streams::get_stream::GetStreamResponse
• responses::streams::get_stream::TopicHeader
• responses::streams::get_streams::GetStreamsResponse
• responses::system::describe_options::DescribeOptionsResponse
• responses::system::describe_options::OptionDescriptor
• responses::system::get_cluster_metadata::ClusterMetadataResponse
• responses::system::get_cluster_metadata::ClusterNodeResponse
• responses::system::get_snapshot::GetSnapshotResponse
• responses::system::get_stats::CacheMetricEntry
• responses::system::get_stats::StatsResponse
• responses::topics::get_topic::GetTopicResponse
• responses::topics::get_topic::PartitionResponse
• responses::topics::get_topics::GetTopicsResponse
• responses::users::get_user::UserDetailsResponse
• responses::users::get_users::GetUsersResponse
• responses::users::login_register::LoginRegisterResponse
• responses::users::login_user::IdentityResponse
• responses::users::user_response::UserResponse
• version::ClientVersionInfo
• version::ProtocolVersion

Enums

• batch::BatchIntegrity
• consensus::Command
• consensus::ConsensusError
• consensus::EvictionReason
• consensus::ForwardLogoutOutcome
• consensus::ForwardRegisterOutcome
• consensus::Operation
• error::WireError
• primitives::ack_level::AckLevel
• primitives::identifier::WireIdentifier
• primitives::partitioning::WirePartitioning

Traits

• codec::WireDecode
• codec::WireEncode
• consensus::ConsensusHeader

Functions

• batch::calculate_batch_checksum
• batch::decode_batch_slice
• batch::decode_batch_slice_with
• batch::verify_and_recompute_batch_checksum
• codec::bounded_capacity
• codec::read_bytes
• codec::read_f32_le
• codec::read_str
• codec::read_u128_le
• codec::read_u16_le
• codec::read_u32_le
• codec::read_u64_le
• codec::read_u8
• codes::command_name
• consensus::frame_body
• consensus::frame_checksum_bytes
• consensus::prepare_identity_checksum_bytes
• consensus::read_size_field
• consensus::result_code
• consensus::result_section_len
• dispatch::lookup_by_operation
• dispatch::lookup_command
• namespace::bits_required
• primitives::options::decode_options_prefixed
• primitives::options::encode_options_prefixed
• primitives::options::options_prefixed_size
• primitives::options::validate_options
• primitives::user_headers::encode_user_headers
• primitives::user_headers::user_headers_encoded_size
• primitives::user_headers::validate_user_headers
• version::is_protocol_compatible
• version::pack_protocol_version

Type Aliases

• responses::consumer_groups::CreateConsumerGroupResponse
• responses::consumer_groups::DeleteConsumerGroupResponse
• responses::consumer_groups::JoinConsumerGroupResponse
• responses::consumer_groups::LeaveConsumerGroupResponse
• responses::consumer_offsets::DeleteConsumerOffsetResponse
• responses::consumer_offsets::StoreConsumerOffsetResponse
• responses::personal_access_tokens::DeletePersonalAccessTokenResponse
• responses::personal_access_tokens::login_with_personal_access_token::LoginWithPersonalAccessTokenResponse
• responses::streams::CreateStreamResponse
• responses::streams::DeleteStreamResponse
• responses::streams::PurgeStreamResponse
• responses::streams::UpdateStreamResponse
• responses::system::PingResponse
• responses::system::get_me::GetMeResponse
• responses::topics::CreateTopicResponse
• responses::topics::DeleteTopicResponse
• responses::topics::PurgeTopicResponse
• responses::topics::UpdateTopicResponse
• responses::users::ChangePasswordResponse
• responses::users::CreateUserResponse
• responses::users::DeleteUserResponse
• responses::users::LogoutUserResponse
• responses::users::UpdatePermissionsResponse
• responses::users::UpdateUserResponse

Constants

• MAX_PARTITIONS_PER_REQUEST
• batch::BATCH_CHECKSUM_OFFSET
• batch::BATCH_HEADER_SIZE
• batch::BATCH_MESSAGE_COUNT_OFFSET
• batch::BATCH_MESSAGE_HEADER_SIZE
• batch::BATCH_RESERVED_OFFSET
• batch::MAX_TIMESTAMP_DELTA_MICROS
• codes::ATTACH_CONSUMER_SESSION_CODE
• codes::CHANGE_PASSWORD_CODE
• codes::CREATE_CONSUMER_GROUP_CODE
• codes::CREATE_PARTITIONS_CODE
• codes::CREATE_PERSONAL_ACCESS_TOKEN_CODE
• codes::CREATE_STREAM_CODE
• codes::CREATE_TOPIC_CODE
• codes::CREATE_USER_CODE
• codes::DELETE_CONSUMER_GROUP_CODE
• codes::DELETE_CONSUMER_OFFSET_CODE
• codes::DELETE_PARTITIONS_CODE
• codes::DELETE_PERSONAL_ACCESS_TOKEN_CODE
• codes::DELETE_SEGMENTS_CODE
• codes::DELETE_STREAM_CODE
• codes::DELETE_TOPIC_CODE
• codes::DELETE_USER_CODE
• codes::DESCRIBE_OPTIONS_CODE
• codes::FLUSH_UNSAVED_BUFFER_CODE
• codes::GET_CLIENTS_CODE
• codes::GET_CLIENT_CODE
• codes::GET_CLUSTER_METADATA_CODE
• codes::GET_CONSUMER_GROUPS_CODE
• codes::GET_CONSUMER_GROUP_CODE
• codes::GET_CONSUMER_OFFSET_CODE
• codes::GET_CONSUMER_OFFSET_ROUTING_CODE
• codes::GET_ME_CODE
• codes::GET_PERSONAL_ACCESS_TOKENS_CODE
• codes::GET_POLL_ROUTING_CODE
• codes::GET_SNAPSHOT_FILE_CODE
• codes::GET_STATS_CODE
• codes::GET_STREAMS_CODE
• codes::GET_STREAM_CODE
• codes::GET_TOPICS_CODE
• codes::GET_TOPIC_CODE
• codes::GET_USERS_CODE
• codes::GET_USER_CODE
• codes::JOIN_CONSUMER_GROUP_CODE
• codes::LEAVE_CONSUMER_GROUP_CODE
• codes::LOGIN_REGISTER_CODE
• codes::LOGIN_REGISTER_WITH_PAT_CODE
• codes::LOGIN_USER_CODE
• codes::LOGIN_WITH_PERSONAL_ACCESS_TOKEN_CODE
• codes::LOGOUT_USER_CODE
• codes::PING_CODE
• codes::POLL_MESSAGES_CODE
• codes::POLL_MESSAGES_ON_PRIMARY_CODE
• codes::PURGE_STREAM_CODE
• codes::PURGE_TOPIC_CODE
• codes::SEND_MESSAGES_CODE
• codes::STORE_CONSUMER_OFFSET_CODE
• codes::SYNC_CONSUMER_GROUP_CODE
• codes::UPDATE_PERMISSIONS_CODE
• codes::UPDATE_STREAM_CODE
• codes::UPDATE_TOPIC_CODE
• codes::UPDATE_USER_CODE
• consensus::CHECKSUM_UNSEALED
• consensus::DVC_HEADERS_MAX
• consensus::HEADER_SIZE
• consensus::RESERVED_COMMAND_LEN
• consensus::RESULT_COUNT_LEN
• consensus::RESULT_ENTRY_LEN
• consensus::SIZE_FIELD_OFFSET
• dispatch::COMMAND_TABLE
• framing::STATUS_OK
• namespace::MAX_PARTITIONS
• namespace::MAX_STREAMS
• namespace::MAX_TOPICS
• namespace::METADATA_GROUP
• namespace::PACKED_NAMESPACE_BITS
• namespace::PACKED_NAMESPACE_MAX
• namespace::PARTITION_BITS
• namespace::PARTITION_MASK
• namespace::PARTITION_SHIFT
• namespace::STREAM_BITS
• namespace::STREAM_MASK
• namespace::STREAM_SHIFT
• namespace::TOPIC_BITS
• namespace::TOPIC_MASK
• namespace::TOPIC_SHIFT
• primitives::consumer::KIND_CONSUMER
• primitives::consumer::KIND_CONSUMER_GROUP
• primitives::identifier::MAX_WIRE_NAME_LENGTH
• primitives::options::MAX_OPTIONS
• primitives::options::MAX_OPTIONS_BYTES
• primitives::partitioning::MAX_MESSAGES_KEY_LENGTH
• requests::system::describe_options::OPTIONS_SCOPE_STREAM
• requests::system::describe_options::OPTIONS_SCOPE_TOPIC
• requests::system::describe_options::OPTIONS_SCOPE_USER
• version::IGGY_PROTOCOL_VERSION
• version::IGGY_PROTOCOL_VERSION_MIN