utils

Documentation

Index

• func GenerateLargeHTMLFile(filePath string, sizeMB int) error
• func GenerateLargeJSONFile(filePath string, sizeMB int) error
• func GenerateLargeTextFile(filePath string, sizeMB int) error
• type ConnectionPool
  • func NewConnectionPool(opts PoolOptions) *ConnectionPool
  • func (p *ConnectionPool) Close() error
  • func (p *ConnectionPool) Get(ctx context.Context) (interface{}, error)
  • func (p *ConnectionPool) Put(conn interface{})
• type Pool
• type PoolOptions

Functions

func GenerateLargeHTMLFile

func GenerateLargeHTMLFile(filePath string, sizeMB int) error

GenerateLargeHTMLFile generates a large HTML file with the specified size in MB

func GenerateLargeJSONFile

func GenerateLargeJSONFile(filePath string, sizeMB int) error

GenerateLargeJSONFile generates a large JSON file with the specified size in MB

func GenerateLargeTextFile

func GenerateLargeTextFile(filePath string, sizeMB int) error

GenerateLargeTextFile generates a large text file with the specified size in MB

Types

type ConnectionPool

type ConnectionPool struct {
	// contains filtered or unexported fields
}

ConnectionPool implements a generic connection pool

func NewConnectionPool

func NewConnectionPool(opts PoolOptions) *ConnectionPool

NewConnectionPool creates a new connection pool

func (*ConnectionPool) Close

func (p *ConnectionPool) Close() error

Close closes all connections in the pool

func (*ConnectionPool) Get

func (p *ConnectionPool) Get(ctx context.Context) (interface{}, error)

Get retrieves a connection from the pool

func (*ConnectionPool) Put

func (p *ConnectionPool) Put(conn interface{})

Put returns a connection to the pool

type Pool

type Pool interface {
	// Get retrieves a connection from the pool
	Get(ctx context.Context) (interface{}, error)
	// Put returns a connection to the pool
	Put(conn interface{})
	// Close closes all connections in the pool
	Close() error
}

Pool defines the interface for connection pooling

type PoolOptions

type PoolOptions struct {
	CreateConn   func() (interface{}, error)
	ValidateConn func(interface{}) bool
	CloseConn    func(interface{}) error
	MaxIdle      int
	MaxActive    int
	IdleTimeout  time.Duration
}

PoolOptions configures the connection pool