ValueZ is value store to be used from code written in FunL programming language. Values are FunL type of values. Values are kept in memory (RAM) and accessed primarily from there but are also stored to persistent storage (disk). ValueZ works more efficiently if client is more read-intensive than write-intensive.
ValueZ supports concurrent access to data and guarantees consistency via transactions and views (snapshots). Also collection operations modify values in collection so that consistency remains inside collection.
ValueZ is used in context of one process (not to be shared with several processes).
Database (db) and Collection (col) are main concepts in ValueZ.
Database (db) contains many collections. Persistent storage works in scope of database.
Collection contains many FunL values. Most operations of ValueZ are applied at collection level. Consistency is guaranteed at collection level.
Transaction is procedure call inside which several operations for collection can be done so that changes are isolated from current collection contents. Depending on return value of procedure call changes are committed or discarded.
Views are snapshots of collection. View is implemented with procedure call inside which several operations to collection share same snapshot of values. Only read -type of operations are allowed inside views.
Persistent storage is implemented by using bbolt key-value storage.
ValueZ can act also as in-memory mode also if 'in-mem' option in open is given as true. In-memory mode means that data is not written to permanent storage (bbolt, file) but only stored in memory.
Note. if in-memory mode is used then also such FunL data which is not serializable (like functions, channels etc.) can be stored (as it doesn't need to be serialized before storing).
Values (in collection) can be any serializable FunL values.
ValueZ provides following kind of interfaces for client:
- db/col operations
- open
- new-col
- get-col
- get-col-names
- del-col
- close
- reading/writing values
- put-value
- get-values
- take-values
- update
- transactions/views
- trans
- view
Database (db) and collection (col) are represented as opaque FunL types.
Opens existing database or if it does not exist creates new database. Database file is created with name given as argument (if not existing already).
valuez.open(<db-name:string>) -> list(<ok:bool> <error:string> <db:opaque>)
valuez.open(<db-name:string> <OPTIONAL:options-map>) -> list(<ok:bool> <error:string> <db:opaque>)
Optionally options map can be given as 2nd argument:
Key (string) | Value |
---|---|
'in-mem' | if true then db is storen in memory only, if false then also stored to permanent storage |
Creates new collection for db.
valuez.new-col(<db:opaque> <col-name:string>) -> list(<ok:bool> <error:string> <col:opaque>)
Gets collection value by name from db.
valuez.get-col(<db:opaque> <col-name:string>) -> list(<ok:bool> <error:string> <col:opaque>)
Gets list of collection names in db.
valuez.get-col-names(<db:opaque>) -> list(<ok:bool> <error:string> <col-names:list-of-strings>)
Deletes collection from db. Waits ongoing operations to finish before removal.
valuez.del-col(<col:opaque>) -> list(<ok:bool> <error:string>)
Closes db. Waits ongoing operations to finish before closing.
valuez.close(<db:opaque>) -> list(<ok:bool> <error:string> <db:opaque>)
Procedures for reading and writing from/to collection can be used in two ways:
- Outside of transaction or view
- Inside transaction or view
If operation is done outside of transaction/view then operation is directly applied to collection. If operation is done in context of transaction then changes are applied to transaction, not directly to collection (after commit changes are applied to collection). Similarly in context of view operation (only read operations allowed) is applied to snapshot of collection, not to latest version of collection.
In case of transaction and view (opaque) transaction value is given as argument to operation instead of (opaque) collection value.
Note: procedures (proc) can be given as arguments instead of functions also in reading and writing operations.
Writes value to collection.
valuez.put-value(<col/txn:opaque> <value>) -> list(<ok:bool> <error:string>)
Reads values from collection which satisfy filter condition given as function arument (2nd argument). Function is called for each value in collection. Value is given as argument to function, if function returns true value is included in result list, if it returns false then it's not included.
valuez.get-values(<col/txn:opaque> <func>) -> list(<value>, ...)
Example: Get all values from collection
ns main
import valuez
import stddbc
main = proc()
open-ok open-err db = call(valuez.open 'dbexample'):
_ = call(stddbc.assert open-ok open-err)
col-ok col-err col = call(valuez.new-col db 'examplecol'):
_ = call(stddbc.assert col-ok col-err)
_ = call(valuez.put-value col 'Pizza')
_ = call(valuez.put-value col 'Burger')
_ = call(valuez.put-value col 'Hot Dog')
items = call(valuez.get-values col func(x) true end)
_ = call(valuez.close db)
items
end
endns
-> list('Pizza', 'Burger', 'Hot Dog')
Example: Get values which start with 'P'
ns main
import valuez
import stddbc
main = proc()
import stdstr
open-ok open-err db = call(valuez.open 'dbexample'):
_ = call(stddbc.assert open-ok open-err)
col-ok col-err col = call(valuez.new-col db 'examplecol'):
_ = call(stddbc.assert col-ok col-err)
_ = call(valuez.put-value col 'Pizza')
_ = call(valuez.put-value col 'Burger')
_ = call(valuez.put-value col 'Hot Dog')
items = call(valuez.get-values col func(x) call(stdstr.startswith x 'P') end)
_ = call(valuez.close db)
items
end
endns
-> list('Pizza')
Takes values from collection which satisfy filter condition given as function arument (2nd argument). Function is called for each value in collection. Value is given as argument to function, if function returns true value is included in result list and removed from collection, if it returns false then it's not included in result list and it remains in collection.
valuez.take-values(<col/txn:opaque> <func>) -> list(<value>, ...)
Example: Take 'Burger' value from collection
ns main
import valuez
import stddbc
main = proc()
open-ok open-err db = call(valuez.open 'dbexample'):
_ = call(stddbc.assert open-ok open-err)
col-ok col-err col = call(valuez.new-col db 'examplecol'):
_ = call(stddbc.assert col-ok col-err)
_ = call(valuez.put-value col 'Pizza')
_ = call(valuez.put-value col 'Burger')
_ = call(valuez.put-value col 'Hot Dog')
taken-items = call(valuez.take-values col func(x) eq(x 'Burger') end)
left-items = call(valuez.get-values col func(x) true end)
_ = call(valuez.close db)
sprintf('items taken: %v, items left: %v' taken-items left-items)
end
endns
-> 'items taken: list('Burger'), items left: list('Pizza', 'Hot Dog')'
Applies function given as argument to each value in collection and if function returns list in which first item is true then value is replaced in collection with value given as second item in list. If first item in returned list is false then value remains same in collection.
valuez.update(<col/txn:opaque> <func>) -> <bool>
Return value is true if any value in collection was updated and changes were successfully written to persistent storage.
Example: Change all values (strings) to lowercase strings
ns main
import valuez
import stddbc
main = proc()
open-ok open-err db = call(valuez.open 'dbexample'):
_ = call(stddbc.assert open-ok open-err)
col-ok col-err col = call(valuez.new-col db 'examplecol'):
_ = call(stddbc.assert col-ok col-err)
_ = call(valuez.put-value col 'Pizza')
_ = call(valuez.put-value col 'Burger')
_ = call(valuez.put-value col 'Hot Dog')
import stdstr
_ = call(valuez.update col func(x) list(true call(stdstr.lowercase x)) end)
items = call(valuez.get-values col func(x) true end)
_ = call(valuez.close db)
items
end
endns
-> list('pizza', 'burger', 'hot dog')
Transactions and Views are implemented so that client defines procedure which is called from ValueZ with (opaque) transaction/view value. Inside that procedure using that transaction/view value for read/write operations consistent view is maintained.
Executes transaction for given collection, transaction implementation is given as procedure in 2nd argument.
valuez.trans(<col:opaque> <procedure>) -> bool
Return value is true if changes were committed, false if not.
Procedure given as argument is following kind:
<proc>(<txn:opaque>) -> <commit/cancel:bool>
Example: Atomic transaction from one account to other => Changes Committed
ns main
import valuez
import stddbc
example-transaction = proc(txn)
# move 250 euros from John to Jack in consistent way
transfer-amount = 250
john-old = head(call(valuez.take-values txn
func(x)
eq(get(x 'name') 'John')
end
))
john-new = map(
'name' get(john-old 'name')
'saldo' minus(get(john-old 'saldo') transfer-amount)
)
jack-old = head(call(valuez.take-values txn
func(x)
eq(get(x 'name') 'Jack')
end
))
jack-new = map(
'name' get(jack-old 'name')
'saldo' plus(get(jack-old 'saldo') transfer-amount)
)
_ = call(valuez.put-value txn john-new)
_ = call(valuez.put-value txn jack-new)
items = call(valuez.get-values txn func(x) true end)
_ = print('From transaction accounts are: ' items '\n')
true # changes are committed
end
main = proc()
open-ok open-err db = call(valuez.open 'dbexample'):
_ = call(stddbc.assert open-ok open-err)
col-ok col-err col = call(valuez.new-col db 'accounts'):
_ = call(stddbc.assert col-ok col-err)
# saldos for each person
_ = call(valuez.put-value col map('name' 'John' 'saldo' 3500))
_ = call(valuez.put-value col map('name' 'Jack' 'saldo' 1000))
_ = call(valuez.put-value col map('name' 'Steve' 'saldo' 500))
_ = print('orinally accounts are: ' call(valuez.get-values col func(x) true end) '\n')
_ = call(valuez.trans col example-transaction)
items = call(valuez.get-values col func(x) true end)
_ = call(valuez.close db)
sprintf('resulting accounts are: %v' items)
end
endns
->
orinally accounts are: list(map('name' : 'John', 'saldo' : 3500), map('name' : 'Jack', 'saldo' : 1000), map('name' : 'Steve', 'saldo' : 500))
From transaction accounts are: list(map('name' : 'Steve', 'saldo' : 500), map('name' : 'John', 'saldo' : 3250), map('name' : 'Jack', 'saldo' : 1250))
'resulting accounts are: list(map('name' : 'Jack', 'saldo' : 1250), map('name' : 'John', 'saldo' : 3250), map('name' : 'Steve', 'saldo' : 500))'
Example: Atomic transaction from one account to other => Changes Cancelled
ns main
import valuez
import stddbc
example-transaction = proc(txn)
# move 250 euros from John to Jack in consistent way
transfer-amount = 250
john-old = head(call(valuez.take-values txn
func(x)
eq(get(x 'name') 'John')
end
))
john-new = map(
'name' get(john-old 'name')
'saldo' minus(get(john-old 'saldo') transfer-amount)
)
jack-old = head(call(valuez.take-values txn
func(x)
eq(get(x 'name') 'Jack')
end
))
jack-new = map(
'name' get(jack-old 'name')
'saldo' plus(get(jack-old 'saldo') transfer-amount)
)
_ = call(valuez.put-value txn john-new)
_ = call(valuez.put-value txn jack-new)
items = call(valuez.get-values txn func(x) true end)
_ = print('From transaction accounts are: ' items '\n')
false # changes are not committed
end
main = proc()
open-ok open-err db = call(valuez.open 'dbexample'):
_ = call(stddbc.assert open-ok open-err)
col-ok col-err col = call(valuez.new-col db 'accounts'):
_ = call(stddbc.assert col-ok col-err)
# saldos for each person
_ = call(valuez.put-value col map('name' 'John' 'saldo' 3500))
_ = call(valuez.put-value col map('name' 'Jack' 'saldo' 1000))
_ = call(valuez.put-value col map('name' 'Steve' 'saldo' 500))
_ = print('orinally accounts are: ' call(valuez.get-values col func(x) true end) '\n')
_ = call(valuez.trans col example-transaction)
items = call(valuez.get-values col func(x) true end)
_ = call(valuez.close db)
sprintf('resulting accounts are: %v' items)
end
endns
->
orinally accounts are: list(map('name' : 'John', 'saldo' : 3500), map('name' : 'Jack', 'saldo' : 1000), map('name' : 'Steve', 'saldo' : 500))
From transaction accounts are: list(map('name' : 'Steve', 'saldo' : 500), map('name' : 'Jack', 'saldo' : 1250), map('name' : 'John', 'saldo' : 3250))
'resulting accounts are: list(map('name' : 'John', 'saldo' : 3500), map('name' : 'Jack', 'saldo' : 1000), map('name' : 'Steve', 'saldo' : 500))'
Executes View for given collection, View implementation is given as procedure in 2nd argument. View sees consistent snapshot of collection.
valuez.view(<col:opaque> <procedure>) -> <value>
Return value is return value returned from procedure given as argument.
Procedure given as argument is following kind:
<proc>(<txn:opaque>) -> <value>
Example: Showing how view seems same snapshot alhtough collection is already updated (synchronized via channels to demonstrate timeline)
ns main
import valuez
import stddbc
run-viewer = proc(ch1 ch2 ch3 col)
viewer = proc(txn)
_ = print('In view')
_ = send(ch1 'ready')
_ = recv(ch2)
items = call(valuez.get-values txn func(x) true end)
_ = print('View sees still these: ' items)
_ = send(ch3 'done')
'whatever return value view'
end
spawn( print('view result: ' call(valuez.view col viewer) ) )
end
main = proc()
open-ok open-err db = call(valuez.open 'dbexample'):
_ = call(stddbc.assert open-ok open-err)
col-ok col-err col = call(valuez.new-col db 'examplecol'):
_ = call(stddbc.assert col-ok col-err)
_ = call(valuez.put-value col 'Pizza')
_ = call(valuez.put-value col 'Burger')
ch1 ch2 ch3 = list(chan() chan() chan()):
_ = call(run-viewer ch1 ch2 ch3 col)
_ = recv(ch1)
_ = print('put more items to collection')
_ = call(valuez.put-value col 'Lasagne')
_ = call(valuez.put-value col 'Hot Dog')
items = call(valuez.get-values col func(x) true end)
_ = print('Collection now: ' items)
_ = send(ch2 'continue')
_ = recv(ch3)
_ = call(valuez.close db)
items
end
endns
->
In view
put more items to collection
Collection now: list('Pizza', 'Burger', 'Lasagne', 'Hot Dog')
View sees still these: list('Burger', 'Pizza')
view result: whatever return value view
list('Pizza', 'Burger', 'Lasagne', 'Hot Dog')
There are two ways to take ValueZ into use:
- As plugin module
- As std module (locally add to standard library modules)
Option 1. is preferred but plugin modules can be used only in FreeBSD/Linux/Mac, not in Windows. Here's more information about FunL plugin modules. So in Windows option 2. remains way to use ValueZ.
There is own Github repository for ValueZ plugin building. To create ValueZ as shared object librarys (valuez.so) do following steps:
git clone https://github.com/anssihalmeaho/valuezplugin.git
cd valuezplugin/
go get github.com/anssihalmeaho/fuvaluez
make
-> produces valuez.so- set FUNLPATH environment variable so that valuez.so is found
See FunL plugin guide for more information
Note. Go modules implementation can be very strict about module/package versions so it may be required
that after cloning FunL repository from Github (git clone https://github.com/anssihalmeaho/funl.git
)
all other files and folders removed but following ones:
- main.go
- Makefile
- go.mod
Also rename module to some other name in go.mod, for example:
module github.com/anssihalmeaho/funl
=>
module funla
And then build funla executable by make
.
See here how built-in modules can be extended with own ones Steps are:
- clone FunL repository from Github:
git clone https://github.com/anssihalmeaho/funl.git
- add own Go module into /std directory (named for example like valuezm.go)
go get github.com/anssihalmeaho/fuvaluez
- make -> produces funla executable where ValueZ is buil-in module (with name valuez)
Here's how built-in module (valuezm.go) should be:
package std
import (
"github.com/anssihalmeaho/funl/funl"
"github.com/anssihalmeaho/fuvaluez/fuvaluez"
)
func init() {
funl.AddExtensionInitializer(initMyExt)
}
func convGetter(inGetter func(string) fuvaluez.FZProc) func(string) stdFuncType {
return func(name string) stdFuncType {
return stdFuncType(inGetter(name))
}
}
func initMyExt(interpreter *funl.Interpreter) (err error) {
stdModuleName := "valuez"
topFrame := funl.NewTopFrameWithInterpreter(interpreter)
stdFuncs := []stdFuncInfo{
{
Name: "open",
Getter: convGetter(fuvaluez.GetVZOpen),
},
{
Name: "new-col",
Getter: convGetter(fuvaluez.GetVZNewCol),
},
{
Name: "get-col",
Getter: convGetter(fuvaluez.GetVZGetCol),
},
{
Name: "get-col-names",
Getter: convGetter(fuvaluez.GetVZGetColNames),
},
{
Name: "put-value",
Getter: convGetter(fuvaluez.GetVZPutValue),
},
{
Name: "get-values",
Getter: convGetter(fuvaluez.GetVZGetValues),
},
{
Name: "take-values",
Getter: convGetter(fuvaluez.GetVZTakeValues),
},
{
Name: "update",
Getter: convGetter(fuvaluez.GetVZUpdate),
},
{
Name: "trans",
Getter: convGetter(fuvaluez.GetVZTrans),
},
{
Name: "view",
Getter: convGetter(fuvaluez.GetVZView),
},
{
Name: "del-col",
Getter: convGetter(fuvaluez.GetVZDelCol),
},
{
Name: "close",
Getter: convGetter(fuvaluez.GetVZClose),
},
}
err = setSTDFunctions(topFrame, stdModuleName, stdFuncs, interpreter)
return
}