List of all items

Structs

• client_provider::ClientProviderConfig
• client_wrappers::connection_info::ConnectionInfo
• clients::client::IggyClient
• clients::client_builder::HttpClientBuilder
• clients::client_builder::IggyClientBuilder
• clients::client_builder::QuicClientBuilder
• clients::client_builder::TcpClientBuilder
• clients::client_builder::WebSocketClientBuilder
• clients::consumer::IggyConsumer
• clients::consumer::ReceivedMessage
• clients::consumer_builder::IggyConsumerBuilder
• clients::producer::IggyProducer
• clients::producer::ProducerCore
• clients::producer_builder::IggyProducerBuilder
• clients::producer_config::BackgroundConfig
• clients::producer_config::BackgroundConfigBuilder
• clients::producer_config::DirectConfig
• clients::producer_config::DirectConfigBuilder
• clients::producer_dispatcher::ProducerDispatcher
• clients::producer_error_callback::ErrorCtx
• clients::producer_error_callback::LogErrorCallback
• clients::producer_sharding::BalancedSharding
• clients::producer_sharding::Shard
• clients::producer_sharding::ShardMessage
• clients::producer_sharding::ShardMessageWithPermits
• http::http_client::HttpClient
• prelude::Aes256GcmEncryptor
• prelude::Args
• prelude::ArgsOptional
• prelude::CacheMetrics
• prelude::CacheMetricsKey
• prelude::ClientInfoDetails
• prelude::ClusterMetadata
• prelude::ClusterNode
• prelude::Consumer
• prelude::ConsumerGroupDetails
• prelude::FlushUnsavedBuffer
• prelude::GlobalPermissions
• prelude::HeaderKey
• prelude::HeaderValue
• prelude::HttpClientConfig
• prelude::HttpClientConfigBuilder
• prelude::Identifier
• prelude::IdentityInfo
• prelude::IggyByteSize
• prelude::IggyDuration
• prelude::IggyIndexView
• prelude::IggyMessage
• prelude::IggyMessageHeader
• prelude::IggyMessageHeaderView
• prelude::IggyMessageView
• prelude::IggyMessageViewIterator
• prelude::IggyTimestamp
• prelude::Partition
• prelude::Partitioning
• prelude::Permissions
• prelude::PollMessages
• prelude::PolledMessages
• prelude::PollingStrategy
• prelude::QuicClientConfig
• prelude::QuicClientConfigBuilder
• prelude::QuicClientReconnectionConfig
• prelude::SendMessages
• prelude::Stats
• prelude::Stream
• prelude::StreamDetails
• prelude::StreamPermissions
• prelude::TcpClient
• prelude::TcpClientConfig
• prelude::TcpClientConfigBuilder
• prelude::TcpClientReconnectionConfig
• prelude::Topic
• prelude::TopicDetails
• prelude::TopicPermissions
• prelude::TransportEndpoints
• prelude::WebSocketClientConfig
• prelude::WebSocketClientConfigBuilder
• prelude::WebSocketClientReconnectionConfig
• quic::quic_client::QuicClient
• 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
• websocket::websocket_client::WebSocketClient

Enums

• client_wrappers::client_wrapper::ClientWrapper
• clients::consumer::AutoCommit
• clients::consumer::AutoCommitAfter
• clients::consumer::AutoCommitWhen
• clients::producer_builder::SendMode
• clients::producer_config::BackpressureMode
• prelude::AutoLogin
• prelude::ClientError
• prelude::ClusterNodeRole
• prelude::ClusterNodeStatus
• prelude::CompressionAlgorithm
• prelude::ConsumerKind
• prelude::EncryptorKind
• prelude::IdKind
• prelude::IggyError
• prelude::IggyExpiry
• prelude::MaxTopicSize
• prelude::PollingKind
• prelude::SnapshotCompression
• prelude::SystemSnapshotType
• prelude::TransportProtocol
• prelude::UserStatus

Traits

• clients::producer::ProducerCoreBackend
• clients::producer_error_callback::ErrorCallback
• clients::producer_sharding::Sharding
• consumer_ext::IggyConsumerMessageExt
• consumer_ext::LocalMessageConsumer
• consumer_ext::MessageConsumer
• prelude::BytesSerializable
• prelude::Client
• prelude::ClusterClient
• prelude::ConsumerGroupClient
• prelude::ConsumerOffsetClient
• prelude::MessageClient
• prelude::PartitionClient
• prelude::Partitioner
• prelude::PersonalAccessTokenClient
• prelude::SegmentClient
• prelude::Sizeable
• prelude::StreamClient
• prelude::SystemClient
• prelude::TopicClient
• prelude::UserClient
• prelude::Validatable
• prelude::locking::IggyRwLockFn

Functions

• client_provider::get_client
• client_provider::get_default_client_
• client_provider::get_raw_client
• client_provider::get_raw_connected_client

Type Aliases

• prelude::PersonalAccessTokenExpiry
• prelude::UserId
• prelude::locking::IggyRwLock

Constants

• prelude::DEFAULT_ROOT_PASSWORD
• prelude::DEFAULT_ROOT_USERNAME
• prelude::DEFAULT_ROOT_USER_ID
• prelude::IGGY_MESSAGE_CHECKSUM_OFFSET_RANGE
• prelude::IGGY_MESSAGE_HEADERS_LENGTH_OFFSET_RANGE
• prelude::IGGY_MESSAGE_HEADER_SIZE
• prelude::IGGY_MESSAGE_ID_OFFSET_RANGE
• prelude::IGGY_MESSAGE_OFFSET_OFFSET_RANGE
• prelude::IGGY_MESSAGE_ORIGIN_TIMESTAMP_OFFSET_RANGE
• prelude::IGGY_MESSAGE_PAYLOAD_LENGTH_OFFSET_RANGE
• prelude::IGGY_MESSAGE_TIMESTAMP_OFFSET_RANGE
• prelude::INDEX_SIZE
• prelude::MAX_PAYLOAD_SIZE
• prelude::MAX_USER_HEADERS_SIZE
• prelude::SEC_IN_MICRO
• prelude::defaults::DEFAULT_ROOT_PASSWORD
• prelude::defaults::DEFAULT_ROOT_USERNAME
• prelude::defaults::DEFAULT_ROOT_USER_ID
• prelude::defaults::MAX_PASSWORD_LENGTH
• prelude::defaults::MAX_PAT_LENGTH
• prelude::defaults::MAX_PERSONAL_ACCESS_TOKEN_NAME_LENGTH
• prelude::defaults::MAX_USERNAME_LENGTH
• prelude::defaults::MIN_PASSWORD_LENGTH
• prelude::defaults::MIN_PERSONAL_ACCESS_TOKEN_NAME_LENGTH
• prelude::defaults::MIN_USERNAME_LENGTH