Struct async_nats::jetstream::ErrorCode

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

Implementations

impl ErrorCode

pub const CLUSTER_PEER_NOT_MEMBER: ErrorCode = _

Peer not a member

pub const CONSUMER_EPHEMERAL_WITH_DURABLE: ErrorCode = _

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

pub const STREAM_EXTERNAL_DELETE_PREFIX_OVERLAPS: ErrorCode = _

Stream external delivery prefix overlaps with stream subject

pub const ACCOUNT_RESOURCES_EXCEEDED: ErrorCode = _

Resource limits exceeded for account

pub const CLUSTER_NOT_AVAILABLE: ErrorCode = _

Jetstream system temporarily unavailable

pub const STREAM_SUBJECT_OVERLAP: ErrorCode = _

Subjects overlap with an existing stream

pub const STREAM_WRONG_LAST_SEQUENCE: ErrorCode = _

Wrong last sequence

pub const NAME_NOT_MATCH_SUBJECT: ErrorCode = _

Template name in subject does not match request

pub const CLUSTER_NO_PEERS: ErrorCode = _

No suitable peers for placement

pub const CONSUMER_EPHEMERAL_WITH_DURABLE_NAME: ErrorCode = _

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

pub const INSUFFICIENT_RESOURCES: ErrorCode = _

Insufficient resources

pub const MIRROR_MAX_MESSAGE_SIZE_TOO_BIG: ErrorCode = _

Stream mirror must have max message size >= source

pub const STREAM_DELETE_FAILED: ErrorCode = _

Generic error from stream deletion operation

pub const BAD_REQUEST: ErrorCode = _

Bad request

pub const NOT_SUPPORTED_IN_CLUSTER_MODE: ErrorCode = _

Not currently supported in clustered mode

pub const CONSUMER_NOT_FOUND: ErrorCode = _

Consumer not found

pub const SOURCE_MAX_MESSAGE_SIZE_TOO_BIG: ErrorCode = _

Stream source must have max message size >= target

pub const STREAM_ASSIGNMENT: ErrorCode = _

Generic error when stream operation fails.

pub const STREAM_MESSAGE_EXCEEDS_MAXIMUM: ErrorCode = _

Message size exceeds maximum allowed

pub const STREAM_CREATE_TEMPLATE: ErrorCode = _

Generic error for stream creation error with a string

pub const INVALID_JSON: ErrorCode = _

Invalid JSON

pub const STREAM_INVALID_EXTERNAL_DELIVERY_SUBJECT: ErrorCode = _

Stream external delivery prefix must not contain wildcards

pub const STREAM_RESTORE: ErrorCode = _

Restore failed

pub const CLUSTER_INCOMPLETE: ErrorCode = _

Incomplete results

pub const NO_ACCOUNT: ErrorCode = _

Account not found

pub const RAFT_GENERAL: ErrorCode = _

General RAFT error

pub const RESTORE_SUBSCRIBE_FAILED: ErrorCode = _

Jetstream unable to subscribe to restore snapshot

pub const STREAM_DELETE: ErrorCode = _

Stream deletion failed

pub const STREAM_EXTERNAL_API_OVERLAP: ErrorCode = _

Stream external api prefix must not overlap

pub const MIRROR_WITH_SUBJECTS: ErrorCode = _

Stream mirrors can not contain subjects

pub const JETSTREAM_NOT_ENABLED: ErrorCode = _

Jetstream not enabled

pub const JETSTREAM_NOT_ENABLED_FOR_ACCOUNT: ErrorCode = _

Jetstream not enabled for account

pub const SEQUENCE_NOT_FOUND: ErrorCode = _

Sequence not found

pub const STREAM_MIRROR_NOT_UPDATABLE: ErrorCode = _

Stream mirror configuration can not be updated

pub const STREAM_SEQUENCE_NOT_MATCH: ErrorCode = _

Expected stream sequence does not match

pub const STREAM_WRONG_LAST_MESSAGE_ID: ErrorCode = _

Wrong last msg id

pub const TEMP_STORAGE_FAILED: ErrorCode = _

Jetstream unable to open temp storage for restore

pub const STORAGE_RESOURCES_EXCEEDED: ErrorCode = _

Insufficient storage resources available

pub const STREAM_MISMATCH: ErrorCode = _

Stream name in subject does not match request

pub const STREAM_NOT_MATCH: ErrorCode = _

Expected stream does not match

