wwdb

Documentation

Index

• Constants
• func FloodCommand(dbConn func() *sqlx.DB) *cli.Command
• func FloodGC(ctx context.Context, dbConn *sqlx.DB) (int64, error)
• func FloodUnban(ctx context.Context, dbConn *sqlx.DB, identifier string) (int64, error)
• func Lock(ctx context.Context, db *sqlx.DB, name string) error
• func MigrateCommand(migrator func() *migrate.Migrate) *cli.Command
• func MysqlDbMigrate(db *sqlx.DB, migrations *bindata.AssetSource) (*migrate.Migrate, error)
• func OpenDb(log zerolog.Logger, driverName string, dsn string, maxOpenConns int) (*sqlx.DB, error)
• func OpenDbFromWhaleblazer(log zerolog.Logger, maxOpenConns int) (*sqlx.DB, error)
• func Unlock(ctx context.Context, name string) error
• func WhaleblazerMysqlConfig() (*mysql2.Config, error)
• type Flood
  • func (f *Flood) Clear(ctx context.Context, identifier string) error
  • func (f *Flood) Empty(ctx context.Context) error
  • func (f *Flood) IsAllowed(ctx context.Context, identifier string) bool
  • func (f *Flood) Register(ctx context.Context, identifier string)
• type FloodHit
• type FloodSummaryItem
  • func FloodGetSummary(ctx context.Context, dbConn *sqlx.DB) ([]*FloodSummaryItem, error)

Constants

const MB = 1 << 20

Functions

func FloodCommand

func FloodCommand(dbConn func() *sqlx.DB) *cli.Command

func FloodGC

func FloodGC(ctx context.Context, dbConn *sqlx.DB) (int64, error)

func FloodUnban

func FloodUnban(ctx context.Context, dbConn *sqlx.DB, identifier string) (int64, error)

func Lock

func Lock(ctx context.Context, db *sqlx.DB, name string) error

func MigrateCommand

func MigrateCommand(migrator func() *migrate.Migrate) *cli.Command

func MysqlDbMigrate

func MysqlDbMigrate(db *sqlx.DB, migrations *bindata.AssetSource) (*migrate.Migrate, error)

func OpenDb

func OpenDb(log zerolog.Logger, driverName string, dsn string, maxOpenConns int) (*sqlx.DB, error)

func OpenDbFromWhaleblazer

func OpenDbFromWhaleblazer(log zerolog.Logger, maxOpenConns int) (*sqlx.DB, error)

func Unlock

func Unlock(ctx context.Context, name string) error

func WhaleblazerMysqlConfig

func WhaleblazerMysqlConfig() (*mysql2.Config, error)

Types

type Flood

type Flood struct {
	Db        *sqlx.DB
	Name      string
	Window    time.Duration
	Threshold int
}

func (*Flood) Clear

func (f *Flood) Clear(ctx context.Context, identifier string) error

func (*Flood) Empty

func (f *Flood) Empty(ctx context.Context) error

func (*Flood) IsAllowed

func (f *Flood) IsAllowed(ctx context.Context, identifier string) bool

func (*Flood) Register

func (f *Flood) Register(ctx context.Context, identifier string)

type FloodHit

type FloodHit struct {
	Event      string    `db:"event"`
	Identifier string    `db:"identifier"`
	Timestamp  time.Time `db:"timestamp"`
	Expiration time.Time `db:"expiration"`
}

type FloodSummaryItem

type FloodSummaryItem struct {
	Event      string    `db:"event"`
	Identifier string    `db:"identifier"`
	Count      int       `db:"count"`
	LastHit    time.Time `db:"lastHit"`
}

func FloodGetSummary

func FloodGetSummary(ctx context.Context, dbConn *sqlx.DB) ([]*FloodSummaryItem, error)