Fixing misspells

client/v1/client.go

@@ -122,7 +122,7 @@ type Task struct {
 	ExecutionStats ExecutionStats
 }
 
-// Infomation about a recording
+// Information about a recording
 type Recording struct {
 	ID      string
 	Type    string

cmd/kapacitor/main.go

@@ -450,7 +450,7 @@ func (d *dbrps) Set(value string) error {
 	return nil
 }
 
-// read from txt starting with begining quote until next unescaped quote.
+// read from txt starting with beginning quote until next unescaped quote.
 func parseQuotedStr(txt string) (string, int) {
 	literal := txt[1 : len(txt)-1]
 	quote := txt[0]

edge.go

@@ -189,8 +189,8 @@ func (e *Edge) CollectBatch(b models.Batch) error {
 
 // Increment the emitted count of the group for this edge.
 func (e *Edge) incEmitted(group models.GroupID, tags models.Tags, dims []string) {
-	// we are "manually" calling Unlock() and not using defer, becasue this method is called
-	// in hot locations (NextPoint/CollectPoint) and defer have some performance penatly
+	// we are "manually" calling Unlock() and not using defer, because this method is called
+	// in hot locations (NextPoint/CollectPoint) and defer have some performance penalty
 	e.groupMu.Lock()
 
 	if stats, ok := e.groupStats[group]; ok {
@@ -209,8 +209,8 @@ func (e *Edge) incEmitted(group models.GroupID, tags models.Tags, dims []string)
 
 // Increment the collected count of the group for this edge.
 func (e *Edge) incCollected(group models.GroupID, tags models.Tags, dims []string) {
-	// we are "manually" calling Unlock() and not using defer, becasue this method is called
-	// in hot locations (NextPoint/CollectPoint) and defer have some performance penatly
+	// we are "manually" calling Unlock() and not using defer, because this method is called
+	// in hot locations (NextPoint/CollectPoint) and defer have some performance penalty
 	e.groupMu.Lock()
 
 	if stats, ok := e.groupStats[group]; ok {

etc/kapacitor/kapacitor.conf

@@ -125,7 +125,7 @@ data_dir = "/var/lib/kapacitor"
   idle-timeout = "30s"
 
   # If true the all alerts will be sent via Email
-  # without explicity marking them in the TICKscript.
+  # without explicitly marking them in the TICKscript.
   global = false
   # Only applies if global is true.
   # Sets all alerts in state-changes-only mode,
@@ -148,7 +148,7 @@ data_dir = "/var/lib/kapacitor"
     # trigger (Add Notes, Close Alert, etc.)
     recovery_url = "https://api.opsgenie.com/v1/json/alert/note"
     # If true then all alerts will be sent to OpsGenie
-    # without explicity marking them in the TICKscript.
+    # without explicitly marking them in the TICKscript.
     # The team and recipients can still be overridden.
     global = false
 
@@ -162,7 +162,7 @@ data_dir = "/var/lib/kapacitor"
   # The VictorOps API URL should not need to be changed.
   url = "https://alert.victorops.com/integrations/generic/20131114/alert"
   # If true the all alerts will be sent to VictorOps
-  # without explicity marking them in the TICKscript.
+  # without explicitly marking them in the TICKscript.
   # The routing key can still be overridden.
   global = false
 
@@ -174,7 +174,7 @@ data_dir = "/var/lib/kapacitor"
   # The PagerDuty API URL should not need to be changed.
   url = "https://events.pagerduty.com/generic/2010-04-15/create_event.json"
   # If true the all alerts will be sent to PagerDuty
-  # without explicity marking them in the TICKscript.
+  # without explicitly marking them in the TICKscript.
   global = false
 
 [slack]
@@ -188,7 +188,7 @@ data_dir = "/var/lib/kapacitor"
   # Default channel for messages
   channel = ""
   # If true the all alerts will be sent to Slack
-  # without explicity marking them in the TICKscript.
+  # without explicitly marking them in the TICKscript.
   global = false
   # Only applies if global is true.
   # Sets all alerts in state-changes-only mode,

examples/scores/scores.sh

@@ -1,6 +1,6 @@
 #!/bin/bash
 
-# default options: can be overriden with corresponding arguments.
+# default options: can be overridden with corresponding arguments.
 host=${1-localhost}
 port=${2-9100}
 games=${3-10}

integrations/helpers_test.go

@@ -109,7 +109,7 @@ func compareResultsIgnoreSeriesOrder(exp, got kapacitor.Result) (bool, string) {
 }
 
 func compareAlertData(exp, got kapacitor.AlertData) (bool, string) {
-	// Pull out Result for comparision
+	// Pull out Result for comparison
 	expData := kapacitor.Result(exp.Data)
 	exp.Data = influxql.Result{}
 	gotData := kapacitor.Result(got.Data)

join.go

@@ -122,7 +122,7 @@ func (j *JoinNode) runJoin([]byte) error {
 			return err
 		}
 	}
-	// No more points are comming signal all groups to finish up.
+	// No more points are coming signal all groups to finish up.
 	for _, group := range j.groups {
 		close(group.points)
 	}

node.go

@@ -110,7 +110,7 @@ func (n *node) start(snapshot []byte) {
 		defer func() {
 			// Always close children edges
 			n.closeChildEdges()
-			// Propogate error up
+			// Propagate error up
 			if err != nil {
 				// Handle panic in runF
 				r := recover()

pipeline/join.go

@@ -99,7 +99,7 @@ func (j *JoinNode) As(names ...string) *JoinNode {
 	return j
 }
 
-// Join on specfic dimensions.
+// Join on specific dimensions.
 // For example given two measurements:
 //
 // 1. building_power -- tagged by building, value is the total power consumed by the building.

pipeline/stream.go

@@ -98,7 +98,7 @@ type StreamNode struct {
 	Measurement string
 
 	// Optional duration for truncating timestamps.
-	// Helpful to ensure data points land on specfic boundaries
+	// Helpful to ensure data points land on specific boundaries
 	// Example:
 	//    stream
 	//       |from()

services/httpd/logger.go

@@ -108,7 +108,7 @@ func buildLogLine(l *responseLogger, r *http.Request, start time.Time) string {
 	return strings.Join(fields, " ")
 }
 
-// detect detects the first presense of a non blank string and returns it
+// detect detects the first presence of a non blank string and returns it
 func detect(values ...string) string {
 	for _, v := range values {
 		if v != "" {

services/opsgenie/config.go

@@ -8,9 +8,9 @@ type Config struct {
 	Enabled bool `toml:"enabled"`
 	// The OpsGenie API key.
 	APIKey string `toml:"api-key"`
-	// The default Teams, can be overriden per alert.
+	// The default Teams, can be overridden per alert.
 	Teams []string `toml:"teams"`
-	// The default Teams, can be overriden per alert.
+	// The default Teams, can be overridden per alert.
 	Recipients []string `toml:"recipients"`
 	// The OpsGenie API URL, should not need to be changed.
 	URL string `toml:"url"`

services/replay/service.go

@@ -230,7 +230,7 @@ func (r *Service) handleReplay(w http.ResponseWriter, req *http.Request) {
 		return
 	}
 
-	// Call close explicity to check for error
+	// Call close explicitly to check for error
 	err = tm.Close()
 	if err != nil {
 		httpd.HttpError(w, "closing: "+err.Error(), true, http.StatusInternalServerError)

services/slack/config.go

@@ -5,7 +5,7 @@ type Config struct {
 	Enabled bool `toml:"enabled"`
 	// The Slack webhook URL, can be obtained by adding Incoming Webhook integration.
 	URL string `toml:"url"`
-	// The default channel, can be overriden per alert.
+	// The default channel, can be overridden per alert.
 	Channel string `toml:"channel"`
 	// Whether all alerts should automatically post to slack
 	Global bool `toml:"global"`

services/talk/config.go

@@ -9,7 +9,7 @@ type Config struct {
 	Enabled bool `toml:"enabled"`
 	// The Talk webhook URL, can be obtained by adding Incoming Webhook integration.
 	URL string `toml:"url"`
-	// The default authorName, can be overriden per alert.
+	// The default authorName, can be overridden per alert.
 	AuthorName string `toml:"author_name"`
 }
 

services/victorops/config.go

@@ -7,7 +7,7 @@ type Config struct {
 	Enabled bool `toml:"enabled"`
 	// The Victor Ops API key.
 	APIKey string `toml:"api-key"`
-	// The default Routing Key, can be overriden per alert.
+	// The default Routing Key, can be overridden per alert.
 	RoutingKey string `toml:"routing-key"`
 	// The Victor Ops API URL, should not need to be changed.
 	URL string `toml:"url"`

task_master.go

@@ -510,7 +510,7 @@ func (tm *TaskMaster) newFork(taskName string, dbrps []DBRP, measurements []stri
 	for _, key := range forkKeys(dbrps, measurements) {
 		tm.taskToForkKeys[taskName] = append(tm.taskToForkKeys[taskName], key)
 
-		// Add the task to the tasksMap if it dosen't exists
+		// Add the task to the tasksMap if it doesn't exists
 		tasksMap, ok := tm.forks[key]
 		if !ok {
 			tasksMap = make(map[string]*Edge, 0)

tick/cmd/tickdoc/main.go

@@ -1,4 +1,4 @@
-// Tickdoc is a simple utility similiar to godoc that generates documentation from comments.
+// Tickdoc is a simple utility similar to godoc that generates documentation from comments.
 //
 // The 'tickdoc' utility understands several special comments to help it generate clean documentation.
 //

tick/lex.go

@@ -177,7 +177,7 @@ func isMathOperator(typ TokenType) bool {
 	return typ > begin_tok_operator_math && typ < end_tok_operator_math
 }
 
-// True if token type is an operator used in comparisions.
+// True if token type is an operator used in comparisons.
 func isCompOperator(typ TokenType) bool {
 	return typ > begin_tok_operator_comp && typ < end_tok_operator_comp
 }

tick/node.go

@@ -692,7 +692,7 @@ func (n *FunctionNode) SetComment(c *CommentNode) {
 	n.Comment = c
 }
 
-// Represents the begining of a lambda expression
+// Represents the beginning of a lambda expression
 type LambdaNode struct {
 	position
 	Node    Node

udf/udf.proto

@@ -127,7 +127,7 @@ message KeepaliveResponse {
     int64 time = 1;
 }
 
-// Sent from the process to Kapacitor indicating an error has occured.
+// Sent from the process to Kapacitor indicating an error has occurred.
 // If an ErrorResponse is received, Kapacitor will terminate the process.
 message ErrorResponse {
     string error = 1;