pub const MIRROR_CONSUMER_SETUP_FAILED: ErrorCode = _

Setting up consumer mirror failed

pub const NOT_EMPTY_REQUEST: ErrorCode = _

Expected an empty request payload

pub const STREAM_NAME_EXIST: ErrorCode = _

Stream name already in use with a different configuration

pub const CLUSTER_TAGS: ErrorCode = _

Tags placement not supported for operation

pub const MAXIMUM_CONSUMERS_LIMIT: ErrorCode = _

Maximum consumers limit reached

pub const SOURCE_CONSUMER_SETUP_FAILED: ErrorCode = _

General source consumer setup failure

pub const CONSUMER_CREATE: ErrorCode = _

Consumer creation failed

pub const CONSUMER_DURABLE_NAME_NOT_IN_SUBJECT: ErrorCode = _

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

pub const STREAM_LIMITS: ErrorCode = _

Stream limits error

pub const STREAM_REPLICAS_NOT_UPDATABLE: ErrorCode = _

Replicas configuration can not be updated

pub const STREAM_TEMPLATE_NOT_FOUND: ErrorCode = _

Template not found

pub const CLUSTER_NOT_ASSIGNED: ErrorCode = _

Jetstream cluster not assigned to this server

pub const CLUSTER_NOT_LEADER: ErrorCode = _

Jetstream cluster can’t handle request

pub const CONSUMER_NAME_EXIST: ErrorCode = _

Consumer name already in use

pub const MIRROR_WITH_SOURCES: ErrorCode = _

Stream mirrors can’t also contain other sources

pub const STREAM_NOT_FOUND: ErrorCode = _

Stream not found

pub const CLUSTER_REQUIRED: ErrorCode = _

Jetstream clustering support required

pub const CONSUMER_DURABLE_NAME_NOT_SET: ErrorCode = _

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

pub const MAXIMUM_STREAMS_LIMIT: ErrorCode = _

Maximum number of streams reached

pub const MIRROR_WITH_START_SEQUENCE_AND_TIME: ErrorCode = _

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

pub const STREAM_SNAPSHOT: ErrorCode = _

Stream snapshot failed

pub const STREAM_UPDATE: ErrorCode = _

Stream update failed

pub const CLUSTER_NOT_ACTIVE: ErrorCode = _

Jetstream not in clustered mode

pub const CONSUMER_DURABLE_NAME_NOT_MATCH_SUBJECT: ErrorCode = _

Consumer name in subject does not match durable name in request

pub const MEMORY_RESOURCES_EXCEEDED: ErrorCode = _

Insufficient memory resources available

pub const MIRROR_WITH_SUBJECT_FILTERS: ErrorCode = _

Stream mirrors can not contain filtered subjects

pub const STREAM_CREATE: ErrorCode = _

Stream create failed with a string

pub const CLUSTER_SERVER_NOT_MEMBER: ErrorCode = _

Server is not a member of the cluster

pub const NO_MESSAGE_FOUND: ErrorCode = _

No message found

pub const SNAPSHOT_DELIVER_SUBJECT_INVALID: ErrorCode = _

Deliver subject not valid

pub const STREAM_GENERALOR: ErrorCode = _

General stream failure

pub const STREAM_INVALID_CONFIG: ErrorCode = _

Invalid stream config

pub const STREAM_REPLICAS_NOT_SUPPORTED: ErrorCode = _

Replicas > 1 not supported in non-clustered mode

pub const STREAM_MESSAGE_DELETE_FAILED: ErrorCode = _

Stream message delete failed

pub const PEER_REMAP: ErrorCode = _

Peer remap failed

pub const STREAM_STORE_FAILED: ErrorCode = _

Stream store failed

pub const CONSUMER_CONFIG_REQUIRED: ErrorCode = _

Consumer config required

pub const CONSUMER_DELIVER_TO_WILDCARDS: ErrorCode = _

Consumer deliver subject has wildcards

pub const CONSUMER_PUSH_MAX_WAITING: ErrorCode = _

Consumer in push mode can not set max waiting

pub const CONSUMER_DELIVER_CYCLE: ErrorCode = _

Consumer deliver subject forms a cycle

pub const CONSUMER_MAX_PENDING_ACK_POLICY_REQUIRED: ErrorCode = _

Consumer requires ack policy for max ack pending

pub const CONSUMER_SMALL_HEARTBEAT: ErrorCode = _

