orm

package module
v1.3.25 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 27, 2021 License: MIT Imports: 32 Imported by: 3

README

orm

Documentation

Index

Constants

View Source 
const (
	QueryLoggerSourceDB = iota
	QueryLoggerSourceRedis
	QueryLoggerSourceElastic
	QueryLoggerSourceClickHouse
	QueryLoggerSourceLocalCache
	QueryLoggerSourceStreams
)
View Source 
const RedisSearchNullNumber = -math.MaxInt64

Variables

This section is empty.

Functions

func EscapeRedisSearchString added in v1.1.11 

func EscapeRedisSearchString(val string) string

Types

type Alter 

type Alter struct {
	SQL  string
	Safe bool
	Pool string
	// contains filtered or unexported fields
}

func (Alter) Exec added in v1.3.0 

func (a Alter) Exec()

type BackgroundConsumer added in v1.3.1 

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

func NewBackgroundConsumer added in v1.3.1 

func NewBackgroundConsumer(engine *Engine) *BackgroundConsumer

func (*BackgroundConsumer) Digest added in v1.3.1 

func (r *BackgroundConsumer) Digest(ctx context.Context)

func (*BackgroundConsumer) DisableLoop added in v1.3.1 

func (b *BackgroundConsumer) DisableLoop()

func (*BackgroundConsumer) HeartBeat added in v1.3.1 

func (b *BackgroundConsumer) HeartBeat(force bool)

func (*BackgroundConsumer) SetErrorHandler added in v1.3.1 

func (b *BackgroundConsumer) SetErrorHandler(handler ConsumerErrorHandler)

func (*BackgroundConsumer) SetHeartBeat added in v1.3.1 

func (b *BackgroundConsumer) SetHeartBeat(duration time.Duration, beat func())

func (*BackgroundConsumer) SetLimit added in v1.3.1 

func (b *BackgroundConsumer) SetLimit(limit int)

func (*BackgroundConsumer) SetLogLogger added in v1.3.1 

func (r *BackgroundConsumer) SetLogLogger(logger func(log *LogQueueValue))

type Bind 

type Bind map[string]interface{}

type CachedQuery 

type CachedQuery struct{}

type ClickHouse 

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

func (*ClickHouse) Begin 

func (c *ClickHouse) Begin()

func (*ClickHouse) Commit 

func (c *ClickHouse) Commit()

func (*ClickHouse) Exec 

func (c *ClickHouse) Exec(query string, args ...interface{}) sql.Result

func (*ClickHouse) Prepare 

func (c *ClickHouse) Prepare(query string) (preparedStatement *PreparedStatement, deferF func())

func (*ClickHouse) Queryx 

func (c *ClickHouse) Queryx(query string, args ...interface{}) (rows *sqlx.Rows, deferF func())

func (*ClickHouse) Rollback 

func (c *ClickHouse) Rollback()

type ClickHouseConfig 

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

type ConsumerErrorHandler added in v1.1.0 

type ConsumerErrorHandler func(err interface{}, event Event) error

type DB 

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

func (*DB) Begin 

func (db *DB) Begin()

func (*DB) Commit 

func (db *DB) Commit()

func (*DB) Exec 

func (db *DB) Exec(query string, args ...interface{}) ExecResult

func (*DB) GetPoolConfig added in v1.3.0 

func (db *DB) GetPoolConfig() MySQLPoolConfig

func (*DB) Query 

func (db *DB) Query(query string, args ...interface{}) (rows Rows, deferF func())

func (*DB) QueryRow 

func (db *DB) QueryRow(query *Where, toFill ...interface{}) (found bool)

func (*DB) Rollback 

func (db *DB) Rollback()

type DirtyEntityEvent 

type DirtyEntityEvent interface {
	ID() uint64
	TableSchema() TableSchema
	Added() bool
	Updated() bool
	Deleted() bool
}

func EventDirtyEntity 

func EventDirtyEntity(e Event) DirtyEntityEvent

type DuplicatedKeyError 

type DuplicatedKeyError struct {
	Message string
	Index   string
}

func (*DuplicatedKeyError) Error 

func (err *DuplicatedKeyError) Error() string

type Elastic 

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

func (*Elastic) Client 

func (e *Elastic) Client() *elastic.Client

func (*Elastic) CreateIndex 

func (e *Elastic) CreateIndex(index ElasticIndexDefinition)

func (*Elastic) DropIndex 

func (e *Elastic) DropIndex(index ElasticIndexDefinition)

func (*Elastic) Search 

func (e *Elastic) Search(index string, query elastic.Query, pager *Pager, options *SearchOptions) *elastic.SearchResult

type ElasticConfig 

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

type ElasticIndexAlter 

type ElasticIndexAlter struct {
	Index       ElasticIndexDefinition
	Safe        bool
	Pool        string
	NewMapping  map[string]interface{}
	OldMapping  map[string]interface{}
	NewSettings interface{}
	OldSettings interface{}
}

type ElasticIndexDefinition 

type ElasticIndexDefinition interface {
	GetName() string
	GetDefinition() map[string]interface{}
}

type Engine 

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

func (*Engine) AddQueryLogger 

func (e *Engine) AddQueryLogger(handler logApex.Handler, level logApex.Level, source ...QueryLoggerSource)

func (*Engine) CachedSearch 

func (e *Engine) CachedSearch(entities interface{}, indexName string, pager *Pager, arguments ...interface{}) (totalRows int)

func (*Engine) CachedSearchCount 

func (e *Engine) CachedSearchCount(entity Entity, indexName string, arguments ...interface{}) int

func (*Engine) CachedSearchIDs 

func (e *Engine) CachedSearchIDs(entity Entity, indexName string, pager *Pager, arguments ...interface{}) (totalRows int, ids []uint64)

func (*Engine) CachedSearchLazy added in v1.1.13 

func (e *Engine) CachedSearchLazy(entities interface{}, indexName string, pager *Pager, arguments ...interface{}) (totalRows int)

func (*Engine) CachedSearchOne 

func (e *Engine) CachedSearchOne(entity Entity, indexName string, arguments ...interface{}) (found bool)

func (*Engine) CachedSearchOneLazy added in v1.1.13 

