Skip to content

A very simple and fast key-value pure-go store but persisting data to disk, with a "localStorage-like" API.

License

Notifications You must be signed in to change notification settings

sopherapps/go-scdb

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

40 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

go-scdb

CI

A very simple and fast key-value pure-go store but persisting data to disk, with a "localStorage-like" API.

This is the pure-golang version of the original scdb

scdb may not be production-ready yet. It works, quite well but it requires more vigorous testing.

Purpose

Coming from front-end web development, localStorage was always a convenient way of quickly persisting data to be used later by a given application even after a restart. Its API was extremely simple i.e. localStorage.getItem(), localStorage.setItem(), localStorage.removeItem() , localStorage.clear().

Coming to the backend (or even desktop) development, such an embedded persistent data store with a simple API was hard to come by.

scdb is meant to be like the 'localStorage' of backend and desktop (and possibly mobile) systems. Of course to make it a little more appealing, it has some extra features like:

  • Time-to-live (TTL) where a key-value pair expires after a given time
  • Non-blocking reads from separate processes, and threads.
  • Fast Sequential writes to the store, queueing any writes from multiple processes and threads.

Dependencies

  • golang +v1.18

Quick Start

  • Ensure you have golang +v1.18 installed. You can check the official instructions for how to do that.

  • Initialize a new go modules project

mkdir example-go-scdb
cd example-go-scdb
go mod init github.com/<your-username>/example-go-scdb
  • Install the package
go get github.com/sopherapps/go-scdb/scdb
  • Create a main.go file
touch main.go
  • Add the following code to the main.go file
package main

import (
	"fmt"
	"github.com/sopherapps/go-scdb/scdb"
	"log"
)

func main() {
	records := map[string][]byte{
		"hey":      []byte("English"),
		"hi":       []byte("English"),
		"salut":    []byte("French"),
		"bonjour":  []byte("French"),
		"hola":     []byte("Spanish"),
		"oi":       []byte("Portuguese"),
		"mulimuta": []byte("Runyoro"),
	}

	var maxKeys uint64 = 1_000_000
	var redundantBlocks uint16 = 1
	var poolCapacity uint64 = 10
	var compactionInterval uint32 = 1_800

	store, err := scdb.New(
		"db",
		&maxKeys,
		&redundantBlocks,
		&poolCapacity,
		&compactionInterval)
	if err != nil {
		log.Fatalf("error opening store: %s", err)
	}
	defer func() {
		_ = store.Close()
    }()

	// inserting without ttl
	for k, v := range records {
		err := store.Set([]byte(k), v, nil)
		if err != nil {
			log.Fatalf("error inserting without ttl: %s", err)
		}
	}

	// inserting with ttl of 5 seconds
	var ttl uint64 = 5
	for k, v := range records {
		err := store.Set([]byte(k), v, &ttl)
		if err != nil {
			log.Fatalf("error inserting with ttl: %s", err)
		}
	}

	// updating - just set them again
	updates := map[string][]byte{
		"hey":      []byte("Jane"),
		"hi":       []byte("John"),
		"hola":     []byte("Santos"),
		"oi":       []byte("Ronaldo"),
		"mulimuta": []byte("Aliguma"),
	}
	for k, v := range updates {
		err := store.Set([]byte(k), v, nil)
		if err != nil {
			log.Fatalf("error updating: %s", err)
		}
	}

	// getting
	for k := range records {
		value, err := store.Get([]byte(k))
		if err != nil {
			log.Fatalf("error getting: %s", err)
		}

		fmt.Printf("Key: %s, Value: %s", k, value)
	}

	// deleting
	for k := range records {
		err := store.Delete([]byte(k))
		if err != nil {
			log.Fatalf("error deleting: %s", err)
		}
	}

	// clearing
	err = store.Clear()
	if err != nil {
		log.Fatalf("error clearing: %s", err)
	}

	// compacting (Use sparingly, say if database file is too big)
	err = store.Compact()
	if err != nil {
		log.Fatalf("error compacting: %s", err)
	}
}
  • Run the module
go run main.go 

Contributing

Contributions are welcome. The docs have to maintained, the code has to be made cleaner, more idiomatic and faster, and there might be need for someone else to take over this repo in case I move on to other things. It happens!

Please look at the CONTRIBUTIONS GUIDELINES

You can also look in the ./docs folder of the rust scdb to get up to speed with the internals of scdb e.g.

Bindings

scdb is meant to be used in multiple languages of choice. However, the bindings for most of them are yet to be developed.

For other programming languages, see the main README

How to Test

  • Ensure you have golang +v1.18 installed. You can check the official instructions for how to do that.
  • Clone this repo and enter its root folder
git clone https://github.com/sopherapps/go-scdb.git && cd go-scdb
  • Install dependencies
go mod tidy
  • Run the tests command
go test ./... -timeout 30s -race
  • Run benchmarks
go test -bench=. ./scdb -run=^#

Benchmarks

On a average PC

