zoom

Jan 12, 2018

Changes in this version

type Model

+ ModelID func() string

+ SetModelID func(string)

type Query

+ func (q *Query) IDs() ([]string, error)

+ func (q *Query) StoreIDs(destKey string) error

+ type RandomID struct

+ ID string

+ func (r *RandomID) ModelID() string

+ func (r *RandomID) SetModelID(id string)

type Transaction

+ func (t *Transaction) DeleteModelsBySetIDs(setKey string, collectionName string, handler ReplyHandler)

+ func (t *Transaction) ExtractIDsFromFieldIndex(setKey string, destKey string, min interface{}, max interface{})

+ func (t *Transaction) ExtractIDsFromStringIndex(setKey, destKey, min, max string)

type TransactionQuery

+ func (q *TransactionQuery) IDs(ids *[]string)

+ func (q *TransactionQuery) StoreIDs(destKey string)

May 31, 2016

Changes in this version

type Collection

+ func (c *Collection) Exists(id string) (bool, error)

type Transaction

+ func (t *Transaction) Exists(c *Collection, id string, exists *bool)

+ func (t *Transaction) Watch(model Model) error

+ func (t *Transaction) WatchKey(key string) error

+ type WatchError struct

+ func (e WatchError) Error() string

Mar 29, 2016

Changes in this version

+ var DefaultCollectionOptions = CollectionOptions

+ var DefaultPoolOptions = PoolOptions

type Collection

+ func (c *Collection) SaveFields(fieldNames []string, model Model) error

type CollectionOptions

+ func (options CollectionOptions) WithFallbackMarshalerUnmarshaler(fallback MarshalerUnmarshaler) CollectionOptions

+ func (options CollectionOptions) WithIndex(index bool) CollectionOptions

+ func (options CollectionOptions) WithName(name string) CollectionOptions

type ModelNotFoundError

+ Collection *Collection

type Pool

+ func NewPoolWithOptions(options PoolOptions) *Pool

+ func (p *Pool) NewCollectionWithOptions(model Model, options CollectionOptions) (*Collection, error)

type PoolOptions

+ IdleTimeout time.Duration

+ MaxActive int

+ MaxIdle int

+ Wait bool

+ func (options PoolOptions) WithAddress(address string) PoolOptions

+ func (options PoolOptions) WithDatabase(database int) PoolOptions

+ func (options PoolOptions) WithIdleTimeout(timeout time.Duration) PoolOptions

+ func (options PoolOptions) WithMaxActive(maxActive int) PoolOptions

+ func (options PoolOptions) WithMaxIdle(maxIdle int) PoolOptions

+ func (options PoolOptions) WithNetwork(network string) PoolOptions

+ func (options PoolOptions) WithPassword(password string) PoolOptions

+ func (options PoolOptions) WithWait(wait bool) PoolOptions

type Query

+ func (q *Query) StoreIds(destKey string) error

type Transaction

+ func (t *Transaction) FindModelsByIdsKey(collection *Collection, idsKey string, fieldNames []string, limit uint, ...)

+ func (t *Transaction) SaveFields(c *Collection, fieldNames []string, model Model)

+ func (tx *Transaction) Query(collection *Collection) *TransactionQuery

+ type TransactionQuery struct

+ func (q *TransactionQuery) Count(count *int)

+ func (q *TransactionQuery) Exclude(fields ...string) *TransactionQuery

+ func (q *TransactionQuery) Filter(filterString string, value interface{}) *TransactionQuery

+ func (q *TransactionQuery) Ids(ids *[]string)

+ func (q *TransactionQuery) Include(fields ...string) *TransactionQuery

+ func (q *TransactionQuery) Limit(amount uint) *TransactionQuery

+ func (q *TransactionQuery) Offset(amount uint) *TransactionQuery

+ func (q *TransactionQuery) Order(fieldName string) *TransactionQuery

+ func (q *TransactionQuery) Run(models interface{})

+ func (q *TransactionQuery) RunOne(model Model)

+ func (q *TransactionQuery) StoreIds(destKey string)

+ func (q TransactionQuery) String() string

Mar 1, 2016

Changes in this version

type Collection

+ func (c *Collection) FieldNames() []string

