beeorm

package module

Go to main page

Versions in this module

v2

v2.10.2

Aug 18, 2023

Changes in this version

+ func LoadByID(id I, engine Engine, references ...string) (entity E, found bool)

+ type ID interface

type RedisCache

+ ZRangeArgs func(args redis.ZRangeArgs) []string

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

type RedisCacheSetter

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

v2.10.1

Jun 9, 2023

v2.10.0

Jun 9, 2023

Changes in this version

type Engine

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

+ type Meta map[string]string

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

type RedisCache

+ AddNamespacePrefix func(key string) string

+ GetCode func() string

+ GetNamespace func() string

+ HasNamespace func() bool

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

+ RemoveNamespacePrefix func(key string) string

type RedisCacheSetter

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

type Registry

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

v2.9.2

Mar 21, 2023

v2.9.1

Mar 21, 2023

v2.9.0

Mar 21, 2023

v2.8.2

Mar 17, 2023

v2.8.1

Mar 15, 2023

Changes in this version

type FlushType

+ const InsertUpdate

v2.7.9

Mar 15, 2023

v2.7.8

Mar 14, 2023

v2.7.7

Mar 13, 2023

v2.7.6

Mar 13, 2023

Changes in this version

+ type EntitySchemaReference struct

+ ColumnName string

+ EntityName string

+ FieldPath []string

v2.7.5

Mar 13, 2023

v2.7.4

Mar 10, 2023

v2.7.3

Mar 9, 2023

v2.7.2

Mar 9, 2023

v2.7.1

Mar 9, 2023

Changes in this version

type ORM

+ ID uint64

v2.7.0

Mar 9, 2023

v2.6.0

Mar 6, 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

+ SetID func(id uint64)

+ 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() []string

+ 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 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 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(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(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) SetID(id uint64)

+ 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

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

+ 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

+ 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

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

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

+ 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

Other modules containing this package

github.com/latolukasz/beeorm

github.com/latolukasz/beeorm/v3

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