elastiwatch

package
v0.0.0-...-3abce5f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 13, 2023 License: BSD-3-Clause Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DB

type DB struct {
	*base.DB
}

func NewDB

func NewDB(db *sql.DB) *DB

func (*DB) Create

func (d *DB) Create(regex, author string) error

func (*DB) List

func (d *DB) List() (res []deferral, err error)

func (*DB) Remove

func (d *DB) Remove(id int) error

type HTTPSrv

type HTTPSrv struct {
	*base.HTTPSrv
	// contains filtered or unexported fields
}

func NewHTTPSrv

func NewHTTPSrv(stats *base.StatsRegistry, kbc *kbchat.API, debugConfig *base.ChatDebugOutputConfig, db *DB) *HTTPSrv

type Handler

type Handler struct {
	*base.DebugOutput
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(kbc *kbchat.API, debugConfig *base.ChatDebugOutputConfig,
	httpSrv *HTTPSrv, db *DB, logs *LogWatch) *Handler

func (*Handler) HandleCommand

func (h *Handler) HandleCommand(msg chat1.MsgSummary) error

func (*Handler) HandleNewConv

func (h *Handler) HandleNewConv(chat1.ConvSummary) error

type LogWatch

type LogWatch struct {
	*base.DebugOutput
	// contains filtered or unexported fields
}

func NewLogWatch

func NewLogWatch(cli *elastic.Client, db *DB, index, email string, emailer base.Emailer,
	alertConvID, emailConvID chat1.ConvIDStr, debugConfig *base.ChatDebugOutputConfig) *LogWatch

func (*LogWatch) Peek

func (l *LogWatch) Peek()

func (*LogWatch) Run

func (l *LogWatch) Run() error

func (*LogWatch) Shutdown

func (l *LogWatch) Shutdown() (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL