This commit is contained in:
Raven Scott
2026-05-20 23:40:55 -04:00
parent be94546cd3
commit d89d6ec0b6
9 changed files with 185 additions and 0 deletions
@@ -71,6 +71,7 @@ Branches share buffer references; treat as trusted in-process only.
3. `readBranch('process')` consumes on worker tick. 3. `readBranch('process')` consumes on worker tick.
4. `close()` clears all branches on shutdown. 4. `close()` clears all branches on shutdown.
5. Use `pending(name)` to detect backlog before applying backpressure upstream. 5. Use `pending(name)` to detect backlog before applying backpressure upstream.
6. Monitor `getStats().written` vs branch `pending` for imbalance.
## See also ## See also
@@ -0,0 +1,23 @@
{
"scores": {
"df2fdf0fc4ad7dec75f5367805277f19e76b10847c837af48caa1bb7e26aef96": {
"score": 75,
"lastUpdated": 1779334819096,
"attestationsCount": 1
}
},
"history": {
"df2fdf0fc4ad7dec75f5367805277f19e76b10847c837af48caa1bb7e26aef96": [
{
"ts": 1779334819096,
"delta": 75,
"attester": "82d660b8f6829bddf91a9ad576e27cf49b5732b98d18184812cd00de041a88d3",
"signature": "1Zgt2jkqSTeqij8eHtyoney7fB1kjjyBHq+kHgozqrOcGX8OCXCJWYFAQ7GUQ/S8oWUNHgFMQgqsYMV8vtbGCg==",
"metadata": {
"context": "test"
}
}
]
},
"lastPersist": 1779334819159
}
@@ -0,0 +1,21 @@
{
"scores": {
"decay-peer": {
"score": 90,
"lastUpdated": 1779334819162,
"attestationsCount": 1
}
},
"history": {
"decay-peer": [
{
"ts": 1779334819162,
"delta": 100,
"attester": "24a9185bf43d980a6b950cb016459c4df04caf24fd2a7a7c97f2274c14fe9f42",
"signature": "dfKg7dgJF2dA98HiVK8OKy1wOqfbc7LlhyVTXLvtkwvtmj/4jp5iYraDn6MdeiX8B7ojJe8CSbxeLJ2MNyaDBQ==",
"metadata": {}
}
]
},
"lastPersist": 1779334819162
}
@@ -0,0 +1,5 @@
{
"scores": {},
"history": {},
"lastPersist": 1779334819094
}
@@ -0,0 +1,21 @@
{
"scores": {
"persist-peer": {
"score": 55,
"lastUpdated": 1779334819162,
"attestationsCount": 1
}
},
"history": {
"persist-peer": [
{
"ts": 1779334819162,
"delta": 55,
"attester": "26ea68631ce8fabc11c2af9dfbf7323c17b8f217933a56025ea2b65720b94ce1",
"signature": "/60wo7ifn784e+wIR8CZb28snjKH5noTQ7m5+wjQ8AcWpFizLvf6O+ggDWwR/6WgiBIBjbsbMuZkvA+D3NefCw==",
"metadata": {}
}
]
},
"lastPersist": 1779334819163
}
@@ -0,0 +1,35 @@
{
"scores": {
"peer1": {
"score": 100,
"lastUpdated": 1779334819160,
"attestationsCount": 1
},
"peer2": {
"score": 60,
"lastUpdated": 1779334819161,
"attestationsCount": 1
}
},
"history": {
"peer1": [
{
"ts": 1779334819160,
"delta": 100,
"attester": "43eba6fdec918444beffaac2c1789713b489aa2b5a912c0e4317849c6758a854",
"signature": "SXTffhCsn6j4XWNt/otsb318BkpdhSxwTvfCJ5ZL5HaPm0HErD2yS1SFA1GYIcjl/qZZHQBIYVZsi+vrMcGACw==",
"metadata": {}
}
],
"peer2": [
{
"ts": 1779334819161,
"delta": 60,
"attester": "43eba6fdec918444beffaac2c1789713b489aa2b5a912c0e4317849c6758a854",
"signature": "RsSP9T/pdVMADjQt9s189zYF0uR2Hng4TrALlOfq/8H6iTnAZwYHrYC99Niwvl/dsBXftYuxaDbrwmKRvLC1BA==",
"metadata": {}
}
]
},
"lastPersist": 1779334819161
}
@@ -0,0 +1,5 @@
{
"scores": {},
"history": {},
"lastPersist": 1779334819160
}
@@ -0,0 +1,37 @@
{
"scores": {
"snapshot-peer-1": {
"score": 120,
"lastUpdated": 1779334819164,
"attestationsCount": 1
},
"snapshot-peer-2": {
"score": 80,
"lastUpdated": 1779334819165,
"attestationsCount": 1
}
},
"history": {
"snapshot-peer-1": [
{
"ts": 1779334819164,
"delta": 120,
"attester": "adb4e9efa65491305179e3cd516a20ffd1432848676a4cd6d2f9cb162aeee56e",
"signature": "RHhjvxfRpcB7WnFVzUdrp1z3OFhYfJjNFvu5+Xqz5st1rIOG+D0pVFX0f72j6QyCs3g4M4RDdeLNTOA7oKVmAw==",
"metadata": {
"category": "reliability"
}
}
],
"snapshot-peer-2": [
{
"ts": 1779334819165,
"delta": 80,
"attester": "adb4e9efa65491305179e3cd516a20ffd1432848676a4cd6d2f9cb162aeee56e",
"signature": "AIK/MX3GRWnOwhJMsTMDebcT03d8rXMbgK+7sXUZ8JKLII79wRduOHxsg237xOIT/qJYxJHJKtR4G4R74PgWDw==",
"metadata": {}
}
]
},
"lastPersist": 1779334819165
}
@@ -0,0 +1,37 @@
{
"scores": {
"snapshot-peer-1": {
"score": 120,
"lastUpdated": 1779334819164,
"attestationsCount": 1
},
"snapshot-peer-2": {
"score": 80,
"lastUpdated": 1779334819165,
"attestationsCount": 1
}
},
"history": {
"snapshot-peer-1": [
{
"ts": 1779334819164,
"delta": 120,
"attester": "adb4e9efa65491305179e3cd516a20ffd1432848676a4cd6d2f9cb162aeee56e",
"signature": "RHhjvxfRpcB7WnFVzUdrp1z3OFhYfJjNFvu5+Xqz5st1rIOG+D0pVFX0f72j6QyCs3g4M4RDdeLNTOA7oKVmAw==",
"metadata": {
"category": "reliability"
}
}
],
"snapshot-peer-2": [
{
"ts": 1779334819165,
"delta": 80,
"attester": "adb4e9efa65491305179e3cd516a20ffd1432848676a4cd6d2f9cb162aeee56e",
"signature": "AIK/MX3GRWnOwhJMsTMDebcT03d8rXMbgK+7sXUZ8JKLII79wRduOHxsg237xOIT/qJYxJHJKtR4G4R74PgWDw==",
"metadata": {}
}
]
},
"lastPersist": 1779334819166
}