Enum FastPublishErrorKind 

#[non_exhaustive]
pub enum FastPublishErrorKind {
    NotEnabled,
    InvalidPattern,
    InvalidBatchId,
    UnknownBatchId,
    TooManyInflight,
    GapDetected,
    FlowError,
    EmptyBatch,
    InvalidInboxShape,
    InvalidConfig,
    Closed,
    Timeout,
    Subscribe,
    Publish,
    Serialization,
    InvalidState,
    Other,
}

Kinds of errors that can occur during fast-ingest batch publishing.

API error codes are verified against nats-server 2.14 errors.json.

Marked #[non_exhaustive] — adding a new variant in a future release will not be a breaking change. Match on _ for forward compatibility.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

NotEnabled

Stream does not have allow_batched: true. (BATCH_PUBLISH_DISABLED, 10205)

InvalidPattern

Reply subject pattern rejected by the server. (BATCH_PUBLISH_INVALID_PATTERN, 10206)

InvalidBatchId

Batch id exceeds 64 characters or is otherwise invalid. (BATCH_PUBLISH_INVALID_BATCH_ID, 10207)

UnknownBatchId

Server has forgotten this batch (timed out, leader change in GapMode::Fail, etc.). (BATCH_PUBLISH_UNKNOWN_BATCH_ID, 10208)

TooManyInflight

Too many in-flight fast batches on the server. (BATCH_PUBLISH_TOO_MANY_INFLIGHT, 10211)

GapDetected

A gap was detected while running in GapMode::Fail. The final ack will indicate which messages were persisted.

FlowError

Any other server-side error reported via a BatchFlowErr message.

EmptyBatch

close() was called on a publisher that has not received any adds.

InvalidInboxShape

build() rejected the inbox because it does not have exactly two tokens. The reply-subject parser requires <prefix>.<id> shape.

InvalidConfig

build() rejected a configuration value (e.g. max_outstanding_acks outside 1..=3).

Closed

Called a method on a publisher that has already committed, closed, or failed fatally.

Timeout

Timed out waiting for a flow ack or final pub ack.

Subscribe

Failed to subscribe to the batch inbox.

Publish

Failed to publish a batch message.

Serialization

Failed to parse a server response.

InvalidState

An internal operation that depends on a runtime invariant was called before that invariant held — currently only emitted when the publisher would need to send a ping but no message has been published yet, so there is no first-subject to address the ping to.

Other

Catch-all.

Trait Implementations

impl Clone for FastPublishErrorKind

fn clone(&self) -> FastPublishErrorKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FastPublishErrorKind

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

Formats the value using the given formatter.

impl Display for FastPublishErrorKind

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

Formats the value using the given formatter.

impl Hash for FastPublishErrorKind

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for FastPublishErrorKind

fn eq(&self, other: &FastPublishErrorKind) -> 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 Copy for FastPublishErrorKind

impl Eq for FastPublishErrorKind

impl StructuralPartialEq for FastPublishErrorKind