valarm

package

v0.0.2 Latest Latest Go to latest Published: Mar 30, 2025 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Alarm struct {
	Options *Options
	// contains filtered or unexported fields
}

func New(options map[string]any) (alarm *Alarm, err error)

New create new alarm

func (alarm *Alarm) GetMsg(msgM vmap.M) (dataJson string)

GetMsg get message

func (alarm *Alarm) Process() (data *gmap.Map)

Process processes message

func (alarm *Alarm) Push(title string, service string, trace string, content string)

Push pushes the data into the queue data deduplication rule: service + title + trace

func (alarm *Alarm) Run()

Run send msg

func (alarm *Alarm) RunCron() (err error)

RunCron send msg by cron

func (alarm *Alarm) Send(msg string) (err error)

Send sends message

func (alarm *Alarm) SetConfig(options map[string]any) (err error)

SetConfig set config

type Options struct {
	QueueMaxSize int
	SendInterval int // second
	Url          string
}