kcpx

Documentation

Overview

Package kcpx is some tidy wrappers around rpcx/kcp RPC communication

Index

• func NewXClient(address, serviceName, password string) (x client.XClient)
• func Serve(address, serviceName, password string, service interface{}) (srv *server.Server, shutdown func() <-chan struct{})
• type ConfigUDPSession
  • func (p *ConfigUDPSession) HandleConnAccept(conn net.Conn) (net.Conn, bool)

Functions

func NewXClient

func NewXClient(address, serviceName, password string) (x client.XClient)

NewXClient returns a new XClient configured for parallelcoin rpcx service for a given service name

func Serve

func Serve(address, serviceName, password string,
	service interface{}) (srv *server.Server, shutdown func() <-chan struct{})

Serve serves up an RPC service that can be contacted over kcp with the same password as used for NewXClient

Types

type ConfigUDPSession

type ConfigUDPSession struct{}

func (*ConfigUDPSession) HandleConnAccept

func (p *ConfigUDPSession) HandleConnAccept(conn net.Conn) (net.Conn, bool)