kv

package

v0.0.2 Latest Latest Go to latest Published: Feb 16, 2025 License: BSD-3-Clause Imports: 12 Imported by: 0

Details

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

Repository

github.com/aep/apogy

Links

Open Source Insights

Documentation ¶

Index ¶

type KV
- func NewPebble() (KV, error)
- func NewTikv() (KV, error)
type KeyAndValue
type PebbleRead
type PebbleWrite
type Pebbledb
type Read
type Tikv
type TikvRead
type TikvWrite
type Write

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type KV ¶

type KV interface {
	Close()
	Write() Write
	Read() Read
}

func NewPebble ¶

func NewPebble() (KV, error)

func NewTikv ¶

func NewTikv() (KV, error)

type KeyAndValue ¶

type KeyAndValue struct {
	K []byte
	V []byte
}

type PebbleRead ¶

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

func (*PebbleRead) Close ¶

func (r *PebbleRead) Close()

func (*PebbleRead) Get ¶

func (r *PebbleRead) Get(ctx context.Context, key []byte) ([]byte, error)

func (*PebbleRead) Iter ¶

func (r *PebbleRead) Iter(ctx context.Context, start []byte, end []byte) iter.Seq2[KeyAndValue, error]

func (*PebbleRead) SetKeyOnly ¶

func (r *PebbleRead) SetKeyOnly(b bool)

type PebbleWrite ¶

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

func (*PebbleWrite) Close ¶

func (r *PebbleWrite) Close()

func (*PebbleWrite) Commit ¶

func (w *PebbleWrite) Commit(ctx context.Context) error

func (*PebbleWrite) Del ¶

func (w *PebbleWrite) Del(key []byte) error

func (*PebbleWrite) Get ¶

func (w *PebbleWrite) Get(ctx context.Context, key []byte) ([]byte, error)

func (*PebbleWrite) Iter ¶

func (r *PebbleWrite) Iter(ctx context.Context, start []byte, end []byte) iter.Seq2[KeyAndValue, error]

func (*PebbleWrite) Put ¶

func (w *PebbleWrite) Put(key []byte, value []byte) error

func (*PebbleWrite) Rollback ¶

func (w *PebbleWrite) Rollback() error

type Pebbledb ¶

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

func (*Pebbledb) Close ¶

func (p *Pebbledb) Close()

func (*Pebbledb) Read ¶

func (p *Pebbledb) Read() Read

func (*Pebbledb) Write ¶

func (p *Pebbledb) Write() Write

type Read ¶

type Read interface {
	Get(ctx context.Context, key []byte) ([]byte, error)
	Iter(ctx context.Context, srart []byte, end []byte) iter.Seq2[KeyAndValue, error]
	Close()
}

type Tikv ¶

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

func (*Tikv) Close ¶

func (t *Tikv) Close()

func (*Tikv) Read ¶

func (t *Tikv) Read() Read

func (*Tikv) Write ¶

func (t *Tikv) Write() Write

type TikvRead ¶

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

func (*TikvRead) Close ¶

func (r *TikvRead) Close()

func (*TikvRead) Get ¶

func (r *TikvRead) Get(ctx context.Context, key []byte) ([]byte, error)

func (*TikvRead) Iter ¶

func (r *TikvRead) Iter(ctx context.Context, start []byte, end []byte) iter.Seq2[KeyAndValue, error]

func (*TikvRead) SetKeyOnly ¶

func (r *TikvRead) SetKeyOnly(b bool)

type TikvWrite ¶

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

func (*TikvWrite) Close ¶

func (r *TikvWrite) Close()

func (*TikvWrite) Commit ¶

func (w *TikvWrite) Commit(ctx context.Context) error

func (*TikvWrite) Del ¶

func (w *TikvWrite) Del(key []byte) error

func (*TikvWrite) Get ¶

func (w *TikvWrite) Get(ctx context.Context, key []byte) ([]byte, error)

func (*TikvWrite) Iter ¶

func (r *TikvWrite) Iter(ctx context.Context, start []byte, end []byte) iter.Seq2[KeyAndValue, error]

func (*TikvWrite) Put ¶

func (w *TikvWrite) Put(key []byte, value []byte) error

func (*TikvWrite) Rollback ¶

func (w *TikvWrite) Rollback() error

type Write ¶

type Write interface {
	Read
	Get(ctx context.Context, key []byte) ([]byte, error)
	Put(key []byte, value []byte) error
	Del(key []byte) error
	Commit(ctx context.Context) error
	Rollback() error
	Close()
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cmd
debug

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