Versions in this module Expand all Collapse all v1 v1.1.5 Jun 8, 2026 v1.1.4 Jun 8, 2026 Changes in this version + func Start(ctx context.Context, eng *engine.Engine, queue JobQueue, queues []string) + type DBQueue struct + func NewDBQueue(dbMgr *dbmanager.DBManager, connName string) *DBQueue + func (q *DBQueue) Close() error + func (q *DBQueue) Pop(ctx context.Context, queues []string) (string, []byte, error) + func (q *DBQueue) Push(ctx context.Context, queue string, payload []byte) error + type JobPayload struct + CreatedAt time.Time + Data map[string]interface{} + ScriptPath string + type JobQueue interface + Close func() error + Pop func(ctx context.Context, queues []string) (string, []byte, error) + Push func(ctx context.Context, queue string, payload []byte) error
Go to main page