async

type Config struct {
	Store        Store
	Handler      Handler
	Logger       ports.Logger
	Metrics      MetricsRecorder
	BatchSize    int
	Concurrency  int
	PollInterval time.Duration
}

type Event struct {
	Kind    string
	Outcome string
}

type Handler interface {
	Handle(ctx context.Context, job Job) error
}

type HandlerFunc func(context.Context, Job) error

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

type HandlerRoute struct {
	Kind    string
	Handler Handler
}

type Job struct {
	ID       string
	Kind     string
	TenantID string
	Payload  []byte
	Attempts int
}

type MetricsRecorder interface {
	ObserveAsyncJob(ctx context.Context, event Event)
}

type MetricsRecorderFunc func(context.Context, Event)

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

type Store interface {
	Lease(ctx context.Context, limit int) ([]Job, error)
	Complete(ctx context.Context, id string) error
	Fail(ctx context.Context, id string, message string) error
}