engine

Documentation

Overview

Reactor engine.

Index

• type Engine
  • func New() *Engine
  • func (that *Engine) GetBalancer() iface.IBalancer
  • func (that *Engine) GetHandler() iface.IEventHandler
  • func (that *Engine) GetOptions() *iface.Options
  • func (that *Engine) Serve(handler iface.IEventHandler, ln iface.IListener, opt *iface.Options) (err error)
  • func (that *Engine) Stop()

Types

type Engine

type Engine struct {
	Listener  iface.IListener
	Balancer  iface.IBalancer
	MainLoop  *eloop.Eloop
	Handler   iface.IEventHandler
	IsClosing int32
	Options   *iface.Options
	Pool      *ants.Pool
	// contains filtered or unexported fields
}

func New

func New() *Engine

func (*Engine) GetBalancer

func (that *Engine) GetBalancer() iface.IBalancer

func (*Engine) GetHandler

func (that *Engine) GetHandler() iface.IEventHandler

func (*Engine) GetOptions

func (that *Engine) GetOptions() *iface.Options

func (*Engine) Serve

func (that *Engine) Serve(handler iface.IEventHandler, ln iface.IListener, opt *iface.Options) (err error)

TODO: reuseport options

func (*Engine) Stop

func (that *Engine) Stop()

send stop signal to the engine.