database

Documentation

Index

• type DB
  • func New(location string, memory bool, continousWrite bool, ec chan error, wd chan bool, ...) *DB
  • func (d *DB) Connect() error
  • func (d *DB) Create(key string, value interface{}) error
  • func (d *DB) Delete(key string) error
  • func (d *DB) DeleteMany(keys ...string) map[string]interface{}
  • func (d *DB) Disconnect() error
  • func (d *DB) NewWrite()
  • func (d *DB) Read(key string) (interface{}, error)
  • func (d *DB) ReadAll() string
  • func (d *DB) ReadMany(keys ...string) map[string]interface{}
  • func (d *DB) Update(key string, value interface{}) error

Types

type DB

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

DB represents the database struct

func New

func New(location string, memory bool, continousWrite bool, ec chan error, wd chan bool, writeInt int) *DB

New initializes a database to a given location and sets it's internal DB to an empty map or reads from file first

func (*DB) Connect

func (d *DB) Connect() error

Connect connects to file and saves it's contents to database field

func (*DB) Create

func (d *DB) Create(key string, value interface{}) error

Create creates a new record

func (*DB) Delete

func (d *DB) Delete(key string) error

Delete deletes a single entry

func (*DB) DeleteMany

func (d *DB) DeleteMany(keys ...string) map[string]interface{}

func (*DB) Disconnect

func (d *DB) Disconnect() error

Disconnect encodes database with json and saves it to location if provided

func (*DB) NewWrite

func (d *DB) NewWrite()

NewWrite sends a copy of database to write job queue

func (*DB) Read

func (d *DB) Read(key string) (interface{}, error)

Read reads from a single key

func (*DB) ReadAll

func (d *DB) ReadAll() string

ReadAll returns all entries from DB

func (*DB) ReadMany

func (d *DB) ReadMany(keys ...string) map[string]interface{}

ReadMany returns multiple keys

func (*DB) Update

func (d *DB) Update(key string, value interface{}) error

Update updates a single entry