List of all items

Structs

• Aes256GcmEncryptor
• Args
• ArgsOptional
• CacheMetrics
• CacheMetricsKey
• ClientInfo
• ClientInfoDetails
• ClusterMetadata
• ClusterNode
• ConnectionString
• ConnectionStringUtils
• Consumer
• ConsumerGroup
• ConsumerGroupDetails
• ConsumerGroupId
• ConsumerGroupInfo
• ConsumerGroupMember
• ConsumerGroupOffsets
• ConsumerOffset
• ConsumerOffsetInfo
• ConsumerOffsets
• DateTime
• GlobalPermissions
• HeaderEntry
• HeaderField
• HttpClientConfig
• HttpClientConfigBuilder
• HttpConnectionStringOptions
• Identifier
• IdentityInfo
• IggyByteSize
• IggyDuration
• IggyIndex
• IggyIndexView
• IggyIndexes
• IggyIndexesMut
• IggyMessage
• IggyMessageHeader
• IggyMessageHeaderView
• IggyMessageHeaderViewMut
• IggyMessageView
• IggyMessageViewIterator
• IggyMessageViewMut
• IggyMessageViewMutIterator
• IggyMessagesBatch
• IggyMessagesBatchMut
• IggyMessagesBatchSet
• IggyMessagesBatchSetInFlight
• IggyPollMetadata
• IggyTimestamp
• IndexReader
• IndexWriter
• KeyMarker
• MemoryPool
• MemoryPoolConfigOther
• MessageDeduplicator
• MessagesReader
• MessagesWriter
• Partition
• PartitionStats
• Partitioning
• Permissions
• PersonalAccessToken
• PersonalAccessTokenInfo
• PollMessages
• PolledMessages
• PollingStrategy
• PooledBuffer
• QuicClientConfig
• QuicClientConfigBuilder
• QuicClientReconnectionConfig
• QuicConnectionStringOptions
• QuicSender
• RawPersonalAccessToken
• Segment
• SegmentStorage
• SemanticVersion
• SendMessages
• Snapshot
• Stats
• Stream
• StreamDetails
• StreamPermissions
• StreamStats
• TcpClientConfig
• TcpClientConfigBuilder
• TcpClientReconnectionConfig
• TcpConnectionStringOptions
• TcpSender
• TcpTlsSender
• TokenInfo
• Topic
• TopicDetails
• TopicPermissions
• TopicStats
• TransportEndpoints
• UserInfo
• UserInfoDetails
• Utc
• ValueMarker
• WebSocketClientConfig
• WebSocketClientConfigBuilder
• WebSocketClientReconnectionConfig
• WebSocketConfig
• WebSocketConnectionStringOptions
• WebSocketSender
• WebSocketTlsSender
• change_password::ChangePassword
• create_consumer_group::CreateConsumerGroup
• create_partitions::CreatePartitions
• create_personal_access_token::CreatePersonalAccessToken
• create_stream::CreateStream
• create_topic::CreateTopic
• create_user::CreateUser
• delete_consumer_group::DeleteConsumerGroup
• delete_consumer_offset::DeleteConsumerOffset
• delete_partitions::DeletePartitions
• delete_personal_access_token::DeletePersonalAccessToken
• delete_segments::DeleteSegments
• delete_stream::DeleteStream
• delete_topic::DeleteTopic
• delete_user::DeleteUser
• flush_unsaved_buffer::FlushUnsavedBuffer
• get_consumer_offset::GetConsumerOffset
• get_snapshot::GetSnapshot
• login_user::LoginUser
• login_with_personal_access_token::LoginWithPersonalAccessToken
• partitioning::Partitioning
• poll_messages::PollMessages
• polled_messages::PolledMessages
• polling_strategy::PollingStrategy
• purge_stream::PurgeStream
• purge_topic::PurgeTopic
• send_messages2::IggyMessage2
• send_messages2::IggyMessage2Header
• send_messages2::IggyMessages2
• send_messages2::SendMessages2Header
• send_messages2::SendMessages2Iterator
• send_messages2::SendMessages2IteratorWithOffsets
• send_messages2::SendMessages2MessageHeader
• send_messages2::SendMessages2MessageView
• send_messages2::SendMessages2MessageViewWithOffsets
• send_messages2::SendMessages2Owned
• send_messages2::SendMessages2Ref
• send_messages::SendMessages
• sharding::IggyNamespace
• sharding::LocalIdx
• sharding::PartitionLocation
• sharding::ShardId
• store_consumer_offset::StoreConsumerOffset
• update_permissions::UpdatePermissions
• update_stream::UpdateStream
• update_topic::UpdateTopic
• update_user::UpdateUser

Enums

