Method WithLockDuration

lineage_worker.go:91–94

WithLockDuration sets the lock duration for claimed entries. Parameters: - duration time.Duration: The lock duration. Returns: - *LineageOutboxProcessor: The processor for chaining.

(duration time.Duration)

// Returns:
// - *LineageOutboxProcessor: The processor for chaining.
func (p *LineageOutboxProcessor) WithLockDuration(duration time.Duration) *LineageOutboxProcessor {
	p.lockDuration = duration
	return p
}

// Start begins processing outbox entries in the background.
// The processor will poll for pending entries at the configured interval.