indexing

type Embedder interface {
	Embed(ctx context.Context, texts []string) ([][]float32, error)
}

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

type IndexerConfig struct {
	// WorkerCount is the number of concurrent workers for directory indexing (default: 10)
	WorkerCount int
	// FileChannelBuffer is the buffer size for the file channel in directory indexing (default: 100)
	FileChannelBuffer int
	// ErrorChannelBuffer is the buffer size for the error channel in directory indexing (default: 10)
	ErrorChannelBuffer int
}

type Logger interface {
	Info(ctx context.Context, message string, fields map[string]interface{})
	Debug(ctx context.Context, message string, fields map[string]interface{})
	Error(ctx context.Context, message string, err error, fields map[string]interface{})
}

type Metrics interface {
	RecordErrorCount(ctx context.Context, errorType string)
	RecordIndexLatency(ctx context.Context, duration time.Duration)
	RecordIndexCount(ctx context.Context, status string)
}

type Source = core.Source

type Tracer interface {
	StartSpan(ctx context.Context, name string) (context.Context, observability.Span)
	Extract(ctx context.Context) (observability.Span, bool)
}