tcp

package module

v2.0.0-...-f9caf38 Latest Latest Go to latest Published: Apr 23, 2026 License: MIT Imports: 17 Imported by: 4

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dobyte/due

Links

Open Source Insights

Documentation ¶

Index ¶

func NewClient(opts ...ClientOption) network.Client
func NewServer(opts ...ServerOption) network.Server
type ClientOption
type HeartbeatMechanism
type ServerOption

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewClient ¶

func NewClient(opts ...ClientOption) network.Client

func NewServer ¶

func NewServer(opts ...ServerOption) network.Server

Types ¶

type ClientOption ¶

type ClientOption func(o *clientOptions)

func WithClientAddr ¶

func WithClientAddr(addr string) ClientOption

WithClientAddr 设置拨号地址

func WithClientCredentials ¶

func WithClientCredentials(caFile string, serverName string) ClientOption

WithClientCredentials 设置CA证书和校验域名

func WithClientDialTimeout ¶

func WithClientDialTimeout(dialTimeout time.Duration) ClientOption

WithClientDialTimeout 设置拨号超时时间

func WithClientHeartbeatInterval ¶

func WithClientHeartbeatInterval(heartbeatInterval time.Duration) ClientOption

WithClientHeartbeatInterval 设置心跳间隔时间

func WithClientWriteQueueSize ¶

func WithClientWriteQueueSize(writeQueueSize int) ClientOption

WithClientWriteQueueSize 设置写队列大小

func WithClientWriteTimeout ¶

func WithClientWriteTimeout(writeTimeout time.Duration) ClientOption

WithClientWriteTimeout 设置写超时时间

type HeartbeatMechanism ¶

type HeartbeatMechanism string

const (
	RespHeartbeat HeartbeatMechanism = "resp" // 响应式心跳
	TickHeartbeat HeartbeatMechanism = "tick" // 主动定时心跳
)

type ServerOption ¶

type ServerOption func(o *serverOptions)

func WithServerAddr ¶

func WithServerAddr(addr string) ServerOption

WithServerAddr 设置监听地址

func WithServerAuthorizeTimeout ¶

func WithServerAuthorizeTimeout(authorizeTimeout time.Duration) ServerOption

WithServerAuthorizeTimeout 设置授权超时时间

func WithServerCredentials ¶

func WithServerCredentials(certFile, keyFile string) ServerOption

WithServerCredentials 设置服务器证书和秘钥

func WithServerHeartbeatInterval ¶

func WithServerHeartbeatInterval(heartbeatInterval time.Duration) ServerOption

WithServerHeartbeatInterval 设置心跳检测间隔时间

func WithServerHeartbeatMechanism ¶

func WithServerHeartbeatMechanism(heartbeatMechanism HeartbeatMechanism) ServerOption

WithServerHeartbeatMechanism 设置心跳机制

func WithServerMaxConnNum ¶

func WithServerMaxConnNum(maxConnNum int) ServerOption

WithServerMaxConnNum 设置连接的最大连接数

func WithServerWriteQueueSize ¶

func WithServerWriteQueueSize(writeQueueSize int) ServerOption

WithServerWriteQueueSize 设置写入队列大小

func WithServerWriteTimeout ¶

func WithServerWriteTimeout(writeTimeout time.Duration) ServerOption

WithServerWriteTimeout 设置写超时时间

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL