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

evnet

package module

Go to main page

Versions in this module

v0

v0.9.2

Feb 16, 2023

v0.9.1

Feb 16, 2023

Changes in this version

type Conn

+ Close func() error

v0.9.0

Feb 16, 2023

Changes in this version

+ const PollEventsCap

+ var ErrClose = errors.New("Close")

+ var ErrClosedWhenWritting = errors.New("Closed when writting")

+ var ErrShutdown = errors.New("Shutdown")

type BuiltinEventHandler

+ func (builtinEventHandler BuiltinEventHandler) OnBoot(mr *MainReactor) error

+ func (builtinEventHandler BuiltinEventHandler) OnOpen(c Conn) error

+ func (builtinEventHandler BuiltinEventHandler) OnShutdown(mr *MainReactor) error

+ func (builtinEventHandler BuiltinEventHandler) OnTraffic(c Conn) error

type Conn

+ Context func() interface{}

+ SetContext func(ctx interface{})

type EventHandler

+ OnBoot func(mr *MainReactor) error

+ OnOpen func(c Conn) error

+ OnShutdown func(mr *MainReactor) error

+ OnTraffic func(c Conn) error

+ type OptionArg struct

+ LogLevel log.Level

+ LogPath string

type Poller

+ func (p *Poller) ModRead(fd int) error

+ func (p *Poller) ModReadWrite(fd int) error

+ type SetOption func(optArg *OptionArg)

+ func WithLogLevel(logLevel log.Level) SetOption

type SubReactor

+ func (sr *SubReactor) Polling(callback func(fd int, events uint32) error)

+ type Writer interface

+ AsyncWrite func([]byte, func(Conn) error) error

v0.0.3

Aug 11, 2022

v0.0.2

Aug 11, 2022

Changes in this version

+ const ErrEvents

+ const InEvents

+ const OutEvents

+ var SubReactorsNum = 2

+ func AcceptSocket(fd int) (int, net.Addr, error)

+ func Run(eventHandler EventHandler, protoAddr string, optList ...Option)

+ type BuiltinEventHandler struct

+ func (builtinEventHandler BuiltinEventHandler) OnClose(c Conn)

+ func (builtinEventHandler BuiltinEventHandler) OnConn(c Conn)

+ type Conn interface

+ LocalAddr func() (addr net.Addr)

+ Next func(n int) ([]byte, error)

+ RemoteAddr func() (addr net.Addr)

+ func NewConn(fd int, la net.Addr, ra net.Addr) (Conn, error)

+ type EventHandler interface

+ OnClose func(c Conn)

+ OnConn func(c Conn)

+ type Listener struct

+ Fd int

+ type MainReactor struct

+ func (mainReactor *MainReactor) Listen(proto, addr string) (fd int, netAddr net.Addr, err error)

+ func (mainReactor *MainReactor) Loop()

+ func (mr *MainReactor) Init(proto, addr string) error

+ func (mr *MainReactor) SetEventHandler(eh EventHandler)

+ type Option func(opts *Options)

+ func WithLogPath(logPath string) Option

+ type Options struct

+ LogPath string

+ type PollAttachment struct

+ Event unix.EpollEvent

+ Fd int

+ type Poller struct

+ Fd int

+ func OpenPoller() (poller *Poller, err error)

+ func (p *Poller) Delete(fd int) error

+ func (poller *Poller) AddPollRead(pafd int) error

+ func (poller *Poller) Polling() []unix.EpollEvent

+ type SubReactor struct

+ func (sr *SubReactor) Loop()