netreactors

package module
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 25, 2025 License: MIT Imports: 15 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

View Source 
const (
	PrependSize    = 8
	BufferInitSize = 1024
)
View Source 
const (
	MaxRetryTime  = 30 * time.Second
	InitRetryTime = 500 * time.Millisecond
)
View Source 
const (
	InitEventListSize = 16
)

Variables ¶

View Source 
var AtomicNumber int64 = 0
View Source 
var Dlog = &Log{
	IsOpenDebugLog: false,
}

Functions ¶

This section is empty.

Types ¶

type Acceptor ¶ 

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

func NewAcceptor ¶ 

func NewAcceptor(loop *EventLoop, listenAddr *netip.AddrPort, reusePort bool) (ac *Acceptor)

func (*Acceptor) Listen ¶ 

func (a *Acceptor) Listen()

func (*Acceptor) Listening ¶ 

func (a *Acceptor) Listening() bool

func (*Acceptor) SetAcceptorNewConnectionCallback ¶ 

func (a *Acceptor) SetAcceptorNewConnectionCallback(cb AcceptorNewConnectionCallback)

type AcceptorNewConnectionCallback ¶ 

type AcceptorNewConnectionCallback func(int, *netip.AddrPort)

type Buffer ¶ 

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

func NewBuffer ¶ 

func NewBuffer() *Buffer

func (*Buffer) Append ¶ 

func (b *Buffer) Append(data []byte)

func (*Buffer) Peek ¶ 

func (b *Buffer) Peek() *byte

func (*Buffer) Prepend ¶ 

func (b *Buffer) Prepend(data []byte)

func (*Buffer) PrependBytes ¶ 

func (b *Buffer) PrependBytes() int

func (*Buffer) ReadFd ¶ 

func (b *Buffer) ReadFd(fd int, saveErrno *error) int

func (*Buffer) ReadableBytes ¶ 

func (b *Buffer) ReadableBytes() int

func (*Buffer) Retrieve ¶ 

func (b *Buffer) Retrieve(size int)

func (*Buffer) RetrieveAll ¶ 

func (b *Buffer) RetrieveAll()

func (*Buffer) RetrieveAllString ¶ 

func (b *Buffer) RetrieveAllString() []byte

func (*Buffer) RetrieveAsString ¶ 

func (b *Buffer) RetrieveAsString(size int) []byte

func (*Buffer) WriteableBytes ¶ 

func (b *Buffer) WriteableBytes() int

type Channel ¶ 

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

func NewChannel ¶ 

func NewChannel(loop *EventLoop, fdArg int32) *Channel

func (*Channel) DisableAll ¶ 

func (c *Channel) DisableAll()

func (*Channel) DisableReading ¶ 

func (c *Channel) DisableReading()

func (*Channel) DisableWriting ¶ 

func (c *Channel) DisableWriting()

func (*Channel) EnableReading ¶ 

func (c *Channel) EnableReading()

func (*Channel) EnableWriting ¶ 

func (c *Channel) EnableWriting()

func (*Channel) Events ¶ 

func (c *Channel) Events() int16

func (*Channel) Fd ¶ 

func (c *Channel) Fd() int32

func (*Channel) HandleEvent ¶ 

func (c *Channel) HandleEvent(time time.Time)

func (*Channel) Index ¶ 

func (c *Channel) Index() int

func (*Channel) IsNoneEvent ¶ 

func (c *Channel) IsNoneEvent() bool

func (*Channel) IsReading ¶ 

func (c *Channel) IsReading() bool

func (*Channel) IsWriting ¶ 

func (c *Channel) IsWriting() bool

func (*Channel) OwnerLoop ¶ 

func (c *Channel) OwnerLoop() *EventLoop

func (*Channel) Remove ¶ 

func (c *Channel) Remove()

func (*Channel) SetCloseCallback ¶ 

func (c *Channel) SetCloseCallback(cb EventCallback)

func (*Channel) SetErrorCallback ¶ 

func (c *Channel) SetErrorCallback(cb EventCallback)

func (*Channel) SetIndex ¶ 

func (c *Channel) SetIndex(idx int)

func (*Channel) SetReadCallback ¶ 

func (c *Channel) SetReadCallback(cb ReadEventCallback)

func (*Channel) SetRevents ¶ 

func (c *Channel) SetRevents(revt int16)

func (*Channel) SetWriteCallback ¶ 

func (c *Channel) SetWriteCallback(cb EventCallback)

type CloseCallback ¶ 

type CloseCallback func(*TcpConnection)

type ConnectionCallback ¶ 

type ConnectionCallback func(*TcpConnection)

