ierror

package

Go to main page

Versions in this module

v0

v0.8.0

Apr 14, 2026

v0.7.1-edge.1

Mar 5, 2026

v0.7.0

Feb 17, 2026

v0.6.1-edge.1

Feb 6, 2026

v0.6.0

Dec 2, 2025

Changes in this version

+ var ErrAccessTokenMissing = AccessTokenMissing

+ var ErrBackgroundSendBufferFull = BackgroundSendBufferFull

+ var ErrBackgroundSendBufferOverflow = BackgroundSendBufferOverflow

+ var ErrBackgroundSendError = BackgroundSendError

+ var ErrBackgroundSendTimeout = BackgroundSendTimeout

+ var ErrBackgroundWorkerDisconnected = BackgroundWorkerDisconnected

+ var ErrCannotAppendMessage = CannotAppendMessage

+ var ErrCannotAppendToFile = CannotAppendToFile

+ var ErrCannotChangePermissions = CannotChangePermissions

+ var ErrCannotCreateBaseDirectory = CannotCreateBaseDirectory

+ var ErrCannotCreateConsumerGroupInfo = CannotCreateConsumerGroupInfo

+ var ErrCannotCreateConsumerOffsetsDirectory = CannotCreateConsumerOffsetsDirectory

+ var ErrCannotCreateEndpoint = CannotCreateEndpoint

+ var ErrCannotCreatePartition = CannotCreatePartition

+ var ErrCannotCreatePartitionDirectory = CannotCreatePartitionDirectory

+ var ErrCannotCreatePartitionsDirectory = CannotCreatePartitionsDirectory

+ var ErrCannotCreateRuntimeDirectory = CannotCreateRuntimeDirectory

+ var ErrCannotCreateSegmentIndexFile = CannotCreateSegmentIndexFile

+ var ErrCannotCreateSegmentLogFile = CannotCreateSegmentLogFile

+ var ErrCannotCreateSegmentTimeIndexFile = CannotCreateSegmentTimeIndexFile

+ var ErrCannotCreateStateDirectory = CannotCreateStateDirectory

+ var ErrCannotCreateStream = CannotCreateStream

+ var ErrCannotCreateStreamDirectory = CannotCreateStreamDirectory

+ var ErrCannotCreateStreamInfo = CannotCreateStreamInfo

+ var ErrCannotCreateStreamsDirectory = CannotCreateStreamsDirectory

+ var ErrCannotCreateTopic = CannotCreateTopic

+ var ErrCannotCreateTopicDirectory = CannotCreateTopicDirectory

+ var ErrCannotCreateTopicInfo = CannotCreateTopicInfo

+ var ErrCannotCreateTopicsDirectory = CannotCreateTopicsDirectory

+ var ErrCannotDecryptData = CannotDecryptData

+ var ErrCannotDeleteConsumerGroupInfo = CannotDeleteConsumerGroupInfo

+ var ErrCannotDeleteConsumerOffsetFile = CannotDeleteConsumerOffsetFile

+ var ErrCannotDeleteConsumerOffsetsDirectory = CannotDeleteConsumerOffsetsDirectory

+ var ErrCannotDeleteFile = CannotDeleteFile

+ var ErrCannotDeletePartition = CannotDeletePartition

+ var ErrCannotDeletePartitionDirectory = CannotDeletePartitionDirectory

+ var ErrCannotDeleteStream = CannotDeleteStream

+ var ErrCannotDeleteStreamDirectory = CannotDeleteStreamDirectory

+ var ErrCannotDeleteTopic = CannotDeleteTopic

+ var ErrCannotDeleteTopicDirectory = CannotDeleteTopicDirectory

+ var ErrCannotDeleteUser = CannotDeleteUser

+ var ErrCannotDeserializeResource = CannotDeserializeResource

+ var ErrCannotEncryptData = CannotEncryptData

+ var ErrCannotEstablishConnection = CannotEstablishConnection

+ var ErrCannotGenerateJwt = CannotGenerateJwt

+ var ErrCannotOpenDatabase = CannotOpenDatabase

+ var ErrCannotOpenPartitionLogFile = CannotOpenPartitionLogFile

+ var ErrCannotOpenStreamInfo = CannotOpenStreamInfo

+ var ErrCannotOpenTopicInfo = CannotOpenTopicInfo

+ var ErrCannotOverwriteFile = CannotOverwriteFile

+ var ErrCannotParseHeaderKind = CannotParseHeaderKind

+ var ErrCannotParseUrl = CannotParseUrl

+ var ErrCannotPollTopic = CannotPollTopic

+ var ErrCannotReadBatchBaseOffset = CannotReadBatchBaseOffset

+ var ErrCannotReadBatchLength = CannotReadBatchLength

+ var ErrCannotReadBatchPayload = CannotReadBatchPayload

+ var ErrCannotReadConsumerOffsets = CannotReadConsumerOffsets

+ var ErrCannotReadFile = CannotReadFile

+ var ErrCannotReadFileMetadata = CannotReadFileMetadata

+ var ErrCannotReadHeadersLength = CannotReadHeadersLength

+ var ErrCannotReadHeadersPayload = CannotReadHeadersPayload

+ var ErrCannotReadIndexOffset = CannotReadIndexOffset

+ var ErrCannotReadIndexPosition = CannotReadIndexPosition

+ var ErrCannotReadIndexTimestamp = CannotReadIndexTimestamp

+ var ErrCannotReadLastOffsetDelta = CannotReadLastOffsetDelta

+ var ErrCannotReadMaxTimestamp = CannotReadMaxTimestamp

+ var ErrCannotReadMessage = CannotReadMessage

+ var ErrCannotReadMessageChecksum = CannotReadMessageChecksum

+ var ErrCannotReadMessageId = CannotReadMessageId

+ var ErrCannotReadMessageLength = CannotReadMessageLength

+ var ErrCannotReadMessagePayload = CannotReadMessagePayload

+ var ErrCannotReadMessageState = CannotReadMessageState

+ var ErrCannotReadMessageTimestamp = CannotReadMessageTimestamp

+ var ErrCannotReadPartitions = CannotReadPartitions

+ var ErrCannotReadStreamInfo = CannotReadStreamInfo

+ var ErrCannotReadStreams = CannotReadStreams

+ var ErrCannotReadTopicInfo = CannotReadTopicInfo

+ var ErrCannotReadTopics = CannotReadTopics

+ var ErrCannotRemoveRuntimeDirectory = CannotRemoveRuntimeDirectory

+ var ErrCannotSaveIndexToSegment = CannotSaveIndexToSegment

+ var ErrCannotSaveMessagesToSegment = CannotSaveMessagesToSegment

+ var ErrCannotSaveTimeIndexToSegment = CannotSaveTimeIndexToSegment

+ var ErrCannotSeekFile = CannotSeekFile

+ var ErrCannotSendMessagesDueToClientDisconnection = CannotSendMessagesDueToClientDisconnection

+ var ErrCannotSerializeResource = CannotSerializeResource

+ var ErrCannotSyncFile = CannotSyncFile

+ var ErrCannotUpdateStreamInfo = CannotUpdateStreamInfo

+ var ErrCannotUpdateTopicInfo = CannotUpdateTopicInfo

+ var ErrCannotWriteToFile = CannotWriteToFile

+ var ErrClientNotFound = ClientNotFound

+ var ErrClientShutdown = ClientShutdown

+ var ErrCommandLengthError = CommandLengthError

+ var ErrConnectionClosed = ConnectionClosed

+ var ErrConsumerGroupIdAlreadyExists = ConsumerGroupIdAlreadyExists

+ var ErrConsumerGroupIdNotFound = ConsumerGroupIdNotFound

+ var ErrConsumerGroupMemberNotFound = ConsumerGroupMemberNotFound

+ var ErrConsumerGroupNameAlreadyExists = ConsumerGroupNameAlreadyExists

+ var ErrConsumerGroupNameNotFound = ConsumerGroupNameNotFound

+ var ErrConsumerOffsetNotFound = ConsumerOffsetNotFound

+ var ErrDisconnected = Disconnected

+ var ErrEmptyMessagePayload = EmptyMessagePayload

+ var ErrEmptyResponse = EmptyResponse

+ var ErrError = Error

+ var ErrFailedToAddCertificate = FailedToAddCertificate

+ var ErrFeatureUnavailable = FeatureUnavailable

+ var ErrHttpResponseError = HttpResponseError

+ var ErrInvalidAccessToken = InvalidAccessToken

+ var ErrInvalidBooleanValue = InvalidBooleanValue

+ var ErrInvalidBytesResponse = InvalidBytesResponse

+ var ErrInvalidClientAddress = InvalidClientAddress

+ var ErrInvalidClientId = InvalidClientId

+ var ErrInvalidCommand = InvalidCommand

+ var ErrInvalidConfiguration = InvalidConfiguration

+ var ErrInvalidConnectionString = InvalidConnectionString

