oceanbase

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 2, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package oceanbase implements the OceanBase relational profile and indexes.

Package oceanbase implements OceanBase-specific rebuildable indexes. The authoritative relational stores remain in sqlstore and use MySQLDialect.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExperienceFTSIndex

type ExperienceFTSIndex struct{}

func (ExperienceFTSIndex) Initialize

func (ExperienceFTSIndex) Initialize(ctx context.Context, db sqlstore.DBTX) error

func (ExperienceFTSIndex) Replace

func (ExperienceFTSIndex) Replace(ctx context.Context, db sqlstore.DBTX, scopeID string, value experience.Experience) error

func (ExperienceFTSIndex) Search

func (ExperienceFTSIndex) Search(
	ctx context.Context,
	db sqlstore.DBTX,
	scopeID, query string,
	limit int,
) (hits []experience.SearchHit, returnErr error)

type MemoryFTSIndex

type MemoryFTSIndex struct{}

func (MemoryFTSIndex) Capabilities

func (MemoryFTSIndex) Capabilities() memory.Capabilities

func (MemoryFTSIndex) Hydrate

func (MemoryFTSIndex) Hydrate(
	_ context.Context,
	_ sqlstore.DBTX,
	_ string,
	projections []memory.Projection,
) ([]memory.Projection, error)

func (MemoryFTSIndex) Initialize

func (MemoryFTSIndex) Initialize(ctx context.Context, db sqlstore.DBTX) error

func (MemoryFTSIndex) Replace

func (MemoryFTSIndex) Search

func (MemoryFTSIndex) Search(
	ctx context.Context,
	db sqlstore.DBTX,
	scopeID string,
	request memory.SearchRequest,
) (channels memory.SearchChannels, returnErr error)

type MemoryVectorIndex

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

MemoryVectorIndex maintains the Python-compatible OceanBase VECTOR/HNSW active-head projection for one exact embedding profile.

func NewMemoryVectorIndex

func NewMemoryVectorIndex(profile memory.EmbeddingProfile) (*MemoryVectorIndex, error)

func (*MemoryVectorIndex) Capabilities

func (i *MemoryVectorIndex) Capabilities() memory.Capabilities

func (*MemoryVectorIndex) Hydrate

func (i *MemoryVectorIndex) Hydrate(
	ctx context.Context,
	db sqlstore.DBTX,
	scopeID string,
	projections []memory.Projection,
) ([]memory.Projection, error)

func (*MemoryVectorIndex) Initialize

func (i *MemoryVectorIndex) Initialize(ctx context.Context, db sqlstore.DBTX) error

func (*MemoryVectorIndex) Replace

func (i *MemoryVectorIndex) Replace(
	ctx context.Context,
	db sqlstore.DBTX,
	scopeID string,
	memoryRef artifact.Ref,
	projections []memory.Projection,
) error

func (*MemoryVectorIndex) Search

func (i *MemoryVectorIndex) Search(
	ctx context.Context,
	db sqlstore.DBTX,
	scopeID string,
	request memory.SearchRequest,
) (channels memory.SearchChannels, returnErr error)

func (*MemoryVectorIndex) VectorComplete

func (i *MemoryVectorIndex) VectorComplete(
	ctx context.Context,
	db sqlstore.DBTX,
	scopeID string,
	memories []artifact.Ref,
	profile memory.EmbeddingProfile,
) (bool, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL