beeorm

package module

Go to main page

Versions in this module

v2

v2.9.40

Jun 5, 2023

v2.9.22

May 4, 2023

v2.9.21

May 4, 2023

v2.9.20

May 4, 2023

v2.9.19

May 2, 2023

v2.9.18

May 2, 2023

Changes in this version

type Engine

+ HasRedisLogger func() (bool, []LogHandler)

v2.9.17

May 2, 2023

v2.9.16

Apr 19, 2023

v2.9.15

Mar 31, 2023

v2.9.14

Mar 31, 2023

Changes in this version

type RedisCacheSetter

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

v2.9.13

Mar 31, 2023

v2.9.12

Mar 31, 2023

v2.9.11

Mar 31, 2023

v2.9.10

Mar 31, 2023

v2.9.9

Mar 30, 2023

v2.9.8

Mar 30, 2023

v2.9.7

Mar 31, 2023

v2.9.6

Mar 30, 2023

Changes in this version

type Registry

+ func (r *Registry) HasRegisteredRedisPool(pool string) bool

v2.9.5

Mar 30, 2023

v2.9.4

Mar 30, 2023

Changes in this version

type RedisCache

+ GetNamespace func() string

v2.9.3

Mar 30, 2023

Changes in this version

+ const DateFormat

+ const LazyFlushChannelName

+ const LazyFlushGroupName

+ const NullBindValue

+ const StreamGarbageCollectorChannelName

+ const StreamGarbageCollectorGroupName

+ const TimeFormat

+ func DisableCacheHashCheck()

+ func RunLazyFlushConsumer(engine Engine, garbage bool)

+ func RunStreamGarbageCollectorConsumer(engine Engine)

+ type Alter struct

+ Pool string

+ SQL string

+ Safe bool

+ func (a Alter) Exec(engine Engine)

+ type Bind map[string]string

+ func (m Bind) Get(key string) string

+ type CachedQuery struct

+ type ColumnSchemaDefinition struct

+ ColumnName string

+ Definition string

+ type DB struct

+ func (db *DB) Begin()

+ func (db *DB) Commit()

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

+ func (db *DB) GetDBClient() DBClient

+ func (db *DB) GetDBClientTX() DBClientTX

+ func (db *DB) GetPoolConfig() MySQLPoolConfig

+ func (db *DB) IsInTransaction() bool

+ func (db *DB) Prepare(query string) (stmt PreparedStmt, close func())

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

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

+ func (db *DB) Rollback()

+ func (db *DB) SetMockClientTX(mock DBClientTX)

+ func (db *DB) SetMockDBClient(mock DBClient)

+ type DBClient interface

+ Begin func() (*sql.Tx, error)

