async_nats::jetstream

Struct ErrorCode

Source 
pub struct ErrorCode(/* private fields */);

Implementations§

Source§

impl ErrorCode

Source

pub const CLUSTER_PEER_NOT_MEMBER: ErrorCode = _

Peer not a member

Source

pub const CONSUMER_EPHEMERAL_WITH_DURABLE: ErrorCode = _

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

Source

pub const STREAM_EXTERNAL_DELETE_PREFIX_OVERLAPS: ErrorCode = _

Stream external delivery prefix overlaps with stream subject

Source

pub const ACCOUNT_RESOURCES_EXCEEDED: ErrorCode = _

Resource limits exceeded for account

Source

pub const CLUSTER_NOT_AVAILABLE: ErrorCode = _

Jetstream system temporarily unavailable

Source

pub const STREAM_SUBJECT_OVERLAP: ErrorCode = _

Subjects overlap with an existing stream

Source

pub const STREAM_WRONG_LAST_SEQUENCE: ErrorCode = _

Wrong last sequence

Source

pub const NAME_NOT_MATCH_SUBJECT: ErrorCode = _

Template name in subject does not match request

Source

pub const CLUSTER_NO_PEERS: ErrorCode = _

No suitable peers for placement

Source

pub const CONSUMER_EPHEMERAL_WITH_DURABLE_NAME: ErrorCode = _

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

Source

pub const INSUFFICIENT_RESOURCES: ErrorCode = _

Insufficient resources

Source

pub const MIRROR_MAX_MESSAGE_SIZE_TOO_BIG: ErrorCode = _

Stream mirror must have max message size >= source

Source

pub const STREAM_DELETE_FAILED: ErrorCode = _

Generic error from stream deletion operation

Source

pub const BAD_REQUEST: ErrorCode = _

Bad request

Source

pub const NOT_SUPPORTED_IN_CLUSTER_MODE: ErrorCode = _

Not currently supported in clustered mode

Source

pub const CONSUMER_NOT_FOUND: ErrorCode = _

Consumer not found

Source

pub const SOURCE_MAX_MESSAGE_SIZE_TOO_BIG: ErrorCode = _

Stream source must have max message size >= target

Source

pub const STREAM_ASSIGNMENT: ErrorCode = _

Generic error when stream operation fails.

Source

pub const STREAM_MESSAGE_EXCEEDS_MAXIMUM: ErrorCode = _

Message size exceeds maximum allowed

Source

pub const STREAM_CREATE_TEMPLATE: ErrorCode = _

Generic error for stream creation error with a string

Source

pub const INVALID_JSON: ErrorCode = _

Invalid JSON

Source

pub const STREAM_INVALID_EXTERNAL_DELIVERY_SUBJECT: ErrorCode = _

Stream external delivery prefix must not contain wildcards

Source

pub const STREAM_RESTORE: ErrorCode = _

Restore failed

Source

pub const CLUSTER_INCOMPLETE: ErrorCode = _

Incomplete results

Source

pub const NO_ACCOUNT: ErrorCode = _

Account not found

Source

pub const RAFT_GENERAL: ErrorCode = _

General RAFT error

Source

pub const RESTORE_SUBSCRIBE_FAILED: ErrorCode = _

Jetstream unable to subscribe to restore snapshot

Source

pub const STREAM_DELETE: ErrorCode = _

Stream deletion failed

Source

pub const STREAM_EXTERNAL_API_OVERLAP: ErrorCode = _

Stream external api prefix must not overlap

Source

pub const MIRROR_WITH_SUBJECTS: ErrorCode = _

Stream mirrors can not contain subjects

Source

pub const JETSTREAM_NOT_ENABLED: ErrorCode = _

Jetstream not enabled

Source

pub const JETSTREAM_NOT_ENABLED_FOR_ACCOUNT: ErrorCode = _

Jetstream not enabled for account

Source

pub const SEQUENCE_NOT_FOUND: ErrorCode = _

Sequence not found

Source

pub const STREAM_MIRROR_NOT_UPDATABLE: ErrorCode = _

Stream mirror configuration can not be updated

Source

pub const STREAM_SEQUENCE_NOT_MATCH: ErrorCode = _

Expected stream sequence does not match

Source

pub const STREAM_WRONG_LAST_MESSAGE_ID: ErrorCode = _

Wrong last msg id

Source

pub const TEMP_STORAGE_FAILED: ErrorCode = _

Jetstream unable to open temp storage for restore

Source

pub const STORAGE_RESOURCES_EXCEEDED: ErrorCode = _

Insufficient storage resources available

Source

pub const STREAM_MISMATCH: ErrorCode = _

Stream name in subject does not match request

Source

pub const STREAM_NOT_MATCH: ErrorCode = _

Expected stream does not match

