diff options
author | Emiliano Ciavatta | 2020-04-09 10:37:48 +0000 |
---|---|---|
committer | Emiliano Ciavatta | 2020-04-09 10:37:48 +0000 |
commit | 7ca2f30a0eb21e22071f4e6b04a5207fa273d283 (patch) | |
tree | 63acb98147ffda7606bdf81abe2894e5f8363bd9 /rules_manager.go | |
parent | 0520dab47d61e2c4de246459bf4f5c72d69182d3 (diff) |
Refactor connection_handler
Diffstat (limited to 'rules_manager.go')
-rw-r--r-- | rules_manager.go | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/rules_manager.go b/rules_manager.go index e5a8d38..69439e0 100644 --- a/rules_manager.go +++ b/rules_manager.go @@ -52,6 +52,11 @@ type Rule struct { Version int64 `json:"version" bson:"version"` } +type RulesDatabase struct { + database hyperscan.StreamDatabase + version RowID +} + type RulesManager struct { storage Storage rules map[string]Rule @@ -59,7 +64,7 @@ type RulesManager struct { ruleIndex int patterns map[string]Pattern mPatterns sync.Mutex - databaseUpdated chan interface{} + databaseUpdated chan RulesDatabase } func NewRulesManager(storage Storage) RulesManager { @@ -153,7 +158,10 @@ func (rm RulesManager) generateDatabase(version RowID) error { return err } - rm.databaseUpdated <- database + rm.databaseUpdated <- RulesDatabase{ + database: database, + version: version, + } return nil } |