ingestionqueue

type Delivery ¶

type Delivery struct {
	Job
	OwnerID string
	Token   string
	Request ingestion.Request
}

type Ingest ¶

type Ingest func(context.Context, string, ingestion.Request) (string, error)

type Job ¶

type Job = ingestion.Job

type Queue ¶

type Queue interface {
	Accept(context.Context, string, ingestion.Request) (Job, error)
	Get(context.Context, string, string) (Job, error)
	Claim(context.Context, time.Duration) (Delivery, error)
	Renew(context.Context, Delivery, time.Duration) error
	Complete(context.Context, Delivery, string) error
	Retry(context.Context, Delivery, time.Time, string) error
	Fail(context.Context, Delivery, string) error
}

Queue guarantees durable, idempotent acceptance and fenced job transitions. Completed jobs retain their identity even when the observation is deleted. An external broker adapter must atomically persist scheduling intent (outbox).