Enum nats::jetstream::ErrorCode

source · [−]

#[repr(u64)]
pub enum ErrorCode {
Show 108 variants    ClusterPeerNotMember,
    ConsumerEphemeralWithDurableInSubject,
    StreamExternalDelPrefixOverlaps,
    AccountResourcesExceeded,
    ClusterNotAvail,
    StreamSubjectOverlap,
    StreamWrongLastSequence,
    TemplateNameNotMatchSubject,
    ClusterNoPeers,
    ConsumerEphemeralWithDurableName,
    InsufficientResources,
    MirrorMaxMessageSizeTooBig,
    StreamTemplateDelete,
    BadRequest,
    ClusterUnSupportFeature,
    ConsumerNotFound,
    SourceMaxMessageSizeTooBig,
    StreamAssignment,
    StreamMessageExceedsMaximum,
    StreamTemplateCreate,
    InvalidJSON,
    StreamInvalidExternalDeliverySubject,
    StreamRestore,
    ClusterIncomplete,
    NoAccount,
    RaftGeneral,
    RestoreSubscribeFailed,
    StreamDelete,
    StreamExternalApiOverlap,
    MirrorWithSubjects,
    NotEnabled,
    NotEnabledForAccount,
    SequenceNotFound,
    StreamMirrorNotUpdatable,
    StreamSequenceNotMatch,
    StreamWrongLastMsgId,
    TempStorageFailed,
    StorageResourcesExceeded,
    StreamMismatch,
    StreamNotMatch,
    MirrorConsumerSetupFailed,
    NotEmptyRequest,
    StreamNameExist,
    ClusterTags,
    MaximumConsumersLimit,
    SourceConsumerSetupFailed,
    ConsumerCreate,
    ConsumerDurableNameNotInSubject,
    StreamLimits,
    StreamReplicasNotUpdatable,
    StreamTemplateNotFound,
    ClusterNotAssigned,
    ClusterNotLeader,
    ConsumerNameExist,
    MirrorWithSources,
    StreamNotFound,
    ClusterRequired,
    ConsumerDurableNameNotSet,
    MaximumStreamsLimit,
    MirrorWithStartSeqAndTime,
    StreamSnapshot,
    StreamUpdate,
    ClusterNotActive,
    ConsumerDurableNameNotMatchSubject,
    MemoryResourcesExceeded,
    MirrorWithSubjectFilters,
    StreamCreate,
    ClusterServerNotMember,
    NoMessageFound,
    SnapshotDeliverSubjectInvalid,
    StreamGeneralErrorF,
    StreamInvalidConfigF,
    StreamReplicasNotSupported,
    StreamMsgDeleteFailedF,
    PeerRemap,
    StreamStoreFailedF,
    ConsumerConfigRequired,
    ConsumerDeliverToWildcards,
    ConsumerPushMaxWaiting,
    ConsumerDeliverCycle,
    ConsumerMaxPendingAckPolicyRequired,
    JSConsumerMaxRequestBatchNegative,
    JSConsumerMaxRequestExpiresToSmall,
    ConsumerSmallHeartbeat,
    ConsumerPullRequiresAck,
    ConsumerPullNotDurable,
    ConsumerPullWithRateLimit,
    ConsumerMaxWaitingNegative,
    ConsumerHBRequiresPush,
    ConsumerFCRequiresPush,
    ConsumerDirectRequiresPush,
    ConsumerDirectRequiresEphemeral,
    ConsumerOnMapped,
    ConsumerFilterNotSubset,
    ConsumerInvalidPolicy,
    ConsumerInvalidSampling,
    StreamInvalid,
    ConsumerWQRequiresExplicitAck,
    ConsumerWQMultipleUnfiltered,
    ConsumerWQConsumerNotUnique,
    ConsumerWQConsumerNotDeliverAll,
    ConsumerNameTooLong,
    ConsumerBadDurableName,
    ConsumerStoreFailed,
    ConsumerExistingActive,
    ConsumerReplacementWithDifferentName,
    ConsumerDescriptionTooLong,
    StreamHeaderExceedsMaximum,
}

Expand description

ErrorCode which can be returned from a server an a response when an error occurs.

Variants

`ClusterPeerNotMember`

