capture

type Options struct {
	Source     Source
	Normalizer normalize.Normalizer
	Store      storage.Store
	Manifest   core.Manifest
	Capture    core.CaptureSettings
	RunID      string
	RunIDGenerator
}

type Pipeline struct {
	// contains filtered or unexported fields
}

type RunIDGenerator func() string

type Source interface {
	Frames() <-chan []byte
	Meta() core.SourceMeta
}