glats/jetstream
Types
Errors that can be returned when working with Jetstream.
pub type JetstreamError {
JetstreamNotEnabledForAccount(String)
JetstreamNotEnabled(String)
InsufficientResources(String)
InvalidStreamConfig(String)
StreamNameInSubjectDoesNotMatch(String)
StreamNameInUse(String)
StreamNotFound(String)
StreamPurgeNotAllowed(String)
NoMessageFound(String)
ConsumerNotFound(String)
ConsumerNameExists(String)
ConsumerAlreadyExists(String)
WrongLastSequence(String)
BadRequest(String)
Unknown(Int, String)
DecodeError(String)
Timeout
NoResponders
PullConsumerRequired(String)
}
Constructors
-
JetstreamNotEnabledForAccount(String)
-
JetstreamNotEnabled(String)
-
InsufficientResources(String)
-
InvalidStreamConfig(String)
-
StreamNameInSubjectDoesNotMatch(String)
-
StreamNameInUse(String)
-
StreamNotFound(String)
-
StreamPurgeNotAllowed(String)
-
NoMessageFound(String)
-
ConsumerNotFound(String)
-
ConsumerNameExists(String)
-
ConsumerAlreadyExists(String)
-
WrongLastSequence(String)
-
BadRequest(String)
-
Unknown(Int, String)
-
DecodeError(String)
-
Timeout
-
NoResponders
-
PullConsumerRequired(String)
Sets the storage type in a stream.
pub type StorageType {
FileStorage
MemoryStorage
}
Constructors
-
FileStorage
-
MemoryStorage
Functions
pub fn ack(
conn: Subject(ConnectionMessage),
message: Message,
) -> Result(Nil, Error)
Sends an acknowledgement for a message.
pub fn nack(
conn: Subject(ConnectionMessage),
message: Message,
) -> Result(Nil, Error)
Sends a negative acknowledgement for a message.
Delivery will be retried until ack’d or term’d.
pub fn nack_delay(
conn: Subject(ConnectionMessage),
message: Message,
with delay: Int,
) -> Result(Nil, Error)
Sends a negative acknowledgement for a message and delays redelivery of the message. The unit is in nanoseconds.