func (e *Engine) CachedSearchOneLazy(entity Entity, indexName string, arguments ...interface{}) (found bool)

func (*Engine) CachedSearchOneWithReferences 

func (e *Engine) CachedSearchOneWithReferences(entity Entity, indexName string, arguments []interface{}, references []string) (found bool)

func (*Engine) CachedSearchOneWithReferencesLazy added in v1.1.13 

func (e *Engine) CachedSearchOneWithReferencesLazy(entity Entity, indexName string, arguments []interface{}, references []string) (found bool)

func (*Engine) CachedSearchWithReferences 

func (e *Engine) CachedSearchWithReferences(entities interface{}, indexName string, pager *Pager,
	arguments []interface{}, references []string) (totalRows int)

func (*Engine) CachedSearchWithReferencesLazy added in v1.1.13 

func (e *Engine) CachedSearchWithReferencesLazy(entities interface{}, indexName string, pager *Pager,
	arguments []interface{}, references []string) (totalRows int)

func (*Engine) ClearByIDs 

func (e *Engine) ClearByIDs(entity Entity, ids ...uint64)

func (*Engine) Delete 

func (e *Engine) Delete(entity Entity)

func (*Engine) DeleteMany 

func (e *Engine) DeleteMany(entities ...Entity)

func (*Engine) EnableDebug 

func (e *Engine) EnableDebug()

func (*Engine) EnableLogger 

func (e *Engine) EnableLogger(level logApex.Level, handlers ...logApex.Handler)

func (*Engine) EnableQueryDebug 

func (e *Engine) EnableQueryDebug(source ...QueryLoggerSource)

func (*Engine) EnableRequestCache 

func (e *Engine) EnableRequestCache()

func (*Engine) Flush 

func (e *Engine) Flush(entity Entity)

func (*Engine) FlushLazy 

func (e *Engine) FlushLazy(entity Entity)

func (*Engine) FlushLazyMany 

func (e *Engine) FlushLazyMany(entities ...Entity)

func (*Engine) FlushMany 

func (e *Engine) FlushMany(entities ...Entity)

func (*Engine) FlushWithCheck 

func (e *Engine) FlushWithCheck(entity ...Entity) error

func (*Engine) ForceDelete 

func (e *Engine) ForceDelete(entity Entity)

func (*Engine) ForceDeleteMany added in v1.3.0 

func (e *Engine) ForceDeleteMany(entities ...Entity)

func (*Engine) GetAlters 

func (e *Engine) GetAlters() (alters []Alter)

func (*Engine) GetClickHouse 

func (e *Engine) GetClickHouse(code ...string) *ClickHouse

func (*Engine) GetElastic 

func (e *Engine) GetElastic(code ...string) *Elastic

func (*Engine) GetElasticIndexAlters 

func (e *Engine) GetElasticIndexAlters() (alters []ElasticIndexAlter)

func (*Engine) GetEventBroker 

func (e *Engine) GetEventBroker() EventBroker

func (*Engine) GetLocalCache 

func (e *Engine) GetLocalCache(code ...string) *LocalCache

func (*Engine) GetMysql 

func (e *Engine) GetMysql(code ...string) *DB

func (*Engine) GetRedis 

func (e *Engine) GetRedis(code ...string) *RedisCache

func (*Engine) GetRedisSearch 

func (e *Engine) GetRedisSearch(code ...string) *RedisSearch

func (*Engine) GetRedisSearchIndexAlters 

func (e *Engine) GetRedisSearchIndexAlters() (alters []RedisSearchIndexAlter)

func (*Engine) GetRegistry 

func (e *Engine) GetRegistry() ValidatedRegistry

func (*Engine) HealthCheck added in v1.1.16 

func (e *Engine) HealthCheck() (errors []HealthCheckError, warnings []HealthCheckError, valid []HealthCheckStep)

func (*Engine) Load 

func (e *Engine) Load(entity Entity, references ...string) (found bool)

func (*Engine) LoadByID 

func (e *Engine) LoadByID(id uint64, entity Entity, references ...string) (found bool)

func (*Engine) LoadByIDLazy added in v1.1.9 

func (e *Engine) LoadByIDLazy(id uint64, entity Entity, references ...string) (found bool)

func (*Engine) LoadByIDs 

func (e *Engine) LoadByIDs(ids []uint64, entities interface{}, references ...string) (missing bool)

func (*Engine) LoadByIDsLazy added in v1.1.13 

func (e *Engine) LoadByIDsLazy(ids []uint64, entities interface{}, references ...string) (missing bool)

func (*Engine) LoadLazy added in v1.1.13 

func (e *Engine) LoadLazy(entity Entity, references ...string)

func (*Engine) Log 

func (e *Engine) Log() Log

func (*Engine) NewFlusher 

func (e *Engine) NewFlusher() Flusher

func (*Engine) NewRedisFlusher 

func (e *Engine) NewRedisFlusher() RedisFlusher

func (*Engine) NewRedisSearchIndexPusher added in v1.0.4 

func (e *Engine) NewRedisSearchIndexPusher(pool string) RedisSearchIndexPusher

func (*Engine) RedisSearch added in v1.0.1 

func (e *Engine) RedisSearch(entities interface{}, query *RedisSearchQuery, pager *Pager, references ...string) (totalRows uint64)

func (*Engine) RedisSearchCount added in v1.2.0 

func (e *Engine) RedisSearchCount(entity Entity, query *RedisSearchQuery) (totalRows uint64)

func (*Engine) RedisSearchIds 

func (e *Engine) RedisSearchIds(entity Entity, query *RedisSearchQuery, pager *Pager) (ids []uint64, totalRows uint64)

func (*Engine) RedisSearchLazy added in v1.1.13 

func (e *Engine) RedisSearchLazy(entities interface{}, query *RedisSearchQuery, pager *Pager, references ...string) (totalRows uint64)

func (*Engine) RedisSearchOne added in v1.0.1 

func (e *Engine) RedisSearchOne(entity Entity, query *RedisSearchQuery, references ...string) (found bool)

func (*Engine) RedisSearchOneLazy added in v1.1.13 

func (e *Engine) RedisSearchOneLazy(entity Entity, query *RedisSearchQuery, references ...string) (found bool)

func (*Engine) Search 

