diff options
author | alexv-smirnov <alex@ydb.tech> | 2024-01-19 14:58:06 +0300 |
---|---|---|
committer | alexv-smirnov <alex@ydb.tech> | 2024-01-19 15:19:16 +0300 |
commit | 5ad9230c8cc1de0dbd03cffca57a245b4fb28b54 (patch) | |
tree | 8369b898c8f7be653cda333f92629d3abc75cdd4 | |
parent | 43d5b5c64970eed529ec82a1e383ee6306469540 (diff) | |
download | ydb-5ad9230c8cc1de0dbd03cffca57a245b4fb28b54.tar.gz |
Update YT white list
-rw-r--r-- | yt/yt/flow/lib/client/public.h | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/yt/yt/flow/lib/client/public.h b/yt/yt/flow/lib/client/public.h new file mode 100644 index 0000000000..2fb42f2f1b --- /dev/null +++ b/yt/yt/flow/lib/client/public.h @@ -0,0 +1,39 @@ +#pragma once + +#include <yt/yt/core/misc/public.h> + +namespace NYT::NFlow { + +//////////////////////////////////////////////////////////////////////////////// + +/* + TODO(mikari): naming + Pipeline State + 1) Stopped - everything stopped and all internal queues is empty. + 2) Paused - everything stopped but some internal queues may not be empty. + 3) Working - usual work. + 4) Draining - preparing to stop pipeline. + Injection of new messages and trigger activation disabled, waiting for emptiness of internal queues. + 5) Pausing - preparing to pause pipeline. + 6) Completed - everything has been processed. +*/ +DEFINE_ENUM(EPipelineState, + ((Unknown) (0)) + ((Stopped) (1)) + ((Paused) (2)) + ((Working) (3)) + ((Draining) (4)) + ((Pausing) (5)) + ((Completed) (6)) +); + +//////////////////////////////////////////////////////////////////////////////// + +inline const TString PipelineFormatVersionAttribute("flow_pipeline_format_version"); +inline const TString LeaderControllerAddressAttribute("leader_controller_address"); + +constexpr int CurrentPipelineFormatVersion = 1; + +//////////////////////////////////////////////////////////////////////////////// + +} // namespace NYT::NFlow |