Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Ingester ¶
type Ingester struct {
// contains filtered or unexported fields
}
func NewIngester ¶
func NewIngester(indexer *indexer.ActionDispatcher, dbClient mediaserverdbproto.DBControllerClient, vfs fs.FS, concurrentWorkers int, ingestTimeout time.Duration, ingestWait time.Duration, logger zLogger.ZLogger) (*Ingester, error)
Click to show internal directories.
Click to hide internal directories.