pebble_driver

README

Pebble driver for Kilovolt

Simple Pebble driver for Kilovolt.

Usage

Usage is literally a function call to wrap an existing Pebble instance in a Kilovolt driver interface and then passing it over.

package example

import (
	"github.com/cockroachdb/pebble"
	kv "github.com/strimertul/kilovolt/v7"
	pebble_driver "github.com/strimertul/kv-pebble"
)

func main() {
	// Initialize your database 
	db, err := pebble.Open("test", &pebble.Options{})
	if err != nil {
		panic(err)
	}
	defer db.Close()

	// Create driver using database instance, second parameter is "sync" (should be kept to true)
	driver := pebble_driver.NewPebbleBackend(db, true)

	// Pass it to Kilovolt
	hub, err := kv.NewHub(driver, kv.HubOptions{}, nil)
	if err != nil {
		panic(err)
	}
	go hub.Run()

	// etc.
}

Documentation

Index

• type Driver
  • func NewPebbleBackend(db *pebble.DB, sync bool) Driver
  • func (b Driver) Delete(key string) error
  • func (b Driver) Get(key string) (string, error)
  • func (b Driver) GetBulk(keys []string) (map[string]string, error)
  • func (b Driver) GetPrefix(prefix string) (map[string]string, error)
  • func (b Driver) List(prefix string) ([]string, error)
  • func (b Driver) Set(key, value string) error
  • func (b Driver) SetBulk(kv map[string]string) error

Types

type Driver

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

func NewPebbleBackend

func NewPebbleBackend(db *pebble.DB, sync bool) Driver

func (Driver) Delete

func (b Driver) Delete(key string) error

func (Driver) Get

func (b Driver) Get(key string) (string, error)

func (Driver) GetBulk

func (b Driver) GetBulk(keys []string) (map[string]string, error)

func (Driver) GetPrefix

func (b Driver) GetPrefix(prefix string) (map[string]string, error)

func (Driver) List

func (b Driver) List(prefix string) ([]string, error)

func (Driver) Set

func (b Driver) Set(key, value string) error

func (Driver) SetBulk

func (b Driver) SetBulk(kv map[string]string) error