Class PostgresStore

Namespace

Mythosia.VectorDb.Postgres

Assembly

Mythosia.VectorDb.Postgres.dll

public class PostgresStore : IVectorStore, IDisposable

Inheritance

object

PostgresStore

Implements

IVectorStore

IDisposable

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

PostgresStore(PostgresOptions)

public PostgresStore(PostgresOptions options)

Parameters

options PostgresOptions

Methods

CountAsync(VectorFilter?, CancellationToken)

public Task<long> CountAsync(VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<long>

DeleteAsync(string, VectorFilter?, CancellationToken)

public Task DeleteAsync(string id, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

id string

filter VectorFilter

cancellationToken CancellationToken

Returns

Task

DeleteByFilterAsync(VectorFilter, CancellationToken)

public Task DeleteByFilterAsync(VectorFilter filter, CancellationToken cancellationToken = default)

Parameters

filter VectorFilter

cancellationToken CancellationToken

Returns

Task

Dispose()

public void Dispose()

GetAsync(string, VectorFilter?, CancellationToken)

public Task<VectorRecord?> GetAsync(string id, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

id string

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<VectorRecord>

GetBatchAsync(IEnumerable<string>, VectorFilter?, CancellationToken)

public Task<IReadOnlyList<VectorRecord>> GetBatchAsync(IEnumerable<string> ids, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

ids IEnumerable<string>

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<IReadOnlyList<VectorRecord>>

HybridSearchAsync(float[], string, int, VectorFilter?, CancellationToken)

public Task<IReadOnlyList<VectorSearchResult>> HybridSearchAsync(float[] denseVector, string query, int topK, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

denseVector float[]

query string

topK int

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<IReadOnlyList<VectorSearchResult>>

ParseVectorString(string)

public static float[] ParseVectorString(string text)

Parameters

text string

Returns

float[]

ReplaceByFilterAsync(VectorFilter, IReadOnlyList<VectorRecord>, CancellationToken)

public Task ReplaceByFilterAsync(VectorFilter filter, IReadOnlyList<VectorRecord> records, CancellationToken cancellationToken = default)

Parameters

filter VectorFilter

records IReadOnlyList<VectorRecord>

cancellationToken CancellationToken

Returns

Task

SearchAsync(float[], int, VectorFilter?, VectorSearchRuntimeOptions?, CancellationToken)

public Task<IReadOnlyList<VectorSearchResult>> SearchAsync(float[] queryVector, int topK, VectorFilter? filter, VectorSearchRuntimeOptions? runtimeOptions, CancellationToken cancellationToken = default)

Parameters

queryVector float[]

topK int

filter VectorFilter

runtimeOptions VectorSearchRuntimeOptions

cancellationToken CancellationToken

Returns

Task<IReadOnlyList<VectorSearchResult>>

SearchAsync(float[], int, VectorFilter?, CancellationToken)

public Task<IReadOnlyList<VectorSearchResult>> SearchAsync(float[] queryVector, int topK = 5, VectorFilter? filter = null, CancellationToken cancellationToken = default)

Parameters

queryVector float[]

topK int

filter VectorFilter

cancellationToken CancellationToken

Returns

Task<IReadOnlyList<VectorSearchResult>>

UpsertAsync(VectorRecord, CancellationToken)

public Task UpsertAsync(VectorRecord record, CancellationToken cancellationToken = default)

Parameters

record VectorRecord

cancellationToken CancellationToken

Returns

Task

UpsertBatchAsync(IEnumerable<VectorRecord>, CancellationToken)

public Task UpsertBatchAsync(IEnumerable<VectorRecord> records, CancellationToken cancellationToken = default)

Parameters

records IEnumerable<VectorRecord>

cancellationToken CancellationToken

Returns

Task

VectorToString(float[])

public static string VectorToString(float[] values)

Parameters

values float[]

Returns

string

VerifyConnectionAsync(CancellationToken)

public Task VerifyConnectionAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

Task