diff --git a/Documentation/metrics.md b/Documentation/metrics.md index 4b6ab2635..c1de455ef 100644 --- a/Documentation/metrics.md +++ b/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. diff --git a/etcdctlv3/command/lease_command.go b/etcdctlv3/command/lease_command.go index 25761ad54..d456859df 100644 --- a/etcdctlv3/command/lease_command.go +++ b/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) diff --git a/etcdserver/etcdhttp/client_test.go b/etcdserver/etcdhttp/client_test.go index 2d3e2c1b6..fcb664826 100644 --- a/etcdserver/etcdhttp/client_test.go +++ b/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 } diff --git a/integration/v3_grpc_test.go b/integration/v3_grpc_test.go index 003e6f8c7..8577dc17f 100644 --- a/integration/v3_grpc_test.go +++ b/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 diff --git a/lease/lessor.go b/lease/lessor.go index 23d97b1c7..88151f6f7 100644 --- a/lease/lessor.go +++ b/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{}), diff --git a/pkg/transport/timeout_transport.go b/pkg/transport/timeout_transport.go index 365a0834b..2b6df6e02 100644 --- a/pkg/transport/timeout_transport.go +++ b/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{ diff --git a/rafthttp/msgappv2_codec.go b/rafthttp/msgappv2_codec.go index 5b0cf8e2e..e9292fab0 100644 --- a/rafthttp/msgappv2_codec.go +++ b/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 | diff --git a/rafthttp/pipeline_test.go b/rafthttp/pipeline_test.go index 9f15f0c49..8bf909592 100644 --- a/rafthttp/pipeline_test.go +++ b/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()