func (e *Engine) Search(where *Where, pager *Pager, entities interface{}, references ...string)

func (*Engine) SearchIDs 

func (e *Engine) SearchIDs(where *Where, pager *Pager, entity Entity) []uint64

func (*Engine) SearchIDsWithCount 

func (e *Engine) SearchIDsWithCount(where *Where, pager *Pager, entity Entity) (results []uint64, totalRows int)

func (*Engine) SearchLazy added in v1.1.13 

func (e *Engine) SearchLazy(where *Where, pager *Pager, entities interface{}, references ...string)

func (*Engine) SearchOne 

func (e *Engine) SearchOne(where *Where, entity Entity, references ...string) (found bool)

func (*Engine) SearchOneLazy added in v1.1.13 

func (e *Engine) SearchOneLazy(where *Where, entity Entity, references ...string) (found bool)

func (*Engine) SearchWithCount 

func (e *Engine) SearchWithCount(where *Where, pager *Pager, entities interface{}, references ...string) (totalRows int)

func (*Engine) SearchWithCountLAzy added in v1.1.13 

func (e *Engine) SearchWithCountLAzy(where *Where, pager *Pager, entities interface{}, references ...string) (totalRows int)

func (*Engine) SetLogMetaData 

func (e *Engine) SetLogMetaData(key string, value interface{})

type Entity 

type Entity interface {
	GetID() uint64

	IsLoaded() bool
	IsLazy() bool
	Fill(engine *Engine)
	IsDirty() bool
	GetDirtyBind() (bind Bind, has bool)
	SetOnDuplicateKeyUpdate(bind Bind)
	SetEntityLogMeta(key string, value interface{})
	SetField(field string, value interface{}) error
	GetFieldLazy(field string) interface{}
	// contains filtered or unexported methods
}

type Enum 

type Enum interface {
	GetFields() []string
	GetDefault() string
	Has(value string) bool
}

type Event 

type Event interface {
	Ack()
	Skip()
	ID() string
	Stream() string
	RawData() map[string]interface{}
	Unserialize(val interface{}) error
	IsSerialized() bool
}

type EventAsMap 

type EventAsMap map[string]interface{}

type EventBroker 

type EventBroker interface {
	PublishMap(stream string, event EventAsMap) (id string)
	Publish(stream string, event interface{}) (id string)
	Consumer(name, group string) EventsConsumer
	NewFlusher() EventFlusher
}

type EventConsumerHandler 

type EventConsumerHandler func([]Event)

type EventFlusher 

type EventFlusher interface {
	PublishMap(stream string, event EventAsMap)
	Publish(stream string, event interface{})
	Flush()
}

type EventsConsumer 

type EventsConsumer interface {
	Consume(ctx context.Context, count int, blocking bool, handler EventConsumerHandler)
	DisableLoop()
	SetLimit(limit int)
	SetHeartBeat(duration time.Duration, beat func())
	SetErrorHandler(handler ConsumerErrorHandler)
}

type ExecResult 

type ExecResult interface {
	LastInsertId() uint64
	RowsAffected() uint64
}

type Flusher 

type Flusher interface {
	Track(entity ...Entity) Flusher
	Flush()
	FlushWithCheck() error
	FlushInTransactionWithCheck() error
	FlushWithFullCheck() error
	FlushLazy()
	FlushInTransaction()
	Clear()
	MarkDirty(entity Entity, queueCode string, ids ...uint64)
	Delete(entity ...Entity) Flusher
	ForceDelete(entity ...Entity) Flusher
}

type ForeignKeyError 

type ForeignKeyError struct {
	Message    string
	Constraint string
}

func (*ForeignKeyError) Error 

func (err *ForeignKeyError) Error() string

type GetSetProvider 

type GetSetProvider func() interface{}

type HealthCheckError added in v1.1.16 

type HealthCheckError struct {
	HealthCheckStep
	Message string
}

type HealthCheckStep added in v1.1.16 

type HealthCheckStep struct {
	Name        string
	Description string
}

type LocalCache 

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

func (*LocalCache) Clear 

func (c *LocalCache) Clear()

func (*LocalCache) Get 

func (c *LocalCache) Get(key string) (value interface{}, ok bool)

func (*LocalCache) GetObjectsCount 

func (c *LocalCache) GetObjectsCount() int

func (*LocalCache) GetPoolConfig added in v1.3.0 

func (c *LocalCache) GetPoolConfig() LocalCachePoolConfig

func (*LocalCache) GetSet 

func (c *LocalCache) GetSet(key string, ttlSeconds int, provider GetSetProvider) interface{}

func (*LocalCache) HMget 

func (c *LocalCache) HMget(key string, fields ...string) map[string]interface{}

func (*LocalCache) HMset 

func (c *LocalCache) HMset(key string, fields map[string]interface{})

func (*LocalCache) MGet 

func (c *LocalCache) MGet(keys ...string) map[string]interface{}

func (*LocalCache) MGetFast added in v1.2.0 

func (c *LocalCache) MGetFast(keys ...string) []interface{}

func (*LocalCache) MSet 

func (c *LocalCache) MSet(pairs ...interface{})

func (*LocalCache) Remove 

func (c *LocalCache) Remove(keys ...string)

func (*LocalCache) Set 

func (c *LocalCache) Set(key string, value interface{})

type LocalCachePoolConfig added in v1.3.0 

type LocalCachePoolConfig interface {
	GetCode() string
	GetLimit() int
}

type Lock 

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

func (*Lock) Refresh 

func (l *Lock) Refresh(ctx context.Context, ttl time.Duration) bool

func (*Lock) Release 

func (l *Lock) Release()

func (*Lock) TTL 

func (l *Lock) TTL() time.Duration

type Locker 

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

func (*Locker) Obtain 

func (l *Locker) Obtain(ctx context.Context, key string, ttl time.Duration, waitTimeout time.Duration) (lock *Lock, obtained bool)

type Log 

type Log interface {
	AddFields(fields apexLog.Fielder)
	Debug(message string, fields apexLog.Fielder)
	Info(message string, fields apexLog.Fielder)
	Warn(message string, fields apexLog.Fielder)
	Error(err interface{}, fields apexLog.Fielder)
	ErrorMessage(message string, fields apexLog.Fielder)
	AddFieldsFromHTTPRequest(r *http.Request, ip string)
	SetHTTPResponseCode(code int)
}

