Versions in this module Expand all Collapse all v0 v0.1.1 Jun 25, 2026 v0.1.0 Jun 25, 2026 Changes in this version + const StatusDone + const StatusFailed + const StatusQueued + const StatusRetried + const StatusRunning + type Filter struct + Limit int + Queue string + Since time.Time + Status string + Type string + type Job struct + Attempts int + Duration int64 + Error string + Finished *time.Time + ID string + Payload any + Queue string + Queued time.Time + Started *time.Time + Status string + Type string + type QueueStat struct + AvgMs int64 + Done int + Failed int + FailureRate float64 + Queue string + Queued int + Running int + Total int + type Service struct + func FromKernel(k *togo.Kernel) (*Service, bool) + func (s *Service) Delete(id string) bool + func (s *Service) Get(id string) (Job, bool) + func (s *Service) Jobs(f Filter) []Job + func (s *Service) RecordDispatch(queue, jobType string, payload any) string + func (s *Service) Retry(ctx context.Context, id string) error + func (s *Service) Stats() []QueueStat + func (s *Service) Wrap(queue, jobType string, h togo.QueueHandler) togo.QueueHandler
Go to main page