epoll

Documentation

Index

• Variables
• type Config
  • func (Config) MarshalEasyJSON(w *jwriter.Writer)
  • func (Config) MarshalJSON() ([]byte, error)
  • func (*Config) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (*Config) UnmarshalJSON([]byte) error
• type ConfigItem
  • func (ConfigItem) MarshalEasyJSON(w *jwriter.Writer)
  • func (ConfigItem) MarshalJSON() ([]byte, error)
  • func (*ConfigItem) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (*ConfigItem) UnmarshalJSON([]byte) error
• type ConnectionHandler
• type EasyJSON_exporter_Config
• type EasyJSON_exporter_ConfigItem
• type Epoll
  • func NewEpoll(log logger.Logger) (*Epoll, error)
  • func (e *Epoll) AddOrClose(c net.Conn) error
  • func (e *Epoll) Close(c *NetItem) error
  • func (e *Epoll) CloseAll() (er error)
  • func (e *Epoll) Wait() (NetSlice, error)
• type Events
• type NetItem
  • func (n *NetItem) Await(b bool)
  • func (n *NetItem) IsAwait() bool
• type NetMap
• type NetSlice
• type Server
  • func New(conf *Config, handler ConnectionHandler, log logger.Logger) *Server
  • func NewCustomServer(conf ConfigItem, handler ConnectionHandler, eof []byte, log logger.Logger) *Server
  • func (s *Server) Down() (err error)
  • func (s *Server) Up() (err error)

Variables

var (
	ErrEpollEmptyEvents = errors.New("epoll empty event")
)

var (
	ErrInvalidEOF = errors.New("invalid eof chars")
)

var (
	ErrInvalidPoolType = errors.New("invalid data type from pool")
)

Types

type Config

type Config struct {
	Epoll ConfigItem `yaml:"epoll" json:"epoll"`
}

Config model

func (Config) MarshalEasyJSON

func (Config) MarshalEasyJSON(w *jwriter.Writer)

func (Config) MarshalJSON

func (Config) MarshalJSON() ([]byte, error)

func (*Config) UnmarshalEasyJSON

func (*Config) UnmarshalEasyJSON(l *jlexer.Lexer)

func (*Config) UnmarshalJSON

func (*Config) UnmarshalJSON([]byte) error

type ConfigItem

type ConfigItem struct {
	Addr string `yaml:"addr" json:"addr"`
}

ConfigItem model

func (ConfigItem) MarshalEasyJSON

func (ConfigItem) MarshalEasyJSON(w *jwriter.Writer)

func (ConfigItem) MarshalJSON

func (ConfigItem) MarshalJSON() ([]byte, error)

func (*ConfigItem) UnmarshalEasyJSON

func (*ConfigItem) UnmarshalEasyJSON(l *jlexer.Lexer)

func (*ConfigItem) UnmarshalJSON

func (*ConfigItem) UnmarshalJSON([]byte) error

type ConnectionHandler

type ConnectionHandler func([]byte, io.Writer) error

ConnectionHandler ...

type EasyJSON_exporter_Config

type EasyJSON_exporter_Config *Config

type EasyJSON_exporter_ConfigItem

type EasyJSON_exporter_ConfigItem *ConfigItem

type Epoll

type Epoll struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Epoll ...

func NewEpoll

func NewEpoll(log logger.Logger) (*Epoll, error)

New init epoll

func (*Epoll) AddOrClose

func (e *Epoll) AddOrClose(c net.Conn) error

AddOrClose ...

func (*Epoll) Close

func (e *Epoll) Close(c *NetItem) error

Close ...

func (*Epoll) CloseAll

func (e *Epoll) CloseAll() (er error)

CloseAll ...

func (*Epoll) Wait

func (e *Epoll) Wait() (NetSlice, error)

Wait ...

type Events

type Events []unix.EpollEvent

type NetItem

type NetItem struct {
	Conn net.Conn

	Fd int
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*NetItem) Await

func (n *NetItem) Await(b bool)

Await ...

func (*NetItem) IsAwait

func (n *NetItem) IsAwait() bool

IsAwait ...

type NetMap

type NetMap map[int]*NetItem

type NetSlice

type NetSlice []*NetItem

type Server

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

Server ...

func New

func New(conf *Config, handler ConnectionHandler, log logger.Logger) *Server

NewServer ...

func NewCustomServer

func NewCustomServer(conf ConfigItem, handler ConnectionHandler, eof []byte, log logger.Logger) *Server

NewCustomServer ...

func (*Server) Down

func (s *Server) Down() (err error)

Down ...

func (*Server) Up

func (s *Server) Up() (err error)

Up ...