Consumer idle heartbeat needs to be >= 100ms

pub const CONSUMER_PULL_REQUIRES_ACK: ErrorCode = _

Consumer in pull mode requires ack policy

pub const CONSUMER_PULL_NOT_DURABLE: ErrorCode = _

Consumer in pull mode requires a durable name

pub const CONSUMER_PULL_WITH_RATE_LIMIT: ErrorCode = _

Consumer in pull mode can not have rate limit set

pub const CONSUMER_MAX_WAITING_NEGATIVE: ErrorCode = _

Consumer max waiting needs to be positive

pub const CONSUMER_HEARTBEAT_REQUIRES_PUSH: ErrorCode = _

Consumer idle heartbeat requires a push based consumer

pub const CONSUMER_FLOW_CONTROL_REQUIRES_PUSH: ErrorCode = _

Consumer flow control requires a push based consumer

pub const CONSUMER_DIRECT_REQUIRES_PUSH: ErrorCode = _

Consumer direct requires a push based consumer

pub const CONSUMER_DIRECT_REQUIRES_EPHEMERAL: ErrorCode = _

Consumer direct requires an ephemeral consumer

pub const CONSUMER_ON_MAPPED: ErrorCode = _

Consumer direct on a mapped consumer

pub const CONSUMER_FILTER_NOT_SUBSET: ErrorCode = _

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

pub const CONSUMER_INVALID_POLICY: ErrorCode = _

Invalid consumer policy

pub const CONSUMER_INVALID_SAMPLING: ErrorCode = _

Failed to parse consumer sampling configuration

pub const STREAM_INVALID: ErrorCode = _

Stream not valid

pub const CONSUMER_WQ_REQUIRES_EXPLICIT_ACK: ErrorCode = _

Workqueue stream requires explicit ack

pub const CONSUMER_WQ_MULTIPLE_UNFILTERED: ErrorCode = _

Multiple non-filtered consumers not allowed on workqueue stream

pub const CONSUMER_WQ_CONSUMER_NOT_UNIQUE: ErrorCode = _

Filtered consumer not unique on workqueue stream

pub const CONSUMER_WQ_CONSUMER_NOT_DELIVER_ALL: ErrorCode = _

Consumer must be deliver all on workqueue stream

pub const CONSUMER_NAME_TOO_LONG: ErrorCode = _

Consumer name is too long

pub const CONSUMER_BAD_DURABLE_NAME: ErrorCode = _

Durable name can not contain token separators and wildcards

pub const CONSUMER_STORE_FAILED: ErrorCode = _

Error creating store for consumer

pub const CONSUMER_EXISTING_ACTIVE: ErrorCode = _

Consumer already exists and is still active

pub const CONSUMER_REPLACEMENT_WITH_DIFFERENT_NAME: ErrorCode = _

Consumer replacement durable config not the same

pub const CONSUMER_DESCRIPTION_TOO_LONG: ErrorCode = _

Consumer description is too long

pub const STREAM_HEADER_EXCEEDS_MAXIMUM: ErrorCode = _

Header size exceeds maximum allowed of 64k

pub const CONSUMER_WITH_FLOW_CONTROL_NEEDS_HEARTBEATS: ErrorCode = _

Consumer with flow control also needs heartbeats

pub const STREAM_SEALED: ErrorCode = _

Invalid operation on sealed stream

pub const STREAM_PURGE_FAILED: ErrorCode = _

Stream purge failed

pub const STREAM_ROLLUP_FAILED: ErrorCode = _

Stream rollup failed

pub const CONSUMER_INVALID_DELIVER_SUBJECT: ErrorCode = _

Invalid push consumer deliver subject

pub const STREAM_MAX_BYTES_REQUIRED: ErrorCode = _

Account requires a stream config to have max bytes set

pub const CONSUMER_MAX_REQUEST_BATCH_NEGATIVE: ErrorCode = _

Consumer max request batch needs to be > 0

pub const CONSUMER_MAX_REQUEST_EXPIRES_TO_SMALL: ErrorCode = _

Consumer max request expires needs to be >= 1ms

pub const CONSUMER_MAX_DELIVER_BACKOFF: ErrorCode = _

Max deliver is required to be > length of backoff values

pub const STREAM_INFO_MAX_SUBJECTS: ErrorCode = _

Subject details would exceed maximum allowed

pub const STREAM_OFFLINE: ErrorCode = _

