Enum nats::jetstream::ErrorCode

source ·
#[repr(u64)]
pub enum ErrorCode {
Show 108 variants ClusterPeerNotMember = 10_040, ConsumerEphemeralWithDurableInSubject = 10_019, StreamExternalDelPrefixOverlaps = 10_022, AccountResourcesExceeded = 10_002, ClusterNotAvail = 10_008, StreamSubjectOverlap = 10_065, StreamWrongLastSequence = 10_071, TemplateNameNotMatchSubject = 10_073, ClusterNoPeers = 10_005, ConsumerEphemeralWithDurableName = 10_020, InsufficientResources = 10_023, MirrorMaxMessageSizeTooBig = 10_030, StreamTemplateDelete = 10_067, BadRequest = 10_003, ClusterUnSupportFeature = 10_036, ConsumerNotFound = 10_014, SourceMaxMessageSizeTooBig = 10_046, StreamAssignment = 10_048, StreamMessageExceedsMaximum = 10_054, StreamTemplateCreate = 10_066, InvalidJSON = 10_025, StreamInvalidExternalDeliverySubject = 10_024, StreamRestore = 10_062, ClusterIncomplete = 10_004, NoAccount = 10_035, RaftGeneral = 10_041, RestoreSubscribeFailed = 10_042, StreamDelete = 10_050, StreamExternalApiOverlap = 10_021, MirrorWithSubjects = 10_034, NotEnabled = 10_076, NotEnabledForAccount = 10_039, SequenceNotFound = 10_043, StreamMirrorNotUpdatable = 10_055, StreamSequenceNotMatch = 10_063, StreamWrongLastMsgId = 10_070, TempStorageFailed = 10_072, StorageResourcesExceeded = 10_047, StreamMismatch = 10_056, StreamNotMatch = 10_060, MirrorConsumerSetupFailed = 10_029, NotEmptyRequest = 10_038, StreamNameExist = 10_058, ClusterTags = 10_011, MaximumConsumersLimit = 10_026, SourceConsumerSetupFailed = 10_045, ConsumerCreate = 10_012, ConsumerDurableNameNotInSubject = 10_016, StreamLimits = 10_053, StreamReplicasNotUpdatable = 10_061, StreamTemplateNotFound = 10_068, ClusterNotAssigned = 10_007, ClusterNotLeader = 10_009, ConsumerNameExist = 10_013, MirrorWithSources = 10_031, StreamNotFound = 10_059, ClusterRequired = 10_010, ConsumerDurableNameNotSet = 10_018, MaximumStreamsLimit = 10_027, MirrorWithStartSeqAndTime = 10_032, StreamSnapshot = 10_064, StreamUpdate = 10_069, ClusterNotActive = 10_006, ConsumerDurableNameNotMatchSubject = 10_017, MemoryResourcesExceeded = 10_028, MirrorWithSubjectFilters = 10_033, StreamCreate = 10_049, ClusterServerNotMember = 10_044, NoMessageFound = 10_037, SnapshotDeliverSubjectInvalid = 10_015, StreamGeneralErrorF = 10_051, StreamInvalidConfigF = 10_052, StreamReplicasNotSupported = 10_074, StreamMsgDeleteFailedF = 10_057, PeerRemap = 10_075, StreamStoreFailedF = 10_077, ConsumerConfigRequired = 10_078, ConsumerDeliverToWildcards = 10_079, ConsumerPushMaxWaiting = 10_080, ConsumerDeliverCycle = 10_081, ConsumerMaxPendingAckPolicyRequired = 10_082, JSConsumerMaxRequestBatchNegative = 10_114, JSConsumerMaxRequestExpiresToSmall = 10_115, ConsumerSmallHeartbeat = 10_083, ConsumerPullRequiresAck = 10_084, ConsumerPullNotDurable = 10_085, ConsumerPullWithRateLimit = 10_086, ConsumerMaxWaitingNegative = 10_087, ConsumerHBRequiresPush = 10_088, ConsumerFCRequiresPush = 10_089, ConsumerDirectRequiresPush = 10_090, ConsumerDirectRequiresEphemeral = 10_091, ConsumerOnMapped = 10_092, ConsumerFilterNotSubset = 10_093, ConsumerInvalidPolicy = 10_094, ConsumerInvalidSampling = 10_095, StreamInvalid = 10_096, ConsumerWQRequiresExplicitAck = 10_098, ConsumerWQMultipleUnfiltered = 10_099, ConsumerWQConsumerNotUnique = 10_100, ConsumerWQConsumerNotDeliverAll = 10_101, ConsumerNameTooLong = 10_102, ConsumerBadDurableName = 10_103, ConsumerStoreFailed = 10_104, ConsumerExistingActive = 10_105, ConsumerReplacementWithDifferentName = 10_106, ConsumerDescriptionTooLong = 10_107, StreamHeaderExceedsMaximum = 10_097,
}
Expand description

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

