List of all items
Structs
- args::Args
- args::ArgsOptional
- client_provider::ClientProviderConfig
- clients::builder::HttpClientBuilder
- clients::builder::IggyClientBuilder
- clients::builder::QuicClientBuilder
- clients::builder::TcpClientBuilder
- clients::client::IggyClient
- clients::consumer::IggyConsumer
- clients::consumer::IggyConsumerBuilder
- clients::consumer::ReceivedMessage
- clients::producer::IggyProducer
- clients::producer::IggyProducerBuilder
- consumer::Consumer
- consumer_groups::create_consumer_group::CreateConsumerGroup
- consumer_groups::delete_consumer_group::DeleteConsumerGroup
- consumer_groups::get_consumer_group::GetConsumerGroup
- consumer_groups::get_consumer_groups::GetConsumerGroups
- consumer_groups::join_consumer_group::JoinConsumerGroup
- consumer_groups::leave_consumer_group::LeaveConsumerGroup
- consumer_offsets::delete_consumer_offset::DeleteConsumerOffset
- consumer_offsets::get_consumer_offset::GetConsumerOffset
- consumer_offsets::store_consumer_offset::StoreConsumerOffset
- http::client::HttpClient
- http::config::HttpClientConfig
- http::config::HttpClientConfigBuilder
- identifier::Identifier
- messages::flush_unsaved_buffer::FlushUnsavedBuffer
- messages::poll_messages::PollMessages
- messages::poll_messages::PollingStrategy
- messages::send_messages::Message
- messages::send_messages::Partitioning
- messages::send_messages::SendMessages
- models::client_info::ClientInfo
- models::client_info::ClientInfoDetails
- models::client_info::ConsumerGroupInfo
- models::consumer_group::ConsumerGroup
- models::consumer_group::ConsumerGroupDetails
- models::consumer_group::ConsumerGroupMember
- models::consumer_offset_info::ConsumerOffsetInfo
- models::header::HeaderKey
- models::header::HeaderValue
- models::identity_info::IdentityInfo
- models::identity_info::TokenInfo
- models::messages::PolledMessage
- models::messages::PolledMessages
- models::partition::Partition
- models::permissions::GlobalPermissions
- models::permissions::Permissions
- models::permissions::StreamPermissions
- models::permissions::TopicPermissions
- models::personal_access_token::PersonalAccessTokenInfo
- models::personal_access_token::RawPersonalAccessToken
- models::snapshot::Snapshot
- models::stats::CacheMetrics
- models::stats::CacheMetricsKey
- models::stats::Stats
- models::stream::Stream
- models::stream::StreamDetails
- models::topic::Topic
- models::topic::TopicDetails
- models::user_info::UserInfo
- models::user_info::UserInfoDetails
- partitions::create_partitions::CreatePartitions
- partitions::delete_partitions::DeletePartitions
- personal_access_tokens::create_personal_access_token::CreatePersonalAccessToken
- personal_access_tokens::delete_personal_access_token::DeletePersonalAccessToken
- personal_access_tokens::get_personal_access_tokens::GetPersonalAccessTokens
- personal_access_tokens::login_with_personal_access_token::LoginWithPersonalAccessToken
- quic::client::QuicClient
- quic::config::QuicClientConfig
- quic::config::QuicClientConfigBuilder
- quic::config::QuicClientReconnectionConfig
- stream_builder::IggyConsumerConfig
- stream_builder::IggyConsumerConfigBuilder
- stream_builder::IggyProducerConfig
- stream_builder::IggyProducerConfigBuilder
- stream_builder::IggyStream
- stream_builder::IggyStreamConfig
- stream_builder::IggyStreamConfigBuilder
- stream_builder::IggyStreamConsumer
- stream_builder::IggyStreamProducer
- streams::create_stream::CreateStream
- streams::delete_stream::DeleteStream
- streams::get_stream::GetStream
- streams::get_streams::GetStreams
- streams::purge_stream::PurgeStream
- streams::update_stream::UpdateStream
- system::get_client::GetClient
- system::get_clients::GetClients
- system::get_me::GetMe
- system::get_snapshot::GetSnapshot
- system::get_stats::GetStats
- system::ping::Ping
- tcp::client::TcpClient
- tcp::config::TcpClientConfig
- tcp::config::TcpClientConfigBuilder
- tcp::config::TcpClientReconnectionConfig
- topics::create_topic::CreateTopic
- topics::delete_topic::DeleteTopic
- topics::get_topic::GetTopic
- topics::get_topics::GetTopics
- topics::purge_topic::PurgeTopic
- topics::update_topic::UpdateTopic
- users::change_password::ChangePassword
- users::create_user::CreateUser
- users::delete_user::DeleteUser
- users::get_user::GetUser
- users::get_users::GetUsers
- users::login_user::LoginUser
- users::logout_user::LogoutUser
- users::update_permissions::UpdatePermissions
- users::update_user::UpdateUser
- utils::byte_size::IggyByteSize
- utils::crypto::Aes256GcmEncryptor
- utils::duration::IggyDuration
- utils::timestamp::IggyTimestamp
Enums
- binary::ClientState
- client::AutoLogin
- client::Credentials
- client_error::ClientError
- clients::consumer::AutoCommit
- clients::consumer::AutoCommitAfter
- clients::consumer::AutoCommitWhen
- compression::compression_algorithm::CompressionAlgorithm
- confirmation::Confirmation
- consumer::ConsumerKind
- diagnostic::DiagnosticEvent
- error::IggyError
- identifier::IdKind
- messages::poll_messages::PollingKind
- messages::send_messages::PartitioningKind
- models::header::HeaderKind
- models::messages::MessageState
- models::user_status::UserStatus
- snapshot::SnapshotCompression
- snapshot::SystemSnapshotType
- utils::crypto::EncryptorKind
- utils::expiry::IggyExpiry
- utils::topic_size::MaxTopicSize
Traits
- binary::BinaryTransport
- binary::binary_client::BinaryClient
- bytes_serializable::BytesSerializable
- cli_command::CliCommand
- client::Client
- client::ConsumerGroupClient
- client::ConsumerOffsetClient
- client::MessageClient
- client::PartitionClient
- client::PersonalAccessTokenClient
- client::StreamClient
- client::SystemClient
- client::TopicClient
- client::UserClient
- command::Command
- consumer_ext::IggyConsumerMessageExt
- consumer_ext::LocalMessageConsumer
- consumer_ext::MessageConsumer
- http::HttpTransport
- locking::IggySharedMutFn
- partitioner::Partitioner
- utils::crypto::Encryptor
- utils::sizeable::Sizeable
- validatable::Validatable
Functions
- client_provider::get_client
- client_provider::get_default_client_
- client_provider::get_raw_client
- client_provider::get_raw_connected_client
- command::get_name_from_code
- models::header::get_headers_size_bytes
- utils::checksum::calculate
- utils::text::as_base64
- utils::text::from_base64_as_bytes
Type Aliases
- locking::IggySharedMut
- models::user_info::AtomicUserId
- models::user_info::UserId
- utils::personal_access_token_expiry::PersonalAccessTokenExpiry
Statics
Constants
- command::CHANGE_PASSWORD
- command::CHANGE_PASSWORD_CODE
- command::CREATE_CONSUMER_GROUP
- command::CREATE_CONSUMER_GROUP_CODE
- command::CREATE_PARTITIONS
- command::CREATE_PARTITIONS_CODE
- command::CREATE_PERSONAL_ACCESS_TOKEN
- command::CREATE_PERSONAL_ACCESS_TOKEN_CODE
- command::CREATE_STREAM
- command::CREATE_STREAM_CODE
- command::CREATE_TOPIC
- command::CREATE_TOPIC_CODE
- command::CREATE_USER
- command::CREATE_USER_CODE
- command::DELETE_CONSUMER_GROUP
- command::DELETE_CONSUMER_GROUP_CODE
- command::DELETE_CONSUMER_OFFSET
- command::DELETE_CONSUMER_OFFSET_CODE
- command::DELETE_PARTITIONS
- command::DELETE_PARTITIONS_CODE
- command::DELETE_PERSONAL_ACCESS_TOKEN
- command::DELETE_PERSONAL_ACCESS_TOKEN_CODE
- command::DELETE_STREAM
- command::DELETE_STREAM_CODE
- command::DELETE_TOPIC
- command::DELETE_TOPIC_CODE
- command::DELETE_USER
- command::DELETE_USER_CODE
- command::FLUSH_UNSAVED_BUFFER
- command::FLUSH_UNSAVED_BUFFER_CODE
- command::GET_CLIENT
- command::GET_CLIENTS
- command::GET_CLIENTS_CODE
- command::GET_CLIENT_CODE
- command::GET_CONSUMER_GROUP
- command::GET_CONSUMER_GROUPS
- command::GET_CONSUMER_GROUPS_CODE
- command::GET_CONSUMER_GROUP_CODE
- command::GET_CONSUMER_OFFSET
- command::GET_CONSUMER_OFFSET_CODE
- command::GET_ME
- command::GET_ME_CODE
- command::GET_PERSONAL_ACCESS_TOKENS
- command::GET_PERSONAL_ACCESS_TOKENS_CODE
- command::GET_SNAPSHOT_FILE
- command::GET_SNAPSHOT_FILE_CODE
- command::GET_STATS
- command::GET_STATS_CODE
- command::GET_STREAM
- command::GET_STREAMS
- command::GET_STREAMS_CODE
- command::GET_STREAM_CODE
- command::GET_TOPIC
- command::GET_TOPICS
- command::GET_TOPICS_CODE
- command::GET_TOPIC_CODE
- command::GET_USER
- command::GET_USERS
- command::GET_USERS_CODE
- command::GET_USER_CODE
- command::JOIN_CONSUMER_GROUP
- command::JOIN_CONSUMER_GROUP_CODE
- command::LEAVE_CONSUMER_GROUP
- command::LEAVE_CONSUMER_GROUP_CODE
- command::LOGIN_USER
- command::LOGIN_USER_CODE
- command::LOGIN_WITH_PERSONAL_ACCESS_TOKEN
- command::LOGIN_WITH_PERSONAL_ACCESS_TOKEN_CODE
- command::LOGOUT_USER
- command::LOGOUT_USER_CODE
- command::PING
- command::PING_CODE
- command::POLL_MESSAGES
- command::POLL_MESSAGES_CODE
- command::PURGE_STREAM
- command::PURGE_STREAM_CODE
- command::PURGE_TOPIC
- command::PURGE_TOPIC_CODE
- command::SEND_MESSAGES
- command::SEND_MESSAGES_CODE
- command::STORE_CONSUMER_OFFSET
- command::STORE_CONSUMER_OFFSET_CODE
- command::UPDATE_PERMISSIONS
- command::UPDATE_PERMISSIONS_CODE
- command::UPDATE_STREAM
- command::UPDATE_STREAM_CODE
- command::UPDATE_TOPIC
- command::UPDATE_TOPIC_CODE
- command::UPDATE_USER
- command::UPDATE_USER_CODE
- messages::MAX_PAYLOAD_SIZE
- models::messages::POLLED_MESSAGE_METADATA
- users::defaults::DEFAULT_ROOT_PASSWORD
- users::defaults::DEFAULT_ROOT_USERNAME
- users::defaults::DEFAULT_ROOT_USER_ID
- users::defaults::MAX_PASSWORD_LENGTH
- users::defaults::MAX_PAT_LENGTH
- users::defaults::MAX_PERSONAL_ACCESS_TOKEN_NAME_LENGTH
- users::defaults::MAX_USERNAME_LENGTH
- users::defaults::MIN_PASSWORD_LENGTH
- users::defaults::MIN_PERSONAL_ACCESS_TOKEN_NAME_LENGTH
- users::defaults::MIN_USERNAME_LENGTH
- utils::duration::SEC_IN_MICRO
- utils::timestamp::UTC_TIME_FORMAT