Fix small spelling mistakes (#3434)

Makefile

@@ -57,7 +57,7 @@ clean-vendor:
 .PHONY: check
 check:
 	$(foreach var,$(PROJECTS),$(MAKE) -C $(var) check || exit 1;)
-	# Validate that all updates were commited
+	# Validate that all updates were committed
 	$(MAKE) update
 	git update-index --refresh
 	git diff-index --exit-code HEAD --

Vagrantfile

@@ -9,7 +9,7 @@
 # This box is used as a Windows development and testing environment for Beats.
 #
 # Usage and Features:
-#   - Two users exist: Administartor and Vagrant. Both have the password: vagrant
+#   - Two users exist: Administrator and Vagrant. Both have the password: vagrant
 #   - Use 'vagrant ssh' to open a Windows command prompt.
 #   - Use 'vagrant rdp' to open a Windows Remote Deskop session. Mac users must
 #     install the Microsoft Remote Desktop Client from the App Store.

dev-tools/README.md

@@ -44,7 +44,7 @@ pip install -r requirements.txt
 
 This creates the environment that contains all the python packages required to
 run the `export_dashboards.py` script. Thus, for the next runs you just need
-to enable the enviroment:
+to enable the environment:
 
 ```
 . env/bin/activate

filebeat/harvester/log_test.go

@@ -132,7 +132,7 @@ func TestInitRegexp(t *testing.T) {
 
 // readLine reads a full line into buffer and returns it.
 // In case of partial lines, readLine does return an error and an empty string
-// This could potentialy be improved / replaced by https://github.com/elastic/beats/libbeat/tree/master/common/streambuf
+// This could potentially be improved / replaced by https://github.com/elastic/beats/libbeat/tree/master/common/streambuf
 func readLine(reader reader.Reader) (time.Time, string, int, common.MapStr, error) {
 	message, err := reader.Next()
 

filebeat/tests/open-file-handlers/docker-compose.yml

@@ -19,7 +19,7 @@ logs:
     - filebeat
 
 
-#addtional:
+#additional:
 #  image: debian
 #  links:
 #    - filebeat

filebeat/tests/system/test_registrar.py

@@ -1009,7 +1009,7 @@ def test_restart_state_reset(self):
         assert len(data) == 1
         assert data[0]["ttl"] > 0
 
-        # No config file which does not match the exisitng state
+        # No config file which does not match the existing state
         self.render_config_template(
             path=os.path.abspath(self.working_dir) + "/log/test2.log",
             clean_inactive="10s",
@@ -1127,7 +1127,7 @@ def test_restart_state_reset_ttl_with_space(self):
         assert len(data) == 1
         assert data[0]["ttl"] == 20 * 1000 * 1000 * 1000
 
-        # new config file whith other clean_inactive
+        # new config file with other clean_inactive
         self.render_config_template(
             path=os.path.abspath(self.working_dir) + "/log/test file.log",
             clean_inactive="40s",

heartbeat/monitors/active/icmp/loop.go

@@ -324,7 +324,7 @@ func createListener(name, network string) *icmp.PacketConn {
 	conn, err := icmp.ListenPacket(network, "")
 
 	// XXX: need to check for conn == nil, as 'err != nil' seems always to be
-	//      true, even if error value itself is `nil`. Checking for conn supresses
+	//      true, even if error value itself is `nil`. Checking for conn suppresses
 	//      missleading log message.
 	if conn == nil && err != nil {
 		logp.Info("%v ICMP not supported: %v", name, err)

libbeat/logp/file_rotator_test.go

@@ -24,7 +24,7 @@ func Test_Rotator(t *testing.T) {
 		return
 	}
 
-	Debug("rotator", "Direcotry: %s", dir)
+	Debug("rotator", "Directory: %s", dir)
 
 	rotateeverybytes := uint64(1000)
 	keepfiles := 3
@@ -118,7 +118,7 @@ func Test_Rotator_By_Bytes(t *testing.T) {
 		return
 	}
 
-	Debug("rotator", "Direcotry: %s", dir)
+	Debug("rotator", "Directory: %s", dir)
 
 	rotateeverybytes := uint64(100)
 	keepfiles := 3

libbeat/scripts/generate_template.py

@@ -309,7 +309,7 @@ def fill_field_properties(args, field, defaults, path):
 
         dynamic_templates.extend(dynamic)
     else:
-        raise ValueError("Unkown type found: " + field.get("type"))
+        raise ValueError("Unknown type found: " + field.get("type"))
 
     return properties, dynamic_templates
 

metricbeat/module/couchbase/bucket/bucket_test.go

@@ -21,7 +21,7 @@ func TestFetchEventContents(t *testing.T) {
 	response, err := ioutil.ReadFile(absPath + "/sample_response.json")
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(200)
-		w.Header().Set("Content-Type", "appication/json;")
+		w.Header().Set("Content-Type", "application/json;")
 		w.Write([]byte(response))
 	}))
 	defer server.Close()

metricbeat/module/couchbase/cluster/cluster_test.go

@@ -21,7 +21,7 @@ func TestFetchEventContents(t *testing.T) {
 	response, err := ioutil.ReadFile(absPath + "/sample_response.json")
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(200)
-		w.Header().Set("Content-Type", "appication/json;")
+		w.Header().Set("Content-Type", "application/json;")
 		w.Write([]byte(response))
 	}))
 	defer server.Close()

metricbeat/module/couchbase/node/node_test.go

@@ -21,7 +21,7 @@ func TestFetchEventContents(t *testing.T) {
 	response, err := ioutil.ReadFile(absPath + "/sample_response.json")
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		w.WriteHeader(200)
-		w.Header().Set("Content-Type", "appication/json;")
+		w.Header().Set("Content-Type", "application/json;")
 		w.Write([]byte(response))
 	}))
 	defer server.Close()

packetbeat/SUPPORT_PROTOCOL.md

@@ -1,6 +1,6 @@
 # Support a new protocol
 
-This is a simple guide, written while implementing support for mongodb protocol in order to make life easier for following developpers.
+This is a simple guide, written while implementing support for mongodb protocol in order to make life easier for following developers.
 
 # Have a look at the code
 

packetbeat/_meta/beat.full.yml

@@ -82,7 +82,7 @@ packetbeat.protocols.amqp:
   # Default: false
   #parse_arguments: false
 
-  # Hide all methods relative to connection negociation between server and
+  # Hide all methods relative to connection negotiation between server and
   # client.
   # Default: true
   #hide_connection_information: true

packetbeat/_meta/fields.yml

@@ -1387,13 +1387,13 @@
           type: long
           format: bytes
           description: >
-            The byte count of the values being transfered.
+            The byte count of the values being transferred.
 
         - name: response.bytes
           type: long
           format: bytes
           description: >
-            The byte count of the values being transfered.
+            The byte count of the values being transferred.
 
         - name: request.delta
           type: long

packetbeat/docs/fields.asciidoc

@@ -2064,7 +2064,7 @@ type: long
 
 format: bytes
 
-The byte count of the values being transfered.
+The byte count of the values being transferred.
 
 
 [float]
@@ -2074,7 +2074,7 @@ type: long
 
 format: bytes
 
-The byte count of the values being transfered.
+The byte count of the values being transferred.
 
 
 [float]

packetbeat/flows/util.go

@@ -66,7 +66,7 @@ func (w *worker) tick(t *time.Ticker) bool {
 	}
 }
 
-func (w *worker) periodicaly(tick time.Duration, fn func() error) {
+func (w *worker) periodically(tick time.Duration, fn func() error) {
 	defer debugf("stop periodic loop")
 
 	ticker := time.NewTicker(tick)

packetbeat/flows/worker.go

@@ -96,7 +96,7 @@ func makeWorker(
 		nPeriod := ticksPeriod
 		reportPeriodically := ticksPeriod > 0
 		debugf("start flows worker loop")
-		w.periodicaly(tickDuration, func() error {
+		w.periodically(tickDuration, func() error {
 			nTimeout--
 			nPeriod--
 			debugf("worker tick, nTimeout=%v, nPeriod=%v", nTimeout, nPeriod)

packetbeat/packetbeat.full.yml

@@ -82,7 +82,7 @@ packetbeat.protocols.amqp:
   # Default: false
   #parse_arguments: false
 
-  # Hide all methods relative to connection negociation between server and
+  # Hide all methods relative to connection negotiation between server and
   # client.
   # Default: true
   #hide_connection_information: true

packetbeat/protos/cassandra/internal/gocql/frame.go

@@ -201,8 +201,8 @@ func (f *Framer) ReadFrame() (data map[string]interface{}, err error) {
 	if f.Header.Flags&flagCompress == flagCompress {
 		//decompress data and switch to use bytearray decoder
 		if f.compres == nil {
-			logp.Err("hit compress flag, but comprossor was not set")
-			panic(errors.New("hit compress flag, but comprossor was not set"))
+			logp.Err("hit compress flag, but compressor was not set")
+			panic(errors.New("hit compress flag, but compressor was not set"))
 		}
 
 		decoder := &ByteArrayDecoder{}

packetbeat/protos/memcache/_meta/fields.yml

@@ -137,13 +137,13 @@
           type: long
           format: bytes
           description: >
-            The byte count of the values being transfered.
+            The byte count of the values being transferred.
 
         - name: response.bytes
           type: long
           format: bytes
           description: >
-            The byte count of the values being transfered.
+            The byte count of the values being transferred.
 
         - name: request.delta
           type: long

packetbeat/sniffer/sniffer.go

@@ -76,7 +76,7 @@ func deviceNameFromIndex(index int, devices []string) (string, error) {
 // ListDevicesNames returns the list of adapters available for sniffing on
 // this computer. If the withDescription parameter is set to true, a human
 // readable version of the adapter name is added. If the withIP parameter
-// is set to true, IP address of the adatper is added.
+// is set to true, IP address of the adapter is added.
 func ListDeviceNames(withDescription bool, withIP bool) ([]string, error) {
 	devices, err := pcap.FindAllDevs()
 	if err != nil {

packetbeat/tests/system/files/ThriftTest.thrift

@@ -169,7 +169,7 @@ service ThriftTest
   double       testDouble(1: double thing),
 
   /**
-   * Prints 'testStruct("{%s}")' where thing has been formatted into a string of comma seperated values
+   * Prints 'testStruct("{%s}")' where thing has been formatted into a string of comma separated values
    * @param Xtruct thing - the Xtruct to print
    * @return Xtruct - returns the Xtruct 'thing'
    */
@@ -184,31 +184,31 @@ service ThriftTest
 
   /**
    * Prints 'testMap("{%s")' where thing has been formatted into a string of  'key => value' pairs
-   *  seperated by commas and new lines
+   *  separated by commas and new lines
    * @param map<i32,i32> thing - the map<i32,i32> to print
    * @return map<i32,i32> - returns the map<i32,i32> 'thing'
    */
   map<i32,i32> testMap(1: map<i32,i32> thing),
 
   /**
    * Prints 'testStringMap("{%s}")' where thing has been formatted into a string of  'key => value' pairs
-   *  seperated by commas and new lines
+   *  separated by commas and new lines
    * @param map<string,string> thing - the map<string,string> to print
    * @return map<string,string> - returns the map<string,string> 'thing'
    */
   map<string,string> testStringMap(1: map<string,string> thing),
 
   /**
    * Prints 'testSet("{%s}")' where thing has been formatted into a string of  values
-   *  seperated by commas and new lines
+   *  separated by commas and new lines
    * @param set<i32> thing - the set<i32> to print
    * @return set<i32> - returns the set<i32> 'thing'
    */
   set<i32>     testSet(1: set<i32> thing),
 
   /**
    * Prints 'testList("{%s}")' where thing has been formatted into a string of  values
-   *  seperated by commas and new lines
+   *  separated by commas and new lines
    * @param list<i32> thing - the list<i32> to print
    * @return list<i32> - returns the list<i32> 'thing'
    */