Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.5.8

May 1, 2024

v0.5.7

Apr 23, 2024

v0.5.6

Apr 19, 2024

v0.5.5

Apr 10, 2024

Changes in this version

+ func DisableHttpPProf()

+ func EnableHttpPProf(addr, prefix string, errorHandler func(err error))

+ type Conn interface

+ DelQueue func()

+ GetQueue func() string

+ SetQueue func(queue string)

+ Write func(data []byte) (n int, err error)

+ WriteBytes func(data []byte) error

+ WriteContext func(data []byte, context interface{}) error

+ WritePacket func(packet Packet) error

+ type ConnWriter func(packet Packet) error

+ type ConnectionClosedEventHandler func(srv Server, conn Conn, err error)

+ type ConnectionOpenedEventHandler func(srv Server, conn Conn)

+ type ConnectionReceivePacketEventHandler func(srv Server, conn Conn, packet Packet)

+ type Controller interface

+ EliminateConnection func(conn net.Conn, err error)

+ GetAnts func() *ants.Pool

+ GetServer func() Server

+ ReactPacket func(conn net.Conn, packet Packet)

+ RegisterConnection func(conn net.Conn, writer ConnWriter)

+ type Events interface

+ RegisterConnectionClosedEvent func(handler ConnectionClosedEventHandler, priority ...int)

+ RegisterConnectionOpenedEvent func(handler ConnectionOpenedEventHandler, priority ...int)

+ RegisterConnectionReceivePacketEvent func(handler ConnectionReceivePacketEventHandler, priority ...int)

+ RegisterLaunchedEvent func(handler LaunchedEventHandler, priority ...int)

+ RegisterShutdownEvent func(handler ShutdownEventHandler, priority ...int)

+ type LaunchedEventHandler func(srv Server, ip string, t time.Time)

+ type Network interface

+ Address func() string

+ OnRun func() error

+ OnSetup func(ctx context.Context, controller Controller) error

+ OnShutdown func() error

+ Schema func() string

+ type Options struct

+ func DefaultOptions() *Options

+ func NewOptions() *Options

+ func (opt *Options) Apply(options ...*Options)

+ func (opt *Options) GetActorMessageBufferInitialSize() int

+ func (opt *Options) GetActorMessageChannelSize() int

+ func (opt *Options) GetAsyncLowMessageDuration() time.Duration

+ func (opt *Options) GetLifeCycleLimit() time.Duration

+ func (opt *Options) GetLogger() *log.Logger

+ func (opt *Options) GetServerMessageBufferInitialSize() int

+ func (opt *Options) GetServerMessageChannelSize() int

+ func (opt *Options) GetSyncLowMessageDuration() time.Duration

+ func (opt *Options) IsDebug() bool

+ func (opt *Options) WithActorMessageBufferInitialSize(size int) *Options

+ func (opt *Options) WithActorMessageChannelSize(size int) *Options

+ func (opt *Options) WithAsyncLowMessageMonitor(duration time.Duration) *Options

+ func (opt *Options) WithDebug(debug bool) *Options

+ func (opt *Options) WithLifeCycleEnd(end time.Time) *Options

+ func (opt *Options) WithLifeCycleLimit(limit time.Duration) *Options

+ func (opt *Options) WithLogger(logger *log.Logger) *Options

+ func (opt *Options) WithServerMessageBufferInitialSize(size int) *Options

+ func (opt *Options) WithServerMessageChannelSize(size int) *Options

+ func (opt *Options) WithSyncLowMessageMonitor(duration time.Duration) *Options

+ type Packet interface

+ GetBytes func() []byte

+ GetContext func() any

+ SetContext func(ctx any) Packet

+ func NewPacket(data []byte) Packet

+ type Producer struct

+ func (p Producer) GetConn() (conn Conn, exist bool)

+ func (p Producer) GetServer() Server

+ type Server interface

+ GetStatus func() *State

+ PublishAsyncMessage func(topic string, handler messageEvents.AsynchronousHandler, ...)

+ PublishSyncMessage func(topic string, handler messageEvents.SynchronousHandler)

+ Run func() error

+ Shutdown func() error

+ func NewServer(network Network, options ...*Options) Server

+ type ShutdownEventHandler func(srv Server)

+ type State struct

+ Ip string

+ LaunchedAt time.Time

+ func (s *State) Status() *State