Enum nats::jetstream::ErrorCode

#[repr(u64)]
pub enum ErrorCode {
    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,
}

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

impl Clone for ErrorCode

fn clone(&self) -> ErrorCode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ErrorCode

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

Formats the value using the given formatter.

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

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ErrorCode

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

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

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.

impl Serialize for ErrorCode

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

where S: Serializer,

Serialize this value into the given Serde serializer.

impl Copy for ErrorCode

impl Eq for ErrorCode

impl StructuralPartialEq for ErrorCode