guacseam

type DocumentFunc func(ctx context.Context, p Parsed) error

type Expansion struct {
	Collected int
	Limit     int
	Exhausted bool
	Failed    []FailedDocument
}

type FailedDocument struct {
	Source string
	Err    error
}

type FilesReceiver struct {
	Path     string
	Poll     bool
	Interval time.Duration
}

type GCSReceiver struct {
	Bucket   string
	Poll     bool
	Interval time.Duration
}

type OCIReceiver struct {
	Refs     []string // image refs (image mode) or registry hosts (Registry mode)
	Registry bool     // true ⇒ collect whole registries (OciRegistryDataSources)
	Insecure bool     // plain-HTTP / skip-TLS, for local registries
	Poll     bool
	Interval time.Duration
}

type Origin int

type Outcome struct {
	Documents int
	Failed    []FailedDocument
}

type Parsed struct {
	Source     string // Doc.SourceInformation.Source
	Origin     Origin
	Doc        *processor.Document
	Preds      []assembler.IngestPredicates
	Purls      []string
	ScanFailed []ScanFailure
}

type S3Receiver struct {
	URL    string // custom endpoint (e.g. MinIO); "" ⇒ AWS SDK defaults
	Bucket string
	Path   string // folder prefix; list mode only
	Region string // "" ⇒ collector default
	Queues string // comma-separated; required when Poll (SQS message provider)
	Poll   bool
}

type ScanFailure struct {
	Source string
	Err    error
}

type ScanFlags struct {
	Vulns    bool
	Licenses bool
	EOL      bool
	DepsDev  bool
}

type Sources struct {
	Files  *FilesReceiver
	OCI    *OCIReceiver
	S3     *S3Receiver
	GCS    *GCSReceiver
	Scan   ScanFlags
	OnSkip func(FailedDocument)
	// ProcessingContext optionally shares a drain deadline with a caller's final flush.
	ProcessingContext context.Context
}