type LogQueueValue 

type LogQueueValue struct {
	PoolName  string
	TableName string
	ID        uint64
	LogID     uint64
	Meta      map[string]interface{}
	Before    map[string]interface{}
	Changes   map[string]interface{}
	Updated   time.Time
}

type MySQLPoolConfig added in v1.3.0 

type MySQLPoolConfig interface {
	GetCode() string
	GetDatabase() string
	GetDataSourceURI() string
	GetVersion() int
	// contains filtered or unexported methods
}

type ORM 

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

func (*ORM) Fill added in v1.2.0 

func (orm *ORM) Fill(engine *Engine)

func (*ORM) GetDirtyBind 

func (orm *ORM) GetDirtyBind() (bind Bind, has bool)

func (*ORM) GetFieldLazy added in v1.1.9 

func (orm *ORM) GetFieldLazy(field string) interface{}

func (*ORM) GetID 

func (orm *ORM) GetID() uint64

func (*ORM) IsDirty 

func (orm *ORM) IsDirty() bool

func (*ORM) IsLazy added in v1.2.0 

func (orm *ORM) IsLazy() bool

func (*ORM) IsLoaded added in v1.1.9 

func (orm *ORM) IsLoaded() bool

func (*ORM) SetEntityLogMeta 

func (orm *ORM) SetEntityLogMeta(key string, value interface{})

func (*ORM) SetField 

func (orm *ORM) SetField(field string, value interface{}) error

func (*ORM) SetOnDuplicateKeyUpdate 

func (orm *ORM) SetOnDuplicateKeyUpdate(bind Bind)

type Pager 

type Pager struct {
	CurrentPage int
	PageSize    int
}

func NewPager 

func NewPager(currentPage, pageSize int) *Pager

func (*Pager) GetCurrentPage 

func (pager *Pager) GetCurrentPage() int

func (*Pager) GetPageSize 

func (pager *Pager) GetPageSize() int

func (*Pager) IncrementPage 

func (pager *Pager) IncrementPage()

type PipeLineBool 

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

func (*PipeLineBool) Result 

func (c *PipeLineBool) Result() (bool, error)

type PipeLineGet 

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

func (*PipeLineGet) Result 

func (c *PipeLineGet) Result() (value string, has bool, err error)

type PipeLineInt 

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

func (*PipeLineInt) Result 

func (c *PipeLineInt) Result() (int64, error)

type PipeLineStatus 

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

func (*PipeLineStatus) Result 

func (c *PipeLineStatus) Result() error

type PipeLineString 

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

func (*PipeLineString) Result 

func (c *PipeLineString) Result() (string, error)

type PreparedStatement 

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

func (*PreparedStatement) Exec 

func (p *PreparedStatement) Exec(args ...interface{}) sql.Result

type QueryLoggerSource 

type QueryLoggerSource int

type RedisCache 

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

func (*RedisCache) Del 

func (r *RedisCache) Del(keys ...string)

func (*RedisCache) Eval 

func (r *RedisCache) Eval(script string, keys []string, args ...interface{}) interface{}

func (*RedisCache) EvalSha 

func (r *RedisCache) EvalSha(sha1 string, keys []string, args ...interface{}) interface{}

func (*RedisCache) Exists 

func (r *RedisCache) Exists(keys ...string) int64

func (*RedisCache) Expire 

func (r *RedisCache) Expire(key string, expiration time.Duration) bool

func (*RedisCache) FlushAll added in v1.2.7 

func (r *RedisCache) FlushAll()

func (*RedisCache) FlushDB 

func (r *RedisCache) FlushDB()

func (*RedisCache) Get 

func (r *RedisCache) Get(key string) (value string, has bool)

func (*RedisCache) GetLocker added in v1.2.14 

func (r *RedisCache) GetLocker() *Locker

func (*RedisCache) GetPoolConfig added in v1.3.0 

func (r *RedisCache) GetPoolConfig() RedisPoolConfig

func (*RedisCache) GetSet 

func (r *RedisCache) GetSet(key string, ttlSeconds int, provider GetSetProvider) interface{}

func (*RedisCache) HDel 

func (r *RedisCache) HDel(key string, fields ...string)

func (*RedisCache) HGet 

func (r *RedisCache) HGet(key, field string) (value string, has bool)

func (*RedisCache) HGetAll 

func (r *RedisCache) HGetAll(key string) map[string]string

func (*RedisCache) HIncrBy 

func (r *RedisCache) HIncrBy(key, field string, incr int64) int64

func (*RedisCache) HLen 

func (r *RedisCache) HLen(key string) int64

func (*RedisCache) HMget 

func (r *RedisCache) HMget(key string, fields ...string) map[string]interface{}

func (*RedisCache) HSet 

func (r *RedisCache) HSet(key string, values ...interface{})

func (*RedisCache) Incr 

func (r *RedisCache) Incr(key string) int64

func (*RedisCache) IncrBy 

func (r *RedisCache) IncrBy(key string, incr int64) int64

func (*RedisCache) Info 

func (r *RedisCache) Info(section ...string) string

func (*RedisCache) LLen 

func (r *RedisCache) LLen(key string) int64

func (*RedisCache) LPush 

func (r *RedisCache) LPush(key string, values ...interface{}) int64

func (*RedisCache) LRange 

func (r *RedisCache) LRange(key string, start, stop int64) []string

func (*RedisCache) LRem 

func (r *RedisCache) LRem(key string, count int64, value interface{})

func (*RedisCache) LSet 

func (r *RedisCache) LSet(key string, index int64, value interface{})

func (*RedisCache) Ltrim 

func (r *RedisCache) Ltrim(key string, start, stop int64)

func (*RedisCache) MGet 

func (r *RedisCache) MGet(keys ...string) map[string]interface{}

func (*RedisCache) MGetFast added in v1.2.0 

func (r *RedisCache) MGetFast(keys ...string) []interface{}

func (*RedisCache) MSet 

func (r *RedisCache) MSet(pairs ...interface{})

func (*RedisCache) PipeLine 

