Method ProcessTestData

src/input/input.go:549–558

ProcessTestData processes test data through the input component's normal data flow This ensures test data goes through the same processing as production data

(data map[string]interface{})

// ProcessTestData processes test data through the input component's normal data flow
// This ensures test data goes through the same processing as production data
func (in *Input) ProcessTestData(data map[string]interface{}) {
	// Only increment total count - same as production logic
	atomic.AddUint64(&in.consumeTotal, 1)

	// Skip sampling in testing mode - not needed for test scenarios

	in.dispatchMessage(in.prepareMessage(data))

	logger.Debug("Test data processed through input", "input", in.Id, "downstream_count", in.DownstreamCount())
}

func (in *Input) prepareMessage(msg map[string]interface{}) map[string]interface{} {
	if msg == nil {