Source

pub const MIRROR_CONSUMER_SETUP_FAILED: ErrorCode = _

Setting up consumer mirror failed

Source

pub const NOT_EMPTY_REQUEST: ErrorCode = _

Expected an empty request payload

Source

pub const STREAM_NAME_EXIST: ErrorCode = _

Stream name already in use with a different configuration

Source

pub const CLUSTER_TAGS: ErrorCode = _

Tags placement not supported for operation

Source

pub const MAXIMUM_CONSUMERS_LIMIT: ErrorCode = _

Maximum consumers limit reached

Source

pub const SOURCE_CONSUMER_SETUP_FAILED: ErrorCode = _

General source consumer setup failure

Source

pub const CONSUMER_CREATE: ErrorCode = _

Consumer creation failed

Source

pub const CONSUMER_DURABLE_NAME_NOT_IN_SUBJECT: ErrorCode = _

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

Source

pub const STREAM_LIMITS: ErrorCode = _

Stream limits error

Source

pub const STREAM_REPLICAS_NOT_UPDATABLE: ErrorCode = _

Replicas configuration can not be updated

Source

pub const STREAM_TEMPLATE_NOT_FOUND: ErrorCode = _

Template not found

Source

pub const CLUSTER_NOT_ASSIGNED: ErrorCode = _

Jetstream cluster not assigned to this server

Source

pub const CLUSTER_NOT_LEADER: ErrorCode = _

Jetstream cluster can’t handle request

Source

pub const CONSUMER_NAME_EXIST: ErrorCode = _

Consumer name already in use

Source

pub const MIRROR_WITH_SOURCES: ErrorCode = _

Stream mirrors can’t also contain other sources

Source

pub const STREAM_NOT_FOUND: ErrorCode = _

Stream not found

Source

pub const CLUSTER_REQUIRED: ErrorCode = _

Jetstream clustering support required

Source

pub const CONSUMER_DURABLE_NAME_NOT_SET: ErrorCode = _

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

Source

pub const MAXIMUM_STREAMS_LIMIT: ErrorCode = _

Maximum number of streams reached

Source

pub const MIRROR_WITH_START_SEQUENCE_AND_TIME: ErrorCode = _

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

Source

pub const STREAM_SNAPSHOT: ErrorCode = _

Stream snapshot failed

Source

pub const STREAM_UPDATE: ErrorCode = _

Stream update failed

Source

pub const CLUSTER_NOT_ACTIVE: ErrorCode = _

Jetstream not in clustered mode

Source

pub const CONSUMER_DURABLE_NAME_NOT_MATCH_SUBJECT: ErrorCode = _

Consumer name in subject does not match durable name in request

Source

pub const MEMORY_RESOURCES_EXCEEDED: ErrorCode = _

Insufficient memory resources available

Source

pub const MIRROR_WITH_SUBJECT_FILTERS: ErrorCode = _

Stream mirrors can not contain filtered subjects

Source

pub const STREAM_CREATE: ErrorCode = _

Stream create failed with a string

Source

pub const CLUSTER_SERVER_NOT_MEMBER: ErrorCode = _

Server is not a member of the cluster

Source

pub const NO_MESSAGE_FOUND: ErrorCode = _

No message found

Source

pub const SNAPSHOT_DELIVER_SUBJECT_INVALID: ErrorCode = _

Deliver subject not valid

Source

pub const STREAM_GENERALOR: ErrorCode = _

General stream failure

Source

pub const STREAM_INVALID_CONFIG: ErrorCode = _

Invalid stream config

Source

pub const STREAM_REPLICAS_NOT_SUPPORTED: ErrorCode = _

Replicas > 1 not supported in non-clustered mode

Source

pub const STREAM_MESSAGE_DELETE_FAILED: ErrorCode = _

Stream message delete failed

Source

pub const PEER_REMAP: ErrorCode = _

Peer remap failed

Source

pub const STREAM_STORE_FAILED: ErrorCode = _

Stream store failed

Source

pub const CONSUMER_CONFIG_REQUIRED: ErrorCode = _

Consumer config required

Source

pub const CONSUMER_DELIVER_TO_WILDCARDS: ErrorCode = _

Consumer deliver subject has wildcards

Source

pub const CONSUMER_PUSH_MAX_WAITING: ErrorCode = _

Consumer in push mode can not set max waiting

Source

pub const CONSUMER_DELIVER_CYCLE: ErrorCode = _

Consumer deliver subject forms a cycle

Source

pub const CONSUMER_MAX_PENDING_ACK_POLICY_REQUIRED: ErrorCode = _

Consumer requires ack policy for max ack pending

Source

pub const CONSUMER_SMALL_HEARTBEAT: ErrorCode = _

Consumer idle heartbeat needs to be >= 100ms

