Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

network

package

Go to main page

Versions in this module

v0

v0.8.1

Feb 28, 2023

v0.7.1

Feb 28, 2023

v0.6.1

Dec 23, 2022

v0.6.0

Dec 21, 2022

v0.5.0

Aug 3, 2022

Changes in this version

type Session

+ Get func(key string) interface{}

+ Set func(key string, value interface{})

v0.4.0

Aug 1, 2022

v0.3.0

Jul 29, 2022

Changes in this version

type Router

+ SetHandlerFunc func(handler HandlerFunc)

v0.2.0

Jul 29, 2022

v0.1.0

Jun 17, 2022

Changes in this version

+ const FlagCompress

+ const FlagEncrypt

+ const FlagInit

+ var ErrHandlerNotFound = errors.New("handler not found")

+ var ErrRouterRepeated = errors.New("router repeated")

+ var ErrSessionNotFound = errors.New("session not found")

+ func RouterID(module, action uint8) uint16

+ type Client interface

+ Connect func(network, host string, port int) error

+ Logger func() zerologger.Logger

+ type CloseCallbackFunc func(session Session)

+ type Config struct

+ CloseTimeout time.Duration

+ Compress zerocompress.Compress

+ CompressThreshold int

+ Datapack Datapack

+ Host string

+ Logger zerologger.Logger

+ LoggerLevel int

+ MaxConnNum int

+ Network string

+ OnConnClose ConnFunc

+ OnConnected ConnFunc

+ OnServerClose func()

+ OnServerStart func() error

+ Port int

+ RecvBufferSize int

+ RecvDeadLine time.Duration

+ RecvQueueSize int

+ SendBufferSize int

+ SendDeadLine time.Duration

+ SendQueueSize int

+ WhetherCompress bool

+ WhetherCrypto bool

+ func DefaultConfig() *Config

+ type ConnFunc func(session Session)

+ type Crypto interface

+ Decrypt func(in []byte) ([]byte, error)

+ Encrypt func(in []byte) ([]byte, error)

+ type Datapack interface

+ HeadLen func() int

+ Pack func(message Message, crypto Crypto) ([]byte, error)

+ Unpack func(buffer *zerocircle.Circle, crypto Crypto) ([]Message, error)

+ type HandlerFunc func(message Message) (Message, error)

+ type Message interface

+ ActionID func() uint8

+ Code func() uint16

+ Flag func() uint16

+ ModuleID func() uint8

+ Payload func() []byte

+ SN func() uint16

+ SessionID func() SessionID

+ SetSessionID func(sessionID SessionID)

+ String func() string

+ type MessageHander func(message Message) (Message, error)

+ type NewMessageFunc func(flag, sn, code uint16, module, action uint8, payload []byte) Message

+ type Option func(Peer)

+ func WithCloseTimeout(closeTimeout time.Duration) Option

+ func WithCompress(compress zerocompress.Compress) Option

+ func WithCompressThreshold(compressThreshold int) Option

+ func WithDatapack(datapack Datapack) Option

+ func WithHost(host string) Option

+ func WithLogger(logger zerologger.Logger) Option

+ func WithLoggerLevel(loggerLevel int) Option

+ func WithMaxConnNum(MaxConnNum int) Option

+ func WithNetwork(network string) Option

+ func WithOnConnClose(onConnClose ConnFunc) Option

+ func WithOnConnected(onConnected ConnFunc) Option

+ func WithOnServerClose(onServerClose func()) Option

+ func WithOnServerStart(onServerStart func() error) Option

+ func WithPort(port int) Option

+ func WithRecvBufferSize(recvBufferSize int) Option

+ func WithRecvDeadLine(recvDeadLine time.Duration) Option

+ func WithRecvQueueSize(recvQueueSize int) Option

+ func WithSendBufferSize(sendBufferSize int) Option

+ func WithSendDeadLine(sendDeadLine time.Duration) Option

+ func WithSendQueueSize(sendQueueSize int) Option

+ func WithWhetherCompress(whetherCompress bool) Option

+ func WithWhetherCrypto(whetherCrypto bool) Option

+ type Peer interface

+ Close func() error

+ ListenSignal func()

+ Logger func() zerologger.Logger

+ Router func() Router

+ SessionManager func() SessionManager

+ Start func() error

+ type PeerOption interface

+ SetCloseTimeout func(closeTimeout time.Duration)

+ SetCompress func(compress zerocompress.Compress)

+ SetCompressThreshold func(compressThreshold int)

+ SetDatapack func(datapack Datapack)

+ SetHost func(host string)

+ SetLogger func(logger zerologger.Logger)

+ SetLoggerLevel func(loggerLevel int)

+ SetMaxConnNum func(MaxConnNum int)

+ SetNetwork func(network string)

+ SetOnConnClose func(onConnClose ConnFunc)

+ SetOnConnected func(onConnected ConnFunc)

+ SetOnServerClose func(onServerClose func())

+ SetOnServerStart func(onServerStart func() error)

+ SetPort func(port int)

+ SetRecvBufferSize func(recvBufferSize int)

+ SetRecvDeadLine func(recvDeadLine time.Duration)

+ SetRecvQueueSize func(recvQueueSize int)

+ SetSendBufferSize func(recvBufferSize int)

+ SetSendDeadLine func(recvDeadLine time.Duration)

+ SetSendQueueSize func(recvQueueSize int)

+ SetWhetherCompress func(whetherCompress bool)

+ SetWhetherCrypto func(whetherCrypto bool)

+ WithOption func(opts ...Option) Peer

+ type Router interface

+ AddRouter func(module, action uint8, handle HandlerFunc) error

+ Handler func(message Message) (Message, error)

+ func NewRouter() Router

+ type SendCallbackFunc func(session Session)

+ type Session interface

+ Close func()

+ Config func() *Config

+ Conn func() net.Conn

+ ID func() SessionID

+ RemoteAddr func() net.Addr

+ Run func()

+ Send func(message Message) error

+ SendCallback func(message Message, callback SendCallbackFunc) error

+ SetCrypto func(crypto Crypto)

+ type SessionID = uint64

+ type SessionManager interface

+ Add func(session Session)

+ Close func()

+ Del func(sessionID SessionID)

+ GenSessionID func() SessionID

+ Get func(sessionID SessionID) (Session, error)

+ Len func() int

+ Send func(sessionID SessionID, message Message) error

+ SendAll func(message Message)

+ SendCallback func(sessionID SessionID, message Message, callback SendCallbackFunc) error

+ func NewSessionManager() SessionManager