|
NATS C Client with JetStream and Streaming support
- 3.0.0
+ 3.1.0
The nats.io C Client, Supported by Synadia Communications Inc.
|
@@ -333,1099 +333,1111 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
+
+
+
+
-
+
- 770 #ifndef BUILD_IN_DOXYGEN
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+ 783 #ifndef BUILD_IN_DOXYGEN
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
- 836 #if defined(NATS_HAS_STREAMING)
-
+
+
+
-
+
+
+
+
+
- 853 typedef struct __stanMsg
stanMsg;
-
-
-
-
-
-
-
-
-
-
+ 849 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+ 866 typedef struct __stanMsg
stanMsg;
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
- 1003 char **customErrTxt,
-
-
-
-
- 1033 char **customErrTxt,
- 1034 unsigned char **signature,
- 1035 int *signatureLength,
-
-
-
- 1047 typedef const char* (*natsTokenHandler)(
void *closure);
-
-
-
-
-
-
- 1081 #ifdef BUILD_IN_DOXYGEN
-
-
-
- 1118 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 1202 #ifdef BUILD_IN_DOXYGEN
-
-
-
- 1220 #define nats_CheckCompatibility() nats_CheckCompatibilityImpl(NATS_VERSION_REQUIRED_NUMBER, \
- 1221 NATS_VERSION_NUMBER, \
- 1222 NATS_VERSION_STRING)
-
-
- 1225 nats_CheckCompatibilityImpl(uint32_t reqVerNumber, uint32_t verNumber,
const char *verString);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+ 1016 char **customErrTxt,
+
+
+
+
+ 1046 char **customErrTxt,
+ 1047 unsigned char **signature,
+ 1048 int *signatureLength,
+
+
+
+ 1060 typedef const char* (*natsTokenHandler)(
void *closure);
+
+
+
+
+
+
+ 1094 #ifdef BUILD_IN_DOXYGEN
+
+
+
+ 1131 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1215 #ifdef BUILD_IN_DOXYGEN
+
+
+
+ 1233 #define nats_CheckCompatibility() nats_CheckCompatibilityImpl(NATS_VERSION_REQUIRED_NUMBER, \
+ 1234 NATS_VERSION_NUMBER, \
+ 1235 NATS_VERSION_STRING)
+
+
+ 1238 nats_CheckCompatibilityImpl(uint32_t reqVerNumber, uint32_t verNumber,
const char *verString);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
- 1375 unsigned char **signature,
- 1376 int *signatureLength);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 1509 uint64_t *inMsgs, uint64_t *inBytes,
- 1510 uint64_t *outMsgs, uint64_t *outBytes,
- 1511 uint64_t *reconnects);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+ 1388 unsigned char **signature,
+ 1389 int *signatureLength);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1522 uint64_t *inMsgs, uint64_t *inBytes,
+ 1523 uint64_t *outMsgs, uint64_t *outBytes,
+ 1524 uint64_t *reconnects);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 1782 const char *certsFileName,
- 1783 const char *keyFileName);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1795 const char *certsFileName,
+ 1796 const char *keyFileName);
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 2448 const char *userOrChainedFile,
- 2449 const char *seedFile);
-
-
-
-
-
-
-
-
-
-
- 2507 const char *seedFile);
-
-
-
-
-
-
-
-
-
-
-
- 2574 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 2461 const char *userOrChainedFile,
+ 2462 const char *seedFile);
+
+
+
+
+
+
+
+
+
+
+ 2520 const char *seedFile);
+
+
+
+
+
+
+
+
+
+
+
+ 2587 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
- 3006 const char *data,
int dataLen);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3238 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3019 const char *data,
int dataLen);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3251 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3658 const unsigned char *message,
int messageLen,
- 3659 unsigned char sig[64]);
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3671 const unsigned char *message,
int messageLen,
+ 3672 unsigned char sig[64]);
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3769 const void *data,
int dataLen);
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3782 const void *data,
int dataLen);
+
+
+
+
-
-
- 3816 const char *reply,
const void *data,
int dataLen);
-
-
-
- 3836 const char *reply,
const char *str);
-
-
-
- 3857 const void *data,
int dataLen, int64_t timeout);
-
-
-
- 3882 const char *subj,
const char *str,
-
-
-
-
- 3901 natsMsg *requestMsg, int64_t timeout);
-
-
-
-
-
-
-
-
-
- 3962 const char *subject, int64_t timeout,
-
-
-
-
- 3977 const char *subject);
-
-
-
- 3998 const char *subject,
const char *queueGroup,
-
-
-
-
- 4035 const char *subject,
const char *queueGroup,
-
-
-
-
- 4051 const char *subject,
const char *queueGroup);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 4286 int *maxPendingMsgs,
- 4287 int *maxPendingBytes,
- 4288 int64_t *deliveredMsgs,
- 4289 int64_t *droppedMsgs);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 4471 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+ 3829 const char *reply,
const void *data,
int dataLen);
+
+
+
+ 3849 const char *reply,
const char *str);
+
+
+
+ 3870 const void *data,
int dataLen, int64_t timeout);
+
+
+
+ 3895 const char *subj,
const char *str,
+
+
+
+
+ 3914 natsMsg *requestMsg, int64_t timeout);
+
+
+
+
+
+
+
+
+
+ 3975 const char *subject, int64_t timeout,
+
+
+
+
+ 3990 const char *subject);
+
+
+
+ 4011 const char *subject,
const char *queueGroup,
+
+
+
+
+ 4048 const char *subject,
const char *queueGroup,
+
+
+
+
+ 4064 const char *subject,
const char *queueGroup);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 4299 int *maxPendingMsgs,
+ 4300 int *maxPendingBytes,
+ 4301 int64_t *deliveredMsgs,
+ 4302 int64_t *droppedMsgs);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 4484 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
- 4611 const void *data,
int dataLen);
-
-
-
- 4638 const void *data,
int dataLen,
-
-
-
-
-
-
-
-
-
-
- 4691 const char *channel,
const char *queueGroup,
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+ 4624 const void *data,
int dataLen);
+
+
+
+ 4651 const void *data,
int dataLen,
+
+
+
+
+
+
+
+
+
+
+ 4704 const char *channel,
const char *queueGroup,
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 5044 const char *stream,
const char *consumer,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 5057 const char *stream,
const char *consumer,
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-void(* natsOnCompleteCB)(void *closure)
Callback used to notify that an object lifecycle is complete.
Definition: nats.h:1057
natsStatus(* natsEvLoop_Attach)(void **userData, void *loop, natsConnection *nc, natsSock socket)
Attach this connection to the external event loop.
Definition: nats.h:938
natsStatus(* natsUserJWTHandler)(char **userJWT, char **customErrTxt, void *closure)
Callback used to fetch and return account signed user JWT.
Definition: nats.h:1001
natsStatus(* natsEvLoop_WriteAddRemove)(void *userData, bool add)
Write event needs to be added or removed.
Definition: nats.h:966
int64_t(* natsCustomReconnectDelayHandler)(natsConnection *nc, int attempts, void *closure)
Callback used to specify how long to wait between reconnects.
Definition: nats.h:1079
const char *(* natsTokenHandler)(void *closure)
Callback used to build a token on connections and reconnections.
Definition: nats.h:1047
void(* jsPubAckErrHandler)(jsCtx *js, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish errors from JetStream.
Definition: nats.h:1115
void(* natsErrHandler)(natsConnection *nc, natsSubscription *subscription, natsStatus err, void *closure)
Callback used to notify the user of errors encountered while processing inbound messages.
Definition: nats.h:921
natsStatus(* natsEvLoop_Detach)(void *userData)
Detach from the event loop.
Definition: nats.h:977
natsStatus(* natsSignatureHandler)(char **customErrTxt, unsigned char **signature, int *signatureLength, const char *nonce, void *closure)
Callback used to sign a nonce sent by the server.
Definition: nats.h:1032
void(* stanConnectionLostHandler)(stanConnection *sc, const char *errorTxt, void *closure)
Callback used to notify the user of the permanent loss of the connection.
Definition: nats.h:1147
void(* natsConnectionHandler)(natsConnection *nc, void *closure)
Callback used to notify the user of asynchronous connection events.
Definition: nats.h:912
void(* natsMsgHandler)(natsConnection *nc, natsSubscription *sub, natsMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:896
void(* stanPubAckHandler)(const char *guid, const char *error, void *closure)
Callback used to notify of an asynchronous publish result.
Definition: nats.h:1127
natsStatus(* natsEvLoop_ReadAddRemove)(void *userData, bool add)
Read event needs to be added or removed.
Definition: nats.h:953
void(* stanMsgHandler)(stanConnection *sc, stanSubscription *sub, const char *channel, stanMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1138
void(* natsOnCompleteCB)(void *closure)
Callback used to notify that an object lifecycle is complete.
Definition: nats.h:1070
natsStatus(* natsEvLoop_Attach)(void **userData, void *loop, natsConnection *nc, natsSock socket)
Attach this connection to the external event loop.
Definition: nats.h:951
natsStatus(* natsUserJWTHandler)(char **userJWT, char **customErrTxt, void *closure)
Callback used to fetch and return account signed user JWT.
Definition: nats.h:1014
natsStatus(* natsEvLoop_WriteAddRemove)(void *userData, bool add)
Write event needs to be added or removed.
Definition: nats.h:979
int64_t(* natsCustomReconnectDelayHandler)(natsConnection *nc, int attempts, void *closure)
Callback used to specify how long to wait between reconnects.
Definition: nats.h:1092
const char *(* natsTokenHandler)(void *closure)
Callback used to build a token on connections and reconnections.
Definition: nats.h:1060
void(* jsPubAckErrHandler)(jsCtx *js, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish errors from JetStream.
Definition: nats.h:1128
void(* natsErrHandler)(natsConnection *nc, natsSubscription *subscription, natsStatus err, void *closure)
Callback used to notify the user of errors encountered while processing inbound messages.
Definition: nats.h:934
natsStatus(* natsEvLoop_Detach)(void *userData)
Detach from the event loop.
Definition: nats.h:990
natsStatus(* natsSignatureHandler)(char **customErrTxt, unsigned char **signature, int *signatureLength, const char *nonce, void *closure)
Callback used to sign a nonce sent by the server.
Definition: nats.h:1045
void(* stanConnectionLostHandler)(stanConnection *sc, const char *errorTxt, void *closure)
Callback used to notify the user of the permanent loss of the connection.
Definition: nats.h:1160
void(* natsConnectionHandler)(natsConnection *nc, void *closure)
Callback used to notify the user of asynchronous connection events.
Definition: nats.h:925
void(* natsMsgHandler)(natsConnection *nc, natsSubscription *sub, natsMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:909
void(* stanPubAckHandler)(const char *guid, const char *error, void *closure)
Callback used to notify of an asynchronous publish result.
Definition: nats.h:1140
natsStatus(* natsEvLoop_ReadAddRemove)(void *userData, bool add)
Read event needs to be added or removed.
Definition: nats.h:966
void(* stanMsgHandler)(stanConnection *sc, stanSubscription *sub, const char *channel, stanMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1151
NATS_EXTERN int natsConnection_Buffered(natsConnection *nc)
Returns the number of bytes to be sent to the server.
bool natsConnection_IsDraining(natsConnection *nc)
Test if connection is draining.
NATS_EXTERN void natsConnection_Close(natsConnection *nc)
Closes the connection.
NATS_EXTERN natsStatus natsSubscription_SetOnCompleteCB(natsSubscription *sub, natsOnCompleteCB cb, void *closure)
Sets a completion callback.
NATS_EXTERN natsStatus natsSubscription_Unsubscribe(natsSubscription *sub)
Unsubscribes.
NATS_EXTERN natsStatus natsSubscription_ClearMaxPending(natsSubscription *sub)
Clears the statistics regarding the maximum pending values.
struct __stanSubOptions stanSubOptions
Way to configure a stanSubscription.
Definition: nats.h:865
struct __stanSubOptions stanSubOptions
Way to configure a stanSubscription.
Definition: nats.h:878
struct jsConsumerConfig jsConsumerConfig
struct jsOptions jsOptions
jsDeliverPolicy
Definition: nats.h:240
struct __stanConnOptions stanConnOptions
Way to configure a stanConnection.
Definition: nats.h:859
struct __stanConnOptions stanConnOptions
Way to configure a stanConnection.
Definition: nats.h:872
jsStorageType
Definition: nats.h:230
struct jsPeerInfo jsPeerInfo
char natsInbox
Unique subject often used for point-to-point communication.
Definition: nats.h:137
struct jsStreamInfo jsStreamInfo
struct jsStreamConfig jsStreamConfig
struct jsSequenceInfo jsSequenceInfo
struct jsStreamState jsStreamState
struct __stanMsg stanMsg
The Streaming message.
Definition: nats.h:853
struct __stanMsg stanMsg
The Streaming message.
Definition: nats.h:866
struct jsConsumerInfo jsConsumerInfo
struct jsSequencePair jsSequencePair
jsRetentionPolicy
Definition: nats.h:209
jsReplayPolicy
Definition: nats.h:266
struct __natsSubscription natsSubscription
Interest on a given subject.
Definition: nats.h:115
jsAckPolicy
Definition: nats.h:254
struct __stanConnection stanConnection
A connection to a NATS Streaming Server.
Definition: nats.h:841
struct __stanConnection stanConnection
A connection to a NATS Streaming Server.
Definition: nats.h:854
struct jsAccountLimits jsAccountLimits
struct __jsCtx jsCtx
Definition: nats.h:177
struct jsClusterInfo jsClusterInfo
struct jsAPIStats jsAPIStats
struct jsPubAckErr jsPubAckErr
struct __natsMsg natsMsg
A structure holding a subject, optional reply and payload.
Definition: nats.h:122
struct __stanSubscription stanSubscription
Interest on a given channel.
Definition: nats.h:847
struct __stanSubscription stanSubscription
Interest on a given channel.
Definition: nats.h:860
struct jsExternalStream jsExternalStream
struct jsLostStreamData jsLostStreamData
jsErrCode
Definition: status.h:135
natsStatus
Status returned by most of the APIs.
Definition: status.h:50
natsConnStatus
The connection state.
Definition: status.h:24
uint64_t Total
Definition: nats.h:696
uint64_t Errors
Definition: nats.h:697
int64_t Consumers
Definition: nats.h:721
int64_t Streams
Definition: nats.h:720
uint64_t Memory
Definition: nats.h:718
jsAPIStats API
Definition: nats.h:723
jsAccountLimits Limits
Definition: nats.h:724
char * Domain
Definition: nats.h:722
uint64_t Store
Definition: nats.h:719
int64_t MaxStreams
Definition: nats.h:708
int64_t MaxConsumers
Definition: nats.h:709
int64_t MaxStore
Definition: nats.h:707
int64_t MaxMemory
Definition: nats.h:706
uint64_t Total
Definition: nats.h:707
uint64_t Errors
Definition: nats.h:708
int64_t Consumers
Definition: nats.h:732
int64_t Streams
Definition: nats.h:731
uint64_t Memory
Definition: nats.h:729
jsAPIStats API
Definition: nats.h:734
jsAccountLimits Limits
Definition: nats.h:735
char * Domain
Definition: nats.h:733
uint64_t Store
Definition: nats.h:730
int64_t MaxStreams
Definition: nats.h:719
int64_t MaxConsumers
Definition: nats.h:720
int64_t MaxStore
Definition: nats.h:718
int64_t MaxMemory
Definition: nats.h:717
int ReplicasLen
Definition: nats.h:480
char * Name
Definition: nats.h:477
jsPeerInfo ** Replicas
Definition: nats.h:479
char * Leader
Definition: nats.h:478
uint64_t OptStartSeq
Definition: nats.h:552
uint64_t RateLimit
Definition: nats.h:559
jsDeliverPolicy DeliverPolicy
Definition: nats.h:551
const char * Description
Definition: nats.h:549
const char * Durable
Definition: nats.h:548
const char * SampleFrequency
Definition: nats.h:560
bool FlowControl
Definition: nats.h:563
int64_t AckWait
Definition: nats.h:555
int64_t OptStartTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:553
int64_t MaxWaiting
Definition: nats.h:561
jsAckPolicy AckPolicy
Definition: nats.h:554
const char * DeliverSubject
Definition: nats.h:550
int64_t Heartbeat
Heartbeat interval expressed in number of nanoseconds.
Definition: nats.h:564
int64_t MaxDeliver
Definition: nats.h:556
jsReplayPolicy ReplayPolicy
Definition: nats.h:558
int64_t MaxAckPending
Definition: nats.h:562
const char * FilterSubject
Definition: nats.h:557
jsSequencePair AckFloor
Definition: nats.h:682
jsConsumerConfig * Config
Definition: nats.h:680
jsSequencePair Delivered
Definition: nats.h:681
int64_t NumWaiting
Definition: nats.h:685
int64_t Created
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:679
jsClusterInfo * Cluster
Definition: nats.h:687
int64_t NumAckPending
Definition: nats.h:683
char * Stream
Definition: nats.h:677
int64_t NumRedelivered
Definition: nats.h:684
char * Name
Definition: nats.h:678
uint64_t NumPending
Definition: nats.h:686
uint64_t Stream
This is the stream sequence that the application should resume from.
Definition: nats.h:587
uint64_t ConsumerServer
This is the consumer sequence last sent by the server.
Definition: nats.h:589
uint64_t ConsumerClient
This is the consumer sequence that was last received by the library.
Definition: nats.h:588
uint64_t OptStartSeq
Definition: nats.h:551
uint64_t RateLimit
Definition: nats.h:558
jsDeliverPolicy DeliverPolicy
Definition: nats.h:550
const char * Description
Definition: nats.h:547
const char * Durable
Definition: nats.h:546
const char * SampleFrequency
Definition: nats.h:559
bool FlowControl
Definition: nats.h:562
int64_t AckWait
Definition: nats.h:554
int64_t OptStartTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:552
int64_t MaxWaiting
Definition: nats.h:560
jsAckPolicy AckPolicy
Definition: nats.h:553
const char * DeliverSubject
Definition: nats.h:548
int64_t Heartbeat
Heartbeat interval expressed in number of nanoseconds.
Definition: nats.h:563
int64_t MaxDeliver
Definition: nats.h:555
jsReplayPolicy ReplayPolicy
Definition: nats.h:557
const char * DeliverGroup
Definition: nats.h:549
int64_t MaxAckPending
Definition: nats.h:561
const char * FilterSubject
Definition: nats.h:556
jsSequenceInfo Delivered
Definition: nats.h:691
jsConsumerConfig * Config
Definition: nats.h:690
bool PushBound
Definition: nats.h:698
int64_t NumWaiting
Definition: nats.h:695
int64_t Created
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:689
jsClusterInfo * Cluster
Definition: nats.h:697
int64_t NumAckPending
Definition: nats.h:693
char * Stream
Definition: nats.h:687
int64_t NumRedelivered
Definition: nats.h:694
char * Name
Definition: nats.h:688
jsSequenceInfo AckFloor
Definition: nats.h:692
uint64_t NumPending
Definition: nats.h:696
uint64_t Stream
This is the stream sequence that the application should resume from.
Definition: nats.h:586
uint64_t ConsumerServer
This is the consumer sequence last sent by the server.
Definition: nats.h:588
uint64_t ConsumerClient
This is the consumer sequence that was last received by the library.
Definition: nats.h:587
const char * DeliverPrefix
Definition: nats.h:304
const char * APIPrefix
Definition: nats.h:303
uint64_t * Msgs
Definition: nats.h:429
uint64_t Bytes
Definition: nats.h:431
int MsgsLen
Definition: nats.h:430
jsPubAckErrHandler ErrHandler
Callback invoked when error encountered publishing a given message.
Definition: nats.h:792
void * ErrHandlerClosure
Closure (or user data) passed to jsPubAckErrHandler callback.
Definition: nats.h:793
int64_t StallWait
Amount of time (in milliseconds) to wait in a PublishAsync call when there is MaxPending inflight mes...
Definition: nats.h:794
int64_t MaxPending
Maximum outstanding asynchronous publishes that can be inflight at one time.
Definition: nats.h:791
bool DeletedDetails
Get the list of deleted message sequences.
Definition: nats.h:828
uint64_t Sequence
Purge up to but not including sequence.
Definition: nats.h:818
uint64_t Keep
Number of messages to keep.
Definition: nats.h:819
const char * Subject
This is the subject to match against messages for the purge command.
Definition: nats.h:817
jsPubAckErrHandler ErrHandler
Callback invoked when error encountered publishing a given message.
Definition: nats.h:805
void * ErrHandlerClosure
Closure (or user data) passed to jsPubAckErrHandler callback.
Definition: nats.h:806
int64_t StallWait
Amount of time (in milliseconds) to wait in a PublishAsync call when there is MaxPending inflight mes...
Definition: nats.h:807
int64_t MaxPending
Maximum outstanding asynchronous publishes that can be inflight at one time.
Definition: nats.h:804
bool DeletedDetails
Get the list of deleted message sequences.
Definition: nats.h:841
uint64_t Sequence
Purge up to but not including sequence.
Definition: nats.h:831
uint64_t Keep
Number of messages to keep.
Definition: nats.h:832
const char * Subject
This is the subject to match against messages for the purge command.
Definition: nats.h:830
struct jsOptions::jsOptionsStream::jsOptionsStreamInfo Info
Optional stream information retrieval options.
struct jsOptions::jsOptionsStream::jsOptionsStreamPurge Purge
Optional stream purge options.
struct jsOptions::jsOptionsPublishAsync PublishAsync
int64_t Wait
Amount of time (in milliseconds) to wait for various JetStream API requests, default is 5000 ms (5 se...
Definition: nats.h:784
const char * Prefix
JetStream prefix, default is "$JS.API".
Definition: nats.h:782
const char * Domain
Domain changes the domain part of JetSteam API prefix.
Definition: nats.h:783
int64_t Wait
Amount of time (in milliseconds) to wait for various JetStream API requests, default is 5000 ms (5 se...
Definition: nats.h:797
const char * Prefix
JetStream prefix, default is "$JS.API".
Definition: nats.h:795
const char * Domain
Domain changes the domain part of JetSteam API prefix.
Definition: nats.h:796
struct jsOptions::jsOptionsStream Stream
Optional stream options.
bool Offline
Definition: nats.h:465
int TagsLen
Definition: nats.h:288
const char * Cluster
Definition: nats.h:286
const char ** Tags
Definition: nats.h:287
natsMsg * Msg
Definition: nats.h:763
natsStatus Err
Definition: nats.h:764
jsErrCode ErrCode
Definition: nats.h:765
const char * ErrText
Definition: nats.h:766
uint64_t Sequence
Definition: nats.h:752
bool Duplicate
Definition: nats.h:753
char * Stream
Definition: nats.h:751
natsMsg * Msg
Definition: nats.h:776
natsStatus Err
Definition: nats.h:777
jsErrCode ErrCode
Definition: nats.h:778
const char * ErrText
Definition: nats.h:779
uint64_t Sequence
Definition: nats.h:764
bool Duplicate
Definition: nats.h:766
char * Domain
Definition: nats.h:765
char * Stream
Definition: nats.h:763
const char * ExpectLastMsgId
Expected last message ID in the stream.
Definition: nats.h:199
int64_t MaxWait
Amount of time (in milliseconds) to wait for a publish response, default will the context's Wait valu...
Definition: nats.h:196
const char * ExpectStream
Expected stream to respond from the publish call.
Definition: nats.h:198
const char * MsgId
Message ID used for de-duplication.
Definition: nats.h:197
uint64_t ExpectLastSubjectSeq
Expected last message sequence for the subject in the stream.
Definition: nats.h:201
uint64_t Consumer
Definition: nats.h:664
uint64_t Stream
Definition: nats.h:665
int64_t Last
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:675
uint64_t Stream
Definition: nats.h:674
uint64_t Consumer
Definition: nats.h:673
uint64_t Consumer
Definition: nats.h:663
uint64_t Stream
Definition: nats.h:664
jsDiscardPolicy Discard
Definition: nats.h:411
const char ** Subjects
Definition: nats.h:402
uint64_t NumDeleted
Definition: nats.h:449
uint64_t Bytes
Definition: nats.h:444
int64_t FirstTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:446
bool ManualAck
If true, the user will have to acknowledge the messages.
Definition: nats.h:650
const char * Consumer
If specified, the subscription will be bound to an existing consumer from the Stream without attempti...
Definition: nats.h:626
const char * Stream
If specified, the consumer will be bound to this stream name.
Definition: nats.h:616
const char * Queue
Queue name for queue subscriptions.
Definition: nats.h:637
jsConsumerConfig Config
Consumer configuration.
Definition: nats.h:655
bool ManualAck
If true, the user will have to acknowledge the messages.
Definition: nats.h:649
const char * Consumer
If specified, the subscription will be bound to an existing consumer from the Stream without attempti...
Definition: nats.h:625
const char * Stream
If specified, the consumer will be bound to this stream name.
Definition: nats.h:615
const char * Queue
Queue name for queue subscriptions.
Definition: nats.h:636
jsConsumerConfig Config
Consumer configuration.
Definition: nats.h:654
A list of NATS messages.
Definition: nats.h:163
const int Count
Definition: nats.h:165
natsMsg ** Msgs
Definition: nats.h:164