Peer not a member

`ConsumerEphemeralWithDurableInSubject`

Consumer expected to be ephemeral but detected a durable name set in subject

`StreamExternalDelPrefixOverlaps`

Stream external delivery prefix {prefix} overlaps with stream subject {subject}

`AccountResourcesExceeded`

Resource limits exceeded for account

`ClusterNotAvail`

JetStream system temporarily unavailable

`StreamSubjectOverlap`

Subjects overlap with an existing stream

`StreamWrongLastSequence`

Wrong last sequence: {seq}

`TemplateNameNotMatchSubject`

Template name in subject does not match request

`ClusterNoPeers`

No suitable peers for placement

`ConsumerEphemeralWithDurableName`

Consumer expected to be ephemeral but a durable name was set in request

`InsufficientResources`

Insufficient resources

`MirrorMaxMessageSizeTooBig`

Stream mirror must have max message size >= source

`StreamTemplateDelete`

Generic stream template deletion failed error string

`BadRequest`

Bad request

`ClusterUnSupportFeature`

Not currently supported in clustered mode

`ConsumerNotFound`

Consumer not found

`SourceMaxMessageSizeTooBig`

Stream source must have max message size >= target

`StreamAssignment`

Generic stream assignment error string

`StreamMessageExceedsMaximum`

Message size exceeds maximum allowed

`StreamTemplateCreate`

Generic template creation failed string

`InvalidJSON`

Invalid JSON

`StreamInvalidExternalDeliverySubject`

Stream external delivery prefix {prefix} must not contain wildcards

`StreamRestore`

Restore failed: {err}

`ClusterIncomplete`

Incomplete results

`NoAccount`

Account not found

`RaftGeneral`

General RAFT error string

`RestoreSubscribeFailed`

JetStream unable to subscribe to restore snapshot {subject}: {err}

`StreamDelete`

General stream deletion error string

`StreamExternalApiOverlap`

Stream external api prefix {prefix} must not overlap with {subject}

`MirrorWithSubjects`

Stream mirrors can not also contain subjects

`NotEnabled`

JetStream not enabled

`NotEnabledForAccount`

JetStream not enabled for account

`SequenceNotFound`

Sequence {seq} not found

`StreamMirrorNotUpdatable`

Mirror configuration can not be updated

`StreamSequenceNotMatch`

Expected stream sequence does not match

`StreamWrongLastMsgId`

Wrong last msg Id: {id}

`TempStorageFailed`

JetStream unable to open temp storage for restore

`StorageResourcesExceeded`

Insufficient storage resources available

`StreamMismatch`

Stream name in subject does not match request

`StreamNotMatch`

Expected stream does not match

`MirrorConsumerSetupFailed`

Generic mirror consumer setup failure string

`NotEmptyRequest`

Expected an empty request payload

`StreamNameExist`

Stream name already in use

`ClusterTags`

Tags placement not supported for operation

`MaximumConsumersLimit`

Maximum consumers limit reached

`SourceConsumerSetupFailed`

General source consumer setup failure string

`ConsumerCreate`

General consumer creation failure string

`ConsumerDurableNameNotInSubject`

Consumer expected to be durable but no durable name set in subject

`StreamLimits`

General stream limits exceeded error string

`StreamReplicasNotUpdatable`

Replicas configuration can not be updated

`StreamTemplateNotFound`

Template not found

`ClusterNotAssigned`

JetStream cluster not assigned to this server

`ClusterNotLeader`

JetStream cluster can not handle request

`ConsumerNameExist`

Consumer name already in use

`MirrorWithSources`

Stream mirrors can not also contain other sources

`StreamNotFound`

Stream not found

`ClusterRequired`

JetStream clustering support required

`ConsumerDurableNameNotSet`

Consumer expected to be durable but a durable name was not set

`MaximumStreamsLimit`

Maximum number of streams reached

`MirrorWithStartSeqAndTime`

Stream mirrors can not have both start seq and start time configured

`StreamSnapshot`

Snapshot failed: {err}

`StreamUpdate`

Generic stream update error string

`ClusterNotActive`

JetStream not in clustered mode

`ConsumerDurableNameNotMatchSubject`

