Commit 4adb23c8 authored by Timothy St. Clair's avatar Timothy St. Clair

Update dependency shift from etcd3 changes in latest release.

parent 5f008faa
...@@ -153,7 +153,7 @@ func compact(ctx context.Context, client *clientv3.Client, t, rev int64) (int64, ...@@ -153,7 +153,7 @@ func compact(ctx context.Context, client *clientv3.Client, t, rev int64) (int64,
// We don't compact on bootstrap. // We don't compact on bootstrap.
return curTime, curRev, nil return curTime, curRev, nil
} }
if err = client.Compact(ctx, rev); err != nil { if _, err = client.Compact(ctx, rev); err != nil {
return curTime, curRev, err return curTime, curRev, err
} }
glog.Infof("etcd: compacted rev (%d), endpoints (%v)", rev, client.Endpoints()) glog.Infof("etcd: compacted rev (%d), endpoints (%v)", rev, client.Endpoints())
......
...@@ -36,14 +36,19 @@ func TestCompact(t *testing.T) { ...@@ -36,14 +36,19 @@ func TestCompact(t *testing.T) {
t.Fatalf("Put failed: %v", err) t.Fatalf("Put failed: %v", err)
} }
_, _, err = compact(ctx, client, 0, putResp.Header.Revision) putResp1, err := client.Put(ctx, "/somekey", "data2")
if err != nil {
t.Fatalf("Put failed: %v", err)
}
_, _, err = compact(ctx, client, 0, putResp1.Header.Revision)
if err != nil { if err != nil {
t.Fatalf("compact failed: %v", err) t.Fatalf("compact failed: %v", err)
} }
_, err = client.Get(ctx, "/somekey", clientv3.WithRev(putResp.Header.Revision)) obj, err := client.Get(ctx, "/somekey", clientv3.WithRev(putResp.Header.Revision))
if err != etcdrpc.ErrCompacted { if err != etcdrpc.ErrCompacted {
t.Errorf("Expecting ErrCompacted, but get=%v", err) t.Errorf("Expecting ErrCompacted, but get=%v err=%v", obj, err)
} }
} }
......
...@@ -18,7 +18,7 @@ package etcd3 ...@@ -18,7 +18,7 @@ package etcd3
import ( import (
"github.com/coreos/etcd/clientv3" "github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/storage/storagepb" "github.com/coreos/etcd/mvcc/mvccpb"
) )
type event struct { type event struct {
...@@ -29,7 +29,7 @@ type event struct { ...@@ -29,7 +29,7 @@ type event struct {
isCreated bool isCreated bool
} }
func parseKV(kv *storagepb.KeyValue) *event { func parseKV(kv *mvccpb.KeyValue) *event {
return &event{ return &event{
key: string(kv.Key), key: string(kv.Key),
value: kv.Value, value: kv.Value,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment