epoll

Documentation

Overview

Package epoll implements the epoll-based I/O engine for Linux.

Index

• type Engine
  • func New(cfg resource.Config, handler stream.Handler) (*Engine, error)
  • func (e *Engine) Addr() net.Addr
  • func (e *Engine) Listen(ctx context.Context) error
  • func (e *Engine) Metrics() engine.EngineMetrics
  • func (e *Engine) PauseAccept() error
  • func (e *Engine) ResumeAccept() error
  • func (e *Engine) Shutdown(_ context.Context) error
  • func (e *Engine) Type() engine.EngineType
• type Loop

Types

type Engine

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

Engine implements the epoll-based I/O engine.

func New

func New(cfg resource.Config, handler stream.Handler) (*Engine, error)

New creates a new epoll engine.

func (*Engine) Addr

func (e *Engine) Addr() net.Addr

Addr returns the bound listener address.

func (*Engine) Listen

func (e *Engine) Listen(ctx context.Context) error

Listen starts the epoll engine and blocks until context is canceled.

func (*Engine) Metrics

func (e *Engine) Metrics() engine.EngineMetrics

Metrics returns a snapshot of engine metrics.

func (*Engine) PauseAccept

func (e *Engine) PauseAccept() error

PauseAccept stops accepting new connections while keeping existing ones alive.

func (*Engine) ResumeAccept

func (e *Engine) ResumeAccept() error

ResumeAccept starts accepting new connections again. Wakes any suspended loops so they re-create listen sockets.

func (*Engine) Shutdown

func (e *Engine) Shutdown(_ context.Context) error

Shutdown gracefully shuts down the engine.

func (*Engine) Type

func (e *Engine) Type() engine.EngineType

Type returns the engine type.

type Loop

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

Loop is an epoll-based event loop worker.