protocol

package

v1.1.0 Latest Latest Go to latest Published: Mar 10, 2022 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/p2pdao/libp2p-proxy

Links

Open Source Insights

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
type BufReaderStream
- func NewBufReaderStream(s network.Stream) *BufReaderStream
type ProxyService
- func NewProxyService(ctx context.Context, h host.Host, acl *ACLFilter, p2pHost string) *ProxyService

Constants ¶

View Source

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

Variables ¶

View Source

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

type BufReaderStream ¶

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

func NewBufReaderStream ¶

func NewBufReaderStream(s network.Stream) *BufReaderStream

func (*BufReaderStream) Close ¶ added in v1.1.0

func (bs *BufReaderStream) Close() error

func (*BufReaderStream) CloseRead ¶ added in v1.1.0

func (bs *BufReaderStream) CloseRead() error

func (*BufReaderStream) CloseWrite ¶ added in v1.1.0

func (bs *BufReaderStream) CloseWrite() error

func (*BufReaderStream) Conn ¶ added in v1.1.0

func (bs *BufReaderStream) Conn() network.Conn

func (*BufReaderStream) ID ¶ added in v1.1.0

func (bs *BufReaderStream) ID() string

func (*BufReaderStream) Protocol ¶ added in v1.1.0

func (bs *BufReaderStream) Protocol() protocol.ID

func (*BufReaderStream) Read ¶

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

func (*BufReaderStream) Reset ¶ added in v1.1.0

func (bs *BufReaderStream) Reset() error

func (*BufReaderStream) Scope ¶ added in v1.1.0

func (bs *BufReaderStream) Scope() network.StreamScope

func (*BufReaderStream) SetDeadline ¶ added in v1.1.0

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

func (*BufReaderStream) SetProtocol ¶ added in v1.1.0

func (bs *BufReaderStream) SetProtocol(id protocol.ID) error

func (*BufReaderStream) SetReadDeadline ¶ added in v1.1.0

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

func (*BufReaderStream) SetWriteDeadline ¶ added in v1.1.0

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

func (*BufReaderStream) Stat ¶ added in v1.1.0

func (bs *BufReaderStream) Stat() network.Stats

func (*BufReaderStream) Write ¶ added in v1.1.0

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, acl *ACLFilter, p2pHost string) *ProxyService

func (*ProxyService) Close ¶ added in v1.1.0

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 ¶ added in v1.1.0

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

func (*ProxyService) Wait ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL