ingest

package
v0.0.0-...-e32c873 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 23, 2026 License: MPL-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotFound = errors.New("no matching file discovered")

Functions

This section is empty.

Types

type Comparator 

type Comparator func([]byte) bool

type FileProcessor 

type FileProcessor struct {
	MaxWorkers int
}

func NewParallel 

func NewParallel(maxWorkers int) *FileProcessor

func (*FileProcessor) Discover 

func (f *FileProcessor) Discover(ctx context.Context, path string, cmp Comparator) ([]byte, error)

type Finder 

type Finder interface {
	Discover(ctx context.Context, paths string, cmp Comparator) ([]byte, error)
}

type ManualSelectionProcessor 

type ManualSelectionProcessor struct{}

func NewSelection 

func NewSelection() *ManualSelectionProcessor

func (*ManualSelectionProcessor) Discover 

func (s *ManualSelectionProcessor) Discover(ctx context.Context, path string, cmp Comparator) ([]byte, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.