pipeProxy

Documentation

Index

• Constants
• func LoadFromServer(url string) []string
• func ProbeAllNodes(paths []string, saver func(fd uintptr)) []*wallet.ServeNodeId
• type PipeProxy
  • func NewProxy(addr string, w *wallet.Wallet, t Tun2Pipe) (*PipeProxy, error)
  • func (pp *PipeProxy) Accepting(done chan error)
  • func (pp *PipeProxy) Finish()
  • func (pp *PipeProxy) Proxying()
• type ProxyConfig
  • func (c *ProxyConfig) FindBootServers(path string) []*wallet.ServeNodeId
  • func (c *ProxyConfig) String() string
• type RefreshNodeIDs
• type Tun2Pipe

Constants

const DefaultSeedSever = "https://raw.githubusercontent.com/proton-lab/quantum/master/seed_debug.quantum"

Functions

func LoadFromServer

func LoadFromServer(url string) []string

func ProbeAllNodes

func ProbeAllNodes(paths []string, saver func(fd uintptr)) []*wallet.ServeNodeId

Types

type PipeProxy

type PipeProxy struct {
	*net.TCPListener
	Done   chan error
	Wallet *wallet.Wallet
	TunSrc Tun2Pipe
}

func NewProxy

func NewProxy(addr string, w *wallet.Wallet, t Tun2Pipe) (*PipeProxy, error)

func (*PipeProxy) Accepting

func (pp *PipeProxy) Accepting(done chan error)

func (*PipeProxy) Finish

func (pp *PipeProxy) Finish()

func (*PipeProxy) Proxying

func (pp *PipeProxy) Proxying()

type ProxyConfig

type ProxyConfig struct {
	*wallet.WConfig
	BootNodes string
}

func (*ProxyConfig) FindBootServers

func (c *ProxyConfig) FindBootServers(path string) []*wallet.ServeNodeId

func (*ProxyConfig) String

func (c *ProxyConfig) String() string

type RefreshNodeIDs

type RefreshNodeIDs func(ids string)

type Tun2Pipe

type Tun2Pipe interface {
	GetTarget(conn net.Conn) string
	Finish()
	InputPacket(data []byte)
	Proxying(chan error)
	RemoveFromSession(keyPort int)
}