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

torch

package

Go to main page

Versions in this module

v0

v0.34.4

Mar 12, 2024

v0.34.3

Feb 20, 2024

v0.34.2

Feb 19, 2024

v0.34.1

Sep 8, 2023

v0.34.0

Jun 12, 2023

Changes in this version

+ func Hash(input string) string

+ func StringComputer(inField, outField string, fn func(ctx *Context, in string) (T, error)) func(ctx *Context) error

+ func StringHasher(field string) func(model coal.Model) string

+ func Test(store *coal.Store, operation *Operation, fn func(env Env))

+ type Check struct

+ Handler func(ctx *Context) error

+ Interval time.Duration

+ Jitter float64

+ Model coal.Model

+ Name string

+ func (c *Check) Deadline() time.Time

+ type Computation struct

+ Computer func(ctx *Context) error

+ Hasher func(model coal.Model) string

+ KeepOutdated bool

+ Model coal.Model

+ Name string

+ RecomputeInterval time.Duration

+ RehashInterval time.Duration

+ Releaser func(ctx *Context) error

+ type Context struct

+ AsyncContext *axe.Context

+ Check *Check

+ Computation *Computation

+ Defer bool

+ Model coal.Model

+ Operation *Operation

+ Progress func(factor float64) error

+ Queue *axe.Queue

+ Reactor *Reactor

+ Store *coal.Store

+ Sync bool

+ Update bson.M

+ func (c *Context) Change(op, key string, val interface{})

+ type Env struct

+ Operation *Operation

+ Queue *axe.Queue

+ Reactor *Reactor

+ func (e *Env) Process(model coal.Model) error

+ func (e *Env) Scan() (int, error)

+ type Operation struct

+ Filter func(model coal.Model) bool

+ MaxDeferDelay time.Duration

+ Model coal.Model

+ Name string

+ ProcessLifetime time.Duration

+ ProcessTimeout time.Duration

+ Processor func(ctx *Context) error

+ Query func() bson.M

+ ScanBatch int

+ Sync bool

+ TagExpiry time.Duration

+ TagName string

+ func CheckField(check Check) *Operation

+ func CheckTag(check Check) *Operation

+ func Compute(comp Computation) *Operation

+ func (o *Operation) Validate() error

+ type ProcessJob struct

+ Model coal.ID

+ Operation string

+ func NewProcessJob(operation string, model coal.ID) *ProcessJob

+ func (j *ProcessJob) Validate() error

+ type Reactor struct

+ func NewReactor(store *coal.Store, queue *axe.Queue, operations ...*Operation) *Reactor

+ func (r *Reactor) Check(ctx context.Context, model coal.Model) error

+ func (r *Reactor) Modifier() *fire.Callback

+ func (r *Reactor) ProcessTask() *axe.Task

+ func (r *Reactor) ScanTask() *axe.Task

+ type Registry struct

+ func NewRegistry(operations ...*Operation) *Registry

+ type ScanJob struct

+ Operation string

+ func NewScanJob(operation string) *ScanJob

+ func (j *ScanJob) Validate() error

+ type Status struct

+ Hash string

+ Progress float64

+ Updated time.Time

+ Valid bool