WriteTo merges all ordered parts into w.
(w io.Writer)
| 207 | |
| 208 | // WriteTo merges all ordered parts into w. |
| 209 | func (s *FileBodySource) WriteTo(w io.Writer) error { |
| 210 | if s == nil || w == nil { |
| 211 | return nil |
| 212 | } |
| 213 | paths := s.Paths() |
| 214 | wrote := false |
| 215 | for _, path := range paths { |
| 216 | file, errOpen := os.Open(path) |
| 217 | if errOpen != nil { |
| 218 | if os.IsNotExist(errOpen) { |
| 219 | continue |
| 220 | } |
| 221 | return errOpen |
| 222 | } |
| 223 | if wrote { |
| 224 | if _, errWrite := io.WriteString(w, "\n"); errWrite != nil { |
| 225 | if errClose := file.Close(); errClose != nil { |
| 226 | log.WithError(errClose).Warn("failed to close log part file") |
| 227 | } |
| 228 | return errWrite |
| 229 | } |
| 230 | } |
| 231 | _, errCopy := io.Copy(w, file) |
| 232 | if errClose := file.Close(); errClose != nil { |
| 233 | log.WithError(errClose).Warn("failed to close log part file") |
| 234 | if errCopy == nil { |
| 235 | errCopy = errClose |
| 236 | } |
| 237 | } |
| 238 | if errCopy != nil { |
| 239 | return errCopy |
| 240 | } |
| 241 | wrote = true |
| 242 | } |
| 243 | return nil |
| 244 | } |
| 245 | |
| 246 | // Bytes merges all ordered parts into memory. |
| 247 | func (s *FileBodySource) Bytes() ([]byte, error) { |
no test coverage detected