lazyapp PublicPath ViewsPath MustSub App New App.ListenAndServe App.ServeHTTP Config Helpers RobotsConfig RobotsRule SitemapAlternate SitemapConfig SitemapSource SitemapSourceFunc SitemapSourceFunc.SitemapURLs SitemapURL lazyassets LazyDevAssetsPath RegisterLazyDevHandlers Asset Asset.Open AssetOption AssetSource ContentType ReplaceAsset CachePolicy Manifest OpenFunc Option WithBaseURL WithCSSURLRewrite WithCachePolicies WithDevelopmentMode WithHashLength WithMaxAssetSize WithOversizePolicy WithURLPrefix Options OversizePolicy Registry New Registry.Add Registry.AddFS Registry.AddReader Registry.Empty Registry.Handler Registry.Helpers Registry.Integrity Registry.Manifest Registry.MustPath Registry.Path Registry.ServeHTTP Registry.Unpack Registry.Upload Source SourceFunc SourceFunc.Assets SourceOption Replace SourceName UnpackMode UnpackOption WithUnpackMode UploadOption WithUploadMode WithUploadPrefix WithoutUploadManifest lazybuildinfo LazyDevBuildInfoPath RegisterLazyDevHandlers lazycache LazyDevCacheEntryPath LazyDevCacheEventsPath LazyDevCacheOffPath LazyDevCacheOnPath LazyDevCachePath ErrMiss BuildVersionFromContext Get Key PrometheusCollector RegisterLazyDevHandlers Set WithBuildVersion WithCache WritePrometheus Backend Cache FromContext New Cache.Enabled Cache.Entries Cache.Entry Cache.Get Cache.Keys Cache.Off Cache.On Cache.Set Cache.Stats Cache.Subscribe EntryDetail EntryInfo EntryInspector Event EventKind KeyLister Options Stats lazycache/inmemorycache New Algorithm Cache Cache.Entries Cache.Entry Cache.Get Cache.Keys Cache.Set Cache.Stats Options lazyconfig Getenv MustGetenv Option RemoveEnvNamePrefix lazycontroller LazyDevOpenEditorPath DefaultViews DetailErrors Error ErrorHandler LazyDevContext PanicError RegisterFormat RegisterFormatSuffix RegisterLazyDevHandlers ReportController ReportError ResetResponse StatusCode WasResponseSent WithDetailErrors WithErrorPages WithFormat WithOpenEditorPath WithPathFor WithRenderer WriteError WriteErrorDetail WriteErrorFallback WriteErrorPage WriteFile Base NewBase Base.Alternate Base.Author Base.BindRequest Base.Cache Base.CacheKey Base.CacheKeyF Base.Canonical Base.ContentType Base.Decode Base.Description Base.Format Base.HandleError Base.Header Base.Helper Base.Helpers Base.Is Base.IsGIF Base.IsHTML Base.IsImage Base.IsJPEG Base.IsJSON Base.IsPNG Base.IsSSE Base.IsTurboFrame Base.IsTurboStream Base.JSONLD Base.Kind Base.Language Base.LastUpdated Base.Layout Base.Locale Base.Metadata Base.MustPathFor Base.NoLayout Base.OpenGraph Base.OpenGraphType Base.PathFor Base.PublishedTime Base.Redirect Base.RedirectBack Base.RedirectBackOrTo Base.RedirectTo Base.Render Base.RenderHTML Base.RenderSVGString Base.RenderTurboFrame Base.Request Base.ResetRequest Base.Respond Base.ReturnFile Base.SEO Base.SEOImage Base.SEOImageAlt Base.SSEStream Base.SchemaType Base.ServeErrorPage Base.Set Base.SetLater Base.SetTurboFrameOptions Base.SetWhenNeeded Base.Status Base.Title Base.TwitterCard Base.TwitterCardType Base.Type Base.URL Base.URLFrom Base.Variants Base.Wants BeforeAction Format FormatFromContentType FormatFromRequest FormatFromSuffix NewFormat FormatOption As Suffix Formats HTTPError HTTPError.Error HTTPError.Unwrap PathForFunc Renderer NewRenderer RendererFromContext RequestBinder RequestResetter Responses URLParams Valuer lazycontrolplane Builder Config Config.BuildControlPlane ControlPlane New ControlPlane.AddReadinessCheck ControlPlane.BuildControlPlane ControlPlane.EnablePprof ControlPlane.Handle ControlPlane.Handler ControlPlane.HandlesPath ControlPlane.ServeHTTP ControlPlane.StandaloneHandler ReadinessCheck lazycookie ErrMacInvalid DecodeMulti EncodeMulti GenerateRandomKey Codec CodecsFromPairs Error GobEncoder GobEncoder.Deserialize GobEncoder.Serialize JSONEncoder JSONEncoder.Deserialize JSONEncoder.Serialize MultiError MultiError.Cause MultiError.Error MultiError.IsDecode MultiError.IsInternal MultiError.IsUsage NopEncoder NopEncoder.Deserialize NopEncoder.Serialize SecureCookie New SecureCookie.BlockFunc SecureCookie.Decode SecureCookie.Encode SecureCookie.HashFunc SecureCookie.MaxAge SecureCookie.MaxLength SecureCookie.MinAge SecureCookie.SetSerializer Serializer lazydeps LazyDevDependenciesPath LazyDevDependencyShutdownEventsPath LazyDevDependencyShutdownPath RegisterLazyDevHandlers Edge Func Graph LazyDevOption WithLazyDevRuntime LazyDevRuntime LazyDevShutdownNode LazyDevShutdownState Option WithLogger Ref Service Ref.Use Scope New Scope.Context Scope.Graph Scope.SetContext Scope.Shutdown lazydispatch ApplyETag MethodNotAllowed ReleaseBufferedResponseWriter BufferedResponseWriter AcquireBufferedResponseWriter NewBufferedResponseWriter BufferedResponseWriter.Flush BufferedResponseWriter.Header BufferedResponseWriter.Reset BufferedResponseWriter.StartStream BufferedResponseWriter.Unwrap BufferedResponseWriter.WasResponseSent BufferedResponseWriter.Write BufferedResponseWriter.WriteHeader Dispatcher NewDispatcher Dispatcher.Handler Dispatcher.ServeHTTP Dispatcher.Use Middleware ETag Public ResponseBuffer RouteOnly Router Static MiddlewareFunc MiddlewareFunc.Handler MiddlewareFunc.MiddlewareName RouteHandler lazydispatch/middlewares CrossOriginProtection DynamicRoute MethodOverride MethodOverrideWithLimit OriginalMethod lazydoc Example Func Index LoadDir LoadJSON LoadJSONBytes Index.Latest Index.Search Index.Version Package LoadPackagesFromDir Package.Slug Package.Symbol SearchResult Source Type Value Version Version.Package lazyerrors New Frame Frame.String lazyfiles RolePrimary RoleMirror RoleLegacy StatusActive File Filename Files Files.Find Files.Handler Files.Open Files.Put Files.URL Location Metadata ObjectKey Query Repository StorageName StoredFile lazyfiles/jsonl JSONLRepository New JSONLRepository.Delete JSONLRepository.Find JSONLRepository.Put lazyforms Helpers Field FieldOption FieldAttr FieldClass FieldData FieldID FieldLabel FieldPlaceholder FieldType FieldValue Form Form.Field NumericID Option FormAction FormAddClass FormAttr FormClass FormData FormFile FormID FormMethod FormModel FormMultipart FormRoute FormScope Resource Router StringID lazyjobs ControlJobsPath DefaultQueue ErrNoWork RegisterControlPlaneHandlers RegisterLazyDevHandlers WithRunner Backend BaseJob BaseJob.JobMaxAttempts BaseJob.JobQueue BaseJob.JobRetryDelay ClaimParams Config Definition DiscardParams InsertParams Job JobRunner New RunnerFromContext JobRunner.Definitions JobRunner.Enqueue JobRunner.EnqueueAt JobRunner.EnqueueIn JobRunner.MustRegister JobRunner.Register JobRunner.Running JobRunner.Snapshot JobRunner.Start JobRunner.Stop ListOptions QueueNamer Record RetryParams RetryPolicy Snapshot State Stats lazyjobs/inmemoryjobs Backend New Backend.Claim Backend.Complete Backend.Discard Backend.Insert Backend.List Backend.Retry Backend.Stats lazymailer MustParseAddress ParseAddress Recipients WithContext Address Base NewBase Base.Build Base.Mail Base.Set Defaults Delivery DeliveryFunc DeliveryFunc.Deliver Mailer FromContext New MemoryDelivery MemoryDelivery.Deliver MemoryDelivery.Messages Message Message.Bytes Options Registry NewRegistry Registry.Deliver SMTPDelivery SMTPDelivery.Deliver lazymedia StatusReady StatusGenerating StatusFailed File FileStore Media Media.URL Media.Variant OutputFilename Processor ProcessorFunc ProcessorFunc.Process Regenerate Repository Request Result Source Spec Variant VariantKey lazymedia/jsonl JSONLRepository New JSONLRepository.DeleteVariant JSONLRepository.FindVariant JSONLRepository.SaveVariant lazymigrate Backend BackendMigration Catalog Catalog.Add Catalog.LoadMigrations Catalog.Sources Config Direction FS ForDatabase FS.LoadMigrations Migration Migrator New Migrator.Apply Migrator.Down Migrator.DumpSchema Migrator.List Migrator.LoadSchema Migrator.PlanDown Migrator.PlanRedo Migrator.PlanUp Migrator.Redo Migrator.Setup Migrator.Up Plan Plan.Empty Source SourceFunc SourceFunc.LoadMigrations State Status Step lazymigrate/fakemigrator Backend New Backend.DumpSchema Backend.List Backend.LoadSchema Backend.Run Backend.Runs Backend.Setup Backend.SetupCount Run lazypath AppendURLParams URLParams SplitValues lazyroutes LazyDevRoutesPath Handle RegisterLazyDevHandlers Action ModelRoutes Resource Resource.Delete Resource.Get Resource.MemberDelete Resource.MemberGet Resource.MemberPatch Resource.MemberPost Resource.MemberPut Resource.Model Resource.Param Resource.Patch Resource.Path Resource.Plural Resource.Post Resource.Put Resource.Resources Resource.Singular Route RouteFromContext RouteFromRequest RouteTable Scope New Scope.As Scope.Delete Scope.Get Scope.HandleFunc Scope.HandlesPath Scope.ModelRoutesFor Scope.Namespace Scope.Patch Scope.Path Scope.PathFor Scope.PathForModel Scope.Post Scope.Put Scope.RegisterHelpers Scope.Resources Scope.ServeHTTP lazyroutes/actioncall Options Plan Compile Plan.Call lazyschema FieldID FieldIDFor FieldName FieldNameFor FormatTime ModelName ModelNameForType ConversionError ConversionError.Error Converter Decoder NewDecoder Decoder.Decode Decoder.IgnoreUnknownKeys Decoder.MaxDepth Decoder.MaxKeyLength Decoder.MaxKeys Decoder.MaxSize Decoder.MaxValuesPerKey Decoder.RegisterConverter Decoder.SetAliasTag Decoder.ZeroEmpty EmptyFieldError EmptyFieldError.Error Encoder NewEncoder Encoder.Encode Encoder.RegisterEncoder Encoder.SetAliasTag MultiError MultiError.Error NameConflictError NameConflictError.Error NameOption WithPrefix Path PathFor UnknownKeyError UnknownKeyError.Error lazyseo WebPage WebSite Article BlogPosting NewsArticle Product Profile Book Video MusicSong MusicAlbum Place Restaurant Organization DefaultJSONLD Helpers Alternate Meta New Set OpenGraph Option AlternateLink AlternateURL Author Canonical Description Image ImageAlt JSONLD Kind Language LastUpdated Locale OpenGraphData OpenGraphType PublishedTime SchemaType SiteName Title TwitterCardData TwitterCardType Type URL UpdatedTime PageKind TwitterCard lazyseo/jsonld SchemaOrg Date Article NewArticle BreadcrumbList NewBreadcrumbList ImageObject NewImageObject ListItem NewListItem Organization NewOrganization Person NewPerson WebPage NewWebPage WebSite NewWebSite lazysession NewCookie Save WithManager Config Config.Enabled CookieStore NewCookieStore CookieStore.Get CookieStore.MaxAge CookieStore.New CookieStore.Save FilesystemStore NewFilesystemStore FilesystemStore.Get FilesystemStore.MaxAge FilesystemStore.MaxLength FilesystemStore.New FilesystemStore.Save Manager ManagerFromContext NewManager Manager.Get Manager.Handler Manager.Name Manager.Store MultiError MultiError.Error Options Registry GetRegistry Registry.Get Registry.Save Session Get NewSession Session.AddFlash Session.Flashes Session.Name Session.Save Session.Store Store lazysse Serve Event Option Header Status Source Stream Start Stream.Close Stream.Comment Stream.Context Stream.Done Stream.Heartbeat Stream.JSON Stream.LastEventID Stream.Send Stream.Subscribe SubscribeOptions Subscription lazystorage Take ValidateKey CacheControl ContentDisposition ContentType Deleter DownloadName Event Events ExpiresAt ExpiresIn File Filesystem NewFilesystem Filesystem.Delete Filesystem.List Filesystem.Open Filesystem.Put Filesystem.URL FilesystemOption WithBaseURL Info Iterator Lister Private Public Storage URL URLer Watcher Writer lazystorage/s3 Option WithBucket WithCredentials WithEndpoint WithHTTPClient WithPublicBaseURL WithRegion WithSessionToken Storage New Storage.Delete Storage.EnsureBucket Storage.List Storage.Open Storage.Put Storage.URL Storage.Watch lazysupport/inflection Default Camelize Dasherize ForeignKey Irregular Ordinal Ordinalize Pluralize Singularize Tableize Underscorize Inflector Inflector.Camelize Inflector.Irregular Inflector.Pluralize Inflector.Singularize Inflector.Underscorize lazytelemetry LazyDevRequestMonitoringOffPath LazyDevRequestMonitoringOnPath LazyDevRequestMonitoringPath LazyDevRequestTracesClearPath LazyDevRequestTracesPath EnvironmentMiddleware Logger MetricLabels Middleware MiddlewareFromConfig NewLogger RegisterLazyDevHandlers RequestID RequestMonitoringEnabled SetRequestMonitoringEnabled SpanFromContext SpanID StartRegion StartSpan TraceID WithLogAttrs WithLogGroup WithLogTags WithLogger WithMetricLabels WithRequestID BatchLogRecordProcessorConfig BatchSpanProcessorConfig Config LoadConfig MustLoadConfig Config.Enabled Config.JSONLogs Config.PrometheusMetrics Duration Duration.Duration Duration.UnmarshalText ExporterConfig MiddlewareOption WithMetricsRegistry WithMiddlewareLogger OTLPExporterConfig PrometheusExporterConfig RequestMonitoringSnapshot RequestMonitoringState ZipkinExporterConfig lazytelemetry/lazylogs Debug Error Info LogAttrs Logger NewJSONLogger NewTextLogger Warn WithAttrs WithGroup WithLogger WithTags lazytelemetry/lazymetrics PrometheusHandler WithLabels WritePrometheus Counter Counter.Add Counter.Inc CounterVec CounterVec.With CounterVec.WithLabelValues Gauge Gauge.Add Gauge.Set GaugeVec GaugeVec.With GaugeVec.WithLabelValues Histogram Histogram.Observe HistogramBucketSnapshot HistogramSnapshot HistogramVec HistogramVec.With HistogramVec.WithLabelValues Labels LabelsFromContext MetricSnapshot PrometheusCollector Registry NewRegistry Registry.NewCounter Registry.NewGauge Registry.NewHistogram Registry.Snapshot Snapshot lazytelemetry/lazytracing ClearAllocationSamples Log RequestID SpanID TraceID WithAllocationSampling WithRequestID WithTraceContext AllocationSummary SpanAllocationSummary Event Span SpanFromContext StartRegion StartSpan Span.AddAttributes Span.AddEvent Span.Attributes Span.Children Span.Duration Span.End Span.EndedAt Span.Error Span.Events Span.GoroutineID Span.Name Span.ParentID Span.RecordError Span.SpanID Span.StartedAt Span.TraceID TraceContext ParseTraceparent TraceContextFromContext lazytest App FromHandler New App.Check App.Client App.Do App.Get App.GetPath App.PathFor App.Post App.PostForm App.Routes Case Client Client.Cookies Client.Do Client.Get Client.Post Client.PostForm Client.SetCookie Option WithRouter RequestOption Accept BasicAuth Cookie Cookies Header Response Response.BodyBytes Response.BodyString Response.Contains Response.ContentType Response.Cookies Response.Header Response.HeaderContains Response.HeaderEquals Response.JSON Response.Match Response.MethodNotAllowed Response.NotContains Response.NotFound Response.OK Response.Status lazytui lazytui/encoding/ansi Append CSIToken ControlToken Decoder Decoder.Decode Decoder.Reset Encoder Encoder.Encode EscapeToken HyperlinkToken MouseToken OSCTerminator OSCToken Op CSI CSIWithPrefix Control CursorBack CursorDown CursorForward CursorPosition CursorUp DisableMouse EnableMouse EndHyperlink EraseDisplay EraseLine Escape Hyperlink OSC Print RequestWindowSize SGR Sequence WindowSizeReport WindowTitle Param PrintToken Token UnknownToken WindowSizeToken WindowTitleToken lazytui/encoding/ansi/codes CUU CUD CUF CUB CNL CPL CHA CUP ED EL SU SD HVP SM RM SGRFinal MouseX10 MouseNormal MouseButtonEvent MouseAnyEvent MouseSGR OSCSetIconAndTitle OSCSetIconName OSCSetWindowTitle OSCHyperlink Reset Bold Faint Italic Underline Blink Inverse Conceal CrossedOut NormalIntensity NoItalic NoUnderline NoBlink Positive Reveal NotCrossedOut DefaultFg DefaultBg Framed Encircled Overline NoFrameCircle NoOverline Control SGR Bg256 BgRGB Fg256 FgRGB lazytui/encoding/tty ErrInvalidSize ErrNilBackend ErrNilTransport ErrUnknownState ErrUnsupported Backend Client NewClient Client.IsTerminal Client.MakeRaw Client.Resize Client.Restore Client.Size Decoder NewDecoder Decoder.DecodeRequest Decoder.DecodeResponse Device NewDevice Open Device.IsTerminal Device.MakeRaw Device.Resize Device.Restore Device.Size Encoder NewEncoder Encoder.EncodeRequest Encoder.EncodeResponse Op Request Response Server NewServer Server.RoundTrip Server.Serve Size Size.String Size.Valid State StateID Transport lazytui/examples/twoshells lazytui/progress New Run Func Cmd CmdWarn Mise MiseWarn TaskDefinition Parallel Task UITask Tasks UI UI.Run UI.Stderr UI.Stdin UI.Stdout UI.Takeover Warn Warn.Error Warn.Unwrap lazytui/pty ErrInvalidCommand ErrNotStarted ErrAlreadyStarted Cmd Command CommandContext Cmd.Master Cmd.Process Cmd.Resize Cmd.Run Cmd.Start Cmd.Wait lazytui/window ErrInvalidGeometry Rect SplitSideBySide Rect.Size lazyturbo StreamMIME AcceptsStream Frame FrameID FrameTag Helpers IsFrameRequest IsPrefetch ValidateFrameID FrameOption Action Autoscroll AutoscrollBehavior AutoscrollBlock Busy Complete Disabled Loading Recurse Refresh RefreshMorph Src Target lazyview RegisterEngine CacheClearer CacheContext CacheableEngine Context Context.Helper Context.HelperFuncs Context.Helpers Engine EngineFactory Fragment Helper Options Route Views New Views.AddHelpers Views.Cache Views.Helper Views.Render Views.RenderString lazyview/gotmpl Engine Engine.Cache Engine.ClearCache Engine.Render pg Open OpenEnv pg/pgjobs Migrations Backend New Backend.Claim Backend.Complete Backend.Discard Backend.Insert Backend.List Backend.Retry Backend.Stats pg/pgmigrate ErrSchemaUnsupported Backend New Backend.DumpSchema Backend.List Backend.LoadSchema Backend.Run Backend.Setup pg/withpg Test WithPg Config DB Start DB.Client DB.Close DB.URL pg/withpg/cmd/withpg

