Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

gnet

package module

Go to main page

Versions in this module

v1

v1.3.78

Feb 3, 2021

v1.3.77

Feb 2, 2021

v1.3.76

Feb 2, 2021

v1.3.75

Feb 2, 2021

v1.3.74

Feb 2, 2021

v1.3.73

Feb 2, 2021

v1.3.72

Feb 2, 2021

v1.3.71

Feb 2, 2021

v1.3.7

Jan 30, 2021

v1.3.6

Dec 11, 2020

Changes in this version

+ var CRLFByte = byte('\n')

+ func Serve(eventHandler EventHandler, protoAddr string, opts ...Option) (err error)

+ func Stop(ctx context.Context, protoAddr string) error

+ type Action int

+ const Close

+ const None

+ const Shutdown

+ type BuiltInFrameCodec struct

+ func (cc *BuiltInFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *BuiltInFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type Conn interface

+ AsyncWrite func(dataFrame interface{}) error

+ BufferLength func() (size int)

+ Close func() error

+ Context func() (ctx interface{})

+ LocalAddr func() (addr net.Addr)

+ Read func() (buf []byte)

+ ReadN func(n int) (size int, buf []byte)

+ RemoteAddr func() (addr net.Addr)

+ ResetBuffer func()

+ SendTo func(buf []byte) error

+ SetContext func(ctx interface{})

+ ShiftN func(n int) (size int)

+ Wake func() error

+ type DecoderConfig struct

+ ByteOrder binary.ByteOrder

+ InitialBytesToStrip int

+ LengthAdjustment int

+ LengthFieldLength int

+ LengthFieldOffset int

+ type DelimiterBasedFrameCodec struct

+ func NewDelimiterBasedFrameCodec(delimiter byte) *DelimiterBasedFrameCodec

+ func (cc *DelimiterBasedFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *DelimiterBasedFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type EncoderConfig struct

+ ByteOrder binary.ByteOrder

+ LengthAdjustment int

+ LengthFieldLength int

+ LengthIncludesLengthFieldLength bool

+ type EventHandler interface

+ OnClosed func(c Conn, err error) (action Action)

+ OnInitComplete func(server Server) (action Action)

+ OnOpened func(c Conn) (out []byte, action Action)

+ OnShutdown func(server Server)

+ PreWrite func()

+ React func(frame interface{}, c Conn) (out interface{}, action Action)

+ Tick func() (delay time.Duration, action Action)

+ type EventServer struct

+ func (es *EventServer) OnClosed(c Conn, err error) (action Action)

+ func (es *EventServer) OnInitComplete(svr Server) (action Action)

+ func (es *EventServer) OnOpened(c Conn) (out []byte, action Action)

+ func (es *EventServer) OnShutdown(svr Server)

+ func (es *EventServer) PreWrite()

+ func (es *EventServer) React(frame interface{}, c Conn) (out interface{}, action Action)

+ func (es *EventServer) Tick() (delay time.Duration, action Action)

+ type FixedLengthFrameCodec struct

+ func NewFixedLengthFrameCodec(frameLength int) *FixedLengthFrameCodec

+ func (cc *FixedLengthFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *FixedLengthFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type ICodec interface

+ Decode func(c Conn) ([]byte, error)

+ Encode func(c Conn, buf []byte) ([]byte, error)

+ type LengthFieldBasedFrameCodec struct

+ func NewLengthFieldBasedFrameCodec(ec EncoderConfig, dc DecoderConfig) *LengthFieldBasedFrameCodec

+ func (cc *LengthFieldBasedFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *LengthFieldBasedFrameCodec) Encode(c Conn, buf []byte) (out []byte, err error)

+ type LineBasedFrameCodec struct

+ func (cc *LineBasedFrameCodec) Decode(c Conn) ([]byte, error)

+ func (cc *LineBasedFrameCodec) Encode(c Conn, buf []byte) ([]byte, error)

+ type LoadBalancing int

+ const LeastConnections

+ const RoundRobin

+ const SourceAddrHash

+ type NICodec interface

+ Decode func(c Conn, dataFrame interface{}) (interface{}, error)

+ Encode func(dataFrame interface{}, dest []byte) ([]byte, error)

+ type Option func(opts *Options)

+ func WithBytePool(pool *sync.Pool) Option

+ func WithCodec(codec ICodec) Option

+ func WithLoadBalancing(lb LoadBalancing) Option

+ func WithLockOSThread(lockOSThread bool) Option

+ func WithLogger(logger logging.Logger) Option

+ func WithMulticore(multicore bool) Option

+ func WithNCodec(codec NICodec) Option

+ func WithNumEventLoop(numEventLoop int) Option

+ func WithObjPool(pool *sync.Pool) Option

+ func WithOptions(options Options) Option

+ func WithReusePort(reusePort bool) Option

+ func WithTCPKeepAlive(tcpKeepAlive time.Duration) Option

+ func WithTicker(ticker bool) Option

+ type Options struct

+ BytePool *sync.Pool

+ Codec ICodec

+ LB LoadBalancing

+ LockOSThread bool

+ Logger logging.Logger

+ Multicore bool

+ NCodec NICodec

+ NumEventLoop int

+ ObjPool *sync.Pool

+ ReusePort bool

+ TCPKeepAlive time.Duration

+ Ticker bool

+ type Server struct

+ Addr net.Addr

+ Multicore bool

+ NumEventLoop int

+ ReusePort bool

+ TCPKeepAlive time.Duration

+ func (s Server) CountConnections() (count int)

+ func (s Server) DupFd() (dupFD int, err error)