internal

Documentation

Index

• func DetermineTableName(prefix string, fileName string) string
• func InitializeDB(fileName string) (*sql.DB, error)
• func MakeNotifyChan() chan struct{}
• func PrepareDB(db *sql.DB, createTableQuery string, queries ...string) error

Functions

func DetermineTableName

func DetermineTableName(prefix string, fileName string) string

DetermineTableName determines the table name to use for the queue. If the fileName is empty, we use a unique table name. Otherwise, we use the fileName as the table name.

func InitializeDB

func InitializeDB(fileName string) (*sql.DB, error)

func MakeNotifyChan

func MakeNotifyChan() chan struct{}

MakeNotifyChan creates a new channel with a buffer of 1. This is used to notify the queue that an item has been enqueued. I'm not sure if this is the best way to do this, but it works for now.

func PrepareDB

func PrepareDB(db *sql.DB, createTableQuery string, queries ...string) error