testenv

package

v0.3.0 Latest Latest Go to latest Published: Nov 10, 2026 License: MIT Imports: 15 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 Pause(ctx context.Context, v any, queueName string) error
func PostgresDSN(addr string) string
func Ready(ctx context.Context, v any) error
func Resume(ctx context.Context, v any, queueName string) error
func SelectedBackends(envValue string) map[string]bool
func Snapshot(ctx context.Context, v any, collector *queue.StatsCollector) (queue.StatsSnapshot, error)
func SupportsNativeStats(v any) bool
func SupportsPause(v any) 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"
	BackendTemporal   = "temporal"
)

View Source

const TemporalServerImage = "temporalio/temporal@sha256:2c344b4a39b4489fc6944db095f628f0c30659836faf11780a4dc435599e80e3"

TemporalServerImage pins the qualified CLI/server image for proofs and public-driver acceptance.

Variables ¶

View Source

var ExternalBackends = []string{
	BackendTemporal,
	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 Pause ¶ added in v0.1.12

func Pause(ctx context.Context, v any, queueName string) error

func PostgresDSN ¶

func PostgresDSN(addr string) string

func Ready ¶ added in v0.1.12

func Ready(ctx context.Context, v any) error

func Resume ¶ added in v0.1.12

func Resume(ctx context.Context, v any, queueName string) error

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.

func Snapshot ¶ added in v0.1.12

func Snapshot(ctx context.Context, v any, collector *queue.StatsCollector) (queue.StatsSnapshot, error)

func SupportsNativeStats ¶ added in v0.1.12

func SupportsNativeStats(v any) bool

func SupportsPause ¶ added in v0.1.12

func SupportsPause(v any) bool

Types ¶

type Runtime ¶

type Runtime interface {
	Driver() queue.Driver
	WithContext(ctx context.Context) Runtime
	Dispatch(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