ingest

May 23, 2024

Changes in this version

+ var IngestTypeStrings = map[IngestType]string

+ var IngestTypeValues = map[string]IngestType

+ func NewWorkerPool(num int, ingestTimeout time.Duration, doIt func(job *JobStruct) error, ...) (chan *JobStruct, io.Closer)

+ type IngestType uint

+ const IngestType_COPY

+ const IngestType_KEEP

+ const IngestType_MOVE

+ type Ingester struct

+ func NewIngester(indexer *indexer.ActionDispatcher, ...) (*Ingester, error)

+ func (i *Ingester) Close() error

+ func (i *Ingester) Start() error

+ type JobStruct struct

+ type WriterNopcloser struct

+ func (WriterNopcloser) Close() error