/
init.go
55 lines (47 loc) · 1.39 KB
/
init.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
43
44
45
46
47
48
49
50
51
52
53
54
55
package main
import (
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/service/dynamodb/expression"
"github.com/eniac/Beldi/pkg/beldilib"
"os"
"time"
)
func ClearAll() {
beldilib.DeleteLambdaTables("singleop")
beldilib.DeleteLambdaTables("nop")
beldilib.DeleteTable("bsingleop")
beldilib.DeleteTable("bnop")
beldilib.DeleteLambdaTables("tsingleop")
beldilib.DeleteLambdaTables("tnop")
}
func main() {
if len(os.Args) >= 2 {
option := os.Args[1]
if option == "clean" {
ClearAll()
return
}
}
ClearAll()
beldilib.WaitUntilAllDeleted([]string{
"singleop", "singleop-log", "singleop-collector",
"nop", "nop-log", "nop-collector",
"tsingleop", "tsingleop-log", "tsingleop-collector",
"tnop", "tnop-log", "tnop-collector",
"bsingleop", "bnop",
})
beldilib.CreateLambdaTables("singleop")
beldilib.CreateLambdaTables("nop")
beldilib.CreateBaselineTable("bsingleop")
beldilib.CreateBaselineTable("bnop")
beldilib.CreateTxnTables("tsingleop")
beldilib.CreateTxnTables("tnop")
time.Sleep(60 * time.Second)
beldilib.WriteNRows("singleop", "K", 20)
beldilib.LibWrite("bsingleop", aws.JSONValue{"K": "K"}, map[expression.NameBuilder]expression.OperandBuilder{
expression.Name("V"): expression.Value(1),
})
beldilib.LibWrite("tsingleop", aws.JSONValue{"K": "K"}, map[expression.NameBuilder]expression.OperandBuilder{
expression.Name("V"): expression.Value(1),
})
}