setup

Documentation

Overview

Package setup helps initialize the database and all queries.

Index

• func DB(ctx context.Context, connector db.Connector, dbConns int) error
• func GetActiveQueries(ctx context.Context) (count int64, err error)
• func MeasureActiveQueries(ctx context.Context, interval time.Duration)
• func MeasureInProgressJobs(ctx context.Context, interval time.Duration)
• func MeasureQueueDepth(ctx context.Context, interval time.Duration)
• func PrepareAll(ctx context.Context) error

Functions

func DB

func DB(ctx context.Context, connector db.Connector, dbConns int) error

DB initializes a connection to the database, and prepares queries on all models. If connector is nil, db.DefaultConnection will be used.

func GetActiveQueries

func GetActiveQueries(ctx context.Context) (count int64, err error)

func MeasureActiveQueries

func MeasureActiveQueries(ctx context.Context, interval time.Duration)

TODO all of these should use a different database connection than the server or the worker, to avoid contention.

func MeasureInProgressJobs

func MeasureInProgressJobs(ctx context.Context, interval time.Duration)

func MeasureQueueDepth

func MeasureQueueDepth(ctx context.Context, interval time.Duration)

func PrepareAll

func PrepareAll(ctx context.Context) error