Struct 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