nooschain v0.1.0

---

nooschain / consensus/adapters/raft/in-process-raft-transport / InProcessRaftTransport

Class: InProcessRaftTransport

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:31

Implements

• RaftTransport

Constructors

Constructor

new InProcessRaftTransport(clusterId, nodeId, peerNodeIds, options?): InProcessRaftTransport

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:35

Parameters

clusterId

string

nodeId

string

peerNodeIds

string[]

options?

deliveryDelayMs?

number

Returns

InProcessRaftTransport

Methods

broadcast()

broadcast(message, options?): Promise<void>

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:79

Parameters

message

RaftMessage

options?

exceptNodeIds?

string[]

Returns

Promise<void>

Implementation of

RaftTransport.broadcast

---

disconnectNode()

disconnectNode(nodeId): void

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:53

Parameters

nodeId

string

Returns

void

---

reconnectNode()

reconnectNode(nodeId): void

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:57

Parameters

nodeId

string

Returns

void

---

send()

send(toNodeId, message): Promise<void>

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:61

Parameters

toNodeId

string

message

RaftMessage

Returns

Promise<void>

Implementation of

RaftTransport.send

---

start()

start(handler): Promise<void>

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:41

Parameters

handler

RaftMessageHandler

Returns

Promise<void>

Implementation of

RaftTransport.start

---

stop()

stop(): Promise<void>

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:49

Returns

Promise<void>

Implementation of

RaftTransport.stop

---

clearCluster()

static clearCluster(clusterId): void

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:91

Parameters

clusterId

string

Returns

void

---

deliverMessage()

static deliverMessage(clusterId, toNodeId, message): Promise<void>

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:116

Parameters

clusterId

string

toNodeId

string

message

RaftMessage

Returns

Promise<void>

---

disconnectNode()

static disconnectNode(clusterId, nodeId): void

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:96

Parameters

clusterId

string

nodeId

string

Returns

void

---

reconnectNode()

static reconnectNode(clusterId, nodeId): void

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:101

Parameters

clusterId

string

nodeId

string

Returns

void

---

setDeliveryDelay()

static setDeliveryDelay(clusterId, deliveryDelayMs): void

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:106

Parameters

clusterId

string

deliveryDelayMs

number

Returns

void

---

setDropMessages()

static setDropMessages(clusterId, dropMessages): void

Defined in: consensus/adapters/raft/in-process-raft-transport.ts:111

Parameters

clusterId

string

dropMessages

boolean

Returns

void