fix(buffer): use correct name
This commit is contained in:
@@ -5,7 +5,7 @@ import { RedisBuffer } from './buffer';
|
|||||||
type BufferType = IClickhouseBotEvent;
|
type BufferType = IClickhouseBotEvent;
|
||||||
export class BotBuffer extends RedisBuffer<BufferType> {
|
export class BotBuffer extends RedisBuffer<BufferType> {
|
||||||
constructor() {
|
constructor() {
|
||||||
super(TABLE_NAMES.events, 500);
|
super(TABLE_NAMES.events_bots, 500);
|
||||||
}
|
}
|
||||||
|
|
||||||
protected async insertIntoDB(items: BufferType[]): Promise<void> {
|
protected async insertIntoDB(items: BufferType[]): Promise<void> {
|
||||||
|
|||||||
Reference in New Issue
Block a user