shrex_getter

Documentation

Index

• type Getter
  • func NewGetter(edsClient *shrexeds.Client, ndClient *shrexnd.Client, ...) *Getter
  • func (sg *Getter) GetEDS(ctx context.Context, header *header.ExtendedHeader) (*rsmt2d.ExtendedDataSquare, error)
  • func (sg *Getter) GetNamespaceData(ctx context.Context, header *header.ExtendedHeader, ...) (shwap.NamespaceData, error)
  • func (sg *Getter) GetSamples(context.Context, *header.ExtendedHeader, []shwap.SampleCoords) ([]shwap.Sample, error)
  • func (sg *Getter) Start(ctx context.Context) error
  • func (sg *Getter) Stop(ctx context.Context) error
  • func (sg *Getter) WithMetrics() error

Types

type Getter

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

Getter is a share.Getter that uses the shrex/eds and shrex/nd protocol to retrieve shares.

func NewGetter

func NewGetter(
	edsClient *shrexeds.Client,
	ndClient *shrexnd.Client,
	fullPeerManager *peers.Manager,
	archivalManager *peers.Manager,
	availWindow time.Duration,
) *Getter

func (*Getter) GetEDS

func (sg *Getter) GetEDS(ctx context.Context, header *header.ExtendedHeader) (*rsmt2d.ExtendedDataSquare, error)

func (*Getter) GetNamespaceData

func (sg *Getter) GetNamespaceData(
	ctx context.Context,
	header *header.ExtendedHeader,
	namespace libshare.Namespace,
) (shwap.NamespaceData, error)

func (*Getter) GetSamples

func (sg *Getter) GetSamples(context.Context, *header.ExtendedHeader, []shwap.SampleCoords) ([]shwap.Sample, error)

func (*Getter) Start

func (sg *Getter) Start(ctx context.Context) error

func (*Getter) Stop

func (sg *Getter) Stop(ctx context.Context) error

func (*Getter) WithMetrics

func (sg *Getter) WithMetrics() error