Remove buffers from channels. May be later return back

Author: lomik

carbon/app.go

@@ -160,7 +160,7 @@ func (app *App) Start() (err error) {
 
 	runtime.GOMAXPROCS(conf.Common.MaxCPU)
 
-	app.writeChan = make(chan *RowBinary.WriteBuffer, 128)
+	app.writeChan = make(chan *RowBinary.WriteBuffer)
 
 	/* WRITER start */
 	app.Writer = writer.New(

receiver/receiver.go

@@ -69,7 +69,7 @@ func New(dsn string, opts ...Option) (Receiver, error) {
 		}
 
 		r := &TCP{
-			parseChan: make(chan *Buffer, 128),
+			parseChan: make(chan *Buffer),
 			logger:    zap.New(zap.NullEncoder()),
 		}
 
@@ -91,7 +91,7 @@ func New(dsn string, opts ...Option) (Receiver, error) {
 		}
 
 		r := &UDP{
-			parseChan: make(chan *Buffer, 128),
+			parseChan: make(chan *Buffer),
 			logger:    zap.New(zap.NullEncoder()),
 		}