+ func (c *Collection) FieldRedisNames() []string

type ReplyHandler

+ func NewScanBoolHandler(b *bool) ReplyHandler

+ func NewScanFloat64Handler(f *float64) ReplyHandler

+ func NewScanIntHandler(i *int) ReplyHandler

+ func NewScanModelHandler(fieldNames []string, model Model) ReplyHandler

+ func NewScanModelsHandler(collection *Collection, fieldNames []string, models interface{}) ReplyHandler

+ func NewScanStringHandler(s *string) ReplyHandler

+ func NewScanStringsHandler(strings *[]string) ReplyHandler

type Transaction

+ func (t *Transaction) DeleteModelsBySetIds(setKey string, collectionName string, handler ReplyHandler)

+ func (t *Transaction) ExtractIdsFromFieldIndex(setKey string, destKey string, min interface{}, max interface{})

+ func (t *Transaction) ExtractIdsFromStringIndex(setKey, destKey, min, max string)

Oct 20, 2015

Changes in this version

type Collection

+ func (c *Collection) FindFields(id string, fieldNames []string, model Model) error

type CollectionOptions

+ FallbackMarshalerUnmarshaler MarshalerUnmarshaler

type MarshalerUnmarshaler

+ var GobMarshalerUnmarshaler MarshalerUnmarshaler = gobMarshalerUnmarshaler{}

+ var JSONMarshalerUnmarshaler MarshalerUnmarshaler = jsonMarshalerUnmarshaler{}

type Transaction

+ func (t *Transaction) FindFields(c *Collection, id string, fieldNames []string, model Model)

Oct 16, 2015

Changes in this version

type Collection

+ func (c *Collection) UpdateFields(fieldNames []string, model Model) error

type Transaction

+ func (t *Transaction) UpdateFields(c *Collection, fieldNames []string, model Model)

Sep 10, 2015

Changes in this version

+ type Collection struct

+ func (c *Collection) Count() (int, error)

+ func (c *Collection) Delete(id string) (bool, error)

+ func (c *Collection) DeleteAll() (int, error)

+ func (c *Collection) FieldIndexKey(fieldName string) (string, error)

+ func (c *Collection) Find(id string, model Model) error

+ func (c *Collection) FindAll(models interface{}) error

+ func (c *Collection) IndexKey() string

+ func (c *Collection) ModelKey(id string) (string, error)

+ func (c *Collection) Name() string

+ func (c *Collection) Save(model Model) error

+ func (collection *Collection) NewQuery() *Query

+ type CollectionOptions struct

+ Index bool

+ Name string

type Pool

+ func (p *Pool) NewCollection(model Model, options *CollectionOptions) (*Collection, error)

+ type PoolOptions struct

+ Address string

+ Database int

+ Network string

+ Password string

Jun 14, 2015

Changes in this version

+ type Pool struct

+ func NewPool(config *PoolConfig) *Pool

+ func (p *Pool) Close() error

+ func (p *Pool) NewConn() redis.Conn

+ func (p *Pool) NewTransaction() *Transaction

+ func (p *Pool) Register(model Model) (*ModelType, error)

+ func (p *Pool) RegisterName(name string, model Model) (*ModelType, error)

+ type PoolConfig struct

+ Address string

+ Database int

+ Network string

+ Password string

May 12, 2015

Changes in this version

type Model

+ ModelId func() string

+ SetModelId func(string)

+ type RandomId struct

+ Id string

+ func (r *RandomId) ModelId() string

+ func (r *RandomId) SetModelId(id string)

May 4, 2015

Changes in this version

+ func NewConn() redis.Conn

+ type Action struct

+ type ActionKind int

+ const CommandAction

+ const ScriptAction

type Configuration

+ Password string

type ModelNotFoundError

+ Msg string

+ type ModelType struct

+ func (modelType *ModelType) NewQuery() *Query

+ func (mt *ModelType) AllIndexKey() string

+ func (mt *ModelType) Count() (int, error)

+ func (mt *ModelType) Delete(id string) (bool, error)

+ func (mt *ModelType) DeleteAll() (int, error)

+ func (mt *ModelType) FieldIndexKey(fieldName string) (string, error)