TcpConnection

type Connector ¶ 

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

func NewConnector ¶ 

func NewConnector(loop *EventLoop, addr *netip.AddrPort) *Connector

func (*Connector) Restart ¶ 

func (c *Connector) Restart()

func (*Connector) SetConnectorNewConnectionCallback ¶ 

func (c *Connector) SetConnectorNewConnectionCallback(cb ConnectorNewConnectionCallback)

func (*Connector) Start ¶ 

func (c *Connector) Start()

func (*Connector) Stop ¶ 

func (c *Connector) Stop()

type ConnectorNewConnectionCallback ¶ 

type ConnectorNewConnectionCallback func(int)

type EpollPoller ¶ 

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

func NewEpollPoller ¶ 

func NewEpollPoller(loop *EventLoop) (ep *EpollPoller)

func (*EpollPoller) AssertInLoopGoroutine ¶ 

func (e *EpollPoller) AssertInLoopGoroutine()

func (*EpollPoller) Poll ¶ 

func (e *EpollPoller) Poll(timeoutMs int, activeChannels *[]*Channel) time.Time

func (*EpollPoller) RemoveChannel ¶ 

func (e *EpollPoller) RemoveChannel(channel *Channel)

func (*EpollPoller) UpdateChannel ¶ 

func (e *EpollPoller) UpdateChannel(channel *Channel)

type EventCallback ¶ 

type EventCallback func()

type EventLoop ¶ 

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

func NewEventLoop ¶ 

func NewEventLoop() (el *EventLoop)

func (*EventLoop) AssertInLoopGoroutine ¶ 

func (loop *EventLoop) AssertInLoopGoroutine()

func (*EventLoop) Cancel ¶ 

func (loop *EventLoop) Cancel(timerid TimerId)

func (*EventLoop) DoPendingFunctors ¶ 

func (loop *EventLoop) DoPendingFunctors()

execute callback in queue

func (*EventLoop) HandleRead ¶ 

func (loop *EventLoop) HandleRead(t time.Time)

wake up

func (*EventLoop) IsInLoopGoroutine ¶ 

func (loop *EventLoop) IsInLoopGoroutine() bool

func (*EventLoop) Loop ¶ 

func (loop *EventLoop) Loop()

Loop

func (*EventLoop) QueueInLoop ¶ 

func (loop *EventLoop) QueueInLoop(cb Functor)

functor queue

func (*EventLoop) Quit ¶ 

func (loop *EventLoop) Quit()

func (*EventLoop) RemoveChannel ¶ 

func (loop *EventLoop) RemoveChannel(c *Channel)

func (*EventLoop) RunAfter ¶ 

func (loop *EventLoop) RunAfter(duration time.Duration, cb TimerCallback) TimerId

callback run 'delay' from now

func (*EventLoop) RunAt ¶ 

func (loop *EventLoop) RunAt(t time.Time, cb TimerCallback) TimerId

callback run at 't'

func (*EventLoop) RunEvery ¶ 

func (loop *EventLoop) RunEvery(interval float64, cb TimerCallback) TimerId

callback run every 'interval'

func (*EventLoop) RunInLoop ¶ 

func (loop *EventLoop) RunInLoop(cb Functor)

make sure run in loop

func (*EventLoop) UpdateChannel ¶ 

func (loop *EventLoop) UpdateChannel(c *Channel)

func (*EventLoop) Wakeup ¶ 

func (loop *EventLoop) Wakeup()

type EventLoopGoroutine ¶ 

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

func NewEventLoopGoroutine ¶ 

func NewEventLoopGoroutine(cb GoroutineCallback) (elg *EventLoopGoroutine)

func (*EventLoopGoroutine) StartLoop ¶ 

func (elg *EventLoopGoroutine) StartLoop() *EventLoop

type EventLoopGoroutinePool ¶ 

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

func NewEventLoopGoroutinePool ¶ 

func NewEventLoopGoroutinePool(baseLoop *EventLoop) *EventLoopGoroutinePool

func (*EventLoopGoroutinePool) GetNextLoop ¶ 

func (ep *EventLoopGoroutinePool) GetNextLoop() (loop *EventLoop)

func (*EventLoopGoroutinePool) IsStarted ¶ 

func (ep *EventLoopGoroutinePool) IsStarted() bool

func (*EventLoopGoroutinePool) SetGoroutineNum ¶ 

func (ep *EventLoopGoroutinePool) SetGoroutineNum(num int)

func (*EventLoopGoroutinePool) Start ¶ 

func (ep *EventLoopGoroutinePool) Start(cb GoroutineCallback)

