upgrader

Documentation

Index

• Variables
• func New(security []sec.SecureTransport, muxers []StreamMuxer, psk ipnet.PSK, ...) (transport.Upgrader, error)
• type Option
  • func WithAcceptTimeout(t time.Duration) Option
• type StreamMuxer

Variables

var AcceptQueueLength = 16

AcceptQueueLength 是在不接受任何新连接之前完全设置的连接数

var ErrNilPeer = errors.New("空对等点")

ErrNilPeer 在尝试升级出站连接但未指定对等点ID时返回

Functions

func New

func New(security []sec.SecureTransport, muxers []StreamMuxer, psk ipnet.PSK, rcmgr network.ResourceManager, connGater connmgr.ConnectionGater, opts ...Option) (transport.Upgrader, error)

New 创建一个新的升级器 参数:

• security: []sec.SecureTransport 安全传输列表
• muxers: []StreamMuxer 多路复用器列表
• psk: ipnet.PSK 私有网络共享密钥
• rcmgr: network.ResourceManager 资源管理器
• connGater: connmgr.ConnectionGater 连接过滤器
• opts: ...Option 配置选项

返回值:

• transport.Upgrader 升级器实例
• error 错误信息

Types

type Option

type Option func(*upgrader) error

Option 是配置 upgrader 的函数类型

func WithAcceptTimeout

func WithAcceptTimeout(t time.Duration) Option

WithAcceptTimeout 设置接受超时时间 参数:

• t: time.Duration 超时时间

返回值:

• Option 配置函数

type StreamMuxer

type StreamMuxer struct {
	// ID 多路复用器协议ID
	ID protocol.ID
	// Muxer 网络多路复用器实现
	Muxer network.Multiplexer
}

StreamMuxer 流多路复用器结构体