+ type DBClientQuery interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Prepare func(query string) (*sql.Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ QueryRow func(query string, args ...interface{}) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type DBClientTX interface

+ Commit func() error

+ Rollback func() error

+ type DuplicatedKeyError struct

+ Index string

+ Message string

+ func (err *DuplicatedKeyError) Error() string

+ type Engine interface

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

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

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

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

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

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

+ ClearCacheByIDs func(entity Entity, ids ...uint64)

+ Clone func() Engine

+ Delete func(entity ...Entity)

+ DeleteLazy func(entity ...Entity)

+ EnableQueryDebug func()

+ EnableQueryDebugCustom func(mysql, redis, local bool)

+ EnableRequestCache func()

+ Flush func(entity ...Entity)

+ FlushLazy func(entity ...Entity)

+ FlushWithCheck func(entity ...Entity) error

+ FlushWithFullCheck func(entity ...Entity) error

+ GetAlters func() (alters []Alter)

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

+ GetEventBroker func() EventBroker

+ GetLocalCache func(code ...string) LocalCache

+ GetMetaData func() Bind

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

+ GetPluginOption func(plugin, key string) interface{}

+ GetRedis func(code ...string) RedisCache

+ GetRegistry func() ValidatedRegistry

+ IsDirty func(entity Entity) bool

+ Load func(entity Entity, references ...string) (found bool)

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

+ LoadByIDs func(ids []uint64, entities interface{}, references ...string) (found bool)

+ NewFlusher func() Flusher

+ RegisterQueryLogger func(handler LogHandler, mysql, redis, local bool)

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

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

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

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

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

+ SetMetaData func(key, value string)

+ SetPluginOption func(plugin, key string, value interface{})

+ func PrepareTables(t *testing.T, registry *Registry, mySQLVersion, redisVersion int, ...) (engine Engine)

+ type Entity interface

+ Clone func() Entity

+ GetID func() uint64

+ GetMetaData func() Bind

+ IsLoaded func() bool

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

+ SetMetaData func(key, value string)

+ SetOnDuplicateKeyUpdate func(bind Bind)

+ type EntitySchema interface

+ DisableCache func(local, redis bool)

+ DropTable func(engine Engine)

+ GetColumns func() []string

+ GetEntityName func() string

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

+ GetMysql func(engine Engine) *DB

+ GetMysqlPool func() string

+ GetPluginOption func(plugin, key string) interface{}

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

+ GetReferences func() []EntitySchemaReference

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

+ GetTableName func() string

+ GetTag func(field, key, trueValue, defaultValue string) string

+ GetType func() reflect.Type

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

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

+ NewEntity func() Entity

+ TruncateTable func(engine Engine)

+ UpdateSchema func(engine Engine)

+ UpdateSchemaAndTruncateTable func(engine Engine)

+ type EntitySchemaReference struct

+ ColumnName string

+ EntityName string

+ FieldPath []string

+ type Enum interface

+ GetDefault func() string

+ GetFields func() []string

+ Has func(value string) bool

+ Index func(value string) int

+ type Event interface

+ Ack func()

+ ID func() string

+ Meta func() Bind

+ Stream func() string

+ Unserialize func(val interface{})

+ type EventBroker interface

+ Consumer func(group string) EventsConsumer

+ GetStreamGroupStatistics func(stream, group string) *RedisStreamGroupStatistics

+ GetStreamStatistics func(stream string) *RedisStreamStatistics

+ GetStreamsStatistics func(stream ...string) []*RedisStreamStatistics

+ Publish func(stream string, body interface{}, meta Bind) (id string)

+ type EventConsumerHandler func(events []Event)

+ type EventEntityFlushed interface

+ After func() Bind

+ Before func() Bind

+ EntityID func() uint64

+ EntityName func() string

+ MetaData func() Bind

+ Type func() FlushType

+ type EventEntityFlushing interface

+ SetAfter func(before Bind)

+ SetBefore func(before Bind)

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

+ SetID func(id uint64)

+ SetMetaData func(key, value string)

+ SetType func(t FlushType)

+ type EventsConsumer interface

+ Claim func(from, to int)

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

+ ConsumeMany func(ctx context.Context, nr, count int, handler EventConsumerHandler) bool

+ SetBlockTime func(seconds int)

+ type ExecResult interface

+ LastInsertId func() uint64

+ RowsAffected func() uint64

+ type FlushType int

+ const Delete

+ const Insert

+ const InsertUpdate

+ const Update

+ func (ft FlushType) Is(target FlushType) bool

+ func (ft FlushType) String() string

+ type Flusher interface

+ Clear func()

+ Delete func(entity ...Entity) Flusher

+ Flush func()

+ FlushLazy func()

+ FlushWithCheck func() error

+ FlushWithFullCheck func() error

+ Track func(entity ...Entity) Flusher

+ type FlusherCacheSetter interface

+ GetLocalCacheSetter func(code ...string) LocalCacheSetter

+ GetRedisCacheSetter func(code ...string) RedisCacheSetter

+ PublishToStream func(stream string, body interface{}, meta Bind)

+ type IndexSchemaDefinition struct

+ Name string

+ Unique bool

+ func (ti *IndexSchemaDefinition) GetColumns() []string

+ func (ti *IndexSchemaDefinition) SetColumns(columns []string)

+ type LazyFlushConsumer struct

+ func NewLazyFlushConsumer(engine Engine) *LazyFlushConsumer

+ func (b *LazyFlushConsumer) SetBlockTime(seconds int)

+ func (r *LazyFlushConsumer) Digest(ctx context.Context) bool

+ func (r *LazyFlushConsumer) RegisterLazyFlushQueryErrorResolver(resolver LazyFlushQueryErrorResolver)

+ type LazyFlushQueryErrorResolver func(engine Engine, event EventEntityFlushed, queryError *mysql.MySQLError) error

+ type LocalCache interface

+ Clear func()

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

+ GetObjectsCount func() int

+ GetPoolConfig func() LocalCachePoolConfig

+ GetSet func(key string, ttl time.Duration, provider func() interface{}) interface{}

+ MGet func(keys ...string) []interface{}

+ type LocalCachePoolConfig interface

+ GetCode func() string

+ GetLimit func() int

+ type LocalCacheSetter interface

+ MSet func(pairs ...interface{})

+ Remove func(keys ...string)

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

+ type Lock struct

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

+ func (l *Lock) Release()

+ func (l *Lock) TTL(ctx context.Context) time.Duration

+ type Locker struct

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

+ type LogHandler interface

+ Handle func(engine Engine, log map[string]interface{})

+ type MockDBClient struct

+ BeginMock func() (*sql.Tx, error)

+ CommitMock func() error

+ ExecContextMock func(context context.Context, query string, args ...interface{}) (sql.Result, error)

+ ExecMock func(query string, args ...interface{}) (sql.Result, error)

+ OriginDB DBClient

+ PrepareMock func(query string) (*sql.Stmt, error)

+ QueryContextMock func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ QueryMock func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryRowContextMock func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ QueryRowMock func(query string, args ...interface{}) *sql.Row

+ RollbackMock func() error

+ TX DBClientTX

+ func (m *MockDBClient) Begin() (*sql.Tx, error)

+ func (m *MockDBClient) Commit() error

+ func (m *MockDBClient) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (m *MockDBClient) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (m *MockDBClient) Prepare(query string) (*sql.Stmt, error)

+ func (m *MockDBClient) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (m *MockDBClient) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (m *MockDBClient) QueryRow(query string, args ...interface{}) *sql.Row

+ func (m *MockDBClient) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (m *MockDBClient) Rollback() error

+ type MockLogHandler struct

+ Logs []map[string]interface{}

+ func (h *MockLogHandler) Clear()

+ func (h *MockLogHandler) Handle(_ Engine, log map[string]interface{})

+ type MySQLPoolConfig interface

+ GetCode func() string

+ GetDataSourceURI func() string

+ GetDatabase func() string

+ GetVersion func() int

+ type MySQLPoolOptions struct

+ ConnMaxLifetime time.Duration

+ MaxIdleConnections int

+ MaxOpenConnections int

+ type ORM struct

+ func (orm *ORM) Clone() Entity

+ func (orm *ORM) GetID() uint64

+ func (orm *ORM) GetMetaData() Bind

+ func (orm *ORM) IsLoaded() bool

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

+ func (orm *ORM) SetMetaData(key, value string)

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

+ 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()

+ func (pager *Pager) String() string

+ type PipeLineBool struct

+ func (c *PipeLineBool) Result() bool

+ type PipeLineGet struct

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

+ type PipeLineInt struct

+ func (c *PipeLineInt) Result() int64

+ type PipeLineString struct

+ func (c *PipeLineString) Result() string

+ type Plugin interface

+ GetCode func() string

+ type PluginInterfaceEngineCreated interface

+ PluginInterfaceEngineCreated func(engine Engine)

+ type PluginInterfaceEntityFlushed interface

+ PluginInterfaceEntityFlushed func(engine Engine, event EventEntityFlushed, cacheFlusher FlusherCacheSetter)

+ type PluginInterfaceEntityFlushing interface

+ PluginInterfaceEntityFlushing func(engine Engine, event EventEntityFlushing)

+ type PluginInterfaceEntitySearch interface

+ PluginInterfaceEntitySearch func(engine Engine, schema EntitySchema, where *Where) *Where

+ type PluginInterfaceInitEntitySchema interface

+ InterfaceInitEntitySchema func(schema SettableEntitySchema, registry *Registry) error

+ type PluginInterfaceInitRegistry interface

+ PluginInterfaceInitRegistry func(registry *Registry)

+ type PluginInterfaceTableSQLSchemaDefinition interface

+ PluginInterfaceTableSQLSchemaDefinition func(engine Engine, sqlSchema *TableSQLSchemaDefinition) error

+ type PreparedStmt interface

+ Close func() error

+ Exec func(args ...any) ExecResult

+ Query func(args ...any) (rows Rows, close func())

+ QueryRow func(args []interface{}, toFill ...interface{}) (found bool)

+ type QueryLoggerSource int

+ type RedisCache interface

+ AddNamespacePrefix func(key string) string

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

+ EvalSha func(sha1 string, keys []string, args ...interface{}) (res interface{}, exists bool)

+ Exists func(keys ...string) int64

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

+ FlushAll func()

+ FlushDB func()

+ Get func(key string) (value string, has bool)

+ GetCode func() string

+ GetLocker func() *Locker

+ GetPoolConfig func() RedisPoolConfig

+ GetSet func(key string, expiration time.Duration, provider func() interface{}) interface{}

+ HDel func(key string, fields ...string)

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

+ HGetAll func(key string) map[string]string

+ HIncrBy func(key, field string, incr int64) int64

+ HLen func(key string) int64

+ HMGet func(key string, fields ...string) map[string]interface{}

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

+ HSetNx func(key, field string, value interface{}) bool

+ HasNamespace func() bool

+ Incr func(key string) int64

+ IncrBy func(key string, incr int64) int64

+ IncrWithExpire func(key string, expire time.Duration) int64

+ Info func(section ...string) string

+ LLen func(key string) int64

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

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

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

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

+ Ltrim func(key string, start, stop int64)

+ MGet func(keys ...string) []interface{}

+ PipeLine func() *RedisPipeLine

+ Process func(ctx context.Context, cmd redis.Cmder) error

+ RPop func(key string) (value string, found bool)

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

+ RemoveNamespacePrefix func(key string) string

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

+ SCard func(key string) int64

+ SPop func(key string) (string, bool)

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

+ ScriptExists func(sha1 string) bool

+ ScriptLoad func(script string) string

+ SetNX func(key string, value interface{}, expiration time.Duration) bool

+ Type func(key string) string

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

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

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

+ XDel func(stream string, ids ...string) int64

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

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

+ XGroupDelConsumer func(stream, group, consumer string) int64

+ XGroupDestroy func(stream, group string) int64

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

+ XInfoStream func(stream string) *redis.XInfoStream

+ XLen func(stream string) int64

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

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

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

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

+ XReadGroup func(ctx context.Context, a *redis.XReadGroupArgs) (streams []redis.XStream)

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

+ XTrim func(stream string, maxLen int64) (deleted int64)

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

+ ZCard func(key string) int64

+ ZCount func(key string, min, max string) int64

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

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

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

+ ZScore func(key, member string) float64

+ type RedisCacheSetter interface

+ Del func(keys ...string)

+ MSet func(pairs ...interface{})

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

+ type RedisPipeLine struct

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

+ func (rp *RedisPipeLine) Exec()

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

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

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

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

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

+ func (rp *RedisPipeLine) MSet(pairs ...interface{})

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

+ func (rp *RedisPipeLine) XAdd(stream string, values []string) *PipeLineString

+ type RedisPoolConfig interface

+ GetAddress func() string

+ GetCode func() string

+ GetDatabase func() int

+ GetNamespace func() string

+ HasNamespace func() bool

+ type RedisStreamConsumerStatistics struct

+ Name string

+ Pending uint64

+ type RedisStreamGroupStatistics struct

+ Consumers []*RedisStreamConsumerStatistics

+ Group string

+ Lag int64

+ LastDeliveredDuration time.Duration

+ LastDeliveredID string

+ LowerDuration time.Duration

+ LowerID string

+ Pending uint64

+ type RedisStreamStatistics struct

+ Groups []*RedisStreamGroupStatistics

+ Len uint64

+ OldestEventSeconds int

+ RedisPool string

+ Stream string

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) GetDefaultCollate() string

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

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

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

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

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

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

