Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Connect ¶
Connect establishes a connection pool to the PostgreSQL database using the provided DSN and options.
func NewProvider ¶
func NewProvider(db *sql.DB, opts ...ProviderOption) scrapemate.JobProvider
func NewResultWriter ¶
func NewResultWriter(db *sql.DB) scrapemate.ResultWriter
Types ¶
type ConnectOption ¶
type ConnectOption func(*ConnectOptions)
func WithMaxConnIdleTime ¶
func WithMaxConnIdleTime(d time.Duration) ConnectOption
func WithMaxConnLifetime ¶
func WithMaxConnLifetime(d time.Duration) ConnectOption
func WithMaxConns ¶
func WithMaxConns(n int32) ConnectOption
func WithMinConns ¶
func WithMinConns(n int32) ConnectOption
func WithPingTimeout ¶
func WithPingTimeout(d time.Duration) ConnectOption
type ConnectOptions ¶
type ConnectOptions struct {
// contains filtered or unexported fields
}
type ProviderOption ¶
type ProviderOption func(*provider)
ProviderOption allows configuring the provider
func WithBatchSize ¶
func WithBatchSize(size int) ProviderOption
WithBatchSize sets custom batch size
Source Files
Click to show internal directories.
Click to hide internal directories.