import "golazy.dev/lazyjobs"

const ControlJobsPath = "/jobs"

const DefaultQueue = "default"

var ErrNoWork = errors.New("lazyjobs: no work")

func RegisterControlPlaneHandlers(controlPlane *lazycontrolplane.ControlPlane, runner *JobRunner)

func RegisterLazyDevHandlers(controlPlane *lazycontrolplane.ControlPlane, runner *JobRunner)

func WithRunner(ctx context.Context, runner *JobRunner) context.Context

type Backend interface {
	Insert(context.Context, InsertParams) (Record, error)
	Claim(context.Context, ClaimParams) (Record, bool, error)
	Complete(context.Context, int64) error
	Retry(context.Context, RetryParams) error
	Discard(context.Context, DiscardParams) error
	List(context.Context, ListOptions) ([]Record, error)
	Stats(context.Context) (Stats, error)
}

type BaseJob struct{}

func (BaseJob) JobMaxAttempts() int

func (BaseJob) JobQueue() string

func (BaseJob) JobRetryDelay(attempt int, _ error) time.Duration

type ClaimParams struct {
	Queues	[]string
	Now	time.Time
}

type Config struct {
	Backend		Backend
	Define		func(*JobRunner)
	Workers		int
	PollInterval	time.Duration
	Queues		[]string
}