Consumer name in subject does not match durable name in request

`MemoryResourcesExceeded`

Insufficient memory resources available

`MirrorWithSubjectFilters`

Stream mirrors can not contain filtered subjects

`StreamCreate`

Generic stream creation error string

`ClusterServerNotMember`

Server is not a member of the cluster

`NoMessageFound`

No message found

`SnapshotDeliverSubjectInvalid`

Deliver subject not valid

`StreamGeneralErrorF`

General stream failure string

`StreamInvalidConfigF`

Stream configuration validation error string

`StreamReplicasNotSupported`

Replicas > 1 not supported in non-clustered mode

`StreamMsgDeleteFailedF`

Generic message deletion failure error string

`PeerRemap`

Peer remap failed

`StreamStoreFailedF`

Generic error when storing a message failed

`ConsumerConfigRequired`

Consumer config required

`ConsumerDeliverToWildcards`

Consumer deliver subject has wildcards

`ConsumerPushMaxWaiting`

Consumer in push mode can not set max waiting

`ConsumerDeliverCycle`

Consumer deliver subject forms a cycle

`ConsumerMaxPendingAckPolicyRequired`

Consumer requires ack policy for max ack pending

`JSConsumerMaxRequestBatchNegative`

JSConsumerMaxRequestBatchNegative consumer max request batch needs to be > 0

`JSConsumerMaxRequestExpiresToSmall`

JSConsumerMaxRequestExpiresToSmall consumer max request expires needs to be >= 1ms

`ConsumerSmallHeartbeat`

Consumer idle heartbeat needs to be >= 100ms

`ConsumerPullRequiresAck`

Consumer in pull mode requires ack policy

`ConsumerPullNotDurable`

Consumer in pull mode requires a durable name

`ConsumerPullWithRateLimit`

Consumer in pull mode can not have rate limit set

`ConsumerMaxWaitingNegative`

Consumer max waiting needs to be positive

`ConsumerHBRequiresPush`

Consumer idle heartbeat requires a push based consumer

`ConsumerFCRequiresPush`

Consumer flow control requires a push based consumer

`ConsumerDirectRequiresPush`

Consumer direct requires a push based consumer

`ConsumerDirectRequiresEphemeral`

Consumer direct requires an ephemeral consumer

`ConsumerOnMapped`

Consumer direct on a mapped consumer

`ConsumerFilterNotSubset`

Consumer filter subject is not a valid subset of the interest subjects

`ConsumerInvalidPolicy`

Generic delivery policy error

`ConsumerInvalidSampling`

Failed to parse consumer sampling configuration: {err}

`StreamInvalid`

Stream not valid

`ConsumerWQRequiresExplicitAck`

Workqueue stream requires explicit ack

`ConsumerWQMultipleUnfiltered`

Multiple non-filtered consumers not allowed on workqueue stream

`ConsumerWQConsumerNotUnique`

Filtered consumer not unique on workqueue stream

`ConsumerWQConsumerNotDeliverAll`

Consumer must be deliver all on workqueue stream

`ConsumerNameTooLong`

Consumer name is too long, maximum allowed is {max}

`ConsumerBadDurableName`

Durable name can not contain ‘.’, ‘*’, ‘>’

`ConsumerStoreFailed`

Error creating store for consumer: {err}

`ConsumerExistingActive`

Consumer already exists and is still active

`ConsumerReplacementWithDifferentName`

Consumer replacement durable config not the same

`ConsumerDescriptionTooLong`

Consumer description is too long, maximum allowed is {max}

`StreamHeaderExceedsMaximum`

Header size exceeds maximum allowed of 64k

Trait Implementations

source

impl Clone for ErrorCode

source

fn clone(&self) -> ErrorCode

Returns a copy of the value. Read more

This method tests for !=.

source

impl Serialize for ErrorCode

source

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where
S: Serializer,

Serialize this value into the given Serde serializer. Read more

source

impl StructuralPartialEq for ErrorCode

Auto Trait Implementations

impl RefUnwindSafe for ErrorCode

impl Send for ErrorCode

impl Sync for ErrorCode

impl Unpin for ErrorCode

fn into(self) -> U

Calls U::from(self).

source

fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn vzip(self) -> V

source