Variants§

§

ClusterPeerNotMember = 10_040

Peer not a member

§

ConsumerEphemeralWithDurableInSubject = 10_019

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

§

StreamExternalDelPrefixOverlaps = 10_022

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

§

AccountResourcesExceeded = 10_002

Resource limits exceeded for account

§

ClusterNotAvail = 10_008

JetStream system temporarily unavailable

§

StreamSubjectOverlap = 10_065

Subjects overlap with an existing stream

§

StreamWrongLastSequence = 10_071

Wrong last sequence: {seq}

§

TemplateNameNotMatchSubject = 10_073

Template name in subject does not match request

§

ClusterNoPeers = 10_005

No suitable peers for placement

§

ConsumerEphemeralWithDurableName = 10_020

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

§

InsufficientResources = 10_023

Insufficient resources

§

MirrorMaxMessageSizeTooBig = 10_030

Stream mirror must have max message size >= source

§

StreamTemplateDelete = 10_067

Generic stream template deletion failed error string

§

BadRequest = 10_003

Bad request

§

ClusterUnSupportFeature = 10_036

Not currently supported in clustered mode

§

ConsumerNotFound = 10_014

Consumer not found

§

SourceMaxMessageSizeTooBig = 10_046

Stream source must have max message size >= target

§

StreamAssignment = 10_048

Generic stream assignment error string

§

StreamMessageExceedsMaximum = 10_054

Message size exceeds maximum allowed

§

StreamTemplateCreate = 10_066

Generic template creation failed string

§

InvalidJSON = 10_025

Invalid JSON

§

StreamInvalidExternalDeliverySubject = 10_024

Stream external delivery prefix {prefix} must not contain wildcards

§

StreamRestore = 10_062

Restore failed: {err}

§

ClusterIncomplete = 10_004

Incomplete results

§

NoAccount = 10_035

Account not found

§

RaftGeneral = 10_041

General RAFT error string

§

RestoreSubscribeFailed = 10_042

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

§

StreamDelete = 10_050

General stream deletion error string

§

StreamExternalApiOverlap = 10_021

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

§

MirrorWithSubjects = 10_034

Stream mirrors can not also contain subjects

§

NotEnabled = 10_076

JetStream not enabled

§

NotEnabledForAccount = 10_039

JetStream not enabled for account

§

SequenceNotFound = 10_043

Sequence {seq} not found

§

StreamMirrorNotUpdatable = 10_055

Mirror configuration can not be updated

§

StreamSequenceNotMatch = 10_063

Expected stream sequence does not match

§

StreamWrongLastMsgId = 10_070

Wrong last msg Id: {id}

§

TempStorageFailed = 10_072

JetStream unable to open temp storage for restore

§

StorageResourcesExceeded = 10_047

Insufficient storage resources available

§

StreamMismatch = 10_056

Stream name in subject does not match request

§

StreamNotMatch = 10_060

Expected stream does not match

§

MirrorConsumerSetupFailed = 10_029

Generic mirror consumer setup failure string

§

NotEmptyRequest = 10_038

Expected an empty request payload

§

StreamNameExist = 10_058

Stream name already in use

§

ClusterTags = 10_011

Tags placement not supported for operation

§

MaximumConsumersLimit = 10_026

Maximum consumers limit reached

§

SourceConsumerSetupFailed = 10_045

General source consumer setup failure string

§

ConsumerCreate = 10_012

General consumer creation failure string

§

ConsumerDurableNameNotInSubject = 10_016

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

§

StreamLimits = 10_053

General stream limits exceeded error string

§

StreamReplicasNotUpdatable = 10_061

Replicas configuration can not be updated

§

StreamTemplateNotFound = 10_068

Template not found

§

ClusterNotAssigned = 10_007

JetStream cluster not assigned to this server

§

ClusterNotLeader = 10_009

JetStream cluster can not handle request

§

ConsumerNameExist = 10_013

Consumer name already in use

§

MirrorWithSources = 10_031

Stream mirrors can not also contain other sources

§

StreamNotFound = 10_059

Stream not found

§

ClusterRequired = 10_010

JetStream clustering support required

§

ConsumerDurableNameNotSet = 10_018

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

§

MaximumStreamsLimit = 10_027

Maximum number of streams reached

§

MirrorWithStartSeqAndTime = 10_032

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

