Skip to main content

ErrorCode

Struct ErrorCode 

Source
pub struct ErrorCode(pub u64);
Available on crate feature jetstream only.

Tuple Fields§

§0: u64

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 MIRROR_WITH_FIRST_SEQ: ErrorCode

Stream mirrors cannot have first sequence configured

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

Source

pub const MIRROR_INVALID_TRANSFORM_DESTINATION: ErrorCode

Mirror invalid transform destination

Source

pub const STREAM_TRANSFORM_INVALID_SOURCE: ErrorCode

Stream transform invalid source

Source

pub const STREAM_TRANSFORM_INVALID_DESTINATION: ErrorCode

Stream transform invalid destination

Source

pub const PEDANTIC: ErrorCode

Pedantic error

Source

pub const STREAM_DUPLICATE_MESSAGE_CONFLICT: ErrorCode

Stream duplicate message conflict

Source

pub const CONSUMER_PRIORITY_POLICY_WITHOUT_GROUP: ErrorCode

Consumer priority policy without group

Source

pub const CONSUMER_INVALID_PRIORITY_GROUP: ErrorCode

Consumer invalid priority group

Source

pub const CONSUMER_EMPTY_GROUP_NAME: ErrorCode

Consumer empty group name

Source

pub const CONSUMER_INVALID_GROUP_NAME: ErrorCode

Consumer invalid group name

Source

pub const STREAM_EXPECTED_LAST_SEQ_PER_SUBJECT_NOT_READY: ErrorCode

Stream expected last seq per subject not ready

Source

pub const STREAM_WRONG_LAST_SEQUENCE_CONSTANT: ErrorCode

Stream wrong last sequence constant

Source

pub const MESSAGE_TTL_INVALID: ErrorCode

Message TTL invalid

Source

pub const MESSAGE_TTL_DISABLED: ErrorCode

Message TTL disabled

Source

pub const STREAM_TOO_MANY_REQUESTS: ErrorCode

Stream too many requests

Source

pub const MESSAGE_INCR_DISABLED: ErrorCode

Message increment disabled

Source

pub const MESSAGE_INCR_MISSING: ErrorCode

Message increment missing

Source

pub const MESSAGE_INCR_PAYLOAD: ErrorCode

Message increment payload error

Source

pub const MESSAGE_INCR_INVALID: ErrorCode

Message increment invalid

Source

pub const MESSAGE_COUNTER_BROKEN: ErrorCode

Message counter broken

Source

pub const MIRROR_WITH_COUNTERS: ErrorCode

Mirror with counters

Source

pub const ATOMIC_PUBLISH_DISABLED: ErrorCode

Atomic publish disabled

Source

pub const ATOMIC_PUBLISH_MISSING_SEQ: ErrorCode

Atomic publish sequence missing

Source

pub const ATOMIC_PUBLISH_INCOMPLETE_BATCH: ErrorCode

Atomic publish batch incomplete

Source

pub const ATOMIC_PUBLISH_UNSUPPORTED_HEADER: ErrorCode

Atomic publish unsupported header

Source

pub const CONSUMER_PUSH_WITH_PRIORITY_GROUP: ErrorCode

Consumer push with priority group

Source

pub const ATOMIC_PUBLISH_INVALID_BATCH_ID: ErrorCode

Atomic publish batch ID invalid

Source

pub const STREAM_MIN_LAST_SEQ: ErrorCode

Stream min last sequence error

Source

pub const CONSUMER_ACK_POLICY_INVALID: ErrorCode

Consumer ack policy invalid

Source

pub const CONSUMER_REPLAY_POLICY_INVALID: ErrorCode

Consumer replay policy invalid

Source

pub const CONSUMER_ACK_WAIT_NEGATIVE: ErrorCode

Consumer ack wait negative

Source

pub const CONSUMER_BACKOFF_NEGATIVE: ErrorCode

Consumer backoff negative

Source

pub const REQUIRED_API_LEVEL: ErrorCode

Required API level

Source

pub const MIRROR_WITH_MSG_SCHEDULES: ErrorCode

Mirror with message schedules

Source

pub const SOURCE_WITH_MSG_SCHEDULES: ErrorCode

Source with message schedules

Source

pub const MESSAGE_SCHEDULES_DISABLED: ErrorCode

Message schedules disabled

Source

pub const MESSAGE_SCHEDULES_PATTERN_INVALID: ErrorCode

Message schedules pattern invalid

Source

pub const MESSAGE_SCHEDULES_TARGET_INVALID: ErrorCode

Message schedules target invalid

Source

pub const MESSAGE_SCHEDULES_TTL_INVALID: ErrorCode

Message schedules TTL invalid

Source