Source

pub const CONSUMER_PULL_REQUIRES_ACK: ErrorCode = _

Consumer in pull mode requires ack policy

Source

pub const CONSUMER_PULL_NOT_DURABLE: ErrorCode = _

Consumer in pull mode requires a durable name

Source

pub const CONSUMER_PULL_WITH_RATE_LIMIT: ErrorCode = _

Consumer in pull mode can not have rate limit set

Source

pub const CONSUMER_MAX_WAITING_NEGATIVE: ErrorCode = _

Consumer max waiting needs to be positive

Source

pub const CONSUMER_HEARTBEAT_REQUIRES_PUSH: ErrorCode = _

Consumer idle heartbeat requires a push based consumer

Source

pub const CONSUMER_FLOW_CONTROL_REQUIRES_PUSH: ErrorCode = _

Consumer flow control requires a push based consumer

Source

pub const CONSUMER_DIRECT_REQUIRES_PUSH: ErrorCode = _

Consumer direct requires a push based consumer

Source

pub const CONSUMER_DIRECT_REQUIRES_EPHEMERAL: ErrorCode = _

Consumer direct requires an ephemeral consumer

Source

pub const CONSUMER_ON_MAPPED: ErrorCode = _

Consumer direct on a mapped consumer

Source

pub const CONSUMER_FILTER_NOT_SUBSET: ErrorCode = _

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

Source

pub const CONSUMER_INVALID_POLICY: ErrorCode = _

Invalid consumer policy

Source

pub const CONSUMER_INVALID_SAMPLING: ErrorCode = _

Failed to parse consumer sampling configuration

Source

pub const STREAM_INVALID: ErrorCode = _

Stream not valid

Source

pub const CONSUMER_WQ_REQUIRES_EXPLICIT_ACK: ErrorCode = _

Workqueue stream requires explicit ack

Source

pub const CONSUMER_WQ_MULTIPLE_UNFILTERED: ErrorCode = _

Multiple non-filtered consumers not allowed on workqueue stream

Source

pub const CONSUMER_WQ_CONSUMER_NOT_UNIQUE: ErrorCode = _

Filtered consumer not unique on workqueue stream

Source

pub const CONSUMER_WQ_CONSUMER_NOT_DELIVER_ALL: ErrorCode = _

Consumer must be deliver all on workqueue stream

Source

pub const CONSUMER_NAME_TOO_LONG: ErrorCode = _

Consumer name is too long

Source

pub const CONSUMER_BAD_DURABLE_NAME: ErrorCode = _

Durable name can not contain token separators and wildcards

Source

pub const CONSUMER_STORE_FAILED: ErrorCode = _

Error creating store for consumer

Source

pub const CONSUMER_EXISTING_ACTIVE: ErrorCode = _

Consumer already exists and is still active

Source

pub const CONSUMER_REPLACEMENT_WITH_DIFFERENT_NAME: ErrorCode = _

Consumer replacement durable config not the same

Source

pub const CONSUMER_DESCRIPTION_TOO_LONG: ErrorCode = _

Consumer description is too long

Source

pub const STREAM_HEADER_EXCEEDS_MAXIMUM: ErrorCode = _

Header size exceeds maximum allowed of 64k

Source

pub const CONSUMER_WITH_FLOW_CONTROL_NEEDS_HEARTBEATS: ErrorCode = _

Consumer with flow control also needs heartbeats

Source

pub const STREAM_SEALED: ErrorCode = _

Invalid operation on sealed stream

Source

pub const STREAM_PURGE_FAILED: ErrorCode = _

Stream purge failed

Source

pub const STREAM_ROLLUP_FAILED: ErrorCode = _

Stream rollup failed

Source

pub const CONSUMER_INVALID_DELIVER_SUBJECT: ErrorCode = _

Invalid push consumer deliver subject

Source

pub const STREAM_MAX_BYTES_REQUIRED: ErrorCode = _

Account requires a stream config to have max bytes set

Source

pub const CONSUMER_MAX_REQUEST_BATCH_NEGATIVE: ErrorCode = _

Consumer max request batch needs to be > 0

Source

pub const CONSUMER_MAX_REQUEST_EXPIRES_TO_SMALL: ErrorCode = _

Consumer max request expires needs to be >= 1ms

Source

pub const CONSUMER_MAX_DELIVER_BACKOFF: ErrorCode = _

Max deliver is required to be > length of backoff values

Source

pub const STREAM_INFO_MAX_SUBJECTS: ErrorCode = _

Subject details would exceed maximum allowed

Source

pub const STREAM_OFFLINE: ErrorCode = _

Stream is offline

Source

pub const CONSUMER_OFFLINE: ErrorCode = _

Consumer is offline

Source

