+◆ natsOptions_SetMaxPendingBytes()
+
+
+
+
Specifies the maximum number of inbound bytes that can be buffered in the library, for each subscription, before inbound messages are dropped and NATS_SLOW_CONSUMER status is reported to the natsErrHandler callback (if one has been set).
+
- See also
- natsOptions_SetErrorHandler()
+
- Parameters
-
+
+ | opts | the pointer to the natsOptions object. |
+ | maxPending | the number of bytes allowed to be buffered by the library before triggering a slow consumer scenario. |
+
+
+
+
| NATS_EXTERN natsStatus | natsOptions_SetMaxPendingMsgs (natsOptions *opts, int maxPending) |
| | Sets the maximum number of pending messages per subscription. More...
|
| |
+| NATS_EXTERN natsStatus | natsOptions_SetMaxPendingBytes (natsOptions *opts, int64_t maxPending) |
+| | Sets the maximum number of pending bytes per subscription. More...
|
+| |
| NATS_EXTERN natsStatus | natsOptions_SetErrorHandler (natsOptions *opts, natsErrHandler errHandler, void *closure) |
| | Sets the error handler for asynchronous events. More...
|
| |
diff --git a/doc/html/nats_8h.js b/doc/html/nats_8h.js
index 90e489acd..974d959fa 100644
--- a/doc/html/nats_8h.js
+++ b/doc/html/nats_8h.js
@@ -210,6 +210,7 @@ var nats_8h =
[ "natsOptions_SetCustomReconnectDelay", "group__opts_group.html#ga3593165aa113d6736e0226ddc56b3e9d", null ],
[ "natsOptions_SetReconnectBufSize", "group__opts_group.html#gaa0d4b7ece8477cb9879f0dafff3456a5", null ],
[ "natsOptions_SetMaxPendingMsgs", "group__opts_group.html#ga95510436eee06f9992ded96a44795c40", null ],
+ [ "natsOptions_SetMaxPendingBytes", "group__opts_group.html#ga77afd954ca548054631215e511468e60", null ],
[ "natsOptions_SetErrorHandler", "group__opts_group.html#ga127ec7a8196b453947a7fa9a64096cbd", null ],
[ "natsOptions_SetClosedCB", "group__opts_group.html#ga44410242e73134e5bb51ef27904a9253", null ],
[ "natsOptions_SetDisconnectedCB", "group__opts_group.html#gadc8dc0cedd91bda71d544f3dedc4a039", null ],
diff --git a/doc/html/nats_8h_source.html b/doc/html/nats_8h_source.html
index 86d4c9cca..829a3259e 100644
--- a/doc/html/nats_8h_source.html
+++ b/doc/html/nats_8h_source.html
@@ -1063,1202 +1063,1205 @@
-
-
-
-
+
+
+
-
-
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3072 const char *userOrChainedFile,
- 3073 const char *seedFile);
-
-
-
- 3089 const char *jwtAndSeedContent);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3088 const char *userOrChainedFile,
+ 3089 const char *seedFile);
-
-
-
-
-
-
-
-
-
- 3147 const char *seedFile);
-
-
-
+
+
+ 3105 const char *jwtAndSeedContent);
+
+
+
+
+
+
+
+
+
+
+ 3163 const char *seedFile);
-
-
-
-
-
-
+
+
+
+
+
+
-
+
-
-
-
-
- 3248 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+ 3264 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 3680 const char *data,
int dataLen);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 3696 const char *data,
int dataLen);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
- 3912 #if defined(NATS_HAS_STREAMING)
-
-
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+ 3928 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
- 4332 const unsigned char *message,
int messageLen,
- 4333 unsigned char sig[64]);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 4443 const void *data,
int dataLen);
-
-
-
-
-
-
-
-
-
-
- 4490 const char *reply,
const void *data,
int dataLen);
+
+
+
+
+
+
+
+
+
+
+
+ 4348 const unsigned char *message,
int messageLen,
+ 4349 unsigned char sig[64]);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 4459 const void *data,
int dataLen);
+
+
+
+
+
+
+
-
-
- 4510 const char *reply,
const char *str);
-
-
-
- 4531 const void *data,
int dataLen, int64_t timeout);
-
-
-
- 4556 const char *subj,
const char *str,
-
-
-
-
- 4575 natsMsg *requestMsg, int64_t timeout);
-
-
-
-
-
-
-
-
-
- 4636 const char *subject, int64_t timeout,
-
-
-
-
- 4651 const char *subject);
-
-
-
- 4672 const char *subject,
const char *queueGroup,
-
-
-
-
- 4709 const char *subject,
const char *queueGroup,
-
-
+
+
+ 4506 const char *reply,
const void *data,
int dataLen);
+
+
+
+ 4526 const char *reply,
const char *str);
+
+
+
+ 4547 const void *data,
int dataLen, int64_t timeout);
+
+
+
+ 4572 const char *subj,
const char *str,
+
+
+
+
+ 4591 natsMsg *requestMsg, int64_t timeout);
+
+
+
+
+
+
+
+
+
+ 4652 const char *subject, int64_t timeout,
+
+
+
+
+ 4667 const char *subject);
+
+
+
+ 4688 const char *subject,
const char *queueGroup,
+
+
-
- 4725 const char *subject,
const char *queueGroup);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 4984 int *maxPendingMsgs,
- 4985 int *maxPendingBytes,
- 4986 int64_t *deliveredMsgs,
- 4987 int64_t *droppedMsgs);
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 5169 #if defined(NATS_HAS_STREAMING)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 5309 const void *data,
int dataLen);
-
-
-
- 5336 const void *data,
int dataLen,
-
-
-
-
-
-
-
-
-
-
- 5389 const char *channel,
const char *queueGroup,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+ 4725 const char *subject,
const char *queueGroup,
+
+
+
+
+ 4741 const char *subject,
const char *queueGroup);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 5000 int *maxPendingMsgs,
+ 5001 int *maxPendingBytes,
+ 5002 int64_t *deliveredMsgs,
+ 5003 int64_t *droppedMsgs);
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 5185 #if defined(NATS_HAS_STREAMING)
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 5325 const void *data,
int dataLen);
+
+
+
+ 5352 const void *data,
int dataLen,
+
+
+
+
+
+
+
+
+
+
+ 5405 const char *channel,
const char *queueGroup,
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 5944 const char *stream,
const char *consumer,
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
- 5978 const char *stream,
const char *consumer,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+ 5960 const char *stream,
const char *consumer,
+
+
+
+
+
+
+
+
+ 5994 const char *stream,
const char *consumer,
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 7761 #define MICRO_API_PREFIX "$SRV"
-
- 7766 #define MICRO_INFO_RESPONSE_TYPE "io.nats.micro.v1.info_response"
-
- 7771 #define MICRO_INFO_VERB "INFO"
-
- 7776 #define MICRO_PING_RESPONSE_TYPE "io.nats.micro.v1.ping_response"
-
- 7781 #define MICRO_PING_VERB "PING"
-
- 7786 #define MICRO_STATS_RESPONSE_TYPE "io.nats.micro.v1.stats_response"
-
- 7791 #define MICRO_STATS_VERB "STATS"
-
- 7797 #define MICRO_STATUS_HDR "Nats-Status"
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 7777 #define MICRO_API_PREFIX "$SRV"
+
+ 7782 #define MICRO_INFO_RESPONSE_TYPE "io.nats.micro.v1.info_response"
+
+ 7787 #define MICRO_INFO_VERB "INFO"
+
+ 7792 #define MICRO_PING_RESPONSE_TYPE "io.nats.micro.v1.ping_response"
+
+ 7797 #define MICRO_PING_VERB "PING"
- 7803 #define MICRO_ERROR_HDR "Nats-Service-Error"
-
- 7809 #define MICRO_ERROR_CODE_HDR "Nats-Service-Error-Code"
-
-
-
-
-
+ 7802 #define MICRO_STATS_RESPONSE_TYPE "io.nats.micro.v1.stats_response"
+
+ 7807 #define MICRO_STATS_VERB "STATS"
+
+ 7813 #define MICRO_STATUS_HDR "Nats-Status"
+
+ 7819 #define MICRO_ERROR_HDR "Nats-Service-Error"
+
+ 7825 #define MICRO_ERROR_CODE_HDR "Nats-Service-Error-Code"
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
- 8369 #define microError_Ignore(__err) microError_Destroy(__err)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+ 8385 #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
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:7455
microError *(* microRequestHandler)(microRequest *req)
Callback type for request processing.
Definition: nats.h:7431
void(* microDoneHandler)(microService *m)
Callback type for Done (service stopped) notifications.
Definition: nats.h:7468
void(* microErrorHandler)(microService *m, microEndpoint *ep, natsStatus s)
Callback type for async error notifications.
Definition: nats.h:7471
microError *(* microRequestHandler)(microRequest *req)
Callback type for request processing.
Definition: nats.h:7447
void(* microDoneHandler)(microService *m)
Callback type for Done (service stopped) notifications.
Definition: nats.h:7484
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:7286
struct micro_group_s microGroup
a collection of endpoints and other groups, with a common prefix to their subjects and names.
Definition: nats.h:7355
struct micro_request_s microRequest
a request received by a microservice endpoint.
Definition: nats.h:7362
struct micro_error_s microError
the Microservice error object.
Definition: nats.h:7346
struct __for_forward_compatibility_only microClientConfig
The Microservice configuration object. For forward compatibility only.
Definition: nats.h:7291
NATS_EXTERN microError * micro_ErrorInvalidArg
Definition: nats.h:7409
NATS_EXTERN microError * micro_ErrorOutOfMemory
Definition: nats.h:7408
struct micro_endpoint_s microEndpoint
microEndpoint represents a microservice endpoint.
Definition: nats.h:7302
struct micro_service_s microService
the main object for a configured microservice.
Definition: nats.h:7375
struct micro_client_s microClient
The Microservice client.
Definition: nats.h:7302
struct micro_group_s microGroup
a collection of endpoints and other groups, with a common prefix to their subjects and names.
Definition: nats.h:7371
struct micro_request_s microRequest
a request received by a microservice endpoint.
Definition: nats.h:7378
struct micro_error_s microError
the Microservice error object.
Definition: nats.h:7362
struct __for_forward_compatibility_only microClientConfig
The Microservice configuration object. For forward compatibility only.
Definition: nats.h:7307
NATS_EXTERN microError * micro_ErrorInvalidArg
Definition: nats.h:7425
NATS_EXTERN microError * micro_ErrorOutOfMemory
Definition: nats.h:7424
struct micro_endpoint_s microEndpoint
microEndpoint represents a microservice endpoint.
Definition: nats.h:7318
struct micro_service_s microService
the main object for a configured microservice.
Definition: nats.h:7391
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 natsOptions_SetNKeyFromSeed(natsOptions *opts, const char *pubKey, const char *seedFile)
Sets the NKey public key and its seed file.
NATS_EXTERN natsStatus natsOptions_SkipServerVerification(natsOptions *opts, bool skip)
Switch server certificate verification.
NATS_EXTERN natsStatus natsOptions_UseOldRequestStyle(natsOptions *opts, bool useOldStyle)
Switches the use of old style requests.
NATS_EXTERN natsStatus natsOptions_SetMaxPendingBytes(natsOptions *opts, int64_t maxPending)
Sets the maximum number of pending bytes per subscription.
NATS_EXTERN natsStatus natsOptions_IPResolutionOrder(natsOptions *opts, int order)
Dictates the order in which host name are resolved during connect.
NATS_EXTERN natsStatus natsOptions_SetIgnoreDiscoveredServers(natsOptions *opts, bool ignore)
Sets if the library should ignore or not discovered servers.
NATS_EXTERN natsStatus natsOptions_SetSendAsap(natsOptions *opts, bool sendAsap)
Sets if Publish calls should send data right away.
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:7489
microRequestHandler Handler
The request handler for the endpoint.
Definition: nats.h:7511
const char * Subject
The NATS subject the endpoint will listen on.
Definition: nats.h:7500
natsMetadata Metadata
Definition: nats.h:7506
void * State
A user-provided pointer to store with the endpoint (state/closure).
Definition: nats.h:7517
const char * Subject
The semantic version of the service.
Definition: nats.h:7533
const char * Name
The name of the service.
Definition: nats.h:7528
natsMetadata Metadata
Definition: nats.h:7539
const char * Subject
Definition: nats.h:7548
int64_t NumRequests
The number of requests received by the endpoint.
Definition: nats.h:7553
char LastErrorString[2048]
a copy of the last error message.
Definition: nats.h:7579
int64_t ProcessingTimeSeconds
total request processing time (the seconds part).
Definition: nats.h:7564
int64_t ProcessingTimeNanoseconds
total request processing time (the nanoseconds part).
Definition: nats.h:7569
int64_t NumErrors
The number of errors, service-level and internal, associated with the endpoint.
Definition: nats.h:7559
int64_t AverageProcessingTimeNanoseconds
average request processing time, in ns.
Definition: nats.h:7574
const char * Name
Definition: nats.h:7547
The Microservice top-level configuration object.
Definition: nats.h:7589
const char * Description
The description of the service.
Definition: nats.h:7605
void * State
A user-provided pointer to state data.
Definition: nats.h:7656
const char * Version
The (semantic) version of the service.
Definition: nats.h:7600
microErrorHandler ErrHandler
An error notification handler.
Definition: nats.h:7637
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7610
microRequestHandler StatsHandler
A custom stats handler.
Definition: nats.h:7628
microDoneHandler DoneHandler
A callback handler for handling the final cleanup Done event, right before the service is destroyed.
Definition: nats.h:7647
const char * Name
The name of the service.
Definition: nats.h:7595
microEndpointConfig * Endpoint
The "main" (aka default) endpoint configuration.
Definition: nats.h:7619
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7694
const char * Name
The name of the service.
Definition: nats.h:7674
const char * Version
The semantic version of the service.
Definition: nats.h:7679
const char * Type
Response type. Always "io.nats.micro.v1.info_response".
Definition: nats.h:7669
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7689
microEndpointInfo * Endpoints
Endpoints.
Definition: nats.h:7699
const char * Description
The description of the service.
Definition: nats.h:7684
int EndpointsLen
The number of endpoints in the Endpoints array.
Definition: nats.h:7704
int64_t Started
The timestamp of when the service was started.
Definition: nats.h:7735
int EndpointsLen
The number of endpoints in the endpoints array.
Definition: nats.h:7745
microEndpointStats * Endpoints
The stats for each endpoint of the service.
Definition: nats.h:7740
const char * Version
The semantic version of the service.
Definition: nats.h:7725
const char * Name
The name of the service.
Definition: nats.h:7720
const char * Type
Response type. Always "io.nats.micro.v1.stats_response".
Definition: nats.h:7715
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7730
const char * Name
The name of the endpoint.
Definition: nats.h:7505
microRequestHandler Handler
The request handler for the endpoint.
Definition: nats.h:7527
const char * Subject
The NATS subject the endpoint will listen on.
Definition: nats.h:7516
natsMetadata Metadata
Definition: nats.h:7522
void * State
A user-provided pointer to store with the endpoint (state/closure).
Definition: nats.h:7533
const char * Subject
The semantic version of the service.
Definition: nats.h:7549
const char * Name
The name of the service.
Definition: nats.h:7544
natsMetadata Metadata
Definition: nats.h:7555
const char * Subject
Definition: nats.h:7564
int64_t NumRequests
The number of requests received by the endpoint.
Definition: nats.h:7569
char LastErrorString[2048]
a copy of the last error message.
Definition: nats.h:7595
int64_t ProcessingTimeSeconds
total request processing time (the seconds part).
Definition: nats.h:7580
int64_t ProcessingTimeNanoseconds
total request processing time (the nanoseconds part).
Definition: nats.h:7585
int64_t NumErrors
The number of errors, service-level and internal, associated with the endpoint.
Definition: nats.h:7575
int64_t AverageProcessingTimeNanoseconds
average request processing time, in ns.
Definition: nats.h:7590
const char * Name
Definition: nats.h:7563
The Microservice top-level configuration object.
Definition: nats.h:7605
const char * Description
The description of the service.
Definition: nats.h:7621
void * State
A user-provided pointer to state data.
Definition: nats.h:7672
const char * Version
The (semantic) version of the service.
Definition: nats.h:7616
microErrorHandler ErrHandler
An error notification handler.
Definition: nats.h:7653
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7626
microRequestHandler StatsHandler
A custom stats handler.
Definition: nats.h:7644
microDoneHandler DoneHandler
A callback handler for handling the final cleanup Done event, right before the service is destroyed.
Definition: nats.h:7663
const char * Name
The name of the service.
Definition: nats.h:7611
microEndpointConfig * Endpoint
The "main" (aka default) endpoint configuration.
Definition: nats.h:7635
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7710
const char * Name
The name of the service.
Definition: nats.h:7690
const char * Version
The semantic version of the service.
Definition: nats.h:7695
const char * Type
Response type. Always "io.nats.micro.v1.info_response".
Definition: nats.h:7685
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7705
microEndpointInfo * Endpoints
Endpoints.
Definition: nats.h:7715
const char * Description
The description of the service.
Definition: nats.h:7700
int EndpointsLen
The number of endpoints in the Endpoints array.
Definition: nats.h:7720
int64_t Started
The timestamp of when the service was started.
Definition: nats.h:7751
int EndpointsLen
The number of endpoints in the endpoints array.
Definition: nats.h:7761
microEndpointStats * Endpoints
The stats for each endpoint of the service.
Definition: nats.h:7756
const char * Version
The semantic version of the service.
Definition: nats.h:7741
const char * Name
The name of the service.
Definition: nats.h:7736
const char * Type
Response type. Always "io.nats.micro.v1.stats_response".
Definition: nats.h:7731
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7746