gofmt
This commit is contained in:
@ -167,7 +167,7 @@ func (r *Registry) PeerURLs(leaderName, selfName string) []string {
|
|||||||
|
|
||||||
// Removes a node from the cache.
|
// Removes a node from the cache.
|
||||||
func (r *Registry) Invalidate(name string) {
|
func (r *Registry) Invalidate(name string) {
|
||||||
delete(r.nodes, name)
|
delete(r.nodes, name)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Loads the given node by name from the store into the cache.
|
// Loads the given node by name from the store into the cache.
|
||||||
|
@ -59,7 +59,7 @@ func (c *RemoveCommand) Apply(server *raft.Server) (interface{}, error) {
|
|||||||
log.Debugf("ignore previous remove command.")
|
log.Debugf("ignore previous remove command.")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
b := make([]byte, 8)
|
b := make([]byte, 8)
|
||||||
binary.PutUvarint(b, server.CommitIndex())
|
binary.PutUvarint(b, server.CommitIndex())
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user