diff options
| author | chrislu <chris.lu@gmail.com> | 2022-05-30 16:23:52 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-05-30 16:23:52 -0700 |
| commit | 682382648e36ee7228c2ca630a976e92bf9aa84d (patch) | |
| tree | 4419a763c19dff8f677639904211efa5d1eb1cc9 /weed/cluster/cluster.go | |
| parent | 968ca95b49525fa2be1009163df5a2c1c81fb96c (diff) | |
| download | seaweedfs-682382648e36ee7228c2ca630a976e92bf9aa84d.tar.xz seaweedfs-682382648e36ee7228c2ca630a976e92bf9aa84d.zip | |
collect cluster node start time
Diffstat (limited to 'weed/cluster/cluster.go')
| -rw-r--r-- | weed/cluster/cluster.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/cluster/cluster.go b/weed/cluster/cluster.go index 86daf24e7..6c24df44c 100644 --- a/weed/cluster/cluster.go +++ b/weed/cluster/cluster.go @@ -28,7 +28,7 @@ type ClusterNode struct { Address pb.ServerAddress Version string counter int - createdTs time.Time + CreatedTs time.Time } type Cluster struct { @@ -72,7 +72,7 @@ func (cluster *Cluster) AddClusterNode(ns, nodeType string, address pb.ServerAdd Address: address, Version: version, counter: 1, - createdTs: time.Now(), + CreatedTs: time.Now(), } return cluster.ensureFilerLeaders(filers, true, filerGroup, nodeType, address) case BrokerType: @@ -86,7 +86,7 @@ func (cluster *Cluster) AddClusterNode(ns, nodeType string, address pb.ServerAdd Address: address, Version: version, counter: 1, - createdTs: time.Now(), + CreatedTs: time.Now(), } return []*master_pb.KeepConnectedResponse{ { @@ -238,7 +238,7 @@ func (cluster *Cluster) ensureFilerLeaders(filers *Filers, isAdd bool, filerGrou if filers.leaders.isOneLeader(node.Address) { continue } - duration := now.Sub(node.createdTs).Nanoseconds() + duration := now.Sub(node.CreatedTs).Nanoseconds() if duration < shortestDuration { shortestDuration = duration candidateAddress = node.Address |