From d5364183fa2d0580145f92f8f824486146fabb42 Mon Sep 17 00:00:00 2001 From: tnextday Date: Tue, 29 Mar 2016 23:35:28 +0800 Subject: [PATCH] update --- go/topology/topology_replicate.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/go/topology/topology_replicate.go b/go/topology/topology_replicate.go index 129c1b65b..a491e5d91 100644 --- a/go/topology/topology_replicate.go +++ b/go/topology/topology_replicate.go @@ -57,6 +57,10 @@ func (t *ReplicateTask) WorkingDataNodes() []*DataNode { } } +func (t *ReplicateTask) String() string { + return fmt.Sprintf(" vid: %v, src: %s, dst: %s", t.Vid, t.SrcDN.Url(), t.DstDN.Url()) +} + func planReplicateTasks(t *Topology) (tasks []*ReplicateTask) { for i1 := range t.collectionMap.IterItems() { c := i1.Value.(*Collection)