trounoirDB

type Config ¶

type Config struct {
	Items     []ConfigItem `json:"items"`
	Port      int          `json:"port"`
	CopyRange int          `json:"copy_range"`
	Salt      string       `json:"salt"`
	Folder    string       `json:"folder"`
}

spread 1 2 3 4 1 -> 2 3 2 -> 3 4 3 -> 4 1 4 -> 1 2

to scale up, 1) add cluster 5 2) add 5 to config file of 4 3) restart 4, during restarting 1 2 3 5 will be keep active 4) change config 3, restart 3, during restart 1 2 4 5 will be active 5) change config 2, restart 2, during restart 1 3 4 5 will be active 6) do the rest, config and restart one by one

to scale down change config 3 dup, from 4 1 to 4 2, restart change config 4 dup, from 1 2 to 2 3, restart stop 1 do the rest, config and restart one by one

func (config *Config) GetLocalConfig() (*LocalConfig, error)

func (config *Config) Parse(config_path string) error

type ConfigItem ¶

type ConfigItem struct {
	Host    string `json:"host"`
	IsLocal bool   `json:"islocal"`
}

for example c1 host: 192.168.0.12 islocal: true

type DB ¶

type DB struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (db *DB) GetTable(name string) *DBTable

func (db *DB) LoadTable(name string) error

type DBTable ¶

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

type Doc ¶

type Doc interface {
}

type LocalConfig ¶

type LocalConfig struct {
	Self ConfigItem
	Dup  []ConfigItem
}

local config dup must exclude self for a forward request, send forward request to dup

type MemTable ¶

type MemTable struct {
	sync.RWMutex
	Data map[string]memDataItem
	// contains filtered or unexported fields
}

func (mt *MemTable) Run()

type Method ¶

type Method int

type Request ¶

type Request struct {
	IsRemote   bool
	Timestamp  int64
	SecureHash []byte
	Bucket     string
	Key        string
	Value      interface{}
	MRQuery    []byte
}

func (r *Request) GenSecure(salt string)

func (r *Request) Verify(salt string) bool

type Table ¶

type Table interface {
	Path() string
	Put(key string, b []byte) error
	Get(key string) ([]byte, error)
}

func CreateTable(name string, cfg Config) (Table, error)

func NewTable(name, path string) Table

type Timestamp ¶

type Timestamp int64