orm

package module

Go to main page

Versions in this module

v1

v1.79.2

Mar 5, 2021

Changes in this version

type RedisSearchQuery

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

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

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

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

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

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

v1.79.0

Mar 4, 2021

Changes in this version

type Engine

+ func (e *Engine) RedisSearchIds(entity Entity, pager *Pager, references ...string) (totalRows int, ids []uint64)

type RedisFlusher

+ HSet func(redisPool, key string, values ...interface{})

v1.78.5

Mar 3, 2021

Changes in this version

type AsyncConsumer

+ func (r *AsyncConsumer) RegisterErrorHandler(handler func(err interface{}))

v1.78.3

Mar 3, 2021

Changes in this version

type RedisSearch

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

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

type ValidatedRegistry

+ GetRedisSearchIndices func() map[string][]*RedisSearchIndex

v1.78.2

Mar 2, 2021

v1.78.1

Mar 2, 2021

Changes in this version

type RedisSearchIndexInfoField

+ NoStem bool

v1.78.0

Mar 2, 2021

v1.77.2

Feb 27, 2021

Changes in this version

type RedisSearchIndexAlter

+ Changes []string

type RedisSearchIndexInfoDefinition

+ Filter string

+ type RedisSearchIndexInfoOptions struct

+ MaxTextFields bool

+ NoFields bool

+ NoFreqs bool

+ NoOffsets bool

v1.77.1

Feb 25, 2021

Changes in this version

type RedisPipeLine

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

type RedisSearch

+ func (r *RedisSearch) ForceReindex(index string)

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

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

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

type RedisSearchIndex

+ Indexer RedisSearchIndexerFunc

type RedisSearchIndexAlter

+ Documents uint64

+ Executing bool

type RedisSearchIndexInfoField

+ NoIndex bool

+ NoSteam bool

+ Sortable bool

+ TagSeparator string

+ type RedisSearchIndexPusher interface

+ NewDocument func(key string)

+ PushDocument func()

+ SetField func(key string, value interface{})

+ type RedisSearchIndexer struct

+ func NewRedisSearchIndexer(engine *Engine) *RedisSearchIndexer

+ func (r *RedisSearchIndexer) DisableLoop()

+ func (r *RedisSearchIndexer) Run(ctx context.Context)

+ func (r *RedisSearchIndexer) SetHeartBeat(duration time.Duration, beat func())

+ type RedisSearchIndexerFunc func(lastID uint64, pusher RedisSearchIndexPusher) (newID uint64, hasMore bool)

+ type RedisSearchQuery struct

+ func (q *RedisSearchQuery) ExplainScore() *RedisSearchQuery

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

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

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

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

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

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

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

+ func (q *RedisSearchQuery) InOrder() *RedisSearchQuery

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

+ func (q *RedisSearchQuery) NoStopWords() *RedisSearchQuery

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

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

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

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

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

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

+ func (q *RedisSearchQuery) Verbatim() *RedisSearchQuery

+ func (q *RedisSearchQuery) WithPayLoads() *RedisSearchQuery

+ func (q *RedisSearchQuery) WithScores() *RedisSearchQuery

+ type RedisSearchResult struct

+ ExplainScore []interface{}

+ Fields []interface{}

+ Key string

+ PayLoad string

+ Score float64

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

v1.76.0

Feb 17, 2021

Changes in this version

type Engine

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

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

+ type PipeLineBool struct

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

type RedisCache

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

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

type RedisPipeLine

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

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

+ type RedisSearch struct

+ type RedisSearchIndex struct

+ DefaultLanguage string

+ DefaultScore float64

+ Fields []RedisSearchIndexField

+ Filter string

+ LanguageField string

+ MaxTextFields bool

+ Name string

+ NoFields bool

+ NoFreqs bool

+ NoNHL bool

+ NoOffsets bool

+ PayloadField string

+ Prefixes []string

+ RedisPool string

+ ScoreField string

+ SkipInitialScan bool

+ StopWords []string

+ Temporary int

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

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

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

+ func (rs RedisSearchIndex) AddTextField(name string, weight int, sortable, noindex, nostem bool)

+ type RedisSearchIndexAlter struct

+ Execute func()

+ Pool string

+ Query string

+ Safe bool

+ type RedisSearchIndexField struct

+ Name string

+ NoIndex bool

+ NoStem bool

+ Sortable bool

+ TagSeparator string

+ Type string

+ Weight int

+ type RedisSearchIndexInfo struct

+ BytesPerRecordAvg float64

+ Definition RedisSearchIndexInfoDefinition

+ DocTableSizeMB float64

