golazy.dev – golazy.dev / lazyjobs / inmemoryjobs Index | Files

package inmemoryjobs 

import "golazy.dev/lazyjobs/inmemoryjobs"

Package inmemoryjobs provides an in-memory lazyjobs backend.

Types

type Backend 

type Backend struct {
	// contains filtered or unexported fields
}
func New 
func New() *Backend
func (b *Backend) AdvanceSchedule 
func (b *Backend) AdvanceSchedule(_ context.Context, params lazyjobs.AdvanceScheduleParams) error
func (b *Backend) Claim 
func (b *Backend) Claim(_ context.Context, params lazyjobs.ClaimParams) (lazyjobs.Record, bool, error)
func (b *Backend) ClaimSchedule 
func (b *Backend) ClaimSchedule(_ context.Context, params lazyjobs.ClaimScheduleParams) (lazyjobs.ScheduleRecord, bool, error)
func (b *Backend) Complete 
func (b *Backend) Complete(_ context.Context, id int64) error
func (b *Backend) Discard 
func (b *Backend) Discard(_ context.Context, params lazyjobs.DiscardParams) error
func (b *Backend) HasActiveScheduledJob 
func (b *Backend) HasActiveScheduledJob(_ context.Context, params lazyjobs.ActiveScheduledJobParams) (bool, error)
func (b *Backend) Insert 
func (b *Backend) Insert(_ context.Context, params lazyjobs.InsertParams) (lazyjobs.Record, error)
func (b *Backend) List 
func (b *Backend) List(_ context.Context, options lazyjobs.ListOptions) ([]lazyjobs.Record, error)
func (b *Backend) ListSchedules 
func (b *Backend) ListSchedules(_ context.Context) ([]lazyjobs.ScheduleRecord, error)
func (b *Backend) RegisterSchedule 
func (b *Backend) RegisterSchedule(_ context.Context, params lazyjobs.ScheduleParams) (lazyjobs.ScheduleRecord, error)
func (b *Backend) Retry 
func (b *Backend) Retry(_ context.Context, params lazyjobs.RetryParams) error
func (b *Backend) Stats 
func (b *Backend) Stats(_ context.Context) (lazyjobs.Stats, error)