-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmain.go
42 lines (37 loc) · 909 Bytes
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package main
import (
"github.com/YasiruR/db-writer/arangodb"
"github.com/YasiruR/db-writer/domain"
"github.com/YasiruR/db-writer/elasticsearch"
"github.com/YasiruR/db-writer/neo4j"
"github.com/YasiruR/db-writer/redis"
)
func main() {
banner()
dbCfg, dataCfg, testCfg, file := parseArg()
values := readData(file, &dataCfg)
var db domain.Database
switch dbCfg.Typ {
case domain.Redis:
db = redis.Client()
case domain.Neo4j:
db = neo4j.Client()
case domain.ElasticSearch:
db = elasticsearch.Client()
case domain.ArangoDB:
db = arangodb.Client()
}
db = db.Init(dbCfg)
if testCfg.Typ == `` {
db.Write(values, dataCfg)
return
}
switch testCfg.Typ {
case domain.BenchmarkRead:
db.BenchmarkRead(values, dataCfg, testCfg)
case domain.BenchmarkWrite:
db.BenchmarkWrite(values, dataCfg, testCfg)
case domain.BenchmarkUpdate:
db.BenchmarkWrite(values, dataCfg, testCfg)
}
}