async

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

type JobHandler interface {
	HandleJob(context.Context, *jobs.Event) (any, error)
}

type PublishConfig struct {
	FS           afs.Service
	Notification xasync.Notification
}

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

type WatchConfig struct {
	JobURL       string
	FailedJobURL string
	MaxJobs      int
	PollInterval time.Duration
	// Error receives dispatch/post-processing failures. Concurrent workers may
	// report concurrently; the sink must be concurrency-safe.
	Error func(string, error)
}

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