testenv

package

v0.1.6 Latest Latest Go to latest Published: Mar 16, 2026 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/goforj/queue

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func BackendEnabled(envValue, name string) bool
func MySQLDSN(addr string) string
func NewQueue(cfg any, opts ...queue.Option) (*queue.Queue, error)
func PostgresDSN(addr string) string
func SelectedBackends(envValue string) map[string]bool
type Runtime
- func NewQueueRuntime(cfg any) (Runtime, error)
- func WithWorkers(r Runtime, count int) Runtime

Constants ¶

View Source

const (
	BackendNull       = "null"
	BackendSync       = "sync"
	BackendWorkerpool = "workerpool"
	BackendSQLite     = "sqlite"
	BackendRedis      = "redis"
	BackendMySQL      = "mysql"
	BackendPostgres   = "postgres"
	BackendNATS       = "nats"
	BackendSQS        = "sqs"
	BackendRabbitMQ   = "rabbitmq"
)

Variables ¶

View Source

var ExternalBackends = []string{
	BackendRedis,
	BackendMySQL,
	BackendPostgres,
	BackendNATS,
	BackendSQS,
	BackendRabbitMQ,
}

View Source

var LocalBackends = []string{
	BackendNull,
	BackendSync,
	BackendWorkerpool,
	BackendSQLite,
}

Functions ¶

func BackendEnabled ¶

func BackendEnabled(envValue, name string) bool

func MySQLDSN ¶

func MySQLDSN(addr string) string

func NewQueue ¶

func NewQueue(cfg any, opts ...queue.Option) (*queue.Queue, error)

func PostgresDSN ¶

func PostgresDSN(addr string) string

func SelectedBackends ¶

func SelectedBackends(envValue string) map[string]bool

SelectedBackends returns the enabled backend set for INTEGRATION_BACKEND. When unset or "all", all known backends are enabled.

Types ¶

type Runtime ¶

type Runtime interface {
	Driver() queue.Driver
	Dispatch(job any) error
	DispatchCtx(ctx context.Context, job any) error
	Register(jobType string, handler queue.Handler)
	StartWorkers(ctx context.Context) error
	Shutdown(ctx context.Context) error
}

func NewQueueRuntime ¶

func NewQueueRuntime(cfg any) (Runtime, error)

func WithWorkers ¶

func WithWorkers(r Runtime, count int) Runtime

Source Files ¶

View all Source files

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