diff --git a/cmd/watcher/validator.go b/cmd/watcher/validator.go
index 889a228..d36f92e 100644
--- a/cmd/watcher/validator.go
+++ b/cmd/watcher/validator.go
@@ -44,13 +44,13 @@ func (v *validator) validate(products ...string) {
 	}()
 }
 
-func (v *validator) emit_products(products ...string) {
+func (v *validator) emitProducts(products ...string) {
 	for _, p := range products {
 		go v.validate_product(p)
 	}
 }
 
-func (v *validator) validate_product(product string) {
+func (v *validator) validateProduct(product string) {
 	v.logger.Info("Staring validation of %v", product)
 
 	results, err := v.db.TradeService().TradesAfterAll(product, 0)