Fix typos

apidiff/interactive.go

@@ -77,7 +77,7 @@ func interactiveDisplay(diff *path_trie.PathTrie) error {
 	})
 
 	rootFrame := tview.NewFrame(rootPage)
-	// To go from individial diff pages back to the root page, users need to use
+	// To go from individual diff pages back to the root page, users need to use
 	// ESC. However, if we add the ESC help text as a separate frame on each diff
 	// page, we get nested frames with both instructions. Plus, the 'q' escape
 	// behavior is applied to all pages. Hence, we put both help text ('q' and

apidump/apidump.go

@@ -196,7 +196,7 @@ func (a *apidump) LookupService() error {
 	return nil
 }
 
-// Send the initial mesage to the backend indicating successful start
+// Send the initial message to the backend indicating successful start
 func (a *apidump) SendInitialTelemetry() {
 	// Do not send packet capture telemetry for local captures.
 	if !a.TargetIsRemote() {
@@ -758,7 +758,7 @@ func (a *apidump) Run() error {
 			}
 
 			// If this is false, we will still parse TLS client and server hello messages
-			// but not process them futher.
+			// but not process them further.
 			if args.CollectTCPAndTLSReports {
 				// Process TLS traffic into TLS-connection metadata.
 				collector = tls_conn_tracker.NewCollector(collector)

apidump/summary.go

@@ -51,7 +51,7 @@ func NewSummary(
 }
 
 // Dumps packet counters for packets captured and sent to the Akita backend.
-// If the debug flag is set, also prints packets taht were captured but not
+// If the debug flag is set, also prints packets that were captured but not
 // sent to the backend.
 func (s *Summary) PrintPacketCounts() {
 	s.PrintPacketCountHighlights()

ci/ci.go

@@ -29,12 +29,12 @@ func (c CI) String() string {
 	}
 }
 
-// Implments encoding.TextMarshaler
+// Implements encoding.TextMarshaler
 func (c CI) MarshalText() ([]byte, error) {
 	return []byte(c.String()), nil
 }
 
-// Implments encoding.TextUnmarshaler
+// Implements encoding.TextUnmarshaler
 func (c *CI) UnmarshalText(s []byte) error {
 	switch string(s) {
 	case "CircleCI":

cmd/internal/ecs/add.go

@@ -28,7 +28,7 @@ func reportStep(stepName string) {
 }
 
 // A function which executes the next part of the workflow,
-// and picks a next state (Some) or exits (None), or signals an eror.
+// and picks a next state (Some) or exits (None), or signals an error.
 type AddWorkflowState func(*AddWorkflow) (next optionals.Optional[AddWorkflowState], err error)
 
 // Helper functions for choosing the next state.
@@ -194,7 +194,7 @@ func initState(wf *AddWorkflow) (nextState optionals.Optional[AddWorkflowState],
 
 // Ask the user to specify a profile; "" is fine to use the default profile.
 // TODO: it seems very difficult to present a list (which is what I was trying
-// to do orginally) because the SDK doesn't provide an API to do that, and
+// to do originally) because the SDK doesn't provide an API to do that, and
 // its config file parser is internal.
 func getProfileState(wf *AddWorkflow) (nextState optionals.Optional[AddWorkflowState], err error) {
 	reportStep("Get AWS Profile")

cmd/internal/get/traces.go

@@ -90,7 +90,7 @@ func getTraces(cmd *cobra.Command, args []string) error {
 	case serviceFlag == "":
 		serviceFlag = serviceArg
 	case serviceArg == "":
-		// servceFlag is nonempty
+		// serviceFlag is nonempty
 		break
 	case serviceFlag != serviceArg:
 		return fmt.Errorf("Different projects specified in flag and URI.")

cmd/internal/kube/inject.go

@@ -17,7 +17,7 @@ import (
 )
 
 var (
-	// The target Yaml faile to be injected
+	// The target Yaml failed to be injected
 	// This is required for execution of injectCmd
 	injectFileNameFlag string
 	// The output file to write the injected Yaml to

cmd/internal/kube/injector/injector.go

@@ -23,7 +23,7 @@ type (
 		// Injects the given sidecar into all valid Deployment Objects and returns the result as a list of unstructured objects.
 		Inject(sidecar v1.Container) ([]*unstructured.Unstructured, error)
 		// Returns a list of namespaces that contain injectable objects.
-		// This can be used to generate other Kuberenetes objects that need to be created in the same namespace.
+		// This can be used to generate other Kubernetes objects that need to be created in the same namespace.
 		InjectableNamespaces() ([]string, error)
 	}
 	injectorImpl struct {

cmd/internal/learn/cmd.go

@@ -86,7 +86,7 @@ func runLearnMode() error {
 // trace is captured (e.g., whether the capture was user-initiated or is from
 // CI, and any applicable information from CI).
 func runAPIDump(clientID akid.ClientID, projectName string, tagsMap map[tags.Key]string, plugins []plugin.AkitaPlugin) (*akiuri.URI, error) {
-	// Determing packet filter.
+	// Determine packet filter.
 	var packetFilter string
 	{
 		// Translate --port and --bpf-filter flags

cmd/internal/upload/flags.go

@@ -59,7 +59,7 @@ func init() {
 		&tagsFlag,
 		"tags",
 		nil,
-		`Adds tags to the uploaded object. Specified as a comma-seprated list of "key=value" pairs.`,
+		`Adds tags to the uploaded object. Specified as a comma-separated list of "key=value" pairs.`,
 	)
 
 	Cmd.Flags().BoolVar(

cmd/root.go

@@ -295,6 +295,6 @@ func init() {
 	legacy.SpecsCmd.Hidden = true
 	rootCmd.AddCommand(legacy.SpecsCmd)
 
-	// Special hidden comands
+	// Special hidden commands
 	rootCmd.AddCommand(ascii.Cmd)
 }

integrations/nginx/rest.go

@@ -227,7 +227,7 @@ func (b *NginxBackend) handleRequest(rw http.ResponseWriter, req *http.Request)
 func (b *NginxBackend) handleResponse(rw http.ResponseWriter, req *http.Request) {
 	// Check for JSON encoding
 	if httpErr := daemon.EnsureJSONEncodedRequestBody(req); httpErr != nil {
-		telemetry.RateLimitError("NGINX handleResonse", errors.New("Bad content-type"))
+		telemetry.RateLimitError("NGINX handleResponse", errors.New("Bad content-type"))
 		writeTextResponse(rw, 400, "Expecting application/json body")
 		return
 	}

integrations/nginx/schema.go

@@ -6,7 +6,7 @@ import (
 	"github.com/akitasoftware/go-utils/optionals"
 )
 
-/* Rest API schema objects for the communcation between
+/* Rest API schema objects for the communication between
    the NGINX module and the Postman Live Collections Agent */
 
 // An incoming request to Nginx.

learn/parse_http.go

@@ -47,7 +47,7 @@ var (
 )
 
 const (
-	// The fallback to trying compression algorithms is more exprensive because there doesn't seem to be a
+	// The fallback to trying compression algorithms is more expensive because there doesn't seem to be a
 	// good way of interrogating the algorithms about whether the stream is OK. So we limit the amount of
 	// data is may consume or produce.
 	MaxFallbackInput  = 1 * 1024 * 1024
@@ -193,10 +193,10 @@ func ParseHTTP(elem akinet.ParsedNetworkContent) (*PartialWitness, error) {
 }
 
 // Today body has been completely assembled, but we accept a Reader to allow us to
-// stream throught he decompression later, if it becomes feasible.
+// stream through the decompression later, if it becomes feasible.
 //
 // TODO: some of the compression algorithms return a ReadCloser, but it
-// doesn't look like there's a good standard library way to propogate closes
+// doesn't look like there's a good standard library way to propagate closes
 // all the way back.  So they'd all have to be deferred here?
 func decompress(compression string, body io.Reader) (io.Reader, error) {
 	printer.Debugf("Decompressing body using %s\n", compression)
@@ -662,7 +662,7 @@ func parseHTTPBodyJSON(stream io.Reader) (*pb.Data, error) {
 		return nil, errors.Wrapf(err, "couldn't parse JSON")
 	}
 
-	// JSON already distingishes string values from non-string values, so don't
+	// JSON already distinguishes string values from non-string values, so don't
 	// interpret strings.
 	return parseElem(top, spec_util.NO_INTERPRET_STRINGS), nil
 }

pcap/net_parse.go

@@ -166,7 +166,7 @@ func (p *NetworkTrafficParser) ParseFromInterface(interfaceName, bpfFilter strin
 				// packets more recently than that gap.
 				//
 				// TODO: is this maybe the source of splices, too?  Converting dropped packets
-				// into a continous stream?
+				// into a continuous stream?
 				//
 				// Streams that are idle need to be closed eventually, too.  We use a larger
 				// threshold for that because it costs us less memory to keep just a

telemetry/telemetry.go

@@ -253,7 +253,7 @@ func APIError(method string, path string, e error) {
 	)
 }
 
-// Report a failure withoout a specific error object
+// Report a failure without a specific error object
 func Failure(message string) {
 	analyticsClient.Track(distinctID(),
 		message,