type Definition struct {
	Kind		string	`json:"kind"`
	Type		string	`json:"type"`
	Queue		string	`json:"queue"`
	MaxAttempts	int	`json:"max_attempts"`
}

type DiscardParams struct {
	ID		int64
	LastError	string
}

type InsertParams struct {
	Kind		string
	Queue		string
	Payload		json.RawMessage
	MaxAttempts	int
	RunAt		time.Time
}

type Job interface {
	Kind() string
	Work(context.Context) error
}

type JobRunner struct {
	// contains filtered or unexported fields
}

func New(config Config) (*JobRunner, error)

func RunnerFromContext(ctx context.Context) (*JobRunner, bool)

func (r *JobRunner) Definitions() []Definition

func (r *JobRunner) Enqueue(ctx context.Context, job Job) (Record, error)

func (r *JobRunner) EnqueueAt(ctx context.Context, job Job, runAt time.Time) (Record, error)

func (r *JobRunner) EnqueueIn(ctx context.Context, job Job, delay time.Duration) (Record, error)

func (r *JobRunner) MustRegister(prototype Job)

func (r *JobRunner) Register(prototype Job) error

func (r *JobRunner) Running() bool

func (r *JobRunner) Snapshot(ctx context.Context) (Snapshot, error)

func (r *JobRunner) Start(ctx context.Context)

