Nia Weiss 7734bcd53c change ID allocation to return a structured error on offset desync ... This is used to handle a possible case where a kafka partition is moved to another ingester while a previous ingester is still processing it, causing 2 ingesters to process it at the same time. This allows a duplicate ingester to skip past messages which have already been ingested.		2021-04-06 10:39:22 -04:00
..
client.go	Comment Status function	2021-03-03 23:47:47 +01:00
client_test.go	Add at least 3 nodes on test clusters.	2021-03-26 10:16:41 +01:00
error.go	Fix linter issues: vet	2018-07-19 11:37:50 -05:00
handler.go	change ID allocation to return a structured error on offset desync	2021-04-06 10:39:22 -04:00
handler_internal_test.go	Revert "back out the pql.Decimal changes"	2020-04-01 17:46:46 -05:00
handler_test.go	remove port_mapper because it can't work with our unrestartable server	2021-02-24 11:25:46 -06:00
translator.go	don't reuse sync.Mutex between translate readers	2021-03-08 17:04:52 -06:00
translator_test.go	Review skipped tests, and try to execute them again.	2021-03-30 13:37:33 +02:00