pub const MESSAGE_SCHEDULES_ROLLUP_INVALID: ErrorCode

Message schedules rollup invalid

Source

pub const STREAM_EXPECTED_LAST_SEQ_PER_SUBJECT_INVALID: ErrorCode

Stream expected last seq per subject invalid

Source

pub const STREAM_OFFLINE_REASON: ErrorCode

Stream offline reason

Source

pub const CONSUMER_OFFLINE_REASON: ErrorCode

Consumer offline reason

Source

pub const CONSUMER_PRIORITY_GROUP_WITH_POLICY_NONE: ErrorCode

Consumer priority group with policy none

Source

pub const CONSUMER_PINNED_TTL_WITHOUT_PRIORITY_POLICY_NONE: ErrorCode

Consumer pinned TTL without priority policy none

Source

pub const MIRROR_WITH_ATOMIC_PUBLISH: ErrorCode

Mirror with atomic publish

Source

pub const ATOMIC_PUBLISH_TOO_LARGE_BATCH: ErrorCode

Atomic publish batch too large

Source

pub const ATOMIC_PUBLISH_INVALID_BATCH_COMMIT: ErrorCode

Atomic publish batch commit invalid

Source

pub const ATOMIC_PUBLISH_CONTAINS_DUPLICATE_MESSAGE: ErrorCode

Atomic publish batch contains duplicate message id

Source

pub const CLUSTER_SERVER_MEMBER_CHANGE_INFLIGHT: ErrorCode

Cluster member change is in progress

Source

pub const MESSAGE_SCHEDULES_SOURCE_INVALID: ErrorCode

Message schedules source is invalid

Source

pub const CONSUMER_INVALID_RESET: ErrorCode

Consumer invalid reset

Source

pub const BATCH_PUBLISH_DISABLED: ErrorCode

Batch publish is disabled

Source

pub const BATCH_PUBLISH_INVALID_PATTERN: ErrorCode

Batch publish pattern is invalid

Source

pub const BATCH_PUBLISH_INVALID_BATCH_ID: ErrorCode

Batch publish ID is invalid

Source

pub const BATCH_PUBLISH_UNKNOWN_BATCH_ID: ErrorCode

Batch publish ID unknown

Source

pub const MIRROR_WITH_BATCH_PUBLISH: ErrorCode

Stream mirrors can not also use batch publishing

Source

pub const ATOMIC_PUBLISH_TOO_MANY_INFLIGHT: ErrorCode

Atomic publish too many inflight

Source

pub const BATCH_PUBLISH_TOO_MANY_INFLIGHT: ErrorCode

Batch publish too many inflight

Source

pub const MESSAGE_SCHEDULES_SCHEDULER_INVALID: ErrorCode

Message schedules invalid scheduler

Source

pub const MIRROR_DURABLE_CONSUMER_CFG_INVALID: ErrorCode

Stream mirror consumer config is invalid

Source

pub const MIRROR_CONSUMER_REQUIRES_ACK_FC: ErrorCode

Stream mirror consumer requires flow control ack policy

Source

pub const SOURCE_DURABLE_CONSUMER_CFG_INVALID: ErrorCode

Stream source consumer config is invalid

Source

pub const SOURCE_DURABLE_CONSUMER_DUPLICATE_DETECTED: ErrorCode

Duplicate stream source consumer detected

Source

pub const SOURCE_CONSUMER_REQUIRES_ACK_FC: ErrorCode

Stream source consumer requires flow control ack policy

Source

pub const CONSUMER_ACK_FC_REQUIRES_PUSH: ErrorCode

Flow control ack policy requires a push based consumer

Source

pub const CONSUMER_ACK_FC_REQUIRES_FC: ErrorCode

Flow control ack policy requires flow control

Source

pub const CONSUMER_ACK_FC_REQUIRES_MAX_ACK_PENDING: ErrorCode

Flow control ack policy requires max ack pending

Source

pub const CONSUMER_ACK_FC_REQUIRES_NO_ACK_WAIT: ErrorCode

Flow control ack policy requires unset ack wait

Source

pub const CONSUMER_ACK_FC_REQUIRES_NO_MAX_DELIVER: ErrorCode

Flow control ack policy requires unset max deliver

Source

pub const MESSAGE_SCHEDULES_TIME_ZONE_INVALID: ErrorCode

Message schedules time zone is invalid

Trait Implementations§

Source§

impl Clone for ErrorCode

Source§

fn clone(&self) -> ErrorCode

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Copy for ErrorCode

Source§

impl Debug for ErrorCode

Source§

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

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

impl Default for ErrorCode

Source§

fn default() -> ErrorCode

Returns the “default value” for a type. 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 Eq for ErrorCode

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 (const: unstable) · 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 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, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

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

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