index

type Destination ¶

type Destination interface {
	vectorstore.Upserter
	CheckDocuments(context.Context, vectorstore.SpaceID, []*document.Document) error
}

Destination checks provider-specific input constraints before model I/O. Upsert must still validate the current collection and the returned coordinates.

type Writer ¶

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

func NewWriter(config WriterConfig) (*Writer, error)

func (w *Writer) Write(ctx context.Context, documents []*document.Document) error

type WriterConfig ¶

type WriterConfig struct {
	Destination Destination
	Encoder     *vector.Encoder
	Formatter   document.Formatter
	Batching    tokenizer.BatchConfig
}