Fixed bunch of typos

Author: vgarvardt

docs/README.md

@@ -2,5 +2,5 @@
 
 GoEngine is an Event Sourcing library written for GoLang.
 
-The goal of this library is to reduce the amount of time you have to spend thinking about the infrastructure so you can focus on  
-implementing your Domains and Business logic!
+The goal of this library is to reduce the amount of time you have to spend thinking about the infrastructure, so you can
+focus on implementing your Domains and Business logic!

docs/quick-start.md

@@ -338,13 +338,14 @@ import (
 
 	driverSQL "github.com/hellofresh/goengine/v2/driver/sql"
 	"github.com/hellofresh/goengine/v2/extension/pq"
+	"github.com/hellofresh/goengine/v2/strategy/json/sql/postgres"
 )
 
 func main() {
 	// ...
 
-	var manager postgres.SingleStreamStrategy
-		
+	var manager *postgres.SingleStreamManager
+
 	projector, err := manager.NewStreamProjector(
 		"bank_account_projections", 
 		NewBankTotalsProjection(postgresDB),

driver/sql/eventstore.go

@@ -9,6 +9,6 @@ import (
 
 // ReadOnlyEventStore an interface describing a readonly event store that supports providing a SQL conn
 type ReadOnlyEventStore interface {
-	// LoadWithConnection returns a eventstream based on the provided constraints using the provided Queryer
+	// LoadWithConnection returns an eventstream based on the provided constraints using the provided Queryer
 	LoadWithConnection(ctx context.Context, conn Queryer, streamName goengine.StreamName, fromNumber int64, count *uint, metadataMatcher metadata.Matcher) (goengine.EventStream, error)
 }

driver/sql/listener.go

@@ -2,7 +2,7 @@ package sql
 
 import "context"
 
-// Listener listens to a event stream and triggers a notification when a event was appended
+// Listener listens to an event stream and triggers a notification when a event was appended
 type Listener interface {
 	// Listen starts listening to the event stream and call the trigger when a event was appended
 	Listen(ctx context.Context, trigger ProjectionTrigger) error

driver/sql/metrics_nop.go

@@ -5,8 +5,7 @@ var NopMetrics Metrics = &nopMetrics{}
 
 type nopMetrics struct{}
 
-func (nm *nopMetrics) ReceivedNotification(isNotification bool)                         {}
-func (nm *nopMetrics) QueueNotification(notification *ProjectionNotification)           {}
-func (nm *nopMetrics) StartNotificationProcessing(notification *ProjectionNotification) {}
-func (nm *nopMetrics) FinishNotificationProcessing(notification *ProjectionNotification, success bool) {
-}
+func (nm *nopMetrics) ReceivedNotification(bool)                                  {}
+func (nm *nopMetrics) QueueNotification(*ProjectionNotification)                  {}
+func (nm *nopMetrics) StartNotificationProcessing(*ProjectionNotification)        {}
+func (nm *nopMetrics) FinishNotificationProcessing(*ProjectionNotification, bool) {}

driver/sql/postgres/advisory_lock_aggregate_projection_storage.go

@@ -13,7 +13,7 @@ import (
 
 var _ driverSQL.AggregateProjectorStorage = &AdvisoryLockAggregateProjectionStorage{}
 
-// AdvisoryLockAggregateProjectionStorage is a AggregateProjectorStorage that uses a advisory locks to lock a projection
+// AdvisoryLockAggregateProjectionStorage is a AggregateProjectorStorage that uses an advisory locks to lock a projection
 type AdvisoryLockAggregateProjectionStorage struct {
 	stateSerialization driverSQL.ProjectionStateSerialization
 	useLockField       bool

driver/sql/postgres/advisory_lock_stream_projection_storage.go

@@ -13,7 +13,7 @@ import (
 
 var _ driverSQL.StreamProjectorStorage = &AdvisoryLockStreamProjectionStorage{}
 
-// AdvisoryLockStreamProjectionStorage is a StreamProjectorStorage that uses a advisory locks to lock a projection
+// AdvisoryLockStreamProjectionStorage is a StreamProjectorStorage that uses an advisory locks to lock a projection
 type AdvisoryLockStreamProjectionStorage struct {
 	projectionName               string
 	projectionStateSerialization driverSQL.ProjectionStateSerialization

driver/sql/postgres/eventstore.go

@@ -79,7 +79,7 @@ func NewEventStore(
 	}, nil
 }
 
-// Create creates the database table, index etc needed for the event stream
+// Create creates the database table, index etc. needed for the event stream
 func (e *EventStore) Create(ctx context.Context, streamName goengine.StreamName) error {
 	tableName, err := e.tableName(streamName)
 	if err != nil {

driver/sql/projection.go

@@ -47,18 +47,18 @@ type (
 		EncodeState(obj interface{}) ([]byte, error)
 	}
 
-	// ProjectionErrorCallback is a function used to determin what action to take based on a failed projection
+	// ProjectionErrorCallback is a function used to determine what action to take based on a failed projection
 	ProjectionErrorCallback func(err error, notification *ProjectionNotification) ProjectionErrorAction
 
 	// ProjectionErrorAction a type containing the action that the projector should take after an error
 	ProjectionErrorAction int
 
-	// EventStreamLoader loads a event stream based on the provided notification and state
+	// EventStreamLoader loads an event stream based on the provided notification and state
 	EventStreamLoader func(ctx context.Context, conn *sql.Conn, notification *ProjectionNotification, position int64) (goengine.EventStream, error)
 
 	// ProjectorStorage is an interface for handling the projection storage
 	ProjectorStorage interface {
-		// Acquire this function is used to acquire the projection and it's projectionState
+		// Acquire this function is used to acquire the projection and its projectionState.
 		// A projection can only be acquired once and must be released using the returned func
 		Acquire(ctx context.Context, conn *sql.Conn, notification *ProjectionNotification) (ProjectorTransaction, int64, error)
 	}

projection.go

@@ -33,7 +33,7 @@ type (
 	//  	}
 	//  }
 	Query interface {
-		// init initializes the state of the Query
+		// Init initializes the state of the Query
 		Init(ctx context.Context) (interface{}, error)
 
 		// Handlers return the handlers for a set of messages