summaryrefslogtreecommitdiff
path: root/cleaner.go
diff options
context:
space:
mode:
authorDaniel Langesten <daniel.langest@gmail.com>2015-03-10 09:16:15 +0100
committerDaniel Langesten <daniel.langest@gmail.com>2015-03-10 09:16:15 +0100
commitb757248a2922052342fbdb9540eafe50a2497129 (patch)
tree7597bd5ffbed129277762c5e40e34c749f773bff /cleaner.go
parent86f9dcf142bf8ff872cf0f6f2d89f23ea229f516 (diff)
compile issues
Diffstat (limited to 'cleaner.go')
-rw-r--r--cleaner.go33
1 files changed, 14 insertions, 19 deletions
diff --git a/cleaner.go b/cleaner.go
index 5bda1f4..ba6f6ab 100644
--- a/cleaner.go
+++ b/cleaner.go
@@ -9,11 +9,10 @@ import (
)
const (
- DATABASE_USER = "root"
- DATABASE_PASS = "pass"
+ DATABASE_USER = "cleaner"
+ DATABASE_PASS = "nil"
DATABASE_CONNECTION = "" //e.g. "tcp(localhost:55555)
DATABASE_NAME = "netflow"
- MAXIMUM_ENTRIES = 100
TIMESPAN = "day"
EPSILON = 1000
)
@@ -34,7 +33,7 @@ func cleanData() (err error) {
}
//Fetch data that should be cleaned
- rDat, err := fetchRawData(db, MAXIMUM_ENTRIES)
+ rDat, err := fetchRawData(db, time.Now().Add(-1*time.Hour))
if err != nil {
log.Println("Faild to fetch raw data")
return
@@ -82,35 +81,31 @@ func cleanData() (err error) {
func getTimespan(t time.Time) (span time.Time, err error) {
loc, err := time.LoadLocation("Local")
+ if err != nil {
+ return
+ }
switch {
case TIMESPAN == "5min": //Round the date into 5 minutes
- y, m, d, h, min := t.Date()
- if err != nil {
- return
- }
+ y, m, d := t.Date()
+ h := t.Hour()
+ min := t.Minute()
min = min / 5
span = time.Date(y, m, d, h, min, 0, 0, loc)
case TIMESPAN == "10min": //Round the date into 10 minutes
- y, m, d, h, min := t.Date()
- if err != nil {
- return
- }
+ y, m, d := t.Date()
+ h := t.Hour()
+ min := t.Minute()
min = min / 10
span = time.Date(y, m, d, h, min, 0, 0, loc)
case TIMESPAN == "hour": //Round the date into hour
- y, m, d, h := t.Date()
- if err != nil {
- return
- }
+ y, m, d := t.Date()
+ h := t.Hour()
span = time.Date(y, m, d, h, 0, 0, 0, loc)
case TIMESPAN == "day": //Round the date into day
y, m, d := t.Date()
- if err != nil {
- return
- }
span = time.Date(y, m, d, 0, 0, 0, 0, loc)
default:
err = errors.New("Bad timespan")