Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNoData = fmt.Errorf("fatal: no data returned for job")
)
View Source
var (
ResultQueue chan *m.AlertingJob
)
Functions ¶
func ChanExecutor ¶
func ChanExecutor(jobQueue <-chan *m.AlertingJob, cache *lru.Cache)
func InitResultHandler ¶
func InitResultHandler()
func LoadOrSetOffset ¶
func LoadOrSetOffset() int
func ProcessResult ¶
func ProcessResult(job *m.AlertingJob)
func StoreResult ¶
func StoreResult(job *m.AlertingJob)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.