+ func (r *Registry) RegisterMySQLTable(pool string, tableName ...string)

+ func (r *Registry) RegisterPlugin(plugin Plugin)

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

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

+ func (r *Registry) RegisterRedisSentinelWithCredentials(masterName, namespace, user, password string, db int, sentinels []string, ...)

+ func (r *Registry) RegisterRedisSentinelWithOptions(namespace string, opts redis.FailoverOptions, db int, sentinels []string, ...)

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

+ func (r *Registry) RegisterRedisStreamConsumerGroups(stream string, groups ...string)

+ func (r *Registry) RegisterRedisWithCredentials(address, namespace, user, password string, db int, code ...string)

+ func (r *Registry) SetDefaultCollate(collate string)

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

+ func (r *Registry) Validate() (validated ValidatedRegistry, err 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 SettableEntitySchema interface

+ SetPluginOption func(plugin, key string, value interface{})

+ type StreamGarbageCollectorConsumer struct

+ func NewStreamGarbageCollectorConsumer(engine Engine) *StreamGarbageCollectorConsumer

+ func (b *StreamGarbageCollectorConsumer) SetBlockTime(seconds int)

+ func (r *StreamGarbageCollectorConsumer) Digest(ctx context.Context) bool

+ type TableSQLSchemaDefinition struct

+ DBCreateSchema string

+ DBEncoding string

+ DBIndexes []*IndexSchemaDefinition

+ DBTableColumns []*ColumnSchemaDefinition

+ EntityColumns []*ColumnSchemaDefinition

+ EntityIndexes []*IndexSchemaDefinition

+ EntitySchema EntitySchema

+ PostAlters []Alter

+ PreAlters []Alter

+ func (td *TableSQLSchemaDefinition) CreateTableSQL() string

+ type ValidatedRegistry interface

+ CreateEngine func() Engine

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

+ GetEntitySchema func(entityName string) EntitySchema

+ GetEntitySchemaForCachePrefix func(cachePrefix string) EntitySchema

+ GetEntitySchemaForEntity func(entity Entity) EntitySchema

+ GetEnum func(code string) Enum

+ GetLocalCachePools func() map[string]LocalCachePoolConfig

+ GetMySQLPools func() map[string]MySQLPoolConfig

+ GetPlugin func(code string) Plugin

+ GetPlugins func() []string

+ GetRedisPools func() map[string]RedisPoolConfig

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

+ GetSourceRegistry func() *Registry

+ 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) SetParameter(index int, param interface{}) *Where

+ func (where *Where) SetParameters(params ...interface{}) *Where

+ func (where *Where) String() string

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