job

type AllowOption struct {
	// RetryCount is additional attempts; nil selects zero.
	RetryCount *int64 // Maximum retry attempts (nil uses default: 0)
	// RetryDelay is fixed delay; nil/zero selects exponential backoff.
	RetryDelay *time.Duration // Fixed delay between retries (nil uses exponential backoff)
	// RetryFactor is backoff multiplier; nil selects two.
	RetryFactor *float64 // Backoff multiplier (nil uses default: 2)
	// RetryMin is initial backoff duration; nil selects 100ms.
	RetryMin *time.Duration // Minimum backoff delay (nil uses default: 100ms)
	// RetryMax is backoff cap; nil selects 10s.
	RetryMax *time.Duration // Maximum backoff delay (nil uses default: 10s)
	// Jitter enables randomized backoff; nil selects false.
	Jitter *bool // Enable backoff jitter (nil uses default: false)
	// Timeout is the total cooperative execution budget; nil selects 60 minutes.
	Timeout *time.Duration // Job execution timeout (nil uses default: 60 minutes)
	// Metadata is cloned from the first option; nil means no operational identity.
	Metadata *Metadata // Optional bounded identity propagated to operational records
}

type Message struct {
	// Task is an in-process callback omitted from the wire envelope.
	Task TaskFunc `json:"-" msgpack:"-"`

	// Timeout is the positive total handler/retry budget; constructors default
	// to 60 minutes. Timeout signals cancellation, not forced completion.
	Timeout time.Duration `json:"timeout" msgpack:"timeout"`

	// Body is borrowed application payload, base64-encoded in JSON.
	Body []byte `json:"body" msgpack:"body"`

	// RetryCount is remaining additional handler attempts, from zero to 100.
	// The scheduler decrements it; broker redelivery counts are separate.
	RetryCount int64 `json:"retry_count" msgpack:"retry_count"`

	// RetryDelay is a nonnegative fixed retry delay; default zero selects backoff.
	RetryDelay time.Duration `json:"retry_delay" msgpack:"retry_delay"`

	// RetryFactor is the multiplying factor for each increment step.
	//
	// Defaults to 2.
	RetryFactor float64 `json:"retry_factor" msgpack:"retry_factor"`

	// RetryMin is the initial backoff duration when RetryDelay is zero.
	//
	// Defaults to 100 milliseconds.
	RetryMin time.Duration `json:"retry_min" msgpack:"retry_min"`

	// RetryMax caps backoff durations when RetryDelay is zero.
	//
	// Defaults to 10 seconds.
	RetryMax time.Duration `json:"retry_max" msgpack:"retry_max"`

	// Jitter eases contention by randomizing backoff steps
	Jitter bool `json:"jitter" msgpack:"jitter"`

	// Metadata is optional bounded identity retained for operational records.
	Metadata *Metadata `json:"metadata,omitempty" msgpack:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type Metadata struct {
	// OriginalID is optional application identity, distinct from backend source identity.
	OriginalID string `json:"original_id,omitempty" msgpack:"original_id,omitempty"`
	// PayloadSchemaVersion identifies an application schema this package does not validate.
	PayloadSchemaVersion string `json:"payload_schema_version,omitempty" msgpack:"payload_schema_version,omitempty"`
	// ContentType is optional claimed media type, not verified content.
	ContentType string `json:"content_type,omitempty" msgpack:"content_type,omitempty"`
	// EnqueuedAt is an optional nonzero time; nil means unknown.
	EnqueuedAt *time.Time `json:"enqueued_at,omitempty" msgpack:"enqueued_at,omitempty"`
	// RetryPolicy is optional policy identity, not executable retry configuration.
	RetryPolicy string `json:"retry_policy,omitempty" msgpack:"retry_policy,omitempty"`
	// HandlerType is an optional handler label, not serialized code.
	HandlerType string `json:"handler_type,omitempty" msgpack:"handler_type,omitempty"`
	// JobType is optional application job identity.
	JobType string `json:"job_type,omitempty" msgpack:"job_type,omitempty"`
	// Tags contains mutable bounded dimensions; values are not automatically redacted.
	Tags map[string]string `json:"tags,omitempty" msgpack:"tags,omitempty"`
	// TraceID is claimed trace identity, not authenticated evidence.
	TraceID string `json:"trace_id,omitempty" msgpack:"trace_id,omitempty"`
	// TenantID is claimed tenancy metadata, not access enforcement.
	TenantID string `json:"tenant_id,omitempty" msgpack:"tenant_id,omitempty"`
	// ProducerVersion identifies the producing application when known.
	ProducerVersion string `json:"producer_version,omitempty" msgpack:"producer_version,omitempty"`
	// Correlation is a mutable bounded transport carrier, not authenticated identity.
	Correlation map[string]string `json:"correlation,omitempty" msgpack:"correlation,omitempty"`
	// TraceContext is a mutable telemetry carrier bounded by count and total bytes.
	TraceContext map[string]string `json:"trace_context,omitempty" msgpack:"trace_context,omitempty"`
}

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

type TaskFunc func(context.Context) error