gdio

type ILoader interface {
	LoadAll(IReader) error
}

type IReader interface {
	Source() ISource
	AddItem(interface{}, IRecord)
	FindItem(interface{}) IRecord
	Read(ILoader) error
	Reload(ILoader) error
	FindAll(ptr, fun interface{}) error
	FindAllByIndex(ptr, key, fun interface{}) error
	FindOne(ptr, key interface{}) error
	FindOneByIndex(ptr, lk, pk interface{}) error
	GetOne(interface{}, interface{}) (interface{}, error)
	GetOneByIndex(interface{}, interface{}, interface{}) (interface{}, error)
	Count(ptr interface{}) uint
}

type IRecord interface {
	Remove(bool, ...interface{}) error
	Write(bool, ...interface{}) error
	Read(interface{}) error
	Index(interface{}, interface{}) error
	Indexes(interface{}, interface{}, interface{}) error
	GetByIndex(interface{}) (interface{}, error)
	GetByIndexes(interface{}, interface{}) (interface{}, error)
	Iterator(interface{}, interface{}) error
	IteratorByIndex(interface{}, interface{}, interface{}) error
	Count() uint
}

type ISource interface {
	Remove(...interface{}) error
	Write(...interface{}) error
	ReadOne(interface{}, IRecord) error
	ReadAll(func(interface{}, IRecord) interface{}) error
	SetIndex(name string, ptr interface{}, indexes []*IndexInfo) error
	Close()
}

type IndexInfo struct {
	Indexes  []string
	IsUnique bool
}

type ReadWrite struct {
	*Reader
	NewRecord func(ISource, string, interface{}) IRecord
	// contains filtered or unexported fields
}

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