smartconnpool

package

Go to main page

Versions in this module

v0

v0.19.4

May 8, 2024

v0.19.3

Apr 4, 2024 GO-2024-2826

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

v0.19.2

Apr 4, 2024 GO-2024-2826

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

v0.19.1

Mar 14, 2024 GO-2024-2826

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

v0.19.0

Mar 6, 2024 GO-2024-2826

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

Changes in this version

+ var ErrCtxTimeout = vterrors.New(vtrpcpb.Code_DEADLINE_EXCEEDED, "resource pool context already expired")

+ var ErrTimeout = vterrors.New(vtrpcpb.Code_RESOURCE_EXHAUSTED, "resource pool timed out")

+ type Config struct

+ Capacity int64

+ IdleTimeout time.Duration

+ LogWait func(time.Time)

+ MaxLifetime time.Duration

+ RefreshInterval time.Duration

+ type ConnPool struct

+ Metrics Metrics

+ func NewPool[C Connection](config *Config[C]) *ConnPool[C]

+ func (pool *ConnPool[C]) Active() int64

+ func (pool *ConnPool[C]) Available() int64

+ func (pool *ConnPool[C]) Capacity() int64

+ func (pool *ConnPool[C]) Close()

+ func (pool *ConnPool[C]) Get(ctx context.Context, setting *Setting) (*Pooled[C], error)

+ func (pool *ConnPool[C]) InUse() int64

+ func (pool *ConnPool[C]) IsOpen() bool

+ func (pool *ConnPool[C]) MaxCapacity() int64

+ func (pool *ConnPool[C]) Open(connect Connector[C], refresh RefreshCheck) *ConnPool[C]

+ func (pool *ConnPool[C]) RegisterStats(stats *servenv.Exporter, name string)

+ func (pool *ConnPool[C]) SetCapacity(newcap int64)

+ func (pool *ConnPool[C]) SetIdleTimeout(duration time.Duration)

+ func (pool *ConnPool[C]) StatsJSON() map[string]any

+ func (pool *ConnPool[D]) IdleTimeout() time.Duration

+ func (pool *ConnPool[D]) RefreshInterval() time.Duration

+ type Connection interface

+ ApplySetting func(ctx context.Context, setting *Setting) error

+ Close func()

+ IsClosed func() bool

+ ResetSetting func(ctx context.Context) error

+ Setting func() *Setting

+ type Connector func(ctx context.Context) (C, error)

+ type Metrics struct

+ func (m *Metrics) DiffSettingCount() int64

+ func (m *Metrics) GetCount() int64

+ func (m *Metrics) GetSettingCount() int64

+ func (m *Metrics) IdleClosed() int64

+ func (m *Metrics) MaxLifetimeClosed() int64

+ func (m *Metrics) ResetSettingCount() int64

+ func (m *Metrics) WaitCount() int64

+ func (m *Metrics) WaitTime() time.Duration

+ type Pooled struct

+ Conn C

+ func (dbc *Pooled[C]) Close()

+ func (dbc *Pooled[C]) Recycle()

+ func (dbc *Pooled[C]) Taint()

+ type RefreshCheck func() (bool, error)

+ type Setting struct

+ func NewSetting(apply, reset string) *Setting

+ func (cached *Setting) CachedSize(alloc bool) int64

+ func (s *Setting) ApplyQuery() string

+ func (s *Setting) ResetQuery() string

v0.19.0-rc1

Feb 7, 2024

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