func (r *RedisCache) PipeLine() *RedisPipeLine

func (*RedisCache) RPop 

func (r *RedisCache) RPop(key string) (value string, found bool)

func (*RedisCache) RPush 

func (r *RedisCache) RPush(key string, values ...interface{}) int64

func (*RedisCache) RateLimit 

func (r *RedisCache) RateLimit(key string, limit redis_rate.Limit) bool

func (*RedisCache) SAdd 

func (r *RedisCache) SAdd(key string, members ...interface{}) int64

func (*RedisCache) SCard 

func (r *RedisCache) SCard(key string) int64

func (*RedisCache) SPop 

func (r *RedisCache) SPop(key string) (string, bool)

func (*RedisCache) SPopN 

func (r *RedisCache) SPopN(key string, max int64) []string

func (*RedisCache) ScriptLoad 

func (r *RedisCache) ScriptLoad(script string) string

func (*RedisCache) Set 

func (r *RedisCache) Set(key string, value interface{}, ttlSeconds int)

func (*RedisCache) Type 

func (r *RedisCache) Type(key string) string

func (*RedisCache) XAck 

func (r *RedisCache) XAck(stream, group string, ids ...string) int64

func (*RedisCache) XClaim 

func (r *RedisCache) XClaim(a *redis.XClaimArgs) []redis.XMessage

func (*RedisCache) XClaimJustID 

func (r *RedisCache) XClaimJustID(a *redis.XClaimArgs) []string

func (*RedisCache) XDel 

func (r *RedisCache) XDel(stream string, ids ...string) int64

func (*RedisCache) XGroupCreate 

func (r *RedisCache) XGroupCreate(stream, group, start string) (key string, exists bool)

func (*RedisCache) XGroupCreateMkStream 

func (r *RedisCache) XGroupCreateMkStream(stream, group, start string) (key string, exists bool)

func (*RedisCache) XGroupDelConsumer 

func (r *RedisCache) XGroupDelConsumer(stream, group, consumer string) int64

func (*RedisCache) XGroupDestroy 

func (r *RedisCache) XGroupDestroy(stream, group string) int64

func (*RedisCache) XInfoGroups 

func (r *RedisCache) XInfoGroups(stream string) []redis.XInfoGroup

func (*RedisCache) XInfoStream 

func (r *RedisCache) XInfoStream(stream string) *redis.XInfoStream

func (*RedisCache) XLen 

func (r *RedisCache) XLen(stream string) int64

func (*RedisCache) XPending 

func (r *RedisCache) XPending(stream, group string) *redis.XPending

func (*RedisCache) XPendingExt 

func (r *RedisCache) XPendingExt(a *redis.XPendingExtArgs) []redis.XPendingExt

func (*RedisCache) XRange 

func (r *RedisCache) XRange(stream, start, stop string, count int64) []redis.XMessage

func (*RedisCache) XRead 

func (r *RedisCache) XRead(a *redis.XReadArgs) []redis.XStream

func (*RedisCache) XReadGroup 

func (r *RedisCache) XReadGroup(a *redis.XReadGroupArgs) (streams []redis.XStream)

func (*RedisCache) XRevRange 

func (r *RedisCache) XRevRange(stream, start, stop string, count int64) []redis.XMessage

func (*RedisCache) XTrim 

func (r *RedisCache) XTrim(stream string, maxLen int64, approx bool) (deleted int64)

func (*RedisCache) ZAdd 

func (r *RedisCache) ZAdd(key string, members ...*redis.Z) int64

func (*RedisCache) ZCard 

func (r *RedisCache) ZCard(key string) int64

func (*RedisCache) ZCount 

func (r *RedisCache) ZCount(key string, min, max string) int64

func (*RedisCache) ZRangeWithScores 

func (r *RedisCache) ZRangeWithScores(key string, start, stop int64) []redis.Z

func (*RedisCache) ZRevRange 

func (r *RedisCache) ZRevRange(key string, start, stop int64) []string

func (*RedisCache) ZRevRangeWithScores 

func (r *RedisCache) ZRevRangeWithScores(key string, start, stop int64) []redis.Z

func (*RedisCache) ZScore 

func (r *RedisCache) ZScore(key, member string) float64

type RedisFlusher 

type RedisFlusher interface {
	Del(redisPool string, keys ...string)
	PublishMap(stream string, event EventAsMap)
	Publish(stream string, event interface{})
	Flush()
	HSet(redisPool, key string, values ...interface{})
}

type RedisPipeLine 

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

func (*RedisPipeLine) Del 

func (rp *RedisPipeLine) Del(key ...string) *PipeLineInt

func (*RedisPipeLine) Exec 

func (rp *RedisPipeLine) Exec()

func (*RedisPipeLine) Executed 

func (rp *RedisPipeLine) Executed() bool

func (*RedisPipeLine) Expire 

func (rp *RedisPipeLine) Expire(key string, expiration time.Duration) *PipeLineBool

func (*RedisPipeLine) Get 

func (rp *RedisPipeLine) Get(key string) *PipeLineGet

func (*RedisPipeLine) HDel 

func (rp *RedisPipeLine) HDel(key string, values ...string) *PipeLineInt

func (*RedisPipeLine) HIncrBy 

func (rp *RedisPipeLine) HIncrBy(key, field string, incr int64) *PipeLineInt

func (*RedisPipeLine) HSet 

func (rp *RedisPipeLine) HSet(key string, values ...interface{}) *PipeLineInt

func (*RedisPipeLine) Set 

func (rp *RedisPipeLine) Set(key string, value interface{}, expiration time.Duration) *PipeLineStatus

func (*RedisPipeLine) XAdd 

func (rp *RedisPipeLine) XAdd(stream string, values interface{}) *PipeLineString

type RedisPoolConfig added in v1.3.0 

type RedisPoolConfig interface {
	GetCode() string
	GetDB() int
	GetAddress() string
	// contains filtered or unexported methods
}

type RedisSearch 

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

func (*RedisSearch) ForceReindex 

func (r *RedisSearch) ForceReindex(index string)

func (*RedisSearch) Info 

func (r *RedisSearch) Info(indexName string) *RedisSearchIndexInfo

func (*RedisSearch) ListIndices 

func (r *RedisSearch) ListIndices() []string

