sqlqueuecore

Documentation

Index

• func New(cfg queue.DatabaseConfig) (*databaseQueue, error)
• func NewQueue(driverName string, cfg ModuleConfig, opts ...queue.Option) (*queue.Queue, error)
• type DatabaseConfig
• type ModuleConfig

Functions

func New

func New(cfg queue.DatabaseConfig) (*databaseQueue, error)

func NewQueue

func NewQueue(driverName string, cfg ModuleConfig, opts ...queue.Option) (*queue.Queue, error)

NewQueue creates a high-level queue.Queue from the shared SQL implementation for a specific SQL driver name.

Types

type DatabaseConfig

type DatabaseConfig = queue.DatabaseConfig

DatabaseConfig configures the SQL-backed database q. @group Config

type ModuleConfig

type ModuleConfig struct {
	queueconfig.DriverBaseConfig
	DB                       *sql.DB
	DSN                      string
	ProcessingRecoveryGrace  time.Duration
	ProcessingLeaseNoTimeout time.Duration
}

ModuleConfig contains shared configuration fields used by the SQL dialect driver wrapper modules (mysqlqueue, postgresqueue, sqlitequeue).