+ Fields []RedisSearchIndexInfoField

+ HashIndexingFailures uint64

+ Indexing uint64

+ InvertedSzMB float64

+ KeyTableSizeMB float64

+ MaxDocID uint64

+ Name string

+ NumDocs uint64

+ NumRecords uint64

+ NumTerms uint64

+ OffsetBitsPerRecordAvg float64

+ OffsetVectorsSzMB float64

+ OffsetsPerTermAvg float64

+ Options []interface{}

+ PercentIndexed float64

+ RecordsPerDocAvg float64

+ SortableValuesSizeMB float64

+ StopWords []string

+ TotalInvertedIndexBlocks float64

+ type RedisSearchIndexInfoDefinition struct

+ DefaultScore float64

+ KeyType string

+ LanguageField string

+ PayloadField string

+ Prefixes []string

+ ScoreField string

+ type RedisSearchIndexInfoField struct

+ Name string

+ Type string

+ Weight int

type Registry

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

v1.75.3

Feb 10, 2021

Changes in this version

+ const QueryLoggerSourceStreams

+ type AsyncConsumer struct

+ func NewAsyncConsumer(engine *Engine, name string) *AsyncConsumer

+ func (r *AsyncConsumer) Digest(ctx context.Context, count int)

+ func (r *AsyncConsumer) DisableLoop()

+ func (r *AsyncConsumer) SetHeartBeat(duration time.Duration, beat func())

+ func (r *AsyncConsumer) SetLogLogger(logger func(log *LogQueueValue))

+ type Bind map[string]interface

+ type DirtyEntityEvent interface

+ Added func() bool

+ Deleted func() bool

+ ID func() uint64

+ TableSchema func() TableSchema

+ Updated func() bool

+ func EventDirtyEntity(e Event) DirtyEntityEvent

type Engine

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

+ func (e *Engine) Delete(entity Entity)

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

+ func (e *Engine) EnableRequestCache(goroutines bool)

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

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

+ func (e *Engine) FlushWithCheckMany(entities ...Entity) error

+ func (e *Engine) ForceDelete(entity Entity)

+ func (e *Engine) GetEventBroker() EventBroker

+ func (e *Engine) NewFastEngine() FastEngine

+ func (e *Engine) NewFlusher() Flusher

+ func (e *Engine) NewRedisFlusher() RedisFlusher

type Entity

+ GetDirtyBind func() (bind Bind, has bool)

+ IsDirty func() bool

+ Loaded func() bool

+ SetEntityLogMeta func(key string, value interface{})

+ SetOnDuplicateKeyUpdate func(bind Bind)

+ type Event interface

+ Ack func()

+ ID func() string

+ RawData func() map[string]interface{}

+ Skip func()

+ Stream func() string

+ Unserialize func(val interface{}) error

+ type EventAsMap map[string]interface

+ type EventBroker interface

+ Consumer func(name, group string) EventsConsumer

+ NewFlusher func() EventFlusher

+ Publish func(stream string, event interface{}) (id string)

+ PublishMap func(stream string, event EventAsMap) (id string)

+ type EventConsumerHandler func([]Event)

+ type EventFlusher interface

+ Flush func()

+ Publish func(stream string, event interface{})

+ PublishMap func(stream string, event EventAsMap)

+ type EventsConsumer interface

+ Consume func(ctx context.Context, count int, blocking bool, handler EventConsumerHandler)

+ DisableLoop func()

+ SetHeartBeat func(duration time.Duration, beat func())

+ type FastEngine interface

+ LoadByID func(id uint64, entity Entity, references ...string) (found bool, fastEntity FastEntity)

+ LoadByIDs func(ids []uint64, entity Entity, references ...string) (result []FastEntity, missing []uint64)

+ type FastEntity interface

+ Fill func(entity Entity)

+ Get func(field string) interface{}

+ GetID func() uint64

+ Is func(entity Entity) bool

+ type Flusher interface

+ Clear func()

+ Delete func(entity ...Entity) Flusher

+ Flush func()

+ FlushInTransaction func()

+ FlushInTransactionWithCheck func() error

+ FlushInTransactionWithLock func(lockerPool string, lockName string, ttl time.Duration, ...)

+ FlushLazy func()

+ FlushWithCheck func() error

+ FlushWithFullCheck func() error

+ FlushWithLock func(lockerPool string, lockName string, ttl time.Duration, ...)

+ ForceDelete func(entity ...Entity) Flusher

+ MarkDirty func(entity Entity, queueCode string, ids ...uint64)

+ Track func(entity ...Entity) Flusher

type Lock

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

type ORM

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

+ func (orm *ORM) IsDirty() bool

