Method IsRunning

lineage_worker.go:138–142

IsRunning returns whether the processor is currently running. Returns: - bool: True if the processor is running.

()

// Returns:
// - bool: True if the processor is running.
func (p *LineageOutboxProcessor) IsRunning() bool {
	p.mu.Lock()
	defer p.mu.Unlock()
	return p.running
}

// run is the main processing loop.
func (p *LineageOutboxProcessor) run(ctx context.Context) {