ionutboangiu 96c2a3acee Prevent deadlocks in file reader unit tests

2025-01-22 17:37:17 +01:00

..

amqp_it_test.go

Add reader id within the *vars in ERs

2024-08-09 09:14:24 +02:00

amqp_test.go

Add new unit tests on ees and ers

2024-08-09 09:18:46 +02:00

amqp.go

added StartDelay for ers processing

2024-11-15 20:58:10 +01:00

amqpv1_it_test.go

Add reader id within the *vars in ERs

2024-08-09 09:14:24 +02:00

amqpv1_test.go

…

amqpv1.go

added StartDelay for ers processing

2024-11-15 20:58:10 +01:00

ers_it_test.go

Add WHERE statement availability and non-delete option to ERS SQL reader

2024-12-03 18:36:22 +01:00

ers_reload_it_test.go

…

ers_test.go

Add WHERE statement availability and non-delete option to ERS SQL reader

2024-12-03 18:36:22 +01:00

ers.go

Add 'ees_ids' field to ERs readers config

2024-12-20 17:33:45 +01:00

filecsv_it_test.go

Prevent deadlocks in file reader unit tests

2025-01-22 17:37:17 +01:00

filecsv.go

added asynchronus startdelay for file readers and nats

2024-11-26 11:20:40 +01:00

filefwv_it_test.go

Prevent deadlocks in file reader unit tests

2025-01-22 17:37:17 +01:00

filefwv.go

added asynchronus startdelay for file readers and nats

2024-11-26 11:20:40 +01:00

filejson_it_test.go

Prevent deadlocks in file reader unit tests

2025-01-22 17:37:17 +01:00

filejson_test.go

…

filejson.go

added asynchronus startdelay for file readers and nats

2024-11-26 11:20:40 +01:00

filexml_it_test.go

Prevent deadlocks in file reader unit tests

2025-01-22 17:37:17 +01:00

filexml_test.go

…

filexml.go

added asynchronus startdelay for file readers and nats

2024-11-26 11:20:40 +01:00

flatstore_it_test.go

…

kafka_it_test.go

Add reader id within the *vars in ERs

2024-08-09 09:14:24 +02:00

kafka_test.go

…

kafka.go

added StartDelay for ers processing

2024-11-15 20:58:10 +01:00

lib_test.go

Add coverage tests on ers and config

2024-09-10 13:20:39 +02:00

libers.go

Add WaitGroup to ensure safe file processing in ERs

2025-01-21 19:30:33 +01:00

nats_it_test.go

Add ability to ERS to update or move ERS SQL events to a new table & add *export flag for ERS readers

2024-12-20 13:26:06 +01:00

nats_test.go

…

nats.go

added asynchronus startdelay for file readers and nats

2024-11-26 11:20:40 +01:00

partial_csv_it_test.go

…

reader.go

Add WHERE statement availability and non-delete option to ERS SQL reader

2024-12-03 18:36:22 +01:00

readers_test.go

Add WHERE statement availability and non-delete option to ERS SQL reader

2024-12-03 18:36:22 +01:00

s3_it_test.go

Add reader id within the *vars in ERs

2024-08-09 09:14:24 +02:00

s3_test.go

changed conReqs to not populate buffer at start

2024-04-24 17:09:54 +02:00

s3.go

added StartDelay for ers processing

2024-11-15 20:58:10 +01:00

sql_it_test.go

Add WHERE statement availability and non-delete option to ERS SQL reader

2024-12-03 18:36:22 +01:00

sql_test.go

…

sql.go

Add sqlBatchSize to ERS SQL OPTS and adjust delete functionality

2025-01-14 17:04:18 +01:00

sqs_it_test.go

Add reader id within the *vars in ERs

2024-08-09 09:14:24 +02:00

sqs_test.go

changed conReqs to not populate buffer at start

2024-04-24 17:09:54 +02:00

sqs.go

added StartDelay for ers processing

2024-11-15 20:58:10 +01:00