+ func (orm *ORM) Loaded() bool

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

+ func (orm *ORM) SetOnDuplicateKeyUpdate(bind Bind)

+ type PipeLineGet struct

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

+ type PipeLineInt struct

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

+ type PipeLineStatus struct

+ func (c *PipeLineStatus) Result() error

+ type PipeLineString struct

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

type RedisCache

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

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

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

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

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

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

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

+ func (r *RedisCache) PipeLine() *RedisPipeLine

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type RedisFlusher interface

+ Del func(redisPool string, keys ...string)

+ Flush func()

+ Publish func(stream string, event interface{})

+ PublishMap func(stream string, event EventAsMap)

+ type RedisPipeLine struct

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

+ func (rp *RedisPipeLine) Exec()

+ func (rp *RedisPipeLine) Executed() bool

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

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

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

type Registry

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

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

+ func (r *Registry) SetDefaultEncoding(encoding string)

type ValidatedRegistry

+ GetRedisPools func() []string

+ GetRedisStreams func() map[string]map[string][]string

v1.51.15

Nov 5, 2020

Changes in this version

+ const QueryLoggerSourceClickHouse

+ const QueryLoggerSourceDB

+ const QueryLoggerSourceElastic

+ const QueryLoggerSourceLocalCache

+ const QueryLoggerSourceRabbitMQ

+ const QueryLoggerSourceRedis

+ func StartDataDogProfiler(service string, apiKey string, environment string, duration time.Duration) (def func())

+ func StartDataDogTracer(rate float64, opts ...tracer.StartOption) (def func())

+ type APM interface

+ Finish func()

+ type Alter struct

+ Pool string

+ SQL string

+ Safe bool

+ type CachedQuery struct

+ type ClickHouse struct

+ func (c *ClickHouse) Begin()

+ func (c *ClickHouse) Commit()

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

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

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

+ func (c *ClickHouse) Rollback()

+ type ClickHouseConfig struct

+ type DB struct

+ func (db *DB) Begin()

+ func (db *DB) Commit()

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

+ func (db *DB) GetDatabaseName() string

+ func (db *DB) GetPoolCode() string

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

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

+ func (db *DB) Rollback()

+ type DBConfig struct

+ type DataDog interface

+ DropAPM func()

+ EnableORMAPMLog func(level apexLog.Level, withAnalytics bool, source ...QueryLoggerSource)

+ FinishAPM func()

+ RegisterAPMError func(err interface{})

+ SetAPMTag func(key string, value interface{})

+ StartAPM func(service string, environment string)

+ StartHTTPAPM func(request *http.Request, service string, environment string) HTTPAPM

+ StartWorkSpan func(name string) WorkSpan

+ type DirtyData struct

+ Added bool

+ Deleted bool

+ ID uint64

+ TableSchema *tableSchema

+ Updated bool

+ type DirtyHandler func(data []*DirtyData)

+ type DirtyQueueValue struct

+ Added bool

+ Deleted bool

+ EntityName string

+ ID uint64

+ Updated bool

+ type DirtyReceiver struct

+ func NewDirtyReceiver(engine *Engine) *DirtyReceiver

+ func (r *DirtyReceiver) Digest(code string, handler DirtyHandler)

+ func (r *DirtyReceiver) DisableLoop()

+ func (r *DirtyReceiver) Purge(code string)

+ func (r *DirtyReceiver) SetHeartBeat(beat func())

+ func (r *DirtyReceiver) SetMaxLoopDuration(duration time.Duration)

+ type DuplicatedKeyError struct

+ Index string

+ Message string

+ func (err *DuplicatedKeyError) Error() string

+ type Elastic struct

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

+ func (e *Elastic) CreateIndex(index ElasticIndexDefinition)

+ func (e *Elastic) DropIndex(index ElasticIndexDefinition)

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

+ type ElasticConfig struct

+ type ElasticIndexAlter struct

+ Index ElasticIndexDefinition

+ NewMapping map[string]interface{}

+ OldMapping map[string]interface{}

+ Pool string

+ Safe bool

+ type ElasticIndexDefinition interface

+ GetDefinition func() map[string]interface{}

+ GetName func() string

+ type Engine struct

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

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

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

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

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

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

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

+ func (e *Engine) ClearTrackedEntities()

+ func (e *Engine) DataDog() DataDog

+ func (e *Engine) EnableDebug()

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

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

+ func (e *Engine) Flush()

+ func (e *Engine) FlushInTransaction()

+ func (e *Engine) FlushInTransactionWithCheck() error

+ func (e *Engine) FlushInTransactionWithLock(lockerPool string, lockName string, ttl time.Duration, ...)

