share

Sep 13, 2022

Changes in this version

+ var DefaultWriteBatchSize = 2048

+ var GetData = ipld.ShareData

+ var GetID = ipld.ShareID

+ func EnsureEmptySquareExists(ctx context.Context, bServ blockservice.BlockService) error

+ func NewDiscovery(h host.Host, d core.Discovery, peersLimit uint, ...) *discovery

+ func NewTestDAGNet(ctx context.Context, t *testing.T) *dagNet

+ func RandFullLocalServiceWithSquare(t *testing.T, n int) (*Service, *Root)

+ func RandLightLocalServiceWithSquare(t *testing.T, n int) (*Service, *Root)

type Availability

+ func NewTestBrokenAvailability() Availability

+ func NewTestSuccessfulAvailability() Availability

+ ProbabilityOfAvailability func() float64

+ type CacheAvailability struct

+ func NewCacheAvailability(avail Availability, ds datastore.Batching) *CacheAvailability

+ func (ca *CacheAvailability) Close(ctx context.Context) error

+ func (ca *CacheAvailability) ProbabilityOfAvailability() float64

+ func (ca *CacheAvailability) SharesAvailable(ctx context.Context, root *Root) error

+ type FullAvailability struct

+ func TestFullAvailability(bServ blockservice.BlockService) *FullAvailability

+ func (fa *FullAvailability) ProbabilityOfAvailability() float64

+ func (fa *FullAvailability) SharesAvailable(ctx context.Context, root *Root) error

+ func (fa *FullAvailability) Start(context.Context) error

+ func (fa *FullAvailability) Stop(context.Context) error

+ type LightAvailability struct

+ func TestLightAvailability(bServ blockservice.BlockService) *LightAvailability

+ func (la *LightAvailability) ProbabilityOfAvailability() float64

+ func (la *LightAvailability) SharesAvailable(ctx context.Context, dah *Root) error

+ func (la *LightAvailability) Start(context.Context) error

+ func (la *LightAvailability) Stop(context.Context) error

type Root

+ func FillBS(t *testing.T, bServ blockservice.BlockService, shares []Share) *Root

+ func RandFillBS(t *testing.T, n int, bServ blockservice.BlockService) *Root

type Service

+ func RandLightService() (*Service, blockservice.BlockService)

+ type TestBrokenAvailability struct

+ Root *Root

+ func (b *TestBrokenAvailability) ProbabilityOfAvailability() float64

+ func (b *TestBrokenAvailability) SharesAvailable(_ context.Context, root *Root) error

+ type TestSuccessfulAvailability struct

+ func (tsa *TestSuccessfulAvailability) ProbabilityOfAvailability() float64

+ func (tsa *TestSuccessfulAvailability) SharesAvailable(context.Context, *Root) error

Feb 25, 2022

Changes in this version

+ func RandFullServiceWithSquare(t *testing.T, n int) (Service, *Root)

+ func RandLightServiceWithSquare(t *testing.T, n int) (Service, *Root)

type Availability

+ func NewFullAvailability(get format.NodeGetter) Availability

type DAGNet

+ func (dn *DAGNet) RandFullService(n int) (Service, *Root)

+ func (dn *DAGNet) RandLightService(n int) (Service, *Root)

Dec 6, 2021

Changes in this version

+ const AvailabilityTimeout

+ var DefaultSampleAmount = 16

+ var ErrNotAvailable = errors.New("da: data not available")

+ func RandServiceWithSquare(t *testing.T, n int) (Service, *Root)

+ type Availability interface

+ SharesAvailable func(context.Context, *Root) error

+ func NewLightAvailability(get format.NodeGetter) Availability

+ type DAGNet struct

+ func NewDAGNet(ctx context.Context, t *testing.T) *DAGNet

+ func (dn *DAGNet) CleanDAG() format.DAGService

+ func (dn *DAGNet) CleanService() Service

+ func (dn *DAGNet) ConnectAll()

+ func (dn *DAGNet) RandDAG(n int) (format.DAGService, *Root)

+ func (dn *DAGNet) RandService(n int) (Service, *Root)

+ type Root = da.DataAvailabilityHeader

+ func RandFillDAG(t *testing.T, n int, dag format.DAGService) *Root

+ type Sample struct

+ Col int

+ Row int

+ func SampleSquare(squareWidth int, num int) ([]Sample, error)

+ type Service interface

+ GetShare func(ctx context.Context, root *Root, row, col int) (Share, error)

+ GetShares func(context.Context, *Root) ([][]Share, error)

+ GetSharesByNamespace func(context.Context, *Root, namespace.ID) ([]Share, error)

+ Start func(context.Context) error

+ Stop func(context.Context) error

+ func NewService(dag format.DAGService, avail Availability) Service

+ type Share = namespace.PrefixedData8

+ func RandShares(t *testing.T, n int) []Share