NATS C Client with JetStream and Streaming support
3.9.1
The nats.io C Client, Supported by Synadia Communications Inc.
|
#include <nats.h>
Public Attributes | |
int64_t | MaxPending |
Maximum outstanding asynchronous publishes that can be inflight at one time. More... | |
jsPubAckHandler | AckHandler |
Callback invoked for each asynchronous published message. More... | |
void * | AckHandlerClosure |
Closure (or user data) passed to jsPubAckHandler callback. More... | |
jsPubAckErrHandler | ErrHandler |
Callback invoked when error encountered publishing a given message. More... | |
void * | ErrHandlerClosure |
Closure (or user data) passed to jsPubAckErrHandler callback. More... | |
int64_t | StallWait |
Amount of time (in milliseconds) to wait in a PublishAsync call when there is MaxPending inflight messages, default is 200 ms. More... | |
int64_t jsOptions::jsOptionsPublishAsync::MaxPending |
jsPubAckHandler jsOptions::jsOptionsPublishAsync::AckHandler |
void* jsOptions::jsOptionsPublishAsync::AckHandlerClosure |
jsPubAckErrHandler jsOptions::jsOptionsPublishAsync::ErrHandler |
void* jsOptions::jsOptionsPublishAsync::ErrHandlerClosure |
int64_t jsOptions::jsOptionsPublishAsync::StallWait |