connection

Documentation

Index

• type Limiter
  • func NewLimiter(client client.Client, limit int64, duration time.Duration) *Limiter
  • func (l *Limiter) Close() error
  • func (l *Limiter) Driver() driver2.Driver
  • func (l *Limiter) Exec(s string, i ...interface{}) (sql.Result, error)
  • func (l *Limiter) ExecContext(ctx context.Context, s string, i ...interface{}) (sql.Result, error)
  • func (l *Limiter) Query(s string, i ...interface{}) (*sql.Rows, error)
  • func (l *Limiter) QueryContext(ctx context.Context, s string, i ...interface{}) (*sql.Rows, error)
  • func (l *Limiter) QueryRow(s string, i ...interface{}) *sql.Row
  • func (l *Limiter) QueryRowContext(ctx context.Context, s string, i ...interface{}) *sql.Row
  • func (l *Limiter) SQL() *sql.DB

Types

type Limiter

type Limiter struct {
	client.Client
	// contains filtered or unexported fields
}

Limiter implements a circuit breaker pattern for database connections. It tracks consecutive errors and blocks requests for a duration when the error limit is reached. After the duration, it allows requests again.

func NewLimiter

func NewLimiter(client client.Client, limit int64, duration time.Duration) *Limiter

func (*Limiter) Close

func (l *Limiter) Close() error

func (*Limiter) Driver

func (l *Limiter) Driver() driver2.Driver

func (*Limiter) Exec

func (l *Limiter) Exec(s string, i ...interface{}) (sql.Result, error)

func (*Limiter) ExecContext

func (l *Limiter) ExecContext(ctx context.Context, s string, i ...interface{}) (sql.Result, error)

func (*Limiter) Query

func (l *Limiter) Query(s string, i ...interface{}) (*sql.Rows, error)

func (*Limiter) QueryContext

func (l *Limiter) QueryContext(ctx context.Context, s string, i ...interface{}) (*sql.Rows, error)

func (*Limiter) QueryRow

func (l *Limiter) QueryRow(s string, i ...interface{}) *sql.Row

func (*Limiter) QueryRowContext

func (l *Limiter) QueryRowContext(ctx context.Context, s string, i ...interface{}) *sql.Row

func (*Limiter) SQL

func (l *Limiter) SQL() *sql.DB