Method Start

lineage_worker.go:101–116

Start begins processing outbox entries in the background. The processor will poll for pending entries at the configured interval. Parameters: - ctx context.Context: The context for the operation. When cancelled, processing stops.

(ctx context.Context)

// Parameters:
// - ctx context.Context: The context for the operation. When cancelled, processing stops.
func (p *LineageOutboxProcessor) Start(ctx context.Context) {
	p.mu.Lock()
	if p.running {
		p.mu.Unlock()
		return
	}
	p.running = true
	p.stopCh = make(chan struct{})
	p.mu.Unlock()

	p.wg.Add(1)
	go func() {
		defer p.wg.Done()
		p.run(ctx)
	}()
}

// Stop gracefully stops the outbox processor.
// It signals the processor to stop and waits for pending work to complete.