func (*RedisSearch) Search 

func (r *RedisSearch) Search(index string, query *RedisSearchQuery, pager *Pager) (total uint64, rows []*RedisSearchResult)

func (*RedisSearch) SearchKeys 

func (r *RedisSearch) SearchKeys(index string, query *RedisSearchQuery, pager *Pager) (total uint64, keys []string)

func (*RedisSearch) SearchRaw 

func (r *RedisSearch) SearchRaw(index string, query *RedisSearchQuery, pager *Pager) (total uint64, rows []interface{})

type RedisSearchIndex 

type RedisSearchIndex struct {
	Name            string
	RedisPool       string
	Prefixes        []string
	Filter          string
	DefaultLanguage string
	LanguageField   string
	DefaultScore    float64
	ScoreField      string
	PayloadField    string
	MaxTextFields   bool
	Temporary       int
	NoOffsets       bool
	NoNHL           bool
	NoFields        bool
	NoFreqs         bool
	SkipInitialScan bool
	StopWords       []string
	Fields          []RedisSearchIndexField
	Indexer         RedisSearchIndexerFunc `json:"-"`
}

func (*RedisSearchIndex) AddGeoField 

func (rs *RedisSearchIndex) AddGeoField(name string, sortable, noindex bool)

func (*RedisSearchIndex) AddNumericField 

func (rs *RedisSearchIndex) AddNumericField(name string, sortable, noindex bool)

func (*RedisSearchIndex) AddTagField 

func (rs *RedisSearchIndex) AddTagField(name string, sortable, noindex bool, separator string)

func (*RedisSearchIndex) AddTextField 

func (rs *RedisSearchIndex) AddTextField(name string, weight float64, sortable, noindex, nostem bool)

type RedisSearchIndexAlter 

type RedisSearchIndexAlter struct {
	Query     string
	Executing bool
	Documents uint64
	Changes   []string
	Pool      string
	Execute   func()
	// contains filtered or unexported fields
}

type RedisSearchIndexField 

type RedisSearchIndexField struct {
	Type         string
	Name         string
	Sortable     bool
	NoIndex      bool
	NoStem       bool
	Weight       float64
	TagSeparator string
}

type RedisSearchIndexInfo 

type RedisSearchIndexInfo struct {
	Name                     string
	Options                  RedisSearchIndexInfoOptions
	Definition               RedisSearchIndexInfoDefinition
	Fields                   []RedisSearchIndexInfoField
	NumDocs                  uint64
	MaxDocID                 uint64
	NumTerms                 uint64
	NumRecords               uint64
	InvertedSzMB             float64
	TotalInvertedIndexBlocks float64
	OffsetVectorsSzMB        float64
	DocTableSizeMB           float64
	SortableValuesSizeMB     float64
	KeyTableSizeMB           float64
	RecordsPerDocAvg         int
	BytesPerRecordAvg        int
	OffsetsPerTermAvg        float64
	OffsetBitsPerRecordAvg   float64
	HashIndexingFailures     uint64
	Indexing                 bool
	PercentIndexed           float64
	StopWords                []string
}

type RedisSearchIndexInfoDefinition 

type RedisSearchIndexInfoDefinition struct {
	KeyType       string
	Prefixes      []string
	Filter        string
	LanguageField string
	ScoreField    string
	PayloadField  string
	DefaultScore  float64
}

type RedisSearchIndexInfoField 

type RedisSearchIndexInfoField struct {
	Name         string
	Type         string
	Weight       float64
	Sortable     bool
	NoStem       bool
	NoIndex      bool
	TagSeparator string
}

type RedisSearchIndexInfoOptions 

type RedisSearchIndexInfoOptions struct {
	NoFreqs       bool
	NoOffsets     bool
	NoFields      bool
	MaxTextFields bool
}

type RedisSearchIndexPusher 

type RedisSearchIndexPusher interface {
	NewDocument(key string)
	DeleteDocuments(key ...string)
	SetString(key string, value string)
	SetTag(key string, tag ...string)
	SetUint(key string, value uint64)
	SetInt(key string, value int64)
	SetFloat(key string, value float64)
	SetGeo(key string, lon float64, lat float64)
	PushDocument()
	Flush()
	// contains filtered or unexported methods
}

type RedisSearchIndexerFunc 

type RedisSearchIndexerFunc func(engine *Engine, lastID uint64, pusher RedisSearchIndexPusher) (newID uint64, hasMore bool)

type RedisSearchQuery 

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

func NewRedisSearchQuery added in v1.3.1 

func NewRedisSearchQuery() *RedisSearchQuery

func (*RedisSearchQuery) AppendQueryRaw added in v1.3.19 

func (q *RedisSearchQuery) AppendQueryRaw(query string) *RedisSearchQuery

func (*RedisSearchQuery) ExplainScore 

func (q *RedisSearchQuery) ExplainScore() *RedisSearchQuery

func (*RedisSearchQuery) FilterBool 

func (q *RedisSearchQuery) FilterBool(field string, value bool) *RedisSearchQuery

func (*RedisSearchQuery) FilterDate 