type Functor ¶ 

type Functor func()

type GoroutineCallback ¶ 

type GoroutineCallback func(*EventLoop)

type HighWaterMarkCallback ¶ 

type HighWaterMarkCallback func(*TcpConnection, int)

type Log ¶ 

type Log struct {
	IsOpenDebugLog bool
}

func (*Log) Printf ¶ 

func (d *Log) Printf(format string, v ...any)

func (*Log) TurnOffLog ¶ 

func (d *Log) TurnOffLog()

func (*Log) TurnOnLog ¶ 

func (d *Log) TurnOnLog()

type MessageCallback ¶ 

type MessageCallback func(*TcpConnection, *Buffer, time.Time)

type PollPoller ¶ 

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

func NewPollPoller ¶ 

func NewPollPoller(loop *EventLoop) *PollPoller

func (*PollPoller) AssertInLoopGoroutine ¶ 

func (p *PollPoller) AssertInLoopGoroutine()

func (*PollPoller) Poll ¶ 

func (p *PollPoller) Poll(timeoutMs int, activeChannels *[]*Channel) time.Time

func (*PollPoller) RemoveChannel ¶ 

func (p *PollPoller) RemoveChannel(channel *Channel)

func (*PollPoller) UpdateChannel ¶ 

func (p *PollPoller) UpdateChannel(channel *Channel)

type Poller ¶ 

type Poller interface {
	Poll(timeoutMs int, activeChannels *[]*Channel) time.Time
	UpdateChannel(channel *Channel)
	RemoveChannel(channel *Channel)
	// contains filtered or unexported methods
}

func NewDefaultPoller ¶ 

func NewDefaultPoller(loop *EventLoop) Poller

type ReadEventCallback ¶ 

type ReadEventCallback func(time.Time)

type TcpClient ¶ 

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

func NewTcpClient ¶ 

func NewTcpClient(loop *EventLoop, serverAddr *netip.AddrPort, name string) (client *TcpClient)

func (*TcpClient) Connect ¶ 

func (tc *TcpClient) Connect()

func (*TcpClient) Disconnect ¶ 

func (tc *TcpClient) Disconnect()

func (*TcpClient) EnableRetry ¶ 

func (tc *TcpClient) EnableRetry()

func (*TcpClient) GetLoop ¶ 

func (tc *TcpClient) GetLoop() *EventLoop

func (*TcpClient) IsRetry ¶ 

func (tc *TcpClient) IsRetry() bool

func (*TcpClient) Name ¶ 

func (tc *TcpClient) Name() string

func (*TcpClient) SetConnectionCallback ¶ 

func (tc *TcpClient) SetConnectionCallback(cb ConnectionCallback)

func (*TcpClient) SetMessageCallback ¶ 

func (tc *TcpClient) SetMessageCallback(cb MessageCallback)

func (*TcpClient) SetWriteCompleteCallback ¶ 

func (tc *TcpClient) SetWriteCompleteCallback(cb WriteCompleteCallback)

func (*TcpClient) Stop ¶ 

func (tc *TcpClient) Stop()

type TcpConnection ¶ 

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

func NewTcpConnection ¶ 

func NewTcpConnection(loop *EventLoop, name string, fd int, localAddr *netip.AddrPort, peerAddr *netip.AddrPort) (conn *TcpConnection)

************************* public: *************************

func (*TcpConnection) BindWriteCompleteCallback ¶ 

func (tc *TcpConnection) BindWriteCompleteCallback() func()

func (*TcpConnection) ConnectDestroyed ¶ 

func (tc *TcpConnection) ConnectDestroyed()

called when TcpServer has removed me from it's map

func (*TcpConnection) ConnectEstablished ¶ 

func (tc *TcpConnection) ConnectEstablished()

called when TcpServer accepts a new connection

func (*TcpConnection) Connected ¶ 

func (tc *TcpConnection) Connected() bool

func (*TcpConnection) ForceClose ¶ added in v1.0.1 

func (tc *TcpConnection) ForceClose()

ForceClose: force close connetion

func (*TcpConnection) GetLoop ¶ 

func (tc *TcpConnection) GetLoop() *EventLoop

func (*TcpConnection) InBuffer ¶ 

func (tc *TcpConnection) InBuffer() *Buffer

func (*TcpConnection) LocalAddr ¶ 

func (tc *TcpConnection) LocalAddr() *netip.AddrPort

func (*TcpConnection) Name ¶ 

func (tc *TcpConnection) Name() string

func (*TcpConnection) OutBuffer ¶ 

func (tc *TcpConnection) OutBuffer() *Buffer

