| 129 | } |
| 130 | |
| 131 | func (f *FilterForwarder) Shutdown(ctx context.Context) error { |
| 132 | var errs []error |
| 133 | |
| 134 | if err := f.filterProcessor.Shutdown(ctx); err != nil { |
| 135 | errs = append(errs, fmt.Errorf("failed to shutdown filter processor: %w", err)) |
| 136 | } |
| 137 | |
| 138 | if err := f.next.Shutdown(ctx); err != nil { |
| 139 | errs = append(errs, fmt.Errorf("failed to shutdown next forwarder: %w", err)) |
| 140 | } |
| 141 | |
| 142 | return multierr.Combine(errs...) |
| 143 | } |
| 144 | |
| 145 | // GetExtensions implements component.Host |
| 146 | func (f *FilterForwarder) GetExtensions() map[component.ID]component.Component { |