database

Aug 27, 2024

Changes in this version

+ func FiltrWhere(field field.Expr, value any) field.Expr

+ func QueryPaging(query any, page Paging) error

+ type Aggregator struct

+ func NewAggregator(batchProcessor BatchProcessFunc, optionFuncs ...SetAggregatorOptionFunc) (*Aggregator, error)

+ func (agt *Aggregator) Enqueue(item interface{}) error

+ func (agt *Aggregator) EnqueueWithRetry(item interface{}, maxRetries int, backoff time.Duration) bool

+ func (agt *Aggregator) SafeStop()

+ func (agt *Aggregator) Start()

+ func (agt *Aggregator) Stop()

+ func (agt *Aggregator) TryEnqueue(item interface{}) bool

+ type AggregatorOption struct

+ BatchSize int

+ ChannelBufferSize int

+ ErrorHandler ErrorHandlerFunc

+ LingerTime time.Duration

+ Logger *log.Logger

+ Workers int

+ type BatchProcessFunc func([]interface{}) error

+ type ErrorHandlerFunc func(err error, items []interface{}, batchProcessFunc BatchProcessFunc, ...)

+ type Paging interface

+ GetTotal func() int

+ OffsetLimit func() (offset, limit int)

+ OrderBy func() string

+ SetTotal func(int)

+ func New() Paging

+ type SetAggregatorOptionFunc func(option *AggregatorOption)

+ func WithBatchSize(batchSize int) SetAggregatorOptionFunc

+ func WithChannelBufferSize(size int) SetAggregatorOptionFunc

+ func WithErrorHandler(handler ErrorHandlerFunc) SetAggregatorOptionFunc

+ func WithLingerTime(duration time.Duration) SetAggregatorOptionFunc

+ func WithLogger(logger *log.Logger) SetAggregatorOptionFunc

+ func WithWorkers(workers int) SetAggregatorOptionFunc

Aug 9, 2024

Changes in this version

+ func SetDsn(m config.ModGormDb) string

+ type DBConfig struct

+ Config *gorm.Config

+ DSN string

+ Driver string

+ type DBManager struct

+ func GetDBManager() *DBManager

+ func GetGormDB(dbConfig config.ModGormDb) (dbm *DBManager, err error)

+ func (m *DBManager) GetDB() *gorm.DB

+ func (m *DBManager) InitDB(config DBConfig) error

+ func (m *DBManager) ReconnectIfNeeded() error

+ func (m *DBManager) StartHealthCheck(interval time.Duration)