sqlqueue

Documentation

Overview

Package sqlqueue implements queue.Queue using database/sql (SQLite-compatible). database/sql (SQLite 互換) による queue.Queue の実装。

Index

• func New(db *sql.DB) queue.Queue

Functions

func New

func New(db *sql.DB) queue.Queue

New creates a new Queue backed by the given *sql.DB. The queue_jobs table must already exist (created by store migrations). 指定 *sql.DB をバックエンドとする Queue を生成する。 queue_jobs テーブルは Store のマイグレーションで作成済みであること。