+ var ErrInvalidConsumerGroupId = InvalidConsumerGroupId

+ var ErrInvalidConsumerGroupName = InvalidConsumerGroupName

+ var ErrInvalidCredentials = InvalidCredentials

+ var ErrInvalidEncryptionKey = InvalidEncryptionKey

+ var ErrInvalidFormat = InvalidFormat

+ var ErrInvalidHeaderKey = InvalidHeaderKey

+ var ErrInvalidHeaderValue = InvalidHeaderValue

+ var ErrInvalidHttpRequest = InvalidHttpRequest

+ var ErrInvalidIdentifier = InvalidIdentifier

+ var ErrInvalidIndexesByteSize = InvalidIndexesByteSize

+ var ErrInvalidIndexesCount = InvalidIndexesCount

+ var ErrInvalidIpAddress = InvalidIpAddress

+ var ErrInvalidJsonResponse = InvalidJsonResponse

+ var ErrInvalidJwtAlgorithm = InvalidJwtAlgorithm

+ var ErrInvalidJwtSecret = InvalidJwtSecret

+ var ErrInvalidKeyValueLength = InvalidKeyValueLength

+ var ErrInvalidMessageChecksum = InvalidMessageChecksum

+ var ErrInvalidMessagePayloadLength = InvalidMessagePayloadLength

+ var ErrInvalidMessagesCount = InvalidMessagesCount

+ var ErrInvalidMessagesSize = InvalidMessagesSize

+ var ErrInvalidNumberEncoding = InvalidNumberEncoding

+ var ErrInvalidNumberValue = InvalidNumberValue

+ var ErrInvalidOffset = InvalidOffset

+ var ErrInvalidPassword = InvalidPassword

+ var ErrInvalidPersonalAccessToken = InvalidPersonalAccessToken

+ var ErrInvalidPersonalAccessTokenName = InvalidPersonalAccessTokenName

+ var ErrInvalidReplicationFactor = InvalidReplicationFactor

+ var ErrInvalidSegmentSize = InvalidSegmentSize

+ var ErrInvalidSegmentsCount = InvalidSegmentsCount

+ var ErrInvalidServerAddress = InvalidServerAddress

+ var ErrInvalidSizeBytes = InvalidSizeBytes

+ var ErrInvalidStateEntryChecksum = InvalidStateEntryChecksum

+ var ErrInvalidStreamId = InvalidStreamId

+ var ErrInvalidStreamName = InvalidStreamName

+ var ErrInvalidTlsCertificate = InvalidTlsCertificate

+ var ErrInvalidTlsCertificatePath = InvalidTlsCertificatePath

+ var ErrInvalidTlsDomain = InvalidTlsDomain

+ var ErrInvalidTopicId = InvalidTopicId

+ var ErrInvalidTopicName = InvalidTopicName

+ var ErrInvalidTopicSize = InvalidTopicSize

+ var ErrInvalidUserStatus = InvalidUserStatus

+ var ErrInvalidUsername = InvalidUsername

+ var ErrInvalidUtf8 = InvalidUtf8

+ var ErrInvalidVersion = InvalidVersion

+ var ErrJwtMissing = JwtMissing

+ var ErrMissingBaseOffsetRetainedMessageBatch = MissingBaseOffsetRetainedMessageBatch

+ var ErrMissingIndex = MissingIndex

+ var ErrMissingLastOffsetDeltaRetainedMessageBatch = MissingLastOffsetDeltaRetainedMessageBatch

+ var ErrMissingLengthRetainedMessageBatch = MissingLengthRetainedMessageBatch

+ var ErrMissingMaxTimestampRetainedMessageBatch = MissingMaxTimestampRetainedMessageBatch

+ var ErrMissingPayloadRetainedMessageBatch = MissingPayloadRetainedMessageBatch

+ var ErrNoPartitions = NoPartitions

+ var ErrNonZeroOffset = NonZeroOffset

+ var ErrNonZeroTimestamp = NonZeroTimestamp

+ var ErrNotConnected = NotConnected

+ var ErrPartitionNotFound = PartitionNotFound

+ var ErrPersonalAccessTokenAlreadyExists = PersonalAccessTokenAlreadyExists

+ var ErrPersonalAccessTokenExpired = PersonalAccessTokenExpired

+ var ErrPersonalAccessTokensLimitReached = PersonalAccessTokensLimitReached

+ var ErrProducerClosed = ProducerClosed

+ var ErrProducerSendFailed = ProducerSendFailed

+ var ErrQuicError = QuicError

+ var ErrResourceNotFound = ResourceNotFound

+ var ErrSegmentClosed = SegmentClosed

+ var ErrSegmentNotFound = SegmentNotFound

+ var ErrSnapshotFileCompletionFailed = SnapshotFileCompletionFailed

+ var ErrStaleClient = StaleClient

+ var ErrStateFileCorrupted = StateFileCorrupted

+ var ErrStateFileNotFound = StateFileNotFound

+ var ErrStreamIdAlreadyExists = StreamIdAlreadyExists

+ var ErrStreamIdNotFound = StreamIdNotFound

+ var ErrStreamNameAlreadyExists = StreamNameAlreadyExists

+ var ErrStreamNameNotFound = StreamNameNotFound

+ var ErrTcpError = TcpError

+ var ErrTooBigMessagePayload = TooBigMessagePayload

+ var ErrTooBigUserHeaders = TooBigUserHeaders

+ var ErrTooManyMessages = TooManyMessages

+ var ErrTooManyPartitions = TooManyPartitions

+ var ErrTooSmallMessage = TooSmallMessage

+ var ErrTopicFull = TopicFull

+ var ErrTopicIdAlreadyExists = TopicIdAlreadyExists

+ var ErrTopicIdNotFound = TopicIdNotFound

+ var ErrTopicNameAlreadyExists = TopicNameAlreadyExists

+ var ErrTopicNameNotFound = TopicNameNotFound

+ var ErrUnauthenticated = Unauthenticated

+ var ErrUnauthorized = Unauthorized

+ var ErrUserAlreadyExists = UserAlreadyExists

+ var ErrUserInactive = UserInactive

+ var ErrUsersLimitReached = UsersLimitReached

+ type AccessTokenMissing struct

+ func (e AccessTokenMissing) Code() Code

+ func (e AccessTokenMissing) Error() string

+ func (e AccessTokenMissing) Is(target error) bool

+ type BackgroundSendBufferFull struct

+ func (e BackgroundSendBufferFull) Code() Code

+ func (e BackgroundSendBufferFull) Error() string

+ func (e BackgroundSendBufferFull) Is(target error) bool

+ type BackgroundSendBufferOverflow struct

+ func (e BackgroundSendBufferOverflow) Code() Code

+ func (e BackgroundSendBufferOverflow) Error() string

+ func (e BackgroundSendBufferOverflow) Is(target error) bool

+ type BackgroundSendError struct

+ func (e BackgroundSendError) Code() Code

+ func (e BackgroundSendError) Error() string

+ func (e BackgroundSendError) Is(target error) bool

+ type BackgroundSendTimeout struct

+ func (e BackgroundSendTimeout) Code() Code

+ func (e BackgroundSendTimeout) Error() string

+ func (e BackgroundSendTimeout) Is(target error) bool

+ type BackgroundWorkerDisconnected struct

+ func (e BackgroundWorkerDisconnected) Code() Code

+ func (e BackgroundWorkerDisconnected) Error() string

+ func (e BackgroundWorkerDisconnected) Is(target error) bool

+ type CannotAppendMessage struct

+ func (e CannotAppendMessage) Code() Code

+ func (e CannotAppendMessage) Error() string

+ func (e CannotAppendMessage) Is(target error) bool

+ type CannotAppendToFile struct

+ func (e CannotAppendToFile) Code() Code

+ func (e CannotAppendToFile) Error() string

+ func (e CannotAppendToFile) Is(target error) bool

+ type CannotChangePermissions struct

+ ID uint32

+ func (e CannotChangePermissions) Code() Code

+ func (e CannotChangePermissions) Error() string

+ func (e CannotChangePermissions) Is(target error) bool

+ type CannotCreateBaseDirectory struct

+ Path string

+ func (e CannotCreateBaseDirectory) Code() Code

+ func (e CannotCreateBaseDirectory) Error() string

+ func (e CannotCreateBaseDirectory) Is(target error) bool

+ type CannotCreateConsumerGroupInfo struct

+ GroupId uint32

+ StreamId uint32

+ TopicId uint32

+ func (e CannotCreateConsumerGroupInfo) Code() Code

+ func (e CannotCreateConsumerGroupInfo) Error() string

+ func (e CannotCreateConsumerGroupInfo) Is(target error) bool

+ type CannotCreateConsumerOffsetsDirectory struct

+ Path string

+ func (e CannotCreateConsumerOffsetsDirectory) Code() Code

+ func (e CannotCreateConsumerOffsetsDirectory) Error() string

