all: fix a lot of typos

_examples/basic/1-your-first-app/README.md

@@ -35,7 +35,7 @@ server_1     | 2019/08/29 19:41:28 received event {ID:8}
 server_1     | 2019/08/29 19:41:29 received event {ID:9}
 ```
 
-Open another termial and take a look at Kafka topics to see that all messages are there. The initial events should be present on the `events` topic:
+Open another terminal and take a look at Kafka topics to see that all messages are there. The initial events should be present on the `events` topic:
 
 ```bash
 > docker-compose exec kafka kafka-console-consumer --bootstrap-server localhost:9092 --topic events

dev/coverage.sh

@@ -1,7 +1,7 @@
 #!/bin/sh
 ########
 # Source: https://gist.github.com/lwolf/3764a3b6cd08387e80aa6ca3b9534b8a
-# originaly from https://github.com/mlafeldt/chef-runner/blob/v0.7.0/script/coverage
+# originally from https://github.com/mlafeldt/chef-runner/blob/v0.7.0/script/coverage
 #######
 # Generate test coverage statistics for Go packages.
 #

docs/layouts/shortcodes/render-md.html

@@ -6,6 +6,6 @@
 {{% load-snippet-partial (...) %}}
 {{% /render-md %}}
 
-bacause it is rendered as raw text by default
+because it is rendered as raw text by default
 */}}
 {{.Inner}}

message/router.go

@@ -716,7 +716,7 @@ func (r *Router) decorateHandlerSubscriber(h *handler) error {
 	return nil
 }
 
-// addHandlerContext enriches the contex with values that are relevant within this handler's context.
+// addHandlerContext enriches the context with values that are relevant within this handler's context.
 func (h *handler) addHandlerContext(messages ...*Message) {
 	for i, msg := range messages {
 		ctx := msg.Context()

message/router/middleware/deduplicator.go

@@ -21,7 +21,7 @@ import (
 const MessageHasherReadLimitMinimum = 64
 
 // ExpiringKeyRepository is a state container for checking the
-// existance of a key in a certain time window.
+// existence of a key in a certain time window.
 // All operations must be safe for concurrent use.
 type ExpiringKeyRepository interface {
 	// IsDuplicate returns `true` if the key

message/subscriber/read.go

@@ -6,7 +6,7 @@ import (
 	"github.com/ThreeDotsLabs/watermill/message"
 )
 
-// BulkRead reads provided amount of messages from the provided channel, until a timeout occurrs or the limit is reached.
+// BulkRead reads provided amount of messages from the provided channel, until a timeout occurs or the limit is reached.
 func BulkRead(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool) {
 MessagesLoop:
 	for len(receivedMessages) < limit {
@@ -27,7 +27,7 @@ MessagesLoop:
 }
 
 // BulkReadWithDeduplication reads provided number of messages from the provided channel, ignoring duplicates,
-// until a timeout occurrs or the limit is reached.
+// until a timeout occurs or the limit is reached.
 func BulkReadWithDeduplication(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool) {
 	receivedIDs := map[string]struct{}{}
 

slog.go

@@ -42,7 +42,7 @@ func (s *SlogLoggerAdapter) Debug(msg string, fields LogFields) {
 func (s *SlogLoggerAdapter) Trace(msg string, fields LogFields) {
 	s.slog.Log(
 		// Void context, following the slog example
-		// as it treats context slighly differently from
+		// as it treats context slightly differently from
 		// normal usage, minding contextual
 		// values, but ignoring contextual deadline.
 		// See the [slog] package documentation