Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tasqueue

package module

Go to main page

Versions in this module

v2

v2.2.1

Jul 15, 2024

v2.2.0

Mar 14, 2024

Changes in this version

type Job

+ OnError []*Job

type Meta

+ OnSuccessIDs []string

v2.1.1

Nov 30, 2023

v2.1.0

Sep 20, 2023

v2.0.2

Sep 3, 2023

v2.0.1

Aug 14, 2023

Changes in this version

+ var ErrNotFound = errors.New("result not found")

type Results

+ NilError func() error

v2.0.0

Jun 8, 2023

Changes in this version

+ const DefaultQueue

+ const StatusDone

+ const StatusFailed

+ const StatusProcessing

+ const StatusRetrying

+ const StatusStarted

+ type Broker interface

+ Consume func(ctx context.Context, work chan []byte, queue string)

+ Enqueue func(ctx context.Context, msg []byte, queue string) error

+ EnqueueScheduled func(ctx context.Context, msg []byte, queue string, ts time.Time) error

+ GetPending func(ctx context.Context, queue string) ([]string, error)

+ type Chain struct

+ Jobs []Job

+ Opts ChainOpts

+ func NewChain(j []Job, opts ChainOpts) (Chain, error)

+ type ChainMessage struct

+ type ChainMeta struct

+ ID string

+ JobID string

+ PrevJobs []string

+ Status string

+ type ChainOpts struct

+ ID string

+ type Group struct

+ Jobs []Job

+ Opts GroupOpts

+ func NewGroup(j []Job, opts GroupOpts) (Group, error)

+ type GroupMessage struct

+ Group *Group

+ type GroupMeta struct

+ ID string

+ JobStatus map[string]string

+ Status string

+ type GroupOpts struct

+ ID string

+ type Job struct

+ OnSuccess *Job

+ Opts JobOpts

+ Payload []byte

+ Task string

+ func NewJob(handler string, payload []byte, opts JobOpts) (Job, error)

+ type JobCtx struct

+ Meta Meta

+ func (c JobCtx) Save(b []byte) error

+ type JobMessage struct

+ Job *Job

+ type JobOpts struct

+ ETA time.Time

+ ID string

+ MaxRetries uint32

+ Queue string

+ Schedule string

+ Timeout time.Duration

+ type Meta struct

+ ID string

+ MaxRetry uint32

+ OnSuccessID string

+ PrevErr string

+ PrevJobResult []byte

+ ProcessedAt time.Time

+ Queue string

+ Retried uint32

+ Schedule string

+ Status string

+ func DefaultMeta(opts JobOpts) Meta

+ type Results interface

+ DeleteJob func(ctx context.Context, id string) error

+ Get func(ctx context.Context, id string) ([]byte, error)

+ GetFailed func(ctx context.Context) ([]string, error)

+ GetSuccess func(ctx context.Context) ([]string, error)

+ Set func(ctx context.Context, id string, b []byte) error

+ SetFailed func(ctx context.Context, id string) error

+ SetSuccess func(ctx context.Context, id string) error

+ type Server struct

+ func NewServer(o ServerOpts) (*Server, error)

+ func (s *Server) DeleteJob(ctx context.Context, id string) error

+ func (s *Server) Enqueue(ctx context.Context, t Job) (string, error)

+ func (s *Server) EnqueueChain(ctx context.Context, c Chain) (string, error)

+ func (s *Server) EnqueueGroup(ctx context.Context, t Group) (string, error)

+ func (s *Server) GetChain(ctx context.Context, id string) (ChainMessage, error)

+ func (s *Server) GetFailed(ctx context.Context) ([]string, error)

+ func (s *Server) GetGroup(ctx context.Context, id string) (GroupMessage, error)

+ func (s *Server) GetJob(ctx context.Context, id string) (JobMessage, error)

+ func (s *Server) GetPending(ctx context.Context, queue string) ([]JobMessage, error)

+ func (s *Server) GetResult(ctx context.Context, id string) ([]byte, error)

+ func (s *Server) GetSuccess(ctx context.Context) ([]string, error)

+ func (s *Server) GetTasks() []string

+ func (s *Server) RegisterTask(name string, fn handler, opts TaskOpts)

+ func (s *Server) Start(ctx context.Context)

+ type ServerOpts struct

+ Broker Broker

+ Logger logf.Logger

+ Results Results

+ TraceProvider *trace.TracerProvider

+ type Task struct

+ type TaskOpts struct

+ Concurrency uint32

+ FailedCB func(JobCtx)

+ ProcessingCB func(JobCtx)

+ Queue string

+ RetryingCB func(JobCtx)

+ SuccessCB func(JobCtx)

Other modules containing this package

github.com/kalbhor/tasqueue