tasqueue

package module

Go to main page

Versions in this module

v1

v1.4.0

Jun 6, 2023

Changes in this version

type Chain

+ Opts ChainOpts

+ type ChainOpts struct

+ UUID string

type Group

+ Opts GroupOpts

+ type GroupOpts struct

+ UUID string

type JobOpts

+ UUID string

v1.3.0

Jun 5, 2023

Changes in this version

type Broker

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

type Results

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

type Server

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

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

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

v1.2.0

May 8, 2023

Changes in this version

type JobOpts

+ Timeout time.Duration

type Meta

+ PrevJobResult []byte

v1.1.0

Oct 10, 2022

v1.0.0

Sep 2, 2022

Changes in this version

type Job

+ Opts JobOpts

v0

v0.4.0

Sep 1, 2022

Changes in this version

type ServerOpts

+ Broker Broker

+ Logger logf.Logger

+ Results Results

+ TraceProvider *trace.TracerProvider

v0.3.0

Aug 1, 2022

Changes in this version

type Results

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

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

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

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

type Server

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

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

v0.2.0

Jul 18, 2022

Changes in this version

type Meta

+ PrevJobResults []byte

+ func DefaultMeta(opts JobOpts) Meta

type TaskOpts

+ Concurrency uint32

+ Queue string

v0.1.0

May 31, 2022

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

+ type Chain struct

+ Jobs []Job

+ func NewChain(j ...Job) (Chain, error)

+ type ChainMessage struct

+ Chain *Chain

+ type ChainMeta struct

+ JobUUID string

+ PrevJobs []string

+ Status string

+ UUID string

+ type ConcurrencyOpt uint32

+ func (c ConcurrencyOpt) Name() string

+ func (c ConcurrencyOpt) Value() interface{}

+ type CustomMaxRetry uint32

+ func (c CustomMaxRetry) Name() string

+ func (c CustomMaxRetry) Value() interface{}

+ type CustomQueue string

+ func (c CustomQueue) Name() string

+ func (c CustomQueue) Value() interface{}

+ type CustomSchedule string

+ func (c CustomSchedule) Name() string

+ func (c CustomSchedule) Value() interface{}

+ type FailedCB func(JobCtx)

+ func (c FailedCB) Name() string

+ func (c FailedCB) Value() interface{}

+ type Group struct

+ Jobs []Job

+ func NewGroup(j ...Job) (Group, error)

+ type GroupMessage struct

+ Group *Group

+ type GroupMeta struct

+ JobStatus map[string]string

+ Status string

+ UUID string

+ type Job struct

+ OnSuccess *Job

+ 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

+ MaxRetries uint32

+ Queue string

+ Schedule string

+ type Meta struct

+ MaxRetry uint32

+ OnSuccessUUID string

+ PrevErr string

+ ProcessedAt time.Time

+ Queue string

+ Retried uint32

+ Schedule string

+ Status string

+ UUID string

+ type Opts interface

+ Name func() string

+ Value func() interface{}

+ func Concurrency(val uint32) Opts

+ func FailedCallback(f func(JobCtx)) Opts

+ func MaxRetry(val uint32) Opts

+ func ProcessingCallback(f func(JobCtx)) Opts

+ func Queue(name string) Opts

+ func RetryingCallback(f func(JobCtx)) Opts

+ func Schedule(spec string) Opts

+ func SuccessCallback(f func(JobCtx)) Opts

+ type ProcessingCB func(JobCtx)

+ func (c ProcessingCB) Name() string

+ func (c ProcessingCB) Value() interface{}

+ type Results interface

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

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

+ type RetryingCB func(JobCtx)

+ func (c RetryingCB) Name() string

+ func (c RetryingCB) Value() interface{}

+ type Server struct

+ func NewServer(b Broker, r Results, opts ServerOpts) (*Server, 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, uuid string) (ChainMessage, error)

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

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

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

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

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

+ type ServerOpts struct

+ Concurrency uint32

+ Queue string

+ type SuccessCB func(JobCtx)

+ func (c SuccessCB) Name() string

+ func (c SuccessCB) Value() interface{}

+ type Task struct

+ type TaskOpts struct

+ FailedCB func(JobCtx)

+ ProcessingCB func(JobCtx)

+ RetryingCB func(JobCtx)

+ SuccessCB func(JobCtx)

Other modules containing this package

github.com/kalbhor/tasqueue/v2

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