§

StreamSnapshot = 10_064

Snapshot failed: {err}

§

StreamUpdate = 10_069

Generic stream update error string

§

ClusterNotActive = 10_006

JetStream not in clustered mode

§

ConsumerDurableNameNotMatchSubject = 10_017

Consumer name in subject does not match durable name in request

§

MemoryResourcesExceeded = 10_028

Insufficient memory resources available

§

MirrorWithSubjectFilters = 10_033

Stream mirrors can not contain filtered subjects

§

StreamCreate = 10_049

Generic stream creation error string

§

ClusterServerNotMember = 10_044

Server is not a member of the cluster

§

NoMessageFound = 10_037

No message found

§

SnapshotDeliverSubjectInvalid = 10_015

Deliver subject not valid

§

StreamGeneralErrorF = 10_051

General stream failure string

§

StreamInvalidConfigF = 10_052

Stream configuration validation error string

§

StreamReplicasNotSupported = 10_074

Replicas > 1 not supported in non-clustered mode

§

StreamMsgDeleteFailedF = 10_057

Generic message deletion failure error string

§

PeerRemap = 10_075

Peer remap failed

§

StreamStoreFailedF = 10_077

Generic error when storing a message failed

§

ConsumerConfigRequired = 10_078

Consumer config required

§

ConsumerDeliverToWildcards = 10_079

Consumer deliver subject has wildcards

§

ConsumerPushMaxWaiting = 10_080

Consumer in push mode can not set max waiting

§

ConsumerDeliverCycle = 10_081

Consumer deliver subject forms a cycle

§

ConsumerMaxPendingAckPolicyRequired = 10_082

Consumer requires ack policy for max ack pending

§

JSConsumerMaxRequestBatchNegative = 10_114

JSConsumerMaxRequestBatchNegative consumer max request batch needs to be > 0

§

JSConsumerMaxRequestExpiresToSmall = 10_115

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

§

ConsumerSmallHeartbeat = 10_083

Consumer idle heartbeat needs to be >= 100ms

§

ConsumerPullRequiresAck = 10_084

Consumer in pull mode requires ack policy

§

ConsumerPullNotDurable = 10_085

Consumer in pull mode requires a durable name

§

ConsumerPullWithRateLimit = 10_086

Consumer in pull mode can not have rate limit set

§

ConsumerMaxWaitingNegative = 10_087

Consumer max waiting needs to be positive

§

ConsumerHBRequiresPush = 10_088

Consumer idle heartbeat requires a push based consumer

§

ConsumerFCRequiresPush = 10_089

Consumer flow control requires a push based consumer

§

ConsumerDirectRequiresPush = 10_090

Consumer direct requires a push based consumer

§

ConsumerDirectRequiresEphemeral = 10_091

Consumer direct requires an ephemeral consumer

§

ConsumerOnMapped = 10_092

Consumer direct on a mapped consumer

§

ConsumerFilterNotSubset = 10_093

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

§

ConsumerInvalidPolicy = 10_094

Generic delivery policy error

§

ConsumerInvalidSampling = 10_095

Failed to parse consumer sampling configuration: {err}

§

StreamInvalid = 10_096

Stream not valid

§

ConsumerWQRequiresExplicitAck = 10_098

Workqueue stream requires explicit ack

§

ConsumerWQMultipleUnfiltered = 10_099

Multiple non-filtered consumers not allowed on workqueue stream

§

ConsumerWQConsumerNotUnique = 10_100

Filtered consumer not unique on workqueue stream

§

ConsumerWQConsumerNotDeliverAll = 10_101

Consumer must be deliver all on workqueue stream

§

ConsumerNameTooLong = 10_102

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

§

ConsumerBadDurableName = 10_103

Durable name can not contain ., *, >

§

ConsumerStoreFailed = 10_104

Error creating store for consumer: {err}

§

ConsumerExistingActive = 10_105

Consumer already exists and is still active

§

ConsumerReplacementWithDifferentName = 10_106

Consumer replacement durable config not the same

§

ConsumerDescriptionTooLong = 10_107

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

§

StreamHeaderExceedsMaximum = 10_097

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
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl Debug for ErrorCode

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
source§

impl<'de> Deserialize<'de> for ErrorCode

source§

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
source§

impl PartialEq for ErrorCode

source§

fn eq(&self, other: &ErrorCode) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.
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 Copy for ErrorCode

source§

impl Eq for ErrorCode

source§

impl StructuralPartialEq for ErrorCode

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

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

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

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

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

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

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

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

Performs the conversion.
source§

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

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

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

Performs the conversion.
source§

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

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,