supernode

Documentation

Index

• type Client
  • func NewClient(px proxy.Proxy, h host.Host, ps pstore.Peerstore, local peer.ID) (*Client, error)
  • func (c *Client) Bootstrap(ctx context.Context) error
  • func (c *Client) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo, error)
  • func (c *Client) FindProvidersAsync(ctx context.Context, k *cid.Cid, max int) <-chan pstore.PeerInfo
  • func (c *Client) GetValue(ctx context.Context, k string) ([]byte, error)
  • func (c *Client) GetValues(ctx context.Context, k string, _ int) ([]routing.RecvdVal, error)
  • func (c *Client) Ping(ctx context.Context, id peer.ID) (time.Duration, error)
  • func (c *Client) Provide(ctx context.Context, k *cid.Cid) error
  • func (c *Client) PutValue(ctx context.Context, k string, v []byte) error
• type Server
  • func NewServer(ds datastore.Datastore, ps pstore.Peerstore, local peer.ID) (*Server, error)
  • func (_ *Server) Bootstrap(ctx context.Context) error
  • func (s *Server) HandleRequest(ctx context.Context, p peer.ID, req *dhtpb.Message) *dhtpb.Message

Types

type Client

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

func NewClient

func NewClient(px proxy.Proxy, h host.Host, ps pstore.Peerstore, local peer.ID) (*Client, error)

TODO take in datastore/cache

func (*Client) Bootstrap

func (c *Client) Bootstrap(ctx context.Context) error

func (*Client) FindPeer

func (c *Client) FindPeer(ctx context.Context, id peer.ID) (pstore.PeerInfo, error)

func (*Client) FindProvidersAsync

func (c *Client) FindProvidersAsync(ctx context.Context, k *cid.Cid, max int) <-chan pstore.PeerInfo

func (*Client) GetValue

func (c *Client) GetValue(ctx context.Context, k string) ([]byte, error)

func (*Client) GetValues

func (c *Client) GetValues(ctx context.Context, k string, _ int) ([]routing.RecvdVal, error)

func (*Client) Ping

func (c *Client) Ping(ctx context.Context, id peer.ID) (time.Duration, error)

func (*Client) Provide

func (c *Client) Provide(ctx context.Context, k *cid.Cid) error

func (*Client) PutValue

func (c *Client) PutValue(ctx context.Context, k string, v []byte) error

type Server

type Server struct {
	*proxy.Loopback // so server can be injected into client
	// contains filtered or unexported fields
}

Server handles routing queries using a database backend

func NewServer

func NewServer(ds datastore.Datastore, ps pstore.Peerstore, local peer.ID) (*Server, error)

NewServer creates a new Supernode routing Server

func (*Server) Bootstrap

func (_ *Server) Bootstrap(ctx context.Context) error

func (*Server) HandleRequest

func (s *Server) HandleRequest(ctx context.Context, p peer.ID, req *dhtpb.Message) *dhtpb.Message

HandleLocalRequest implements the proxy.RequestHandler interface. This is where requests are received from the outside world.