pgmfx

type ConnectConfig struct {
	ConnString     string `envconfig:"conn_string" default:"user=postgres host=localhost port=5432 dbname=postgres" json:"conn_string"`
	Password       string `envconfig:"password" default_pwd:"postgres" json:"password"`
	MaxConnections int    `envconfig:"max_connections" default:"5" json:"max_connections"`
	MinConnections int    `envconfig:"min_connections" default:"0" json:"min_connections"`
	// OpenTimeout time in open state; 0 mean forever open
	OpenTimeout              time.Duration `envconfig:"open_timeout" default:"600s" json:"open_timeout"`
	IdleTimeout              time.Duration `envconfig:"idle_timeout" default:"600s" json:"idle_timeout"`
	PoolGetConnectionTimeout time.Duration `envconfig:"get_connection_timeout" default:"5s" json:"get_connection_timeout"`
	PoolName                 string        `envconfig:"pool_name" json:"pool_name"`
}

type MetricsProvider interface {
	WriteMetricRequest(poolName, sqlName string)
	WriteMetricGetPool(mRequest time.Time, poolName, sqlName string, resultResult string)
	WriteMetricDoRequest(mRequest time.Time, poolName, sqlName string, resultResult string)
	WriteMetricDoReadResponce(mRequest time.Time, poolName, sqlName string, resultResult string)
	WriteMetricResponce(mRequest time.Time, poolName, sqlName string, resultResult string)
}

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

type PgxMFPool struct {
	Pool                    *poh.ConnectionPool[*pgx.Conn]
	PoolName                func() string
	MetricsProvider         MetricsProvider
	GetNewConnectionTimeout poh.ExpireDurationFunc
	// contains filtered or unexported fields
}

type RowsProcess func(rows pgx.Rows) error