Class: Phronomy::Agent::Context::Knowledge::Embeddings::Base

Inherits:

Object

• Object
• Phronomy::Agent::Context::Knowledge::Embeddings::Base

Defined in:

lib/phronomy/agent/context/knowledge/embeddings/base.rb

Overview

Abstract interface for embedding adapters.

Concrete implementations must override #embed and return a vector as an +Array+.

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) ⇒ BlockingAdapterPool::PendingOperation

  Submits an #embed call to BlockingAdapterPool and returns a BlockingAdapterPool::PendingOperation.

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) —

  optional; raises CancellationError when cancelled

Returns:

• (Array<Float>) —

  the embedding vector

Raises:

• (NotImplementedError)

# File 'lib/phronomy/agent/context/knowledge/embeddings/base.rb', line 19

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) ⇒ BlockingAdapterPool::PendingOperation

Submits an #embed call to BlockingAdapterPool and returns a BlockingAdapterPool::PendingOperation.

Parameters:

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

  seconds before the operation is abandoned

Returns:

• (BlockingAdapterPool::PendingOperation)

# File 'lib/phronomy/agent/context/knowledge/embeddings/base.rb', line 32

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