func (*TcpConnection) PeerAddr ¶ 

func (tc *TcpConnection) PeerAddr() *netip.AddrPort

func (*TcpConnection) Send ¶ 

func (tc *TcpConnection) Send(message []byte)

send the 'message'

func (*TcpConnection) SendFromBuffer ¶ 

func (tc *TcpConnection) SendFromBuffer(buf *Buffer)

send the data from 'buf'

func (*TcpConnection) SetCloseCallback ¶ 

func (tc *TcpConnection) SetCloseCallback(cb CloseCallback)

func (*TcpConnection) SetConnectionCallback ¶ 

func (tc *TcpConnection) SetConnectionCallback(cb ConnectionCallback)

set callback

func (*TcpConnection) SetHighWaterMarkCallback ¶ 

func (tc *TcpConnection) SetHighWaterMarkCallback(cb HighWaterMarkCallback)

func (*TcpConnection) SetMessageCallback ¶ 

func (tc *TcpConnection) SetMessageCallback(cb MessageCallback)

func (*TcpConnection) SetTcpNoDelay ¶ 

func (tc *TcpConnection) SetTcpNoDelay(on bool)

func (*TcpConnection) SetWriteCompleteCallback ¶ 

func (tc *TcpConnection) SetWriteCompleteCallback(cb WriteCompleteCallback)

func (*TcpConnection) Shutdown ¶ 

func (tc *TcpConnection) Shutdown()

Shutdown: shutDown write side

type TcpServer ¶ 

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

func NewTcpServer ¶ 

func NewTcpServer(loop *EventLoop, addr *netip.AddrPort, name string) (server *TcpServer)

func (*TcpServer) SetConnectionCallback ¶ 

func (t *TcpServer) SetConnectionCallback(cb ConnectionCallback)

func (*TcpServer) SetGoroutineCallback ¶ 

func (t *TcpServer) SetGoroutineCallback(cb GoroutineCallback)

func (*TcpServer) SetGoroutineNum ¶ 

func (t *TcpServer) SetGoroutineNum(num int)

func (*TcpServer) SetMessageCallback ¶ 

func (t *TcpServer) SetMessageCallback(cb MessageCallback)

func (*TcpServer) SetWriteCompleteCallback ¶ 

func (t *TcpServer) SetWriteCompleteCallback(cb WriteCompleteCallback)

func (*TcpServer) Start ¶ 

func (t *TcpServer) Start()

type TimeEntry ¶ 

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

type Timer ¶ 

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

func NewTimer ¶ 

func NewTimer(cb TimerCallback, when time.Time, interval float64) *Timer

func (*Timer) Expiration ¶ 

func (t *Timer) Expiration() time.Time

func (*Timer) Repeat ¶ 

func (t *Timer) Repeat() bool

func (*Timer) Restart ¶ 

func (t *Timer) Restart(now time.Time)

func (*Timer) Run ¶ 

func (t *Timer) Run()

func (*Timer) Sequence ¶ 

func (t *Timer) Sequence() int64

type TimerCallback ¶ 

type TimerCallback func()

type TimerId ¶ 

type TimerId struct {
	Timer_    *Timer
	Sequence_ int64
}

func NewTimerId ¶ 

func NewTimerId(timer *Timer, seq int64) TimerId

type TimerList ¶ 

type TimerList []TimeEntry

func (TimerList) Len ¶ 

func (t TimerList) Len() int

implement the heap.Interface: implement the sort.Interface

func (TimerList) Less ¶ 

func (t TimerList) Less(i, j int) bool

func (*TimerList) Pop ¶ 

func (t *TimerList) Pop() any

func (*TimerList) Push ¶ 

func (t *TimerList) Push(x any)

implement Push and Pop

func (TimerList) Swap ¶ 

func (t TimerList) Swap(i, j int)

type TimerQueue ¶ 

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

fix: more high performance

func NewTimerQueue ¶ 

func NewTimerQueue(loop *EventLoop) (tq *TimerQueue)

func (*TimerQueue) AddTimer ¶ 

func (tq *TimerQueue) AddTimer(cb TimerCallback, when time.Time, interval float64) TimerId

func (*TimerQueue) Cancel ¶ 

func (tq *TimerQueue) Cancel(timerid TimerId)

func (*TimerQueue) HandleRead ¶ 

func (tq *TimerQueue) HandleRead(t time.Time)

called when timer alarms

type WriteCompleteCallback ¶ 

type WriteCompleteCallback func(*TcpConnection)

Source Files ¶

View all Source files

Directories ¶

Path Synopsis
base
goroutine
socket
util
benchmark
echo/netreactors command

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.