+ func (e CannotCreateConsumerOffsetsDirectory) Is(target error) bool

+ type CannotCreateEndpoint struct

+ func (e CannotCreateEndpoint) Code() Code

+ func (e CannotCreateEndpoint) Error() string

+ func (e CannotCreateEndpoint) Is(target error) bool

+ type CannotCreatePartition struct

+ PartitionId uint32

+ StreamId uint32

+ TopicId uint32

+ func (e CannotCreatePartition) Code() Code

+ func (e CannotCreatePartition) Error() string

+ func (e CannotCreatePartition) Is(target error) bool

+ type CannotCreatePartitionDirectory struct

+ PartitionId uint32

+ StreamId uint32

+ TopicId uint32

+ func (e CannotCreatePartitionDirectory) Code() Code

+ func (e CannotCreatePartitionDirectory) Error() string

+ func (e CannotCreatePartitionDirectory) Is(target error) bool

+ type CannotCreatePartitionsDirectory struct

+ StreamId uint32

+ TopicId uint32

+ func (e CannotCreatePartitionsDirectory) Code() Code

+ func (e CannotCreatePartitionsDirectory) Error() string

+ func (e CannotCreatePartitionsDirectory) Is(target error) bool

+ type CannotCreateRuntimeDirectory struct

+ Path string

+ func (e CannotCreateRuntimeDirectory) Code() Code

+ func (e CannotCreateRuntimeDirectory) Error() string

+ func (e CannotCreateRuntimeDirectory) Is(target error) bool

+ type CannotCreateSegmentIndexFile struct

+ Path string

+ func (e CannotCreateSegmentIndexFile) Code() Code

+ func (e CannotCreateSegmentIndexFile) Error() string

+ func (e CannotCreateSegmentIndexFile) Is(target error) bool

+ type CannotCreateSegmentLogFile struct

+ Path string

+ func (e CannotCreateSegmentLogFile) Code() Code

+ func (e CannotCreateSegmentLogFile) Error() string

+ func (e CannotCreateSegmentLogFile) Is(target error) bool

+ type CannotCreateSegmentTimeIndexFile struct

+ Path string

+ func (e CannotCreateSegmentTimeIndexFile) Code() Code

+ func (e CannotCreateSegmentTimeIndexFile) Error() string

+ func (e CannotCreateSegmentTimeIndexFile) Is(target error) bool

+ type CannotCreateStateDirectory struct

+ Path string

+ func (e CannotCreateStateDirectory) Code() Code

+ func (e CannotCreateStateDirectory) Error() string

+ func (e CannotCreateStateDirectory) Is(target error) bool

+ type CannotCreateStream struct

+ ID uint32

+ func (e CannotCreateStream) Code() Code

+ func (e CannotCreateStream) Error() string

+ func (e CannotCreateStream) Is(target error) bool

+ type CannotCreateStreamDirectory struct

+ ID uint32

+ Path string

+ func (e CannotCreateStreamDirectory) Code() Code

+ func (e CannotCreateStreamDirectory) Error() string

+ func (e CannotCreateStreamDirectory) Is(target error) bool

+ type CannotCreateStreamInfo struct

+ ID uint32

+ func (e CannotCreateStreamInfo) Code() Code

+ func (e CannotCreateStreamInfo) Error() string

+ func (e CannotCreateStreamInfo) Is(target error) bool

+ type CannotCreateStreamsDirectory struct

+ Path string

+ func (e CannotCreateStreamsDirectory) Code() Code

+ func (e CannotCreateStreamsDirectory) Error() string

+ func (e CannotCreateStreamsDirectory) Is(target error) bool

+ type CannotCreateTopic struct

+ StreamId uint32

+ TopicId uint32

+ func (e CannotCreateTopic) Code() Code

+ func (e CannotCreateTopic) Error() string

+ func (e CannotCreateTopic) Is(target error) bool

+ type CannotCreateTopicDirectory struct

+ Path string

+ StreamId uint32

+ TopicId uint32

+ func (e CannotCreateTopicDirectory) Code() Code

+ func (e CannotCreateTopicDirectory) Error() string

+ func (e CannotCreateTopicDirectory) Is(target error) bool

+ type CannotCreateTopicInfo struct

+ StreamId uint32

+ TopicId uint32

+ func (e CannotCreateTopicInfo) Code() Code

+ func (e CannotCreateTopicInfo) Error() string

+ func (e CannotCreateTopicInfo) Is(target error) bool

+ type CannotCreateTopicsDirectory struct

+ ID uint32

+ Path string

+ func (e CannotCreateTopicsDirectory) Code() Code

+ func (e CannotCreateTopicsDirectory) Error() string

+ func (e CannotCreateTopicsDirectory) Is(target error) bool

+ type CannotDecryptData struct

+ func (e CannotDecryptData) Code() Code

+ func (e CannotDecryptData) Error() string

+ func (e CannotDecryptData) Is(target error) bool

+ type CannotDeleteConsumerGroupInfo struct

+ GroupId uint32

+ StreamId uint32

+ TopicId uint32

+ func (e CannotDeleteConsumerGroupInfo) Code() Code

+ func (e CannotDeleteConsumerGroupInfo) Error() string

+ func (e CannotDeleteConsumerGroupInfo) Is(target error) bool

+ type CannotDeleteConsumerOffsetFile struct

+ Path string

+ func (e CannotDeleteConsumerOffsetFile) Code() Code

+ func (e CannotDeleteConsumerOffsetFile) Error() string

+ func (e CannotDeleteConsumerOffsetFile) Is(target error) bool

+ type CannotDeleteConsumerOffsetsDirectory struct

+ Path string

+ func (e CannotDeleteConsumerOffsetsDirectory) Code() Code

+ func (e CannotDeleteConsumerOffsetsDirectory) Error() string

+ func (e CannotDeleteConsumerOffsetsDirectory) Is(target error) bool

+ type CannotDeleteFile struct

+ func (e CannotDeleteFile) Code() Code

+ func (e CannotDeleteFile) Error() string

+ func (e CannotDeleteFile) Is(target error) bool

+ type CannotDeletePartition struct

+ PartitionId uint32

+ StreamId uint32

+ TopicId uint32

+ func (e CannotDeletePartition) Code() Code

+ func (e CannotDeletePartition) Error() string

+ func (e CannotDeletePartition) Is(target error) bool

+ type CannotDeletePartitionDirectory struct

+ PartitionId uint32

+ StreamId uint32

+ TopicId uint32

+ func (e CannotDeletePartitionDirectory) Code() Code

+ func (e CannotDeletePartitionDirectory) Error() string

+ func (e CannotDeletePartitionDirectory) Is(target error) bool

+ type CannotDeleteStream struct

+ ID uint32

+ func (e CannotDeleteStream) Code() Code

+ func (e CannotDeleteStream) Error() string

+ func (e CannotDeleteStream) Is(target error) bool

+ type CannotDeleteStreamDirectory struct

+ ID uint32

+ func (e CannotDeleteStreamDirectory) Code() Code

+ func (e CannotDeleteStreamDirectory) Error() string

+ func (e CannotDeleteStreamDirectory) Is(target error) bool

+ type CannotDeleteTopic struct

+ StreamId uint32

+ TopicId uint32

+ func (e CannotDeleteTopic) Code() Code

+ func (e CannotDeleteTopic) Error() string

+ func (e CannotDeleteTopic) Is(target error) bool

+ type CannotDeleteTopicDirectory struct

+ Path string

+ StreamId uint32

+ TopicId uint32

+ func (e CannotDeleteTopicDirectory) Code() Code

+ func (e CannotDeleteTopicDirectory) Error() string

+ func (e CannotDeleteTopicDirectory) Is(target error) bool

+ type CannotDeleteUser struct

+ ID uint32

+ func (e CannotDeleteUser) Code() Code

+ func (e CannotDeleteUser) Error() string

+ func (e CannotDeleteUser) Is(target error) bool

+ type CannotDeserializeResource struct

+ func (e CannotDeserializeResource) Code() Code

+ func (e CannotDeserializeResource) Error() string

+ func (e CannotDeserializeResource) Is(target error) bool

+ type CannotEncryptData struct

+ func (e CannotEncryptData) Code() Code

+ func (e CannotEncryptData) Error() string

+ func (e CannotEncryptData) Is(target error) bool

+ type CannotEstablishConnection struct

+ func (e CannotEstablishConnection) Code() Code

+ func (e CannotEstablishConnection) Error() string

+ func (e CannotEstablishConnection) Is(target error) bool

+ type CannotGenerateJwt struct

+ func (e CannotGenerateJwt) Code() Code

+ func (e CannotGenerateJwt) Error() string

+ func (e CannotGenerateJwt) Is(target error) bool

+ type CannotOpenDatabase struct

+ Path string

+ func (e CannotOpenDatabase) Code() Code

+ func (e CannotOpenDatabase) Error() string

+ func (e CannotOpenDatabase) Is(target error) bool