+ func (e *Engine) FlushLazy()

+ func (e *Engine) FlushWithCheck() error

+ func (e *Engine) FlushWithFullCheck() error

+ func (e *Engine) FlushWithLock(lockerPool string, lockName string, ttl time.Duration, ...)

+ func (e *Engine) ForceMarkToDelete(entity ...Entity)

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

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

+ func (e *Engine) GetDirtyBind(entity Entity) (bool, map[string]interface{})

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

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

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

+ func (e *Engine) GetLocker(code ...string) *Locker

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

+ func (e *Engine) GetRabbitMQQueue(queueName string) *RabbitMQQueue

+ func (e *Engine) GetRabbitMQRouter(queueName string) *RabbitMQRouter

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

+ func (e *Engine) GetRegistry() ValidatedRegistry

+ func (e *Engine) IsDirty(entity Entity) bool

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

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

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

+ func (e *Engine) Loaded(entity Entity) bool

+ func (e *Engine) Log() Log

+ func (e *Engine) MarkDirty(entity Entity, queueCode string, ids ...uint64)

+ func (e *Engine) MarkToDelete(entity ...Entity)

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

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

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

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

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

+ func (e *Engine) SetEntityLogMeta(key string, value interface{}, entity ...Entity)

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

+ func (e *Engine) SetOnDuplicateKeyUpdate(update *Where, entity Entity)

+ func (e *Engine) Track(entity ...Entity)

+ func (e *Engine) TrackAndFlush(entity ...Entity)

+ type Entity interface

+ GetID func() uint64

+ SetField func(field string, value interface{}) error

+ type Enum interface

+ GetDefault func() string

+ GetFields func() []string

+ GetMapping func() map[string]string

+ Has func(value string) bool

+ type EnumModel struct

+ func (enum *EnumModel) GetDefault() string

+ func (enum *EnumModel) GetFields() []string

+ func (enum *EnumModel) GetMapping() map[string]string

+ func (enum *EnumModel) Has(value string) bool

+ type ExecResult interface

+ LastInsertId func() uint64

+ RowsAffected func() uint64

+ type ForeignKeyError struct

+ Constraint string

+ Message string

+ func (err *ForeignKeyError) Error() string

+ type GetSetProvider func() interface

+ type HTTPAPM interface

+ SetResponseStatus func(status int)

+ type LazyReceiver struct

+ func NewLazyReceiver(engine *Engine) *LazyReceiver

+ func (r *LazyReceiver) Digest()

+ func (r *LazyReceiver) DisableLoop()

+ func (r *LazyReceiver) Purge()

+ func (r *LazyReceiver) SetHeartBeat(beat func())

+ func (r *LazyReceiver) SetMaxLoopDuration(duration time.Duration)

+ type LocalCache struct

+ func (c *LocalCache) Clear()

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

+ func (c *LocalCache) GetObjectsCount() int

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

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

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

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

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

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

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

+ type LocalCacheConfig struct

+ type Lock struct

+ func (l *Lock) Release()

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

+ type Locker struct

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

+ type Log interface

+ AddFields func(fields apexLog.Fielder)

+ AddFieldsFromHTTPRequest func(r *http.Request, ip string)

+ Debug func(message string, fields apexLog.Fielder)

+ Error func(err interface{}, fields apexLog.Fielder)

+ ErrorMessage func(message string, fields apexLog.Fielder)

+ Info func(message string, fields apexLog.Fielder)

+ SetHTTPResponseCode func(code int)

+ Warn func(message string, fields apexLog.Fielder)

+ type LogQueueValue struct

+ Before map[string]interface{}

+ Changes map[string]interface{}

+ ID uint64

+ LogID uint64

+ Meta map[string]interface{}

+ PoolName string

+ TableName string

+ Updated time.Time

+ type LogReceiver struct

+ Logger func(log *LogQueueValue)

+ func NewLogReceiver(engine *Engine) *LogReceiver

+ func (r *LogReceiver) Digest()

+ func (r *LogReceiver) DisableLoop()

+ func (r *LogReceiver) Purge()

+ func (r *LogReceiver) SetHeartBeat(beat func())

+ type ORM struct

+ func (orm *ORM) GetID() uint64

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

+ type Pager struct

+ CurrentPage int

+ PageSize int

+ func NewPager(currentPage, pageSize int) *Pager

+ func (pager *Pager) GetCurrentPage() int

+ func (pager *Pager) GetPageSize() int

+ func (pager *Pager) IncrementPage()

+ type PreparedStatement struct

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

+ type PubSub struct

