@@ -164,2136 +164,2159 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
240 typedef struct __jsCtx
jsCtx;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
262 typedef struct __jsCtx
jsCtx;
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
1149 #ifndef BUILD_IN_DOXYGEN
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
1171 #ifndef BUILD_IN_DOXYGEN
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
1266 typedef struct __kvStore
kvStore;
-
-
1271 typedef struct __kvEntry
kvEntry;
-
-
1276 typedef struct __kvStatus
kvStatus;
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
+
+
+
1288 typedef struct __kvStore
kvStore;
+
+
1293 typedef struct __kvEntry
kvEntry;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
1298 typedef struct __kvStatus
kvStatus;
+
+
+
+
+
+
+
+
+
-
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
+
+
+
+
+
+
-
-
-
1401 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
1418 typedef struct __stanMsg
stanMsg;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
1568 char **customErrTxt,
-
-
-
-
-
1598 char **customErrTxt,
-
1599 unsigned char **signature,
-
1600 int *signatureLength,
-
-
-
-
1612 typedef const char* (*natsTokenHandler)(
void *closure);
-
-
-
-
-
+
+
+
+
+
+
+
+
1423 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
1440 typedef struct __stanMsg
stanMsg;
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
1590 char **customErrTxt,
+
+
+
+
+
1620 char **customErrTxt,
+
1621 unsigned char **signature,
+
1622 int *signatureLength,
+
+
+
+
1634 typedef const char* (*natsTokenHandler)(
void *closure);
+
+
+
-
1646 #ifdef BUILD_IN_DOXYGEN
-
-
-
-
-
-
1726 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
1810 #ifdef BUILD_IN_DOXYGEN
-
-
-
-
1828 #define nats_CheckCompatibility() nats_CheckCompatibilityImpl(NATS_VERSION_REQUIRED_NUMBER, \
-
1829 NATS_VERSION_NUMBER, \
-
1830 NATS_VERSION_STRING)
+
+
+
1668 #ifdef BUILD_IN_DOXYGEN
+
+
+
+
+
+
1748 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
1833 nats_CheckCompatibilityImpl(uint32_t reqVerNumber, uint32_t verNumber,
const char *verString);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
1983 unsigned char **signature,
-
1984 int *signatureLength);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
2117 uint64_t *inMsgs, uint64_t *inBytes,
-
2118 uint64_t *outMsgs, uint64_t *outBytes,
-
2119 uint64_t *reconnects);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
2390 const char *certsFileName,
-
2391 const char *keyFileName);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
1849 #ifdef BUILD_IN_DOXYGEN
+
+
+
+
1867 #define nats_CheckCompatibility() nats_CheckCompatibilityImpl(NATS_VERSION_REQUIRED_NUMBER, \
+
1868 NATS_VERSION_NUMBER, \
+
1869 NATS_VERSION_STRING)
+
+
+
1872 nats_CheckCompatibilityImpl(uint32_t reqVerNumber, uint32_t verNumber,
const char *verString);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
2022 unsigned char **signature,
+
2023 int *signatureLength);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
2156 uint64_t *inMsgs, uint64_t *inBytes,
+
2157 uint64_t *outMsgs, uint64_t *outBytes,
+
2158 uint64_t *reconnects);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
2446 const char *certsFileName,
+
2447 const char *keyFileName);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
3088 const char *userOrChainedFile,
-
3089 const char *seedFile);
-
-
-
-
3105 const char *jwtAndSeedContent);
-
-
-
-
-
-
-
-
-
-
-
3163 const char *seedFile);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
3264 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
3696 const char *data,
int dataLen);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
3928 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
3144 const char *userOrChainedFile,
+
3145 const char *seedFile);
+
+
+
+
3161 const char *jwtAndSeedContent);
+
+
+
+
+
+
+
+
+
+
+
3219 const char *seedFile);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
3320 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
3752 const char *data,
int dataLen);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
3984 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
4360 const unsigned char *message,
int messageLen,
-
4361 unsigned char sig[64]);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
4416 const unsigned char *message,
int messageLen,
+
4417 unsigned char sig[64]);
+
+
+
+
+
+
-
-
-
4471 const void *data,
int dataLen);
-
-
-
-
-
-
-
-
-
-
-
4518 const char *reply,
const void *data,
int dataLen);
-
-
-
-
4538 const char *reply,
const char *str);
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
4527 const void *data,
int dataLen);
+
+
+
+
+
-
-
4559 const void *data,
int dataLen, int64_t timeout);
-
-
-
-
4584 const char *subj,
const char *str,
-
-
-
-
-
4603 natsMsg *requestMsg, int64_t timeout);
-
-
-
-
-
-
-
-
-
-
4664 const char *subject, int64_t timeout,
-
-
-
-
-
4679 const char *subject);
-
-
-
-
4700 const char *subject,
const char *queueGroup,
-
-
-
-
-
4737 const char *subject,
const char *queueGroup,
-
-
-
-
-
4753 const char *subject,
const char *queueGroup);
-
-
+
+
+
+
+
4574 const char *reply,
const void *data,
int dataLen);
+
+
+
+
4594 const char *reply,
const char *str);
+
+
+
+
4615 const void *data,
int dataLen, int64_t timeout);
+
+
+
+
4640 const char *subj,
const char *str,
+
+
+
+
+
4659 natsMsg *requestMsg, int64_t timeout);
+
+
+
+
+
+
+
+
+
+
4720 const char *subject, int64_t timeout,
+
+
+
+
+
4735 const char *subject);
+
+
+
+
4756 const char *subject,
const char *queueGroup,
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
5012 int *maxPendingMsgs,
-
5013 int *maxPendingBytes,
-
5014 int64_t *deliveredMsgs,
-
5015 int64_t *droppedMsgs);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
5197 #if defined(NATS_HAS_STREAMING)
+
+
+
4793 const char *subject,
const char *queueGroup,
+
+
+
+
+
4809 const char *subject,
const char *queueGroup);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
5068 int *maxPendingMsgs,
+
5069 int *maxPendingBytes,
+
5070 int64_t *deliveredMsgs,
+
5071 int64_t *droppedMsgs);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
5337 const void *data,
int dataLen);
-
-
-
-
5364 const void *data,
int dataLen,
-
-
-
+
+
+
+
+
+
+
5253 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
5417 const char *channel,
const char *queueGroup,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
5972 const char *stream,
const char *consumer,
-
-
-
-
-
-
-
-
-
6006 const char *stream,
const char *consumer,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
5393 const void *data,
int dataLen);
+
+
+
+
5420 const void *data,
int dataLen,
+
+
+
+
+
+
+
+
+
+
+
5473 const char *channel,
const char *queueGroup,
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
6028 const char *stream,
const char *consumer,
+
+
+
+
+
+
+
+
+
6062 const char *stream,
const char *consumer,
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
-
+
-
+
-
+
-
-
-
-
-
7852 #define MICRO_API_PREFIX "$SRV"
+
+
+
+
+
+
+
+
-
7857 #define MICRO_INFO_RESPONSE_TYPE "io.nats.micro.v1.info_response"
-
-
7862 #define MICRO_INFO_VERB "INFO"
+
+
+
-
7867 #define MICRO_PING_RESPONSE_TYPE "io.nats.micro.v1.ping_response"
+
-
7872 #define MICRO_PING_VERB "PING"
+
-
7877 #define MICRO_STATS_RESPONSE_TYPE "io.nats.micro.v1.stats_response"
+
-
7882 #define MICRO_STATS_VERB "STATS"
+
-
7888 #define MICRO_STATUS_HDR "Nats-Status"
-
-
7894 #define MICRO_ERROR_HDR "Nats-Service-Error"
-
-
7900 #define MICRO_ERROR_CODE_HDR "Nats-Service-Error-Code"
-
-
-
-
-
-
-
+
+
+
+
+
+
+
7908 #define MICRO_API_PREFIX "$SRV"
+
+
7913 #define MICRO_INFO_RESPONSE_TYPE "io.nats.micro.v1.info_response"
+
+
7918 #define MICRO_INFO_VERB "INFO"
+
+
7923 #define MICRO_PING_RESPONSE_TYPE "io.nats.micro.v1.ping_response"
+
+
7928 #define MICRO_PING_VERB "PING"
+
+
7933 #define MICRO_STATS_RESPONSE_TYPE "io.nats.micro.v1.stats_response"
+
+
7938 #define MICRO_STATS_VERB "STATS"
+
+
7944 #define MICRO_STATUS_HDR "Nats-Status"
+
+
7950 #define MICRO_ERROR_HDR "Nats-Service-Error"
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
7956 #define MICRO_ERROR_CODE_HDR "Nats-Service-Error-Code"
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
8460 #define microError_Ignore(__err) microError_Destroy(__err)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
8516 #define microError_Ignore(__err) microError_Destroy(__err)
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
void(* natsOnCompleteCB)(void *closure)
Callback used to notify that an object lifecycle is complete.
Definition: nats.h:1622
-
natsStatus(* natsEvLoop_Attach)(void **userData, void *loop, natsConnection *nc, natsSock socket)
Attach this connection to the external event loop.
Definition: nats.h:1503
-
natsStatus(* natsUserJWTHandler)(char **userJWT, char **customErrTxt, void *closure)
Callback used to fetch and return account signed user JWT.
Definition: nats.h:1566
-
natsStatus(* natsEvLoop_WriteAddRemove)(void *userData, bool add)
Write event needs to be added or removed.
Definition: nats.h:1531
-
int64_t(* natsCustomReconnectDelayHandler)(natsConnection *nc, int attempts, void *closure)
Callback used to specify how long to wait between reconnects.
Definition: nats.h:1644
-
void(* jsPubAckHandler)(jsCtx *js, natsMsg *msg, jsPubAck *pa, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish responses from JetStream.
Definition: nats.h:1723
-
const char *(* natsTokenHandler)(void *closure)
Callback used to build a token on connections and reconnections.
Definition: nats.h:1612
-
void(* jsPubAckErrHandler)(jsCtx *js, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish errors from JetStream.
Definition: nats.h:1680
-
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:1486
-
natsStatus(* natsEvLoop_Detach)(void *userData)
Detach from the event loop.
Definition: nats.h:1542
-
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:1597
-
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:1755
-
void(* natsConnectionHandler)(natsConnection *nc, void *closure)
Callback used to notify the user of asynchronous connection events.
Definition: nats.h:1477
-
void(* natsMsgHandler)(natsConnection *nc, natsSubscription *sub, natsMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1461
-
void(* stanPubAckHandler)(const char *guid, const char *error, void *closure)
Callback used to notify of an asynchronous publish result.
Definition: nats.h:1735
-
natsStatus(* natsEvLoop_ReadAddRemove)(void *userData, bool add)
Read event needs to be added or removed.
Definition: nats.h:1518
-
void(* stanMsgHandler)(stanConnection *sc, stanSubscription *sub, const char *channel, stanMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1746
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
void(* natsOnCompleteCB)(void *closure)
Callback used to notify that an object lifecycle is complete.
Definition: nats.h:1644
+
natsStatus(* natsEvLoop_Attach)(void **userData, void *loop, natsConnection *nc, natsSock socket)
Attach this connection to the external event loop.
Definition: nats.h:1525
+
natsStatus(* natsUserJWTHandler)(char **userJWT, char **customErrTxt, void *closure)
Callback used to fetch and return account signed user JWT.
Definition: nats.h:1588
+
natsStatus(* natsEvLoop_WriteAddRemove)(void *userData, bool add)
Write event needs to be added or removed.
Definition: nats.h:1553
+
int64_t(* natsCustomReconnectDelayHandler)(natsConnection *nc, int attempts, void *closure)
Callback used to specify how long to wait between reconnects.
Definition: nats.h:1666
+
void(* jsPubAckHandler)(jsCtx *js, natsMsg *msg, jsPubAck *pa, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish responses from JetStream.
Definition: nats.h:1745
+
const char *(* natsTokenHandler)(void *closure)
Callback used to build a token on connections and reconnections.
Definition: nats.h:1634
+
void(* jsPubAckErrHandler)(jsCtx *js, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish errors from JetStream.
Definition: nats.h:1702
+
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:1508
+
natsStatus(* natsEvLoop_Detach)(void *userData)
Detach from the event loop.
Definition: nats.h:1564
+
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:1619
+
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:1777
+
void(* natsConnectionHandler)(natsConnection *nc, void *closure)
Callback used to notify the user of asynchronous connection events.
Definition: nats.h:1499
+
void(* natsMsgHandler)(natsConnection *nc, natsSubscription *sub, natsMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1483
+
void(* stanPubAckHandler)(const char *guid, const char *error, void *closure)
Callback used to notify of an asynchronous publish result.
Definition: nats.h:1757
+
natsStatus(* natsEvLoop_ReadAddRemove)(void *userData, bool add)
Read event needs to be added or removed.
Definition: nats.h:1540
+
void(* stanMsgHandler)(stanConnection *sc, stanSubscription *sub, const char *channel, stanMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1768
NATS_EXTERN int natsConnection_Buffered(natsConnection *nc)
Returns the number of bytes to be sent to the server.
NATS_EXTERN void natsConnection_Close(natsConnection *nc)
Closes the connection.
NATS_EXTERN natsStatus natsConnection_Flush(natsConnection *nc)
Flushes the connection.
@@ -2460,6 +2483,7 @@
NATS_EXTERN bool nats_CheckCompatibility(void)
Check that the header is compatible with the library.
NATS_EXTERN int64_t nats_Now(void)
Gives the current time in milliseconds.
NATS_EXTERN natsStatus nats_SetMessageDeliveryPoolSize(int max)
Sets the maximum size of the global message delivery thread pool.
+
natsStatus nats_OpenWithConfig(natsClientConfig *config)
Initializes the library.
NATS_EXTERN natsStatus nats_GetLastErrorStack(char *buffer, size_t bufLen)
Returns the calling thread's last known error stack.
NATS_EXTERN int64_t nats_NowInNanoSeconds(void)
Gives the current time in nanoseconds.
NATS_EXTERN void nats_Sleep(int64_t sleepTime)
Sleeps for a given number of milliseconds.
@@ -2468,9 +2492,9 @@
NATS_EXTERN natsStatus nats_Sign(const char *encodedSeed, const char *input, unsigned char **signature, int *signatureLength)
Signs a given text using the provided private key.
NATS_EXTERN const char * nats_GetVersion(void)
Returns the Library's version.
NATS_EXTERN void nats_ReleaseThreadMemory(void)
Release thread-local memory possibly allocated by the library.
-
void(* microErrorHandler)(microService *m, microEndpoint *ep, natsStatus s)
Callback type for async error notifications.
Definition: nats.h:7546
-
microError *(* microRequestHandler)(microRequest *req)
Callback type for request processing.
Definition: nats.h:7522
-
void(* microDoneHandler)(microService *m)
Callback type for Done (service stopped) notifications.
Definition: nats.h:7559
+
void(* microErrorHandler)(microService *m, microEndpoint *ep, natsStatus s)
Callback type for async error notifications.
Definition: nats.h:7602
+
microError *(* microRequestHandler)(microRequest *req)
Callback type for request processing.
Definition: nats.h:7578
+
void(* microDoneHandler)(microService *m)
Callback type for Done (service stopped) notifications.
Definition: nats.h:7615
NATS_EXTERN void microServiceInfo_Destroy(microServiceInfo *info)
Destroys a microServiceInfo object.
NATS_EXTERN void microServiceStats_Destroy(microServiceStats *stats)
Destroys a microServiceStats object.
NATS_EXTERN microError * micro_NewClient(microClient **new_client, natsConnection *nc, microClientConfig *cfg)
Creates a new microservice client.
@@ -2515,15 +2539,15 @@
NATS_EXTERN bool microService_IsStopped(microService *m)
Checks if the service is stopped.
NATS_EXTERN microError * microService_Destroy(microService *m)
Destroys a microservice, stopping it first if needed.
NATS_EXTERN microError * microService_GetStats(microServiceStats **new_stats, microService *m)
Returns run-time statistics for a microservice.
-
struct micro_client_s microClient
The Microservice client.
Definition: nats.h:7377
-
struct micro_group_s microGroup
a collection of endpoints and other groups, with a common prefix to their subjects and names.
Definition: nats.h:7446
-
struct micro_request_s microRequest
a request received by a microservice endpoint.
Definition: nats.h:7453
-
struct micro_error_s microError
the Microservice error object.
Definition: nats.h:7437
-
struct __for_forward_compatibility_only microClientConfig
The Microservice configuration object. For forward compatibility only.
Definition: nats.h:7382
+
struct micro_client_s microClient
The Microservice client.
Definition: nats.h:7433
+
struct micro_group_s microGroup
a collection of endpoints and other groups, with a common prefix to their subjects and names.
Definition: nats.h:7502
+
struct micro_request_s microRequest
a request received by a microservice endpoint.
Definition: nats.h:7509
+
struct micro_error_s microError
the Microservice error object.
Definition: nats.h:7493
+
struct __for_forward_compatibility_only microClientConfig
The Microservice configuration object. For forward compatibility only.
Definition: nats.h:7438
NATS_EXTERN microError * micro_ErrorInvalidArg
NATS_EXTERN microError * micro_ErrorOutOfMemory
-
struct micro_endpoint_s microEndpoint
microEndpoint represents a microservice endpoint.
Definition: nats.h:7393
-
struct micro_service_s microService
the main object for a configured microservice.
Definition: nats.h:7466
+
struct micro_endpoint_s microEndpoint
microEndpoint represents a microservice endpoint.
Definition: nats.h:7449
+
struct micro_service_s microService
the main object for a configured microservice.
Definition: nats.h:7522
NATS_EXTERN natsStatus natsMsg_Create(natsMsg **newMsg, const char *subj, const char *reply, const char *data, int dataLen)
Creates a natsMsg object.
NATS_EXTERN void natsMsgList_Destroy(natsMsgList *list)
Destroys this list of messages.
NATS_EXTERN int natsMsg_GetDataLength(const natsMsg *msg)
Returns the message length.
@@ -2587,6 +2611,7 @@
NATS_EXTERN natsStatus natsOptions_SetDiscoveredServersCB(natsOptions *opts, natsConnectionHandler discoveredServersCb, void *closure)
Sets the callback to be invoked when new servers are discovered.
NATS_EXTERN natsStatus natsOptions_UseGlobalMessageDelivery(natsOptions *opts, bool global)
Switch on/off the use of a central message delivery thread pool.
NATS_EXTERN natsStatus natsOptions_SetCustomInboxPrefix(natsOptions *opts, const char *inboxPrefix)
Sets a custom inbox prefix.
+
NATS_EXTERN natsStatus natsOptions_TLSHandshakeFirst(natsOptions *opts)
Performs TLS handshake first.
NATS_EXTERN natsStatus natsOptions_SetServers(natsOptions *opts, const char **servers, int serversCount)
Set the list of servers to try to (re)connect to.
NATS_EXTERN natsStatus natsOptions_SetToken(natsOptions *opts, const char *token)
Sets the token to use when not specified in the URL.
NATS_EXTERN natsStatus natsOptions_SetDisconnectedCB(natsOptions *opts, natsConnectionHandler disconnectedCb, void *closure)
Sets the callback to be invoked when the connection to a server is lost.
@@ -2662,14 +2687,14 @@
NATS_EXTERN natsStatus natsSubscription_Unsubscribe(natsSubscription *sub)
Unsubscribes.
NATS_EXTERN natsStatus natsSubscription_ClearMaxPending(natsSubscription *sub)
Clears the statistics regarding the maximum pending values.
struct kvEntryList kvEntryList
A list of KeyValue store entries.
-
struct __stanSubOptions stanSubOptions
Way to configure a stanSubscription.
Definition: nats.h:1430
+
struct __stanSubOptions stanSubOptions
Way to configure a stanSubscription.
Definition: nats.h:1452
struct jsConsumerConfig jsConsumerConfig
-
struct __kvStore kvStore
Definition: nats.h:1266
+
struct __kvStore kvStore
Definition: nats.h:1288
struct jsOptions jsOptions
-
jsStorageCompression
Definition: nats.h:304
-
jsDeliverPolicy
Definition: nats.h:313
-
struct __stanConnOptions stanConnOptions
Way to configure a stanConnection.
Definition: nats.h:1424
-
jsStorageType
Definition: nats.h:294
+
jsStorageCompression
Definition: nats.h:326
+
jsDeliverPolicy
Definition: nats.h:335
+
struct __stanConnOptions stanConnOptions
Way to configure a stanConnection.
Definition: nats.h:1446
+
jsStorageType
Definition: nats.h:316
struct jsStreamInfoList jsStreamInfoList
struct jsPeerInfo jsPeerInfo
@@ -2679,28 +2704,28 @@
struct jsStreamConfig jsStreamConfig
struct jsSequenceInfo jsSequenceInfo
struct jsStreamState jsStreamState
-
struct __stanMsg stanMsg
The Streaming message.
Definition: nats.h:1418
+
struct __stanMsg stanMsg
The Streaming message.
Definition: nats.h:1440
struct jsConsumerInfo jsConsumerInfo
struct jsSequencePair jsSequencePair
struct natsMetadata natsMetadata
A type to represent user-provided metadata, a list of k=v pairs.
-
jsRetentionPolicy
Definition: nats.h:273
+
jsRetentionPolicy
Definition: nats.h:295
struct jsPlacement jsPlacement
-
struct __kvWatcher kvWatcher
Definition: nats.h:1281
+
struct __kvWatcher kvWatcher
Definition: nats.h:1303
struct jsStreamStateSubject jsStreamStateSubject
struct __natsStatistics natsStatistics
Statistics of a natsConnection.
Definition: nats.h:159
struct jsAccountInfo jsAccountInfo
struct jsPubOptions jsPubOptions
-
jsDiscardPolicy
Definition: nats.h:284
+
jsDiscardPolicy
Definition: nats.h:306
struct jsDirectGetMsgOptions jsDirectGetMsgOptions
-
jsReplayPolicy
Definition: nats.h:339
+
jsReplayPolicy
Definition: nats.h:361
struct __natsSubscription natsSubscription
Interest on a given subject.
Definition: nats.h:165
-
kvOperation
Definition: nats.h:1287
-
jsAckPolicy
Definition: nats.h:327
+
kvOperation
Definition: nats.h:1309
+
jsAckPolicy
Definition: nats.h:349
struct kvPurgeOptions kvPurgeOptions
-
struct __stanConnection stanConnection
A connection to a NATS Streaming Server.
Definition: nats.h:1406
+
struct __stanConnection stanConnection
A connection to a NATS Streaming Server.
Definition: nats.h:1428
struct jsAccountLimits jsAccountLimits
-
struct __jsCtx jsCtx
Definition: nats.h:240
+
struct __jsCtx jsCtx
Definition: nats.h:262
struct jsClusterInfo jsClusterInfo
struct jsStreamSourceInfo jsStreamSourceInfo
struct kvKeysList kvKeysList
A list of KeyValue store keys.
@@ -2714,14 +2739,15 @@
struct jsMsgMetaData jsMsgMetaData
struct jsConsumerNamesList jsConsumerNamesList
struct jsAPIStats jsAPIStats
+
struct __natsClientConfig natsClientConfig
An initial configuration for NATS client. Provides control over the threading model,...
struct jsConsumerPauseResponse jsConsumerPauseResponse
-
struct __kvStatus kvStatus
Definition: nats.h:1276
-
struct __kvEntry kvEntry
Definition: nats.h:1271
+
struct __kvStatus kvStatus
Definition: nats.h:1298
+
struct __kvEntry kvEntry
Definition: nats.h:1293
struct jsConsumerInfoList jsConsumerInfoList
struct jsStreamConsumerLimits jsStreamConsumerLimits
struct jsPubAckErr jsPubAckErr
struct __natsMsg natsMsg
A structure holding a subject, optional reply and payload.
Definition: nats.h:172
-
struct __stanSubscription stanSubscription
Interest on a given channel.
Definition: nats.h:1412
+
struct __stanSubscription stanSubscription
Interest on a given channel.
Definition: nats.h:1434
struct jsStreamStateSubjects jsStreamStateSubjects
struct jsExternalStream jsExternalStream
struct jsFetchRequest jsFetchRequest
@@ -2730,401 +2756,409 @@
struct jsLostStreamData jsLostStreamData
struct __natsConnection natsConnection
A connection to a NATS Server.
Definition: nats.h:152
struct natsMsgList natsMsgList
A list of NATS messages.
-
@ js_StorageCompressionNone
Specifies no compression. It's the default.
Definition: nats.h:305
-
@ js_StorageCompressionS2
Specifies S2.
Definition: nats.h:306
-
@ js_DeliverByStartSequence
Starts from a given sequence.
Definition: nats.h:317
-
@ js_DeliverByStartTime
Starts from a given UTC time (number of nanoseconds since epoch)
Definition: nats.h:318
-
@ js_DeliverNew
Starts with messages sent after the consumer is created.
Definition: nats.h:316
-
@ js_DeliverLastPerSubject
Starts with the last message for all subjects received.
Definition: nats.h:319
-
@ js_DeliverLast
Starts with the last sequence received.
Definition: nats.h:315
-
@ js_DeliverAll
Starts from the very beginning of a stream. This is the default.
Definition: nats.h:314
-
@ js_FileStorage
Specifies on disk storage. It's the default.
Definition: nats.h:295
-
@ js_MemoryStorage
Specifies in memory only.
Definition: nats.h:296
-
@ js_LimitsPolicy
Specifies that messages are retained until any given limit is reached, which could be one of MaxMsgs,...
Definition: nats.h:274
-
@ js_InterestPolicy
Specifies that when all known observables have acknowledged a message it can be removed.
Definition: nats.h:275
-
@ js_WorkQueuePolicy
Specifies that when the first worker or subscriber acknowledges the message it can be removed.
Definition: nats.h:276
-
@ js_DiscardNew
Will fail to store new messages.
Definition: nats.h:286
-
@ js_DiscardOld
Will remove older messages to return to the limits. This is the default.
Definition: nats.h:285
-
@ js_ReplayInstant
Replays messages as fast as possible.
Definition: nats.h:340
-
@ js_ReplayOriginal
Maintains the same timing as the messages were received.
Definition: nats.h:341
-
@ kvOp_Unknown
Definition: nats.h:1288
-
@ kvOp_Delete
Definition: nats.h:1290
-
@ kvOp_Put
Definition: nats.h:1289
-
@ kvOp_Purge
Definition: nats.h:1291
-
@ js_AckExplicit
Requires ack or nack for all messages.
Definition: nats.h:328
-
@ js_AckAll
When acking a sequence number, this implicitly acks all sequences below this one as well.
Definition: nats.h:330
-
@ js_AckNone
Requires no acks for delivered messages.
Definition: nats.h:329
+
@ js_StorageCompressionNone
Specifies no compression. It's the default.
Definition: nats.h:327
+
@ js_StorageCompressionS2
Specifies S2.
Definition: nats.h:328
+
@ js_DeliverByStartSequence
Starts from a given sequence.
Definition: nats.h:339
+
@ js_DeliverByStartTime
Starts from a given UTC time (number of nanoseconds since epoch)
Definition: nats.h:340
+
@ js_DeliverNew
Starts with messages sent after the consumer is created.
Definition: nats.h:338
+
@ js_DeliverLastPerSubject
Starts with the last message for all subjects received.
Definition: nats.h:341
+
@ js_DeliverLast
Starts with the last sequence received.
Definition: nats.h:337
+
@ js_DeliverAll
Starts from the very beginning of a stream. This is the default.
Definition: nats.h:336
+
@ js_FileStorage
Specifies on disk storage. It's the default.
Definition: nats.h:317
+
@ js_MemoryStorage
Specifies in memory only.
Definition: nats.h:318
+
@ js_LimitsPolicy
Specifies that messages are retained until any given limit is reached, which could be one of MaxMsgs,...
Definition: nats.h:296
+
@ js_InterestPolicy
Specifies that when all known observables have acknowledged a message it can be removed.
Definition: nats.h:297
+
@ js_WorkQueuePolicy
Specifies that when the first worker or subscriber acknowledges the message it can be removed.
Definition: nats.h:298
+
@ js_DiscardNew
Will fail to store new messages.
Definition: nats.h:308
+
@ js_DiscardOld
Will remove older messages to return to the limits. This is the default.
Definition: nats.h:307
+
@ js_ReplayInstant
Replays messages as fast as possible.
Definition: nats.h:362
+
@ js_ReplayOriginal
Maintains the same timing as the messages were received.
Definition: nats.h:363
+
@ kvOp_Unknown
Definition: nats.h:1310
+
@ kvOp_Delete
Definition: nats.h:1312
+
@ kvOp_Put
Definition: nats.h:1311
+
@ kvOp_Purge
Definition: nats.h:1313
+
@ js_AckExplicit
Requires ack or nack for all messages.
Definition: nats.h:350
+
@ js_AckAll
When acking a sequence number, this implicitly acks all sequences below this one as well.
Definition: nats.h:352
+
@ js_AckNone
Requires no acks for delivered messages.
Definition: nats.h:351
#define NATS_EXTERN
Needed for shared library.
Definition: nats.h:49
int natsSock
Definition: nats.h:50
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:1056
-
uint64_t Errors
Definition: nats.h:1057
-
-
int64_t Consumers
Definition: nats.h:1096
-
int64_t Streams
Definition: nats.h:1095
-
int TiersLen
Definition: nats.h:1101
-
uint64_t Memory
Definition: nats.h:1093
-
jsAPIStats API
Definition: nats.h:1098
-
jsAccountLimits Limits
Definition: nats.h:1099
-
jsTier ** Tiers
Definition: nats.h:1100
-
char * Domain
Definition: nats.h:1097
-
uint64_t Store
Definition: nats.h:1094
-
-
int64_t MemoryMaxStreamBytes
Definition: nats.h:1071
-
int64_t MaxStreams
Definition: nats.h:1068
-
int64_t MaxAckPending
Definition: nats.h:1070
-
int64_t MaxConsumers
Definition: nats.h:1069
-
int64_t MaxStore
Definition: nats.h:1067
-
int64_t MaxMemory
Definition: nats.h:1066
-
bool MaxBytesRequired
Definition: nats.h:1073
-
int64_t StoreMaxStreamBytes
Definition: nats.h:1072
-
-
int ReplicasLen
Definition: nats.h:692
-
char * Name
Definition: nats.h:689
-
jsPeerInfo ** Replicas
Definition: nats.h:691
-
char * Leader
Definition: nats.h:690
-
-
bool MemoryStorage
Definition: nats.h:851
-
const char * Name
Definition: nats.h:815
-
int FilterSubjectsLen
Definition: nats.h:856
-
uint64_t OptStartSeq
Definition: nats.h:819
-
bool HeadersOnly
Definition: nats.h:834
-
uint64_t RateLimit
Definition: nats.h:828
-
jsDeliverPolicy DeliverPolicy
Definition: nats.h:818
-
const char * Description
Definition: nats.h:817
-
const char * Durable
Definition: nats.h:816
-
const char * SampleFrequency
Definition: nats.h:829
-
bool FlowControl
Definition: nats.h:832
-
int64_t MaxRequestBatch
Maximum Pull Consumer request batch size.
Definition: nats.h:837
-
int64_t AckWait
Definition: nats.h:822
-
int64_t MaxRequestMaxBytes
Maximum Pull Consumer request maximum bytes.
Definition: nats.h:839
-
int64_t OptStartTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:820
-
int64_t MaxWaiting
Definition: nats.h:830
-
jsAckPolicy AckPolicy
Definition: nats.h:821
-
natsMetadata Metadata
User-provided metadata for the consumer, encoded as an array of {"key", "value",.....
Definition: nats.h:857
-
const char * DeliverSubject
Definition: nats.h:842
-
int64_t * BackOff
Redelivery durations expressed in nanoseconds.
Definition: nats.h:824
-
int64_t MaxRequestExpires
Maximum Pull Consumer request expiration, expressed in number of nanoseconds.
Definition: nats.h:838
-
int64_t Heartbeat
Heartbeat interval expressed in number of nanoseconds.
Definition: nats.h:833
-
int64_t PauseUntil
Suspends the consumer until this deadline, represented as number of nanoseconds since epoch.
Definition: nats.h:861
-
int64_t Replicas
Definition: nats.h:849
-
int BackOffLen
Definition: nats.h:825
-
int64_t MaxDeliver
Definition: nats.h:823
-
const char ** FilterSubjects
Multiple filter subjects.
Definition: nats.h:855
-
jsReplayPolicy ReplayPolicy
Definition: nats.h:827
-
const char * DeliverGroup
Definition: nats.h:843
-
int64_t MaxAckPending
Definition: nats.h:831
-
const char * FilterSubject
Definition: nats.h:826
-
int64_t InactiveThreshold
How long the server keeps an ephemeral after detecting loss of interest, expressed in number of nanos...
Definition: nats.h:846
-
-
bool Paused
Definition: nats.h:1007
-
jsSequenceInfo Delivered
Definition: nats.h:999
-
jsConsumerConfig * Config
Definition: nats.h:998
-
bool PushBound
Definition: nats.h:1006
-
int64_t NumWaiting
Definition: nats.h:1003
-
int64_t Created
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:997
-
jsClusterInfo * Cluster
Definition: nats.h:1005
-
int64_t PauseRemaining
Remaining time in nanoseconds.
Definition: nats.h:1008
-
int64_t NumAckPending
Definition: nats.h:1001
-
char * Stream
Definition: nats.h:995
-
int64_t NumRedelivered
Definition: nats.h:1002
-
char * Name
Definition: nats.h:996
-
jsSequenceInfo AckFloor
Definition: nats.h:1000
-
uint64_t NumPending
Definition: nats.h:1004
-
-
jsConsumerInfo ** List
Definition: nats.h:1020
-
int Count
Definition: nats.h:1021
-
-
int Count
Definition: nats.h:1035
-
char ** List
Definition: nats.h:1034
-
-
int64_t PauseRemaining
Remaining time in nanoseconds.
Definition: nats.h:1048
-
bool Paused
Definition: nats.h:1046
-
int64_t PauseUntil
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:1047
-
-
uint64_t Stream
This is the stream sequence that the application should resume from.
Definition: nats.h:883
-
uint64_t ConsumerServer
This is the consumer sequence last sent by the server.
Definition: nats.h:885
-
uint64_t ConsumerClient
This is the consumer sequence that was last received by the library.
Definition: nats.h:884
-
-
const char * NextBySubject
Get the next message (based on sequence) for that subject.
Definition: nats.h:1167
-
uint64_t Sequence
Get the message at this sequence.
Definition: nats.h:1166
-
const char * LastBySubject
Get the last message on that subject.
Definition: nats.h:1168
-
-
const char * DeliverPrefix
Definition: nats.h:377
-
const char * APIPrefix
Definition: nats.h:376
-
-
int64_t MaxBytes
Maximum bytes for the request (request complete based on whichever Batch or MaxBytes comes first)
Definition: nats.h:1181
-
int Batch
Maximum number of messages to be received (see MaxBytes)
Definition: nats.h:1180
-
int64_t Expires
Expiration of the request, expressed in nanoseconds.
Definition: nats.h:1179
-
bool NoWait
Will not wait if the request cannot be completed.
Definition: nats.h:1182
-
int64_t Heartbeat
Have server sends heartbeats to help detect communication failures.
Definition: nats.h:1183
-
-
uint64_t * Msgs
Definition: nats.h:591
-
uint64_t Bytes
Definition: nats.h:593
-
int MsgsLen
Definition: nats.h:592
-
-
-
-
-
-
-
-
-
-
jsPubAckErrHandler ErrHandler
Callback invoked when error encountered publishing a given message.
Definition: nats.h:1217
-
jsPubAckHandler AckHandler
Callback invoked for each asynchronous published message.
Definition: nats.h:1210
-
void * AckHandlerClosure
Closure (or user data) passed to jsPubAckHandler callback.
Definition: nats.h:1211
-
void * ErrHandlerClosure
Closure (or user data) passed to jsPubAckErrHandler callback.
Definition: nats.h:1218
-
int64_t StallWait
Amount of time (in milliseconds) to wait in a PublishAsync call when there is MaxPending inflight mes...
Definition: nats.h:1220
-
int64_t MaxPending
Maximum outstanding asynchronous publishes that can be inflight at one time.
Definition: nats.h:1203
-
-
bool DeletedDetails
Get the list of deleted message sequences.
Definition: nats.h:1254
-
const char * SubjectsFilter
Get the list of subjects in this stream.
Definition: nats.h:1255
-
-
uint64_t Sequence
Purge up to but not including sequence.
Definition: nats.h:1244
-
uint64_t Keep
Number of messages to keep.
Definition: nats.h:1245
-
const char * Subject
This is the subject to match against messages for the purge command.
Definition: nats.h:1243
-
+
An initial configuration for NATS client. Provides control over the threading model,...
Definition: nats.h:196
+
bool DefaultRepliesToThreadPool
Definition: nats.h:206
+
bool UseSeparatePoolForReplies
Definition: nats.h:207
+
int ReplyThreadPoolMax
Definition: nats.h:208
+
int ThreadPoolMax
Definition: nats.h:203
+
int64_t DefaultWriteDeadline
Definition: nats.h:197
+
bool DefaultToThreadPool
Definition: nats.h:202
+
int64_t LockSpinCount
Definition: nats.h:199
+
+
uint64_t Total
Definition: nats.h:1078
+
uint64_t Errors
Definition: nats.h:1079
+
+
int64_t Consumers
Definition: nats.h:1118
+
int64_t Streams
Definition: nats.h:1117
+
int TiersLen
Definition: nats.h:1123
+
uint64_t Memory
Definition: nats.h:1115
+
jsAPIStats API
Definition: nats.h:1120
+
jsAccountLimits Limits
Definition: nats.h:1121
+
jsTier ** Tiers
Definition: nats.h:1122
+
char * Domain
Definition: nats.h:1119
+
uint64_t Store
Definition: nats.h:1116
+
+
int64_t MemoryMaxStreamBytes
Definition: nats.h:1093
+
int64_t MaxStreams
Definition: nats.h:1090
+
int64_t MaxAckPending
Definition: nats.h:1092
+
int64_t MaxConsumers
Definition: nats.h:1091
+
int64_t MaxStore
Definition: nats.h:1089
+
int64_t MaxMemory
Definition: nats.h:1088
+
bool MaxBytesRequired
Definition: nats.h:1095
+
int64_t StoreMaxStreamBytes
Definition: nats.h:1094
+
+
int ReplicasLen
Definition: nats.h:714
+
char * Name
Definition: nats.h:711
+
jsPeerInfo ** Replicas
Definition: nats.h:713
+
char * Leader
Definition: nats.h:712
+
+
bool MemoryStorage
Definition: nats.h:873
+
const char * Name
Definition: nats.h:837
+
int FilterSubjectsLen
Definition: nats.h:878
+
uint64_t OptStartSeq
Definition: nats.h:841
+
bool HeadersOnly
Definition: nats.h:856
+
uint64_t RateLimit
Definition: nats.h:850
+
jsDeliverPolicy DeliverPolicy
Definition: nats.h:840
+
const char * Description
Definition: nats.h:839
+
const char * Durable
Definition: nats.h:838
+
const char * SampleFrequency
Definition: nats.h:851
+
bool FlowControl
Definition: nats.h:854
+
int64_t MaxRequestBatch
Maximum Pull Consumer request batch size.
Definition: nats.h:859
+
int64_t AckWait
Definition: nats.h:844
+
int64_t MaxRequestMaxBytes
Maximum Pull Consumer request maximum bytes.
Definition: nats.h:861
+
int64_t OptStartTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:842
+
int64_t MaxWaiting
Definition: nats.h:852
+
jsAckPolicy AckPolicy
Definition: nats.h:843
+
natsMetadata Metadata
User-provided metadata for the consumer, encoded as an array of {"key", "value",.....
Definition: nats.h:879
+
const char * DeliverSubject
Definition: nats.h:864
+
int64_t * BackOff
Redelivery durations expressed in nanoseconds.
Definition: nats.h:846
+
int64_t MaxRequestExpires
Maximum Pull Consumer request expiration, expressed in number of nanoseconds.
Definition: nats.h:860
+
int64_t Heartbeat
Heartbeat interval expressed in number of nanoseconds.
Definition: nats.h:855
+
int64_t PauseUntil
Suspends the consumer until this deadline, represented as number of nanoseconds since epoch.
Definition: nats.h:883
+
int64_t Replicas
Definition: nats.h:871
+
int BackOffLen
Definition: nats.h:847
+
int64_t MaxDeliver
Definition: nats.h:845
+
const char ** FilterSubjects
Multiple filter subjects.
Definition: nats.h:877
+
jsReplayPolicy ReplayPolicy
Definition: nats.h:849
+
const char * DeliverGroup
Definition: nats.h:865
+
int64_t MaxAckPending
Definition: nats.h:853
+
const char * FilterSubject
Definition: nats.h:848
+
int64_t InactiveThreshold
How long the server keeps an ephemeral after detecting loss of interest, expressed in number of nanos...
Definition: nats.h:868
+
+
bool Paused
Definition: nats.h:1029
+
jsSequenceInfo Delivered
Definition: nats.h:1021
+
jsConsumerConfig * Config
Definition: nats.h:1020
+
bool PushBound
Definition: nats.h:1028
+
int64_t NumWaiting
Definition: nats.h:1025
+
int64_t Created
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:1019
+
jsClusterInfo * Cluster
Definition: nats.h:1027
+
int64_t PauseRemaining
Remaining time in nanoseconds.
Definition: nats.h:1030
+
int64_t NumAckPending
Definition: nats.h:1023
+
char * Stream
Definition: nats.h:1017
+
int64_t NumRedelivered
Definition: nats.h:1024
+
char * Name
Definition: nats.h:1018
+
jsSequenceInfo AckFloor
Definition: nats.h:1022
+
uint64_t NumPending
Definition: nats.h:1026
+
+
jsConsumerInfo ** List
Definition: nats.h:1042
+
int Count
Definition: nats.h:1043
+
+
int Count
Definition: nats.h:1057
+
char ** List
Definition: nats.h:1056
+
+
int64_t PauseRemaining
Remaining time in nanoseconds.
Definition: nats.h:1070
+
bool Paused
Definition: nats.h:1068
+
int64_t PauseUntil
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:1069
+
+
uint64_t Stream
This is the stream sequence that the application should resume from.
Definition: nats.h:905
+
uint64_t ConsumerServer
This is the consumer sequence last sent by the server.
Definition: nats.h:907
+
uint64_t ConsumerClient
This is the consumer sequence that was last received by the library.
Definition: nats.h:906
+
+
const char * NextBySubject
Get the next message (based on sequence) for that subject.
Definition: nats.h:1189
+
uint64_t Sequence
Get the message at this sequence.
Definition: nats.h:1188
+
const char * LastBySubject
Get the last message on that subject.
Definition: nats.h:1190
+
+
const char * DeliverPrefix
Definition: nats.h:399
+
const char * APIPrefix
Definition: nats.h:398
+
+
int64_t MaxBytes
Maximum bytes for the request (request complete based on whichever Batch or MaxBytes comes first)
Definition: nats.h:1203
+
int Batch
Maximum number of messages to be received (see MaxBytes)
Definition: nats.h:1202
+
int64_t Expires
Expiration of the request, expressed in nanoseconds.
Definition: nats.h:1201
+
bool NoWait
Will not wait if the request cannot be completed.
Definition: nats.h:1204
+
int64_t Heartbeat
Have server sends heartbeats to help detect communication failures.
Definition: nats.h:1205
+
+
uint64_t * Msgs
Definition: nats.h:613
+
uint64_t Bytes
Definition: nats.h:615
+
int MsgsLen
Definition: nats.h:614
+
+
+
+
+
+
+
+
+
+
jsPubAckErrHandler ErrHandler
Callback invoked when error encountered publishing a given message.
Definition: nats.h:1239
+
jsPubAckHandler AckHandler
Callback invoked for each asynchronous published message.
Definition: nats.h:1232
+
void * AckHandlerClosure
Closure (or user data) passed to jsPubAckHandler callback.
Definition: nats.h:1233
+
void * ErrHandlerClosure
Closure (or user data) passed to jsPubAckErrHandler callback.
Definition: nats.h:1240
+
int64_t StallWait
Amount of time (in milliseconds) to wait in a PublishAsync call when there is MaxPending inflight mes...
Definition: nats.h:1242
+
int64_t MaxPending
Maximum outstanding asynchronous publishes that can be inflight at one time.
Definition: nats.h:1225
+
+
bool DeletedDetails
Get the list of deleted message sequences.
Definition: nats.h:1276
+
const char * SubjectsFilter
Get the list of subjects in this stream.
Definition: nats.h:1277
+
+
uint64_t Sequence
Purge up to but not including sequence.
Definition: nats.h:1266
+
uint64_t Keep
Number of messages to keep.
Definition: nats.h:1267
+
const char * Subject
This is the subject to match against messages for the purge command.
Definition: nats.h:1265
+
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:1196
-
const char * Prefix
JetStream prefix, default is "$JS.API".
Definition: nats.h:1194
-
const char * Domain
Domain changes the domain part of JetSteam API prefix.
Definition: nats.h:1195
+
int64_t Wait
Amount of time (in milliseconds) to wait for various JetStream API requests, default is 5000 ms (5 se...
Definition: nats.h:1218
+
const char * Prefix
JetStream prefix, default is "$JS.API".
Definition: nats.h:1216
+
const char * Domain
Domain changes the domain part of JetSteam API prefix.
Definition: nats.h:1217
struct jsOptions::jsOptionsStream Stream
Optional stream options.
-
-
bool Offline
Definition: nats.h:677
-
uint64_t Lag
Definition: nats.h:679
-
int64_t Active
Definition: nats.h:678
-
char * Name
Definition: nats.h:675
-
bool Current
Definition: nats.h:676
-
-
int TagsLen
Definition: nats.h:361
-
const char * Cluster
Definition: nats.h:359
-
const char ** Tags
Definition: nats.h:360
-
-
natsMsg * Msg
Definition: nats.h:1142
-
natsStatus Err
Definition: nats.h:1143
-
jsErrCode ErrCode
Definition: nats.h:1144
-
const char * ErrText
Definition: nats.h:1145
-
-
uint64_t Sequence
Definition: nats.h:1130
-
bool Duplicate
Definition: nats.h:1132
-
char * Domain
Definition: nats.h:1131
-
char * Stream
Definition: nats.h:1129
-
-
const char * ExpectLastMsgId
Expected last message ID in the stream.
Definition: nats.h:262
-
int64_t MaxWait
Amount of time (in milliseconds) to wait for a publish response, default will the context's Wait valu...
Definition: nats.h:259
-
uint64_t ExpectLastSeq
Expected last message sequence in the stream.
Definition: nats.h:263
-
bool ExpectNoMessage
Expected no message (that is, sequence == 0) for the subject in the stream.
Definition: nats.h:265
-
const char * ExpectStream
Expected stream to respond from the publish call.
Definition: nats.h:261
-
const char * MsgId
Message ID used for de-duplication.
Definition: nats.h:260
-
uint64_t ExpectLastSubjectSeq
Expected last message sequence for the subject in the stream.
Definition: nats.h:264
-
-
bool HeadersOnly
Definition: nats.h:414
-
const char * Source
Definition: nats.h:412
-
const char * Destination
Definition: nats.h:413
-
-
int64_t Last
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:983
-
uint64_t Stream
Definition: nats.h:982
-
uint64_t Consumer
Definition: nats.h:981
-
-
uint64_t Consumer
Definition: nats.h:971
-
uint64_t Stream
Definition: nats.h:972
-
-
const char * Name
Definition: nats.h:716
-
const char * Cluster
Definition: nats.h:718
-
const char * Domain
Definition: nats.h:717
-
-
jsDiscardPolicy Discard
Definition: nats.h:529
-
const char ** Subjects
Definition: nats.h:520
-
jsSubjectTransformConfig SubjectTransform
Definition: nats.h:582
-
bool AllowDirect
Definition: nats.h:552
-
int SourcesLen
Definition: nats.h:538
-
bool DiscardNewPerSubject
Definition: nats.h:557
-
jsStorageCompression Compression
Definition: nats.h:580
-
const char * Description
Definition: nats.h:519
-
const char * Template
Definition: nats.h:533
-
bool DenyPurge
Restrict the ability to purge messages.
Definition: nats.h:541
-
jsStorageType Storage
Definition: nats.h:530
-
jsStreamConsumerLimits ConsumerLimits
Definition: nats.h:583
-
jsRetentionPolicy Retention
Definition: nats.h:522
-
int64_t MaxMsgs
Definition: nats.h:524
-
int64_t MaxConsumers
Definition: nats.h:523
-
natsMetadata Metadata
Configuration options introduced in 2.10.
Definition: nats.h:579
-
uint64_t FirstSeq
Definition: nats.h:581
-
const char * Name
Definition: nats.h:518
-
bool NoAck
Definition: nats.h:532
-
jsStreamSource ** Sources
Definition: nats.h:537
-
int32_t MaxMsgSize
Definition: nats.h:528
-
jsRePublish * RePublish
Definition: nats.h:549
-
bool MirrorDirect
Definition: nats.h:554
-
int64_t Duplicates
Definition: nats.h:534
-
int64_t MaxMsgsPerSubject
Definition: nats.h:527
-
int64_t MaxAge
Definition: nats.h:526
-
int SubjectsLen
Definition: nats.h:521
-
bool AllowRollup
Definition: nats.h:546
-
jsStreamSource * Mirror
Definition: nats.h:536
-
jsPlacement * Placement
Definition: nats.h:535
-
int64_t MaxBytes
Definition: nats.h:525
-
int64_t Replicas
Definition: nats.h:531
-
bool Sealed
Seal a stream so no messages can get our or in.
Definition: nats.h:539
-
bool DenyDelete
Restrict the ability to delete messages.
Definition: nats.h:540
-
-
int MaxAckPending
Definition: nats.h:435
-
int64_t InactiveThreshold
Definition: nats.h:434
-
-
jsStreamSourceInfo ** Sources
Definition: nats.h:735
-
int64_t Created
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:731
-
jsStreamAlternate ** Alternates
Definition: nats.h:737
-
jsStreamState State
Definition: nats.h:732
-
jsClusterInfo * Cluster
Definition: nats.h:733
-
jsStreamSourceInfo * Mirror
Definition: nats.h:734
-
int AlternatesLen
Definition: nats.h:738
-
jsStreamConfig * Config
Definition: nats.h:730
-
int SourcesLen
Definition: nats.h:736
-
-
jsStreamInfo ** List
Definition: nats.h:751
-
int Count
Definition: nats.h:752
-
-
char ** List
Definition: nats.h:765
-
int Count
Definition: nats.h:766
-
-
jsExternalStream * External
Definition: nats.h:399
-
int64_t OptStartTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:397
-
const char * Name
Definition: nats.h:395
-
const char * Domain
Definition: nats.h:403
-
uint64_t OptStartSeq
Definition: nats.h:396
-
const char * FilterSubject
Definition: nats.h:398
-
-
const char * FilterSubject
Definition: nats.h:705
-
int64_t Active
Definition: nats.h:704
-
int SubjectTransformsLen
Definition: nats.h:707
-
char * Name
Definition: nats.h:701
-
jsExternalStream * External
Definition: nats.h:702
-
uint64_t Lag
Definition: nats.h:703
-
jsSubjectTransformConfig * SubjectTransforms
Definition: nats.h:706
-
-
jsLostStreamData * Lost
Definition: nats.h:664
-
uint64_t LastSeq
Definition: nats.h:657
-
int64_t Consumers
Definition: nats.h:665
-
int DeletedLen
Definition: nats.h:663
-
uint64_t Msgs
Definition: nats.h:653
-
jsStreamStateSubjects * Subjects
Definition: nats.h:660
-
uint64_t FirstSeq
Definition: nats.h:655
-
int64_t LastTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:658
-
int64_t NumSubjects
Definition: nats.h:659
-
uint64_t * Deleted
Definition: nats.h:662
-
uint64_t NumDeleted
Definition: nats.h:661
-
uint64_t Bytes
Definition: nats.h:654
-
int64_t FirstTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:656
-
-
uint64_t Msgs
Definition: nats.h:605
-
const char * Subject
Definition: nats.h:604
-
-
int Count
Definition: nats.h:641
-
jsStreamStateSubject * List
Definition: nats.h:640
-
-
bool ManualAck
If true, the user will have to acknowledge the messages.
Definition: nats.h:950
-
const char * Consumer
If specified, the subscription will be bound to an existing consumer from the Stream without attempti...
Definition: nats.h:922
-
const char * Stream
If specified, the consumer will be bound to this stream name.
Definition: nats.h:912
-
bool Ordered
If true, this will be an ordered consumer.
Definition: nats.h:962
-
const char * Queue
Queue name for queue subscriptions.
Definition: nats.h:937
-
jsConsumerConfig Config
Consumer configuration.
Definition: nats.h:955
-
-
-
-
-
const char * Name
Definition: nats.h:1079
-
int64_t Streams
Definition: nats.h:1082
-
uint64_t Store
Definition: nats.h:1081
-
int64_t Consumers
Definition: nats.h:1083
-
uint64_t Memory
Definition: nats.h:1080
-
jsAccountLimits Limits
Definition: nats.h:1084
-
-
uint8_t History
Definition: nats.h:1305
-
const char * Bucket
Definition: nats.h:1302
-
int64_t MaxBytes
Definition: nats.h:1307
-
int32_t MaxValueSize
Definition: nats.h:1304
-
int Replicas
Definition: nats.h:1309
-
const char * Description
Definition: nats.h:1303
-
jsStreamSource * Mirror
Definition: nats.h:1311
-
int64_t TTL
Definition: nats.h:1306
-
jsStorageType StorageType
Definition: nats.h:1308
-
jsRePublish * RePublish
Definition: nats.h:1310
-
int SourcesLen
Definition: nats.h:1313
-
jsStreamSource ** Sources
Definition: nats.h:1312
-
A list of KeyValue store entries.
Definition: nats.h:1371
-
kvEntry ** Entries
Definition: nats.h:1372
-
int Count
Definition: nats.h:1373
-
A list of KeyValue store keys.
Definition: nats.h:1395
-
int Count
Definition: nats.h:1397
-
char ** Keys
Definition: nats.h:1396
-
-
int64_t Timeout
Definition: nats.h:1339
-
int64_t DeleteMarkersOlderThan
Definition: nats.h:1349
-
-
bool IgnoreDeletes
Definition: nats.h:1324
-
bool IncludeHistory
Definition: nats.h:1325
-
int64_t Timeout
How long to wait (in milliseconds) for some operations to complete.
Definition: nats.h:1327
-
bool MetaOnly
Definition: nats.h:1326
-
-
const char * Name
The name of the endpoint.
Definition: nats.h:7580
-
microRequestHandler Handler
The request handler for the endpoint.
Definition: nats.h:7602
-
const char * Subject
The NATS subject the endpoint will listen on.
Definition: nats.h:7591
-
natsMetadata Metadata
Definition: nats.h:7597
-
void * State
A user-provided pointer to store with the endpoint (state/closure).
Definition: nats.h:7608
-
-
const char * Subject
The semantic version of the service.
Definition: nats.h:7624
-
const char * Name
The name of the service.
Definition: nats.h:7619
-
natsMetadata Metadata
Definition: nats.h:7630
-
-
const char * Subject
Definition: nats.h:7639
-
int64_t NumRequests
The number of requests received by the endpoint.
Definition: nats.h:7644
-
char LastErrorString[2048]
a copy of the last error message.
Definition: nats.h:7670
-
int64_t ProcessingTimeSeconds
total request processing time (the seconds part).
Definition: nats.h:7655
-
int64_t ProcessingTimeNanoseconds
total request processing time (the nanoseconds part).
Definition: nats.h:7660
-
int64_t NumErrors
The number of errors, service-level and internal, associated with the endpoint.
Definition: nats.h:7650
-
int64_t AverageProcessingTimeNanoseconds
average request processing time, in ns.
Definition: nats.h:7665
-
const char * Name
Definition: nats.h:7638
-
The Microservice top-level configuration object.
Definition: nats.h:7680
-
const char * Description
The description of the service.
Definition: nats.h:7696
-
void * State
A user-provided pointer to state data.
Definition: nats.h:7747
-
const char * Version
The (semantic) version of the service.
Definition: nats.h:7691
-
microErrorHandler ErrHandler
An error notification handler.
Definition: nats.h:7728
-
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7701
-
microRequestHandler StatsHandler
A custom stats handler.
Definition: nats.h:7719
-
microDoneHandler DoneHandler
A callback handler for handling the final cleanup Done event, right before the service is destroyed.
Definition: nats.h:7738
-
const char * Name
The name of the service.
Definition: nats.h:7686
-
microEndpointConfig * Endpoint
The "main" (aka default) endpoint configuration.
Definition: nats.h:7710
-
-
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7785
-
const char * Name
The name of the service.
Definition: nats.h:7765
-
const char * Version
The semantic version of the service.
Definition: nats.h:7770
-
const char * Type
Response type. Always "io.nats.micro.v1.info_response".
Definition: nats.h:7760
-
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7780
-
microEndpointInfo * Endpoints
Endpoints.
Definition: nats.h:7790
-
const char * Description
The description of the service.
Definition: nats.h:7775
-
int EndpointsLen
The number of endpoints in the Endpoints array.
Definition: nats.h:7795
-
-
int64_t Started
The timestamp of when the service was started.
Definition: nats.h:7826
-
int EndpointsLen
The number of endpoints in the endpoints array.
Definition: nats.h:7836
-
microEndpointStats * Endpoints
The stats for each endpoint of the service.
Definition: nats.h:7831
-
const char * Version
The semantic version of the service.
Definition: nats.h:7816
-
const char * Name
The name of the service.
Definition: nats.h:7811
-
const char * Type
Response type. Always "io.nats.micro.v1.stats_response".
Definition: nats.h:7806
-
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7821
-
-
-
-
A list of NATS messages.
Definition: nats.h:213
-
int Count
Definition: nats.h:215
-
natsMsg ** Msgs
Definition: nats.h:214
+
+
bool Offline
Definition: nats.h:699
+
uint64_t Lag
Definition: nats.h:701
+
int64_t Active
Definition: nats.h:700
+
char * Name
Definition: nats.h:697
+
bool Current
Definition: nats.h:698
+
+
int TagsLen
Definition: nats.h:383
+
const char * Cluster
Definition: nats.h:381
+
const char ** Tags
Definition: nats.h:382
+
+
natsMsg * Msg
Definition: nats.h:1164
+
natsStatus Err
Definition: nats.h:1165
+
jsErrCode ErrCode
Definition: nats.h:1166
+
const char * ErrText
Definition: nats.h:1167
+
+
uint64_t Sequence
Definition: nats.h:1152
+
bool Duplicate
Definition: nats.h:1154
+
char * Domain
Definition: nats.h:1153
+
char * Stream
Definition: nats.h:1151
+
+
const char * ExpectLastMsgId
Expected last message ID in the stream.
Definition: nats.h:284
+
int64_t MaxWait
Amount of time (in milliseconds) to wait for a publish response, default will the context's Wait valu...
Definition: nats.h:281
+
uint64_t ExpectLastSeq
Expected last message sequence in the stream.
Definition: nats.h:285
+
bool ExpectNoMessage
Expected no message (that is, sequence == 0) for the subject in the stream.
Definition: nats.h:287
+
const char * ExpectStream
Expected stream to respond from the publish call.
Definition: nats.h:283
+
const char * MsgId
Message ID used for de-duplication.
Definition: nats.h:282
+
uint64_t ExpectLastSubjectSeq
Expected last message sequence for the subject in the stream.
Definition: nats.h:286
+
+
bool HeadersOnly
Definition: nats.h:436
+
const char * Source
Definition: nats.h:434
+
const char * Destination
Definition: nats.h:435
+
+
int64_t Last
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:1005
+
uint64_t Stream
Definition: nats.h:1004
+
uint64_t Consumer
Definition: nats.h:1003
+
+
uint64_t Consumer
Definition: nats.h:993
+
uint64_t Stream
Definition: nats.h:994
+
+
const char * Name
Definition: nats.h:738
+
const char * Cluster
Definition: nats.h:740
+
const char * Domain
Definition: nats.h:739
+
+
jsDiscardPolicy Discard
Definition: nats.h:551
+
const char ** Subjects
Definition: nats.h:542
+
jsSubjectTransformConfig SubjectTransform
Definition: nats.h:604
+
bool AllowDirect
Definition: nats.h:574
+
int SourcesLen
Definition: nats.h:560
+
bool DiscardNewPerSubject
Definition: nats.h:579
+
jsStorageCompression Compression
Definition: nats.h:602
+
const char * Description
Definition: nats.h:541
+
const char * Template
Definition: nats.h:555
+
bool DenyPurge
Restrict the ability to purge messages.
Definition: nats.h:563
+
jsStorageType Storage
Definition: nats.h:552
+
jsStreamConsumerLimits ConsumerLimits
Definition: nats.h:605
+
jsRetentionPolicy Retention
Definition: nats.h:544
+
int64_t MaxMsgs
Definition: nats.h:546
+
int64_t MaxConsumers
Definition: nats.h:545
+
natsMetadata Metadata
Configuration options introduced in 2.10.
Definition: nats.h:601
+
uint64_t FirstSeq
Definition: nats.h:603
+
const char * Name
Definition: nats.h:540
+
bool NoAck
Definition: nats.h:554
+
jsStreamSource ** Sources
Definition: nats.h:559
+
int32_t MaxMsgSize
Definition: nats.h:550
+
jsRePublish * RePublish
Definition: nats.h:571
+
bool MirrorDirect
Definition: nats.h:576
+
int64_t Duplicates
Definition: nats.h:556
+
int64_t MaxMsgsPerSubject
Definition: nats.h:549
+
int64_t MaxAge
Definition: nats.h:548
+
int SubjectsLen
Definition: nats.h:543
+
bool AllowRollup
Definition: nats.h:568
+
jsStreamSource * Mirror
Definition: nats.h:558
+
jsPlacement * Placement
Definition: nats.h:557
+
int64_t MaxBytes
Definition: nats.h:547
+
int64_t Replicas
Definition: nats.h:553
+
bool Sealed
Seal a stream so no messages can get our or in.
Definition: nats.h:561
+
bool DenyDelete
Restrict the ability to delete messages.
Definition: nats.h:562
+
+
int MaxAckPending
Definition: nats.h:457
+
int64_t InactiveThreshold
Definition: nats.h:456
+
+
jsStreamSourceInfo ** Sources
Definition: nats.h:757
+
int64_t Created
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:753
+
jsStreamAlternate ** Alternates
Definition: nats.h:759
+
jsStreamState State
Definition: nats.h:754
+
jsClusterInfo * Cluster
Definition: nats.h:755
+
jsStreamSourceInfo * Mirror
Definition: nats.h:756
+
int AlternatesLen
Definition: nats.h:760
+
jsStreamConfig * Config
Definition: nats.h:752
+
int SourcesLen
Definition: nats.h:758
+
+
jsStreamInfo ** List
Definition: nats.h:773
+
int Count
Definition: nats.h:774
+
+
char ** List
Definition: nats.h:787
+
int Count
Definition: nats.h:788
+
+
jsExternalStream * External
Definition: nats.h:421
+
int64_t OptStartTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:419
+
const char * Name
Definition: nats.h:417
+
const char * Domain
Definition: nats.h:425
+
uint64_t OptStartSeq
Definition: nats.h:418
+
const char * FilterSubject
Definition: nats.h:420
+
+
const char * FilterSubject
Definition: nats.h:727
+
int64_t Active
Definition: nats.h:726
+
int SubjectTransformsLen
Definition: nats.h:729
+
char * Name
Definition: nats.h:723
+
jsExternalStream * External
Definition: nats.h:724
+
uint64_t Lag
Definition: nats.h:725
+
jsSubjectTransformConfig * SubjectTransforms
Definition: nats.h:728
+
+
jsLostStreamData * Lost
Definition: nats.h:686
+
uint64_t LastSeq
Definition: nats.h:679
+
int64_t Consumers
Definition: nats.h:687
+
int DeletedLen
Definition: nats.h:685
+
uint64_t Msgs
Definition: nats.h:675
+
jsStreamStateSubjects * Subjects
Definition: nats.h:682
+
uint64_t FirstSeq
Definition: nats.h:677
+
int64_t LastTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:680
+
int64_t NumSubjects
Definition: nats.h:681
+
uint64_t * Deleted
Definition: nats.h:684
+
uint64_t NumDeleted
Definition: nats.h:683
+
uint64_t Bytes
Definition: nats.h:676
+
int64_t FirstTime
UTC time expressed as number of nanoseconds since epoch.
Definition: nats.h:678
+
+
uint64_t Msgs
Definition: nats.h:627
+
const char * Subject
Definition: nats.h:626
+
+
int Count
Definition: nats.h:663
+
jsStreamStateSubject * List
Definition: nats.h:662
+
+
bool ManualAck
If true, the user will have to acknowledge the messages.
Definition: nats.h:972
+
const char * Consumer
If specified, the subscription will be bound to an existing consumer from the Stream without attempti...
Definition: nats.h:944
+
const char * Stream
If specified, the consumer will be bound to this stream name.
Definition: nats.h:934
+
bool Ordered
If true, this will be an ordered consumer.
Definition: nats.h:984
+
const char * Queue
Queue name for queue subscriptions.
Definition: nats.h:959
+
jsConsumerConfig Config
Consumer configuration.
Definition: nats.h:977
+
+
+
+
+
const char * Name
Definition: nats.h:1101
+
int64_t Streams
Definition: nats.h:1104
+
uint64_t Store
Definition: nats.h:1103
+
int64_t Consumers
Definition: nats.h:1105
+
uint64_t Memory
Definition: nats.h:1102
+
jsAccountLimits Limits
Definition: nats.h:1106
+
+
uint8_t History
Definition: nats.h:1327
+
const char * Bucket
Definition: nats.h:1324
+
int64_t MaxBytes
Definition: nats.h:1329
+
int32_t MaxValueSize
Definition: nats.h:1326
+
int Replicas
Definition: nats.h:1331
+
const char * Description
Definition: nats.h:1325
+
jsStreamSource * Mirror
Definition: nats.h:1333
+
int64_t TTL
Definition: nats.h:1328
+
jsStorageType StorageType
Definition: nats.h:1330
+
jsRePublish * RePublish
Definition: nats.h:1332
+
int SourcesLen
Definition: nats.h:1335
+
jsStreamSource ** Sources
Definition: nats.h:1334
+
A list of KeyValue store entries.
Definition: nats.h:1393
+
kvEntry ** Entries
Definition: nats.h:1394
+
int Count
Definition: nats.h:1395
+
A list of KeyValue store keys.
Definition: nats.h:1417
+
int Count
Definition: nats.h:1419
+
char ** Keys
Definition: nats.h:1418
+
+
int64_t Timeout
Definition: nats.h:1361
+
int64_t DeleteMarkersOlderThan
Definition: nats.h:1371
+
+
bool IgnoreDeletes
Definition: nats.h:1346
+
bool IncludeHistory
Definition: nats.h:1347
+
int64_t Timeout
How long to wait (in milliseconds) for some operations to complete.
Definition: nats.h:1349
+
bool MetaOnly
Definition: nats.h:1348
+
+
const char * Name
The name of the endpoint.
Definition: nats.h:7636
+
microRequestHandler Handler
The request handler for the endpoint.
Definition: nats.h:7658
+
const char * Subject
The NATS subject the endpoint will listen on.
Definition: nats.h:7647
+
natsMetadata Metadata
Definition: nats.h:7653
+
void * State
A user-provided pointer to store with the endpoint (state/closure).
Definition: nats.h:7664
+
+
const char * Subject
The semantic version of the service.
Definition: nats.h:7680
+
const char * Name
The name of the service.
Definition: nats.h:7675
+
natsMetadata Metadata
Definition: nats.h:7686
+
+
const char * Subject
Definition: nats.h:7695
+
int64_t NumRequests
The number of requests received by the endpoint.
Definition: nats.h:7700
+
char LastErrorString[2048]
a copy of the last error message.
Definition: nats.h:7726
+
int64_t ProcessingTimeSeconds
total request processing time (the seconds part).
Definition: nats.h:7711
+
int64_t ProcessingTimeNanoseconds
total request processing time (the nanoseconds part).
Definition: nats.h:7716
+
int64_t NumErrors
The number of errors, service-level and internal, associated with the endpoint.
Definition: nats.h:7706
+
int64_t AverageProcessingTimeNanoseconds
average request processing time, in ns.
Definition: nats.h:7721
+
const char * Name
Definition: nats.h:7694
+
The Microservice top-level configuration object.
Definition: nats.h:7736
+
const char * Description
The description of the service.
Definition: nats.h:7752
+
void * State
A user-provided pointer to state data.
Definition: nats.h:7803
+
const char * Version
The (semantic) version of the service.
Definition: nats.h:7747
+
microErrorHandler ErrHandler
An error notification handler.
Definition: nats.h:7784
+
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7757
+
microRequestHandler StatsHandler
A custom stats handler.
Definition: nats.h:7775
+
microDoneHandler DoneHandler
A callback handler for handling the final cleanup Done event, right before the service is destroyed.
Definition: nats.h:7794
+
const char * Name
The name of the service.
Definition: nats.h:7742
+
microEndpointConfig * Endpoint
The "main" (aka default) endpoint configuration.
Definition: nats.h:7766
+
+
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7841
+
const char * Name
The name of the service.
Definition: nats.h:7821
+
const char * Version
The semantic version of the service.
Definition: nats.h:7826
+
const char * Type
Response type. Always "io.nats.micro.v1.info_response".
Definition: nats.h:7816
+
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7836
+
microEndpointInfo * Endpoints
Endpoints.
Definition: nats.h:7846
+
const char * Description
The description of the service.
Definition: nats.h:7831
+
int EndpointsLen
The number of endpoints in the Endpoints array.
Definition: nats.h:7851
+
+
int64_t Started
The timestamp of when the service was started.
Definition: nats.h:7882
+
int EndpointsLen
The number of endpoints in the endpoints array.
Definition: nats.h:7892
+
microEndpointStats * Endpoints
The stats for each endpoint of the service.
Definition: nats.h:7887
+
const char * Version
The semantic version of the service.
Definition: nats.h:7872
+
const char * Name
The name of the service.
Definition: nats.h:7867
+
const char * Type
Response type. Always "io.nats.micro.v1.stats_response".
Definition: nats.h:7862
+
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7877
+
+
+
+
A list of NATS messages.
Definition: nats.h:235
+
int Count
Definition: nats.h:237
+
natsMsg ** Msgs
Definition: nats.h:236