From 6e9a91b02121c2a0a003a47040a332b5b88fe2fe Mon Sep 17 00:00:00 2001 From: Icebob Date: Sat, 9 Dec 2023 15:59:59 +0100 Subject: [PATCH] format d.ts --- src/cachers/index.d.ts | 2 +- src/cachers/redis.d.ts | 1 - src/context.d.ts | 24 ++++++---- src/errors.d.ts | 13 +++--- src/loggers/base.d.ts | 6 +-- src/loggers/bunyan.d.ts | 3 +- src/loggers/console.d.ts | 1 - src/loggers/datadog.d.ts | 16 +++---- src/loggers/debug.d.ts | 1 - src/loggers/file.d.ts | 9 ++-- src/loggers/formatted.d.ts | 17 +++---- src/loggers/log4js.d.ts | 3 +- src/loggers/pino.d.ts | 7 ++- src/loggers/winston.d.ts | 7 ++- src/metrics/constants.d.ts | 33 +++++++++----- src/metrics/registry.d.ts | 54 ++++++++++++++--------- src/metrics/reporters/base.d.ts | 2 +- src/metrics/reporters/console.d.ts | 4 +- src/metrics/reporters/csv.d.ts | 6 +-- src/metrics/reporters/datadog.d.ts | 6 +-- src/metrics/reporters/event.d.ts | 2 +- src/metrics/reporters/index.d.ts | 2 +- src/metrics/reporters/prometheus.d.ts | 8 ++-- src/metrics/reporters/statsd.d.ts | 12 ++--- src/metrics/types/histogram.d.ts | 11 ++--- src/metrics/types/index.d.ts | 4 +- src/registry/action-catalog.d.ts | 8 ++-- src/registry/discoverers/base.d.ts | 1 - src/registry/discoverers/etcd3.d.ts | 3 +- src/registry/discoverers/index.d.ts | 2 +- src/registry/discoverers/local.d.ts | 1 - src/registry/discoverers/redis.d.ts | 5 +-- src/registry/endpoint-action.d.ts | 8 +++- src/registry/endpoint-event.d.ts | 8 +++- src/registry/endpoint-list.d.ts | 40 ++++++++++------- src/registry/endpoint.d.ts | 1 - src/registry/event-catalog.d.ts | 26 ++++++----- src/registry/node-catalog.d.ts | 16 +++---- src/registry/registry.d.ts | 23 +++++----- src/registry/service-catalog.d.ts | 11 +++-- src/registry/service-item.d.ts | 2 +- src/runner.d.ts | 5 +-- src/serializers/base.d.ts | 8 ++-- src/serializers/cbor.d.ts | 4 +- src/serializers/index.d.ts | 2 +- src/serializers/json-extended.d.ts | 6 +-- src/serializers/json.d.ts | 4 +- src/serializers/msgpack.d.ts | 4 +- src/serializers/notepack.d.ts | 4 +- src/service-broker.d.ts | 42 ++++++++++-------- src/service.d.ts | 4 +- src/strategies/base.d.ts | 2 +- src/strategies/cpu-usage.d.ts | 8 ++-- src/strategies/index.d.ts | 4 +- src/strategies/latency.d.ts | 8 ++-- src/strategies/random.d.ts | 1 - src/strategies/round-robin.d.ts | 1 - src/strategies/shard.d.ts | 11 +++-- src/tracing/exporters/datadog.d.ts | 5 +-- src/tracing/exporters/index.d.ts | 2 +- src/tracing/exporters/newrelic.d.ts | 6 +-- src/tracing/exporters/zipkin.d.ts | 6 +-- src/tracing/rate-limiter.d.ts | 14 +++--- src/tracing/span.d.ts | 12 ++--- src/tracing/tracer.d.ts | 50 ++++++++++++--------- src/transit.d.ts | 15 ++++--- src/transporters/amqp.d.ts | 6 +-- src/transporters/amqp10.d.ts | 6 +-- src/transporters/fake.d.ts | 4 +- src/transporters/index.d.ts | 2 +- src/transporters/kafka.d.ts | 1 - src/transporters/mqtt.d.ts | 1 - src/transporters/nats.d.ts | 1 - src/transporters/redis.d.ts | 5 +-- src/transporters/tcp.d.ts | 30 ++++++------- src/transporters/tcp/constants.d.ts | 4 +- src/transporters/tcp/parser.d.ts | 8 ++-- src/transporters/tcp/tcp-writer.d.ts | 22 ++++----- src/transporters/tcp/udp-broadcaster.d.ts | 39 +++++++++------- src/utils.d.ts | 16 ++++--- src/validators/base.d.ts | 1 - src/validators/fastest.d.ts | 7 +-- src/validators/index.d.ts | 2 +- 83 files changed, 427 insertions(+), 365 deletions(-) diff --git a/src/cachers/index.d.ts b/src/cachers/index.d.ts index db635b4d5..ac4a1f900 100644 --- a/src/cachers/index.d.ts +++ b/src/cachers/index.d.ts @@ -10,5 +10,5 @@ export { RedisCacher as Redis }; -export declare function resolve(opt: Record|string|boolean): Cacher; +export declare function resolve(opt: Record | string | boolean): Cacher; export declare function register(name: string, value: Cacher): void; diff --git a/src/cachers/redis.d.ts b/src/cachers/redis.d.ts index 91d076e20..57104d94a 100644 --- a/src/cachers/redis.d.ts +++ b/src/cachers/redis.d.ts @@ -26,7 +26,6 @@ declare class RedisCacher extends BaseCacher { clean(match?: string | string[]): Promise; tryLock(key: string | string[], ttl?: number): Promise<() => Promise>; lock(key: string | string[], ttl?: number): Promise<() => Promise>; - } export = RedisCacher; diff --git a/src/context.d.ts b/src/context.d.ts index 8c7f152d0..78d16d95f 100644 --- a/src/context.d.ts +++ b/src/context.d.ts @@ -9,7 +9,6 @@ import { Stream } from "stream"; import util = require("util"); declare namespace Context { - export interface ContextParentSpan { id: string; traceID: string; @@ -17,15 +16,24 @@ declare namespace Context { } } -declare class Context, THeaders = Record> { +declare class Context< + TParams = unknown, + TMeta extends object = {}, + TLocals = Record, + THeaders = Record +> { static create( broker: ServiceBroker, - endpoint: ActionEndpoint|EventEndpoint, + endpoint: ActionEndpoint | EventEndpoint, params: Record, opts: Record ): Context; - static create(broker: ServiceBroker, endpoint: ActionEndpoint|EventEndpoint, params: Record): Context; - static create(broker: ServiceBroker, endpoint: ActionEndpoint|EventEndpoint): Context; + static create( + broker: ServiceBroker, + endpoint: ActionEndpoint | EventEndpoint, + params: Record + ): Context; + static create(broker: ServiceBroker, endpoint: ActionEndpoint | EventEndpoint): Context; static create(broker: ServiceBroker): Context; id: string; @@ -80,9 +88,9 @@ declare class Context(eventName: string, data: D, opts?: Record): Promise; broadcast(eventName: string): Promise; - copy(endpoint: ActionEndpoint|EventEndpoint): this; + copy(endpoint: ActionEndpoint | EventEndpoint): this; copy(): this; startSpan(name: string, opts?: Record): Span; diff --git a/src/errors.d.ts b/src/errors.d.ts index 430c732ba..ef5a34bda 100644 --- a/src/errors.d.ts +++ b/src/errors.d.ts @@ -101,14 +101,15 @@ export declare class Regenerator { extractPlainError(err: Record, payload?: Record): PlainMoleculerError; - restoreCustomError( - plainError: PlainMoleculerError, - payload: Record - ): Error; + restoreCustomError(plainError: PlainMoleculerError, payload: Record): Error; private _createDefaultError(plainError: PlainMoleculerError): Error; - private _restoreExternalFields(plainError: PlainMoleculerError, err: PlainMoleculerError, payload: Record): void; + private _restoreExternalFields( + plainError: PlainMoleculerError, + err: PlainMoleculerError, + payload: Record + ): void; private _restoreStack(plainError: PlainMoleculerError, err: Error): void; } -export declare function resolveRegenerator(opts?: Regenerator): Regenerator +export declare function resolveRegenerator(opts?: Regenerator): Regenerator; diff --git a/src/loggers/base.d.ts b/src/loggers/base.d.ts index 551edad2a..95e8ddf53 100644 --- a/src/loggers/base.d.ts +++ b/src/loggers/base.d.ts @@ -8,7 +8,7 @@ declare namespace BaseLogger { export interface LoggerOptions { level?: LogLevels; - createLogger?: Function + createLogger?: Function; } // export const BaseLogger; @@ -17,8 +17,8 @@ declare namespace BaseLogger { declare abstract class BaseLogger { constructor(opts?: T); - loggerFactory: LoggerFactory; - broker: ServiceBroker; + loggerFactory: LoggerFactory; + broker: ServiceBroker; opts: T; diff --git a/src/loggers/bunyan.d.ts b/src/loggers/bunyan.d.ts index f758513f4..780652038 100644 --- a/src/loggers/bunyan.d.ts +++ b/src/loggers/bunyan.d.ts @@ -6,9 +6,8 @@ import type { LoggerOptions } from "./base"; import type { LoggerOptions as BunyanNativeLoggerOptions } from "bunyan"; declare namespace BunyanLogger { - export interface BunyanLoggerOptions extends LoggerOptions { - bunyan?: BunyanNativeLoggerOptions + bunyan?: BunyanNativeLoggerOptions; } } diff --git a/src/loggers/console.d.ts b/src/loggers/console.d.ts index 28c12b3fa..68091fd55 100644 --- a/src/loggers/console.d.ts +++ b/src/loggers/console.d.ts @@ -5,7 +5,6 @@ import FormattedLogger = require("./formatted"); import type { FormattedLoggerOptions } from "./formatted"; declare namespace ConsoleLogger { - export interface ConsoleLoggerOptions extends FormattedLoggerOptions {} } diff --git a/src/loggers/datadog.d.ts b/src/loggers/datadog.d.ts index c38ff5f90..58087fde7 100644 --- a/src/loggers/datadog.d.ts +++ b/src/loggers/datadog.d.ts @@ -4,16 +4,14 @@ import BaseLogger = require("./base"); import type { LoggerOptions } from "./base"; declare namespace DatadogLogger { - export interface DatadogLoggerOptions extends LoggerOptions { - url?: string, - apiKey?: string, - ddSource?: string, - env?: string, - hostname?: string, - objectPrinter?: (obj: any) => string, - interval?: number - + url?: string; + apiKey?: string; + ddSource?: string; + env?: string; + hostname?: string; + objectPrinter?: (obj: any) => string; + interval?: number; } } diff --git a/src/loggers/debug.d.ts b/src/loggers/debug.d.ts index 8eb93fe9b..151008cf2 100644 --- a/src/loggers/debug.d.ts +++ b/src/loggers/debug.d.ts @@ -4,7 +4,6 @@ import BaseLogger = require("./base"); import type { LoggerOptions } from "./base"; declare namespace DebugLogger { - export interface DebugLoggerOptions extends LoggerOptions {} } diff --git a/src/loggers/file.d.ts b/src/loggers/file.d.ts index 23e1a601a..3b5e89191 100644 --- a/src/loggers/file.d.ts +++ b/src/loggers/file.d.ts @@ -5,12 +5,11 @@ import FormattedLogger = require("./formatted"); import type { FormattedLoggerOptions } from "./formatted"; declare namespace FileLogger { - export interface FileLoggerOptions extends FormattedLoggerOptions { - folder?: string, - filename?: string, - eol?: string, - interval?: number + folder?: string; + filename?: string; + eol?: string; + interval?: number; } } diff --git a/src/loggers/formatted.d.ts b/src/loggers/formatted.d.ts index 6601641c8..ae259a508 100644 --- a/src/loggers/formatted.d.ts +++ b/src/loggers/formatted.d.ts @@ -4,22 +4,23 @@ import BaseLogger = require("./base"); import type { LoggerOptions } from "./base"; declare namespace FormattedLogger { - export type FormatterFunction = (type: string, args: any[]) => string[]; export interface FormattedLoggerOptions extends LoggerOptions { - colors?: boolean, - moduleColors?: boolean|string[], - formatter?: FormatterFunction|"json"|"jsonext"|"simple"|"short"|"full", - objectPrinter?: (obj: any) => string, - autoPadding?: boolean + colors?: boolean; + moduleColors?: boolean | string[]; + formatter?: FormatterFunction | "json" | "jsonext" | "simple" | "short" | "full"; + objectPrinter?: (obj: any) => string; + autoPadding?: boolean; } } -declare class FormattedLogger extends BaseLogger { +declare class FormattedLogger< + T extends FormattedLogger.FormattedLoggerOptions +> extends BaseLogger { init(loggerFactory: LoggerFactory): void; getLogHandler(bindings: LoggerFactory.LoggerBindings): BaseLogger.LogHandler | null; - getFormatter(bindings: LoggerFactory.LoggerBindings) : FormattedLogger.FormatterFunction; + getFormatter(bindings: LoggerFactory.LoggerBindings): FormattedLogger.FormatterFunction; render(str: string, obj: Record): string; } diff --git a/src/loggers/log4js.d.ts b/src/loggers/log4js.d.ts index f8bef39ac..679ccc037 100644 --- a/src/loggers/log4js.d.ts +++ b/src/loggers/log4js.d.ts @@ -5,9 +5,8 @@ import type { LoggerOptions } from "./base"; import type { Configuration } from "log4js"; declare namespace Log4jsLogger { - export interface Log4jsLoggerOptions extends LoggerOptions { - log4js?: Configuration + log4js?: Configuration; } } diff --git a/src/loggers/pino.d.ts b/src/loggers/pino.d.ts index 18b927beb..34a08a5cb 100644 --- a/src/loggers/pino.d.ts +++ b/src/loggers/pino.d.ts @@ -4,12 +4,11 @@ import BaseLogger = require("./base"); import type { LoggerOptions } from "./base"; declare namespace PinoLogger { - export interface PinoLoggerOptions extends LoggerOptions { pino?: { - options: Record, - destination: Record, - } + options: Record; + destination: Record; + }; } } diff --git a/src/loggers/winston.d.ts b/src/loggers/winston.d.ts index efc763160..f6aa9dd71 100644 --- a/src/loggers/winston.d.ts +++ b/src/loggers/winston.d.ts @@ -4,12 +4,11 @@ import BaseLogger = require("./base"); import type { LoggerOptions } from "./base"; declare namespace WinstonLogger { - export interface WinstonLoggerOptions extends LoggerOptions { winston: { - level?: string, - [key: string]: any - } + level?: string; + [key: string]: any; + }; } } diff --git a/src/metrics/constants.d.ts b/src/metrics/constants.d.ts index 1250f1178..285f4de4c 100644 --- a/src/metrics/constants.d.ts +++ b/src/metrics/constants.d.ts @@ -3,7 +3,6 @@ export declare const TYPE_GAUGE = "gauge"; export declare const TYPE_HISTOGRAM = "histogram"; export declare const TYPE_INFO = "info"; - export declare const PROCESS_ARGUMENTS: "process.arguments"; export declare const PROCESS_PID = "process.pid"; @@ -16,17 +15,27 @@ export declare const PROCESS_MEMORY_EXTERNAL = "process.memory.external"; export declare const PROCESS_MEMORY_HEAP_SPACE_SIZE_TOTAL = "process.memory.heap.space.size.total"; export declare const PROCESS_MEMORY_HEAP_SPACE_SIZE_USED = "process.memory.heap.space.size.used"; -export declare const PROCESS_MEMORY_HEAP_SPACE_SIZE_AVAILABLE = "process.memory.heap.space.size.available"; -export declare const PROCESS_MEMORY_HEAP_SPACE_SIZE_PHYSICAL = "process.memory.heap.space.size.physical"; - -export declare const PROCESS_MEMORY_HEAP_STAT_HEAP_SIZE_TOTAL = "process.memory.heap.stat.heap.size.total"; -export declare const PROCESS_MEMORY_HEAP_STAT_EXECUTABLE_SIZE_TOTAL = "process.memory.heap.stat.executable.size.total"; -export declare const PROCESS_MEMORY_HEAP_STAT_PHYSICAL_SIZE_TOTAL = "process.memory.heap.stat.physical.size.total"; -export declare const PROCESS_MEMORY_HEAP_STAT_AVAILABLE_SIZE_TOTAL = "process.memory.heap.stat.available.size.total"; -export declare const PROCESS_MEMORY_HEAP_STAT_USED_HEAP_SIZE = "process.memory.heap.stat.used.heap.size"; -export declare const PROCESS_MEMORY_HEAP_STAT_HEAP_SIZE_LIMIT = "process.memory.heap.stat.heap.size.limit"; -export declare const PROCESS_MEMORY_HEAP_STAT_MALLOCATED_MEMORY = "process.memory.heap.stat.mallocated.memory"; -export declare const PROCESS_MEMORY_HEAP_STAT_PEAK_MALLOCATED_MEMORY = "process.memory.heap.stat.peak.mallocated.memory"; +export declare const PROCESS_MEMORY_HEAP_SPACE_SIZE_AVAILABLE = + "process.memory.heap.space.size.available"; +export declare const PROCESS_MEMORY_HEAP_SPACE_SIZE_PHYSICAL = + "process.memory.heap.space.size.physical"; + +export declare const PROCESS_MEMORY_HEAP_STAT_HEAP_SIZE_TOTAL = + "process.memory.heap.stat.heap.size.total"; +export declare const PROCESS_MEMORY_HEAP_STAT_EXECUTABLE_SIZE_TOTAL = + "process.memory.heap.stat.executable.size.total"; +export declare const PROCESS_MEMORY_HEAP_STAT_PHYSICAL_SIZE_TOTAL = + "process.memory.heap.stat.physical.size.total"; +export declare const PROCESS_MEMORY_HEAP_STAT_AVAILABLE_SIZE_TOTAL = + "process.memory.heap.stat.available.size.total"; +export declare const PROCESS_MEMORY_HEAP_STAT_USED_HEAP_SIZE = + "process.memory.heap.stat.used.heap.size"; +export declare const PROCESS_MEMORY_HEAP_STAT_HEAP_SIZE_LIMIT = + "process.memory.heap.stat.heap.size.limit"; +export declare const PROCESS_MEMORY_HEAP_STAT_MALLOCATED_MEMORY = + "process.memory.heap.stat.mallocated.memory"; +export declare const PROCESS_MEMORY_HEAP_STAT_PEAK_MALLOCATED_MEMORY = + "process.memory.heap.stat.peak.mallocated.memory"; export declare const PROCESS_MEMORY_HEAP_STAT_ZAP_GARBAGE = "process.memory.heap.stat.zap.garbage"; export declare const PROCESS_UPTIME = "process.uptime"; diff --git a/src/metrics/registry.d.ts b/src/metrics/registry.d.ts index c7edd508a..ed0dba9fc 100644 --- a/src/metrics/registry.d.ts +++ b/src/metrics/registry.d.ts @@ -20,25 +20,31 @@ declare namespace MetricRegistry { excludes?: string | string[]; } - export type MetricsReporter = { - type: "Console", - options?: ConsoleReporterOptions, - } | { - type: "CSV", - options?: ConsoleReporterOptions, - } | { - type: "Datadog", - options?: DatadogReporterOptions, - } | { - type: "Event", - options?: EventReporterOptions, - } | { - type: "Prometheus", - options?: PrometheusReporterOptions, - } | { - type: "StatsD", - options?: StatsDReporterOptions, - }; + export type MetricsReporter = + | { + type: "Console"; + options?: ConsoleReporterOptions; + } + | { + type: "CSV"; + options?: ConsoleReporterOptions; + } + | { + type: "Datadog"; + options?: DatadogReporterOptions; + } + | { + type: "Event"; + options?: EventReporterOptions; + } + | { + type: "Prometheus"; + options?: PrometheusReporterOptions; + } + | { + type: "StatsD"; + options?: StatsDReporterOptions; + }; type MetricsReporterTypes = MetricsReporter["type"]; @@ -46,7 +52,11 @@ declare namespace MetricRegistry { enabled?: boolean; collectProcessMetrics?: boolean; collectInterval?: number; - reporter?: MetricsReporterTypes | MetricsReporter | (MetricsReporter | MetricsReporterTypes)[] | null; + reporter?: + | MetricsReporterTypes + | MetricsReporter + | (MetricsReporter | MetricsReporterTypes)[] + | null; defaultBuckets?: number[]; defaultQuantiles?: number[]; defaultMaxAgeSeconds?: number; @@ -66,8 +76,8 @@ declare namespace MetricRegistry { type HistogramMetricOptions = BaseMetricOptions & { type: "histogram"; - quantiles?: boolean|number[]; - buckets?: boolean|number[]; + quantiles?: boolean | number[]; + buckets?: boolean | number[]; }; type InfoMetricOptions = BaseMetricOptions & { diff --git a/src/metrics/reporters/base.d.ts b/src/metrics/reporters/base.d.ts index 9a5d30416..e7d9ebdac 100644 --- a/src/metrics/reporters/base.d.ts +++ b/src/metrics/reporters/base.d.ts @@ -1,7 +1,7 @@ import ServiceBroker = require("../../service-broker"); import type MetricRegistry = require("../registry"); import type BaseMetric = require("../types/base"); -import type {Logger} from "../../logger-factory"; +import type { Logger } from "../../logger-factory"; declare namespace MetricBaseReporter { export interface MetricReporterOptions { diff --git a/src/metrics/reporters/console.d.ts b/src/metrics/reporters/console.d.ts index 620898906..f55b61c07 100644 --- a/src/metrics/reporters/console.d.ts +++ b/src/metrics/reporters/console.d.ts @@ -25,8 +25,8 @@ declare class ConsoleReporter extends MetricBaseReporter { constructor(opts?: ConsoleReporter.ConsoleReporterOptions); labelsToStr(labels: Record): string; - print(): void; - log(...args: any[]): any; + print(): void; + log(...args: any[]): any; metricChanged(metric: BaseMetric): void; } diff --git a/src/metrics/reporters/csv.d.ts b/src/metrics/reporters/csv.d.ts index 077a19a30..8bb71aa10 100644 --- a/src/metrics/reporters/csv.d.ts +++ b/src/metrics/reporters/csv.d.ts @@ -28,9 +28,9 @@ declare class CSVReporter extends MetricBaseReporter { constructor(opts?: CSVReporter.CSVReporterOptions); labelsToStr(labels: Record): string; - getFilename(metric: BaseMetric, item: any): any; - flush(): void; - writeRow(filename: string, headers: string[], fields: string[]): void; + getFilename(metric: BaseMetric, item: any): any; + flush(): void; + writeRow(filename: string, headers: string[], fields: string[]): void; metricChanged(metric: BaseMetric, value: any, labels?: Record): void; } diff --git a/src/metrics/reporters/datadog.d.ts b/src/metrics/reporters/datadog.d.ts index f19af19d3..77e7ff64d 100644 --- a/src/metrics/reporters/datadog.d.ts +++ b/src/metrics/reporters/datadog.d.ts @@ -22,8 +22,8 @@ declare class DatadogReporter extends MetricBaseReporter { flush(): Promise; generateDatadogSeries(): Array; - escapeLabelValue(str: string): string; - labelsToTags(itemLabels: Record): Array; - posixTimestamp(time?: number): number; + escapeLabelValue(str: string): string; + labelsToTags(itemLabels: Record): Array; + posixTimestamp(time?: number): number; } export = DatadogReporter; diff --git a/src/metrics/reporters/event.d.ts b/src/metrics/reporters/event.d.ts index 23bc74e14..a87cc3015 100644 --- a/src/metrics/reporters/event.d.ts +++ b/src/metrics/reporters/event.d.ts @@ -22,7 +22,7 @@ declare class EventReporter extends MetricBaseReporter { timer: NodeJS.Timeout; init(registry: MetricRegistry): void; - sendEvent(): void; + sendEvent(): void; metricChanged(metric: BaseMetric): void; } export = EventReporter; diff --git a/src/metrics/reporters/index.d.ts b/src/metrics/reporters/index.d.ts index 250177250..dde60919a 100644 --- a/src/metrics/reporters/index.d.ts +++ b/src/metrics/reporters/index.d.ts @@ -16,5 +16,5 @@ export { StatsDReporter as StatsD }; -export declare function resolve(opt: Record|string|boolean): MetricBaseReporter; +export declare function resolve(opt: Record | string | boolean): MetricBaseReporter; export declare function register(name: string, value: MetricBaseReporter): void; diff --git a/src/metrics/reporters/prometheus.d.ts b/src/metrics/reporters/prometheus.d.ts index 30365ae02..94682e885 100644 --- a/src/metrics/reporters/prometheus.d.ts +++ b/src/metrics/reporters/prometheus.d.ts @@ -1,6 +1,6 @@ import MetricRegistry = require("../registry"); import MetricBaseReporter = require("./base"); -import { Server, IncomingMessage, ServerResponse} from "http"; +import { Server, IncomingMessage, ServerResponse } from "http"; declare namespace PrometheusReporter { export interface PrometheusReporterOptions extends MetricBaseReporter.MetricReporterOptions { @@ -20,8 +20,8 @@ declare class PrometheusReporter extends MetricBaseReporter { stop(): Promise; handler(req: IncomingMessage, res: ServerResponse): void; - generatePrometheusResponse(): string; - escapeLabelValue(str: string): string; - labelsToStr(itemLabels: Record, extraLabels?: Record): string; + generatePrometheusResponse(): string; + escapeLabelValue(str: string): string; + labelsToStr(itemLabels: Record, extraLabels?: Record): string; } export = PrometheusReporter; diff --git a/src/metrics/reporters/statsd.d.ts b/src/metrics/reporters/statsd.d.ts index 6aa7c0582..1ef64b058 100644 --- a/src/metrics/reporters/statsd.d.ts +++ b/src/metrics/reporters/statsd.d.ts @@ -20,12 +20,12 @@ declare class StatsDReporter extends MetricBaseReporter { flush(): void; sendChunks(series: Array): void; - send(buf: Buffer): void; + send(buf: Buffer): void; - generateStatsDSeries(): Array; - generateStatDLine(metric: any, item: any, lastValue: any): string; - metricChanged(metric: BaseMetric, value: any, labels: any): void; - escapeLabelValue(str: string): string; - labelsToTags(itemLabels: Record): string; + generateStatsDSeries(): Array; + generateStatDLine(metric: any, item: any, lastValue: any): string; + metricChanged(metric: BaseMetric, value: any, labels: any): void; + escapeLabelValue(str: string): string; + labelsToTags(itemLabels: Record): string; } export = StatsDReporter; diff --git a/src/metrics/types/histogram.d.ts b/src/metrics/types/histogram.d.ts index 6b3cc8a1c..7c9f2f082 100644 --- a/src/metrics/types/histogram.d.ts +++ b/src/metrics/types/histogram.d.ts @@ -1,7 +1,6 @@ import BaseMetric = require("./base"); declare namespace HistogramMetric { - export interface HistogramMetricOptions extends BaseMetric.BaseMetricOptions { linearBuckets?: { start: number; @@ -13,8 +12,8 @@ declare namespace HistogramMetric { factor: number; count: number; }; - buckets?: boolean|number[]; - quantiles?: boolean|number[]; + buckets?: boolean | number[]; + quantiles?: boolean | number[]; maxAgeSeconds?: number; ageBuckets?: number; @@ -55,7 +54,10 @@ declare class HistogramMetric extends BaseMetric, key: string): HistogramMetric.HistogramMetricSnapshot; + generateItemSnapshot( + item: Record, + key: string + ): HistogramMetric.HistogramMetricSnapshot; resetItem(item: Record, timestamp?: number): Record; @@ -66,6 +68,5 @@ declare class HistogramMetric extends BaseMetric): void; diff --git a/src/registry/action-catalog.d.ts b/src/registry/action-catalog.d.ts index e738cdcb4..51aaf15e2 100644 --- a/src/registry/action-catalog.d.ts +++ b/src/registry/action-catalog.d.ts @@ -18,9 +18,9 @@ declare namespace ActionCatalog { } interface ActionEndpointList { - nodeID: string, - state: boolean, - available: boolean, + nodeID: string; + state: boolean; + available: boolean; } export interface ActionCatalogListResult { @@ -35,7 +35,7 @@ declare namespace ActionCatalog { declare class ActionCatalog { registry: Registry; - broker: ServiceBroker; + broker: ServiceBroker; actions: Map; StrategyFactory: Strategy; EndpointFactory: typeof ActionEndpoint; diff --git a/src/registry/discoverers/base.d.ts b/src/registry/discoverers/base.d.ts index 85c287795..c5f974b54 100644 --- a/src/registry/discoverers/base.d.ts +++ b/src/registry/discoverers/base.d.ts @@ -21,7 +21,6 @@ declare namespace BaseDiscoverer { } declare abstract class BaseDiscoverer { - broker: ServiceBroker; registry: Registry; Promise: PromiseConstructor; diff --git a/src/registry/discoverers/etcd3.d.ts b/src/registry/discoverers/etcd3.d.ts index 9e8aa95d3..ed411934e 100644 --- a/src/registry/discoverers/etcd3.d.ts +++ b/src/registry/discoverers/etcd3.d.ts @@ -1,12 +1,11 @@ import Registry = require("../registry"); import BaseDiscoverer = require("./base"); - declare namespace Etcd3Discoverer { export interface Etcd3DiscovererOptions extends BaseDiscoverer.DiscovererOptions { etcd?: any; serializer?: string; - fullCheck?: number|null; + fullCheck?: number | null; } } diff --git a/src/registry/discoverers/index.d.ts b/src/registry/discoverers/index.d.ts index c08b98536..d56914d1d 100644 --- a/src/registry/discoverers/index.d.ts +++ b/src/registry/discoverers/index.d.ts @@ -11,5 +11,5 @@ export { }; export { RegistryDiscovererOptions } from "./base"; -export declare function resolve(opts: Record|string): BaseDiscoverer; +export declare function resolve(opts: Record | string): BaseDiscoverer; export declare function register(name: string, value: BaseDiscoverer): void; diff --git a/src/registry/discoverers/local.d.ts b/src/registry/discoverers/local.d.ts index 93e06b311..9c89c7f6b 100644 --- a/src/registry/discoverers/local.d.ts +++ b/src/registry/discoverers/local.d.ts @@ -1,7 +1,6 @@ import Registry = require("../registry"); import BaseDiscoverer = require("./base"); - declare namespace LocalDiscoverer { export interface LocalDiscovererOptions extends BaseDiscoverer.DiscovererOptions {} } diff --git a/src/registry/discoverers/redis.d.ts b/src/registry/discoverers/redis.d.ts index 97e774d6b..07e119c90 100644 --- a/src/registry/discoverers/redis.d.ts +++ b/src/registry/discoverers/redis.d.ts @@ -1,12 +1,11 @@ import Registry = require("../registry"); import BaseDiscoverer = require("./base"); - declare namespace RedisDiscoverer { export interface RedisDiscovererOptions extends BaseDiscoverer.DiscovererOptions { redis?: any; serializer?: string; - fullCheck?: number|null; + fullCheck?: number | null; scanLength?: number; monitor?: boolean; } @@ -24,7 +23,7 @@ declare class RedisDiscoverer extends BaseDiscoverer { reconnecting: boolean; - constructor(opts?: string|RedisDiscoverer.RedisDiscovererOptions); + constructor(opts?: string | RedisDiscoverer.RedisDiscovererOptions); init(registry: Registry): void; stop(): Promise; registerMoleculerMetrics(): void; diff --git a/src/registry/endpoint-action.d.ts b/src/registry/endpoint-action.d.ts index ee448c4ba..e74e72c72 100644 --- a/src/registry/endpoint-action.d.ts +++ b/src/registry/endpoint-action.d.ts @@ -10,7 +10,13 @@ declare class ActionEndpoint extends Endpoint { service: Service; action: ActionSchema; - constructor(registry: Registry, broker: ServiceBroker, node: Node, service: Service, action: any); + constructor( + registry: Registry, + broker: ServiceBroker, + node: Node, + service: Service, + action: any + ); update(action: ActionSchema): void; } diff --git a/src/registry/endpoint-event.d.ts b/src/registry/endpoint-event.d.ts index d0bd908cf..7c73ff186 100644 --- a/src/registry/endpoint-event.d.ts +++ b/src/registry/endpoint-event.d.ts @@ -10,7 +10,13 @@ declare class EventEndpoint extends Endpoint { service: Service; event: EventSchema; - constructor(registry: Registry, broker: ServiceBroker, node: Node, service: Service, event: EventSchema); + constructor( + registry: Registry, + broker: ServiceBroker, + node: Node, + service: Service, + event: EventSchema + ); update(event: EventSchema): void; } diff --git a/src/registry/endpoint-list.d.ts b/src/registry/endpoint-list.d.ts index 0528e66ab..7953993b7 100644 --- a/src/registry/endpoint-list.d.ts +++ b/src/registry/endpoint-list.d.ts @@ -10,17 +10,25 @@ import ServiceItem = require("./service-item"); import Context = require("../context"); declare class EndpointList { - registry: Registry; - broker: ServiceBroker; - strategy: typeof BaseStrategy; - name: string; - group: string; - internal: boolean; - EndPointFactory: typeof Endpoint; + registry: Registry; + broker: ServiceBroker; + strategy: typeof BaseStrategy; + name: string; + group: string; + internal: boolean; + EndPointFactory: typeof Endpoint; endpoints: (ActionEndpoint | EventEndpoint)[]; - localEndpoints: (ActionEndpoint | EventEndpoint)[]; + localEndpoints: (ActionEndpoint | EventEndpoint)[]; - constructor(registry: Registry, broker: ServiceBroker, name: string, group: string, EndPointFactory?: typeof ActionEndpoint | typeof EventEndpoint, StrategyFactory?: typeof BaseStrategy, strategyOptions?: Record); + constructor( + registry: Registry, + broker: ServiceBroker, + name: string, + group: string, + EndPointFactory?: typeof ActionEndpoint | typeof EventEndpoint, + StrategyFactory?: typeof BaseStrategy, + strategyOptions?: Record + ); add(node: Node, service: ServiceItem, data: any): Endpoint; getFirst(): Endpoint | null; @@ -28,14 +36,14 @@ declare class EndpointList { next(ctx: Context): Endpoint | null; nextLocal(ctx: Context): Endpoint | null; - hasAvailable(): boolean; - hasLocal(): boolean; - setLocalEndpoints(): void; - count(): number; + hasAvailable(): boolean; + hasLocal(): boolean; + setLocalEndpoints(): void; + count(): number; getEndpointByNodeID(nodeID: string): Endpoint | null; - hasNodeID(nodeID: string): boolean; - removeByService(service: ServiceItem): void; - removeByNodeID(nodeID: string): void; + hasNodeID(nodeID: string): boolean; + removeByService(service: ServiceItem): void; + removeByNodeID(nodeID: string): void; } export = EndpointList; diff --git a/src/registry/endpoint.d.ts b/src/registry/endpoint.d.ts index 3e05ad269..2dcad054d 100644 --- a/src/registry/endpoint.d.ts +++ b/src/registry/endpoint.d.ts @@ -18,6 +18,5 @@ declare abstract class Endpoint { get isAvailable(): boolean; abstract update(param: ActionSchema | EventSchema): void; - } export = Endpoint; diff --git a/src/registry/event-catalog.d.ts b/src/registry/event-catalog.d.ts index 91a8c0e70..ba4872ba4 100644 --- a/src/registry/event-catalog.d.ts +++ b/src/registry/event-catalog.d.ts @@ -20,9 +20,9 @@ declare namespace EventCatalog { } interface EventEndpointList { - nodeID: string, - state: boolean, - available: boolean, + nodeID: string; + state: boolean; + available: boolean; } export interface EventCatalogListResult { @@ -37,26 +37,30 @@ declare namespace EventCatalog { declare class EventCatalog { registry: Registry; - broker: ServiceBroker; + broker: ServiceBroker; events: EndpointList[]; StrategyFactory: typeof Strategy; EndpointFactory: typeof EventEndpoint; constructor(registry: Registry, broker: ServiceBroker, StrategyFactory: typeof Strategy); - add(node: Node, service: ServiceItem, event: EventSchema ): EndpointList; + add(node: Node, service: ServiceItem, event: EventSchema): EndpointList; - get(eventName: string, groupName: string ): EndpointList | null; + get(eventName: string, groupName: string): EndpointList | null; - getBalancedEndpoints(eventName: string, groups?: string | string[], ctx?: Context): [EventEndpoint, string][]; - getGroups(eventName: string): string[]; - getAllEndpoints(eventName: string, groupNames?: string[]): EventEndpoint[]; + getBalancedEndpoints( + eventName: string, + groups?: string | string[], + ctx?: Context + ): [EventEndpoint, string][]; + getGroups(eventName: string): string[]; + getAllEndpoints(eventName: string, groupNames?: string[]): EventEndpoint[]; emitLocalServices(ctx: Context): Promise; - callEventHandler(ctx: Context): Promise; + callEventHandler(ctx: Context): Promise; removeByService(service: ServiceItem): void; - remove(eventName: string, nodeID: string): void; + remove(eventName: string, nodeID: string): void; list(opts: EventCatalog.EventCatalogListOptions): EventCatalog.EventCatalogListResult[]; } diff --git a/src/registry/node-catalog.d.ts b/src/registry/node-catalog.d.ts index 83a9a789c..e5e4366b4 100644 --- a/src/registry/node-catalog.d.ts +++ b/src/registry/node-catalog.d.ts @@ -13,7 +13,7 @@ declare namespace NodeCatalog { declare class NodeCatalog { registry: Registry; - broker: ServiceBroker; + broker: ServiceBroker; nodes: Map; localNode?: Node; @@ -23,13 +23,13 @@ declare class NodeCatalog { add(id: string, node: Node): void; has(id: string): boolean; get(id: string): Node; - delete(id: string): boolean; - count(): number; - onlineCount(): number; - processNodeInfo(payload: any): Node; - disconnected(nodeID: string, isUnexpected: boolean): void; - list(opts: NodeCatalog.NodeCatalogListOptions): NodeCatalog.NodeCatalogListResult[]; - toArray(): Node[]; + delete(id: string): boolean; + count(): number; + onlineCount(): number; + processNodeInfo(payload: any): Node; + disconnected(nodeID: string, isUnexpected: boolean): void; + list(opts: NodeCatalog.NodeCatalogListOptions): NodeCatalog.NodeCatalogListResult[]; + toArray(): Node[]; } export = NodeCatalog; diff --git a/src/registry/registry.d.ts b/src/registry/registry.d.ts index 4ab318f22..ffb416cb9 100644 --- a/src/registry/registry.d.ts +++ b/src/registry/registry.d.ts @@ -32,16 +32,19 @@ declare namespace ServiceRegistry { services: [Record]; } - type DiscovererConfig = { - type: "Local"; - options?: LocalDiscovererOptions; - } | { - type: "Etcd3"; - options?: Etcd3DiscovererOptions; - } | { - type: "Redis"; - options?: RedisDiscovererOptions; - }; + type DiscovererConfig = + | { + type: "Local"; + options?: LocalDiscovererOptions; + } + | { + type: "Etcd3"; + options?: Etcd3DiscovererOptions; + } + | { + type: "Redis"; + options?: RedisDiscovererOptions; + }; type DiscovererType = DiscovererConfig["type"]; diff --git a/src/registry/service-catalog.d.ts b/src/registry/service-catalog.d.ts index 560713c05..b9e5223cb 100644 --- a/src/registry/service-catalog.d.ts +++ b/src/registry/service-catalog.d.ts @@ -48,7 +48,7 @@ declare namespace ServiceCatalog { declare class ServiceCatalog { registry: Registry; - broker: ServiceBroker; + broker: ServiceBroker; services: ServiceItem[]; constructor(registry: Registry, broker: ServiceBroker); @@ -56,15 +56,14 @@ declare class ServiceCatalog { add(node: Node, service: ServiceItem, local: boolean): ServiceItem; has(fullName: string, nodeID: string): boolean; - get(fullName: string, nodeID: string): ServiceItem; + get(fullName: string, nodeID: string): ServiceItem; list(opts: ServiceCatalog.ServiceCatalogListOptions): ServiceCatalog.ServiceCatalogListResult[]; - getLocalNodeServices(): ServiceCatalog.ServiceCatalogLocalNodeServicesResult[]; - - removeAllByNodeID(nodeID: string): void; - remove(fullName: string, nodeID: string): void; + getLocalNodeServices(): ServiceCatalog.ServiceCatalogLocalNodeServicesResult[]; + removeAllByNodeID(nodeID: string): void; + remove(fullName: string, nodeID: string): void; } export = ServiceCatalog; diff --git a/src/registry/service-item.d.ts b/src/registry/service-item.d.ts index da16859d0..c56210025 100644 --- a/src/registry/service-item.d.ts +++ b/src/registry/service-item.d.ts @@ -22,6 +22,6 @@ declare class ServiceItem { update(svc: Record): void; addAction(action: ActionSchema): void; - addEvent(event: EventSchema): void; + addEvent(event: EventSchema): void; } export = ServiceItem; diff --git a/src/runner.d.ts b/src/runner.d.ts index 430c571b8..7ef089222 100644 --- a/src/runner.d.ts +++ b/src/runner.d.ts @@ -1,6 +1,6 @@ import ServiceBroker = require("./service-broker"); import Service = require("./service"); -import type { ServiceBrokerOptions} from "./service-broker"; +import type { ServiceBrokerOptions } from "./service-broker"; import { Worker } from "cluster"; declare namespace Runner { @@ -8,7 +8,6 @@ declare namespace Runner { * Parsed CLI flags */ export interface RunnerFlags { - /** * Path to load configuration from a file */ @@ -48,9 +47,7 @@ declare namespace Runner { * File mask for loading services */ mask?: string; - } - } /** diff --git a/src/serializers/base.d.ts b/src/serializers/base.d.ts index c0505cd96..d2089742c 100644 --- a/src/serializers/base.d.ts +++ b/src/serializers/base.d.ts @@ -9,12 +9,12 @@ declare abstract class Serializer { abstract serialize(obj: Record, type?: string): Buffer; - abstract deserialize(buf: Buffer|string, type?: string): any; + abstract deserialize(buf: Buffer | string, type?: string): any; - serializeCustomFields(type: string, obj: Record): Record; - deserializeCustomFields(type: string, obj: Record): Record; + serializeCustomFields(type: string, obj: Record): Record; + deserializeCustomFields(type: string, obj: Record): Record; convertDataToTransport(obj: Record, field: string, fieldType: string): void; - convertDataFromTransport(obj: Record, field: string, fieldType: string): void; + convertDataFromTransport(obj: Record, field: string, fieldType: string): void; } export = Serializer; diff --git a/src/serializers/cbor.d.ts b/src/serializers/cbor.d.ts index 62bf50a22..74627d6be 100644 --- a/src/serializers/cbor.d.ts +++ b/src/serializers/cbor.d.ts @@ -8,11 +8,9 @@ declare namespace CborSerializer { } declare class CborSerializer extends BaseSerializer { - opts: CborSerializer.CborSerializerOptions; serialize(obj: any): Buffer; - deserialize(buf: Buffer|string): any; - + deserialize(buf: Buffer | string): any; } export = CborSerializer; diff --git a/src/serializers/index.d.ts b/src/serializers/index.d.ts index 43fa86218..395c3d0ad 100644 --- a/src/serializers/index.d.ts +++ b/src/serializers/index.d.ts @@ -14,5 +14,5 @@ export { CborSerializer as CBOR }; -export declare function resolve(opt: Record|string|boolean): Serializer; +export declare function resolve(opt: Record | string | boolean): Serializer; export declare function register(name: string, value: Serializer): void; diff --git a/src/serializers/json-extended.d.ts b/src/serializers/json-extended.d.ts index 46951be21..8eb2bca24 100644 --- a/src/serializers/json-extended.d.ts +++ b/src/serializers/json-extended.d.ts @@ -1,7 +1,6 @@ import BaseSerializer = require("./base"); declare namespace JSONExtSerializer { - export interface JSONExtSerializerOptionsCustomType { prefix: string; check: (v: any, key: string, obj: object) => boolean; @@ -13,15 +12,12 @@ declare namespace JSONExtSerializer { } } - declare class JSONExtSerializer extends BaseSerializer { - opts: JSONExtSerializer.JSONExtSerializerOptions; hasCustomTypes: boolean; serialize(obj: any): Buffer; - deserialize(buf: Buffer|string): any; - + deserialize(buf: Buffer | string): any; } export = JSONExtSerializer; diff --git a/src/serializers/json.d.ts b/src/serializers/json.d.ts index 7ac3129d5..8542e6079 100644 --- a/src/serializers/json.d.ts +++ b/src/serializers/json.d.ts @@ -1,9 +1,7 @@ import BaseSerializer = require("./base"); declare class JSONSerializer extends BaseSerializer { - serialize(obj: any): Buffer; - deserialize(buf: Buffer|string): any; - + deserialize(buf: Buffer | string): any; } export = JSONSerializer; diff --git a/src/serializers/msgpack.d.ts b/src/serializers/msgpack.d.ts index 324e2eef1..1b6af8d76 100644 --- a/src/serializers/msgpack.d.ts +++ b/src/serializers/msgpack.d.ts @@ -3,11 +3,9 @@ import type ServiceBroker = require("../service-broker"); import BaseSerializer = require("./base"); declare class MsgPackSerializer extends BaseSerializer { - init(broker: ServiceBroker): void; serialize(obj: any): Buffer; - deserialize(buf: Buffer|string): any; - + deserialize(buf: Buffer | string): any; } export = MsgPackSerializer; diff --git a/src/serializers/notepack.d.ts b/src/serializers/notepack.d.ts index ffd224b86..3ae4b2eb8 100644 --- a/src/serializers/notepack.d.ts +++ b/src/serializers/notepack.d.ts @@ -3,11 +3,9 @@ import type ServiceBroker = require("../service-broker"); import BaseSerializer = require("./base"); declare class NotepackSerializer extends BaseSerializer { - init(broker: ServiceBroker): void; serialize(obj: any): Buffer; - deserialize(buf: Buffer|string): any; - + deserialize(buf: Buffer | string): any; } export = NotepackSerializer; diff --git a/src/service-broker.d.ts b/src/service-broker.d.ts index d4b4482e1..59bdff392 100644 --- a/src/service-broker.d.ts +++ b/src/service-broker.d.ts @@ -96,19 +96,24 @@ declare namespace ServiceBroker { type CacherType = CacherConfig["type"]; - type SerializerConfig = { - type: "JSON" - } | { - type: "JSONExt", - options?: JSONExtSerializerOptions - } | { - type: "MsgPack" - } | { - type: "Notepack" - } | { - type: "CBOR", - options?: CborSerializerOptions - }; + type SerializerConfig = + | { + type: "JSON"; + } + | { + type: "JSONExt"; + options?: JSONExtSerializerOptions; + } + | { + type: "MsgPack"; + } + | { + type: "Notepack"; + } + | { + type: "CBOR"; + options?: CborSerializerOptions; + }; type SerializerType = SerializerConfig["type"]; @@ -386,13 +391,12 @@ declare class ServiceBroker { opts?: MiddlewareCallHandlerOptions ): any; - callMiddlewareHook(name: string, args: any[], opts?: MiddlewareCallHandlerOptions): Promise; - callMiddlewareHookSync( + callMiddlewareHook( name: string, args: any[], opts?: MiddlewareCallHandlerOptions - ): void; - + ): Promise; + callMiddlewareHookSync(name: string, args: any[], opts?: MiddlewareCallHandlerOptions): void; isMetricsEnabled(): boolean; @@ -411,7 +415,7 @@ declare class ServiceBroker { _restartService(service: Service): Promise; - addLocalService(service: Service): void + addLocalService(service: Service): void; registerLocalService(registryItem: ServiceItem): void; destroyService(service: Service | string | ServiceDependency): Promise; @@ -429,7 +433,7 @@ declare class ServiceBroker { ): Promise; findNextActionEndpoint( - actionName: string|ActionEndpoint, + actionName: string | ActionEndpoint, opts?: Record, ctx?: Context ): ActionEndpoint | MoleculerRetryableError; diff --git a/src/service.d.ts b/src/service.d.ts index 5895e272f..3ac0fdbbd 100644 --- a/src/service.d.ts +++ b/src/service.d.ts @@ -112,7 +112,7 @@ declare namespace Service { retryPolicy?: RetryPolicyOptions; fallback?: string | FallbackHandler; hooks?: ActionHooks; - strategy?: string| typeof Strategy; + strategy?: string | typeof Strategy; strategyOptions?: Record; // [key: string]: any; @@ -168,7 +168,7 @@ declare namespace Service { context?: boolean; debounce?: number; throttle?: number; - strategy?: string| typeof Strategy; + strategy?: string | typeof Strategy; strategyOptions?: Record; handler?: EventSchemaHandler; diff --git a/src/strategies/base.d.ts b/src/strategies/base.d.ts index 746d2c400..a59fcb5c0 100644 --- a/src/strategies/base.d.ts +++ b/src/strategies/base.d.ts @@ -7,7 +7,7 @@ declare abstract class BaseStrategy { constructor(registry: Registry, broker: ServiceBroker, opts?: object); registry: Registry; - broker: ServiceBroker; + broker: ServiceBroker; // opts: Record; abstract select(list: Endpoint[], ctx?: Context): Endpoint; diff --git a/src/strategies/cpu-usage.d.ts b/src/strategies/cpu-usage.d.ts index daff21d18..d07b72926 100644 --- a/src/strategies/cpu-usage.d.ts +++ b/src/strategies/cpu-usage.d.ts @@ -12,12 +12,14 @@ declare namespace CpuUsageStrategy { } declare class CpuUsageStrategy extends BaseStrategy { - - constructor(registry: Registry, broker: ServiceBroker, opts?: CpuUsageStrategy.CpuUsageStrategyOptions); + constructor( + registry: Registry, + broker: ServiceBroker, + opts?: CpuUsageStrategy.CpuUsageStrategyOptions + ); opts: CpuUsageStrategy.CpuUsageStrategyOptions; select(list: Endpoint[]): Endpoint; - } export = CpuUsageStrategy; diff --git a/src/strategies/index.d.ts b/src/strategies/index.d.ts index 24053b0da..7f230b417 100644 --- a/src/strategies/index.d.ts +++ b/src/strategies/index.d.ts @@ -11,8 +11,8 @@ export { RandomStrategy as Random, CpuUsageStrategy as CpuUsage, LatencyStrategy as Latency, - ShardStrategy as Shard, + ShardStrategy as Shard }; -export declare function resolve(opts: Record|string): typeof BaseStrategy; +export declare function resolve(opts: Record | string): typeof BaseStrategy; export declare function register(name: string, value: BaseStrategy): void; diff --git a/src/strategies/latency.d.ts b/src/strategies/latency.d.ts index b35cf4844..017041cc3 100644 --- a/src/strategies/latency.d.ts +++ b/src/strategies/latency.d.ts @@ -14,13 +14,15 @@ declare namespace LatencyStrategy { } declare class LatencyStrategy extends BaseStrategy { - - constructor(registry: Registry, broker: ServiceBroker, opts?: LatencyStrategy.LatencyStrategyOptions); + constructor( + registry: Registry, + broker: ServiceBroker, + opts?: LatencyStrategy.LatencyStrategyOptions + ); opts: LatencyStrategy.LatencyStrategyOptions; select(list: Endpoint[]): Endpoint; - } export = LatencyStrategy; diff --git a/src/strategies/random.d.ts b/src/strategies/random.d.ts index 9e9ee510f..24908ed63 100644 --- a/src/strategies/random.d.ts +++ b/src/strategies/random.d.ts @@ -5,7 +5,6 @@ import type Registry = require("../registry/registry"); import type Endpoint = require("../registry/endpoint"); declare class RandomStrategy extends BaseStrategy { - constructor(registry: Registry, broker: ServiceBroker, opts?: object); select(list: Endpoint[]): Endpoint; diff --git a/src/strategies/round-robin.d.ts b/src/strategies/round-robin.d.ts index d3053cf7b..7a9b4185c 100644 --- a/src/strategies/round-robin.d.ts +++ b/src/strategies/round-robin.d.ts @@ -10,6 +10,5 @@ declare class RoundRobinStrategy extends BaseStrategy { counter: number; select(list: Endpoint[]): Endpoint; - } export = RoundRobinStrategy; diff --git a/src/strategies/shard.d.ts b/src/strategies/shard.d.ts index 80420bfee..54488c710 100644 --- a/src/strategies/shard.d.ts +++ b/src/strategies/shard.d.ts @@ -7,16 +7,19 @@ import type Endpoint = require("../registry/endpoint"); declare namespace ShardStrategy { export interface ShardStrategyOptions { - shardKey?: string|null; + shardKey?: string | null; vnodes?: number; - ringSize?: number|null; + ringSize?: number | null; cacheSize?: number; } } declare class ShardStrategy extends BaseStrategy { - - constructor(registry: Registry, broker: ServiceBroker, opts?: ShardStrategy.ShardStrategyOptions); + constructor( + registry: Registry, + broker: ServiceBroker, + opts?: ShardStrategy.ShardStrategyOptions + ); opts: ShardStrategy.ShardStrategyOptions; diff --git a/src/tracing/exporters/datadog.d.ts b/src/tracing/exporters/datadog.d.ts index c85933e63..b51aebc3b 100644 --- a/src/tracing/exporters/datadog.d.ts +++ b/src/tracing/exporters/datadog.d.ts @@ -28,12 +28,11 @@ declare class DatadogTraceExporter extends BaseTraceExporter { init(tracer: Tracer): void; stop(): void; - spanStarted(span: Span): void; spanFinished(span: Span): void; addTags(span: any, key: string, value: any, prefix?: string): void; - addLogs(span: any, logs: Span.SpanLogEntry[]): void; - convertID(id: string): string; + addLogs(span: any, logs: Span.SpanLogEntry[]): void; + convertID(id: string): string; } export = DatadogTraceExporter; diff --git a/src/tracing/exporters/index.d.ts b/src/tracing/exporters/index.d.ts index c708a26c1..92e03f2c2 100644 --- a/src/tracing/exporters/index.d.ts +++ b/src/tracing/exporters/index.d.ts @@ -16,5 +16,5 @@ export { NewRelicTraceExporter as NewRelic }; -export declare function resolve(opt: Record|string): BaseTraceExporter; +export declare function resolve(opt: Record | string): BaseTraceExporter; export declare function register(name: string, value: BaseTraceExporter): void; diff --git a/src/tracing/exporters/newrelic.d.ts b/src/tracing/exporters/newrelic.d.ts index dec511e04..caffbcd81 100644 --- a/src/tracing/exporters/newrelic.d.ts +++ b/src/tracing/exporters/newrelic.d.ts @@ -32,8 +32,8 @@ declare class NewRelicTraceExporter extends BaseTraceExporter { flush(): void; generateTracingData(): Record[]; - makePayload(span: Span): Record; - convertID(id: string): string; - convertTime(ts: number): number; + makePayload(span: Span): Record; + convertID(id: string): string; + convertTime(ts: number): number; } export = NewRelicTraceExporter; diff --git a/src/tracing/exporters/zipkin.d.ts b/src/tracing/exporters/zipkin.d.ts index 97b57fe26..9764bf115 100644 --- a/src/tracing/exporters/zipkin.d.ts +++ b/src/tracing/exporters/zipkin.d.ts @@ -34,8 +34,8 @@ declare class ZipkinTraceExporter extends BaseTraceExporter { flush(): void; generateTracingData(): Record[]; - makePayload(span: Span): Record; - convertID(id: string): string; - convertTime(ts: number): number; + makePayload(span: Span): Record; + convertID(id: string): string; + convertTime(ts: number): number; } export = ZipkinTraceExporter; diff --git a/src/tracing/rate-limiter.d.ts b/src/tracing/rate-limiter.d.ts index 2c3eb26d2..0dfc66743 100644 --- a/src/tracing/rate-limiter.d.ts +++ b/src/tracing/rate-limiter.d.ts @@ -1,17 +1,17 @@ declare namespace RateLimiter { export type RateLimiterOptions = { tracesPerSecond?: number; - } + }; } declare class RateLimiter { - constructor(opts?: RateLimiter.RateLimiterOptions); - opts: RateLimiter.RateLimiterOptions; - lastTime: number; - balance: number; - maxBalance: any; + constructor(opts?: RateLimiter.RateLimiterOptions); + opts: RateLimiter.RateLimiterOptions; + lastTime: number; + balance: number; + maxBalance: any; - check(cost?: number): boolean; + check(cost?: number): boolean; } export = RateLimiter; diff --git a/src/tracing/span.d.ts b/src/tracing/span.d.ts index 7da8dc60d..93ce24cb6 100644 --- a/src/tracing/span.d.ts +++ b/src/tracing/span.d.ts @@ -7,11 +7,13 @@ declare namespace Span { id?: string; traceID?: string; parentID?: string | null; - service?: string | { - name?: string; - version?: string | number; - fullName?: string; - }; + service?: + | string + | { + name?: string; + version?: string | number; + fullName?: string; + }; priority?: number; sampled?: boolean; tags?: Record; diff --git a/src/tracing/tracer.d.ts b/src/tracing/tracer.d.ts index 5676f34a3..55a6a6d03 100644 --- a/src/tracing/tracer.d.ts +++ b/src/tracing/tracer.d.ts @@ -37,31 +37,41 @@ declare namespace Tracer { meta?: boolean | string[]; }; - export type TracingExporter = { - type: "Console", - options?: ConsoleTraceExporterOptions - } | { - type: "Datadog", - options?: DatadogTraceExporterOptions - } | { - type: "Event", - options?: EventTraceExporterOptions - } | { - type: "Jaeger", - options?: JaegerTraceExporterOptions - } | { - type: "NewRelic", - options?: NewRelicTraceExporterOptions - } | { - type: "Zipkin", - options?: ZipkinTraceExporterOptions - } + export type TracingExporter = + | { + type: "Console"; + options?: ConsoleTraceExporterOptions; + } + | { + type: "Datadog"; + options?: DatadogTraceExporterOptions; + } + | { + type: "Event"; + options?: EventTraceExporterOptions; + } + | { + type: "Jaeger"; + options?: JaegerTraceExporterOptions; + } + | { + type: "NewRelic"; + options?: NewRelicTraceExporterOptions; + } + | { + type: "Zipkin"; + options?: ZipkinTraceExporterOptions; + }; type TracingExporterTypes = TracingExporter["type"]; export interface TracerOptions { enabled?: boolean; - exporter?: TracingExporterTypes | TracingExporter | (TracingExporter | TracingExporterTypes)[] | null; + exporter?: + | TracingExporterTypes + | TracingExporter + | (TracingExporter | TracingExporterTypes)[] + | null; sampling?: { rate?: number | null; tracesPerSecond?: number | null; diff --git a/src/transit.d.ts b/src/transit.d.ts index 3e69aff4e..541eaea6b 100644 --- a/src/transit.d.ts +++ b/src/transit.d.ts @@ -7,9 +7,7 @@ import ServiceBroker = require("./service-broker"); import Transporter = require("./transporters/base"); import BaseDiscoverer = require("./registry/discoverers/base"); import MetricRegistry = require("./metrics/registry"); -import type { - Regenerator as ErrorRegenerator -} from "./errors"; +import type { Regenerator as ErrorRegenerator } from "./errors"; import { Stream } from "stream"; import { NodeRawInfo } from "./registry"; @@ -67,7 +65,7 @@ declare class Transit { eventHandler(payload: Record): Promise; requestHandler(payload: Record): Promise; - _handleIncomingRequestStream(payload: Record): boolean|Stream; + _handleIncomingRequestStream(payload: Record): boolean | Stream; _createErrFromPayload(error: Record, payload: Record): Error; responseHandler(packet: Record): void; _handleIncomingResponseStream(packet: Record, req: Record): boolean; @@ -82,7 +80,14 @@ declare class Transit { _createPayloadErrorField(error: Error, payload: Record): Record; - sendResponse(nodeID: string, id: string, meta: Record, headers: Record, data: Record, err?: Error): Promise; + sendResponse( + nodeID: string, + id: string, + meta: Record, + headers: Record, + data: Record, + err?: Error + ): Promise; discoverNodes(): Promise; discoverNode(nodeID: string): Promise; diff --git a/src/transporters/amqp.d.ts b/src/transporters/amqp.d.ts index e3ba6208a..e4fa24fad 100644 --- a/src/transporters/amqp.d.ts +++ b/src/transporters/amqp.d.ts @@ -10,12 +10,12 @@ declare namespace AmqpTransporter { exchangeOptions?: Record; messageOptions?: Record; consumeOptions?: Record; - autoDeleteQueues?: boolean|number; + autoDeleteQueues?: boolean | number; } } declare class AmqpTransporter extends BaseTransporter { - opts: AmqpTransporter.AmqpTransporterOptions + opts: AmqpTransporter.AmqpTransporterOptions; hasBuiltInBalancer: boolean; connection: any; @@ -26,7 +26,7 @@ declare class AmqpTransporter extends BaseTransporter { connectionDisconnecting: boolean; connectionCount: number; - constructor(opts?: string|AmqpTransporter.AmqpTransporterOptions); + constructor(opts?: string | AmqpTransporter.AmqpTransporterOptions); connect(): Promise; disconnect(): Promise; diff --git a/src/transporters/amqp10.d.ts b/src/transporters/amqp10.d.ts index 013399b18..50ff112f3 100644 --- a/src/transporters/amqp10.d.ts +++ b/src/transporters/amqp10.d.ts @@ -9,12 +9,12 @@ declare namespace Amqp10Transporter { queueOptions?: Record; topicOptions?: Record; messageOptions?: Record; - autoDeleteQueues?: boolean|number; + autoDeleteQueues?: boolean | number; } } declare class Amqp10Transporter extends BaseTransporter { - opts: Amqp10Transporter.Amqp10TransporterOptions + opts: Amqp10Transporter.Amqp10TransporterOptions; hasBuiltInBalancer: boolean; connection: any; @@ -25,7 +25,7 @@ declare class Amqp10Transporter extends BaseTransporter { connectionDisconnecting: boolean; connectionCount: number; - constructor(opts?: string|Amqp10Transporter.Amqp10TransporterOptions); + constructor(opts?: string | Amqp10Transporter.Amqp10TransporterOptions); connect(): Promise; disconnect(): Promise; diff --git a/src/transporters/fake.d.ts b/src/transporters/fake.d.ts index 54e6027e5..bbfab02fb 100644 --- a/src/transporters/fake.d.ts +++ b/src/transporters/fake.d.ts @@ -4,9 +4,9 @@ import BaseTransporter = require("./base"); declare class FakeTransporter extends BaseTransporter { bus: EventEmitter; hasBuiltInBalancer: boolean; - subscriptions: Array<{ topic: string, handler: Function }>; + subscriptions: Array<{ topic: string; handler: Function }>; - constructor(opts?: string|Record); + constructor(opts?: string | Record); connect(): Promise; disconnect(): Promise; diff --git a/src/transporters/index.d.ts b/src/transporters/index.d.ts index d5da06bd8..813ad6731 100644 --- a/src/transporters/index.d.ts +++ b/src/transporters/index.d.ts @@ -20,5 +20,5 @@ export { TcpTransporter as TCP }; -export declare function resolve(opt: Record|string): BaseTransporter; +export declare function resolve(opt: Record | string): BaseTransporter; export declare function register(name: string, value: BaseTransporter): void; diff --git a/src/transporters/kafka.d.ts b/src/transporters/kafka.d.ts index f5c9a3f7d..a291074db 100644 --- a/src/transporters/kafka.d.ts +++ b/src/transporters/kafka.d.ts @@ -31,6 +31,5 @@ declare class KafkaTransporter extends BaseTransporter { subscribeBalancedEvent(event: string, group: string): Promise; send(topic: string, data: Buffer, meta: Record): Promise; - } export = KafkaTransporter; diff --git a/src/transporters/mqtt.d.ts b/src/transporters/mqtt.d.ts index 20aa100d5..a8cf30169 100644 --- a/src/transporters/mqtt.d.ts +++ b/src/transporters/mqtt.d.ts @@ -26,6 +26,5 @@ declare class MqttTransporter extends BaseTransporter { subscribeBalancedEvent(event: string, group: string): Promise; send(topic: string, data: Buffer): Promise; - } export = MqttTransporter; diff --git a/src/transporters/nats.d.ts b/src/transporters/nats.d.ts index ba87a9844..d41a51b08 100644 --- a/src/transporters/nats.d.ts +++ b/src/transporters/nats.d.ts @@ -27,6 +27,5 @@ declare class NatsTransporter extends BaseTransporter { unsubscribeFromBalancedCommands(): Promise; send(topic: string, data: Buffer): Promise; - } export = NatsTransporter; diff --git a/src/transporters/redis.d.ts b/src/transporters/redis.d.ts index bb0225e74..5e41ba77f 100644 --- a/src/transporters/redis.d.ts +++ b/src/transporters/redis.d.ts @@ -6,7 +6,7 @@ declare namespace RedisTransporter { cluster?: { nodes?: ClusterNode[]; clusterOptions?: ClusterOptions; - } + }; } } @@ -19,7 +19,7 @@ declare class RedisTransporter extends BaseTransporter { constructor(opts?: string | RedisOptions | RedisTransporter.RedisTransporterOptions); - getRedisClient(opts): Redis|Cluster; + getRedisClient(opts): Redis | Cluster; connect(): Promise; disconnect(): Promise; @@ -30,6 +30,5 @@ declare class RedisTransporter extends BaseTransporter { unsubscribeFromBalancedCommands(): Promise; send(topic: string, data: Buffer): Promise; - } export = RedisTransporter; diff --git a/src/transporters/tcp.d.ts b/src/transporters/tcp.d.ts index 3200ecda6..2cfa53533 100644 --- a/src/transporters/tcp.d.ts +++ b/src/transporters/tcp.d.ts @@ -58,28 +58,28 @@ declare class TcpTransporter extends BaseTransporter { loadUrls(): Promise; onIncomingMessage(type: string, message: Buffer, socket: Socket): void | Promise; - receive(type: string, message: Buffer, socket: Socket): void | Promise; - startTimers(): void; - stopTimers(): void; - addOfflineNode(id: string, address: string, port: number): Node; - getNode(nodeID: string): Node; - getNodeAddress(node: Node): string; - sendHello(nodeID: string): Promise; - processGossipHello(msg: Buffer, socket: Socket): void; - sendGossipRequest(): void; - sendGossipToRandomEndpoint(data: Record, endpoints: Node[]): void; - processGossipRequest(msg: Buffer): void; - processGossipResponse(msg: Buffer): void; + receive(type: string, message: Buffer, socket: Socket): void | Promise; + startTimers(): void; + stopTimers(): void; + addOfflineNode(id: string, address: string, port: number): Node; + getNode(nodeID: string): Node; + getNodeAddress(node: Node): string; + sendHello(nodeID: string): Promise; + processGossipHello(msg: Buffer, socket: Socket): void; + sendGossipRequest(): void; + sendGossipToRandomEndpoint(data: Record, endpoints: Node[]): void; + processGossipRequest(msg: Buffer): void; + processGossipResponse(msg: Buffer): void; - getLocalNodeInfo(): Node; - getNodeInfo(nodeID: string): Node; + getLocalNodeInfo(): Node; + getNodeInfo(nodeID: string): Node; subscribe(cmd: string, nodeID?: string): Promise; subscribeBalancedRequest(action: string): Promise; subscribeBalancedEvent(event: string, group: string): Promise; unsubscribeFromBalancedCommands(): Promise; - publish(packet: Packet): any; + publish(packet: Packet): any; send(topic: string, data: Buffer, meta: Record): Promise; } export = TcpTransporter; diff --git a/src/transporters/tcp/constants.d.ts b/src/transporters/tcp/constants.d.ts index 1f4e3a541..f539049a9 100644 --- a/src/transporters/tcp/constants.d.ts +++ b/src/transporters/tcp/constants.d.ts @@ -9,4 +9,6 @@ export const PACKET_GOSSIP_HELLO_ID: number; export const IGNORABLE_ERRORS: string[]; export function resolvePacketID(type: string): number; -export function resolvePacketType(id: number): "EVENT" | "REQ" | "RES" | "PING" | "PONG" | "GOSSIP_REQ" | "GOSSIP_RES" | "GOSSIP_HELLO"; +export function resolvePacketType( + id: number +): "EVENT" | "REQ" | "RES" | "PING" | "PONG" | "GOSSIP_REQ" | "GOSSIP_RES" | "GOSSIP_HELLO"; diff --git a/src/transporters/tcp/parser.d.ts b/src/transporters/tcp/parser.d.ts index 4cbb00e40..d335d807e 100644 --- a/src/transporters/tcp/parser.d.ts +++ b/src/transporters/tcp/parser.d.ts @@ -2,11 +2,11 @@ * TCP packet parser */ declare class Parser extends Writable { - constructor(options: Record, maxPacketSize: number); - maxPacketSize: any; - buf: Buffer; + constructor(options: Record, maxPacketSize: number); + maxPacketSize: any; + buf: Buffer; - _write(chunk: Buffer, encoding: string, cb: Function): void; + _write(chunk: Buffer, encoding: string, cb: Function): void; } import Writable_1 = require("stream"); import Writable = Writable_1.Writable; diff --git a/src/transporters/tcp/tcp-writer.d.ts b/src/transporters/tcp/tcp-writer.d.ts index 1842e6b75..9e40eac0d 100644 --- a/src/transporters/tcp/tcp-writer.d.ts +++ b/src/transporters/tcp/tcp-writer.d.ts @@ -2,19 +2,19 @@ import EventEmitter = require("events"); import { Socket } from "net"; declare class TcpWriter extends EventEmitter { - constructor(transporter: any, opts: any); - sockets: Map; - opts: any; - transporter: any; - Promise: any; - logger: any; + constructor(transporter: any, opts: any); + sockets: Map; + opts: any; + transporter: any; + Promise: any; + logger: any; connect(nodeID: string): any; - send(nodeID: string, type: number, data: Buffer): any; - manageConnections(): void; - addSocket(nodeID: string, socket: Socket, force: boolean): void; - removeSocket(nodeID: string): void; - close(): void; + send(nodeID: string, type: number, data: Buffer): any; + manageConnections(): void; + addSocket(nodeID: string, socket: Socket, force: boolean): void; + removeSocket(nodeID: string): void; + close(): void; } export = TcpWriter; diff --git a/src/transporters/tcp/udp-broadcaster.d.ts b/src/transporters/tcp/udp-broadcaster.d.ts index d5a40cb1a..cc145733a 100644 --- a/src/transporters/tcp/udp-broadcaster.d.ts +++ b/src/transporters/tcp/udp-broadcaster.d.ts @@ -1,27 +1,32 @@ import EventEmitter = require("events"); declare class UdpServer extends EventEmitter { - constructor(transporter: any, opts: any); + constructor(transporter: any, opts: any); servers: any[]; - discoverTimer: NodeJS.Timeout; - opts: any; - transporter: any; - logger: any; - nodeID: any; - namespace: any; - Promise: any; - counter: number; + discoverTimer: NodeJS.Timeout; + opts: any; + transporter: any; + logger: any; + nodeID: any; + namespace: any; + Promise: any; + counter: number; bind(): Promise; - startServer(host: string | null, port: number | null, multicastAddress: string | null, ttl: number | null): any; - discover(): void; - onMessage(data: Buffer, rinfo: Record): void; - startDiscovering(): void; - stopDiscovering(): void; - close(): void; - getBroadcastAddresses(): Array; - getInterfaceAddresses(): Array; + startServer( + host: string | null, + port: number | null, + multicastAddress: string | null, + ttl: number | null + ): any; + discover(): void; + onMessage(data: Buffer, rinfo: Record): void; + startDiscovering(): void; + stopDiscovering(): void; + close(): void; + getBroadcastAddresses(): Array; + getInterfaceAddresses(): Array; } export = UdpServer; diff --git a/src/utils.d.ts b/src/utils.d.ts index 53eb4fd1b..6c7c18291 100644 --- a/src/utils.d.ts +++ b/src/utils.d.ts @@ -24,9 +24,15 @@ export declare function isPromise(promise: unknown): promise is Promise; export declare function polyfillPromise(P: typeof Promise): void; -export declare function promiseAllControl(promises: any[], settled?: boolean, promise?: any): Promise<{ - [p: string]: PromiseSettledResult; -}> | Promise; +export declare function promiseAllControl( + promises: any[], + settled?: boolean, + promise?: any +): + | Promise<{ + [p: string]: PromiseSettledResult; + }> + | Promise; export declare function clearRequireCache(filename: string): void; @@ -40,9 +46,9 @@ export declare function dotSet(obj: T, path: string, value: un export declare function makeDirs(path: string): void; -export declare function parseByteString(value: string|number): number; +export declare function parseByteString(value: string | number): number; -export declare function uniq(arr: Array): Array; +export declare function uniq(arr: Array): Array; export declare function getConstructorName(obj: any): string; diff --git a/src/validators/base.d.ts b/src/validators/base.d.ts index 4962c85f9..b8b9513ed 100644 --- a/src/validators/base.d.ts +++ b/src/validators/base.d.ts @@ -26,6 +26,5 @@ declare abstract class BaseValidator { abstract convertSchemaToMoleculer(schema: any): Record; middleware(broker: ServiceBroker); - } export = BaseValidator; diff --git a/src/validators/fastest.d.ts b/src/validators/fastest.d.ts index 7940181ad..348d2ab78 100644 --- a/src/validators/fastest.d.ts +++ b/src/validators/fastest.d.ts @@ -1,11 +1,13 @@ import type BaseValidator = require("./base"); -import type {ValidatorConstructorOptions} from "fastest-validator"; +import type { ValidatorConstructorOptions } from "fastest-validator"; declare namespace FastestValidator { export type ValidatorNames = "Fastest"; - export interface FastestValidatorOptions extends ValidatorConstructorOptions, BaseValidator.ValidatorOptions {} + export interface FastestValidatorOptions + extends ValidatorConstructorOptions, + BaseValidator.ValidatorOptions {} } declare class FastestValidator extends BaseValidator { @@ -16,6 +18,5 @@ declare class FastestValidator extends BaseValidator { compile(schema: Record): BaseValidator.CheckerFunction; validate(params: Record, schema: Record): boolean; convertSchemaToMoleculer(schema: any): Record; - } export = FastestValidator; diff --git a/src/validators/index.d.ts b/src/validators/index.d.ts index 4214b8e0c..68e6acd1e 100644 --- a/src/validators/index.d.ts +++ b/src/validators/index.d.ts @@ -4,5 +4,5 @@ import FastestValidator = require("./fastest"); export { Validator as Base, FastestValidator as Fastest, ValidatorNames, ValidatorOptions }; -export declare function resolve(opt: Record|string): Validator; +export declare function resolve(opt: Record | string): Validator; export declare function register(name: string, value: Validator): void;