shrexeds

Documentation

Index

• type Client
  • func NewClient(params *Parameters, host host.Host) (*Client, error)
  • func (c *Client) RequestEDS(ctx context.Context, dataHash share.DataHash, peer peer.ID) (*rsmt2d.ExtendedDataSquare, error)
  • func (c *Client) WithMetrics() error
• type Parameters
  • func DefaultParameters() *Parameters
  • func (p *Parameters) Validate() error
• type Server
  • func NewServer(params *Parameters, host host.Host, store *eds.Store) (*Server, error)
  • func (s *Server) Start(context.Context) error
  • func (s *Server) Stop(context.Context) error
  • func (s *Server) WithMetrics() error

Types

type Client

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

Client is responsible for requesting EDSs for blocksync over the ShrEx/EDS protocol.

func NewClient

func NewClient(params *Parameters, host host.Host) (*Client, error)

NewClient creates a new ShrEx/EDS client.

func (*Client) RequestEDS

func (c *Client) RequestEDS(
	ctx context.Context,
	dataHash share.DataHash,
	peer peer.ID,
) (*rsmt2d.ExtendedDataSquare, error)

RequestEDS requests the ODS from the given peers and returns the EDS upon success.

func (*Client) WithMetrics

func (c *Client) WithMetrics() error

type Parameters

type Parameters struct {
	*p2p.Parameters

	// BufferSize defines the size of the buffer used for writing an ODS over the stream.
	BufferSize uint64
}

Parameters is the set of parameters that must be configured for the shrex/eds protocol.

func DefaultParameters

func DefaultParameters() *Parameters

func (*Parameters) Validate

func (p *Parameters) Validate() error

type Server

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

Server is responsible for serving ODSs for blocksync over the ShrEx/EDS protocol.

func NewServer

func NewServer(params *Parameters, host host.Host, store *eds.Store) (*Server, error)

NewServer creates a new ShrEx/EDS server.

func (*Server) Start

func (s *Server) Start(context.Context) error

func (*Server) Stop

func (s *Server) Stop(context.Context) error

func (*Server) WithMetrics

func (s *Server) WithMetrics() error