service

package

v0.0.0-...-3fb6a18 Latest Latest Go to latest Published: Sep 18, 2019 License: GPL-3.0 Imports: 14 Imported by: 0

Details

View Source

const (
	DefaultListenAddr = "127.0.0.1:9001"
)

View Source

var (
	DefaultConnect = func() *net.TCPAddr {
		tcpAddr, _ := net.ResolveTCPAddr("tcp", DefaultListenAddr)
		return tcpAddr
	}
)

func Handle(tcpConn *net.TCPConn)

func New(ctx context.Context, tcpAddr *net.TCPAddr) p2pService

func PingHandle(tcpConn *net.TCPConn, nodeID peer.ID)

func SSHandle(tcpConn *net.TCPConn, config api.ClientConfig)

type ConnHandler func(*net.TCPConn)

type Service interface {
	Start() error
	SetHandler(handle ConnHandler)
	Close()
}

Path	Synopsis
rpcserver