Stream is offline

pub const CONSUMER_OFFLINE: ErrorCode = _

Consumer is offline

pub const NO_LIMITS: ErrorCode = _

No jetstream default or applicable tiered limit present

pub const CONSUMER_MAX_PENDING_ACK_EXCESS: ErrorCode = _

Consumer max ack pending exceeds system limit

pub const STREAM_MAX_STREAM_BYTES_EXCEEDED: ErrorCode = _

Stream max bytes exceeds account limit max stream bytes

pub const STREAM_MOVE_AND_SCALE: ErrorCode = _

Can not move and scale a stream in a single update

pub const STREAM_MOVE_IN_PROGRESS: ErrorCode = _

Stream move already in progress

pub const CONSUMER_MAX_REQUEST_BATCH_EXCEEDED: ErrorCode = _

Consumer max request batch exceeds server limit

pub const CONSUMER_REPLICAS_EXCEEDS_STREAM: ErrorCode = _

Consumer config replica count exceeds parent stream

pub const CONSUMER_NAME_CONTAINS_PATH_SEPARATORS: ErrorCode = _

Consumer name can not contain path separators

pub const STREAM_NAME_CONTAINS_PATH_SEPARATORS: ErrorCode = _

Stream name can not contain path separators

pub const STREAM_MOVE_NOT_IN_PROGRESS: ErrorCode = _

Stream move not in progress

pub const STREAM_NAME_EXIST_RESTORE_FAILED: ErrorCode = _

Stream name already in use, cannot restore

pub const CONSUMER_CREATE_FILTER_SUBJECT_MISMATCH: ErrorCode = _

Consumer create request did not match filtered subject from create subject

pub const CONSUMER_CREATE_DURABLE_AND_NAME_MISMATCH: ErrorCode = _

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

pub const REPLICAS_COUNT_CANNOT_BE_NEGATIVE: ErrorCode = _

Replicas count cannot be negative

pub const CONSUMER_REPLICAS_SHOULD_MATCH_STREAM: ErrorCode = _

Consumer config replicas must match interest retention stream’s replicas

pub const CONSUMER_METADATA_LENGTH: ErrorCode = _

Consumer metadata exceeds maximum size

pub const CONSUMER_DUPLICATE_FILTER_SUBJECTS: ErrorCode = _

Consumer cannot have both filter_subject and filter_subjects specified

pub const CONSUMER_MULTIPLE_FILTERS_NOT_ALLOWED: ErrorCode = _

Consumer with multiple subject filters cannot use subject based api

pub const CONSUMER_OVERLAPPING_SUBJECT_FILTERS: ErrorCode = _

Consumer subject filters cannot overlap

pub const CONSUMER_EMPTY_FILTER: ErrorCode = _

Consumer filter in filter_subjects cannot be empty

pub const SOURCE_DUPLICATE_DETECTED: ErrorCode = _

Duplicate source configuration detected

pub const SOURCE_INVALID_STREAM_NAME: ErrorCode = _

Sourced stream name is invalid

pub const MIRROR_INVALID_STREAM_NAME: ErrorCode = _

Mirrored stream name is invalid

pub const SOURCE_MULTIPLE_FILTERS_NOT_ALLOWED: ErrorCode = _

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

pub const SOURCE_INVALID_SUBJECT_FILTER: ErrorCode = _

Source subject filter is invalid

pub const SOURCE_INVALID_TRANSFORM_DESTINATION: ErrorCode = _

Source transform destination is invalid

pub const SOURCE_OVERLAPPING_SUBJECT_FILTERS: ErrorCode = _

Source filters cannot overlap

pub const CONSUMER_ALREADY_EXISTS: ErrorCode = _

Consumer already exists

pub const CONSUMER_DOES_NOT_EXIST: ErrorCode = _

Consumer does not exist

pub const MIRROR_MULTIPLE_FILTERS_NOT_ALLOWED: ErrorCode = _

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

pub const MIRROR_INVALID_SUBJECT_FILTER: ErrorCode = _

Mirror subject filter is invalid

pub const MIRROR_OVERLAPPING_SUBJECT_FILTERS: ErrorCode = _

Mirror subject filters cannot overlap

pub const CONSUMER_INACTIVE_THRESHOLD_EXCESS: ErrorCode = _

Consumer inactive threshold exceeds system limit

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

Tests for self and other values to be equal, and is used by ==.

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

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