workers

Documentation

Index

• func InitWorkers(config viper.Viper, auditChannel *chan types.AuditRecord, ...)
• func StopWorkers(stopChannel *chan bool)
• type Worker
  • func (w *Worker) WriteAudit(auditChannel *chan types.AuditRecord, stopChannel *chan bool, db *gorm.DB)
  • func (w *Worker) WriteLog(logChannel *chan map[string]interface{}, stopChannel *chan bool)

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