glats/jetstream

Types

JetstreamError

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)
```

StorageType

</>

Sets the storage type in a stream.

pub type StorageType {
  FileStorage
  MemoryStorage
}

Constructors

```
FileStorage
```
```
MemoryStorage
```

Functions

ack

</>

pub fn ack(
  conn: Subject(ConnectionMessage),
  message: Message,
) -> Result(Nil, Error)

Sends an acknowledgement for a message.

nack

</>

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.

nack_delay

</>

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.

term

</>

pub fn term(
  conn: Subject(ConnectionMessage),
  message: Message,
) -> Result(Nil, Error)

Sends a term acknowledgement for a message.

Instructs the server to stop redelivery of a message without acknowledging it as successfully processed.