• AutoLogin
• ClientError
• ClientState
• ClusterNodeRole
• ClusterNodeStatus
• CompressionAlgorithm
• ConsumerKind
• Credentials
• DiagnosticEvent
• Either
• EncryptorKind
• HeaderKind
• IdKind
• IggyError
• IggyErrorDiscriminants
• IggyExpiry
• MaxTopicSize
• PartitioningKind
• PollingKind
• SenderKind
• SnapshotCompression
• SystemSnapshotType
• TransportProtocol
• UserStatus
• partitioning_kind::PartitioningKind
• polling_kind::PollingKind

Traits

• BinaryClient
• BinaryTransport
• Client
• ClusterClient
• ConnectionStringOptions
• ConsumerGroupClient
• ConsumerOffsetClient
• Encryptor
• MessageClient
• PartitionClient
• Partitioner
• PersonalAccessTokenClient
• SegmentClient
• Sender
• Sizeable
• StreamClient
• SystemClient
• TopicClient
• UserClient
• Validatable
• locking::IggyRwLockFn

Macros

• variadic

Functions

• calculate_256
• calculate_32
• calculate_checksum
• deserialize_headers
• generate_self_signed_certificate
• memory_pool
• random_id::get_ulid
• random_id::get_uuid
• send_messages2::convert_request_message
• send_messages2::decode_prepare_slice
• send_messages2::stamp_prepare_for_persistence
• serde_secret::serialize_optional_secret
• serde_secret::serialize_secret
• serialize_headers
• text::as_base64
• text::from_base64_as_bytes
• validate_server_address
• wire_conversions::clients_from_wire
• wire_conversions::cluster_metadata_from_wire
• wire_conversions::consumer_groups_from_wire
• wire_conversions::consumer_to_wire
• wire_conversions::identifier_to_wire
• wire_conversions::partitioning_to_wire
• wire_conversions::permissions_to_wire
• wire_conversions::personal_access_tokens_from_wire
• wire_conversions::polling_strategy_to_wire
• wire_conversions::streams_from_wire
• wire_conversions::topics_from_wire
• wire_conversions::user_headers_from_wire
• wire_conversions::user_headers_to_wire
• wire_conversions::users_from_wire
• wire_conversions::wire_permissions_to_permissions
• write_batch_frozen

Type Aliases

• AtomicUserId
• ChronoDuration
• HeaderKey
• HeaderValue
• PersonalAccessTokenExpiry
• UserHeaders
• UserId
• locking::IggyRwLock

Statics

• MEMORY_POOL

Constants

• IGGY_MESSAGE_CHECKSUM_OFFSET_RANGE
• IGGY_MESSAGE_HEADERS_LENGTH_OFFSET_RANGE
• IGGY_MESSAGE_HEADER_RANGE
• IGGY_MESSAGE_HEADER_SIZE
• IGGY_MESSAGE_ID_OFFSET_RANGE
• IGGY_MESSAGE_OFFSET_OFFSET_RANGE
• IGGY_MESSAGE_ORIGIN_TIMESTAMP_OFFSET_RANGE
• IGGY_MESSAGE_PAYLOAD_LENGTH_OFFSET_RANGE
• IGGY_MESSAGE_TIMESTAMP_OFFSET_RANGE
• INDEX_SIZE
• MAX_NAME_LENGTH
• MAX_PARTITIONS_COUNT
• MAX_PAYLOAD_SIZE
• MAX_USER_HEADERS_SIZE
• SEC_IN_MICRO
• UTC_TIME_FORMAT
• defaults::DEFAULT_ROOT_PASSWORD
• defaults::DEFAULT_ROOT_USERNAME
• defaults::DEFAULT_ROOT_USER_ID
• defaults::MAX_PASSWORD_LENGTH
• defaults::MAX_PAT_LENGTH
• defaults::MAX_PERSONAL_ACCESS_TOKEN_NAME_LENGTH
• defaults::MAX_USERNAME_LENGTH
• defaults::MIN_PASSWORD_LENGTH
• defaults::MIN_PERSONAL_ACCESS_TOKEN_NAME_LENGTH
• defaults::MIN_USERNAME_LENGTH
• poll_messages::DEFAULT_NUMBER_OF_MESSAGES_TO_POLL
• poll_messages::DEFAULT_PARTITION_ID
• send_messages2::COMMAND_HEADER_SIZE
• send_messages2::PREPARE_SPLIT_POINT
• sharding::MAX_PARTITIONS
• sharding::MAX_STREAMS
• sharding::MAX_TOPICS
• sharding::PARTITION_BITS
• sharding::PARTITION_MASK
• sharding::PARTITION_SHIFT
• sharding::STREAM_BITS
• sharding::STREAM_MASK
• sharding::STREAM_SHIFT
• sharding::TOPIC_BITS
• sharding::TOPIC_MASK
• sharding::TOPIC_SHIFT