metpoll

package module

v0.0.0-...-3db8cd0 Latest Latest Go to latest Published: Aug 18, 2022 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jimbirthday/metpoll

Links

Open Source Insights

README ¶

metpoll

Golang Reactor netpoll

Documentation ¶

Rendered for

Index ¶

func GetTcpSocketAddr(addr string) (sa unix.Sockaddr, tcpAddr *net.TCPAddr, err error)
func NewEngine(ps int) *engine
func TCPSocket(addr string, passive bool) (int, net.Addr, error)
type Connect
type LB
type MSocket
type Poller
- func NewPoller() *Poller
type RoundRobinBalance
- func (rrb *RoundRobinBalance) Cur() int
- func (rrb *RoundRobinBalance) Set(t int)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetTcpSocketAddr ¶

func GetTcpSocketAddr(addr string) (sa unix.Sockaddr, tcpAddr *net.TCPAddr, err error)

func NewEngine ¶

func NewEngine(ps int) *engine

func TCPSocket ¶

func TCPSocket(addr string, passive bool) (int, net.Addr, error)

Types ¶

type Connect ¶

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

func (*Connect) Close ¶

func (c *Connect) Close()

func (*Connect) Read ¶

func (c *Connect) Read()

读取数据

func (*Connect) Write ¶

func (c *Connect) Write(data []byte)

type LB ¶

type LB interface {
	Cur() int
	Set(t int)
}

type MSocket ¶

type MSocket struct {
}

type Poller ¶

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

func NewPoller ¶

func NewPoller() *Poller

func (*Poller) AddConn ¶

func (p *Poller) AddConn(conn *Connect)

func (*Poller) CloseConn ¶

func (p *Poller) CloseConn(fd int) error

func (*Poller) DelConn ¶

func (p *Poller) DelConn(fd int)

func (*Poller) EpollAddEvent ¶

func (p *Poller) EpollAddEvent(fd int) error

func (*Poller) EpollRemoveEvent ¶

func (p *Poller) EpollRemoveEvent(fd int) error

func (*Poller) GetConn ¶

func (p *Poller) GetConn(fd int) *Connect

func (*Poller) HandlerEpoll ¶

func (p *Poller) HandlerEpoll() error

处理epoll

type RoundRobinBalance ¶

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

func (*RoundRobinBalance) Cur ¶

func (rrb *RoundRobinBalance) Cur() int

func (*RoundRobinBalance) Set ¶

func (rrb *RoundRobinBalance) Set(t int)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
main
pkg
socket

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL