queueservice

type CallbackError struct {
	// Operation identifies the callback boundary.
	Operation CallbackOperation
	// Err is the original callback failure.
	Err error
}

type CallbackOperation uint8

type CallbackPanicError struct {
	// Operation identifies the callback boundary.
	Operation CallbackOperation
}

type Check[R any] func(context.Context, R) error

type CloseAdmission[R any] func(R) error

type Handler func(context.Context, core.TaskMessage) error

type HandlerOptions struct {
	// Correlation creates a new request ID for every delivery attempt.
	Correlation *correlation.Factory
	// CorrelationOptions configure the existing queue propagation adapter.
	CorrelationOptions queuecorrelation.Options
	// TrustedMetadata preserves inbound correlation only when explicitly true.
	TrustedMetadata bool
	// TracePropagator explicitly extracts caller-owned telemetry context when
	// configured. Nil disables trace propagation.
	TracePropagator propagation.TextMapPropagator
	// Handler performs application-owned work.
	Handler Handler
}

type LifecycleWorker[R any] struct {
	// contains filtered or unexported fields
}

type LifecycleWorkerOptions[R any] struct {
	// Name is the secret-safe component, task, and readiness name.
	Name string
	// Resource is the caller-constructed concrete worker.
	Resource R
	// Correlation creates a new request ID for every delivery attempt.
	Correlation *correlation.Factory
	// CorrelationOptions configure the existing queue propagation adapter.
	CorrelationOptions queuecorrelation.Options
	// TrustedMetadata preserves inbound correlation only when explicitly true.
	TrustedMetadata bool
	// TracePropagator explicitly extracts caller-owned telemetry context when
	// configured. Nil disables trace propagation.
	TracePropagator propagation.TextMapPropagator
	// Handler performs application-owned work.
	Handler Handler
	// Startup optionally validates Resource before intake can run.
	Startup Startup[R]
	// Readiness optionally checks Resource after successful startup.
	Readiness Check[R]
	// CloseAdmission stops backend intake when service drain begins. The adapter
	// independently rejects handler calls after the callback starts.
	CloseAdmission CloseAdmission[R]
	// Run starts intake and joins admitted handlers before returning.
	Run Run[R]
	// Shutdown stops remaining transport work and closes Resource exactly once.
	Shutdown Shutdown[R]
}

type OptionsError struct {
	// Field identifies the rejected option.
	Field string
	// Reason describes the safe failure category.
	Reason string
}

type Producer[R any] struct {
	// contains filtered or unexported fields
}

type ProducerOptions[R any] struct {
	// Name is the secret-safe component name.
	Name string
	// Resource is the caller-constructed concrete producer.
	Resource R
	// Correlation creates message-hop identifiers.
	Correlation *correlation.Factory
	// CorrelationOptions configure the existing queue propagation adapter.
	CorrelationOptions queuecorrelation.Options
	// TracePropagator explicitly injects caller-owned telemetry context when
	// configured. Nil disables trace propagation.
	TracePropagator propagation.TextMapPropagator
	// Startup optionally validates Resource before admission begins.
	Startup Startup[R]
	// Readiness optionally checks Resource after successful startup.
	Readiness Check[R]
	// Publish performs one concrete, caller-bounded append. A returned error has
	// unknown backend acceptance. Prefer PublishWithAcceptance when the backend
	// can distinguish a definite rejection from an ambiguous result.
	Publish Publish[R]
	// PublishWithAcceptance performs one concrete append with an explicit
	// backend-acceptance result. Exactly one publish callback is required.
	PublishWithAcceptance PublishWithAcceptance[R]
	// Shutdown transfers transport close ownership when non-nil.
	Shutdown Shutdown[R]
}

type Publish[R any] func(
	context.Context,
	R,
	core.QueuedMessage,
	...job.AllowOption,
) error

type PublishAcceptance uint8

type PublishError struct {
	// Acceptance describes whether the task reached the backend.
	Acceptance PublishAcceptance
	// Err is the original classifiable failure.
	Err error
}

type PublishWithAcceptance[R any] func(
	context.Context,
	R,
	core.QueuedMessage,
	...job.AllowOption,
) (PublishAcceptance, error)

type Run[R any] func(context.Context, R, Handler) error

type Shutdown[R any] func(context.Context, R) error

type Startup[R any] func(context.Context, R) error

type StartupError struct {
	// Validation is the startup-check failure.
	Validation error
	// Cleanup is an optional transferred-resource shutdown failure.
	Cleanup error
}

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

type WorkerOptions struct {
	// Name is the secret-safe component name.
	Name string
	// Queue is the caller-constructed concrete queue.
	Queue *queue.Queue
}