chore: fix some comments

clog/clog_test.go

@@ -79,7 +79,7 @@ func TestPublicLogs(t *testing.T) {
 	val = GetVal(publicCtx, "foo")
 	assert.Equal("", val)
 
-	// Verify [PublicLogs] gets pre-pended:
+	// Verify [PublicLogs] gets prepended:
 	msg, _ := formatMessage(ctx, false, true, "testing message num=%d", 123)
 	assert.Equal("[PublicLogs] manifestID=fooManID sessionID=fooSessionID nonce=999 seqNo=555 orchSessionID=fooOrchID ethaddress=0x0 orchestrator=http://127.0.0.1:8935 foo=Bar testing message num=123", msg)
 }

doc/discovery.md

@@ -17,7 +17,7 @@ After feching active orchestrators, the discovery algorithm filters for eligible
 - Choosing the first M orchestrators out of N that respond to a `GetOrchestrator` request within a [timeout](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/discovery/discovery.go#L127)
 	- If an insufficient number of orchestrators are found within the timeout, a timeout escalation is used [here](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/discovery/discovery.go#L146) to continue trying to find orchestrators
 	- At the moment, a broadcaster uses separate pools of trusted and untrusted orchestrators for fast verification and for the untrusted orchestrator pool discovery will set M = N (see [here](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/server/broadcast.go#L411) and [here](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/server/broadcast.go#L726))
-- Exclusing orchestrators that are temporarily suspended
+- Excluding orchestrators that are temporarily suspended
 - Excluding orchestrators that do not have compatible capabilities for the job
 - Excluding orchestrators that advertise invalid ticket parameters, that advertise a price that exceeds the broadcaster's max price
 

pm/broker.go

@@ -92,6 +92,6 @@ type SenderManager interface {
 	ClaimedReserve(reserveHolder ethcommon.Address, claimant ethcommon.Address) (*big.Int, error)
 	// Clear clears the cached values for a sender
 	Clear(addr ethcommon.Address)
-	// SubscribeReserveChange notifies a subcriber when the senderInfo for a sender changes
+	// SubscribeReserveChange notifies a subscriber when the senderInfo for a sender changes
 	SubscribeReserveChange(sink chan<- ethcommon.Address) event.Subscription
 }

pm/sendermonitor.go

@@ -440,7 +440,7 @@ func (sm *LocalSenderMonitor) redeemWinningTicket(ticket *SignedTicket) (*types.
 	return tx, nil
 }
 
-// SubscribeMaxFloatChange notifies subcribers when the max float for a sender has changed
+// SubscribeMaxFloatChange notifies subscribers when the max float for a sender has changed
 // and that it should call LocalSenderMonitor.MaxFloat() to get the latest value
 func (sm *LocalSenderMonitor) SubscribeMaxFloatChange(sender ethcommon.Address, sink chan<- struct{}) event.Subscription {
 	sm.mu.Lock()

server/job_rpc.go

@@ -880,7 +880,7 @@ func chargeForCompute(start time.Time, price *net.PriceInfo, orch Orchestrator,
 }
 
 func addPaymentBalanceHeader(w http.ResponseWriter, orch Orchestrator, sender ethcommon.Address, jobId string) {
-	//check balance and return remaning balance in header of response
+	//check balance and return remaining balance in header of response
 	senderBalance := getPaymentBalance(orch, sender, jobId)
 	if senderBalance != nil {
 		w.Header().Set("Livepeer-Payment-Balance", senderBalance.FloatString(0))
@@ -892,7 +892,7 @@ func addPaymentBalanceHeader(w http.ResponseWriter, orch Orchestrator, sender et
 }
 
 func getPaymentBalance(orch Orchestrator, sender ethcommon.Address, jobId string) *big.Rat {
-	//check balance and return remaning balance in header of response
+	//check balance and return remaining balance in header of response
 	senderBalance := orch.Balance(sender, core.ManifestID(jobId))
 	if senderBalance == nil {
 		senderBalance = big.NewRat(0, 1)