+ func (p *PubSub) Close()

+ func (p *PubSub) Consume(size int, handler func(items []*redis.Message))

+ func (p *PubSub) DisableLoop()

+ func (p *PubSub) PUnsubscribe(channels ...string)

+ func (p *PubSub) SetHeartBeat(beat func())

+ func (p *PubSub) SetMaxLoopDuration(duration time.Duration)

+ func (p *PubSub) String() string

+ func (p *PubSub) Unsubscribe(channels ...string)

+ type QueryLoggerSource int

+ type RabbitMQConsumer interface

+ Close func()

+ Consume func(handler func(items [][]byte))

+ DisableLoop func()

+ Purge func()

+ SetHeartBeat func(beat func())

+ SetMaxLoopDuration func(duration time.Duration)

+ type RabbitMQQueue struct

+ func (r *RabbitMQQueue) Publish(body []byte)

+ func (r RabbitMQQueue) NewConsumer(name string) RabbitMQConsumer

+ type RabbitMQQueueConfig struct

+ AutoDelete bool

+ Durable bool

+ Name string

+ PrefetchCount int

+ Router string

+ RouterKeys []string

+ TTL int

+ type RabbitMQRouter struct

+ func (r *RabbitMQRouter) Publish(routerKey string, body []byte)

+ func (r RabbitMQRouter) NewConsumer(name string) RabbitMQConsumer

+ type RabbitMQRouterConfig struct

+ Durable bool

+ Name string

+ Type string

+ type RedisCache struct

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

+ func (r *RedisCache) FlushDB()

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

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

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

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

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

+ func (r *RedisCache) HSet(key string, field string, value interface{})

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

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

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

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

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

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

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

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

+ func (r *RedisCache) PSubscribe(channels ...string) *PubSub

+ func (r *RedisCache) Publish(channel string, message interface{})

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

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

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

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

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

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

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

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

+ func (r *RedisCache) Subscribe(channels ...string) *PubSub

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

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

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

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

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

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

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

+ type RedisCacheConfig struct

+ type Registry struct

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

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

+ func (r *Registry) RegisterDirtyQueue(code string, batchSize int)

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

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

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

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

+ func (r *Registry) RegisterEnumMap(code string, val map[string]string, defaultValue string)

+ func (r *Registry) RegisterEnumSlice(code string, val []string)

+ func (r *Registry) RegisterEnumStruct(code string, val Enum)

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

+ func (r *Registry) RegisterLocker(code string, redisCode string)

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

+ func (r *Registry) RegisterRabbitMQQueue(config *RabbitMQQueueConfig, serverPool ...string)

+ func (r *Registry) RegisterRabbitMQRouter(config *RabbitMQRouterConfig, serverPool ...string)

+ func (r *Registry) RegisterRabbitMQServer(address string, code ...string)

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

+ func (r *Registry) RegisterRedisRing(addresses []string, db int, code ...string)

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

+ type Rows interface

+ Columns func() []string

+ Next func() bool

+ Scan func(dest ...interface{})

+ type SQLRow interface

+ Scan func(dest ...interface{}) error

+ type SQLRows interface

+ Close func() error

+ Columns func() ([]string, error)

+ Err func() error

+ Next func() bool

+ Scan func(dest ...interface{}) error

+ type SearchOptions struct

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

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

+ type TableSchema interface

+ DropTable func(engine *Engine)

+ GetColumns func() []string

+ GetLocalCache func(engine *Engine) (cache *LocalCache, has bool)

+ GetMysql func(engine *Engine) *DB

+ GetRedisCache func(engine *Engine) (cache *RedisCache, has bool)

+ GetReferences func() []string

+ GetSchemaChanges func(engine *Engine) (has bool, alters []Alter)

+ GetTableName func() string

+ GetType func() reflect.Type

+ GetUsage func(registry ValidatedRegistry) map[reflect.Type][]string

+ TruncateTable func(engine *Engine)

+ UpdateSchema func(engine *Engine)

+ UpdateSchemaAndTruncateTable func(engine *Engine)

+ type ValidatedRegistry interface

+ CreateEngine func() *Engine

+ GetDirtyQueues func() map[string]int

+ GetEntities func() map[string]reflect.Type

+ GetEnum func(code string) Enum

+ GetEnums func() map[string]Enum

+ GetSourceRegistry func() *Registry

+ GetTableSchema func(entityName string) TableSchema

+ GetTableSchemaForEntity func(entity Entity) TableSchema

+ type Where struct

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

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

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

+ func (where *Where) String() string

+ type WorkSpan interface

+ Finish func()

+ SetTag func(key string, value interface{})

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL