nooschain / consensus/adapters/raft/http-raft-transport / HttpRaftTransport
Class: HttpRaftTransport
Defined in: consensus/adapters/raft/http-raft-transport.ts:36
RaftTransport implementation backed by authenticated HTTP POST messages.
Implements
Constructors
Constructor
new HttpRaftTransport(
options):HttpRaftTransport
Defined in: consensus/adapters/raft/http-raft-transport.ts:39
Parameters
options
Returns
HttpRaftTransport
Methods
broadcast()
broadcast(
message,options?):Promise<void>
Defined in: consensus/adapters/raft/http-raft-transport.ts:117
Broadcasts to all configured peers except the local node and optional exclusions.
Parameters
message
options?
exceptNodeIds?
string[]
Returns
Promise<void>
Implementation of
getPeerStatuses()
getPeerStatuses():
RaftPeerStatus[]
Defined in: consensus/adapters/raft/http-raft-transport.ts:62
Returns coarse peer connectivity status for observability.
Returns
receive()
receive(
message):Promise<void>
Defined in: consensus/adapters/raft/http-raft-transport.ts:56
Delivers an already-authenticated inbound HTTP message to the Raft engine.
Parameters
message
Returns
Promise<void>
send()
send(
toNodeId,message):Promise<void>
Defined in: consensus/adapters/raft/http-raft-transport.ts:70
Sends one signed Raft message to a configured peer and records transport health.
Parameters
toNodeId
string
message
Returns
Promise<void>
Implementation of
start()
start(
handler):Promise<void>
Defined in: consensus/adapters/raft/http-raft-transport.ts:46
Registers the local Raft message handler.
Parameters
handler
Returns
Promise<void>
Implementation of
stop()
stop():
Promise<void>
Defined in: consensus/adapters/raft/http-raft-transport.ts:51
Stops local delivery; outbound send calls remain guarded by caller lifecycle.
Returns
Promise<void>