*: fix minor typos

Documentation/metrics.md

@@ -124,7 +124,7 @@ Example Prometheus queries that may be useful from these metrics (across all etc
  * `histogram_quantile(0.9, sum(increase(etcd_proxy_events_handling_time_seconds_bucket{job="etcd",method="GET"}[5m])) by (le))`
    `histogram_quantile(0.9, sum(increase(etcd_proxy_events_handling_time_seconds_bucket{job="etcd",method!="GET"}[5m])) by (le))`
     
-    Show the 0.90-tile latency (in seconds) of handling of user requestsacross all proxy machines, with a window of `5m`.  
+    Show the 0.90-tile latency (in seconds) of handling of user requests across all proxy machines, with a window of `5m`.  
  * `sum(rate(etcd_proxy_dropped_total{job="etcd"}[1m])) by (proxying_error)`
     
     Number of failed request on the proxy. This should be 0, spikes here indicate connectivity issues to etcd cluster.

etcdctlv3/command/lease_command.go

@@ -56,7 +56,7 @@ func NewLeaseCreateCommand() *cobra.Command {
 // leaseCreateCommandFunc executes the "lease create" command.
 func leaseCreateCommandFunc(cmd *cobra.Command, args []string) {
 	if len(args) != 1 {
-		ExitWithError(ExitBadArgs, fmt.Errorf("lease create command needs TTL arguement."))
+		ExitWithError(ExitBadArgs, fmt.Errorf("lease create command needs TTL argument."))
 	}
 
 	ttl, err := strconv.ParseInt(args[0], 10, 64)

etcdserver/etcdhttp/client_test.go

@@ -136,7 +136,7 @@ func (fr *flushingRecorder) Flush() {
 }
 
 // resServer implements the etcd.Server interface for testing.
-// It returns the given responsefrom any Do calls, and nil error
+// It returns the given response from any Do calls, and nil error
 type resServer struct {
 	res etcdserver.Response
 }

integration/v3_grpc_test.go

@@ -103,7 +103,7 @@ func TestV3PutOverwrite(t *testing.T) {
 	}
 }
 
-// TestV3DeleteRange tests various edge cases in teh DeleteRange API.
+// TestV3DeleteRange tests various edge cases in the DeleteRange API.
 func TestV3DeleteRange(t *testing.T) {
 	tests := []struct {
 		keySet []string

lease/lessor.go

@@ -150,7 +150,7 @@ func newLessor(lessorID uint8, b backend.Backend) *lessor {
 	l := &lessor{
 		leaseMap: make(map[LeaseID]*Lease),
 		b:        b,
-		// expiredC is a small buffered chan to avoid unncessary blocking.
+		// expiredC is a small buffered chan to avoid unnecessary blocking.
 		expiredC: make(chan []*Lease, 16),
 		stopC:    make(chan struct{}),
 		doneC:    make(chan struct{}),

pkg/transport/timeout_transport.go

@@ -28,7 +28,7 @@ func NewTimeoutTransport(info TLSInfo, dialtimeoutd, rdtimeoutd, wtimeoutd time.
 	if err != nil {
 		return nil, err
 	}
-	// the timeouted connection will tiemout soon after it is idle.
+	// the timeouted connection will timeout soon after it is idle.
 	// it should not be put back to http transport as an idle connection for future usage.
 	tr.MaxIdleConnsPerHost = -1
 	tr.Dial = (&rwTimeoutDialer{

rafthttp/msgappv2_codec.go

@@ -36,7 +36,7 @@ const (
 
 // msgappv2 stream sends three types of message: linkHeartbeatMessage,
 // AppEntries and MsgApp. AppEntries is the MsgApp that is sent in
-// replicate state in raft, whose index and term are fully predicatable.
+// replicate state in raft, whose index and term are fully predictable.
 //
 // Data format of linkHeartbeatMessage:
 // | offset | bytes | description |

rafthttp/pipeline_test.go

@@ -137,7 +137,7 @@ func TestPipelinePost(t *testing.T) {
 	picker := mustNewURLPicker(t, []string{"http://localhost:2380"})
 	p := newPipeline(tr, picker, types.ID(2), types.ID(1), types.ID(1), newPeerStatus(types.ID(1)), nil, &fakeRaft{}, nil)
 	if err := p.post([]byte("some data")); err != nil {
-		t.Fatalf("unexpect post error: %v", err)
+		t.Fatalf("unexpected post error: %v", err)
 	}
 	p.stop()