das

Documentation

Index

• type DASer
  • func NewDASer(da share.Availability, hsub header.Subscriber) *DASer
  • func (d *DASer) Start(context.Context) error
  • func (d *DASer) Stop(ctx context.Context) error

Types

type DASer

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

DASer continuously validates availability of data committed to headers.

func NewDASer

func NewDASer(da share.Availability, hsub header.Subscriber) *DASer

NewDASer creates a new DASer.

func (*DASer) Start

func (d *DASer) Start(context.Context) error

Start initiates subscription for new ExtendedHeaders and spawns a sampling routine.

func (*DASer) Stop

func (d *DASer) Stop(ctx context.Context) error

Stop stops sampling.