sync

package

v0.0.0-...-fc88c08 Latest Latest Go to latest Published: Mar 5, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Fetch func(uint16, []uint64)

Fetch is a function that contacts the given PID and requests units with given IDs.

type Gossip func(uint16)

Gossip is a function that initializes gossip with the given PID.

type Multicast func(gomel.Unit)

Multicast is a function that sends the given unit to all committee members.

type WorkerPool interface {
	Start()
	Stop()
}

WorkerPool represents a pool of parallel workers.

func NewPerPidPool(nProc uint16, multiple int, work func(pid uint16)) WorkerPool

NewPerPidPool creates a pool of workers doing per-pid work for the given nProc.

func NewPool(size int, work func()) WorkerPool

NewPool creates a pool of workers with the given size, all doing the same work.

Path	Synopsis
fetch Package fetch implements a mechanism of fetching specific units with known hashes.	Package fetch implements a mechanism of fetching specific units with known hashes.
gossip Package gossip implements a protocol for synchronizing dags through gossiping.	Package gossip implements a protocol for synchronizing dags through gossiping.
handshake Package handshake implements protocols for identifying the peer.	Package handshake implements protocols for identifying the peer.
multicast Package multicast implements a multicasting service to disseminate units created by us.	Package multicast implements a multicasting service to disseminate units created by us.
rmc Package rmc implements reliable multicast protocol for disseminating units.	Package rmc implements reliable multicast protocol for disseminating units.
syncer