@@ -138,7 +138,7 @@ func NewApp(cfg *config.Config, options ...Option) (*App, error) {
138138 var engine * rules.Engine
139139 var rs * config.RulesCompileResult
140140
141- if cfg .Filters .Rules .Enabled && ! cfg .ForwardMode && ! cfg .IsCaptureSet () {
141+ if cfg .Filters .Rules .Enabled && ! cfg .ForwardMode && ! cfg .IsCaptureSet () && ! cfg . IsFilamentSet () {
142142 engine = rules .NewEngine (psnap , cfg )
143143 var err error
144144 rs , err = engine .Compile ()
@@ -203,9 +203,8 @@ func (f *App) Run(args []string) error {
203203 // In case of a regular run, we additionally set up the aggregator.
204204 // The aggregator will grab the events from the queue, assemble them
205205 // into batches and hand over to output sinks.
206- filamentName := cfg .Filament .Name
207- if filamentName != "" {
208- f .filament , err = filament .New (filamentName , f .psnap , f .hsnap , cfg )
206+ if cfg .IsFilamentSet () {
207+ f .filament , err = filament .New (cfg .Filament .Name , f .psnap , f .hsnap , cfg )
209208 if err != nil {
210209 return err
211210 }
@@ -314,9 +313,9 @@ func (f *App) ReadCapture(ctx context.Context, args []string) error {
314313 if err != nil {
315314 return err
316315 }
317- filamentName := f . config . Filament . Name
318- if filamentName != "" {
319- f .filament , err = filament .New (filamentName , f .psnap , f .hsnap , f .config )
316+
317+ if f . config . IsFilamentSet () {
318+ f .filament , err = filament .New (f . config . Filament . Name , f .psnap , f .hsnap , f .config )
320319 if err != nil {
321320 return err
322321 }
@@ -355,6 +354,7 @@ func (f *App) ReadCapture(ctx context.Context, args []string) error {
355354 return err
356355 }
357356 }
357+
358358 return api .StartServer (f .config )
359359}
360360
0 commit comments