pq

package

Go to main page

Versions in this module

v0

v0.5.0

Mar 11, 2021

v0.4.1

Mar 1, 2021

v0.4.0

Mar 1, 2021

Changes in this version

type Mutex

+ func (m *Mutex) IsLocked() bool

v0.3.0

Feb 23, 2021

Changes in this version

type Config

+ func (c *Config) ComposeDSN() string

+ func (c *Config) SetDefault() *Config

type Enity

+ func (c *Enity) SetSchema(schema string)

type MigrateConfig

+ Schema string

+ func (c *MigrateConfig) SetDefault() *MigrateConfig

v0.2.0

Jan 15, 2021

Changes in this version

type Config

+ Migrate *MigrateConfig

v0.1.0

Jan 12, 2021

Changes in this version

+ const DefaultProviderName

+ func Get(ctx context.Context) (db.Provider, error)

+ func GetEnity(ctx context.Context, enityName string) (interface{}, error)

+ func Registrate(ctx context.Context) (context.Context, error)

+ func RegistrateEnity(ctx context.Context, enityName string, options interface{}) (context.Context, error)

+ type Config struct

+ DSN string

+ MaxConnectionLifetime time.Duration

+ MaxIdleConnections int

+ MaxOpenedConnections int

+ MigrateConfig *MigrateConfig

+ Options string

+ QueueWorkerTimeout time.Duration

+ StartQueueWorker bool

+ StartWatcher bool

+ Timeout time.Duration

+ func (co *Config) GetDBName() string

+ func (co *Config) Validate()

+ type Enity struct

+ Conn *sqlx.DB

+ func GetEnityTypeCast(ctx context.Context, enityName string) (*Enity, error)

+ func NewEnity(ctx context.Context, name string, opts interface{}) (*Enity, error)

+ func (conn *Enity) AppendToQueue(queueItem *QueueItem)

+ func (conn *Enity) GetMetrics(prefix string) map[string]*stats.MetricOptions

+ func (conn *Enity) GetReadyHandlers(prefix string) map[string]stats.CheckFunc

+ func (conn *Enity) Migrate()

+ func (conn *Enity) NewMutex(checkInterval time.Duration) (*Mutex, error)

+ func (conn *Enity) NewMutexByID(lockID interface{}, checkInterval time.Duration) (*Mutex, error)

+ func (conn *Enity) RegisterMigration(migration *MigrationInCode)

+ func (conn *Enity) SetConnPoolLifetime(connMaxLifetime time.Duration)

+ func (conn *Enity) SetConnPoolLimits(maxIdleConnections, maxOpenedConnections int)

+ func (conn *Enity) SetPoolLimits(maxIdleConnections, maxOpenedConnections int, connMaxLifetime time.Duration)

+ func (conn *Enity) SetSchemaName(schemaName string)

+ func (conn *Enity) Shutdown() error

+ func (conn *Enity) Start() error

+ func (conn *Enity) WaitForEstablishing()

+ type MigrateConfig struct

+ Action string

+ Count int64

+ Directory string

+ MigrationsType MigrationsType

+ Only bool

+ func (mo *MigrateConfig) Validate()

+ type MigrationInCode struct

+ Down func(tx *sql.Tx) error

+ Name string

+ Up func(tx *sql.Tx) error

+ type MigrationsType int

+ const MigrationTypeGoCode

+ const MigrationTypeSQLFiles

+ func (mt MigrationsType) String() string

+ type Mutex struct

+ func NewMutex(conn **sqlx.DB, checkInterval time.Duration) (*Mutex, error)

+ func NewMutexByID(conn **sqlx.DB, lockID interface{}, checkInterval time.Duration) (*Mutex, error)

+ func (psqlLock *Mutex) GenerateLockID(databaseName string, additionalNames ...string)

+ func (psqlLock *Mutex) Lock() (err error)

+ func (psqlLock *Mutex) RWLock() (err error)

+ func (psqlLock *Mutex) RWUnlock() (err error)

+ func (psqlLock *Mutex) Unlock() (err error)

+ type Provider struct

+ func NewProvider(ctx context.Context) *Provider

+ func (p *Provider) AppendToQueue(connectionName string, item interface{}) error

+ func (p *Provider) CreateEnity(enityName string, options interface{}) error

+ func (p *Provider) GetEnity(connectionName string) (interface{}, error)

+ func (p *Provider) NewMutex(connectionName string, checkInterval time.Duration, mutex interface{}) error

+ func (p *Provider) NewMutexByID(connectionName string, lockID interface{}, checkInterval time.Duration, ...) error

+ func (p *Provider) RegisterMigration(connectionName string, migration interface{}) error

+ func (p *Provider) WaitForFlush(connectionName string) error

+ type QueueItem struct

+ IsWaitForFlush bool

+ Param QueueItemParam

+ Query string

+ WaitForFlush chan bool

+ type QueueItemParam interface

+ IsUnique func(conn *sqlx.DB) bool

+ Prepare func() bool

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