forked from mesos/mr-redis
-
Notifications
You must be signed in to change notification settings - Fork 0
/
test_store.go
52 lines (38 loc) · 1.17 KB
/
test_store.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
package main
import (
"./id"
"./store/etcd"
"./types"
"log"
)
func main() {
/* Create a variable on the implemented datastore , in this case etcd */
types.Gdb = etcd.New()
/* Setup etcd with the etcd endpoint*/
err := types.Gdb.Setup("http://10.11.12.24:2379")
/* Test if this is setup */
log.Printf("IsSetup %v\n", types.Gdb.IsSetup())
/*Create a dummy Instance */
uid, _ := id.NewUUID()
uid_str := uid.String()
err = types.Gdb.Set(uid_str, "How are you")
if err != nil {
log.Println("Error setting value ", err)
}
value, err := types.Gdb.Get(uid_str)
log.Printf("GET err:%v, value:%v\n", err, value)
/* Use the instance library */
I := types.NewInstance("TestInstance", "S", 1, 0)
I.Status = "Innactive"
/* Write the entier data to db store */
if !I.Sync() {
log.Printf("Failed to write the structure to etcd")
}
J := &types.Instance{}
J.Name = "TestInstance"
if !J.Load() {
log.Printf("Failed to read the structure from the store")
}
/* Print the contents of the structure read fromt he store */
log.Printf("Value read from store {Name : %s, Type : %s, Masters : %d, Slaves : %d, Status : %s}", J.Name, J.Type, J.Masters, J.Slaves, J.Status)
}