new: forward error when Subscriber discarded a message

PaloAltoNetworks · Dec 13, 2018 · c430ce8 · c430ce8
1 parent 0f8f6e2
commit c430ce8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/internal/push/push.go b/internal/push/push.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/tls"
 	"encoding/json"
+	"fmt"
 	"net/http"
 	"sync"
 	"time"
@@ -16,7 +17,7 @@ import (
 )
 
 const (
-	eventChSize  = 1024
+	eventChSize  = 2048
 	errorChSize  = 64
 	statusChSize = 8
 	filterChSize = 2
@@ -210,6 +211,7 @@ func (s *subscription) publishEvent(evt *elemental.Event) {
 	select {
 	case s.events <- evt:
 	default:
+		s.publishError(fmt.Errorf("unable to forward event: channel full"))
 	}
 }