full

Documentation

Index

• func Node(dn *availability_test.TestDagNet) *availability_test.TestNode
• func RandNode(dn *availability_test.TestDagNet, squareSize int) (*availability_test.TestNode, *share.Root)
• func RandServiceWithSquare(t *testing.T, n int) (*service.ShareService, *share.Root)
• type ShareAvailability
  • func NewShareAvailability(bServ blockservice.BlockService, disc *discovery.Discovery) *ShareAvailability
  • func TestAvailability(bServ blockservice.BlockService) *ShareAvailability
  • func (fa *ShareAvailability) ProbabilityOfAvailability(context.Context) float64
  • func (fa *ShareAvailability) SharesAvailable(ctx context.Context, root *share.Root, _ ...peer.ID) error
  • func (fa *ShareAvailability) Start(context.Context) error
  • func (fa *ShareAvailability) Stop(context.Context) error

Functions

func Node

func Node(dn *availability_test.TestDagNet) *availability_test.TestNode

Node creates a new empty Full Node.

func RandNode

func RandNode(dn *availability_test.TestDagNet, squareSize int) (*availability_test.TestNode, *share.Root)

RandNode creates a Full Node filled with a random block of the given size.

func RandServiceWithSquare

func RandServiceWithSquare(t *testing.T, n int) (*service.ShareService, *share.Root)

RandServiceWithSquare provides a service.ShareService filled with 'n' NMT trees of 'n' random shares, essentially storing a whole square.

Types

type ShareAvailability

type ShareAvailability struct {
	// contains filtered or unexported fields
}

ShareAvailability implements share.Availability using the full data square recovery technique. It is considered "full" because it is required to download enough shares to fully reconstruct the data square.

func NewShareAvailability

func NewShareAvailability(bServ blockservice.BlockService, disc *discovery.Discovery) *ShareAvailability

NewShareAvailability creates a new full ShareAvailability.

func TestAvailability

func TestAvailability(bServ blockservice.BlockService) *ShareAvailability

func (*ShareAvailability) ProbabilityOfAvailability

func (fa *ShareAvailability) ProbabilityOfAvailability(context.Context) float64

func (*ShareAvailability) SharesAvailable

func (fa *ShareAvailability) SharesAvailable(ctx context.Context, root *share.Root, _ ...peer.ID) error

SharesAvailable reconstructs the data committed to the given Root by requesting enough Shares from the network.

func (*ShareAvailability) Start

func (fa *ShareAvailability) Start(context.Context) error

func (*ShareAvailability) Stop

func (fa *ShareAvailability) Stop(context.Context) error