Adjust spelling, Address linter warnings for digitalocean#5 (digitalocean#8)

* Adjust spelling, Address linter warnings

Author: ahelium

Makefile

@@ -19,7 +19,7 @@ clean:
 format:
 	@go fmt
 	@go get golang.org/x/tools/cmd/goimports
-	@goimports -w $$(find . -name '*.go' | grep -v vendor)
+	@goimports -w $$(find . -name '*.go' | grep -v 'mock_*')
 
 lint: .makecache .makecache/lint
 

go.mod

@@ -21,7 +21,7 @@ require (
 	github.com/tidwall/gjson v1.2.1 // indirect
 	github.com/tidwall/match v1.0.1 // indirect
 	github.com/tidwall/pretty v0.0.0-20180105212114-65a9db5fad51 // indirect
-	golang.org/x/sys v0.0.0-20191110163157-d32e6e3b99c4 // indirect
+	golang.org/x/sys v0.0.0-20191113165036-4c7a9d0fe056 // indirect
 	golang.org/x/time v0.0.0-20190308202827-9d24e82272b4
 	gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 // indirect
 	gopkg.in/yaml.v2 v2.2.5

go.sum

@@ -175,15 +175,16 @@ golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5h
 golang.org/x/sys v0.0.0-20190422165155-953cdadca894 h1:Cz4ceDQGXuKRnVBDTS23GTn/pU5OE2C0WrNTOYK1Uuc=
 golang.org/x/sys v0.0.0-20190422165155-953cdadca894/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20190801041406-cbf593c0f2f3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20191110163157-d32e6e3b99c4 h1:Hynbrlo6LbYI3H1IqXpkVDOcX/3HiPdhVEuyj5a59RM=
-golang.org/x/sys v0.0.0-20191110163157-d32e6e3b99c4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191113165036-4c7a9d0fe056 h1:dHtDnRWQtSx0Hjq9kvKFpBh9uPPKfQN70NZZmvssGwk=
+golang.org/x/sys v0.0.0-20191113165036-4c7a9d0fe056/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/text v0.3.0 h1:g61tztE5qeGQ89tm6NTjjM9VPIm088od1l6aSorWRWg=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/time v0.0.0-20190308202827-9d24e82272b4 h1:SvFZT6jyqRaOeXpc5h/JSfZenJ2O330aBsf7JfSUXmQ=
 golang.org/x/time v0.0.0-20190308202827-9d24e82272b4/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=
 golang.org/x/tools v0.0.0-20180828015842-6cd1fcedba52/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
+golang.org/x/tools v0.0.0-20190312170243-e65039ee4138 h1:H3uGjxCR/6Ds0Mjgyp7LMK81+LvmbvWWEnJhzk1Pi9E=
 golang.org/x/tools v0.0.0-20190312170243-e65039ee4138/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
 google.golang.org/api v0.3.1/go.mod h1:6wY9I6uQWHQ8EM57III9mq/AjF+i8G65rmVagqKMtkk=
 google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=

helpers.go

@@ -5,6 +5,7 @@ import (
 	"strconv"
 )
 
+// Nodeconfig holds a Nodes configuration
 type Nodeconfig map[string]string
 
 // IntConfig validates and fetches the int-typed optional config value specified by 'name', using the 'defaultValue' if

internal/testnodetypes.go

@@ -388,7 +388,7 @@ func (a *AsyncFilterNode) Receive(msg fbcontext.Message) error {
 	return errors.New("message not supported")
 }
 
-// IndexRequestBuildlerNode is a Node that converts strings to elasticsearch IndexRequests
+// IndexRequestBuilderNode is a Node that converts strings to elasticsearch IndexRequests
 type IndexRequestBuilderNode struct {
 	docNum int
 	fbcontext.ContextAware

leader/leader.go

@@ -117,7 +117,7 @@ func (l *Leader) updateLeadership(status leaderelection.Status) {
 }
 
 // connectZk establishes a Zookeeper client connection.  The underlying client library does not block on creating the initial
-// conection, so no error will be returned from zk.Connect if zookeeper is not available.
+// connection, so no error will be returned from zk.Connect if zookeeper is not available.
 func connectZk(zkHosts string) (*zk.Conn, <-chan zk.Event) {
 	zks := strings.Split(zkHosts, ",")
 

message/kafkamessagesender.go

@@ -53,9 +53,9 @@ func (s KafkaMessageSender) Ack(msg Message) error {
 
 func (s *KafkaMessageSender) produceMessage(msg Message, ack bool) error {
 	wireMsg := &wireMessage{
-		Message:     msg,
-		Updated:     time.Now(),
-		Acknowleged: ack,
+		Message:      msg,
+		Updated:      time.Now(),
+		Acknowledged: ack,
 	}
 
 	wireMsgBytes, err := json.Marshal(wireMsg)

message/kafkamessagewire.go

@@ -6,9 +6,9 @@ import (
 
 // wireMessage is the structure that we send on the Kafka topic
 type wireMessage struct {
-	Message     Message   `json:"message"`
-	Updated     time.Time `json:"updated"`
-	Acknowleged bool      `json:"ack"`
+	Message      Message   `json:"message"`
+	Updated      time.Time `json:"updated"`
+	Acknowledged bool      `json:"ack"`
 }
 
 // uniqueKey concatenates messagetype with the key so that we don't risk collisions across message producers

message/kakfamessagereceiver.go

@@ -199,7 +199,7 @@ func (r *KafkaMessageReceiver) processMessage(value []byte) {
 	if !r.initialized {
 		r.initBuffer[uniqueKey(wireMsg.Message)] = wireMsg
 	} else {
-		if !wireMsg.Acknowleged {
+		if !wireMsg.Acknowledged {
 			r.deliverMessage(wireMsg.Message)
 		}
 	}
@@ -217,7 +217,7 @@ func (r *KafkaMessageReceiver) deliverMessage(msg Message) {
 func (r *KafkaMessageReceiver) processInitBuffer() {
 	log.WithField("buffered_messages", len(r.initBuffer)).Info("kafkamessagereceiver: delivering buffered messages")
 	for _, wireMsg := range r.initBuffer {
-		if !wireMsg.Acknowleged {
+		if !wireMsg.Acknowledged {
 			msg := wireMsg.Message
 			log.WithField("message_key", msg.Key).WithField("message_type", msg.MessageType).Infof("kafkamessagereceiver: delivering initial message")
 			r.deliverMessage(msg)