kvhttp

package module

v0.0.0-...-2244e4f Latest Latest Go to latest Published: Nov 29, 2025 License: Apache-2.0 Imports: 20 Imported by: 2

Details

Package kvhttp exports any visvasity/kv api compatible database over http API for remote access.

This section is empty.

This section is empty.

func Handler(db kv.Database) http.Handler

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

func New(baseURL *url.URL, client *http.Client) *DB

func (db *DB) Close() error

func (db *DB) NewSnapshot(ctx context.Context) (*Snap, error)

func (db *DB) NewTransaction(ctx context.Context) (*Tx, error)

func (db *DB) ServerURL() url.URL

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

func (snap *Snap) Ascend(ctx context.Context, begin, end string, errp *error) iter.Seq2[string, io.Reader]

func (snap *Snap) Descend(ctx context.Context, begin, end string, errp *error) iter.Seq2[string, io.Reader]

func (snap *Snap) Discard(ctx context.Context) error

func (snap *Snap) Get(ctx context.Context, key string) (io.Reader, error)

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

func (tx *Tx) Ascend(ctx context.Context, begin, end string, errp *error) iter.Seq2[string, io.Reader]

func (tx *Tx) Commit(ctx context.Context) error

func (tx *Tx) Delete(ctx context.Context, key string) error

func (tx *Tx) Descend(ctx context.Context, begin, end string, errp *error) iter.Seq2[string, io.Reader]

func (tx *Tx) Get(ctx context.Context, key string) (io.Reader, error)

func (tx *Tx) Rollback(ctx context.Context) error

func (tx *Tx) Set(ctx context.Context, key string, value io.Reader) error

Path	Synopsis
api