+ type CannotOpenPartitionLogFile struct

+ func (e CannotOpenPartitionLogFile) Code() Code

+ func (e CannotOpenPartitionLogFile) Error() string

+ func (e CannotOpenPartitionLogFile) Is(target error) bool

+ type CannotOpenStreamInfo struct

+ ID uint32

+ func (e CannotOpenStreamInfo) Code() Code

+ func (e CannotOpenStreamInfo) Error() string

+ func (e CannotOpenStreamInfo) Is(target error) bool

+ type CannotOpenTopicInfo struct

+ StreamId uint32

+ TopicId uint32

+ func (e CannotOpenTopicInfo) Code() Code

+ func (e CannotOpenTopicInfo) Error() string

+ func (e CannotOpenTopicInfo) Is(target error) bool

+ type CannotOverwriteFile struct

+ func (e CannotOverwriteFile) Code() Code

+ func (e CannotOverwriteFile) Error() string

+ func (e CannotOverwriteFile) Is(target error) bool

+ type CannotParseHeaderKind struct

+ Str string

+ func (e CannotParseHeaderKind) Code() Code

+ func (e CannotParseHeaderKind) Error() string

+ func (e CannotParseHeaderKind) Is(target error) bool

+ type CannotParseUrl struct

+ func (e CannotParseUrl) Code() Code

+ func (e CannotParseUrl) Error() string

+ func (e CannotParseUrl) Is(target error) bool

+ type CannotPollTopic struct

+ func (e CannotPollTopic) Code() Code

+ func (e CannotPollTopic) Error() string

+ func (e CannotPollTopic) Is(target error) bool

+ type CannotReadBatchBaseOffset struct

+ func (e CannotReadBatchBaseOffset) Code() Code

+ func (e CannotReadBatchBaseOffset) Error() string

+ func (e CannotReadBatchBaseOffset) Is(target error) bool

+ type CannotReadBatchLength struct

+ func (e CannotReadBatchLength) Code() Code

+ func (e CannotReadBatchLength) Error() string

+ func (e CannotReadBatchLength) Is(target error) bool

+ type CannotReadBatchPayload struct

+ func (e CannotReadBatchPayload) Code() Code

+ func (e CannotReadBatchPayload) Error() string

+ func (e CannotReadBatchPayload) Is(target error) bool

+ type CannotReadConsumerOffsets struct

+ Path string

+ func (e CannotReadConsumerOffsets) Code() Code

+ func (e CannotReadConsumerOffsets) Error() string

+ func (e CannotReadConsumerOffsets) Is(target error) bool

+ type CannotReadFile struct

+ func (e CannotReadFile) Code() Code

+ func (e CannotReadFile) Error() string

+ func (e CannotReadFile) Is(target error) bool

+ type CannotReadFileMetadata struct

+ func (e CannotReadFileMetadata) Code() Code

+ func (e CannotReadFileMetadata) Error() string

+ func (e CannotReadFileMetadata) Is(target error) bool

+ type CannotReadHeadersLength struct

+ func (e CannotReadHeadersLength) Code() Code

+ func (e CannotReadHeadersLength) Error() string

+ func (e CannotReadHeadersLength) Is(target error) bool

+ type CannotReadHeadersPayload struct

+ func (e CannotReadHeadersPayload) Code() Code

+ func (e CannotReadHeadersPayload) Error() string

+ func (e CannotReadHeadersPayload) Is(target error) bool

+ type CannotReadIndexOffset struct

+ func (e CannotReadIndexOffset) Code() Code

+ func (e CannotReadIndexOffset) Error() string

+ func (e CannotReadIndexOffset) Is(target error) bool

+ type CannotReadIndexPosition struct

+ func (e CannotReadIndexPosition) Code() Code

+ func (e CannotReadIndexPosition) Error() string

+ func (e CannotReadIndexPosition) Is(target error) bool

+ type CannotReadIndexTimestamp struct

+ func (e CannotReadIndexTimestamp) Code() Code

+ func (e CannotReadIndexTimestamp) Error() string

+ func (e CannotReadIndexTimestamp) Is(target error) bool

+ type CannotReadLastOffsetDelta struct

+ func (e CannotReadLastOffsetDelta) Code() Code

+ func (e CannotReadLastOffsetDelta) Error() string

+ func (e CannotReadLastOffsetDelta) Is(target error) bool

+ type CannotReadMaxTimestamp struct

+ func (e CannotReadMaxTimestamp) Code() Code

+ func (e CannotReadMaxTimestamp) Error() string

+ func (e CannotReadMaxTimestamp) Is(target error) bool

+ type CannotReadMessage struct

+ func (e CannotReadMessage) Code() Code

+ func (e CannotReadMessage) Error() string

+ func (e CannotReadMessage) Is(target error) bool

+ type CannotReadMessageChecksum struct

+ func (e CannotReadMessageChecksum) Code() Code

+ func (e CannotReadMessageChecksum) Error() string

+ func (e CannotReadMessageChecksum) Is(target error) bool

+ type CannotReadMessageId struct

+ func (e CannotReadMessageId) Code() Code

+ func (e CannotReadMessageId) Error() string

+ func (e CannotReadMessageId) Is(target error) bool

+ type CannotReadMessageLength struct

+ func (e CannotReadMessageLength) Code() Code

+ func (e CannotReadMessageLength) Error() string

+ func (e CannotReadMessageLength) Is(target error) bool

+ type CannotReadMessagePayload struct

+ func (e CannotReadMessagePayload) Code() Code

+ func (e CannotReadMessagePayload) Error() string

+ func (e CannotReadMessagePayload) Is(target error) bool

+ type CannotReadMessageState struct

+ func (e CannotReadMessageState) Code() Code

+ func (e CannotReadMessageState) Error() string

+ func (e CannotReadMessageState) Is(target error) bool

+ type CannotReadMessageTimestamp struct

+ func (e CannotReadMessageTimestamp) Code() Code

+ func (e CannotReadMessageTimestamp) Error() string

+ func (e CannotReadMessageTimestamp) Is(target error) bool

+ type CannotReadPartitions struct

+ func (e CannotReadPartitions) Code() Code

+ func (e CannotReadPartitions) Error() string

+ func (e CannotReadPartitions) Is(target error) bool

+ type CannotReadStreamInfo struct

+ ID uint32

+ func (e CannotReadStreamInfo) Code() Code

+ func (e CannotReadStreamInfo) Error() string

+ func (e CannotReadStreamInfo) Is(target error) bool

+ type CannotReadStreams struct

+ func (e CannotReadStreams) Code() Code

+ func (e CannotReadStreams) Error() string

+ func (e CannotReadStreams) Is(target error) bool

+ type CannotReadTopicInfo struct

+ StreamId uint32

+ TopicId uint32

+ func (e CannotReadTopicInfo) Code() Code

+ func (e CannotReadTopicInfo) Error() string

+ func (e CannotReadTopicInfo) Is(target error) bool

+ type CannotReadTopics struct

+ ID uint32

+ func (e CannotReadTopics) Code() Code

+ func (e CannotReadTopics) Error() string

+ func (e CannotReadTopics) Is(target error) bool

+ type CannotRemoveRuntimeDirectory struct

+ Path string

+ func (e CannotRemoveRuntimeDirectory) Code() Code

+ func (e CannotRemoveRuntimeDirectory) Error() string

+ func (e CannotRemoveRuntimeDirectory) Is(target error) bool

+ type CannotSaveIndexToSegment struct

+ func (e CannotSaveIndexToSegment) Code() Code

+ func (e CannotSaveIndexToSegment) Error() string

+ func (e CannotSaveIndexToSegment) Is(target error) bool

+ type CannotSaveMessagesToSegment struct

+ func (e CannotSaveMessagesToSegment) Code() Code

+ func (e CannotSaveMessagesToSegment) Error() string

+ func (e CannotSaveMessagesToSegment) Is(target error) bool

+ type CannotSaveTimeIndexToSegment struct

+ func (e CannotSaveTimeIndexToSegment) Code() Code

+ func (e CannotSaveTimeIndexToSegment) Error() string

+ func (e CannotSaveTimeIndexToSegment) Is(target error) bool

+ type CannotSeekFile struct

+ func (e CannotSeekFile) Code() Code

+ func (e CannotSeekFile) Error() string

+ func (e CannotSeekFile) Is(target error) bool

+ type CannotSendMessagesDueToClientDisconnection struct

+ func (e CannotSendMessagesDueToClientDisconnection) Code() Code

+ func (e CannotSendMessagesDueToClientDisconnection) Error() string

+ func (e CannotSendMessagesDueToClientDisconnection) Is(target error) bool

+ type CannotSerializeResource struct

+ func (e CannotSerializeResource) Code() Code

+ func (e CannotSerializeResource) Error() string

+ func (e CannotSerializeResource) Is(target error) bool

+ type CannotSyncFile struct

