goNet

Jun 30, 2020

Changes in this version

type Session

+ JoinOrUpdateRoute func(index int, c Route)

type SessionRoute

+ func (s *SessionRoute) GetRoute(index int) (Route, error)

+ func (s *SessionRoute) JoinOrUpdateRoute(index int, c Route)

Jun 29, 2020

Changes in this version

+ func TuneHandlerCount(count int)

Jun 29, 2020

Changes in this version

+ const Default_Handler_Count

+ const System_Route_ID

+ func HandleEvent(e Event)

+ func NewSessionManager() *sessionManager

+ func UpdateSysRoute(c Route)

+ type Event struct

+ func CreateEvent(s Session, c Route, msg interface{}) Event

+ type Route interface

+ OnMsg func(session Session, msg interface{})

+ type SessionRoute struct

+ func (s *SessionRoute) GetController(index int) (Route, error)

+ func (s *SessionRoute) JoinOrUpdateController(index int, c Route)

Jun 12, 2020

Changes in this version

+ const Default_Pool_Size

+ var AntsPool *ants.Pool

May 29, 2020

Changes in this version

+ func FindMsg(msgID int) interface

+ func FindMsgIDByType(t reflect.Type) int

type Session

+ JoinOrUpdateController func(index int, c Controller)

type SessionController

+ func (s *SessionController) JoinOrUpdateController(index int, c Controller)

May 28, 2020

Changes in this version

+ func Broadcast(msg interface{})

+ func RecycleSession(ses Session)

+ func SessionCount() int

type Session

+ func AddSession() Session

+ func FindSession(id uint64) (Session, bool)

+ type SessionAbility interface

+ JoinController func(index int, c Controller)

+ SetID func(id uint64)

May 17, 2020

Changes in this version

+ func RegisterSessionType(ses interface{})

type Options

+ AllowMaxConn int

type PeerIdentify

+ func (p *PeerIdentify) Options(o Options)

+ func (p *PeerIdentify) SetOptions(o Options)

type SessionController

+ func (s *SessionController) JoinController(index int, c Controller)

+ type SessionStore struct

+ func (s *SessionStore) Value(v ...interface{}) interface{}

Apr 23, 2020

Changes in this version

+ type MsgController interface

+ ProcessMsg func(session Session, msg interface{})

+ type MsgControllers struct

+ func (s *MsgControllers) AddController(index int, c MsgController)

+ func (s *MsgControllers) GetController(index int) (MsgController, error)

+ type SystemMsgController struct

+ func (*SystemMsgController) ProcessMsg(session Session, msg interface{})

Apr 5, 2020

Changes in this version

+ const INVALID_SESSION_ID

+ const POOL_DEFAULT_SIZE

+ const SYSTEM_CONTROLLER_IDX

+ var Log = logrus.New()

+ var Opts = &Options

+ var SessionManager = newSessionManager()

+ func GetMsgBelongToControllerIdx(msgIndex int) int

+ func GetMsgByIdx(msgIndex int) interface

+ func GetMsgIdxByType(t reflect.Type) int

+ func NewLogrusHook(field string, levels ...logrus.Level) logrus.Hook

+ func RegisterMsg(msgIndex, controllerIndex int, msg interface{})

+ func RegisterPeer(peer Peer)

+ func SubmitMsgToAntsPool(c Controller, s Session, msg interface{})

+ func UpdateSystemController(c Controller)

+ type Controller interface

+ OnMsg func(session Session, msg interface{})

+ type Option func(opts *Options)

+ func WithAddr(addr string) Option

+ func WithOptions(options Options) Option

+ func WithPanicHandler(panicHandler func(interface{})) Option

+ func WithPeerType(peerType PeerType) Option

+ func WithReadDeadline(dur time.Duration) Option

+ func WithRoutinePoolSize(size int) Option

+ func WithWriteDeadline(dur time.Duration) Option

+ type Options struct

+ Addr string

+ PanicHandler func(interface{})

+ PeerType PeerType

+ PoolSize int

+ ReadDeadline time.Duration

+ WriteDeadline time.Duration

+ type Peer interface

+ Start func()

+ Stop func()

+ func NewPeer(opts ...Option) Peer

+ type PeerIdentify struct

+ func (p *PeerIdentify) Addr() string

+ func (p *PeerIdentify) SetAddr(addr string)

+ func (p *PeerIdentify) SetType(t PeerType)

+ func (p *PeerIdentify) Type() PeerType

+ type PeerType string

+ const PEERTYPE_CLIENT

+ const PEERTYPE_SERVER

+ type Ping struct

+ TimeStamp int64

+ type Pong struct

+ TimeStamp int64

+ type ProtoCol string

+ const HTTP

+ const KCP

+ const QUIC

+ const RPC

+ const TCP

+ const UDP

+ const WS

+ type Session interface

+ Close func()

+ ID func() uint32

+ Send func(msg interface{})

+ Socket func() interface{}

+ Value func(v ...interface{}) interface{}

+ type SessionClose struct

+ type SessionConnect struct

+ type SessionController struct

+ func (s *SessionController) AddController(index int, c Controller)

+ func (s *SessionController) GetController(index int) (Controller, error)

+ type SessionIdentify struct

+ func (s *SessionIdentify) ID() uint32

+ func (s *SessionIdentify) SetID(id uint32)

+ type SystemController struct

+ func (*SystemController) OnMsg(session Session, msg interface{})