Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

tache

package module

Go to main page

Versions in this module

v0

v0.2.2

Dec 9, 2025

v0.2.1

Nov 7, 2025

v0.2.0

Jun 30, 2025

Changes in this version

+ const StateBeforeRetry

+ const StateCanceled

+ const StateCanceling

+ const StateErrored

+ const StateFailed

+ const StateFailing

+ const StatePending

+ const StateRunning

+ const StateSucceeded

+ const StateWaitingRetry

+ func IsRecoverable(err error) bool

+ func NewErr(msg string) error

+ func Unrecoverable(err error) error

+ type Base struct

+ ID string

+ MaxRetry int

+ Retry int

+ State State

+ func (b *Base) Cancel()

+ func (b *Base) Ctx() context.Context

+ func (b *Base) CtxDone() <-chan struct{}

+ func (b *Base) GetErr() error

+ func (b *Base) GetID() string

+ func (b *Base) GetProgress() float64

+ func (b *Base) GetRetry() (int, int)

+ func (b *Base) GetState() State

+ func (b *Base) Persist()

+ func (b *Base) SetCancelFunc(cancelFunc context.CancelFunc)

+ func (b *Base) SetCtx(ctx context.Context)

+ func (b *Base) SetErr(err error)

+ func (b *Base) SetID(id string)

+ func (b *Base) SetPersist(persist func())

+ func (b *Base) SetProgress(progress float64)

+ func (b *Base) SetRetry(retry int, maxRetry int)

+ func (b *Base) SetState(state State)

+ type Info interface

+ GetName func() string

+ GetStatus func() string

+ type Manager struct

+ func NewManager[T Task](opts ...Option) *Manager[T]

+ func (m *Manager[T]) Add(task T)

+ func (m *Manager[T]) Cancel(id string)

+ func (m *Manager[T]) CancelAll()

+ func (m *Manager[T]) CancelByCondition(condition func(task T) bool)

+ func (m *Manager[T]) GetAll() []T

+ func (m *Manager[T]) GetByCondition(condition func(task T) bool) []T

+ func (m *Manager[T]) GetByID(id string) (T, bool)

+ func (m *Manager[T]) GetByState(state ...State) []T

+ func (m *Manager[T]) Pause()

+ func (m *Manager[T]) Remove(id string)

+ func (m *Manager[T]) RemoveAll()

+ func (m *Manager[T]) RemoveByCondition(condition func(task T) bool)

+ func (m *Manager[T]) RemoveByState(state ...State)

+ func (m *Manager[T]) Retry(id string)

+ func (m *Manager[T]) RetryAllFailed()

+ func (m *Manager[T]) SetWorkersNumActive(active int64)

+ func (m *Manager[T]) Start()

+ func (m *Manager[T]) Wait()

+ type OnBeforeRetry interface

+ OnBeforeRetry func()

+ type OnFailed interface

+ OnFailed func()

+ type OnSucceeded interface

+ OnSucceeded func()

+ type Option func(*Options)

+ func WithLogger(logger *slog.Logger) Option

+ func WithMaxRetry(maxRetry int) Option

+ func WithOptions(opts Options) Option

+ func WithPersistDebounce(debounce time.Duration) Option

+ func WithPersistFunction(r func() ([]byte, error), w func([]byte) error) Option

+ func WithPersistPath(path string) Option

+ func WithRunning(running bool) Option

+ func WithTimeout(timeout time.Duration) Option

+ func WithWorks(works int) Option

+ type Options struct

+ Logger *slog.Logger

+ MaxRetry int

+ PersistDebounce *time.Duration

+ PersistPath string

+ PersistReadFunction func() ([]byte, error)

+ PersistWriteFunction func([]byte) error

+ Running bool

+ Timeout *time.Duration

+ Works int

+ func DefaultOptions() *Options

+ type Persistable interface

+ Persistable func() bool

+ type Recoverable interface

+ Recoverable func() bool

+ type Retryable interface

+ Retryable func() bool

+ type State int

+ type TacheError struct

+ Msg string

+ func (e *TacheError) Error() string

+ type Task interface

+ Run func() error

+ type TaskBase interface

+ Cancel func()

+ Ctx func() context.Context

+ CtxDone func() <-chan struct{}

+ GetErr func() error

+ GetID func() string

+ GetProgress func() float64

+ GetRetry func() (int, int)

+ GetState func() State

+ Persist func()

+ SetCancelFunc func(cancelFunc context.CancelFunc)

+ SetCtx func(ctx context.Context)

+ SetErr func(err error)

+ SetID func(id string)

+ SetPersist func(persist func())

+ SetProgress func(progress float64)

+ SetRetry func(retry int, maxRetry int)

+ SetState func(state State)

+ type TaskWithInfo interface

+ type Worker struct

+ ID int

+ func (w Worker[T]) Execute(task T)

+ type WorkerPool struct

+ func NewWorkerPool[T Task](size int) *WorkerPool[T]

+ func (wp *WorkerPool[T]) Get() *Worker[T]

+ func (wp *WorkerPool[T]) Put(worker *Worker[T])

+ func (wp *WorkerPool[T]) SetNumActive(active int64)