ferrum-db-client
Advanced tools
Comparing version 0.3.2 to 0.3.3
@@ -57,3 +57,3 @@ "use strict"; | ||
async hasDatabase(dbName) { | ||
const msg = new database_server_pb_1.CreateDatabaseRequest(); | ||
const msg = new database_server_pb_1.HasDatabaseRequest(); | ||
msg.setName(dbName); | ||
@@ -60,0 +60,0 @@ const res = await (0, util_1.promisify)(this.client.hasDatabase.bind(this.client), msg); |
@@ -20,2 +20,3 @@ "use strict"; | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -31,2 +32,3 @@ const res = await (0, util_1.promisify)(this.client.hasSerie.bind(this.client), msg); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -43,2 +45,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -58,2 +61,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -70,2 +74,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -81,2 +86,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -92,2 +98,3 @@ const res = await (0, util_1.promisify)(this.client.listEntries.bind(this.client), msg); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -103,2 +110,3 @@ const res = await (0, util_1.promisify)(this.client.getEntries.bind(this.client), msg); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -115,2 +123,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -127,2 +136,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -139,2 +149,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -150,2 +161,3 @@ const res = await (0, util_1.promisify)(this.client.getLastEntry.bind(this.client), msg); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -161,2 +173,3 @@ const res = await (0, util_1.promisify)(this.client.getFirstEntry.bind(this.client), msg); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -173,2 +186,3 @@ msg.setN(count); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -185,2 +199,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -197,2 +212,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -210,2 +226,3 @@ msg.setFrom(start); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -224,2 +241,3 @@ const res = await (0, util_1.promisify)(this.client.deleteSerie.bind(this.client), msg); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -226,0 +244,0 @@ msg.setTimestamp(timestamp); |
{ | ||
"name": "ferrum-db-client", | ||
"version": "0.3.2", | ||
"version": "0.3.3", | ||
"main": "dist/index.js", | ||
@@ -5,0 +5,0 @@ "typings": "dist/index.d.ts", |
import { ChannelCredentials } from '@grpc/grpc-js'; | ||
import { FerrumDBRemote } from './db_remote'; | ||
import { DatabaseServerClient } from './proto/database_server_grpc_pb'; | ||
import { CreateDatabaseRequest } from './proto/database_server_pb'; | ||
import { CreateDatabaseRequest, HasDatabaseRequest } from './proto/database_server_pb'; | ||
import { EmptyRequest } from './proto/shared_pb'; | ||
@@ -74,3 +74,3 @@ import { CallbackReturnType, promisify } from './util'; | ||
public async hasDatabase(dbName: string): Promise<boolean> { | ||
const msg = new CreateDatabaseRequest(); | ||
const msg = new HasDatabaseRequest(); | ||
msg.setName(dbName); | ||
@@ -77,0 +77,0 @@ |
@@ -13,2 +13,4 @@ // package: timeseries | ||
setDatabase(value: string): HasSerieRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): HasSerieRequest; | ||
getSerie(): string; | ||
@@ -30,2 +32,3 @@ setSerie(value: string): HasSerieRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -64,2 +67,4 @@ } | ||
setDatabase(value: string): DeleteSerieRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): DeleteSerieRequest; | ||
getSerie(): string; | ||
@@ -81,2 +86,3 @@ setSerie(value: string): DeleteSerieRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -112,2 +118,4 @@ } | ||
setDatabase(value: string): ClearSerieRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): ClearSerieRequest; | ||
getSerie(): string; | ||
@@ -129,2 +137,3 @@ setSerie(value: string): ClearSerieRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -160,2 +169,4 @@ } | ||
setDatabase(value: string): ListSeriesRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): ListSeriesRequest; | ||
getSerie(): string; | ||
@@ -177,2 +188,3 @@ setSerie(value: string): ListSeriesRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -183,2 +195,4 @@ } | ||
export class ListSeriesResponse extends jspb.Message { | ||
getTimeseries(): string; | ||
setTimeseries(value: string): ListSeriesResponse; | ||
clearSeriesList(): void; | ||
@@ -206,2 +220,3 @@ getSeriesList(): Array<string>; | ||
export type AsObject = { | ||
timeseries: string, | ||
seriesList: Array<string>, | ||
@@ -215,2 +230,4 @@ error?: string, | ||
setDatabase(value: string): ListEntriesRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): ListEntriesRequest; | ||
getSerie(): string; | ||
@@ -232,2 +249,3 @@ setSerie(value: string): ListEntriesRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -268,2 +286,4 @@ } | ||
setDatabase(value: string): GetEntriesRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetEntriesRequest; | ||
getSerie(): string; | ||
@@ -285,2 +305,3 @@ setSerie(value: string): GetEntriesRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -323,2 +344,4 @@ } | ||
setDatabase(value: string): HasEntryRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): HasEntryRequest; | ||
getSerie(): string; | ||
@@ -342,2 +365,3 @@ setSerie(value: string): HasEntryRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -377,2 +401,4 @@ timestamp: number, | ||
setDatabase(value: string): GetEntryRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetEntryRequest; | ||
getSerie(): string; | ||
@@ -396,2 +422,3 @@ setSerie(value: string): GetEntryRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -436,2 +463,4 @@ timestamp: number, | ||
setDatabase(value: string): PutEntryRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): PutEntryRequest; | ||
getSerie(): string; | ||
@@ -459,2 +488,3 @@ setSerie(value: string): PutEntryRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -492,2 +522,4 @@ timestamp: number, | ||
setDatabase(value: string): DeleteEntryRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): DeleteEntryRequest; | ||
getSerie(): string; | ||
@@ -511,2 +543,3 @@ setSerie(value: string): DeleteEntryRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -543,2 +576,4 @@ timestamp: number, | ||
setDatabase(value: string): GetNearestEntryRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetNearestEntryRequest; | ||
getSerie(): string; | ||
@@ -562,2 +597,3 @@ setSerie(value: string): GetNearestEntryRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -605,2 +641,4 @@ timestamp: number, | ||
setDatabase(value: string): GetFirstEntryBeforeRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetFirstEntryBeforeRequest; | ||
getSerie(): string; | ||
@@ -624,2 +662,3 @@ setSerie(value: string): GetFirstEntryBeforeRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -667,2 +706,4 @@ timestamp: number, | ||
setDatabase(value: string): GetFirstEntryAfterRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetFirstEntryAfterRequest; | ||
getSerie(): string; | ||
@@ -686,2 +727,3 @@ setSerie(value: string): GetFirstEntryAfterRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -729,2 +771,4 @@ timestamp: number, | ||
setDatabase(value: string): GetFirstEntryRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetFirstEntryRequest; | ||
getSerie(): string; | ||
@@ -746,2 +790,3 @@ setSerie(value: string): GetFirstEntryRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -788,2 +833,4 @@ } | ||
setDatabase(value: string): GetLastEntryRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetLastEntryRequest; | ||
getSerie(): string; | ||
@@ -805,2 +852,3 @@ setSerie(value: string): GetLastEntryRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -847,2 +895,4 @@ } | ||
setDatabase(value: string): GetEntriesBetweenRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetEntriesBetweenRequest; | ||
getSerie(): string; | ||
@@ -868,2 +918,3 @@ setSerie(value: string): GetEntriesBetweenRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -913,2 +964,4 @@ from: number, | ||
setDatabase(value: string): GetFirstNEntriesRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetFirstNEntriesRequest; | ||
getSerie(): string; | ||
@@ -932,2 +985,3 @@ setSerie(value: string): GetFirstNEntriesRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -976,2 +1030,4 @@ n: number, | ||
setDatabase(value: string): GetLastNEntriesRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetLastNEntriesRequest; | ||
getSerie(): string; | ||
@@ -995,2 +1051,3 @@ setSerie(value: string): GetLastNEntriesRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -1039,2 +1096,4 @@ n: number, | ||
setDatabase(value: string): GetEntriesBeforeRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetEntriesBeforeRequest; | ||
getSerie(): string; | ||
@@ -1058,2 +1117,3 @@ setSerie(value: string): GetEntriesBeforeRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -1102,2 +1162,4 @@ timestamp: number, | ||
setDatabase(value: string): GetEntriesAfterRequest; | ||
getTimeseries(): string; | ||
setTimeseries(value: string): GetEntriesAfterRequest; | ||
getSerie(): string; | ||
@@ -1121,2 +1183,3 @@ setSerie(value: string): GetEntriesAfterRequest; | ||
database: string, | ||
timeseries: string, | ||
serie: string, | ||
@@ -1123,0 +1186,0 @@ timestamp: number, |
@@ -44,2 +44,3 @@ import { ChannelCredentials } from '@grpc/grpc-js'; | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -60,2 +61,3 @@ | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -77,2 +79,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -98,2 +101,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -115,2 +119,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -130,2 +135,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -146,2 +152,3 @@ | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -162,2 +169,3 @@ | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -182,2 +190,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -202,2 +211,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -222,2 +232,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -238,2 +249,3 @@ | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -257,2 +269,3 @@ | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -277,2 +290,3 @@ msg.setN(count); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -297,2 +311,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -317,2 +332,3 @@ msg.setTimestamp(timestamp); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -338,2 +354,3 @@ msg.setFrom(start); | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -357,2 +374,3 @@ | ||
msg.setDatabase(this.database); | ||
msg.setTimeseries(this.name); | ||
msg.setSerie(serie); | ||
@@ -359,0 +377,0 @@ msg.setTimestamp(timestamp); |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
1176536
27509