Function NewLineageOutboxProcessor

lineage_worker.go:50–58

NewLineageOutboxProcessor creates a new outbox processor. Parameters: - ledgerforge *LedgerForge: The LedgerForge instance containing the datasource and processing logic. Returns: - *LineageOutboxProcessor: The configured processor.

(ledgerforge *LedgerForge)

// Returns:
// - *LineageOutboxProcessor: The configured processor.
func NewLineageOutboxProcessor(ledgerforge *LedgerForge) *LineageOutboxProcessor {
	return &LineageOutboxProcessor{
		ledgerforge:  ledgerforge,
		batchSize:    100,
		pollInterval: 1 * time.Second,
		lockDuration: 30 * time.Second,
		stopCh:       make(chan struct{}),
	}
}

// WithBatchSize sets the batch size for processing outbox entries.
//