+ func (mt *ModelType) Find(id string, model Model) error

+ func (mt *ModelType) FindAll(models interface{}) error

+ func (mt *ModelType) ModelKey(id string) (string, error)

+ func (mt *ModelType) Name() string

+ func (mt *ModelType) Save(model Model) error

type Query

+ func (q *Query) Ids() ([]string, error)

+ type ReplyHandler func(interface{}) error

+ type Transaction struct

+ func NewTransaction() *Transaction

+ func (t *Transaction) Command(name string, args redis.Args, handler ReplyHandler)

+ func (t *Transaction) Count(mt *ModelType, count *int)

+ func (t *Transaction) Delete(mt *ModelType, id string, deleted *bool)

+ func (t *Transaction) DeleteAll(mt *ModelType, count *int)

+ func (t *Transaction) Exec() error

+ func (t *Transaction) Find(mt *ModelType, id string, model Model)

+ func (t *Transaction) FindAll(mt *ModelType, models interface{})

+ func (t *Transaction) Save(mt *ModelType, model Model)

+ func (t *Transaction) Script(script *redis.Script, args redis.Args, handler ReplyHandler)

Jan 30, 2015

Changes in this version

+ type DependencyCycleError struct

+ func NewDependencyCycleError(phase, dep *phase) *DependencyCycleError

+ func (e *DependencyCycleError) Error() string

Aug 12, 2014

Changes in this version

+ func GetMutexById(mutexId string) *sync.Mutex

Aug 11, 2014

Changes in this version

+ type Sync struct

+ MutexId string

+ func (s *Sync) SetMutexId(id string)

+ func (s Sync) Lock()

+ func (s Sync) Unlock()

+ type Syncer interface

+ Lock func()

+ SetMutexId func(string)

+ Unlock func()

Aug 3, 2014

Changes in this version

+ type ModelNotFoundError struct

+ func NewModelNotFoundError() *ModelNotFoundError

+ func (e *ModelNotFoundError) Error() string

type Query

+ func (q *Query) RunOne() (interface{}, error)

+ func (q *Query) ScanOne(in interface{}) error

May 30, 2014

Changes in this version

+ type ById []*indexedPrimativesModel

+ func (ms ById) Len() int

+ func (ms ById) Less(i, j int) bool

+ func (ms ById) Swap(i, j int)

type Query

+ func (q *Query) String() string

Dec 22, 2013

Changes in this version

type Query

+ func (q *Query) GetIdCount() (int, error)

+ func (q *Query) GetIds() ([]string, error)

+ func (q *Query) GetIdsWithFilters() ([]string, error)

+ func (q *Query) GetIdsWithoutFilters() ([]string, error)

Dec 10, 2013

Changes in this version

+ func Interfaces(in interface{}) []interface

+ func MDelete(models []Model) error

+ func MDeleteById(modelNames []string, ids []string) error

+ func MSave(models []Model) error

+ func MScanById(ids []string, models interface{}) error

+ func RegisterName(name string, model Model) error

+ func Unregister(model Model) error

+ type MarshalerUnmarshaler interface

+ Marshal func(v interface{}) ([]byte, error)

+ Unmarshal func(data []byte, v interface{}) error

type Model

+ func MFindById(modelNames, ids []string) ([]Model, error)

type Query

+ func NewQuery(modelName string) *Query

+ func (q *Query) Count() (int, error)

+ func (q *Query) Exclude(fields ...string) *Query

+ func (q *Query) Filter(filterString string, value interface{}) *Query

+ func (q *Query) IdsOnly() ([]string, error)

+ func (q *Query) Include(fields ...string) *Query

+ func (q *Query) Limit(amount uint) *Query

+ func (q *Query) Offset(amount uint) *Query

+ func (q *Query) Order(fieldName string) *Query

+ func (q *Query) Scan(in interface{}) error

+ type RunScanner interface

+ Run func() (interface{}, error)

+ Scan func(interface{}) error

Sep 25, 2013

Changes in this version

+ type DefaultData struct

+ Id string

+ func (d *DefaultData) GetId() string

+ func (d *DefaultData) SetId(id string)

type Model

+ func Models(in interface{}) []Model

