Documentation
¶
Index ¶
- type Watchman
- func (w *Watchman) CheckClose() error
- func (w *Watchman) Close() error
- func (w *Watchman) Delmg(delmg int)
- func (w *Watchman) PreprosessDb(refreshcontext context.Context, msgchan chan any) (*preprosessd, error)
- func (w *Watchman) RefreshDb(refreshcontext context.Context, docount bool, forceReset bool) error
- func (w *Watchman) Start() error
- type Watchmanconfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Watchman ¶
type Watchman struct {
DeleteQue chan int64
// contains filtered or unexported fields
}
func New ¶
func New(ctx context.Context, ctrl *controller.Controller, btapi botapi.BotAPI, db *db.Database, config *Watchmanconfig, logger *zap.Logger, mgstore *botapi.MessageStore, ) (*Watchman, error)
func (*Watchman) CheckClose ¶
func (*Watchman) PreprosessDb ¶
type Watchmanconfig ¶
type Watchmanconfig struct {
//Simlogpath string `json:"box_log"`
Delbuffer int `json:"del_buffer"` //msg count to buffer before delete
}
Click to show internal directories.
Click to hide internal directories.