workers

package
Version: v0.1.5 Latest Latest
Warning

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

Go to latest
Published: Jun 24, 2019 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitWorkers

func InitWorkers(config viper.Viper, auditChannel *chan types.AuditRecord, logChannel *chan map[string]interface{}, stopChannel *chan bool, db *gorm.DB)

InitWorkers is the function thats starts workers

func StopWorkers

func StopWorkers(stopChannel *chan bool)

StopWorkers it is a function interrupts the workers

Types

type Worker

type Worker struct{}

Worker is default interface for workers

func (*Worker) WriteAudit

func (w *Worker) WriteAudit(auditChannel *chan types.AuditRecord, stopChannel *chan bool, db *gorm.DB)

WriteAudit is the function thats receive AuditRecord from channel auditChannel and handle it

func (*Worker) WriteLog

func (w *Worker) WriteLog(logChannel *chan map[string]interface{}, stopChannel *chan bool)

WriteLog is the function thats receive map from channel auditRecordChannel and handle it

Source Files

Jump to

Keyboard shortcuts

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