dactor 0.3.1

An abstract framework for distributed actors in Rust
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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166

// dactor system message protobuf schemas.
//
// These define the binary wire format for all system-level messages exchanged
// between nodes. Application messages remain pluggable via MessageSerializer.
//
// ⚠️  WIRE PROTOCOL — field numbers are frozen once released.
// Adding new fields is safe (use the next available number).
// Removing or renumbering existing fields breaks compatibility.

syntax = "proto3";

package dactor.system;

// ---------------------------------------------------------------------------
// Shared types
// ---------------------------------------------------------------------------

message ActorIdProto {
    string node_id = 1;
    uint64 local = 2;
}

// ---------------------------------------------------------------------------
// Spawn
// ---------------------------------------------------------------------------

message SpawnRequestProto {
    string type_name = 1;
    bytes args_bytes = 2;
    string name = 3;
    string request_id = 4;
}

message SpawnResponseProto {
    oneof result {
        SpawnSuccessProto success = 1;
        SpawnFailureProto failure = 2;
    }
}

message SpawnSuccessProto {
    string request_id = 1;
    ActorIdProto actor_id = 2;
}

message SpawnFailureProto {
    string request_id = 1;
    string error = 2;
}

// ---------------------------------------------------------------------------
// Watch / Unwatch
// ---------------------------------------------------------------------------

message WatchRequestProto {
    ActorIdProto target = 1;
    ActorIdProto watcher = 2;
}

message UnwatchRequestProto {
    ActorIdProto target = 1;
    ActorIdProto watcher = 2;
}

message WatchNotificationProto {
    ActorIdProto terminated = 1;
    ActorIdProto watcher = 2;
}

// ---------------------------------------------------------------------------
// Cancel
// ---------------------------------------------------------------------------

message CancelRequestProto {
    ActorIdProto target = 1;
    // Optional: only present when cancelling a specific request.
    // Omitted when cancelling all operations for the target actor.
    optional string request_id = 2;
}

message CancelResponseProto {
    oneof result {
        CancelAcknowledgedProto acknowledged = 1;
        CancelNotFoundProto not_found = 2;
    }
}

message CancelAcknowledgedProto {}

message CancelNotFoundProto {
    string reason = 1;
}

// ---------------------------------------------------------------------------
// Peer management
// ---------------------------------------------------------------------------

message ConnectPeerProto {
    string node_id = 1;
    optional string address = 2;
}

message DisconnectPeerProto {
    string node_id = 1;
}

// ---------------------------------------------------------------------------
// Handshake (version compatibility)
// ---------------------------------------------------------------------------

message HandshakeRequestProto {
    string node_id = 1;
    string wire_version = 2;
    optional string app_version = 3;
    string adapter = 4;
}

enum RejectionReasonProto {
    REJECTION_REASON_INCOMPATIBLE_PROTOCOL = 0;
    REJECTION_REASON_INCOMPATIBLE_ADAPTER = 1;
}

message HandshakeResponseProto {
    oneof result {
        HandshakeAcceptedProto accepted = 1;
        HandshakeRejectedProto rejected = 2;
    }
}

message HandshakeAcceptedProto {
    string node_id = 1;
    string wire_version = 2;
    optional string app_version = 3;
    string adapter = 4;
}

message HandshakeRejectedProto {
    string node_id = 1;
    string wire_version = 2;
    RejectionReasonProto reason = 3;
    string detail = 4;
}

// ---------------------------------------------------------------------------
// WireEnvelope framing
// ---------------------------------------------------------------------------

enum SendModeProto {
    SEND_MODE_TELL = 0;
    SEND_MODE_ASK = 1;
    SEND_MODE_EXPAND = 2;
    SEND_MODE_REDUCE = 3;
    SEND_MODE_TRANSFORM = 4;
}

message WireEnvelopeProto {
    ActorIdProto target = 1;
    string target_name = 2;
    string message_type = 3;
    SendModeProto send_mode = 4;
    map<string, bytes> headers = 5;
    bytes body = 6;
    // Must be RFC 4122 UUID format if present (e.g. "550e8400-e29b-41d4-a716-446655440000").
    optional string request_id = 7;
    optional uint32 version = 8;
}