How to use kayvee - 6 common examples
To help you get started, we’ve selected a few kayvee examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
Clever / wag / samples / gen-js-db / index.js View on Github 
this.keepalive = options.keepalive;
} else {
this.keepalive = true;
}
if (options.timeout) {
this.timeout = options.timeout;
} else {
this.timeout = 5000;
}
if (options.retryPolicy) {
this.retryPolicy = options.retryPolicy;
}
if (options.logger) {
this.logger = options.logger;
} else {
this.logger = new kayvee.logger((options.serviceName || "swagger-test") + "-wagclient");
}
const circuitOptions = Object.assign({}, defaultCircuitOptions, options.circuit);
this._hystrixCommand = commandFactory.getOrCreate(options.serviceName || "swagger-test").
errorHandler(this._hystrixCommandErrorHandler).
circuitBreakerForceClosed(circuitOptions.forceClosed).
requestVolumeRejectionThreshold(circuitOptions.maxConcurrentRequests).
circuitBreakerRequestVolumeThreshold(circuitOptions.requestVolumeThreshold).
circuitBreakerSleepWindowInMilliseconds(circuitOptions.sleepWindow).
circuitBreakerErrorThresholdPercentage(circuitOptions.errorPercentThreshold).
timeout(0).
statisticalWindowLength(10000).
statisticalWindowNumberOfBuckets(10).
run(this._hystrixCommandRun).
context(this).
build();this.keepalive = options.keepalive;
} else {
this.keepalive = true;
}
if (options.timeout) {
this.timeout = options.timeout;
} else {
this.timeout = 5000;
}
if (options.retryPolicy) {
this.retryPolicy = options.retryPolicy;
}
if (options.logger) {
this.logger = options.logger;
} else {
this.logger = new kayvee.logger((options.serviceName || "swagger-test") + "-wagclient");
}
const circuitOptions = Object.assign({}, defaultCircuitOptions, options.circuit);
this._hystrixCommand = commandFactory.getOrCreate(options.serviceName || "swagger-test").
errorHandler(this._hystrixCommandErrorHandler).
circuitBreakerForceClosed(circuitOptions.forceClosed).
requestVolumeRejectionThreshold(circuitOptions.maxConcurrentRequests).
circuitBreakerRequestVolumeThreshold(circuitOptions.requestVolumeThreshold).
circuitBreakerSleepWindowInMilliseconds(circuitOptions.sleepWindow).
circuitBreakerErrorThresholdPercentage(circuitOptions.errorPercentThreshold).
timeout(0).
statisticalWindowLength(10000).
statisticalWindowNumberOfBuckets(10).
run(this._hystrixCommandRun).
context(this).
build();this.keepalive = options.keepalive;
} else {
this.keepalive = true;
}
if (options.timeout) {
this.timeout = options.timeout;
} else {
this.timeout = 5000;
}
if (options.retryPolicy) {
this.retryPolicy = options.retryPolicy;
}
if (options.logger) {
this.logger = options.logger;
} else {
this.logger = new kayvee.logger((options.serviceName || "nil-test") + "-wagclient");
}
const circuitOptions = Object.assign({}, defaultCircuitOptions, options.circuit);
this._hystrixCommand = commandFactory.getOrCreate(options.serviceName || "nil-test").
errorHandler(this._hystrixCommandErrorHandler).
circuitBreakerForceClosed(circuitOptions.forceClosed).
requestVolumeRejectionThreshold(circuitOptions.maxConcurrentRequests).
circuitBreakerRequestVolumeThreshold(circuitOptions.requestVolumeThreshold).
circuitBreakerSleepWindowInMilliseconds(circuitOptions.sleepWindow).
circuitBreakerErrorThresholdPercentage(circuitOptions.errorPercentThreshold).
timeout(0).
statisticalWindowLength(10000).
statisticalWindowNumberOfBuckets(10).
run(this._hystrixCommandRun).
context(this).
build();this.keepalive = options.keepalive;
} else {
this.keepalive = true;
}
if (options.timeout) {
this.timeout = options.timeout;
} else {
this.timeout = 5000;
}
if (options.retryPolicy) {
this.retryPolicy = options.retryPolicy;
}
if (options.logger) {
this.logger = options.logger;
} else {
this.logger = new kayvee.logger((options.serviceName || "blog") + "-wagclient");
}
const circuitOptions = Object.assign({}, defaultCircuitOptions, options.circuit);
this._hystrixCommand = commandFactory.getOrCreate(options.serviceName || "blog").
errorHandler(this._hystrixCommandErrorHandler).
circuitBreakerForceClosed(circuitOptions.forceClosed).
requestVolumeRejectionThreshold(circuitOptions.maxConcurrentRequests).
circuitBreakerRequestVolumeThreshold(circuitOptions.requestVolumeThreshold).
circuitBreakerSleepWindowInMilliseconds(circuitOptions.sleepWindow).
circuitBreakerErrorThresholdPercentage(circuitOptions.errorPercentThreshold).
timeout(0).
statisticalWindowLength(10000).
statisticalWindowNumberOfBuckets(10).
run(this._hystrixCommandRun).
context(this).
build();this.keepalive = options.keepalive;
} else {
this.keepalive = true;
}
if (options.timeout) {
this.timeout = options.timeout;
} else {
this.timeout = 5000;
}
if (options.retryPolicy) {
this.retryPolicy = options.retryPolicy;
}
if (options.logger) {
this.logger = options.logger;
} else {
this.logger = new kayvee.logger((options.serviceName || "swagger-test") + "-wagclient");
}
const circuitOptions = Object.assign({}, defaultCircuitOptions, options.circuit);
this._hystrixCommand = commandFactory.getOrCreate(options.serviceName || "swagger-test").
errorHandler(this._hystrixCommandErrorHandler).
circuitBreakerForceClosed(circuitOptions.forceClosed).
requestVolumeRejectionThreshold(circuitOptions.maxConcurrentRequests).
circuitBreakerRequestVolumeThreshold(circuitOptions.requestVolumeThreshold).
circuitBreakerSleepWindowInMilliseconds(circuitOptions.sleepWindow).
circuitBreakerErrorThresholdPercentage(circuitOptions.errorPercentThreshold).
timeout(0).
statisticalWindowLength(10000).
statisticalWindowNumberOfBuckets(10).
run(this._hystrixCommandRun).
context(this).
build();this.keepalive = options.keepalive;
} else {
this.keepalive = true;
}
if (options.timeout) {
this.timeout = options.timeout;
} else {
this.timeout = 5000;
}
if (options.retryPolicy) {
this.retryPolicy = options.retryPolicy;
}
if (options.logger) {
this.logger = options.logger;
} else {
this.logger = new kayvee.logger((options.serviceName || "swagger-test") + "-wagclient");
}
const circuitOptions = Object.assign({}, defaultCircuitOptions, options.circuit);
this._hystrixCommand = commandFactory.getOrCreate(options.serviceName || "swagger-test").
errorHandler(this._hystrixCommandErrorHandler).
circuitBreakerForceClosed(circuitOptions.forceClosed).
requestVolumeRejectionThreshold(circuitOptions.maxConcurrentRequests).
circuitBreakerRequestVolumeThreshold(circuitOptions.requestVolumeThreshold).
circuitBreakerSleepWindowInMilliseconds(circuitOptions.sleepWindow).
circuitBreakerErrorThresholdPercentage(circuitOptions.errorPercentThreshold).
timeout(0).
statisticalWindowLength(10000).
statisticalWindowNumberOfBuckets(10).
run(this._hystrixCommandRun).
context(this).
build();kayvee
Write data to key=val pairs, for human and machine readability
