Class: Phronomy::VectorStore::Embeddings::Base

Inherits:

Object

• Object
• Phronomy::VectorStore::Embeddings::Base

Defined in:

lib/phronomy/vector_store/embeddings/base.rb

Overview

Public extension SPI for embedding adapters.

Concrete implementations override #embed. Phronomy owns the async bridge: #embed_async routes the synchronous implementation through the bounded OffloadPool and returns a Task.

Direct Known Subclasses

RubyLLMEmbeddings

Instance Method Summary

• #embed(text, cancellation_token = nil) ⇒ Array<Float>

  Embed the given text and return a vector representation.

• #embed_async(text, cancellation_token = nil, timeout: nil) ⇒ Phronomy::Task

  Submits an #embed call to OffloadPool.

Instance Method Details

#embed(text, cancellation_token = nil) ⇒ Array<Float>

Embed the given text and return a vector representation.

Parameters:

• text (String) —

  the text to embed

• cancellation_token (Phronomy::Concurrency::CancellationToken, nil) (defaults to: nil)

Returns:

• (Array<Float>) —

  the embedding vector

Raises:

• (NotImplementedError)

# File 'lib/phronomy/vector_store/embeddings/base.rb', line 20

def embed(text, cancellation_token = nil)
  cancellation_token&.raise_if_cancelled!
  raise NotImplementedError, "#{self.class}#embed is not implemented"
end

#embed_async(text, cancellation_token = nil, timeout: nil) ⇒ Phronomy::Task

Submits an #embed call to OffloadPool.

Parameters:

• text (String)
• cancellation_token (Phronomy::Concurrency::CancellationToken, nil) (defaults to: nil)
• timeout (Numeric, nil) (defaults to: nil) —

  operation-wide submit timeout

Returns:

• (Phronomy::Task)

# File 'lib/phronomy/vector_store/embeddings/base.rb', line 32

def embed_async(text, cancellation_token = nil, timeout: nil)
  Phronomy::Runtime.instance.offload.submit(
    timeout: timeout,
    cancellation_token: cancellation_token,
    on_full: :raise
  ) do
    embed(text, cancellation_token)
  end
end