kcp

package module

v0.0.11 Latest Latest Go to latest Published: Apr 3, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

kcp+scop (simple connection-oriented protocol)

View Source

const P_KCP_SCOP = 0x80a1

This section is empty.

func ParseKcpNetAddr(a net.Addr) (ma.Multiaddr, error)

type BlockCryptFactory func(key []byte) (kcpgo.BlockCrypt, error)

type Conn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (c *Conn) LocalMultiaddr() ma.Multiaddr

func (c *Conn) RemoteMultiaddr() ma.Multiaddr

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

func NewTransport(upgrader transport.Upgrader, rcmgr network.ResourceManager, psk pnet.PSK, opts ...Option) (*KcpTransport, error)

func (t *KcpTransport) CanDial(addr ma.Multiaddr) bool

func (t *KcpTransport) Dial(ctx context.Context, raddr ma.Multiaddr, p peer.ID) (transport.CapableConn, error)

func (t *KcpTransport) Listen(a ma.Multiaddr) (transport.Listener, error)

func (t *KcpTransport) Protocols() []int

func (t *KcpTransport) Proxy() bool

type Option func(t *KcpTransport)

func WithKcpBlockCrypt(factory BlockCryptFactory) Option

func WithKcpShards(dataShards, parityShards int) Option

func WithScopOptions(opts ...scop.Option) Option

func WithSessionConfigurer(configurer SessionConfigurer) Option

type SessionConfigurer func(*kcpgo.UDPSession) error

Path	Synopsis
kcptune
scop