func (r *JobRunner) Stop(ctx context.Context) error

type ListOptions struct {
	Limit int
}

type QueueNamer interface {
	JobQueue() string
}

type Record struct {
	ID		int64		`json:"id"`
	Kind		string		`json:"kind"`
	Queue		string		`json:"queue"`
	Payload		json.RawMessage	`json:"-"`
	State		State		`json:"state"`
	Attempt		int		`json:"attempt"`
	MaxAttempts	int		`json:"max_attempts"`
	RunAt		time.Time	`json:"run_at"`
	CreatedAt	time.Time	`json:"created_at"`
	UpdatedAt	time.Time	`json:"updated_at"`
	LastError	string		`json:"last_error,omitempty"`
}

type RetryParams struct {
	ID		int64
	RunAt		time.Time
	LastError	string
}

type RetryPolicy interface {
	JobMaxAttempts() int
	JobRetryDelay(attempt int, err error) time.Duration
}

type Snapshot struct {
	Running		bool		`json:"running"`
	Definitions	[]Definition	`json:"definitions"`
	Stats		Stats		`json:"stats"`
	Recent		[]Record	`json:"recent"`
}

type State string

type Stats struct {
	Total	int		`json:"total"`
	ByState	map[State]int	`json:"by_state"`
	ByKind	map[string]int	`json:"by_kind"`
	ByQueue	map[string]int	`json:"by_queue"`
}