Method Run

core/engine/engine.go:90–103

Run consumes the backend's packet stream until ctx is done.

(ctx context.Context)

// Run consumes the backend's packet stream until ctx is done.
func (e *Engine) Run(ctx context.Context) error {
	ch := e.backend.Packets()
	for {
		select {
		case <-ctx.Done():
			return nil
		case packet, ok := <-ch:
			if !ok {
				return nil
			}
			e.dispatch(packet)
		}
	}
}

// dispatch classifies the packet, updates flow state, and decides on a
// verdict. It MUST call packet.Verdict exactly once.