+ func (e CannotSyncFile) Code() Code

+ func (e CannotSyncFile) Error() string

+ func (e CannotSyncFile) Is(target error) bool

+ type CannotUpdateStreamInfo struct

+ ID uint32

+ func (e CannotUpdateStreamInfo) Code() Code

+ func (e CannotUpdateStreamInfo) Error() string

+ func (e CannotUpdateStreamInfo) Is(target error) bool

+ type CannotUpdateTopicInfo struct

+ StreamId uint32

+ TopicId uint32

+ func (e CannotUpdateTopicInfo) Code() Code

+ func (e CannotUpdateTopicInfo) Error() string

+ func (e CannotUpdateTopicInfo) Is(target error) bool

+ type CannotWriteToFile struct

+ func (e CannotWriteToFile) Code() Code

+ func (e CannotWriteToFile) Error() string

+ func (e CannotWriteToFile) Is(target error) bool

+ type ClientNotFound struct

+ ID uint32

+ func (e ClientNotFound) Code() Code

+ func (e ClientNotFound) Error() string

+ func (e ClientNotFound) Is(target error) bool

+ type ClientShutdown struct

+ func (e ClientShutdown) Code() Code

+ func (e ClientShutdown) Error() string

+ func (e ClientShutdown) Is(target error) bool

+ type Code uint32

+ const AccessTokenMissingCode

+ const BackgroundSendBufferFullCode

+ const BackgroundSendBufferOverflowCode

+ const BackgroundSendErrorCode

+ const BackgroundSendTimeoutCode

+ const BackgroundWorkerDisconnectedCode

+ const CannotAppendMessageCode

+ const CannotAppendToFileCode

+ const CannotChangePermissionsCode

+ const CannotCreateBaseDirectoryCode

+ const CannotCreateConsumerGroupInfoCode

+ const CannotCreateConsumerOffsetsDirectoryCode

+ const CannotCreateEndpointCode

+ const CannotCreatePartitionCode

+ const CannotCreatePartitionDirectoryCode

+ const CannotCreatePartitionsDirectoryCode

+ const CannotCreateRuntimeDirectoryCode

+ const CannotCreateSegmentIndexFileCode

+ const CannotCreateSegmentLogFileCode

+ const CannotCreateSegmentTimeIndexFileCode

+ const CannotCreateStateDirectoryCode

+ const CannotCreateStreamCode

+ const CannotCreateStreamDirectoryCode

+ const CannotCreateStreamInfoCode

+ const CannotCreateStreamsDirectoryCode

+ const CannotCreateTopicCode

+ const CannotCreateTopicDirectoryCode

+ const CannotCreateTopicInfoCode

+ const CannotCreateTopicsDirectoryCode

+ const CannotDecryptDataCode

+ const CannotDeleteConsumerGroupInfoCode

+ const CannotDeleteConsumerOffsetFileCode

+ const CannotDeleteConsumerOffsetsDirectoryCode

+ const CannotDeleteFileCode

+ const CannotDeletePartitionCode

+ const CannotDeletePartitionDirectoryCode

+ const CannotDeleteStreamCode

+ const CannotDeleteStreamDirectoryCode

+ const CannotDeleteTopicCode

+ const CannotDeleteTopicDirectoryCode

+ const CannotDeleteUserCode

+ const CannotDeserializeResourceCode

+ const CannotEncryptDataCode

+ const CannotEstablishConnectionCode

+ const CannotGenerateJwtCode

+ const CannotOpenDatabaseCode

+ const CannotOpenPartitionLogFileCode

+ const CannotOpenStreamInfoCode

+ const CannotOpenTopicInfoCode

+ const CannotOverwriteFileCode

+ const CannotParseHeaderKindCode

+ const CannotParseUrlCode

+ const CannotPollTopicCode

+ const CannotReadBatchBaseOffsetCode

+ const CannotReadBatchLengthCode

+ const CannotReadBatchPayloadCode

+ const CannotReadConsumerOffsetsCode

+ const CannotReadFileCode

+ const CannotReadFileMetadataCode

+ const CannotReadHeadersLengthCode

+ const CannotReadHeadersPayloadCode

+ const CannotReadIndexOffsetCode

+ const CannotReadIndexPositionCode

+ const CannotReadIndexTimestampCode

+ const CannotReadLastOffsetDeltaCode

+ const CannotReadMaxTimestampCode

+ const CannotReadMessageChecksumCode

+ const CannotReadMessageCode

+ const CannotReadMessageIdCode

+ const CannotReadMessageLengthCode

+ const CannotReadMessagePayloadCode

+ const CannotReadMessageStateCode

+ const CannotReadMessageTimestampCode

+ const CannotReadPartitionsCode

+ const CannotReadStreamInfoCode

+ const CannotReadStreamsCode

+ const CannotReadTopicInfoCode

+ const CannotReadTopicsCode

+ const CannotRemoveRuntimeDirectoryCode

+ const CannotSaveIndexToSegmentCode

+ const CannotSaveMessagesToSegmentCode

+ const CannotSaveTimeIndexToSegmentCode

+ const CannotSeekFileCode

+ const CannotSendMessagesDueToClientDisconnectionCode

+ const CannotSerializeResourceCode

+ const CannotSyncFileCode

+ const CannotUpdateStreamInfoCode

+ const CannotUpdateTopicInfoCode

+ const CannotWriteToFileCode

+ const ClientNotFoundCode

+ const ClientShutdownCode

+ const CommandLengthErrorCode

+ const ConnectionClosedCode

+ const ConsumerGroupIdAlreadyExistsCode

+ const ConsumerGroupIdNotFoundCode

+ const ConsumerGroupMemberNotFoundCode

+ const ConsumerGroupNameAlreadyExistsCode

+ const ConsumerGroupNameNotFoundCode

+ const ConsumerOffsetNotFoundCode

+ const DisconnectedCode

+ const EmptyMessagePayloadCode

+ const EmptyResponseCode

+ const ErrorCode

+ const FailedToAddCertificateCode

+ const FeatureUnavailableCode

+ const HttpResponseErrorCode

+ const InvalidAccessTokenCode

+ const InvalidBooleanValueCode

+ const InvalidBytesResponseCode

+ const InvalidClientAddressCode

+ const InvalidClientIdCode

+ const InvalidCommandCode

+ const InvalidConfigurationCode

+ const InvalidConnectionStringCode

+ const InvalidConsumerGroupIdCode

+ const InvalidConsumerGroupNameCode

+ const InvalidCredentialsCode

+ const InvalidEncryptionKeyCode

+ const InvalidFormatCode

+ const InvalidHeaderKeyCode

+ const InvalidHeaderValueCode

+ const InvalidHttpRequestCode

+ const InvalidIdentifierCode

+ const InvalidIndexesByteSizeCode

+ const InvalidIndexesCountCode

+ const InvalidIpAddressCode

+ const InvalidJsonResponseCode

+ const InvalidJwtAlgorithmCode

+ const InvalidJwtSecretCode

+ const InvalidKeyValueLengthCode

+ const InvalidMessageChecksumCode

+ const InvalidMessagePayloadLengthCode

+ const InvalidMessagesCountCode

+ const InvalidMessagesSizeCode

+ const InvalidNumberEncodingCode

+ const InvalidNumberValueCode

+ const InvalidOffsetCode

+ const InvalidPasswordCode

+ const InvalidPersonalAccessTokenCode

+ const InvalidPersonalAccessTokenNameCode

+ const InvalidReplicationFactorCode

+ const InvalidSegmentSizeCode

+ const InvalidSegmentsCountCode

+ const InvalidServerAddressCode

+ const InvalidSizeBytesCode

+ const InvalidStateEntryChecksumCode

+ const InvalidStreamIdCode

+ const InvalidStreamNameCode

+ const InvalidTlsCertificateCode

+ const InvalidTlsCertificatePathCode

+ const InvalidTlsDomainCode

+ const InvalidTopicIdCode

+ const InvalidTopicNameCode

+ const InvalidTopicSizeCode

+ const InvalidUserStatusCode

+ const InvalidUsernameCode

+ const InvalidUtf8Code

+ const InvalidVersionCode

+ const JwtMissingCode

+ const MissingBaseOffsetRetainedMessageBatchCode

+ const MissingIndexCode

+ const MissingLastOffsetDeltaRetainedMessageBatchCode

+ const MissingLengthRetainedMessageBatchCode

+ const MissingMaxTimestampRetainedMessageBatchCode

+ const MissingPayloadRetainedMessageBatchCode

+ const NoPartitionsCode

+ const NonZeroOffsetCode

+ const NonZeroTimestampCode

+ const NotConnectedCode

+ const PartitionNotFoundCode

+ const PersonalAccessTokenAlreadyExistsCode

+ const PersonalAccessTokenExpiredCode

+ const PersonalAccessTokensLimitReachedCode

+ const ProducerClosedCode

+ const ProducerSendFailedCode

