ws

Documentation

Index

• func NewClientChannel(opts ...*Options) core.ConnectorChannel
• func WithAutoReconnect(r bool) core.BuildOption
• func WithCertFile(cf string) core.BuildOption
• func WithKeyFile(kf string) core.BuildOption
• func WithMaxConnNum(mcn int) core.BuildOption
• func WithMaxHeaderSize(s int) core.BuildOption
• func WithMaxReconnectTimes(n int) core.BuildOption
• func WithReadBufSize(s int) core.BuildOption
• func WithTimeout(t time.Duration) core.BuildOption
• func WithWriteBufSize(s int) core.BuildOption
• type Options

Functions

func NewClientChannel

func NewClientChannel(opts ...*Options) core.ConnectorChannel

func WithAutoReconnect

func WithAutoReconnect(r bool) core.BuildOption

WithAutoReconnect sets whether auto reconnect when disconnect with server.

func WithCertFile

func WithCertFile(cf string) core.BuildOption

func WithKeyFile

func WithKeyFile(kf string) core.BuildOption

func WithMaxConnNum

func WithMaxConnNum(mcn int) core.BuildOption

WithMaxConnNum sets max connection number.

func WithMaxHeaderSize

func WithMaxHeaderSize(s int) core.BuildOption

func WithMaxReconnectTimes

func WithMaxReconnectTimes(n int) core.BuildOption

WithMaxReconnectTimes sets max number for trying reconnect with server.

func WithReadBufSize

func WithReadBufSize(s int) core.BuildOption

WithReadBufSize sets max size of pending read.

func WithTimeout

func WithTimeout(t time.Duration) core.BuildOption

func WithWriteBufSize

func WithWriteBufSize(s int) core.BuildOption

WithWriteBufSize sets max size of pending wirte.

Types

type Options

type Options struct {
	WriteBufSize      int
	ReadBufSize       int
	AutoReconnect     bool
	MaxReconnectTimes int
}