dactor-test-harness 0.3.3

Multi-process integration test harness for dactor actor framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138

syntax = "proto3";
package dactor.test.v1;

service TestNodeService {
    // Ping — verify the node is alive and the control channel works
    rpc Ping(PingRequest) returns (PingResponse);

    // Node info
    rpc GetNodeInfo(Empty) returns (NodeInfoResponse);

    // Shutdown
    rpc Shutdown(ShutdownRequest) returns (Empty);

    // Fault injection
    rpc InjectFault(FaultRequest) returns (Empty);
    rpc ClearFaults(Empty) returns (Empty);

    // Event subscription (server-streaming)
    rpc SubscribeEvents(EventFilter) returns (stream NodeEvent);

    // Custom application commands
    rpc CustomCommand(CustomRequest) returns (CustomResponse);

    // Actor management
    rpc SpawnActor(SpawnActorRequest) returns (SpawnActorResponse);
    rpc TellActor(TellActorRequest) returns (TellActorResponse);
    rpc AskActor(AskActorRequest) returns (AskActorResponse);
    rpc StopActor(StopActorRequest) returns (StopActorResponse);

    // Watch another actor — receive event when target stops
    rpc WatchActor(WatchActorRequest) returns (WatchActorResponse);
}

message Empty {}

message PingRequest {
    string echo = 1;
}

message PingResponse {
    string echo = 1;
    string node_id = 2;
    uint64 uptime_ms = 3;
}

message NodeInfoResponse {
    string node_id = 1;
    uint64 uptime_ms = 2;
    string adapter = 3;
    uint32 actor_count = 4;
}

message ShutdownRequest {
    bool graceful = 1;
    uint64 timeout_ms = 2;
}

message FaultRequest {
    string fault_type = 1;
    string target = 2;
    uint64 duration_ms = 3;
    uint32 count = 4;
    string detail = 5;
}

message EventFilter {
    repeated string event_types = 1;
}

message NodeEvent {
    string event_type = 1;
    string detail = 2;
    uint64 timestamp_ms = 3;
}

message CustomRequest {
    string command_type = 1;
    bytes payload = 2;
}

message CustomResponse {
    bytes payload = 1;
}

message SpawnActorRequest {
    string actor_type = 1;
    string actor_name = 2;
    bytes args = 3;
}

message SpawnActorResponse {
    bool success = 1;
    string actor_id = 2;
    string error = 3;
}

message TellActorRequest {
    string actor_name = 1;
    string message_type = 2;
    bytes payload = 3;
}

message TellActorResponse {
    bool success = 1;
    string error = 2;
}

message AskActorRequest {
    string actor_name = 1;
    string message_type = 2;
    bytes payload = 3;
    uint64 timeout_ms = 4;  // 0 = no timeout
}

message AskActorResponse {
    bool success = 1;
    bytes payload = 2;
    string error = 3;
}

message StopActorRequest {
    string actor_name = 1;
}

message StopActorResponse {
    bool success = 1;
    string error = 2;
}

message WatchActorRequest {
    string watcher_name = 1;   // the actor that will be notified
    string target_name = 2;    // the actor to watch
}

message WatchActorResponse {
    bool success = 1;
    string error = 2;
}