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) GetShare(context.Context, *header.ExtendedHeader, int, int) (libshare.Share, error)
  • func (sg *Getter) GetSharesByNamespace(ctx context.Context, header *header.ExtendedHeader, ...) (shwap.NamespaceData, 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 pruner.AvailabilityWindow,
) *Getter

func (*Getter) GetEDS

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

func (*Getter) GetShare

func (sg *Getter) GetShare(context.Context, *header.ExtendedHeader, int, int) (libshare.Share, error)

func (*Getter) GetSharesByNamespace

func (sg *Getter) GetSharesByNamespace(
	ctx context.Context,
	header *header.ExtendedHeader,
	namespace libshare.Namespace,
) (shwap.NamespaceData, 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