store

Documentation

Index

• Variables
• type BaseDocumentStore
• type BaseMemoryStore
  • func (s *BaseMemoryStore[T]) Attach(observer models.Extractor)
  • func (s *BaseMemoryStore[T]) NotifyExtractors(ctx context.Context, appState *models.AppState, eventData *models.MessageEvent)
• type EmbeddingMismatchError
  • func NewEmbeddingMismatchError(originalError error) *EmbeddingMismatchError
  • func (e *EmbeddingMismatchError) Error() string
  • func (e *EmbeddingMismatchError) Unwrap() error
• type StorageError
  • func NewStorageError(message string, originalError error) *StorageError
  • func (e *StorageError) Error() string

Variables

var ErrEmbeddingMismatch = errors.New("embedding width mismatch")

Types

type BaseDocumentStore

type BaseDocumentStore[T any] struct {
	Client T
}

BaseDocumentStore is the base implementation of a DocumentStore. Client is the underlying datastore client, such as a database connection.

type BaseMemoryStore

type BaseMemoryStore[T any] struct {
	Client T
	// contains filtered or unexported fields
}

BaseMemoryStore is the base implementation of a MemoryStore. Client is the underlying datastore client, such as a database connection. The extractorObservers slice is used to store all registered Extractors.

func (*BaseMemoryStore[T]) Attach

func (s *BaseMemoryStore[T]) Attach(observer models.Extractor)

Attach registers an Extractor to the MemoryStore

func (*BaseMemoryStore[T]) NotifyExtractors

func (s *BaseMemoryStore[T]) NotifyExtractors(
	ctx context.Context,
	appState *models.AppState,
	eventData *models.MessageEvent,
)

NotifyExtractors notifies all registered Extractors of a new MessageEvent

type EmbeddingMismatchError

type EmbeddingMismatchError struct {
	Message       string
	OriginalError error
}

func NewEmbeddingMismatchError

func NewEmbeddingMismatchError(
	originalError error,
) *EmbeddingMismatchError

func (*EmbeddingMismatchError) Error

func (e *EmbeddingMismatchError) Error() string

func (*EmbeddingMismatchError) Unwrap

func (e *EmbeddingMismatchError) Unwrap() error

type StorageError

type StorageError struct {
	Message       string
	OriginalError error
}

func NewStorageError

func NewStorageError(message string, originalError error) *StorageError

func (*StorageError) Error

func (e *StorageError) Error() string