docker: add custom processor to pipe

rafael_chicoli · rafael_chicoli · commit 0106a4c98f6f · 2018-05-04T15:07:36.000+02:00
diff --git a/pkg/docker/driver.go b/pkg/docker/driver.go
@@ -94,6 +94,11 @@ func (d *Driver) StartLogging(file string, info logger.Info) error {
 		return err
 	}
 
+	// if err := c.CustomBulkProcessor(pctx, config.Bulk.workers, c.indexName, config.tzpe, config.Bulk.actions, config.Bulk.size, config.Bulk.flushInterval, config.timeout); err != nil {
+	// 	c.logger.WithError(err).Error("could not log to elasticsearch")
+	// 	return err
+	// }
+
 	return nil
 
 }

Original file line number	Diff line number	Diff line change
`@@ -94,6 +94,11 @@ func (d *Driver) StartLogging(file string, info logger.Info) error {`
`94`	`94`	`return err`
`95`	`95`	`}`
`96`	`96`
	`97`	`+ // if err := c.CustomBulkProcessor(pctx, config.Bulk.workers, c.indexName, config.tzpe, config.Bulk.actions, config.Bulk.size, config.Bulk.flushInterval, config.timeout); err != nil {`
	`98`	`+ // c.logger.WithError(err).Error("could not log to elasticsearch")`
	`99`	`+ // return err`
	`100`	`+ // }`
	`101`	`+`
`97`	`102`	`return nil`
`98`	`103`
`99`	`104`	`}`