|
NATS C Client with JetStream and Streaming support
- 3.9.0-beta
+ 3.10.0-beta
The nats.io C Client, Supported by Synadia Communications Inc.
|
@@ -194,184 +194,184 @@
131 nle->tail = newEvent;
- 133 uv_mutex_unlock(nle->lock);
-
- 135 res = uv_async_send(nle->scheduler);
-
-
-
-
-
- 141 natsLibuvPoll(uv_poll_t* handle,
int status,
int events)
-
- 143 natsLibuvEvents *nle = (natsLibuvEvents*)handle->data;
+
+
+
+
+
+
+ 139 res = uv_async_send(nle->scheduler);
+ 140 uv_mutex_unlock(nle->lock);
+
+
+
-
-
-
-
-
-
-
-
-
- 154 if (events & UV_READABLE)
+
+ 146 natsLibuvPoll(uv_poll_t* handle,
int status,
int events)
+
+ 148 natsLibuvEvents *nle = (natsLibuvEvents*)handle->data;
+
+
+
+
+
+
-
- 157 if (events & UV_WRITABLE)
-
-
-
-
- 162 uvPollUpdate(natsLibuvEvents *nle,
int eventType,
bool add)
-
-
+
+
+
+ 159 if (events & UV_READABLE)
+
+
+ 162 if (events & UV_WRITABLE)
+
+
- 166 if (eventType == NATS_LIBUV_READ)
-
-
- 169 nle->events |= UV_READABLE;
-
- 171 nle->events &= ~UV_READABLE;
-
-
-
-
- 176 nle->events |= UV_WRITABLE;
-
- 178 nle->events &= ~UV_WRITABLE;
-
-
-
- 182 res = uv_poll_start(nle->handle, nle->events, natsLibuvPoll);
-
- 184 res = uv_poll_stop(nle->handle);
-
-
-
-
-
-
-
-
- 193 uvHandleClosedCb(uv_handle_t *handle)
-
-
-
-
-
- 199 uvAsyncAttach(natsLibuvEvents *nle)
-
-
-
-
- 204 if (nle->handle != NULL)
-
- 206 uv_close((uv_handle_t*) nle->handle, uvHandleClosedCb);
-
-
-
- 210 nle->handle = (uv_poll_t*) malloc(
sizeof(uv_poll_t));
- 211 if (nle->handle == NULL)
-
-
-
-
- 216 #if UV_VERSION_MAJOR <= 1
- 217 if (uv_poll_init_socket(nle->loop, nle->handle, nle->socket) != 0)
-
- 219 if (uv_poll_init(nle->loop, nle->handle, nle->socket) != 0)
-
-
-
-
-
- 225 && (nle->handle->data = (
void*) nle)
- 226 && (uv_poll_start(nle->handle, UV_READABLE, natsLibuvPoll) != 0))
-
-
-
-
-
-
-
-
- 235 finalCloseCb(uv_handle_t* handle)
-
- 237 natsLibuvEvents *nle = (natsLibuvEvents*)handle->data;
- 238 natsLibuvEvent *event;
-
- 240 while ((event = nle->head) != NULL)
-
- 242 nle->head =
event->next;
-
-
-
- 246 free(nle->scheduler);
- 247 uv_mutex_destroy(nle->lock);
-
-
-
-
-
- 253 closeSchedulerCb(uv_handle_t* scheduler)
-
- 255 natsLibuvEvents *nle = (natsLibuvEvents*) scheduler->data;
-
- 257 uv_close((uv_handle_t*) nle->handle, finalCloseCb);
-
-
-
- 261 uvAsyncDetach(natsLibuvEvents *nle)
-
- 263 uv_close((uv_handle_t*) nle->scheduler, closeSchedulerCb);
-
-
-
- 267 uvAsyncCb(uv_async_t *handle)
-
- 269 natsLibuvEvents *nle = (natsLibuvEvents*) handle->data;
-
- 271 natsLibuvEvent *event = NULL;
-
+
+ 167 uvHandleClosedCb(uv_handle_t *handle)
+
+
+
+
+
+ 173 uvPollUpdate(natsLibuvEvents *nle,
int eventType,
bool add)
+
+ 175 if (eventType == NATS_LIBUV_READ)
+
+
+ 178 nle->events |= UV_READABLE;
+
+ 180 nle->events &= ~UV_READABLE;
+
+
+
+
+ 185 nle->events |= UV_WRITABLE;
+
+ 187 nle->events &= ~UV_WRITABLE;
+
+
+
+
+ 192 int res = uv_poll_start(nle->handle, nle->events, natsLibuvPoll);
+
+
+
+
+ 197 uv_close((uv_handle_t*) nle->handle, uvHandleClosedCb);
+
+
+
+
+
+
+
+
+
+
+ 208 uvAsyncAttach(natsLibuvEvents *nle)
+
+
+
+
+
+
+ 215 nle->handle = (uv_poll_t*) malloc(
sizeof(uv_poll_t));
+ 216 if (nle->handle == NULL)
+
+
+
+
+ 221 #if UV_VERSION_MAJOR <= 1
+ 222 if (uv_poll_init_socket(nle->loop, nle->handle, nle->socket) != 0)
+
+ 224 if (uv_poll_init(nle->loop, nle->handle, nle->socket) != 0)
+
+
+
+
+
+ 230 && (nle->handle->data = (
void*) nle)
+ 231 && (uv_poll_start(nle->handle, UV_READABLE, natsLibuvPoll) != 0))
+
+
+
+
+
+
+
+
+ 240 uvFinalCloseCb(uv_handle_t* handle)
+
+ 242 natsLibuvEvents *nle = (natsLibuvEvents*) handle->data;
+ 243 natsLibuvEvent *event;
+
+ 245 while ((event = nle->head) != NULL)
+
+ 247 nle->head =
event->next;
+
+
+ 250 free(nle->scheduler);
+ 251 uv_mutex_destroy(nle->lock);
+
+
+
+
+
+ 257 uvAsyncDetach(natsLibuvEvents *nle)
+
+ 259 uv_close((uv_handle_t*) nle->scheduler, uvFinalCloseCb);
+
+
+
+ 263 uvAsyncCb(uv_async_t *handle)
+
+ 265 natsLibuvEvents *nle = (natsLibuvEvents*) handle->data;
+
+ 267 natsLibuvEvent *event = NULL;
+
+
+
+
+ 272 uv_mutex_lock(nle->lock);
-
-
- 276 uv_mutex_lock(nle->lock);
-
-
-
-
-
-
- 283 uv_mutex_unlock(nle->lock);
-
-
+
+
+
+
+
+ 279 uv_mutex_unlock(nle->lock);
+
+
+
+ 283 nle->head =
event->next;
+ 284 if (event == nle->tail)
+
- 287 nle->head =
event->next;
- 288 if (event == nle->tail)
-
+ 287 more = (nle->head != NULL ? true :
false);
+
+ 289 uv_mutex_unlock(nle->lock);
- 291 more = (nle->head != NULL ? true :
false);
-
- 293 uv_mutex_unlock(nle->lock);
-
-
-
- 297 case NATS_LIBUV_ATTACH:
-
- 299 s = uvAsyncAttach(nle);
-
-
- 302 case NATS_LIBUV_READ:
- 303 case NATS_LIBUV_WRITE:
-
- 305 s = uvPollUpdate(nle, event->type, event->add);
-
-
- 308 case NATS_LIBUV_DETACH:
-
-
+
+
+ 293 case NATS_LIBUV_ATTACH:
+
+ 295 s = uvAsyncAttach(nle);
+
+
+ 298 case NATS_LIBUV_READ:
+ 299 case NATS_LIBUV_WRITE:
+
+ 301 s = uvPollUpdate(nle, event->type, event->add);
+
+
+ 304 case NATS_LIBUV_DETACH:
+
+
+
+
+
+
@@ -526,6 +526,7 @@
NATS_EXTERN void natsConnection_Close(natsConnection *nc)
Closes the connection.
NATS_EXTERN void natsConnection_ProcessCloseEvent(natsSock *socket)
Process a socket close event when using external event loop.
NATS_EXTERN void natsConnection_ProcessReadEvent(natsConnection *nc)
Process a read event when using external event loop.
NATS_EXTERN void natsConnection_ProcessWriteEvent(natsConnection *nc)
Process a write event when using external event loop.
void natsLibuv_SetThreadLocalLoop(uv_loop_t *loop)
Register the event loop with the thread running uv_run().
Definition: libuv.h:104
|
NATS C Client with JetStream and Streaming support
- 3.9.0-beta
+ 3.10.0-beta
The nats.io C Client, Supported by Synadia Communications Inc.
|
@@ -809,1574 +809,1578 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 1502 #if defined(NATS_HAS_STREAMING)
-
-
-
-
- 1519 typedef struct __stanMsg
stanMsg;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 1669 char **customErrTxt,
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1503 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+ 1520 typedef struct __stanMsg
stanMsg;
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 1670 char **customErrTxt,
+
-
- 1699 char **customErrTxt,
- 1700 unsigned char **signature,
- 1701 int *signatureLength,
-
-
-
- 1713 typedef const char* (*natsTokenHandler)(
void *closure);
-
+
+
+ 1700 char **customErrTxt,
+ 1701 unsigned char **signature,
+ 1702 int *signatureLength,
+
+
+
+ 1714 typedef const char* (*natsTokenHandler)(
void *closure);
-
-
-
-
- 1747 #ifdef BUILD_IN_DOXYGEN
-
-
-
-
-
- 1827 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+ 1748 #ifdef BUILD_IN_DOXYGEN
+
+
+
+
+
+ 1828 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
- 1928 #ifdef BUILD_IN_DOXYGEN
-
-
-
- 1946 #define nats_CheckCompatibility() nats_CheckCompatibilityImpl(NATS_VERSION_REQUIRED_NUMBER, \
- 1947 NATS_VERSION_NUMBER, \
- 1948 NATS_VERSION_STRING)
-
-
- 1951 nats_CheckCompatibilityImpl(uint32_t reqVerNumber, uint32_t verNumber,
const char *verString);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 2101 unsigned char **signature,
- 2102 int *signatureLength);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 2235 uint64_t *inMsgs, uint64_t *inBytes,
- 2236 uint64_t *outMsgs, uint64_t *outBytes,
- 2237 uint64_t *reconnects);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 2526 const char *certsFileName,
- 2527 const char *keyFileName);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3224 const char *userOrChainedFile,
- 3225 const char *seedFile);
-
-
-
- 3241 const char *jwtAndSeedContent);
-
-
-
-
-
-
-
-
-
-
- 3299 const char *seedFile);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3400 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+ 1929 #ifdef BUILD_IN_DOXYGEN
+
+
+
+ 1947 #define nats_CheckCompatibility() nats_CheckCompatibilityImpl(NATS_VERSION_REQUIRED_NUMBER, \
+ 1948 NATS_VERSION_NUMBER, \
+ 1949 NATS_VERSION_STRING)
+
+
+ 1952 nats_CheckCompatibilityImpl(uint32_t reqVerNumber, uint32_t verNumber,
const char *verString);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 2102 unsigned char **signature,
+ 2103 int *signatureLength);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 2236 uint64_t *inMsgs, uint64_t *inBytes,
+ 2237 uint64_t *outMsgs, uint64_t *outBytes,
+ 2238 uint64_t *reconnects);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 2527 const char *certsFileName,
+ 2528 const char *keyFileName);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3225 const char *userOrChainedFile,
+ 3226 const char *seedFile);
+
+
+
+ 3242 const char *jwtAndSeedContent);
+
+
+
+
+
+
+
+
+
+
+ 3300 const char *seedFile);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3401 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3832 const char *data,
int dataLen);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 4064 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3833 const char *data,
int dataLen);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 4065 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
-
- 4496 const unsigned char *message,
int messageLen,
- 4497 unsigned char sig[64]);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 4607 const void *data,
int dataLen);
-
-
-
-
-
-
-
-
+
+
+
+
+ 4511 const unsigned char *message,
int messageLen,
+ 4512 unsigned char sig[64]);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 4622 const void *data,
int dataLen);
+
+
+
+
+
-
- 4654 const char *reply,
const void *data,
int dataLen);
-
-
-
- 4674 const char *reply,
const char *str);
-
-
-
- 4695 const void *data,
int dataLen, int64_t timeout);
-
-
-
- 4720 const char *subj,
const char *str,
-
-
-
-
- 4739 natsMsg *requestMsg, int64_t timeout);
-
-
-
-
-
-
-
-
-
- 4800 const char *subject, int64_t timeout,
-
-
+
+
+
+
+ 4669 const char *reply,
const void *data,
int dataLen);
+
+
+
+ 4689 const char *reply,
const char *str);
+
+
+
+ 4710 const void *data,
int dataLen, int64_t timeout);
+
+
+
+ 4735 const char *subj,
const char *str,
+
+
+
+
+ 4754 natsMsg *requestMsg, int64_t timeout);
+
+
+
+
+
+
+
-
- 4815 const char *subject);
-
-
-
- 4836 const char *subject,
const char *queueGroup,
-
-
-
-
- 4873 const char *subject,
const char *queueGroup,
-
-
-
-
- 4889 const char *subject,
const char *queueGroup);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+ 4815 const char *subject, int64_t timeout,
+
+
+
+
+ 4830 const char *subject);
+
+
+
+ 4851 const char *subject,
const char *queueGroup,
+
+
+
+
+ 4888 const char *subject,
const char *queueGroup,
+
+
+
+
+ 4904 const char *subject,
const char *queueGroup);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
- 5148 int *maxPendingMsgs,
- 5149 int *maxPendingBytes,
- 5150 int64_t *deliveredMsgs,
- 5151 int64_t *droppedMsgs);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 5333 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 5473 const void *data,
int dataLen);
-
-
-
- 5500 const void *data,
int dataLen,
-
-
-
-
-
-
-
-
-
-
- 5553 const char *channel,
const char *queueGroup,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 6108 const char *stream,
const char *consumer,
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+ 5163 int *maxPendingMsgs,
+ 5164 int *maxPendingBytes,
+ 5165 int64_t *deliveredMsgs,
+ 5166 int64_t *droppedMsgs);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 5348 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 5488 const void *data,
int dataLen);
+
+
+
+ 5515 const void *data,
int dataLen,
+
+
+
+
+
+
+
+
+
+
+ 5568 const char *channel,
const char *queueGroup,
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 6123 const char *stream,
const char *consumer,
+
-
-
- 6142 const char *stream,
const char *consumer,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+ 6157 const char *stream,
const char *consumer,
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
-
-
-
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
+
-
+
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
-
-
-
+
+
+
-
+
-
+
-
-
-
-
- 8103 #define MICRO_API_PREFIX "$SRV"
-
- 8108 #define MICRO_INFO_RESPONSE_TYPE "io.nats.micro.v1.info_response"
-
- 8113 #define MICRO_INFO_VERB "INFO"
-
- 8118 #define MICRO_PING_RESPONSE_TYPE "io.nats.micro.v1.ping_response"
+
+
+
+
+
+
+
+
+
+
+ 8118 #define MICRO_API_PREFIX "$SRV"
- 8123 #define MICRO_PING_VERB "PING"
+ 8123 #define MICRO_INFO_RESPONSE_TYPE "io.nats.micro.v1.info_response"
- 8128 #define MICRO_STATS_RESPONSE_TYPE "io.nats.micro.v1.stats_response"
+ 8128 #define MICRO_INFO_VERB "INFO"
- 8133 #define MICRO_STATS_VERB "STATS"
+ 8133 #define MICRO_PING_RESPONSE_TYPE "io.nats.micro.v1.ping_response"
- 8139 #define MICRO_STATUS_HDR "Nats-Status"
-
- 8145 #define MICRO_ERROR_HDR "Nats-Service-Error"
-
- 8151 #define MICRO_ERROR_CODE_HDR "Nats-Service-Error-Code"
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+ 8138 #define MICRO_PING_VERB "PING"
+
+ 8143 #define MICRO_STATS_RESPONSE_TYPE "io.nats.micro.v1.stats_response"
+
+ 8148 #define MICRO_STATS_VERB "STATS"
+
+ 8154 #define MICRO_STATUS_HDR "Nats-Status"
+
+ 8160 #define MICRO_ERROR_HDR "Nats-Service-Error"
+
+ 8166 #define MICRO_ERROR_CODE_HDR "Nats-Service-Error-Code"
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 8709 #define microError_Ignore(__err) microError_Destroy(__err)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-void(* natsOnCompleteCB)(void *closure)
Callback used to notify that an object lifecycle is complete.
Definition: nats.h:1723
natsStatus(* natsEvLoop_Attach)(void **userData, void *loop, natsConnection *nc, natsSock socket)
Attach this connection to the external event loop.
Definition: nats.h:1604
natsStatus(* natsUserJWTHandler)(char **userJWT, char **customErrTxt, void *closure)
Callback used to fetch and return account signed user JWT.
Definition: nats.h:1667
natsStatus(* natsEvLoop_WriteAddRemove)(void *userData, bool add)
Write event needs to be added or removed.
Definition: nats.h:1632
int64_t(* natsCustomReconnectDelayHandler)(natsConnection *nc, int attempts, void *closure)
Callback used to specify how long to wait between reconnects.
Definition: nats.h:1745
void(* jsPubAckHandler)(jsCtx *js, natsMsg *msg, jsPubAck *pa, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish responses from JetStream.
Definition: nats.h:1824
const char *(* natsTokenHandler)(void *closure)
Callback used to build a token on connections and reconnections.
Definition: nats.h:1713
void(* jsPubAckErrHandler)(jsCtx *js, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish errors from JetStream.
Definition: nats.h:1781
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:1587
natsStatus(* natsEvLoop_Detach)(void *userData)
Detach from the event loop.
Definition: nats.h:1643
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:1698
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:1856
void(* natsConnectionHandler)(natsConnection *nc, void *closure)
Callback used to notify the user of asynchronous connection events.
Definition: nats.h:1578
void(* natsMsgHandler)(natsConnection *nc, natsSubscription *sub, natsMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1562
void(* stanPubAckHandler)(const char *guid, const char *error, void *closure)
Callback used to notify of an asynchronous publish result.
Definition: nats.h:1836
natsStatus(* natsEvLoop_ReadAddRemove)(void *userData, bool add)
Read event needs to be added or removed.
Definition: nats.h:1619
void(* stanMsgHandler)(stanConnection *sc, stanSubscription *sub, const char *channel, stanMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1847
8724 #define microError_Ignore(__err) microError_Destroy(__err)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+void(* natsOnCompleteCB)(void *closure)
Callback used to notify that an object lifecycle is complete.
Definition: nats.h:1724
natsStatus(* natsEvLoop_Attach)(void **userData, void *loop, natsConnection *nc, natsSock socket)
Attach this connection to the external event loop.
Definition: nats.h:1605
natsStatus(* natsUserJWTHandler)(char **userJWT, char **customErrTxt, void *closure)
Callback used to fetch and return account signed user JWT.
Definition: nats.h:1668
natsStatus(* natsEvLoop_WriteAddRemove)(void *userData, bool add)
Write event needs to be added or removed.
Definition: nats.h:1633
int64_t(* natsCustomReconnectDelayHandler)(natsConnection *nc, int attempts, void *closure)
Callback used to specify how long to wait between reconnects.
Definition: nats.h:1746
void(* jsPubAckHandler)(jsCtx *js, natsMsg *msg, jsPubAck *pa, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish responses from JetStream.
Definition: nats.h:1825
const char *(* natsTokenHandler)(void *closure)
Callback used to build a token on connections and reconnections.
Definition: nats.h:1714
void(* jsPubAckErrHandler)(jsCtx *js, jsPubAckErr *pae, void *closure)
Callback used to process asynchronous publish errors from JetStream.
Definition: nats.h:1782
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:1588
natsStatus(* natsEvLoop_Detach)(void *userData)
Detach from the event loop.
Definition: nats.h:1644
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:1699
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:1857
void(* natsConnectionHandler)(natsConnection *nc, void *closure)
Callback used to notify the user of asynchronous connection events.
Definition: nats.h:1579
void(* natsMsgHandler)(natsConnection *nc, natsSubscription *sub, natsMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1563
void(* stanPubAckHandler)(const char *guid, const char *error, void *closure)
Callback used to notify of an asynchronous publish result.
Definition: nats.h:1837
natsStatus(* natsEvLoop_ReadAddRemove)(void *userData, bool add)
Read event needs to be added or removed.
Definition: nats.h:1620
void(* stanMsgHandler)(stanConnection *sc, stanSubscription *sub, const char *channel, stanMsg *msg, void *closure)
Callback used to deliver messages to the application.
Definition: nats.h:1848
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.
NATS_EXTERN natsStatus natsConnection_Connect(natsConnection **nc, natsOptions *options)
Connects to a NATS Server using the provided options.
NATS_EXTERN natsStatus natsConnection_GetClientID(natsConnection *nc, uint64_t *cid)
Gets the current client ID assigned by the server.
NATS_EXTERN natsStatus natsConnection_FlushTimeout(natsConnection *nc, int64_t timeout)
Flushes the connection with a given timeout.
NATS_EXTERN void natsConnection_ProcessCloseEvent(natsSock *socket)
Process a socket close event when using external event loop.
NATS_EXTERN natsStatus natsConnection_GetLocalIPAndPort(natsConnection *nc, char **ip, int *port)
Returns the connection local IP and port.
NATS_EXTERN natsStatus natsConnection_GetRTT(natsConnection *nc, int64_t *rtt)
Returns the round trip time between this client and the server.
NATS_EXTERN void natsConnection_ProcessReadEvent(natsConnection *nc)
Process a read event when using external event loop.
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:7745
microError *(* microRequestHandler)(microRequest *req)
Callback type for request processing.
Definition: nats.h:7721
void(* microDoneHandler)(microService *m)
Callback type for Done (service stopped) notifications.
Definition: nats.h:7758
void(* microErrorHandler)(microService *m, microEndpoint *ep, natsStatus s)
Callback type for async error notifications.
Definition: nats.h:7760
microError *(* microRequestHandler)(microRequest *req)
Callback type for request processing.
Definition: nats.h:7736
void(* microDoneHandler)(microService *m)
Callback type for Done (service stopped) notifications.
Definition: nats.h:7773
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.
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:7568
struct micro_group_s microGroup
a collection of endpoints and other groups, with a common prefix to their subjects and names.
Definition: nats.h:7637
struct micro_request_s microRequest
a request received by a microservice endpoint.
Definition: nats.h:7652
struct micro_error_s microError
the Microservice error object.
Definition: nats.h:7628
struct __for_forward_compatibility_only microClientConfig
The Microservice configuration object. For forward compatibility only.
Definition: nats.h:7573
struct micro_client_s microClient
The Microservice client.
Definition: nats.h:7583
struct micro_group_s microGroup
a collection of endpoints and other groups, with a common prefix to their subjects and names.
Definition: nats.h:7652
struct micro_request_s microRequest
a request received by a microservice endpoint.
Definition: nats.h:7667
struct micro_error_s microError
the Microservice error object.
Definition: nats.h:7643
struct __for_forward_compatibility_only microClientConfig
The Microservice configuration object. For forward compatibility only.
Definition: nats.h:7588
NATS_EXTERN microError * micro_ErrorInvalidArg
NATS_EXTERN microError * micro_ErrorOutOfMemory
struct micro_endpoint_s microEndpoint
microEndpoint represents a microservice endpoint.
Definition: nats.h:7584
struct micro_service_s microService
the main object for a configured microservice.
Definition: nats.h:7665
struct micro_endpoint_s microEndpoint
microEndpoint represents a microservice endpoint.
Definition: nats.h:7599
struct micro_service_s microService
the main object for a configured microservice.
Definition: nats.h:7680
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.
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:1531
struct __stanSubOptions stanSubOptions
Way to configure a stanSubscription.
Definition: nats.h:1532
struct jsConsumerConfig jsConsumerConfig
struct __kvStore kvStore
Definition: nats.h:1367
struct jsOptions jsOptions
jsStorageCompression
Definition: nats.h:326
jsDeliverPolicy
Definition: nats.h:335
struct __stanConnOptions stanConnOptions
Way to configure a stanConnection.
Definition: nats.h:1525
struct __stanConnOptions stanConnOptions
Way to configure a stanConnection.
Definition: nats.h:1526
jsStorageType
Definition: nats.h:316
struct jsStreamInfoList jsStreamInfoList
struct jsStreamConfig jsStreamConfig
struct jsSequenceInfo jsSequenceInfo
struct jsStreamState jsStreamState
struct __stanMsg stanMsg
The Streaming message.
Definition: nats.h:1519
struct __stanMsg stanMsg
The Streaming message.
Definition: nats.h:1520
struct jsConsumerInfo jsConsumerInfo
struct jsSequencePair jsSequencePair
struct natsMetadata natsMetadata
A type to represent user-provided metadata, a list of k=v pairs.
kvOperation
Definition: nats.h:1388
jsAckPolicy
Definition: nats.h:349
struct kvPurgeOptions kvPurgeOptions
struct __stanConnection stanConnection
A connection to a NATS Streaming Server.
Definition: nats.h:1507
struct __stanConnection stanConnection
A connection to a NATS Streaming Server.
Definition: nats.h:1508
void(* jsFetchCompleteHandler)(natsConnection *nc, natsSubscription *sub, natsStatus s, void *closure)
Callback used to indicate that the work of js_PullSubscribeAsync is done.
Definition: nats.h:1228
struct jsAccountLimits jsAccountLimits
struct __jsCtx jsCtx
Definition: nats.h:262
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:1513
struct __stanSubscription stanSubscription
Interest on a given channel.
Definition: nats.h:1514
struct jsStreamStateSubjects jsStreamStateSubjects
struct jsExternalStream jsExternalStream
struct jsFetchRequest jsFetchRequest
jsRePublish * RePublish
Definition: nats.h:1411
int SourcesLen
Definition: nats.h:1414
jsStreamSource ** Sources
Definition: nats.h:1413
A list of KeyValue store entries.
Definition: nats.h:1472
kvEntry ** Entries
Definition: nats.h:1473
int Count
Definition: nats.h:1474
A list of KeyValue store keys.
Definition: nats.h:1496
int Count
Definition: nats.h:1498
char ** Keys
Definition: nats.h:1497
int64_t Timeout
Definition: nats.h:1440
int64_t DeleteMarkersOlderThan
Definition: nats.h:1450
A list of KeyValue store entries.
Definition: nats.h:1473
kvEntry ** Entries
Definition: nats.h:1474
int Count
Definition: nats.h:1475
A list of KeyValue store keys.
Definition: nats.h:1497
int Count
Definition: nats.h:1499
char ** Keys
Definition: nats.h:1498
int64_t Timeout
Definition: nats.h:1441
int64_t DeleteMarkersOlderThan
Definition: nats.h:1451
bool IgnoreDeletes
Definition: nats.h:1425
bool IncludeHistory
Definition: nats.h:1426
int64_t Timeout
How long to wait (in milliseconds) for some operations to complete.
Definition: nats.h:1428
bool UpdatesOnly
Only receive updates, no initial snapshot.
Definition: nats.h:1429
bool MetaOnly
Definition: nats.h:1427
const char * Name
The name of the endpoint.
Definition: nats.h:7779
microRequestHandler Handler
The request handler for the endpoint.
Definition: nats.h:7813
const char * Subject
The NATS subject the endpoint will listen on.
Definition: nats.h:7790
natsMetadata Metadata
Metadata for the endpoint, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7808
bool NoQueueGroup
Disables the use of a queue group for the service.
Definition: nats.h:7802
const char * QueueGroup
Overrides the default queue group for the service.
Definition: nats.h:7796
void * State
A user-provided pointer to store with the endpoint (state/closure).
Definition: nats.h:7819
const char * Subject
The semantic version of the service.
Definition: nats.h:7835
const char * Name
The name of the service.
Definition: nats.h:7830
const char * QueueGroup
Endpoint's actual queue group (the default "q", or one explicitly set by the user),...
Definition: nats.h:7841
natsMetadata Metadata
Metadata for the endpoint, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7847
const char * Subject
Definition: nats.h:7856
int64_t NumRequests
The number of requests received by the endpoint.
Definition: nats.h:7867
char LastErrorString[2048]
a copy of the last error message.
Definition: nats.h:7893
int64_t ProcessingTimeSeconds
total request processing time (the seconds part).
Definition: nats.h:7878
int64_t ProcessingTimeNanoseconds
total request processing time (the nanoseconds part).
Definition: nats.h:7883
const char * QueueGroup
Endpoint's actual queue group (the default "q", or one explicitly set by the user),...
Definition: nats.h:7862
int64_t NumErrors
The number of errors, service-level and internal, associated with the endpoint.
Definition: nats.h:7873
int64_t AverageProcessingTimeNanoseconds
average request processing time, in ns.
Definition: nats.h:7888
const char * Name
Definition: nats.h:7855
The Microservice endpoint group configuration object.
Definition: nats.h:7900
bool NoQueueGroup
Disables the use of a queue group for the service.
Definition: nats.h:7908
const char * QueueGroup
Overrides the default queue group for the service.
Definition: nats.h:7905
const char * Prefix
The subject prefix for the group.
Definition: nats.h:7902
The Microservice top-level configuration object.
Definition: nats.h:7918
const char * Description
The description of the service.
Definition: nats.h:7934
void * State
A user-provided pointer to state data.
Definition: nats.h:7998
const char * Version
The (semantic) version of the service.
Definition: nats.h:7929
microErrorHandler ErrHandler
An error notification handler.
Definition: nats.h:7979
natsMetadata Metadata
Immutable metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7952
bool NoQueueGroup
Disables the use of a queue group for the service.
Definition: nats.h:7946
microRequestHandler StatsHandler
A custom stats handler.
Definition: nats.h:7970
microDoneHandler DoneHandler
A callback handler for handling the final cleanup Done event, right before the service is destroyed.
Definition: nats.h:7989
const char * QueueGroup
Overrides the default queue group for the service ("q").
Definition: nats.h:7940
const char * Name
The name of the service.
Definition: nats.h:7924
microEndpointConfig * Endpoint
The "main" (aka default) endpoint configuration.
Definition: nats.h:7961
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:8036
const char * Name
The name of the service.
Definition: nats.h:8016
const char * Version
The semantic version of the service.
Definition: nats.h:8021
const char * Type
Response type. Always "io.nats.micro.v1.info_response".
Definition: nats.h:8011
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:8031
microEndpointInfo * Endpoints
Endpoints.
Definition: nats.h:8041
const char * Description
The description of the service.
Definition: nats.h:8026
int EndpointsLen
The number of endpoints in the Endpoints array.
Definition: nats.h:8046
int64_t Started
The timestamp of when the service was started.
Definition: nats.h:8077
int EndpointsLen
The number of endpoints in the endpoints array.
Definition: nats.h:8087
microEndpointStats * Endpoints
The stats for each endpoint of the service.
Definition: nats.h:8082
const char * Version
The semantic version of the service.
Definition: nats.h:8067
const char * Name
The name of the service.
Definition: nats.h:8062
const char * Type
Response type. Always "io.nats.micro.v1.stats_response".
Definition: nats.h:8057
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:8072
const char * Name
The name of the endpoint.
Definition: nats.h:7794
microRequestHandler Handler
The request handler for the endpoint.
Definition: nats.h:7828
const char * Subject
The NATS subject the endpoint will listen on.
Definition: nats.h:7805
natsMetadata Metadata
Metadata for the endpoint, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7823
bool NoQueueGroup
Disables the use of a queue group for the service.
Definition: nats.h:7817
const char * QueueGroup
Overrides the default queue group for the service.
Definition: nats.h:7811
void * State
A user-provided pointer to store with the endpoint (state/closure).
Definition: nats.h:7834
const char * Subject
The semantic version of the service.
Definition: nats.h:7850
const char * Name
The name of the service.
Definition: nats.h:7845
const char * QueueGroup
Endpoint's actual queue group (the default "q", or one explicitly set by the user),...
Definition: nats.h:7856
natsMetadata Metadata
Metadata for the endpoint, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7862
const char * Subject
Definition: nats.h:7871
int64_t NumRequests
The number of requests received by the endpoint.
Definition: nats.h:7882
char LastErrorString[2048]
a copy of the last error message.
Definition: nats.h:7908
int64_t ProcessingTimeSeconds
total request processing time (the seconds part).
Definition: nats.h:7893
int64_t ProcessingTimeNanoseconds
total request processing time (the nanoseconds part).
Definition: nats.h:7898
const char * QueueGroup
Endpoint's actual queue group (the default "q", or one explicitly set by the user),...
Definition: nats.h:7877
int64_t NumErrors
The number of errors, service-level and internal, associated with the endpoint.
Definition: nats.h:7888
int64_t AverageProcessingTimeNanoseconds
average request processing time, in ns.
Definition: nats.h:7903
const char * Name
Definition: nats.h:7870
The Microservice endpoint group configuration object.
Definition: nats.h:7915
bool NoQueueGroup
Disables the use of a queue group for the service.
Definition: nats.h:7923
const char * QueueGroup
Overrides the default queue group for the service.
Definition: nats.h:7920
const char * Prefix
The subject prefix for the group.
Definition: nats.h:7917
The Microservice top-level configuration object.
Definition: nats.h:7933
const char * Description
The description of the service.
Definition: nats.h:7949
void * State
A user-provided pointer to state data.
Definition: nats.h:8013
const char * Version
The (semantic) version of the service.
Definition: nats.h:7944
microErrorHandler ErrHandler
An error notification handler.
Definition: nats.h:7994
natsMetadata Metadata
Immutable metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7967
bool NoQueueGroup
Disables the use of a queue group for the service.
Definition: nats.h:7961
microRequestHandler StatsHandler
A custom stats handler.
Definition: nats.h:7985
microDoneHandler DoneHandler
A callback handler for handling the final cleanup Done event, right before the service is destroyed.
Definition: nats.h:8004
const char * QueueGroup
Overrides the default queue group for the service ("q").
Definition: nats.h:7955
const char * Name
The name of the service.
Definition: nats.h:7939
microEndpointConfig * Endpoint
The "main" (aka default) endpoint configuration.
Definition: nats.h:7976
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:8051
const char * Name
The name of the service.
Definition: nats.h:8031
const char * Version
The semantic version of the service.
Definition: nats.h:8036
const char * Type
Response type. Always "io.nats.micro.v1.info_response".
Definition: nats.h:8026
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:8046
microEndpointInfo * Endpoints
Endpoints.
Definition: nats.h:8056
const char * Description
The description of the service.
Definition: nats.h:8041
int EndpointsLen
The number of endpoints in the Endpoints array.
Definition: nats.h:8061
int64_t Started
The timestamp of when the service was started.
Definition: nats.h:8092
int EndpointsLen
The number of endpoints in the endpoints array.
Definition: nats.h:8102
microEndpointStats * Endpoints
The stats for each endpoint of the service.
Definition: nats.h:8097
const char * Version
The semantic version of the service.
Definition: nats.h:8082
const char * Name
The name of the service.
Definition: nats.h:8077
const char * Type
Response type. Always "io.nats.micro.v1.stats_response".
Definition: nats.h:8072
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:8087