fix(core): update
This commit is contained in:
		@@ -7,6 +7,7 @@ tap.test('first test', async () => {
 | 
			
		||||
  testClickhouseDb = new smartclickhouse.SmartClickHouseDb({
 | 
			
		||||
    url: 'http://localhost:8123',
 | 
			
		||||
    database: 'test2',
 | 
			
		||||
    unref: true,
 | 
			
		||||
  });
 | 
			
		||||
});
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -3,6 +3,6 @@
 | 
			
		||||
 */
 | 
			
		||||
export const commitinfo = {
 | 
			
		||||
  name: '@pushrocks/smartclickhouse',
 | 
			
		||||
  version: '2.0.8',
 | 
			
		||||
  version: '2.0.9',
 | 
			
		||||
  description: 'an odm for talking to clickhouse'
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
@@ -7,6 +7,12 @@ export interface IClickhouseConstructorOptions {
 | 
			
		||||
  database: string;
 | 
			
		||||
  username?: string;
 | 
			
		||||
  password?: string;
 | 
			
		||||
  /**
 | 
			
		||||
   * allow services to exit when waiting for clickhouse startup
 | 
			
		||||
   * this allows to leave the lifecycle flow to other processes
 | 
			
		||||
   * like a listening server.
 | 
			
		||||
   */
 | 
			
		||||
  unref?: boolean;
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
export class SmartClickHouseDb {
 | 
			
		||||
@@ -44,7 +50,7 @@ export class SmartClickHouseDb {
 | 
			
		||||
      });
 | 
			
		||||
      if (!available) {
 | 
			
		||||
        console.log(`NOT OK: tried pinging ${this.options.url}... Trying again in 5 seconds.`);
 | 
			
		||||
        await plugins.smartdelay.delayFor(5000);
 | 
			
		||||
        await plugins.smartdelay.delayFor(5000, null, this.options.unref);
 | 
			
		||||
      }
 | 
			
		||||
    }
 | 
			
		||||
  }
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user