+ const QuicErrorCode

+ const ResourceNotFoundCode

+ const SegmentClosedCode

+ const SegmentNotFoundCode

+ const SnapshotFileCompletionFailedCode

+ const StaleClientCode

+ const StateFileCorruptedCode

+ const StateFileNotFoundCode

+ const StreamIdAlreadyExistsCode

+ const StreamIdNotFoundCode

+ const StreamNameAlreadyExistsCode

+ const StreamNameNotFoundCode

+ const TcpErrorCode

+ const TooBigMessagePayloadCode

+ const TooBigUserHeadersCode

+ const TooManyMessagesCode

+ const TooManyPartitionsCode

+ const TooSmallMessageCode

+ const TopicFullCode

+ const TopicIdAlreadyExistsCode

+ const TopicIdNotFoundCode

+ const TopicNameAlreadyExistsCode

+ const TopicNameNotFoundCode

+ const UnauthenticatedCode

+ const UnauthorizedCode

+ const UserAlreadyExistsCode

+ const UserInactiveCode

+ const UsersLimitReachedCode

+ func (c Code) String() string

+ type CommandLengthError struct

+ Detail string

+ func (e CommandLengthError) Code() Code

+ func (e CommandLengthError) Error() string

+ func (e CommandLengthError) Is(target error) bool

+ type ConnectionClosed struct

+ func (e ConnectionClosed) Code() Code

+ func (e ConnectionClosed) Error() string

+ func (e ConnectionClosed) Is(target error) bool

+ type ConsumerGroupIdAlreadyExists struct

+ GroupId uint32

+ TopicId uint32

+ func (e ConsumerGroupIdAlreadyExists) Code() Code

+ func (e ConsumerGroupIdAlreadyExists) Error() string

+ func (e ConsumerGroupIdAlreadyExists) Is(target error) bool

type ConsumerGroupIdNotFound

+ GroupId uint32

+ TopicId uint32

+ func (e ConsumerGroupIdNotFound) Code() Code

+ func (e ConsumerGroupIdNotFound) Error() string

+ func (e ConsumerGroupIdNotFound) Is(target error) bool

+ type ConsumerGroupMemberNotFound struct

+ GroupId uint32

+ MemberId uint32

+ TopicId uint32

+ func (e ConsumerGroupMemberNotFound) Code() Code

+ func (e ConsumerGroupMemberNotFound) Error() string

+ func (e ConsumerGroupMemberNotFound) Is(target error) bool

+ type ConsumerGroupNameAlreadyExists struct

+ Name string

+ TopicId uint32

+ func (e ConsumerGroupNameAlreadyExists) Code() Code

+ func (e ConsumerGroupNameAlreadyExists) Error() string

+ func (e ConsumerGroupNameAlreadyExists) Is(target error) bool

+ type ConsumerGroupNameNotFound struct

+ Name string

+ TopicId string

+ func (e ConsumerGroupNameNotFound) Code() Code

+ func (e ConsumerGroupNameNotFound) Error() string

+ func (e ConsumerGroupNameNotFound) Is(target error) bool

+ type ConsumerOffsetNotFound struct

+ ID uint32

+ func (e ConsumerOffsetNotFound) Code() Code

+ func (e ConsumerOffsetNotFound) Error() string

+ func (e ConsumerOffsetNotFound) Is(target error) bool

+ type Disconnected struct

+ func (e Disconnected) Code() Code

+ func (e Disconnected) Error() string

+ func (e Disconnected) Is(target error) bool

+ type EmptyMessagePayload struct

+ func (e EmptyMessagePayload) Code() Code

+ func (e EmptyMessagePayload) Error() string

+ func (e EmptyMessagePayload) Is(target error) bool

+ type EmptyResponse struct

+ func (e EmptyResponse) Code() Code

+ func (e EmptyResponse) Error() string

+ func (e EmptyResponse) Is(target error) bool

+ type Error struct

+ func (e Error) Code() Code

+ func (e Error) Error() string

+ func (e Error) Is(target error) bool

+ type FailedToAddCertificate struct

+ func (e FailedToAddCertificate) Code() Code

+ func (e FailedToAddCertificate) Error() string

+ func (e FailedToAddCertificate) Is(target error) bool

+ type FeatureUnavailable struct

+ func (e FeatureUnavailable) Code() Code

+ func (e FeatureUnavailable) Error() string

+ func (e FeatureUnavailable) Is(target error) bool

+ type HttpResponseError struct

+ Reason string

+ Status uint16

+ func (e HttpResponseError) Code() Code

+ func (e HttpResponseError) Error() string

+ func (e HttpResponseError) Is(target error) bool

type IggyError

+ func FromCode(code Code) IggyError

+ type InvalidAccessToken struct

+ func (e InvalidAccessToken) Code() Code

+ func (e InvalidAccessToken) Error() string

+ func (e InvalidAccessToken) Is(target error) bool

+ type InvalidBooleanValue struct

+ func (e InvalidBooleanValue) Code() Code

+ func (e InvalidBooleanValue) Error() string

+ func (e InvalidBooleanValue) Is(target error) bool

+ type InvalidBytesResponse struct

+ func (e InvalidBytesResponse) Code() Code

+ func (e InvalidBytesResponse) Error() string

+ func (e InvalidBytesResponse) Is(target error) bool

+ type InvalidClientAddress struct

+ func (e InvalidClientAddress) Code() Code

+ func (e InvalidClientAddress) Error() string

+ func (e InvalidClientAddress) Is(target error) bool

+ type InvalidClientId struct

+ func (e InvalidClientId) Code() Code

+ func (e InvalidClientId) Error() string

+ func (e InvalidClientId) Is(target error) bool

+ type InvalidCommand struct

+ func (e InvalidCommand) Code() Code

+ func (e InvalidCommand) Error() string

+ func (e InvalidCommand) Is(target error) bool

type InvalidConfiguration

+ func (e InvalidConfiguration) Code() Code

+ func (e InvalidConfiguration) Error() string

+ func (e InvalidConfiguration) Is(target error) bool

+ type InvalidConnectionString struct

+ func (e InvalidConnectionString) Code() Code

+ func (e InvalidConnectionString) Error() string

+ func (e InvalidConnectionString) Is(target error) bool

+ type InvalidConsumerGroupId struct

+ func (e InvalidConsumerGroupId) Code() Code

+ func (e InvalidConsumerGroupId) Error() string

+ func (e InvalidConsumerGroupId) Is(target error) bool

+ type InvalidConsumerGroupName struct

+ func (e InvalidConsumerGroupName) Code() Code

+ func (e InvalidConsumerGroupName) Error() string

+ func (e InvalidConsumerGroupName) Is(target error) bool

+ type InvalidCredentials struct

+ func (e InvalidCredentials) Code() Code

+ func (e InvalidCredentials) Error() string

+ func (e InvalidCredentials) Is(target error) bool

+ type InvalidEncryptionKey struct

+ func (e InvalidEncryptionKey) Code() Code

+ func (e InvalidEncryptionKey) Error() string

+ func (e InvalidEncryptionKey) Is(target error) bool

+ type InvalidFormat struct

+ func (e InvalidFormat) Code() Code

+ func (e InvalidFormat) Error() string

+ func (e InvalidFormat) Is(target error) bool

+ type InvalidHeaderKey struct

+ func (e InvalidHeaderKey) Code() Code

+ func (e InvalidHeaderKey) Error() string

+ func (e InvalidHeaderKey) Is(target error) bool

+ type InvalidHeaderValue struct

+ func (e InvalidHeaderValue) Code() Code

+ func (e InvalidHeaderValue) Error() string

+ func (e InvalidHeaderValue) Is(target error) bool

+ type InvalidHttpRequest struct

+ func (e InvalidHttpRequest) Code() Code

+ func (e InvalidHttpRequest) Error() string

+ func (e InvalidHttpRequest) Is(target error) bool

type InvalidIdentifier

+ func (e InvalidIdentifier) Code() Code

+ func (e InvalidIdentifier) Error() string

+ func (e InvalidIdentifier) Is(target error) bool

+ type InvalidIndexesByteSize struct

+ Size uint32

+ func (e InvalidIndexesByteSize) Code() Code

+ func (e InvalidIndexesByteSize) Error() string

+ func (e InvalidIndexesByteSize) Is(target error) bool

+ type InvalidIndexesCount struct

+ Count uint32

+ Expected uint32

+ func (e InvalidIndexesCount) Code() Code

+ func (e InvalidIndexesCount) Error() string

+ func (e InvalidIndexesCount) Is(target error) bool

+ type InvalidIpAddress struct

+ IP string

+ Port string

+ func (e InvalidIpAddress) Code() Code

+ func (e InvalidIpAddress) Error() string

+ func (e InvalidIpAddress) Is(target error) bool

+ type InvalidJsonResponse struct

+ func (e InvalidJsonResponse) Code() Code

+ func (e InvalidJsonResponse) Error() string

