in pkg/output/shipper/shipper.go [96:103]
func (s *ShipperOutput) Close() error { if len(s.batch) > 0 { if err := s.send(); err != nil { return err } } return s.conn.Close() }