shrexnd

Documentation

Index

• type Client
  • func NewClient(host host.Host, opts ...Option) (*Client, error)
  • func (c *Client) RequestND(ctx context.Context, root *share.Root, nID namespace.ID, peer peer.ID) (share.NamespacedShares, error)
• type Option
  • func WithConcurrencyLimit(concurrencyLimit int) Option
  • func WithProtocolSuffix(protocolSuffix string) Option
  • func WithReadTimeout(readTimeout time.Duration) Option
  • func WithServeTimeout(serveTimeout time.Duration) Option
  • func WithWriteTimeout(writeTimeout time.Duration) Option
• type Parameters
  • func DefaultParameters() *Parameters
  • func (p *Parameters) Validate() error
• type Server
  • func NewServer(host host.Host, store *eds.Store, getter share.Getter, opts ...Option) (*Server, error)
  • func (srv *Server) Start(context.Context) error
  • func (srv *Server) Stop(context.Context) error

Types

type Client

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

Client implements client side of shrex/nd protocol to obtain namespaced shares data from remote peers.

func NewClient

func NewClient(host host.Host, opts ...Option) (*Client, error)

NewClient creates a new shrEx/nd client

func (*Client) RequestND

func (c *Client) RequestND(
	ctx context.Context,
	root *share.Root,
	nID namespace.ID,
	peer peer.ID,
) (share.NamespacedShares, error)

RequestND requests namespaced data from the given peer. Returns valid data with its verified inclusion against the share.Root.

type Option

type Option func(*Parameters)

Option is the functional option that is applied to the shrex/eds protocol to configure its parameters.

func WithConcurrencyLimit

func WithConcurrencyLimit(concurrencyLimit int) Option

WithConcurrencyLimit is a functional option that configures the `concurrencyLimit` parameter

func WithProtocolSuffix

func WithProtocolSuffix(protocolSuffix string) Option

WithProtocolSuffix is a functional option that configures the `protocolSuffix` parameter

func WithReadTimeout

func WithReadTimeout(readTimeout time.Duration) Option

WithReadTimeout is a functional option that configures the `readTimeout` parameter

func WithServeTimeout

func WithServeTimeout(serveTimeout time.Duration) Option

WithServeTimeout is a functional option that configures the `serveTimeout` parameter

func WithWriteTimeout

func WithWriteTimeout(writeTimeout time.Duration) Option

WithWriteTimeout is a functional option that configures the `writeTimeout` parameter

type Parameters

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

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 implements server side of shrex/nd protocol to serve namespaced share to remote peers.

func NewServer

func NewServer(host host.Host, store *eds.Store, getter share.Getter, opts ...Option) (*Server, error)

NewServer creates new Server

func (*Server) Start

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

Start starts the server

func (*Server) Stop

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

Stop stops the server