protocol

Documentation

Index

• Constants
• Variables
• func IsSocks5(v byte) bool
• type ACLFilter
  • func NewACL(cfg config.ACLConfig) (*ACLFilter, error)
  • func (a *ACLFilter) Allow(p peer.ID, addr ma.Multiaddr) bool
  • func (a *ACLFilter) InterceptAccept(cm network.ConnMultiaddrs) (allow bool)
  • func (a *ACLFilter) InterceptAddrDial(peer.ID, ma.Multiaddr) (allow bool)
  • func (a *ACLFilter) InterceptPeerDial(p peer.ID) (allow bool)
  • func (a *ACLFilter) InterceptSecured(di network.Direction, p peer.ID, cm network.ConnMultiaddrs) (allow bool)
  • func (a *ACLFilter) InterceptUpgraded(network.Conn) (allow bool, reason control.DisconnectReason)
• type BufReaderStream
  • func NewBufReaderStream(s Stream) *BufReaderStream
  • func (bs *BufReaderStream) Close() error
  • func (bs *BufReaderStream) CloseRead() error
  • func (bs *BufReaderStream) CloseWrite() error
  • func (bs *BufReaderStream) Read(p []byte) (int, error)
  • func (bs *BufReaderStream) Reset() error
  • func (bs *BufReaderStream) SetDeadline(t time.Time) error
  • func (bs *BufReaderStream) SetReadDeadline(t time.Time) error
  • func (bs *BufReaderStream) SetWriteDeadline(t time.Time) error
  • func (bs *BufReaderStream) Write(p []byte) (n int, err error)
• type ProxyService
  • func NewProxyService(ctx context.Context, h host.Host, p2pHost string) *ProxyService
  • func (p *ProxyService) Close() error
  • func (p *ProxyService) Handler(s network.Stream)
  • func (p *ProxyService) Serve(proxyAddr string, remotePeer peer.ID) error
  • func (p *ProxyService) ServeHTTP(handler http.Handler, s *http.Server) error
  • func (p *ProxyService) Wait(fn func() error) error
• type Stream

Constants

const (
	P2PHttpID   protocol.ID = "/http"
	ID          protocol.ID = "/p2pdao/libp2p-proxy/1.0.0"
	ServiceName string      = "p2pdao.libp2p-proxy"
)

Variables

var Log = logging.Logger("libp2p-proxy")

Functions

func IsSocks5

func IsSocks5(v byte) bool

Types

type ACLFilter

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

func NewACL

func NewACL(cfg config.ACLConfig) (*ACLFilter, error)

func (*ACLFilter) Allow

func (a *ACLFilter) Allow(p peer.ID, addr ma.Multiaddr) bool

func (*ACLFilter) InterceptAccept

func (a *ACLFilter) InterceptAccept(cm network.ConnMultiaddrs) (allow bool)

func (*ACLFilter) InterceptAddrDial

func (a *ACLFilter) InterceptAddrDial(peer.ID, ma.Multiaddr) (allow bool)

func (*ACLFilter) InterceptPeerDial

func (a *ACLFilter) InterceptPeerDial(p peer.ID) (allow bool)

func (*ACLFilter) InterceptSecured

func (a *ACLFilter) InterceptSecured(di network.Direction, p peer.ID, cm network.ConnMultiaddrs) (allow bool)

func (*ACLFilter) InterceptUpgraded

func (a *ACLFilter) InterceptUpgraded(network.Conn) (allow bool, reason control.DisconnectReason)

type BufReaderStream

type BufReaderStream struct {
	Reader *bufio.Reader
	// contains filtered or unexported fields
}

func NewBufReaderStream

func NewBufReaderStream(s Stream) *BufReaderStream

func (*BufReaderStream) Close

func (bs *BufReaderStream) Close() error

func (*BufReaderStream) CloseRead

func (bs *BufReaderStream) CloseRead() error

func (*BufReaderStream) CloseWrite

func (bs *BufReaderStream) CloseWrite() error

func (*BufReaderStream) Read

func (bs *BufReaderStream) Read(p []byte) (int, error)

func (*BufReaderStream) Reset

func (bs *BufReaderStream) Reset() error

func (*BufReaderStream) SetDeadline

func (bs *BufReaderStream) SetDeadline(t time.Time) error

func (*BufReaderStream) SetReadDeadline

func (bs *BufReaderStream) SetReadDeadline(t time.Time) error

func (*BufReaderStream) SetWriteDeadline

func (bs *BufReaderStream) SetWriteDeadline(t time.Time) error

func (*BufReaderStream) Write

func (bs *BufReaderStream) Write(p []byte) (n int, err error)

type ProxyService

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

func NewProxyService

func NewProxyService(ctx context.Context, h host.Host, p2pHost string) *ProxyService

func (*ProxyService) Close

func (p *ProxyService) Close() error

Close terminates this listener. It will no longer handle any incoming streams

func (*ProxyService) Handler

func (p *ProxyService) Handler(s network.Stream)

func (*ProxyService) Serve

func (p *ProxyService) Serve(proxyAddr string, remotePeer peer.ID) error

func (*ProxyService) ServeHTTP

func (p *ProxyService) ServeHTTP(handler http.Handler, s *http.Server) error

func (*ProxyService) Wait

func (p *ProxyService) Wait(fn func() error) error

type Stream

type Stream interface {
	Read(b []byte) (n int, err error)
	Write(b []byte) (n int, err error)
	Close() error

	SetDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}