| 71 | } |
| 72 | |
| 73 | func (s *Spec) SetDefaults() { |
| 74 | if s.BatchSize == nil { |
| 75 | if s.NoRotate { |
| 76 | s.BatchSize = int64ptr(0) |
| 77 | } else { |
| 78 | s.BatchSize = int64ptr(10000) |
| 79 | } |
| 80 | } |
| 81 | if s.BatchSizeBytes == nil { |
| 82 | if s.NoRotate { |
| 83 | s.BatchSizeBytes = int64ptr(0) |
| 84 | } else { |
| 85 | s.BatchSizeBytes = int64ptr(50 * 1024 * 1024) // 50 MiB |
| 86 | } |
| 87 | } |
| 88 | if s.BatchTimeout == nil { |
| 89 | if s.NoRotate { |
| 90 | d := configtype.NewDuration(0) |
| 91 | s.BatchTimeout = &d |
| 92 | } else { |
| 93 | d := configtype.NewDuration(30 * time.Second) |
| 94 | s.BatchTimeout = &d |
| 95 | } |
| 96 | } |
| 97 | } |
| 98 | |
| 99 | func (s *Spec) Validate() error { |
| 100 | if len(s.Bucket) == 0 { |