queue

package

v0.0.0-...-2965246 Latest Latest Go to latest Published: Aug 1, 2020 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jasontthai/tinyalias

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DispatchDetectSpamJob(qc *que.Client, url string) error
func DispatchExpirationJob(qc *que.Client) error
func DispatchParseGeoRequestJob(qc *que.Client, request ParseGeoRequest) error
func DispatchRemovePendingJob(qc *que.Client) error
func GetPgxPool(dbURL string) (*pgx.ConnPool, error)
func Setup(dbURL string) (*pgx.ConnPool, *que.Client, error)
type DetectSpamRequest
type ParseGeoRequest

Constants ¶

View Source

const (
	ParseGeoRequestJob = "ParseGeoRequestJob"
	DetectSpamJob      = "DetectSpamJob"
	ExpirationJob      = "ExpirationJob"
	RemovePendingJob   = "RemovePendingJob"
)

Variables ¶

This section is empty.

Functions ¶

func DispatchDetectSpamJob ¶

func DispatchDetectSpamJob(qc *que.Client, url string) error

DispatchDetectSpamJob dispatches a job to que-go to detect unsafe links. If url is empty, it will scan all urls

func DispatchExpirationJob ¶

func DispatchExpirationJob(qc *que.Client) error

func DispatchParseGeoRequestJob ¶

func DispatchParseGeoRequestJob(qc *que.Client, request ParseGeoRequest) error

func DispatchRemovePendingJob ¶

func DispatchRemovePendingJob(qc *que.Client) error

func GetPgxPool ¶

func GetPgxPool(dbURL string) (*pgx.ConnPool, error)

GetPgxPool based on the provided database URL

func Setup ¶

func Setup(dbURL string) (*pgx.ConnPool, *que.Client, error)

Setup a *pgx.ConnPool and *que.Client This is here so that setup routines can easily be shared between web and workers

Types ¶

type DetectSpamRequest ¶

type DetectSpamRequest struct {
	URL string `json:"url"`
}

type ParseGeoRequest ¶

type ParseGeoRequest struct {
	IP   string `json:"ip"`
	Slug string `json:"slug"`
}

Source Files ¶

View all Source files

queue.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL