tasks

package

v0.0.0-...-df5dda6 Latest Latest Go to latest Published: Jan 16, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

View Source

const (
	ConversionRetryInterval = 2 * time.Minute
)

View Source

const (
	DeliveryRetryInterval = 2 * time.Minute
)

This section is empty.

This section is empty.

type Context struct {
	Config tenso.Configuration
	DB     *gorp.DbMap
	// contains filtered or unexported fields
}

Context holds things used by the various task implementations in this package.

func NewContext(cfg tenso.Configuration, db *gorp.DbMap) *Context

func (c *Context) ConversionJob(registerer prometheus.Registerer) jobloop.Job

func (c *Context) DeliveryJob(registerer prometheus.Registerer) jobloop.Job

func (c *Context) GarbageCollectionJob(registerer prometheus.Registerer) jobloop.Job

func (c *Context) OverrideTimeNow(now func() time.Time) *Context

OverrideTimeNow is used by unit tests to inject a mock clock.