Versions in this module Expand all Collapse all v0 v0.2.37 Aug 20, 2026 v0.2.36 Aug 18, 2026 Changes in this version + func BuildTagger(opts FilterConfigOpts) (tagger *filter.Tagger, cleanup func(), err error) + func CopyFile(dst, src string, perm os.FileMode) (err error) + func OutputFilename(inputPath string) string + func ParseExcludes(r io.Reader) ([]string, error) + func ProcessFile(cfg FastprocConfig, tagger *filter.Tagger, inputPath string, w io.Writer) error + func ProcessStream(cfg FastprocConfig, tagger *filter.Tagger, r io.Reader, w io.Writer) error + func ResolveFilterConfig(opts FilterConfigOpts) (string, error) + func RunFastSnapshot(cfg FastSnapshotConfig, snapshot SnapshotFunc) error + func RunMembers(cfg MembersConfig, get HTTPGetter, w io.Writer) error + func RunTable(cfg TableConfig, r io.Reader, w io.Writer) error + func Stage1Extract(cfg Stage1Config, excludes map[string]struct{}, r io.Reader, w io.Writer) error + func WriteFields(w io.Writer, sep string, values ...any) (int, error) + type Doer interface + Do func(*http.Request) (*http.Response, error) + type FastSnapshotConfig struct + BatchSize int + CacheClear bool + CacheDir string + CacheEnabled bool + Excludes []string + InputFiles []string + KeepTempFiles bool + NumWorkers int + OutputFile string + ShuffleInputFiles bool + SortBufferSize string + Verbose bool + func DefaultFastSnapshotConfig() FastSnapshotConfig + func (c FastSnapshotConfig) Options() crossref.SnapshotOptions + type FastprocConfig struct + BatchSize int + NumWorkers int + func DefaultFastprocConfig() FastprocConfig + type FilterConfigOpts struct + CacheTTL time.Duration + ExpandFlag string + Force bool + FrozenFile string + NoProxy bool + OkapiURL string + Tenant string + Token string + type HTTPGetter func(url string) (*http.Response, error) + type MembersConfig struct + Base string + Offset int + RetryCount int + Rows int + Sleep time.Duration + func DefaultMembersConfig() MembersConfig + type MembersResponse struct + Message struct{ ... } + MessageType string + MessageVersion string + Status string + type SnapshotFunc func(crossref.SnapshotOptions) error + type Stage1Config struct + BatchSize int + ErrCountThreshold int64 + func DefaultStage1Config() Stage1Config + type Sync struct + ApiEmail string + ApiEndpoint string + ApiFilter string + Client Doer + MaxRetries int + Mode string + Rows int + UserAgent string + Verbose bool + func (s *Sync) WriteWindow(w io.Writer, f, u time.Time) error + type TableConfig struct + BatchSize int + NumWorkers int + func DefaultTableConfig() TableConfig + type WorksResponse struct + Message struct{ ... } + MessageType string + MessageVersion string + Status string
Go to main page