reconstruction

Documentation

Index

• func Listener(sync *replication.Sync, frame *network.Frame, input <-chan *network.Blobs) <-chan *network.Blobs
• func Reconstruct(frame *network.Frame, input <-chan *network.Blobs, sync *replication.Sync, ...) chan *network.Blobs
• type Request
  • func (r *Request) Deserialize(blob *network.Blob)
  • func (r *Request) Equals(r2 *Request) bool
  • func (r *Request) Serialize() *network.Blob

Functions

func Listener

func Listener(sync *replication.Sync, frame *network.Frame, input <-chan *network.Blobs) <-chan *network.Blobs

Listener listens to the incoming requests and sends missing blobs to the nodes

func Reconstruct

func Reconstruct(frame *network.Frame, input <-chan *network.Blobs, sync *replication.Sync, outputConn net.PacketConn) chan *network.Blobs

Reconstruct runs the reconstruction fo the missing blobs

Types

type Request

type Request struct {
	Index uint64
	From  *replication.NodeData
}

Request is a struct to request missing blobs from other nodes.

func (*Request) Deserialize

func (r *Request) Deserialize(blob *network.Blob)

Deserialize deserializes request structure from blob

func (*Request) Equals

func (r *Request) Equals(r2 *Request) bool

Equals compares to Request struct

func (*Request) Serialize

func (r *Request) Serialize() *network.Blob

Serialize serializes the request structure into the blob