func (q *RedisSearchQuery) FilterDate(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateGreater 

func (q *RedisSearchQuery) FilterDateGreater(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateGreaterEqual 

func (q *RedisSearchQuery) FilterDateGreaterEqual(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateLess 

func (q *RedisSearchQuery) FilterDateLess(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateLessEqual 

func (q *RedisSearchQuery) FilterDateLessEqual(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateMinMax 

func (q *RedisSearchQuery) FilterDateMinMax(field string, min, max time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateNull 

func (q *RedisSearchQuery) FilterDateNull(field string) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateTime 

func (q *RedisSearchQuery) FilterDateTime(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateTimeGreater 

func (q *RedisSearchQuery) FilterDateTimeGreater(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateTimeGreaterEqual 

func (q *RedisSearchQuery) FilterDateTimeGreaterEqual(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateTimeLess 

func (q *RedisSearchQuery) FilterDateTimeLess(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateTimeLessEqual 

func (q *RedisSearchQuery) FilterDateTimeLessEqual(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateTimeMinMax 

func (q *RedisSearchQuery) FilterDateTimeMinMax(field string, min, max time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterDateTimeNull 

func (q *RedisSearchQuery) FilterDateTimeNull(field string) *RedisSearchQuery

func (*RedisSearchQuery) FilterFloat 

func (q *RedisSearchQuery) FilterFloat(field string, value ...float64) *RedisSearchQuery

func (*RedisSearchQuery) FilterFloatGreater 

func (q *RedisSearchQuery) FilterFloatGreater(field string, value float64) *RedisSearchQuery

func (*RedisSearchQuery) FilterFloatGreaterEqual 

func (q *RedisSearchQuery) FilterFloatGreaterEqual(field string, value float64) *RedisSearchQuery

func (*RedisSearchQuery) FilterFloatLess 

func (q *RedisSearchQuery) FilterFloatLess(field string, value float64) *RedisSearchQuery

func (*RedisSearchQuery) FilterFloatLessEqual 

func (q *RedisSearchQuery) FilterFloatLessEqual(field string, value float64) *RedisSearchQuery

func (*RedisSearchQuery) FilterFloatMinMax 

func (q *RedisSearchQuery) FilterFloatMinMax(field string, min, max float64) *RedisSearchQuery

func (*RedisSearchQuery) FilterFloatNull 

func (q *RedisSearchQuery) FilterFloatNull(field string) *RedisSearchQuery

func (*RedisSearchQuery) FilterGeo 

func (q *RedisSearchQuery) FilterGeo(field string, lon, lat, radius float64, unit string) *RedisSearchQuery

func (*RedisSearchQuery) FilterInt 

func (q *RedisSearchQuery) FilterInt(field string, value ...int64) *RedisSearchQuery

func (*RedisSearchQuery) FilterIntGreater 

func (q *RedisSearchQuery) FilterIntGreater(field string, value int64) *RedisSearchQuery

func (*RedisSearchQuery) FilterIntGreaterEqual 

func (q *RedisSearchQuery) FilterIntGreaterEqual(field string, value int64) *RedisSearchQuery

func (*RedisSearchQuery) FilterIntLess 

func (q *RedisSearchQuery) FilterIntLess(field string, value int64) *RedisSearchQuery

func (*RedisSearchQuery) FilterIntLessEqual 

func (q *RedisSearchQuery) FilterIntLessEqual(field string, value int64) *RedisSearchQuery

func (*RedisSearchQuery) FilterIntMinMax 

func (q *RedisSearchQuery) FilterIntMinMax(field string, min, max int64) *RedisSearchQuery

func (*RedisSearchQuery) FilterIntNull 

func (q *RedisSearchQuery) FilterIntNull(field string) *RedisSearchQuery

func (*RedisSearchQuery) FilterNotDate added in v1.3.19 

func (q *RedisSearchQuery) FilterNotDate(field string, date time.Time) *RedisSearchQuery

func (*RedisSearchQuery) FilterNotDateNull added in v1.3.19 

func (q *RedisSearchQuery) FilterNotDateNull(field string) *RedisSearchQuery

func (*RedisSearchQuery) FilterNotInt added in v1.3.19 

func (q *RedisSearchQuery) FilterNotInt(field string, value ...int64) *RedisSearchQuery

func (*RedisSearchQuery) FilterNotIntNull added in v1.3.19 

func (q *RedisSearchQuery) FilterNotIntNull(field string) *RedisSearchQuery

func (*RedisSearchQuery) FilterNotString added in v1.3.19 

func (q *RedisSearchQuery) FilterNotString(field string, value ...string) *RedisSearchQuery

func (*RedisSearchQuery) FilterNotTag added in v1.3.19 

func (q *RedisSearchQuery) FilterNotTag(field string, tag ...string) *RedisSearchQuery

func (*RedisSearchQuery) FilterString added in v1.1.11 

func (q *RedisSearchQuery) FilterString(field string, value ...string) *RedisSearchQuery

func (*RedisSearchQuery) FilterTag 

func (q *RedisSearchQuery) FilterTag(field string, tag ...string) *RedisSearchQuery

func (*RedisSearchQuery) FilterUint added in v1.3.13 

func (q *RedisSearchQuery) FilterUint(field string, value ...uint64) *RedisSearchQuery

func (*RedisSearchQuery) FilterUintGreater added in v1.3.13 

func (q *RedisSearchQuery) FilterUintGreater(field string, value uint64) *RedisSearchQuery

func (*RedisSearchQuery) FilterUintGreaterEqual added in v1.3.13 

func (q *RedisSearchQuery) FilterUintGreaterEqual(field string, value uint64) *RedisSearchQuery

func (*RedisSearchQuery) FilterUintLess added in v1.3.13 

func (q *RedisSearchQuery) FilterUintLess(field string, value uint64) *RedisSearchQuery

func (*RedisSearchQuery) FilterUintLessEqual added in v1.3.13 

func (q *RedisSearchQuery) FilterUintLessEqual(field string, value uint64) *RedisSearchQuery

func (*RedisSearchQuery) FilterUintMinMax added in v1.3.13 

func (q *RedisSearchQuery) FilterUintMinMax(field string, min, max uint64) *RedisSearchQuery

func (*RedisSearchQuery) FilterUintNull added in v1.3.13 

func (q *RedisSearchQuery) FilterUintNull(field string) *RedisSearchQuery

func (*RedisSearchQuery) Highlight 

func (q *RedisSearchQuery) Highlight(field ...string) *RedisSearchQuery

func (*RedisSearchQuery) HighlightTags 

func (q *RedisSearchQuery) HighlightTags(openTag, closeTag string) *RedisSearchQuery

func (*RedisSearchQuery) InFields 

func (q *RedisSearchQuery) InFields(field ...string) *RedisSearchQuery

func (*RedisSearchQuery) InKeys 

func (q *RedisSearchQuery) InKeys(key ...string) *RedisSearchQuery

func (*RedisSearchQuery) InOrder 

func (q *RedisSearchQuery) InOrder() *RedisSearchQuery

func (*RedisSearchQuery) Lang 

func (q *RedisSearchQuery) Lang(lang string) *RedisSearchQuery

func (*RedisSearchQuery) NoStopWords 

func (q *RedisSearchQuery) NoStopWords() *RedisSearchQuery

func (*RedisSearchQuery) Query 

func (q *RedisSearchQuery) Query(query string) *RedisSearchQuery

func (*RedisSearchQuery) QueryField added in v1.2.1 

func (q *RedisSearchQuery) QueryField(field string, value ...string) *RedisSearchQuery

func (*RedisSearchQuery) QueryRaw added in v1.1.11 

func (q *RedisSearchQuery) QueryRaw(query string) *RedisSearchQuery

func (*RedisSearchQuery) Return 

func (q *RedisSearchQuery) Return(field ...string) *RedisSearchQuery

func (*RedisSearchQuery) Slop 

func (q *RedisSearchQuery) Slop(slop int) *RedisSearchQuery

func (*RedisSearchQuery) Sort 

func (q *RedisSearchQuery) Sort(field string, desc bool) *RedisSearchQuery

func (*RedisSearchQuery) Summarize 

func (q *RedisSearchQuery) Summarize(field ...string) *RedisSearchQuery

func (*RedisSearchQuery) SummarizeOptions 

func (q *RedisSearchQuery) SummarizeOptions(separator string, frags, len int) *RedisSearchQuery

func (*RedisSearchQuery) Verbatim 

func (q *RedisSearchQuery) Verbatim() *RedisSearchQuery

func (*RedisSearchQuery) WithPayLoads 

func (q *RedisSearchQuery) WithPayLoads() *RedisSearchQuery

func (*RedisSearchQuery) WithScores 

func (q *RedisSearchQuery) WithScores() *RedisSearchQuery

type RedisSearchResult 

type RedisSearchResult struct {
	Key          string
	Fields       []interface{}
	Score        float64
	ExplainScore []interface{}
	PayLoad      string
}

func (*RedisSearchResult) Value 

func (r *RedisSearchResult) Value(field string) interface{}

type Registry 

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

func NewRegistry added in v1.2.7 

func NewRegistry() *Registry

func (*Registry) InitByYaml added in v1.2.7 

func (r *Registry) InitByYaml(yaml map[string]interface{})

func (*Registry) RegisterClickHouse 

func (r *Registry) RegisterClickHouse(url string, code ...string)

func (*Registry) RegisterElastic 

func (r *Registry) RegisterElastic(url string, code ...string)

func (*Registry) RegisterElasticIndex 

func (r *Registry) RegisterElasticIndex(index ElasticIndexDefinition, serverPool ...string)

func (*Registry) RegisterElasticWithTraceLog 

func (r *Registry) RegisterElasticWithTraceLog(url string, code ...string)

func (*Registry) RegisterEntity 

func (r *Registry) RegisterEntity(entity ...Entity)

func (*Registry) RegisterEnum added in v1.3.0 

func (r *Registry) RegisterEnum(code string, values []string, defaultValue ...string)

func (*Registry) RegisterEnumStruct 

func (r *Registry) RegisterEnumStruct(code string, val interface{}, defaultValue ...string)

func (*Registry) RegisterLocalCache 

func (r *Registry) RegisterLocalCache(size int, code ...string)

func (*Registry) RegisterMySQLPool 

func (r *Registry) RegisterMySQLPool(dataSourceName string, code ...string)

func (*Registry) RegisterRedis 

func (r *Registry) RegisterRedis(address string, db int, code ...string)

func (*Registry) RegisterRedisSearchIndex 

func (r *Registry) RegisterRedisSearchIndex(index ...*RedisSearchIndex)

func (*Registry) RegisterRedisSentinel 

func (r *Registry) RegisterRedisSentinel(masterName string, db int, sentinels []string, code ...string)

func (*Registry) RegisterRedisStream 

func (r *Registry) RegisterRedisStream(name string, redisPool string, groups []string)

func (*Registry) SetDefaultEncoding 

func (r *Registry) SetDefaultEncoding(encoding string)

func (*Registry) Validate 

func (r *Registry) Validate() (ValidatedRegistry, error)

type Rows 

type Rows interface {
	Next() bool
	Scan(dest ...interface{})
	Columns() []string
}

type SQLRow 

type SQLRow interface {
	Scan(dest ...interface{}) error
}

type SQLRows 

type SQLRows interface {
	Next() bool
	Err() error
	Close() error
	Scan(dest ...interface{}) error
	Columns() ([]string, error)
}

type SearchOptions 

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

func (*SearchOptions) AddAggregation 

func (p *SearchOptions) AddAggregation(name string, aggregation elastic.Aggregation) *SearchOptions

func (*SearchOptions) AddSort 

func (p *SearchOptions) AddSort(field string, ascending bool) *SearchOptions

type TableSchema 

type TableSchema interface {
	GetTableName() string
	GetType() reflect.Type
	DropTable(engine *Engine)
	TruncateTable(engine *Engine)
	UpdateSchema(engine *Engine)
	UpdateSchemaAndTruncateTable(engine *Engine)
	GetMysql(engine *Engine) *DB
	GetLocalCache(engine *Engine) (cache *LocalCache, has bool)
	GetRedisCache(engine *Engine) (cache *RedisCache, has bool)
	GetReferences() []string
	GetColumns() []string
	GetUsage(registry ValidatedRegistry) map[reflect.Type][]string
	GetSchemaChanges(engine *Engine) (has bool, alters []Alter)
}

type ValidatedRegistry 

type ValidatedRegistry interface {
	CreateEngine() *Engine
	GetTableSchema(entityName string) TableSchema
	GetTableSchemaForEntity(entity Entity) TableSchema
	GetSourceRegistry() *Registry
	GetEnum(code string) Enum
	GetRedisStreams() map[string]map[string][]string
	GetMySQLPools() map[string]MySQLPoolConfig
	GetLocalCachePools() map[string]LocalCachePoolConfig
	GetRedisPools() map[string]RedisPoolConfig
	GetRedisSearchIndices() map[string][]*RedisSearchIndex
	GetEntities() map[string]reflect.Type
}

type Where 

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

func NewWhere 

func NewWhere(query string, parameters ...interface{}) *Where

func (*Where) Append 

func (where *Where) Append(query string, parameters ...interface{})

func (*Where) GetParameters 

func (where *Where) GetParameters() []interface{}

func (*Where) String 

func (where *Where) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.