Skip to content

Commit 394d5be

Browse files
committed
Moved into private space
1 parent 3003be6 commit 394d5be

File tree

1 file changed

+20
-19
lines changed

1 file changed

+20
-19
lines changed

ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h

Lines changed: 20 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -42,25 +42,6 @@
4242
namespace NYql {
4343
namespace NDq {
4444

45-
struct TEvPrivate {
46-
enum EEv : ui32 {
47-
EvRuntimeError = EventSpaceBegin(NActors::TEvents::ES_PRIVATE),
48-
EvEnd
49-
};
50-
51-
static_assert(EvEnd < EventSpaceEnd(NActors::TEvents::ES_PRIVATE), "expect EvEnd < EventSpaceEnd(TEvents::ES_PRIVATE)");
52-
53-
struct TEvAsyncOutputError : public NActors::TEventLocal<TEvAsyncOutputError, EvRuntimeError> {
54-
TEvAsyncOutputError(NYql::NDqProto::StatusIds::StatusCode statusCode, const TIssues& issues)
55-
: StatusCode(statusCode)
56-
, Issues(issues)
57-
{}
58-
59-
NYql::NDqProto::StatusIds::StatusCode StatusCode;
60-
NYql::TIssues Issues;
61-
};
62-
};
63-
6445
struct TSinkCallbacks : public IDqComputeActorAsyncOutput::ICallbacks {
6546
void OnAsyncOutputError(ui64 outputIndex, const TIssues& issues, NYql::NDqProto::StatusIds::StatusCode fatalCode) override final {
6647
OnSinkError(outputIndex, issues, fatalCode);
@@ -117,6 +98,26 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
11798
, public TSinkCallbacks
11899
, public TOutputTransformCallbacks
119100
{
101+
private:
102+
struct TEvPrivate {
103+
enum EEv : ui32 {
104+
EvRuntimeError = EventSpaceBegin(NActors::TEvents::ES_PRIVATE),
105+
EvEnd
106+
};
107+
108+
static_assert(EvEnd < EventSpaceEnd(NActors::TEvents::ES_PRIVATE), "expect EvEnd < EventSpaceEnd(TEvents::ES_PRIVATE)");
109+
110+
struct TEvAsyncOutputError : public NActors::TEventLocal<TEvAsyncOutputError, EvRuntimeError> {
111+
TEvAsyncOutputError(NYql::NDqProto::StatusIds::StatusCode statusCode, const TIssues& issues)
112+
: StatusCode(statusCode)
113+
, Issues(issues)
114+
{}
115+
116+
NYql::NDqProto::StatusIds::StatusCode StatusCode;
117+
NYql::TIssues Issues;
118+
};
119+
};
120+
120121
protected:
121122
enum EEvWakeupTag : ui64 {
122123
TimeoutTag = 1,

0 commit comments

Comments
 (0)