postgres

package

v0.0.0-...-9b2621d Latest Latest Go to latest Published: Aug 14, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/basenana/friday

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type KVIterator
type PgKVReader
- func NewPgKVReader(cli *PostgresClient) *PgKVReader
type PgKVWriter
- func NewPgKVWriter(cli *PostgresClient, mo store.MergeOperator) *PgKVWriter
type PostgresClient
- func NewPostgresClient(postgresUrl string) (*PostgresClient, error)

Constants ¶

View Source

const (
	PgKVStoreName = "pg_table"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type KVIterator ¶

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

func (*KVIterator) Close ¶

func (i *KVIterator) Close() error

func (*KVIterator) Current ¶

func (i *KVIterator) Current() ([]byte, []byte, bool)

func (*KVIterator) Key ¶

func (i *KVIterator) Key() []byte

func (*KVIterator) Next ¶

func (i *KVIterator) Next()

func (*KVIterator) Seek ¶

func (i *KVIterator) Seek(key []byte)

func (*KVIterator) Valid ¶

func (i *KVIterator) Valid() bool

func (*KVIterator) Value ¶

func (i *KVIterator) Value() []byte

type PgKVReader ¶

type PgKVReader struct {
	*PostgresClient
}

func NewPgKVReader ¶

func NewPgKVReader(cli *PostgresClient) *PgKVReader

func (*PgKVReader) Close ¶

func (p *PgKVReader) Close() error

func (*PgKVReader) Get ¶

func (p *PgKVReader) Get(key []byte) ([]byte, error)

func (*PgKVReader) MultiGet ¶

func (p *PgKVReader) MultiGet(keys [][]byte) ([][]byte, error)

func (*PgKVReader) PrefixIterator ¶

func (p *PgKVReader) PrefixIterator(prefix []byte) store.KVIterator

func (*PgKVReader) RangeIterator ¶

func (p *PgKVReader) RangeIterator(start, end []byte) store.KVIterator

type PgKVWriter ¶

type PgKVWriter struct {
	*PostgresClient
	// contains filtered or unexported fields
}

func NewPgKVWriter ¶

func NewPgKVWriter(cli *PostgresClient, mo store.MergeOperator) *PgKVWriter

func (*PgKVWriter) Close ¶

func (p *PgKVWriter) Close() error

func (*PgKVWriter) ExecuteBatch ¶

func (p *PgKVWriter) ExecuteBatch(batch store.KVBatch) error

func (*PgKVWriter) NewBatch ¶

func (p *PgKVWriter) NewBatch() store.KVBatch

func (*PgKVWriter) NewBatchEx ¶

func (p *PgKVWriter) NewBatchEx(options store.KVBatchOptions) ([]byte, store.KVBatch, error)

type PostgresClient ¶

type PostgresClient struct {
	Logger  *zap.SugaredLogger
	DEntity *db.Entity
}

func NewPostgresClient ¶

func NewPostgresClient(postgresUrl string) (*PostgresClient, error)

func (*PostgresClient) CreateDocument ¶

func (p *PostgresClient) CreateDocument(ctx context.Context, doc *doc.Document) error

func (*PostgresClient) DeleteDocument ¶

func (p *PostgresClient) DeleteDocument(ctx context.Context, entryId int64) error

func (*PostgresClient) FilterDocuments ¶

func (p *PostgresClient) FilterDocuments(ctx context.Context, filter *doc.DocumentFilter) ([]*doc.Document, error)

func (*PostgresClient) Get ¶

func (p *PostgresClient) Get(ctx context.Context, oid int64, name string, group int) (*vector.Element, error)

func (*PostgresClient) GetDocument ¶

func (p *PostgresClient) GetDocument(ctx context.Context, entryId int64) (*doc.Document, error)

func (*PostgresClient) Inited ¶

func (p *PostgresClient) Inited(ctx context.Context) (bool, error)

func (*PostgresClient) Search ¶

func (p *PostgresClient) Search(ctx context.Context, query vector.VectorDocQuery, vectors []float32, k int) ([]*vector.Doc, error)

func (*PostgresClient) Store ¶

func (p *PostgresClient) Store(ctx context.Context, element *vector.Element, extra map[string]any) error

func (*PostgresClient) UpdateDocument ¶

func (p *PostgresClient) UpdateDocument(ctx context.Context, doc *doc.Document) error

func (*PostgresClient) UpdateTokens ¶

func (p *PostgresClient) UpdateTokens(ctx context.Context, doc *doc.Document) error

func (*PostgresClient) WithNamespace ¶

func (p *PostgresClient) WithNamespace(ctx context.Context) *gorm.DB

Source Files ¶

View all Source files

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