Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ClosedScannerErrCh = func() <-chan error { ch := make(chan error) close(ch) return ch }()
closedScannerErrCh is closed with no values; ranging over it exits immediately when the scanner stage is skipped.
Functions ¶
This section is empty.
Types ¶
type Scanner ¶
type Scanner struct {
// contains filtered or unexported fields
}
Scanner is the pipeline stage that runs registered scanners per record. It implements pipeline.Scanner by delegating to individual Scanner implementations.
func New ¶
func New(cfg scannerconfig.Config) (*Scanner, error)
New creates an Scanner that runs the configured scanners for each record.
func (*Scanner) Scan ¶
func (s *Scanner) Scan(ctx context.Context, inputCh <-chan *corev1.Record, result *types.Result) (<-chan *corev1.Record, <-chan error)
Scan implements pipeline.Scanner. For each record it runs all configured scanners, merges their results, and applies fail-on-error/warning drop logic.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.