cpu: Intel(R) Core(TM) i7-4870HQ CPU @ 2.50GHz
BenchmarkStore_Clear/Clear-8               40608             30342 ns/op
BenchmarkStore_Clear/Clear_with_ttl:_3600-8                40650             28866 ns/op
BenchmarkStore_Compact/Compact-8                               1        2053004395 ns/op
BenchmarkStore_DeleteWithoutTtl/Delete_key_hey-8          296575              4236 ns/op
BenchmarkStore_DeleteWithoutTtl/Delete_key_hi-8           175813              6824 ns/op
BenchmarkStore_DeleteWithoutTtl/Delete_key_salut-8        182779              6713 ns/op
BenchmarkStore_DeleteWithoutTtl/Delete_key_bonjour-8              174636              6808 ns/op
BenchmarkStore_DeleteWithoutTtl/Delete_key_hola-8                 185263              6905 ns/op
BenchmarkStore_DeleteWithoutTtl/Delete_key_oi-8                   175563              6755 ns/op
BenchmarkStore_DeleteWithoutTtl/Delete_key_mulimuta-8             179035              6890 ns/op
BenchmarkStore_DeleteWithTtl/Delete_key_hey-8                     273160              4323 ns/op
BenchmarkStore_DeleteWithTtl/Delete_key_hi-8                      174811              6674 ns/op
BenchmarkStore_DeleteWithTtl/Delete_key_salut-8                   174747              6700 ns/op
BenchmarkStore_DeleteWithTtl/Delete_key_bonjour-8                 184989              6719 ns/op
BenchmarkStore_DeleteWithTtl/Delete_key_hola-8                    177486              6865 ns/op
BenchmarkStore_DeleteWithTtl/Delete_key_oi-8                      169952              6816 ns/op
BenchmarkStore_DeleteWithTtl/Delete_key_mulimuta-8                186657              6691 ns/op
BenchmarkStore_GetWithoutTtl/Get_hey-8                           1304970               918.2 ns/op
BenchmarkStore_GetWithoutTtl/Get_hi-8                            1316133               915.6 ns/op
BenchmarkStore_GetWithoutTtl/Get_salut-8                         1299086               906.9 ns/op
BenchmarkStore_GetWithoutTtl/Get_bonjour-8                       1311649               921.9 ns/op
BenchmarkStore_GetWithoutTtl/Get_hola-8                          1313056               912.8 ns/op
BenchmarkStore_GetWithoutTtl/Get_oi-8                            1302331               908.8 ns/op
BenchmarkStore_GetWithoutTtl/Get_mulimuta-8                      1317252               918.0 ns/op
BenchmarkStore_GetWithTtl/Get_hey-8                              1000000              1062 ns/op
BenchmarkStore_GetWithTtl/Get_hi-8                               1000000              1083 ns/op
BenchmarkStore_GetWithTtl/Get_salut-8                             996957              1079 ns/op
BenchmarkStore_GetWithTtl/Get_bonjour-8                          1000000              1066 ns/op
BenchmarkStore_GetWithTtl/Get_hola-8                             1000000              1071 ns/op
BenchmarkStore_GetWithTtl/Get_oi-8                               1000000              1062 ns/op
BenchmarkStore_GetWithTtl/Get_mulimuta-8                         1000000              1059 ns/op
BenchmarkStore_SetWithoutTtl/Set_hey_English-8                    159267              7296 ns/op
BenchmarkStore_SetWithoutTtl/Set_hi_English-8                     127662              9400 ns/op
BenchmarkStore_SetWithoutTtl/Set_salut_French-8                   122229              9521 ns/op
BenchmarkStore_SetWithoutTtl/Set_bonjour_French-8                 129010              9431 ns/op
BenchmarkStore_SetWithoutTtl/Set_hola_Spanish-8                   129002              9469 ns/op
BenchmarkStore_SetWithoutTtl/Set_oi_Portuguese-8                  124683              9400 ns/op
BenchmarkStore_SetWithoutTtl/Set_mulimuta_Runyoro-8               120543              9663 ns/op
BenchmarkStore_SetWithTtl/Set_hey_English-8                       171721              8766 ns/op
BenchmarkStore_SetWithTtl/Set_hi_English-8                        122996              9660 ns/op
BenchmarkStore_SetWithTtl/Set_salut_French-8                      120986              9733 ns/op
BenchmarkStore_SetWithTtl/Set_bonjour_French-8                    123841             10434 ns/op
BenchmarkStore_SetWithTtl/Set_hola_Spanish-8                      120808              9698 ns/op
BenchmarkStore_SetWithTtl/Set_oi_Portuguese-8                     123492              9797 ns/op
BenchmarkStore_SetWithTtl/Set_mulimuta_Runyoro-8                  121556             10063 ns/op
PASS
ok      github.com/sopherapps/go-scdb/scdb      66.489s

TODO

  • Optimize Get operation
  • Optimize the Compact operation

Acknowledgements

License

Licensed under both the MIT License

Copyright (c) 2022 Martin Ahindura

Gratitude

"This is real love - not that we loved God, but that He loved us and sent His Son as a sacrifice to take away our sins."

-- 1 John 4: 10

All glory be to God.

Buy Me A Coffee