Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

change api due to go-etcd

Browse Source
This commit is contained in:
Xiang Li 2013-08-01 17:42:06 -07:00
parent aa3f0b3a2a
commit e7f88579bd
2 changed files with 20 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
etcd_test.go
View File

@ -25,9 +25,11 @@ func TestSingleNode(t *testing.T) {
time.Sleep(time.Second) time.Sleep(time.Second)
etcd.SyncCluster() c := etcd.CreateClient()
c.SyncCluster()
// Test Set // Test Set
result, err := etcd.Set("foo", "bar", 100) result, err := c.Set("foo", "bar", 100)
if err != nil || result.Key != "/foo" || result.Value != "bar" || result.TTL != 99 { if err != nil || result.Key != "/foo" || result.Value != "bar" || result.TTL != 99 {
if err != nil { if err != nil {
@ -39,7 +41,7 @@ func TestSingleNode(t *testing.T) {
time.Sleep(time.Second) time.Sleep(time.Second)
result, err = etcd.Set("foo", "bar", 100) result, err = c.Set("foo", "bar", 100)
if err != nil || result.Key != "/foo" || result.Value != "bar" || result.PrevValue != "bar" || result.TTL != 99 { if err != nil || result.Key != "/foo" || result.Value != "bar" || result.PrevValue != "bar" || result.TTL != 99 {
if err != nil { if err != nil {
@ -64,9 +66,11 @@ func TestSingleNodeRecovery(t *testing.T) {
time.Sleep(time.Second) time.Sleep(time.Second)
etcd.SyncCluster() c := etcd.CreateClient()
c.SyncCluster()
// Test Set // Test Set
result, err := etcd.Set("foo", "bar", 100) result, err := c.Set("foo", "bar", 100)
if err != nil || result.Key != "/foo" || result.Value != "bar" || result.TTL != 99 { if err != nil || result.Key != "/foo" || result.Value != "bar" || result.TTL != 99 {
if err != nil { if err != nil {
@ -89,7 +93,7 @@ func TestSingleNodeRecovery(t *testing.T) {
time.Sleep(time.Second) time.Sleep(time.Second)
results, err := etcd.Get("foo") results, err := c.Get("foo")
if err != nil { if err != nil {
t.Fatal("get fail: " + err.Error()) t.Fatal("get fail: " + err.Error())
return return
@ -122,10 +126,12 @@ func TestSimpleMultiNode(t *testing.T) {
time.Sleep(time.Second) time.Sleep(time.Second)
etcd.SyncCluster() c := etcd.CreateClient()
c.SyncCluster()
// Test Set // Test Set
result, err := etcd.Set("foo", "bar", 100) result, err := c.Set("foo", "bar", 100)
if err != nil || result.Key != "/foo" || result.Value != "bar" || result.TTL != 99 { if err != nil || result.Key != "/foo" || result.Value != "bar" || result.TTL != 99 {
if err != nil { if err != nil {
@ -137,7 +143,7 @@ func TestSimpleMultiNode(t *testing.T) {
time.Sleep(time.Second) time.Sleep(time.Second)
result, err = etcd.Set("foo", "bar", 100) result, err = c.Set("foo", "bar", 100)
if err != nil || result.Key != "/foo" || result.Value != "bar" || result.PrevValue != "bar" || result.TTL != 99 { if err != nil || result.Key != "/foo" || result.Value != "bar" || result.PrevValue != "bar" || result.TTL != 99 {
if err != nil { if err != nil {
@ -165,7 +171,9 @@ func TestMultiNodeRecovery(t *testing.T) {
time.Sleep(2 * time.Second) time.Sleep(2 * time.Second)
etcd.SyncCluster() c := etcd.CreateClient()
c.SyncCluster()
stop := make(chan bool) stop := make(chan bool)
// Test Set // Test Set

4
test.go
View File

@ -22,11 +22,11 @@ func set(stop chan bool) {
stopSet := false stopSet := false
i := 0 i := 0
c := etcd.CreateClient()
for { for {
key := fmt.Sprintf("%s_%v", "foo", i) key := fmt.Sprintf("%s_%v", "foo", i)
result, err := etcd.Set(key, "bar", 0) result, err := c.Set(key, "bar", 0)
if err != nil || result.Key != "/"+key || result.Value != "bar" { if err != nil || result.Key != "/"+key || result.Value != "bar" {
select { select {