aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoralexv-smirnov <alex@ydb.tech>2024-01-19 14:58:06 +0300
committeralexv-smirnov <alex@ydb.tech>2024-01-19 15:19:16 +0300
commit5ad9230c8cc1de0dbd03cffca57a245b4fb28b54 (patch)
tree8369b898c8f7be653cda333f92629d3abc75cdd4
parent43d5b5c64970eed529ec82a1e383ee6306469540 (diff)
downloadydb-5ad9230c8cc1de0dbd03cffca57a245b4fb28b54.tar.gz
Update YT white list
-rw-r--r--yt/yt/flow/lib/client/public.h39
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