-
Notifications
You must be signed in to change notification settings - Fork 0
/
moleculer.config.js
156 lines (130 loc) · 5.37 KB
/
moleculer.config.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
"use strict";
/**
* Moleculer ServiceBroker configuration file
*
* More info about options: https://moleculer.services/docs/0.13/broker.html#Broker-options
*
* Overwrite options in production:
* ================================
* You can overwrite any option with environment variables.
* For example to overwrite the "logLevel", use `LOGLEVEL=warn` env var.
* To overwrite a nested parameter, e.g. retryPolicy.retries, use `RETRYPOLICY_RETRIES=10` env var.
*
* To overwrite broker’s deeply nested default options, which are not presented in "moleculer.config.js",
* via environment variables, use the `MOL_` prefix and double underscore `__` for nested properties in .env file.
* For example, to set the cacher prefix to `MYCACHE`, you should declare an env var as `MOL_CACHER__OPTIONS__PREFIX=MYCACHE`.
*/
module.exports = {
// Namespace of nodes to segment your nodes on the same network.
namespace: "",
// Unique node identifier. Must be unique in a namespace.
nodeID: null,
// Enable/disable logging or use custom logger. More info: https://moleculer.services/docs/0.13/logging.html
logger: true,
// Log level for built-in console logger. Available values: trace, debug, info, warn, error, fatal
logLevel: "info",
// Log formatter for built-in console logger. Available values: default, simple, short. It can be also a `Function`.
logFormatter: "default",
// Custom object & array printer for built-in console logger.
logObjectPrinter: null,
// Define transporter.
// More info: https://moleculer.services/docs/0.13/networking.html
transporter: null,
// Define a cacher. More info: https://moleculer.services/docs/0.13/caching.html
cacher: "Memory",
// Define a serializer.
// Available values: "JSON", "Avro", "ProtoBuf", "MsgPack", "Notepack", "Thrift".
// More info: https://moleculer.services/docs/0.13/networking.html
serializer: "JSON",
// Number of milliseconds to wait before reject a request with a RequestTimeout error. Disabled: 0
requestTimeout: 10 * 1000,
// Retry policy settings. More info: https://moleculer.services/docs/0.13/fault-tolerance.html#Retry
retryPolicy: {
// Enable feature
enabled: false,
// Count of retries
retries: 5,
// First delay in milliseconds.
delay: 100,
// Maximum delay in milliseconds.
maxDelay: 1000,
// Backoff factor for delay. 2 means exponential backoff.
factor: 2,
// A function to check failed requests.
check: err => err && !!err.retryable
},
// Limit of calling level. If it reaches the limit, broker will throw an MaxCallLevelError error. (Infinite loop protection)
maxCallLevel: 100,
// Number of seconds to send heartbeat packet to other nodes.
heartbeatInterval: 5,
// Number of seconds to wait before setting node to unavailable status.
heartbeatTimeout: 15,
// Tracking requests and waiting for running requests before shutdowning. More info: https://moleculer.services/docs/0.13/fault-tolerance.html
tracking: {
// Enable feature
enabled: false,
// Number of milliseconds to wait before shutdowning the process
shutdownTimeout: 5000,
},
// Disable built-in request & emit balancer. (Transporter must support it, as well.)
disableBalancer: false,
// Settings of Service Registry. More info: https://moleculer.services/docs/0.13/registry.html
registry: {
// Define balancing strategy.
// Available values: "RoundRobin", "Random", "CpuUsage", "Latency"
strategy: "RoundRobin",
// Enable local action call preferring.
preferLocal: true
},
// Settings of Circuit Breaker. More info: https://moleculer.services/docs/0.13/fault-tolerance.html#Circuit-Breaker
circuitBreaker: {
// Enable feature
enabled: false,
// Threshold value. 0.5 means that 50% should be failed for tripping.
threshold: 0.5,
// Minimum request count. Below it, CB does not trip.
minRequestCount: 20,
// Number of seconds for time window.
windowTime: 60,
// Number of milliseconds to switch from open to half-open state
halfOpenTime: 10 * 1000,
// A function to check failed requests.
check: err => err && err.code >= 500
},
// Settings of bulkhead feature. More info: https://moleculer.services/docs/0.13/fault-tolerance.html#Bulkhead
bulkhead: {
// Enable feature.
enabled: false,
// Maximum concurrent executions.
concurrency: 10,
// Maximum size of queue
maxQueueSize: 100,
},
// Enable parameters validation. More info: https://moleculer.services/docs/0.13/validating.html
validation: true,
// Custom Validator class for validation.
validator: null,
// Enable metrics function. More info: https://moleculer.services/docs/0.13/metrics.html
metrics: false,
// Rate of metrics calls. 1 means to measure every request, 0 means to measure nothing.
metricsRate: 1,
// Register internal services ("$node"). More info: https://moleculer.services/docs/0.13/services.html#Internal-services
internalServices: true,
// Register internal middlewares. More info: https://moleculer.services/docs/0.13/middlewares.html#Internal-middlewares
internalMiddlewares: true,
// Watch the loaded services and hot reload if they changed. You can also enable it in Moleculer Runner with `--hot` argument
hotReload: false,
// Register custom middlewares
middlewares: [],
// Called after broker created.
created(broker) {
},
// Called after broker starte.
started(broker) {
},
// Called after broker stopped.
stopped(broker) {
},
// Register custom REPL commands.
replCommands: null
};