pub const NO_LIMITS: ErrorCode = _

No jetstream default or applicable tiered limit present

Source

pub const CONSUMER_MAX_PENDING_ACK_EXCESS: ErrorCode = _

Consumer max ack pending exceeds system limit

Source

pub const STREAM_MAX_STREAM_BYTES_EXCEEDED: ErrorCode = _

Stream max bytes exceeds account limit max stream bytes

Source

pub const STREAM_MOVE_AND_SCALE: ErrorCode = _

Can not move and scale a stream in a single update

Source

pub const STREAM_MOVE_IN_PROGRESS: ErrorCode = _

Stream move already in progress

Source

pub const CONSUMER_MAX_REQUEST_BATCH_EXCEEDED: ErrorCode = _

Consumer max request batch exceeds server limit

Source

pub const CONSUMER_REPLICAS_EXCEEDS_STREAM: ErrorCode = _

Consumer config replica count exceeds parent stream

Source

pub const CONSUMER_NAME_CONTAINS_PATH_SEPARATORS: ErrorCode = _

Consumer name can not contain path separators

Source

pub const STREAM_NAME_CONTAINS_PATH_SEPARATORS: ErrorCode = _

Stream name can not contain path separators

Source

pub const STREAM_MOVE_NOT_IN_PROGRESS: ErrorCode = _

Stream move not in progress

Source

pub const STREAM_NAME_EXIST_RESTORE_FAILED: ErrorCode = _

Stream name already in use, cannot restore

Source

pub const CONSUMER_CREATE_FILTER_SUBJECT_MISMATCH: ErrorCode = _

Consumer create request did not match filtered subject from create subject

Source

pub const CONSUMER_CREATE_DURABLE_AND_NAME_MISMATCH: ErrorCode = _

Consumer durable and name have to be equal if both are provided

Source

pub const REPLICAS_COUNT_CANNOT_BE_NEGATIVE: ErrorCode = _

Replicas count cannot be negative

Source

pub const CONSUMER_REPLICAS_SHOULD_MATCH_STREAM: ErrorCode = _

Consumer config replicas must match interest retention stream’s replicas

Source

pub const CONSUMER_METADATA_LENGTH: ErrorCode = _

Consumer metadata exceeds maximum size

Source

pub const CONSUMER_DUPLICATE_FILTER_SUBJECTS: ErrorCode = _

Consumer cannot have both filter_subject and filter_subjects specified

Source

pub const CONSUMER_MULTIPLE_FILTERS_NOT_ALLOWED: ErrorCode = _

Consumer with multiple subject filters cannot use subject based api

Source

pub const CONSUMER_OVERLAPPING_SUBJECT_FILTERS: ErrorCode = _

Consumer subject filters cannot overlap

Source

pub const CONSUMER_EMPTY_FILTER: ErrorCode = _

Consumer filter in filter_subjects cannot be empty

Source

pub const SOURCE_DUPLICATE_DETECTED: ErrorCode = _

Duplicate source configuration detected

Source

pub const SOURCE_INVALID_STREAM_NAME: ErrorCode = _

Sourced stream name is invalid

Source

pub const MIRROR_INVALID_STREAM_NAME: ErrorCode = _

Mirrored stream name is invalid

Source

pub const SOURCE_MULTIPLE_FILTERS_NOT_ALLOWED: ErrorCode = _

Source with multiple subject transforms cannot also have a single subject filter

Source

pub const SOURCE_INVALID_SUBJECT_FILTER: ErrorCode = _

Source subject filter is invalid

Source

pub const SOURCE_INVALID_TRANSFORM_DESTINATION: ErrorCode = _

Source transform destination is invalid

Source

pub const SOURCE_OVERLAPPING_SUBJECT_FILTERS: ErrorCode = _

Source filters cannot overlap

Source

pub const CONSUMER_ALREADY_EXISTS: ErrorCode = _

Consumer already exists

Source

pub const CONSUMER_DOES_NOT_EXIST: ErrorCode = _

Consumer does not exist

Source

pub const MIRROR_MULTIPLE_FILTERS_NOT_ALLOWED: ErrorCode = _

Mirror with multiple subject transforms cannot also have a single subject filter

Source

pub const MIRROR_INVALID_SUBJECT_FILTER: ErrorCode = _

Mirror subject filter is invalid

Source

pub const MIRROR_OVERLAPPING_SUBJECT_FILTERS: ErrorCode = _

Mirror subject filters cannot overlap

Source

pub const CONSUMER_INACTIVE_THRESHOLD_EXCESS: ErrorCode = _

Consumer inactive threshold exceeds system limit

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

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

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> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dst: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dst. 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

Source§

type Output = T

Should always be Self
Source§

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

Source§

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>,

Source§

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>,

Source§

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>,

Source§

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T