proxy

Documentation

Index

• Constants
• type Loopback
  • func (_ *Loopback) Bootstrap(ctx context.Context) error
  • func (lb *Loopback) HandleStream(s inet.Stream)
  • func (lb *Loopback) SendMessage(ctx context.Context, m *dhtpb.Message) error
  • func (lb *Loopback) SendRequest(ctx context.Context, m *dhtpb.Message) (*dhtpb.Message, error)
• type Proxy
  • func Standard(h host.Host, remotes []peer.PeerInfo) Proxy
• type RequestHandler

Constants

const ProtocolSNR = "/ipfs/supernoderouting"

Types

type Loopback

type Loopback struct {
	Handler RequestHandler
	Local   peer.ID
}

Loopback forwards requests to a local handler

func (*Loopback) Bootstrap

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

func (*Loopback) HandleStream

func (lb *Loopback) HandleStream(s inet.Stream)

func (*Loopback) SendMessage

func (lb *Loopback) SendMessage(ctx context.Context, m *dhtpb.Message) error

SendMessage intercepts local requests, forwarding them to a local handler

func (*Loopback) SendRequest

func (lb *Loopback) SendRequest(ctx context.Context, m *dhtpb.Message) (*dhtpb.Message, error)

SendRequest intercepts local requests, forwarding them to a local handler

type Proxy

type Proxy interface {
	Bootstrap(context.Context) error
	HandleStream(inet.Stream)
	SendMessage(ctx context.Context, m *dhtpb.Message) error
	SendRequest(ctx context.Context, m *dhtpb.Message) (*dhtpb.Message, error)
}

func Standard

func Standard(h host.Host, remotes []peer.PeerInfo) Proxy

type RequestHandler

type RequestHandler interface {
	HandleRequest(ctx context.Context, p peer.ID, m *dhtpb.Message) *dhtpb.Message
}

RequestHandler handles routing requests locally