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
- FlushUnsavedBuffer
- GetClusterMetadata
- 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_client::GetClient
- get_clients::GetClients
- get_cluster_metadata::GetClusterMetadata
- get_consumer_group::GetConsumerGroup
- get_consumer_groups::GetConsumerGroups
- get_consumer_offset::GetConsumerOffset
- get_me::GetMe
- get_personal_access_tokens::GetPersonalAccessTokens
- get_snapshot::GetSnapshot
- get_stats::GetStats
- get_stream::GetStream
- get_streams::GetStreams
- get_topic::GetTopic
- get_topics::GetTopics
- get_user::GetUser
- get_users::GetUsers
- header::CommitHeader
- header::DoViewChangeHeader
- header::GenericHeader
- header::PrepareHeader
- header::PrepareOkHeader
- header::ReplyHeader
- header::RequestHeader
- header::StartViewChangeHeader
- header::StartViewHeader
- join_consumer_group::JoinConsumerGroup
- leave_consumer_group::LeaveConsumerGroup
- login_user::LoginUser
- login_with_personal_access_token::LoginWithPersonalAccessToken
- logout_user::LogoutUser
- message::Message
- partitioning::Partitioning
- ping::Ping
- poll_messages::PollMessages
- polled_messages::PolledMessages
- polling_strategy::PollingStrategy
- purge_stream::PurgeStream
- purge_topic::PurgeTopic
- 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
- EncryptorKind
- HeaderKind
- IdKind
- IggyError
- IggyErrorDiscriminants
- IggyExpiry
- MaxTopicSize
- PartitioningKind
- PollingKind
- SenderKind
- SnapshotCompression
- SystemSnapshotType
- TransportProtocol
- UserStatus
- header::Command2
- header::ConsensusError
- header::Operation
- message::MessageBag
- partitioning_kind::PartitioningKind
- polling_kind::PollingKind
Traits
- BytesSerializable
- Command
- ConnectionStringOptions
- Encryptor
- Partitioner
- Sender
- Sizeable
- Validatable
- header::ConsensusHeader
- locking::IggyRwLockFn
Functions
- calculate_256
- calculate_32
- calculate_checksum
- deserialize_headers
- generate_self_signed_certificate
- get_name_from_code
- memory_pool
- random_id::get_ulid
- random_id::get_uuid
- serialize_headers
- text::as_base64
- text::from_base64_as_bytes
- write_batch_frozen
Type Aliases
- AtomicUserId
- ChronoDuration
- HeaderKey
- HeaderValue
- PersonalAccessTokenExpiry
- UserHeaders
- UserId
- locking::IggyRwLock
Statics
Constants
- CHANGE_PASSWORD
- CHANGE_PASSWORD_CODE
- CREATE_CONSUMER_GROUP
- CREATE_CONSUMER_GROUP_CODE
- CREATE_PARTITIONS
- CREATE_PARTITIONS_CODE
- CREATE_PERSONAL_ACCESS_TOKEN
- CREATE_PERSONAL_ACCESS_TOKEN_CODE
- CREATE_STREAM
- CREATE_STREAM_CODE
- CREATE_TOPIC
- CREATE_TOPIC_CODE
- CREATE_USER
- CREATE_USER_CODE
- DELETE_CONSUMER_GROUP
- DELETE_CONSUMER_GROUP_CODE
- DELETE_CONSUMER_OFFSET
- DELETE_CONSUMER_OFFSET_CODE
- DELETE_PARTITIONS
- DELETE_PARTITIONS_CODE
- DELETE_PERSONAL_ACCESS_TOKEN
- DELETE_PERSONAL_ACCESS_TOKEN_CODE
- DELETE_SEGMENTS
- DELETE_SEGMENTS_CODE
- DELETE_STREAM
- DELETE_STREAM_CODE
- DELETE_TOPIC
- DELETE_TOPIC_CODE
- DELETE_USER
- DELETE_USER_CODE
- FLUSH_UNSAVED_BUFFER
- FLUSH_UNSAVED_BUFFER_CODE
- GET_CLIENT
- GET_CLIENTS
- GET_CLIENTS_CODE
- GET_CLIENT_CODE
- GET_CLUSTER_METADATA
- GET_CLUSTER_METADATA_CODE
- GET_CONSUMER_GROUP
- GET_CONSUMER_GROUPS
- GET_CONSUMER_GROUPS_CODE
- GET_CONSUMER_GROUP_CODE
- GET_CONSUMER_OFFSET
- GET_CONSUMER_OFFSET_CODE
- GET_ME
- GET_ME_CODE
- GET_PERSONAL_ACCESS_TOKENS
- GET_PERSONAL_ACCESS_TOKENS_CODE
- GET_SNAPSHOT_FILE
- GET_SNAPSHOT_FILE_CODE
- GET_STATS
- GET_STATS_CODE
- GET_STREAM
- GET_STREAMS
- GET_STREAMS_CODE
- GET_STREAM_CODE
- GET_TOPIC
- GET_TOPICS
- GET_TOPICS_CODE
- GET_TOPIC_CODE
- GET_USER
- GET_USERS
- GET_USERS_CODE
- GET_USER_CODE
- 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
- JOIN_CONSUMER_GROUP
- JOIN_CONSUMER_GROUP_CODE
- LEAVE_CONSUMER_GROUP
- LEAVE_CONSUMER_GROUP_CODE
- LOGIN_USER
- LOGIN_USER_CODE
- LOGIN_WITH_PERSONAL_ACCESS_TOKEN
- LOGIN_WITH_PERSONAL_ACCESS_TOKEN_CODE
- LOGOUT_USER
- LOGOUT_USER_CODE
- MAX_PAYLOAD_SIZE
- MAX_USER_HEADERS_SIZE
- PING
- PING_CODE
- POLL_MESSAGES
- POLL_MESSAGES_CODE
- PURGE_STREAM
- PURGE_STREAM_CODE
- PURGE_TOPIC
- PURGE_TOPIC_CODE
- SEC_IN_MICRO
- SEND_MESSAGES
- SEND_MESSAGES_CODE
- STORE_CONSUMER_OFFSET
- STORE_CONSUMER_OFFSET_CODE
- UPDATE_PERMISSIONS
- UPDATE_PERMISSIONS_CODE
- UPDATE_STREAM
- UPDATE_STREAM_CODE
- UPDATE_TOPIC
- UPDATE_TOPIC_CODE
- UPDATE_USER
- UPDATE_USER_CODE
- 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
- 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