cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix go vet: address go vet warnings

Browse Source 
License: MIT
Signed-off-by: Hector Sanjuan <code@hector.link>
This commit is contained in:
Hector Sanjuan 2017-12-06 13:48:41 +01:00
parent c0628e43ff
commit 9a246a237d
5 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cluster.go
View File

@ -314,7 +314,6 @@ func (c *Cluster) pushPingMetrics() {
case <-ticker.C: case <-ticker.C:
} }
} }
logger.Debugf("Peer %s. Finished pushPingMetrics", c.id)
} }
// read the alerts channel from the monitor and triggers repins // read the alerts channel from the monitor and triggers repins

2
cluster_config.go
View File

@ -253,7 +253,7 @@ func (cfg *Config) LoadJSON(raw []byte) error {
clusterSecret, err := DecodeClusterSecret(jcfg.Secret) clusterSecret, err := DecodeClusterSecret(jcfg.Secret)
if err != nil { if err != nil {
err = fmt.Errorf("error loading cluster secret from config: ", err) err = fmt.Errorf("error loading cluster secret from config: %s", err)
return err return err
} }
cfg.Secret = clusterSecret cfg.Secret = clusterSecret

6
consensus/raft/consensus_test.go
View File

@ -141,7 +141,8 @@ func TestConsensusAddPeer(t *testing.T) {
t.Error("the operation did not make it to the log:", err) t.Error("the operation did not make it to the log:", err)
} }
ctx, _ := context.WithTimeout(context.Background(), 10*time.Second) ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
err = cc2.raft.WaitForPeer(ctx, cc.host.ID().Pretty(), false) err = cc2.raft.WaitForPeer(ctx, cc.host.ID().Pretty(), false)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
@ -173,7 +174,8 @@ func TestConsensusRmPeer(t *testing.T) {
t.Error("could not add peer:", err) t.Error("could not add peer:", err)
} }
ctx, _ := context.WithTimeout(context.Background(), 20*time.Second) ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
defer cancel()
err = cc.raft.WaitForPeer(ctx, cc2.host.ID().Pretty(), false) err = cc.raft.WaitForPeer(ctx, cc2.host.ID().Pretty(), false)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)

2
consensus/raft/raft.go
View File

@ -152,7 +152,7 @@ func newRaftWrapper(peers []peer.ID, host host.Host, cfg *Config, fsm hraft.FSM)
logger.Error("Raft peers do not match cluster peers from the configuration.") logger.Error("Raft peers do not match cluster peers from the configuration.")
logger.Error("This likely indicates that this peer has left the cluster and/or") logger.Error("This likely indicates that this peer has left the cluster and/or")
logger.Error("has a dirty state. Clean the raft state for this peer") logger.Error("has a dirty state. Clean the raft state for this peer")
logger.Error("(%s)", dataFolder) logger.Errorf("(%s)", dataFolder)
logger.Error("bootstrap it to a working cluster.") logger.Error("bootstrap it to a working cluster.")
logger.Error("Raft peers:") logger.Error("Raft peers:")
for _, s := range currentCfg.Servers { for _, s := range currentCfg.Servers {

1
ipfs-cluster-service/main.go
View File

@ -361,7 +361,6 @@ func daemon(c *cli.Context) error {
//case <-cluster.Ready(): //case <-cluster.Ready():
} }
} }
return nil
} }
var facilities = []string{ var facilities = []string{