confws

type Client interface {
	// Close 关闭连接并从管理器 Detach;可重复调用.
	Close(ctx context.Context) error

	// Done 关闭完成信号.
	Done() <-chan struct{}
	// Err 关闭原因;未关闭时为 nil.
	Err() error

	// Read 拉模式读一帧;Push 模式返回 ERROR__READ_ON_NON_PULL_CLIENT.
	Read(ctx context.Context) (t int, data []byte, err error)
	// WriteBinary 写二进制帧;失败将关闭连接.
	WriteBinary(ctx context.Context, data []byte) error
	// WriteText 写文本帧;失败将关闭连接.
	WriteText(ctx context.Context, data []byte) error

	// LastActivity 最近读写时间.
	LastActivity() time.Time

	// ID 连接标识(ULID,由框架生成).
	ID() string

	// Underlying 返回原始http请求
	Underlying() *http.Request
}

type ClientManager interface {
	// Add 登记客户端;同 id 已存在则关闭旧连接并替换.
	Add(ctx context.Context, c Client) error
	// Detach 仅当 map 中仍是该实例时摘表.
	Detach(c Client)
	// Remove 关闭指定客户端.
	Remove(ctx context.Context, id string) error
	// Get 返回指定客户端;不存在返回 nil.
	Get(id string) Client
	// Activities 当前登记连接数.
	Activities() int
	// Close 关闭所有登记连接.
	Close(ctx context.Context) error
}

type ClientOptionApplier func(*clientOption)

type ConnectionHandler func(ctx context.Context, r *http.Request) (context.Context, []ClientOptionApplier, error)

type DisconnectionHandler func(ctx context.Context, cid string, err error)

type Endpoint struct {
	Option
	// contains filtered or unexported fields
}

type Error int8

type EstablishHandler func(ctx context.Context, cli Client) (context.Context, error)

type MessageHandler func(ctx context.Context, cli Client, t int, data []byte)

type Option struct {
	// ListenAddr 监听地址,例如 0.0.0.0:10165.
	ListenAddr string `url:",default=80"`
	// Path HTTP upgrade 路径.
	Path string `url:",default=/"`

	// HandshakeTimeout 握手超时.
	HandshakeTimeout types.Duration `url:",default=5s"`
	// WriteTimeout 单次写超时.
	WriteTimeout types.Duration `url:",default=5s"`
	// IdleTimeout 空闲回收超时;<=0 禁用(SetDefault 后默认为 5m).
	IdleTimeout types.Duration `url:",default=5m"`

	// CheckOriginAllowAll 为 true 时升级握手放行任意 Origin.
	CheckOriginAllowAll bool `url:",default=true"`
	// MaxMessageSize 单帧/消息最大字节.
	MaxMessageSize int `url:",default=32768"`
	// MaxConnection 最大同时在线连接数.
	MaxConnection int `url:",default=65536"`

	// Cert TLS 证书;零值表示明文.
	Cert conftls.X509KeyPair
	// contains filtered or unexported fields
}

type ReadFailureHandler func(ctx context.Context, cid string, err error)

type Session interface {
	Session(id string) Client
}

type WriteFailureHandler func(ctx context.Context, cid string, err error)