lwnet

README

lwnet-go

Documentation

Index

• func Serve(eventHandler EventHandler, addr string, opts ...Option) error
• type Connection
• type EventHandler
• type Option
  • func WithAcceptCoroutineNum(acceptCoroutineNum int) Option
  • func WithEventCoroutineNum(eventCoroutineNum int) Option
  • func WithReusePort(reusePort bool) Option
  • func WithRingBufSize(ringBufSize int) Option
• type Options
• type Poller
  • func Create() (*Poller, error)
  • func (ep *Poller) AddRead(fd int) error
  • func (ep *Poller) AddWrite(fd int) error
  • func (ep *Poller) Delete(fd int) error
  • func (ep *Poller) ModRead(fd int) error
  • func (ep *Poller) ModReadWrite(fd int) error
  • func (ep *Poller) Poll(handler func(fd int, event int32))
  • func (ep *Poller) Trigger(job internal.Job) error

Functions

func Serve

func Serve(eventHandler EventHandler, addr string, opts ...Option) error

Types

type Connection

type Connection interface {
	Write(data []byte)
	IsConnected() bool
	RemoteAddr() net.Addr
	Close()
	GetSysFd() int
	SetContext(ctx interface{})
	GetContext() interface{}
}

type EventHandler

type EventHandler interface {
	OnNewConnect(c Connection)
	OnNewRead(c Connection, readBuffer *ringbuffer.RingBuffer)
	OnClose(c Connection)
}

type Option

type Option func(opts *Options)

func WithAcceptCoroutineNum

func WithAcceptCoroutineNum(acceptCoroutineNum int) Option

func WithEventCoroutineNum

func WithEventCoroutineNum(eventCoroutineNum int) Option

func WithReusePort

func WithReusePort(reusePort bool) Option

func WithRingBufSize

func WithRingBufSize(ringBufSize int) Option

type Options

type Options struct {
	AcceptCoroutineNum int
	EventCoroutineNum  int

	RingBufSize int

	// ReusePort indicates whether to set up the SO_REUSEPORT option.
	ReusePort bool
}

type Poller

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

func Create

func Create() (*Poller, error)

func (*Poller) AddRead

func (ep *Poller) AddRead(fd int) error

func (*Poller) AddWrite

func (ep *Poller) AddWrite(fd int) error

func (*Poller) Delete

func (ep *Poller) Delete(fd int) error

func (*Poller) ModRead

func (ep *Poller) ModRead(fd int) error

func (*Poller) ModReadWrite

func (ep *Poller) ModReadWrite(fd int) error

func (*Poller) Poll

func (ep *Poller) Poll(handler func(fd int, event int32))

func (*Poller) Trigger

func (ep *Poller) Trigger(job internal.Job) error