nets

type Bind func(session Sessioner) bool

type Codec interface {
	// Encode 編碼處理
	Encode(input any) (output any, err error)

	// Decode 解碼處理
	Decode(input any) (output any, err error)
}

type ConnectID = int64

type Connecter interface {
	// Connect 啟動連接
	Connect(bind Bind, unbind Unbind, wrong Wrong)

	// Address 取得位址
	Address() string
}

type ListenID = int64

type Listener interface {
	// Listen 啟動接聽
	Listen(bind Bind, unbind Unbind, wrong Wrong)

	// Stop 停止接聽
	Stop() error

	// Address 取得位址
	Address() string
}

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

type Publish func(name string, param any)

type Sessioner interface {
	// Start 啟動會話, 若不是使用多執行緒啟動, 則一定被阻塞在這裡直到停止會話; 當由連接器/接聽器獲得會話器之後, 需要啟動會話才可以傳送或接收封包
	Start(bind Bind, unbind Unbind)

	// Stop 停止會話, 不會等待會話內部循環結束
	Stop()

	// StopWait 停止會話, 會等待會話內部循環結束
	StopWait()

	// SetPublish 設定發布事件處理
	SetPublish(publish ...Publish)

	// SetWrong 設定錯誤處理
	SetWrong(wrong ...Wrong)

	// SetCodec 設定編碼/解碼
	SetCodec(codec ...Codec)

	// SetOwner 設定擁有者
	SetOwner(owner any)

	// Send 傳送封包
	Send(message any)

	// RemoteAddr 取得遠端位址
	RemoteAddr() net.Addr

	// LocalAddr 取得本地位址
	LocalAddr() net.Addr

	// GetOwner 取得擁有者
	GetOwner() any
}

type Status struct {
	Connect int // 連接數量
	Listen  int // 接聽數量
	Session int // 會話數量
}

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

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

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

type Unbind func(session Sessioner)

type Wrong func(err error)