+ func (e InvalidJsonResponse) Is(target error) bool

+ type InvalidJwtAlgorithm struct

+ Algorithm string

+ func (e InvalidJwtAlgorithm) Code() Code

+ func (e InvalidJwtAlgorithm) Error() string

+ func (e InvalidJwtAlgorithm) Is(target error) bool

+ type InvalidJwtSecret struct

+ func (e InvalidJwtSecret) Code() Code

+ func (e InvalidJwtSecret) Error() string

+ func (e InvalidJwtSecret) Is(target error) bool

+ type InvalidKeyValueLength struct

+ func (e InvalidKeyValueLength) Code() Code

+ func (e InvalidKeyValueLength) Error() string

+ func (e InvalidKeyValueLength) Is(target error) bool

+ type InvalidMessageChecksum struct

+ Actual uint64

+ Expected uint64

+ Offset uint64

+ func (e InvalidMessageChecksum) Code() Code

+ func (e InvalidMessageChecksum) Error() string

+ func (e InvalidMessageChecksum) Is(target error) bool

type InvalidMessagePayloadLength

+ func (e InvalidMessagePayloadLength) Code() Code

+ func (e InvalidMessagePayloadLength) Error() string

+ func (e InvalidMessagePayloadLength) Is(target error) bool

type InvalidMessagesCount

+ func (e InvalidMessagesCount) Code() Code

+ func (e InvalidMessagesCount) Error() string

+ func (e InvalidMessagesCount) Is(target error) bool

+ type InvalidMessagesSize struct

+ Actual uint32

+ Expected uint32

+ func (e InvalidMessagesSize) Code() Code

+ func (e InvalidMessagesSize) Error() string

+ func (e InvalidMessagesSize) Is(target error) bool

+ type InvalidNumberEncoding struct

+ func (e InvalidNumberEncoding) Code() Code

+ func (e InvalidNumberEncoding) Error() string

+ func (e InvalidNumberEncoding) Is(target error) bool

+ type InvalidNumberValue struct

+ func (e InvalidNumberValue) Code() Code

+ func (e InvalidNumberValue) Error() string

+ func (e InvalidNumberValue) Is(target error) bool

+ type InvalidOffset struct

+ Offset uint64

+ func (e InvalidOffset) Code() Code

+ func (e InvalidOffset) Error() string

+ func (e InvalidOffset) Is(target error) bool

+ type InvalidPassword struct

+ func (e InvalidPassword) Code() Code

+ func (e InvalidPassword) Error() string

+ func (e InvalidPassword) Is(target error) bool

+ type InvalidPersonalAccessToken struct

+ func (e InvalidPersonalAccessToken) Code() Code

+ func (e InvalidPersonalAccessToken) Error() string

+ func (e InvalidPersonalAccessToken) Is(target error) bool

+ type InvalidPersonalAccessTokenName struct

+ func (e InvalidPersonalAccessTokenName) Code() Code

+ func (e InvalidPersonalAccessTokenName) Error() string

+ func (e InvalidPersonalAccessTokenName) Is(target error) bool

+ type InvalidReplicationFactor struct

+ func (e InvalidReplicationFactor) Code() Code

+ func (e InvalidReplicationFactor) Error() string

+ func (e InvalidReplicationFactor) Is(target error) bool

+ type InvalidSegmentSize struct

+ func (e InvalidSegmentSize) Code() Code

+ func (e InvalidSegmentSize) Error() string

+ func (e InvalidSegmentSize) Is(target error) bool

+ type InvalidSegmentsCount struct

+ Count uint32

+ func (e InvalidSegmentsCount) Code() Code

+ func (e InvalidSegmentsCount) Error() string

+ func (e InvalidSegmentsCount) Is(target error) bool

+ type InvalidServerAddress struct

+ func (e InvalidServerAddress) Code() Code

+ func (e InvalidServerAddress) Error() string

+ func (e InvalidServerAddress) Is(target error) bool

+ type InvalidSizeBytes struct

+ func (e InvalidSizeBytes) Code() Code

+ func (e InvalidSizeBytes) Error() string

+ func (e InvalidSizeBytes) Is(target error) bool

+ type InvalidStateEntryChecksum struct

+ Actual uint32

+ Expected uint32

+ Index uint64

+ func (e InvalidStateEntryChecksum) Code() Code

+ func (e InvalidStateEntryChecksum) Error() string

+ func (e InvalidStateEntryChecksum) Is(target error) bool

+ type InvalidStreamId struct

+ func (e InvalidStreamId) Code() Code

+ func (e InvalidStreamId) Error() string

+ func (e InvalidStreamId) Is(target error) bool

+ type InvalidStreamName struct

+ func (e InvalidStreamName) Code() Code

+ func (e InvalidStreamName) Error() string

+ func (e InvalidStreamName) Is(target error) bool

+ type InvalidTlsCertificate struct

+ func (e InvalidTlsCertificate) Code() Code

+ func (e InvalidTlsCertificate) Error() string

+ func (e InvalidTlsCertificate) Is(target error) bool

+ type InvalidTlsCertificatePath struct

+ func (e InvalidTlsCertificatePath) Code() Code

+ func (e InvalidTlsCertificatePath) Error() string

+ func (e InvalidTlsCertificatePath) Is(target error) bool

+ type InvalidTlsDomain struct

+ func (e InvalidTlsDomain) Code() Code

+ func (e InvalidTlsDomain) Error() string

+ func (e InvalidTlsDomain) Is(target error) bool

+ type InvalidTopicId struct

+ func (e InvalidTopicId) Code() Code

+ func (e InvalidTopicId) Error() string

+ func (e InvalidTopicId) Is(target error) bool

+ type InvalidTopicName struct

+ func (e InvalidTopicName) Code() Code

+ func (e InvalidTopicName) Error() string

+ func (e InvalidTopicName) Is(target error) bool

+ type InvalidTopicSize struct

+ MaxTopicSize uint64

+ SegmentSize uint64

+ func (e InvalidTopicSize) Code() Code

+ func (e InvalidTopicSize) Error() string

+ func (e InvalidTopicSize) Is(target error) bool

+ type InvalidUserStatus struct

+ func (e InvalidUserStatus) Code() Code

+ func (e InvalidUserStatus) Error() string

+ func (e InvalidUserStatus) Is(target error) bool

+ type InvalidUsername struct

+ func (e InvalidUsername) Code() Code

+ func (e InvalidUsername) Error() string

+ func (e InvalidUsername) Is(target error) bool

+ type InvalidUtf8 struct

+ func (e InvalidUtf8) Code() Code

+ func (e InvalidUtf8) Error() string

+ func (e InvalidUtf8) Is(target error) bool

+ type InvalidVersion struct

+ Version string

+ func (e InvalidVersion) Code() Code

+ func (e InvalidVersion) Error() string

+ func (e InvalidVersion) Is(target error) bool

+ type JwtMissing struct

+ func (e JwtMissing) Code() Code

+ func (e JwtMissing) Error() string

+ func (e JwtMissing) Is(target error) bool

+ type MissingBaseOffsetRetainedMessageBatch struct

+ func (e MissingBaseOffsetRetainedMessageBatch) Code() Code

+ func (e MissingBaseOffsetRetainedMessageBatch) Error() string

+ func (e MissingBaseOffsetRetainedMessageBatch) Is(target error) bool

+ type MissingIndex struct

+ Index uint32

+ func (e MissingIndex) Code() Code

+ func (e MissingIndex) Error() string

+ func (e MissingIndex) Is(target error) bool

+ type MissingLastOffsetDeltaRetainedMessageBatch struct

+ func (e MissingLastOffsetDeltaRetainedMessageBatch) Code() Code

+ func (e MissingLastOffsetDeltaRetainedMessageBatch) Error() string

+ func (e MissingLastOffsetDeltaRetainedMessageBatch) Is(target error) bool

+ type MissingLengthRetainedMessageBatch struct

+ func (e MissingLengthRetainedMessageBatch) Code() Code

+ func (e MissingLengthRetainedMessageBatch) Error() string

+ func (e MissingLengthRetainedMessageBatch) Is(target error) bool

+ type MissingMaxTimestampRetainedMessageBatch struct

+ func (e MissingMaxTimestampRetainedMessageBatch) Code() Code

+ func (e MissingMaxTimestampRetainedMessageBatch) Error() string

+ func (e MissingMaxTimestampRetainedMessageBatch) Is(target error) bool

+ type MissingPayloadRetainedMessageBatch struct

+ func (e MissingPayloadRetainedMessageBatch) Code() Code

+ func (e MissingPayloadRetainedMessageBatch) Error() string

+ func (e MissingPayloadRetainedMessageBatch) Is(target error) bool

+ type NoPartitions struct

+ StreamId uint32

+ TopicId uint32

+ func (e NoPartitions) Code() Code

+ func (e NoPartitions) Error() string

+ func (e NoPartitions) Is(target error) bool

