influxdb/task/backend
Lyon Hill 9d6b9555ac
feat(task): add functions to the task executor to allow for coordinator control (#15218)
We needed the coordinator to be able to execute manual runs and resume runs.
These two functions have been added, but we also needed to allow for the executor to be
mocked out. To do that we needed to return a Promise interface instead of an actual
struct. Both these changes are to facilitate coordinator work and testing.
2019-09-20 10:36:44 -06:00
..
coordinator refactor(tasks): separate coordinator and middleware (#14779) 2019-08-23 19:05:13 +00:00
executor feat(task): add functions to the task executor to allow for coordinator control (#15218) 2019-09-20 10:36:44 -06:00
middleware fix(alerts and notifications): updates latest completed when status goes from inactive->active 2019-09-06 17:36:16 -05:00
scheduler feat(task): Change interfaces defining scheduler and executor behavior 2019-09-11 17:02:28 -07:00
analytical_storage.go fix(task): Create tags using NewTags to ensure they are sorted 2019-09-04 15:25:44 -07:00
analytical_storage_test.go refactor(dependencies): use new dependency injection framework (#15174) 2019-09-19 17:01:17 +02:00
coordinator.go fix(task): fix panic when failing to update on startup (#14825) 2019-08-27 13:16:18 -06:00
coordinator_test.go fix(task): fix panic when failing to update on startup (#14825) 2019-08-27 13:16:18 -06:00
error_test.go chore: rename imports from platform to influxdb 2019-01-09 20:51:47 -08:00
read_table_test.go test(tasks): add test for ReadTable in analytical store (#14428) 2019-07-23 14:26:21 -07:00
scheduler.go fix(tasks): use influxdb errors in scheduler (#15145) 2019-09-16 13:55:39 -07:00
scheduler_metrics.go fix(tasks): use influxdb errors in scheduler (#15145) 2019-09-16 13:55:39 -07:00
scheduler_test.go fix(tasks): use influxdb errors in scheduler (#15145) 2019-09-16 13:55:39 -07:00
task.go feat(task): Create a new task executor for the new modular scheduler (#14252) 2019-07-08 08:13:29 -06:00
task_service_checkpointer.go feat(tasks): add last and checkpoint functions 2019-07-08 14:06:15 -07:00
task_service_checkpointer_test.go feat(tasks): add last and checkpoint functions 2019-07-08 14:06:15 -07:00