+ type ModelQuery struct

+ func (q *ModelQuery) Exclude(fields ...string) *ModelQuery

+ func (q *ModelQuery) Include(fields ...string) *ModelQuery

+ func (q *ModelQuery) Run() (interface{}, error)

+ type MultiModelQuery struct

+ func ScanAll(models interface{}) *MultiModelQuery

+ func (q *MultiModelQuery) Exclude(fields ...string) *MultiModelQuery

+ func (q *MultiModelQuery) Include(fields ...string) *MultiModelQuery

+ func (q *MultiModelQuery) Limit(amount uint) *MultiModelQuery

+ func (q *MultiModelQuery) Offset(amount uint) *MultiModelQuery

+ func (q *MultiModelQuery) Order(order string) *MultiModelQuery

+ func (q *MultiModelQuery) Run() (interface{}, error)

+ func (q *MultiModelQuery) SortBy(field string) *MultiModelQuery

+ type Query interface

+ Run func() (interface{}, error)

Aug 24, 2013

Changes in this version

+ const INDEX_CACHE_THROTTLE

+ func ClearCache()

+ func ScheduleIndexCacheUpdate(modelName string)

type Configuration

+ CacheCapacity uint64

+ CacheDisabled bool

Aug 18, 2013

Changes in this version

+ func ScanById(model ModelInterface, id string) error

Aug 17, 2013

Changes in this version

+ const ONE_TO_MANY

+ const ONE_TO_ONE

+ func Close()

+ func Delete(in ModelInterface) error

+ func DeleteById(modelName, id string) error

+ func FindAll(modelName string) ([]interface{}, error)

+ func FindById(modelName, id string) (interface{}, error)

+ func GetConn() redis.Conn

+ func Init(passedConfig *Configuration)

+ func KeyExists(key string, conn redis.Conn) (bool, error)

+ func Register(in interface{}, name string) error

+ func Save(in ModelInterface) error

+ func Scan(src []interface{}, dest ...interface{}) ([]interface{}, error)

+ func ScanStruct(src []interface{}, dest interface{}) error

+ func SetContains(key, member string, conn redis.Conn) (bool, error)

+ func UnregisterName(name string) error

+ func UnregisterType(typ reflect.Type) error

+ type Args []interface

+ func (args Args) Add(value interface{}) Args

+ func (args Args) AddFlat(v interface{}) Args

+ type Configuration struct

+ Address string

+ Database int

+ Network string

+ type InterfaceIsNotPointerError struct

+ func NewInterfaceIsNotPointerError(in interface{}) *InterfaceIsNotPointerError

+ func (e *InterfaceIsNotPointerError) Error() string

+ type KeyNotFoundError struct

+ func NewKeyNotFoundError(msg string) *KeyNotFoundError

+ func (e *KeyNotFoundError) Error() string

+ type MissingParamaterError struct

+ func NewMissingParamaterError(msg string) *MissingParamaterError

+ func (e *MissingParamaterError) Error() string

+ type Model struct

+ Id string

+ func (m *Model) GetId() string

+ func (m *Model) SetId(id string)

+ type ModelInterface interface

+ GetId func() string

+ SetId func(string)

+ type ModelNameNotRegisteredError struct

+ func NewModelNameNotRegisteredError(name string) *ModelNameNotRegisteredError

+ func (e *ModelNameNotRegisteredError) Error() string

+ type ModelTypeNotRegisteredError struct

+ func NewModelTypeNotRegisteredError(typ reflect.Type) *ModelTypeNotRegisteredError

+ func (e *ModelTypeNotRegisteredError) Error() string

+ type NameAlreadyRegisteredError struct

+ func NewNameAlreadyRegisteredError(name string) *NameAlreadyRegisteredError

+ func (e *NameAlreadyRegisteredError) Error() string

+ type RelationNotFoundError struct

+ func NewRelationNotFoundError(name string) *RelationNotFoundError

+ func (e *RelationNotFoundError) Error() string

+ type TypeAlreadyRegisteredError struct

+ func NewTypeAlreadyRegisteredError(typ reflect.Type) *TypeAlreadyRegisteredError

+ func (e *TypeAlreadyRegisteredError) Error() string