Add https-batch to allowed formats

src/pkg/egress/syslog/https.go

@@ -50,6 +50,7 @@ func (w *HTTPSWriter) sendHttpRequest(msg []byte, msgCount float64) error {
 	req.SetBody(msg)
 
 	resp := fasthttp.AcquireResponse()
+	defer fasthttp.ReleaseResponse(resp)
 
 	err := w.client.Do(req, resp)
 	if err != nil {
@@ -100,12 +101,10 @@ func (*HTTPSWriter) Close() error {
 	return nil
 }
 
-func httpClient(netConf NetworkTimeoutConfig, tlsConf *tls.Config) *fasthttp.Client {
+func httpClient(_ NetworkTimeoutConfig, tlsConf *tls.Config) *fasthttp.Client {
 	return &fasthttp.Client{
-		MaxConnsPerHost:     5,
-		MaxIdleConnDuration: 90 * time.Second,
+		MaxConnsPerHost:     100,
+		MaxIdleConnDuration: 10 * time.Second,
 		TLSConfig:           tlsConf,
-		ReadTimeout:         20 * time.Second,
-		WriteTimeout:        20 * time.Second,
 	}
 }

src/pkg/egress/syslog/https_batch.go

@@ -10,7 +10,7 @@ import (
 	"code.cloudfoundry.org/loggregator-agent-release/src/pkg/egress"
 )
 
-const BATCHSIZE = 256 * 1024
+const BATCHSIZE = 1024 * 1024
 
 type HTTPSBatchWriter struct {
 	HTTPSWriter
@@ -39,7 +39,7 @@ func NewHTTPSBatchWriter(
 			syslogConverter: c,
 		},
 		batchSize:    BATCHSIZE,
-		sendInterval: 1 * time.Second,
+		sendInterval: 3 * time.Second,
 		egrMsgCount:  0,
 		msgs:         make(chan []byte),
 	}

src/pkg/ingress/bindings/filtered_binding_fetcher.go

@@ -11,7 +11,7 @@ import (
 	"code.cloudfoundry.org/loggregator-agent-release/src/pkg/egress/syslog"
 )
 
-var allowedSchemes = []string{"syslog", "syslog-tls", "https"}
+var allowedSchemes = []string{"syslog", "syslog-tls", "https", "https-batch"}
 
 type IPChecker interface {
 	ResolveAddr(host string) (net.IP, error)