* Call an other action. It creates a sub-context. * * @param {String} actionName * @param {Object=} params * @param {Object=} _opts * @retur

* Initializes Regenerator * * @param {ServiceBroker} broker * * @memberof Regenerator

* Stop Tracer.

* Create a new service by schema * * @param {ServiceSchema} schema Schema of service or a Service class * @param {ServiceSchema=} schemaMods Mod

* Start span. * * @param {Number=} time * @returns {Span} * @memberof Span

* @param {GaugeMetricOptions|CounterMetricOptions|HistogramMetricOptions|InfoMetricOptions} opts * @returns {CounterMetric | GaugeMetric | Histogram

* Log a trace event. * * @param {String} name * @param {Object?} fields * @param {Number?} time * @returns {Span} * @memberof Span

* Calculate 8 bit integer hash from string key based on MD5 hash. * * @param {String} key * @returns {Number} * @memberof ShardStrategy

* Emit an event (grouped & balanced global event) * * @param {string} eventName * @param {any=} data * @param {Object=} opts * @returns {Pro

* Get nodeID by a hashed numeric key. * * @param {string} key * @returns {String} * @memberof ShardStrategy

* Create a new Context instance * * @param {ServiceBroker} broker * @param {ActionEndpoint|EventEndpoint} endpoint * @param {Object?} params

* Set value. * * @param {any} value * @param {Object?} labels * @param {Number?} timestamp * @returns * @memberof InfoMetric

* Observe a metric. * * @param {String} name * @param {Number} value * @param {Object=} labels * @param {Number=} timestamp * @returns *

* Increment a metric value. * * @param {String} name * @param {Object=} labels * @param {number=} [value=1] * @param {Number=} timestamp *

* Broadcast an event for all local services * * @param {string} eventName * @param {any=} payload * @param {Object=} opts * @returns * *

* Connect with transporter. If failed, try again after 5 sec. * * @memberof Transit

* Get a cache key by name and params. * Concatenate the name and the hashed params object * * @param {Object} action * @param {Object} opts

* Switch the console to REPL mode. * * @example * broker.start().then(() => broker.repl()); * @returns

* Set a content by key to cache * * @param {any} key * @param {any} data * @param {Number?} ttl * * @returns {Promise<any>} * @memberof

* Get a cached content by key * * @param {any} key * * @returns {Promise<any>} * @memberof Cacher

* Serializer a JS object to Buffer * * @param {Object} obj * @param {String?} type * @returns {Buffer} * * @memberof Serializer

* Bind UDP port * * @returns {Promise} * @memberof UdpServer

* Parse Service schema & register as local service * * @param {Partial<ServiceSchema>} schema of Service

* Load a service from file * * @param {string} filePath * @returns {Service} * * @memberof ServiceBroker

* Publish via transporter * * @param {Packet} packet * * @memberof Transit

* Called when a span finished. Call exporters. * * @param {Span} span * @memberof Tracer

* Handle incoming request stream. * * @param {Object} payload * @returns {Stream|false|null}

* Handle incoming response stream. * * @param {Object} packet * @param {Object} req

* Deserialize Buffer to JS object * * @param {Buffer} buf * @param {String?} type * @returns {any} * * @memberof Serializer

* Select an endpoint. * * @param {Endpoint[]} list * @param {Context?} ctx * @returns {Endpoint} * @memberof BaseStrategy

* Emit an event for all local & remote services * * @param {string} eventName * @param {any=} data * @param {Object=} opts * @returns {Promi

* Register cacher as a middleware * * @memberof Cacher

* Resolve cacher by name * * @param {Record<string,any>|string|boolean} opt * @returns {any}

* List all registered metrics with labels & values. * * @param {MetricListOptions?} opts

* Set params of context * * @param {Object} newParams * @param {Boolean} cloning * * @memberof Context

* Called when a span started. Call exporters. * * @param {Span} span * @memberof Tracer

* Wait for other services * * @param {string | ServiceDependency | (string | ServiceDependency)[]} serviceNames * @param {number?} timeout Timeo

* Convert Context to a printable POJO object.

* Delete a node by nodeID * * @param {String} id * @returns * @memberof NodeCatalog

* Prepublish a packet. Handle balancing. * * @param {Packet} packet * @returns {Promise} * @memberof BaseTransporter

* Get count of registered middlewares * * @returns {Number} * @memberof MiddlewareHandler

* Fatal error. Print the message to console and exit the process (if need) * * @param {String} message * @param {Error=} err * @param {boolean

* Start a new child tracing span. * * @param {String} name * @param {Object=} opts * @returns {Span} * @memberof Context

* Update properties * * @param {NodeRawInfo} payload * @param {boolean} isReconnected * @memberof Node

* Decrement a metric value. * * @param {String} name * @param {Object=} labels * @param {number=} [value=1] * @param {Number=} timestamp *

* Get a custom logger for sub-modules (service, transporter, cacher, context...etc) * * @param {String} mod Name of module * @param {Record<stri

* Flush queued log entries to the file.

* Match the metric name. Check the `includes` & `excludes` patterns. * * @param {String} name * @returns {boolean} * @memberof MetricBaseRepor

* Format metric name. Add prefix, suffix and call custom formatter. * * @param {String} name * @returns {String} * @memberof MetricBaseReporte

* Check a node exist by nodeID * * @param {String} id * @returns * @memberof NodeCatalog

* Check metrics are enabled. * * @returns {boolean} * @memberof ServiceBroker

* Decide that span should be sampled. * * @param {Span} span * @returns {Boolean} * @memberof Tracer

* Subscribe to a command

* Start a timer & observe the elapsed time. * * @param {String} name * @param {Object?} labels * @param {Number?} timestamp * @returns {() =

* Get a local service by name * * Example: * getLocalService("v2.posts"); * getLocalService({ name: "posts", version: 2 }); * * @param {

* Message handler for incoming packets * * @param {string} cmd * @param {Packet} packet * @returns {Promise} If packet is processed resolve wi

* Get next endpoint * * @param {Context} ctx * @returns {Endpoint | null} * @memberof EndpointList

* Convert Context ID to Zipkin format * * @param {String} id * @returns {String}

* Check the service equals params * * @param {String} fullName * @param {String=} nodeID * @returns * @memberof ServiceItem

* Produces a random integer number between the inclusive lower and upper bounds. * * @param {Number} a * @param {Number} b * @returns {Number}

* Finish an active span. * * @param {Span} span * @param {Number=} time

* Flattening tags to one-level object. * E.g. * **From:** * ```js * { * error: { * name: "MoleculerError" * } * } * ```

* Local service registry has been changed. We should notify remote nodes. * * @param {String=} nodeID * @returns {Promise<void>}

* Disconnect with transporter * * @memberof Transit

* Create a hash from label values. It will * be used as a key in Map. * * @param {Object} labels * @returns {String} * @memberof BaseMetric

* Wrap a method with middlewares * * @param {string} name * @param {Function} handler * @param {any=} bindTo * @param {Object=} opts * @re

* Add tags. It will be merged with previous tags. * * @param {Object} obj * @returns {Span} * * @memberof Span

* Close the TCP sockets. * * @memberof TcpWriter

* Get a color for the module name.

* Destroy a local service * * @param {Service|string|ServiceDependency} service * @returns Promise<void> * @memberof ServiceBroker

* * @param {LoggerBindings} bindings

* Convert Trace/Span ID to Jaeger format * * @param {String} id * @returns {Buffer}

* Convert Trace ID to Jaeger format. Return 128 bit IDs or 64 bit IDs if legacy is set. * * @param {String} id * @returns {String}

* Get metric item by labels * * @param {Object?} labels * @returns {Object} * @memberof BaseMetric

* Check there is local endpoint * * @returns {boolean} * @memberof EndpointList

* Multiple action calls. * * @template TResult * @param {Record<string, MCallDefinition>|MCallDefinition[]} def * @param {MCallCallingOptions=

* Create an external action handler for broker (internal command!) * * @param {Object|Function} actionDef * @param {String} name * @returns {O

* Metric has been changed. * @param {any=} value * @param {Object=} labels * @param {Number=} timestamp