+◆ kvStore_WatchMulti()
+
+
+
+
Returns a watcher for any updates to keys that match the one of keys argument, which could include wildcards.
+
A NULL entry will be posted when the watcher has received all initial values.
+
Call kvWatcher_Next to get the next kvEntry.
+
- Note
- The watcher should be destroyed to release memory using kvWatcher_Destroy.
+
- Parameters
-
+
+ | new_watcher | the location where to store the pointer to the new kvWatcher object. |
+ | kv | the pointer to the kvStore object. |
+ | keys | the keys (wildcard possible) to create the watcher for. |
+ | numKeys | the number of keys in the keys array. |
+ | opts | the watcher options, possibly NULL. |
+
+
+
+
| NATS_EXTERN natsStatus | js_Subscribe (natsSubscription **sub, jsCtx *js, const char *subject, natsMsgHandler cb, void *cbClosure, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode) |
| | Create an asynchronous subscription. More...
|
| |
+| NATS_EXTERN natsStatus | js_SubscribeMulti (natsSubscription **sub, jsCtx *js, const char **subjects, int numSubjects, natsMsgHandler cb, void *cbClosure, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode) |
+| | Create an asynchronous subscription to multiple subjects. More...
|
+| |
| NATS_EXTERN natsStatus | js_SubscribeSync (natsSubscription **sub, jsCtx *js, const char *subject, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode) |
| | Create a synchronous subscription. More...
|
| |
+| NATS_EXTERN natsStatus | js_SubscribeSyncMulti (natsSubscription **sub, jsCtx *js, const char **subjects, int numSubjects, jsOptions *jsOpts, jsSubOptions *opts, jsErrCode *errCode) |
+| | Create an asynchronous subscription to multiple subjects. More...
|
+| |
| NATS_EXTERN natsStatus | js_PullSubscribe (natsSubscription **sub, jsCtx *js, const char *subject, const char *durable, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode) |
| | Create a pull subscriber. More...
|
| |
@@ -1444,6 +1450,9 @@
| NATS_EXTERN natsStatus | kvStore_Watch (kvWatcher **new_watcher, kvStore *kv, const char *keys, kvWatchOptions *opts) |
| | Returns a watcher for any updates to keys that match the keys argument. More...
|
| |
+| NATS_EXTERN natsStatus | kvStore_WatchMulti (kvWatcher **new_watcher, kvStore *kv, const char **keys, int numKeys, kvWatchOptions *opts) |
+| | Returns a watcher for any updates to keys that match one of the keys argument. More...
|
+| |
| NATS_EXTERN natsStatus | kvStore_WatchAll (kvWatcher **new_watcher, kvStore *kv, kvWatchOptions *opts) |
| | Returns a watcher for any updates to any keys of the KeyValue store bucket. More...
|
| |
diff --git a/doc/html/nats_8h.js b/doc/html/nats_8h.js
index 974d959fa..508d18301 100644
--- a/doc/html/nats_8h.js
+++ b/doc/html/nats_8h.js
@@ -405,7 +405,9 @@ var nats_8h =
[ "js_PublishAsyncGetPendingList", "group__js_pub_group.html#ga2ac95a3450f77f8074fae3f2fbe7e54c", null ],
[ "jsSubOptions_Init", "group__js_sub_group.html#ga472adb949d1af9d8f07bda99f5d7f3f8", null ],
[ "js_Subscribe", "group__js_sub_group.html#gaa686c6efd84ef963de1925108e896515", null ],
+ [ "js_SubscribeMulti", "group__js_sub_group.html#gacb33da7a1644f8cad9d3c202a006bc91", null ],
[ "js_SubscribeSync", "group__js_sub_group.html#gabacb010031e535f9fb6e2167337e8adf", null ],
+ [ "js_SubscribeSyncMulti", "group__js_sub_group.html#ga87c1e984425049924c6d50597c3f579f", null ],
[ "js_PullSubscribe", "group__js_sub_group.html#gaaeaddb73857aa4eb4901eec945ed27cd", null ],
[ "natsSubscription_Fetch", "group__js_sub_group.html#gafc5e0d2269bd23b4d5fb7f3b05278e50", null ],
[ "jsFetchRequest_Init", "group__js_sub_group.html#ga1c3a62de8cd4855ae61ea4f67417a43b", null ],
@@ -451,6 +453,7 @@ var nats_8h =
[ "kvPurgeOptions_Init", "group__kv_group.html#ga243113fd7df34ce104850ab888f04021", null ],
[ "kvStore_PurgeDeletes", "group__kv_group.html#ga34ab74b229ff88e64301ea53a274da69", null ],
[ "kvStore_Watch", "group__kv_group.html#ga30feca870f580c7b9d2ad07a740505b2", null ],
+ [ "kvStore_WatchMulti", "group__kv_group.html#ga409bfd787a87d0e37b69d3711fdb28f4", null ],
[ "kvStore_WatchAll", "group__kv_group.html#gaf011f1dd6813391c65664e982747602e", null ],
[ "kvStore_Keys", "group__kv_group.html#ga6030fc2a672ae868f7603587245b9d5a", null ],
[ "kvKeysList_Destroy", "group__kv_group.html#ga02ccd58bc5062f6ce6f94bf05e3dfe45", null ],
diff --git a/doc/html/nats_8h_source.html b/doc/html/nats_8h_source.html
index 3fbad2482..83d4342d2 100644
--- a/doc/html/nats_8h_source.html
+++ b/doc/html/nats_8h_source.html
@@ -1751,517 +1751,529 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
+
+
-
-
-
-
+
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
- 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"
-
- 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"
-
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+ 7840 #define MICRO_API_PREFIX "$SRV"
+
+ 7845 #define MICRO_INFO_RESPONSE_TYPE "io.nats.micro.v1.info_response"
+
+ 7850 #define MICRO_INFO_VERB "INFO"
+
+ 7855 #define MICRO_PING_RESPONSE_TYPE "io.nats.micro.v1.ping_response"
+
+ 7860 #define MICRO_PING_VERB "PING"
+
+ 7865 #define MICRO_STATS_RESPONSE_TYPE "io.nats.micro.v1.stats_response"
+
+ 7870 #define MICRO_STATS_VERB "STATS"
+
+ 7876 #define MICRO_STATUS_HDR "Nats-Status"
+
+ 7882 #define MICRO_ERROR_HDR "Nats-Service-Error"
+
+ 7888 #define MICRO_ERROR_CODE_HDR "Nats-Service-Error-Code"
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
-
+
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
+
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 8385 #define microError_Ignore(__err) microError_Destroy(__err)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 8448 #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 jsFetchRequest_Init(jsFetchRequest *request)
Initializes a fetch request options structure.
NATS_EXTERN natsStatus jsSubOptions_Init(jsSubOptions *opts)
Initializes a subscribe options structure.
NATS_EXTERN natsStatus natsSubscription_FetchRequest(natsMsgList *list, natsSubscription *sub, jsFetchRequest *request)
Fetches messages for a pull subscription with a complete request configuration.
NATS_EXTERN natsStatus js_SubscribeSyncMulti(natsSubscription **sub, jsCtx *js, const char **subjects, int numSubjects, jsOptions *jsOpts, jsSubOptions *opts, jsErrCode *errCode)
Create an asynchronous subscription to multiple subjects.
NATS_EXTERN natsStatus js_Subscribe(natsSubscription **sub, jsCtx *js, const char *subject, natsMsgHandler cb, void *cbClosure, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode)
Create an asynchronous subscription.
NATS_EXTERN natsStatus natsSubscription_GetConsumerInfo(jsConsumerInfo **ci, natsSubscription *sub, jsOptions *opts, jsErrCode *errCode)
Returns the jsConsumerInfo associated with this subscription.
NATS_EXTERN natsStatus js_PullSubscribe(natsSubscription **sub, jsCtx *js, const char *subject, const char *durable, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode)
Create a pull subscriber.
NATS_EXTERN natsStatus js_SubscribeSync(natsSubscription **sub, jsCtx *js, const char *subject, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode)
Create a synchronous subscription.
NATS_EXTERN natsStatus js_SubscribeMulti(natsSubscription **sub, jsCtx *js, const char **subjects, int numSubjects, natsMsgHandler cb, void *cbClosure, jsOptions *opts, jsSubOptions *subOpts, jsErrCode *errCode)
Create an asynchronous subscription to multiple subjects.
NATS_EXTERN natsStatus natsSubscription_Fetch(natsMsgList *list, natsSubscription *sub, int batch, int64_t timeout, jsErrCode *errCode)
Fetches messages for a pull subscription.
NATS_EXTERN kvOperation kvEntry_Operation(kvEntry *e)
Returns the type of operation of this value.
NATS_EXTERN uint64_t kvEntry_Delta(kvEntry *e)
Returns the distance from the latest value.
NATS_EXTERN natsStatus kvStore_Watch(kvWatcher **new_watcher, kvStore *kv, const char *keys, kvWatchOptions *opts)
Returns a watcher for any updates to keys that match the keys argument.
NATS_EXTERN natsStatus kvStore_PurgeDeletes(kvStore *kv, kvPurgeOptions *opts)
Purge and removes delete markers.
NATS_EXTERN natsStatus kvStore_Purge(kvStore *kv, const char *key, kvPurgeOptions *opts)
Deletes a key by placing a purge marker and removing all revisions.
NATS_EXTERN natsStatus kvStore_WatchMulti(kvWatcher **new_watcher, kvStore *kv, const char **keys, int numKeys, kvWatchOptions *opts)
Returns a watcher for any updates to keys that match one of the keys argument.
NATS_EXTERN natsStatus kvStore_Create(uint64_t *rev, kvStore *kv, const char *key, const void *data, int len)
Places the value for the key into the store if and only if the key does not exist.
NATS_EXTERN natsStatus kvStore_CreateString(uint64_t *rev, kvStore *kv, const char *key, const char *data)
Places the value (as a string) for the key into the store if and only if the key does not exist.
NATS_EXTERN natsStatus kvStore_History(kvEntryList *list, kvStore *kv, const char *key, kvWatchOptions *opts)
Returns all historical entries for the key.
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: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
void(* microErrorHandler)(microService *m, microEndpoint *ep, natsStatus s)
Callback type for async error notifications.
Definition: nats.h:7534
microError *(* microRequestHandler)(microRequest *req)
Callback type for request processing.
Definition: nats.h:7510
void(* microDoneHandler)(microService *m)
Callback type for Done (service stopped) notifications.
Definition: nats.h:7547
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: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
struct micro_client_s microClient
The Microservice client.
Definition: nats.h:7365
struct micro_group_s microGroup
a collection of endpoints and other groups, with a common prefix to their subjects and names.
Definition: nats.h:7434
struct micro_request_s microRequest
a request received by a microservice endpoint.
Definition: nats.h:7441
struct micro_error_s microError
the Microservice error object.
Definition: nats.h:7425
struct __for_forward_compatibility_only microClientConfig
The Microservice configuration object. For forward compatibility only.
Definition: nats.h:7370
NATS_EXTERN microError * micro_ErrorInvalidArg
NATS_EXTERN microError * micro_ErrorOutOfMemory
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
struct micro_endpoint_s microEndpoint
microEndpoint represents a microservice endpoint.
Definition: nats.h:7381
struct micro_service_s microService
the main object for a configured microservice.
Definition: nats.h:7454
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.
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: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
const char * Name
The name of the endpoint.
Definition: nats.h:7568
microRequestHandler Handler
The request handler for the endpoint.
Definition: nats.h:7590
const char * Subject
The NATS subject the endpoint will listen on.
Definition: nats.h:7579
natsMetadata Metadata
Definition: nats.h:7585
void * State
A user-provided pointer to store with the endpoint (state/closure).
Definition: nats.h:7596
const char * Subject
The semantic version of the service.
Definition: nats.h:7612
const char * Name
The name of the service.
Definition: nats.h:7607
natsMetadata Metadata
Definition: nats.h:7618
const char * Subject
Definition: nats.h:7627
int64_t NumRequests
The number of requests received by the endpoint.
Definition: nats.h:7632
char LastErrorString[2048]
a copy of the last error message.
Definition: nats.h:7658
int64_t ProcessingTimeSeconds
total request processing time (the seconds part).
Definition: nats.h:7643
int64_t ProcessingTimeNanoseconds
total request processing time (the nanoseconds part).
Definition: nats.h:7648
int64_t NumErrors
The number of errors, service-level and internal, associated with the endpoint.
Definition: nats.h:7638
int64_t AverageProcessingTimeNanoseconds
average request processing time, in ns.
Definition: nats.h:7653
const char * Name
Definition: nats.h:7626
The Microservice top-level configuration object.
Definition: nats.h:7668
const char * Description
The description of the service.
Definition: nats.h:7684
void * State
A user-provided pointer to state data.
Definition: nats.h:7735
const char * Version
The (semantic) version of the service.
Definition: nats.h:7679
microErrorHandler ErrHandler
An error notification handler.
Definition: nats.h:7716
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7689
microRequestHandler StatsHandler
A custom stats handler.
Definition: nats.h:7707
microDoneHandler DoneHandler
A callback handler for handling the final cleanup Done event, right before the service is destroyed.
Definition: nats.h:7726
const char * Name
The name of the service.
Definition: nats.h:7674
microEndpointConfig * Endpoint
The "main" (aka default) endpoint configuration.
Definition: nats.h:7698
natsMetadata Metadata
Metadata for the service, a JSON-encoded user-provided object, e.g. {"key":"value"}
Definition: nats.h:7773
const char * Name
The name of the service.
Definition: nats.h:7753
const char * Version
The semantic version of the service.
Definition: nats.h:7758
const char * Type
Response type. Always "io.nats.micro.v1.info_response".
Definition: nats.h:7748
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7768
microEndpointInfo * Endpoints
Endpoints.
Definition: nats.h:7778
const char * Description
The description of the service.
Definition: nats.h:7763
int EndpointsLen
The number of endpoints in the Endpoints array.
Definition: nats.h:7783
int64_t Started
The timestamp of when the service was started.
Definition: nats.h:7814
int EndpointsLen
The number of endpoints in the endpoints array.
Definition: nats.h:7824
microEndpointStats * Endpoints
The stats for each endpoint of the service.
Definition: nats.h:7819
const char * Version
The semantic version of the service.
Definition: nats.h:7804
const char * Name
The name of the service.
Definition: nats.h:7799
const char * Type
Response type. Always "io.nats.micro.v1.stats_response".
Definition: nats.h:7794
const char * Id
The ID of the service instance responding to the request.
Definition: nats.h:7809