+ type NonZeroOffset struct

+ Index uint32

+ Offset uint64

+ func (e NonZeroOffset) Code() Code

+ func (e NonZeroOffset) Error() string

+ func (e NonZeroOffset) Is(target error) bool

+ type NonZeroTimestamp struct

+ Index uint32

+ Timestamp uint64

+ func (e NonZeroTimestamp) Code() Code

+ func (e NonZeroTimestamp) Error() string

+ func (e NonZeroTimestamp) Is(target error) bool

+ type NotConnected struct

+ func (e NotConnected) Code() Code

+ func (e NotConnected) Error() string

+ func (e NotConnected) Is(target error) bool

+ type PartitionNotFound struct

+ PartitionId uint32

+ StreamId uint32

+ TopicId uint32

+ func (e PartitionNotFound) Code() Code

+ func (e PartitionNotFound) Error() string

+ func (e PartitionNotFound) Is(target error) bool

+ type PersonalAccessTokenAlreadyExists struct

+ ID uint32

+ Token string

+ func (e PersonalAccessTokenAlreadyExists) Code() Code

+ func (e PersonalAccessTokenAlreadyExists) Error() string

+ func (e PersonalAccessTokenAlreadyExists) Is(target error) bool

+ type PersonalAccessTokenExpired struct

+ ID uint32

+ Token string

+ func (e PersonalAccessTokenExpired) Code() Code

+ func (e PersonalAccessTokenExpired) Error() string

+ func (e PersonalAccessTokenExpired) Is(target error) bool

+ type PersonalAccessTokensLimitReached struct

+ ID uint32

+ Limit uint32

+ func (e PersonalAccessTokensLimitReached) Code() Code

+ func (e PersonalAccessTokensLimitReached) Error() string

+ func (e PersonalAccessTokensLimitReached) Is(target error) bool

+ type ProducerClosed struct

+ func (e ProducerClosed) Code() Code

+ func (e ProducerClosed) Error() string

+ func (e ProducerClosed) Is(target error) bool

+ type ProducerSendFailed struct

+ func (e ProducerSendFailed) Code() Code

+ func (e ProducerSendFailed) Error() string

+ func (e ProducerSendFailed) Is(target error) bool

+ type QuicError struct

+ func (e QuicError) Code() Code

+ func (e QuicError) Error() string

+ func (e QuicError) Is(target error) bool

type ResourceNotFound

+ Key string

+ func (e ResourceNotFound) Code() Code

+ func (e ResourceNotFound) Error() string

+ func (e ResourceNotFound) Is(target error) bool

+ type SegmentClosed struct

+ PartitionId uint32

+ StartOffset uint64

+ func (e SegmentClosed) Code() Code

+ func (e SegmentClosed) Error() string

+ func (e SegmentClosed) Is(target error) bool

+ type SegmentNotFound struct

+ func (e SegmentNotFound) Code() Code

+ func (e SegmentNotFound) Error() string

+ func (e SegmentNotFound) Is(target error) bool

+ type SnapshotFileCompletionFailed struct

+ func (e SnapshotFileCompletionFailed) Code() Code

+ func (e SnapshotFileCompletionFailed) Error() string

+ func (e SnapshotFileCompletionFailed) Is(target error) bool

+ type StaleClient struct

+ func (e StaleClient) Code() Code

+ func (e StaleClient) Error() string

+ func (e StaleClient) Is(target error) bool

+ type StateFileCorrupted struct

+ func (e StateFileCorrupted) Code() Code

+ func (e StateFileCorrupted) Error() string

+ func (e StateFileCorrupted) Is(target error) bool

+ type StateFileNotFound struct

+ func (e StateFileNotFound) Code() Code

+ func (e StateFileNotFound) Error() string

+ func (e StateFileNotFound) Is(target error) bool

+ type StreamIdAlreadyExists struct

+ ID uint32

+ func (e StreamIdAlreadyExists) Code() Code

+ func (e StreamIdAlreadyExists) Error() string

+ func (e StreamIdAlreadyExists) Is(target error) bool

type StreamIdNotFound

+ ID uint32

+ func (e StreamIdNotFound) Code() Code

+ func (e StreamIdNotFound) Error() string

+ func (e StreamIdNotFound) Is(target error) bool

+ type StreamNameAlreadyExists struct

+ Name string

+ func (e StreamNameAlreadyExists) Code() Code

+ func (e StreamNameAlreadyExists) Error() string

+ func (e StreamNameAlreadyExists) Is(target error) bool

+ type StreamNameNotFound struct

+ Name string

+ func (e StreamNameNotFound) Code() Code

+ func (e StreamNameNotFound) Error() string

+ func (e StreamNameNotFound) Is(target error) bool

+ type TcpError struct

+ func (e TcpError) Code() Code

+ func (e TcpError) Error() string

+ func (e TcpError) Is(target error) bool

+ type TooBigMessagePayload struct

+ func (e TooBigMessagePayload) Code() Code

+ func (e TooBigMessagePayload) Error() string

+ func (e TooBigMessagePayload) Is(target error) bool

type TooBigUserHeaders

+ func (e TooBigUserHeaders) Code() Code

+ func (e TooBigUserHeaders) Error() string

+ func (e TooBigUserHeaders) Is(target error) bool

+ type TooManyMessages struct

+ func (e TooManyMessages) Code() Code

+ func (e TooManyMessages) Error() string

+ func (e TooManyMessages) Is(target error) bool

+ type TooManyPartitions struct

+ func (e TooManyPartitions) Code() Code

+ func (e TooManyPartitions) Error() string

+ func (e TooManyPartitions) Is(target error) bool

+ type TooSmallMessage struct

+ Actual uint32

+ Expected uint32

+ func (e TooSmallMessage) Code() Code

+ func (e TooSmallMessage) Error() string

+ func (e TooSmallMessage) Is(target error) bool

+ type TopicFull struct

+ StreamId uint32

+ TopicId uint32

+ func (e TopicFull) Code() Code

+ func (e TopicFull) Error() string

+ func (e TopicFull) Is(target error) bool

+ type TopicIdAlreadyExists struct

+ StreamId uint32

+ TopicId uint32

+ func (e TopicIdAlreadyExists) Code() Code

+ func (e TopicIdAlreadyExists) Error() string

+ func (e TopicIdAlreadyExists) Is(target error) bool

type TopicIdNotFound

+ StreamId uint32

+ TopicId uint32

+ func (e TopicIdNotFound) Code() Code

+ func (e TopicIdNotFound) Error() string

+ func (e TopicIdNotFound) Is(target error) bool

+ type TopicNameAlreadyExists struct

+ StreamId uint32

+ TopicName string

+ func (e TopicNameAlreadyExists) Code() Code

+ func (e TopicNameAlreadyExists) Error() string

+ func (e TopicNameAlreadyExists) Is(target error) bool

+ type TopicNameNotFound struct

+ StreamId string

+ TopicName string

+ func (e TopicNameNotFound) Code() Code

+ func (e TopicNameNotFound) Error() string

+ func (e TopicNameNotFound) Is(target error) bool

+ type Unauthenticated struct

+ func (e Unauthenticated) Code() Code

+ func (e Unauthenticated) Error() string

+ func (e Unauthenticated) Is(target error) bool

+ type Unauthorized struct

+ func (e Unauthorized) Code() Code

+ func (e Unauthorized) Error() string

+ func (e Unauthorized) Is(target error) bool

+ type UserAlreadyExists struct

+ func (e UserAlreadyExists) Code() Code

+ func (e UserAlreadyExists) Error() string

+ func (e UserAlreadyExists) Is(target error) bool

+ type UserInactive struct

+ func (e UserInactive) Code() Code

+ func (e UserInactive) Error() string

+ func (e UserInactive) Is(target error) bool

+ type UsersLimitReached struct

+ func (e UsersLimitReached) Code() Code

+ func (e UsersLimitReached) Error() string

+ func (e UsersLimitReached) Is(target error) bool

v0.5.2-edge.1

Sep 2, 2025

v0.5.1-edge.1

Sep 1, 2025

v0.5.0

Aug 4, 2025

Changes in this version

+ var ConsumerGroupIdNotFound = &IggyError

+ var InvalidConfiguration = &IggyError

+ var InvalidIdentifier = &IggyError

+ var InvalidMessagePayloadLength = &IggyError

+ var InvalidMessagesCount = &IggyError

+ var ResourceNotFound = &IggyError

+ var StreamIdNotFound = &IggyError

+ var TooBigUserHeaders = &IggyError

+ var TooBigUserMessagePayload = &IggyError

+ var TopicIdNotFound = &IggyError

+ func CustomError(message string) error

+ func MapFromCode(code int) error

+ func TextTooLong(message string) error

+ func TranslateErrorCode(code int) string

+ type IggyError struct

+ Code int

+ Message string

+ func (e *IggyError) Error() string

v0.5.0-edge.1

Jul 28, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL