gameapi

Jul 25, 2023

Changes in this version

type App

+ func (a *App) DisableFuse() error

+ func (a *App) EnableFuse() error

+ func (a *App) OnHeartbeat(session *Session)

+ func (a *App) SetHeartbeatListener(l Listener)

+ func (a *App) UpdateGdExtra(extra interface{}) error

type GameMetaData

+ Extra interface{}

+ OutUrl string

+ Version string

+ type Module interface

+ Init func(app *App)

type NetConfig

+ KcpMode string

type Session

+ ID int64

type SessionCallback

+ OnHeartbeat func(*Session)

May 8, 2023

Changes in this version

type App

+ func (a *App) DelSession(userID int64)

type Context

+ SendActorLocation func(userID int64, opcode interface{}, msg proto.Message) error

+ SendActorPush func(userID int64, opcode interface{}, msg proto.Message) error

type DefaultContext

+ func (c *DefaultContext) SendActorLocation(userID int64, opcode interface{}, msg proto.Message) error

+ func (c *DefaultContext) SendActorPush(userID int64, opcode interface{}, msg proto.Message) error

type Session

+ func (s *Session) App() *App

+ func (s *Session) IsExipred() bool

+ func (s *Session) SetExpired(expired int64)

May 6, 2023

Changes in this version

type App

+ func (a *App) GetGd() GameMetaData

May 6, 2023

Changes in this version

type GameMetaData

+ Password string

May 5, 2023

Changes in this version

+ const StateAliave

+ const StateBusy

+ const StateFull

+ const StateIdle

+ const StateZero

+ var ErrWrongOpCode = errors.New("wrong opcode")

type App

+ func (a *App) AddAfterMiddleware(m Middleware)

+ func (a *App) AddBeforeMiddleware(m Middleware)

+ func (a *App) SendAllActor(opcode uint16, msg proto.Message) error

+ func (a *App) UpdateGdState(state int) error

type Context

+ GetOpCode func() uint16

+ SendAllActor func(opcode interface{}, msg proto.Message) error

type DefaultContext

+ func (c *DefaultContext) GetOpCode() uint16

+ func (c *DefaultContext) SendAllActor(opcode interface{}, msg proto.Message) error

type DefaultPacket

+ func (p *DefaultPacket) Free()

+ type GameMetaData struct

+ Fuse bool

+ ID int64

+ Network string

+ State int

+ UseTLS bool

type Middleware

+ Condition func(uint16) bool

+ Do func(Context) error

type Packet

+ var DefaultPacketPool = sync.Pool{ ... }

+ Free func()

+ type UserNats struct

+ func NewUserNats(natsUrl string, serverName string) (*UserNats, error)

+ func (u *UserNats) Close()

+ func (u *UserNats) Consume() <-chan PushActorMessage

+ func (u *UserNats) Publish(userID int64, p Packet) error

+ func (u *UserNats) StartSubscribe(subLimit int) error

Apr 24, 2023

Changes in this version

+ type KcpNetConn struct

+ func (k *KcpNetConn) Close()

+ func (k *KcpNetConn) ReadPacket() (Packet, error)

+ func (k *KcpNetConn) WritePacket(p Packet) error

+ type KcpNetListener struct

+ func (l *KcpNetListener) Accept() (NetConn, error)

+ func (l *KcpNetListener) Close()

+ type NetConfig struct

+ Addr string

+ ReadeTimeout time.Duration

+ TLSConfig *tls.Config

+ WebSocketPath string

+ WriteTimeout time.Duration

+ type NetConn interface

+ Close func()

+ ReadPacket func() (Packet, error)

+ WritePacket func(Packet) error

+ func NewKcpNetConn(c net.Conn, config *NetConfig) NetConn

+ func NewTcpNetConn(c net.Conn, config *NetConfig) NetConn

+ func NewWebSocketNetConn(c *websocket.Conn, config *NetConfig) NetConn

+ type NetListener interface

+ Accept func() (NetConn, error)

+ Close func()

+ func NewKcpNetListener(config NetConfig) (NetListener, error)

+ func NewTcpNetListener(config NetConfig) (NetListener, error)

+ func NewWebSocketNetListener(config NetConfig) (NetListener, error)

type Packet

+ func NewPacket(buff []byte) Packet

+ type TcpNetConn struct

+ func (t *TcpNetConn) Close()

+ func (t *TcpNetConn) ReadPacket() (Packet, error)

+ func (t *TcpNetConn) WritePacket(p Packet) error

+ type TcpNetListener struct

+ func (l *TcpNetListener) Accept() (NetConn, error)

+ func (l *TcpNetListener) Close()

+ type WebSocketNetConn struct

+ func (w *WebSocketNetConn) Close()

+ func (w *WebSocketNetConn) ReadPacket() (Packet, error)

+ func (w *WebSocketNetConn) WritePacket(p Packet) error

+ type WebSocketNetListener struct

+ func (l *WebSocketNetListener) Accept() (NetConn, error)

+ func (l *WebSocketNetListener) Close()

Apr 15, 2023

Changes in this version

+ func GetRequestID(ctx Context) string

type Context

+ GetRequestID func() string

type DefaultContext

+ func (c *DefaultContext) GetRequestID() string

Apr 7, 2023

Changes in this version

+ const NatsPushUserK

+ var ErrUserNoIn = errors.New("user no in instance")

type App

+ func (a *App) AddSession(userID int64, session *Session)

+ func (a *App) SendActor(userID int64, opcode uint16, msg proto.Message) error

+ type Client struct

+ Conn net.Conn

+ func NewClient(conn net.Conn, readLimit int, sendLimit int, heart time.Duration) *Client

+ func (c *Client) Close()

+ func (c *Client) KeepAlive(interval time.Duration)

+ func (c *Client) Ping()

+ func (c *Client) Receive() <-chan Packet

+ func (c *Client) Send(opcode uint16, msg protoreflect.ProtoMessage) error

type Context

+ SendActor func(userID int64, opcode uint16, msg proto.Message) error

+ Valid func(userID int64)

type DefaultContext

+ func (c *DefaultContext) SendActor(userID int64, opcode uint16, msg proto.Message) error

+ func (c *DefaultContext) Valid(userID int64)

+ type PushActorMessage struct

+ Msg []byte

+ OpCode uint16

+ UserID int64

type Session

+ func (s *Session) SetUserID(userID int64)

Apr 1, 2023

Changes in this version

+ var ErrConnClosing = errors.New("session connect is closing")

+ var ErrNoImplementNetwork = errors.New("no implement network: ")

+ type App struct

+ func New(configPath string, addr string, instancdID int64) *App

+ func (a *App) AddHandler(opcode uint16, h Handler)

+ func (a *App) AddModule(module Moddule)

+ func (a *App) GetTotalConn() int64

+ func (a *App) Init() (err error)

+ func (a *App) OnConnect(session *Session) bool

+ func (a *App) OnDisConnect(sesssion *Session)

+ func (a *App) OnMessage(session *Session, p Packet) bool

+ func (a *App) SetBeforeMiddleware(m Middleware)

+ func (a *App) SetConnectListener(l Listener)

+ func (a *App) SetDisconnectListener(l Listener)

+ func (a *App) Start() error

+ func (a *App) Stop()

+ type Context interface

+ Context func() context.Context

+ Params func(m protoreflect.ProtoMessage) error

+ Send func(opcode uint16, msg proto.Message) error

+ Session func() *Session

+ func NewDefaultContext(ctx context.Context, body []byte, session *Session) Context

+ type DefaultContext struct

+ func (c *DefaultContext) Context() context.Context

+ func (c *DefaultContext) Params(m protoreflect.ProtoMessage) error

+ func (c *DefaultContext) Send(opcode uint16, msg proto.Message) error

+ func (c *DefaultContext) Session() *Session

+ type DefaultPacket struct

+ func NewDefaultPacket(buff []byte, opcode uint16) *DefaultPacket

+ func (p *DefaultPacket) Body() []byte

+ func (p *DefaultPacket) BodyLen() uint16

+ func (p *DefaultPacket) OpCode() uint16

+ func (p *DefaultPacket) Serialize() []byte

+ type Handler func(Context) error

+ type Listener func(*Session) error

+ type Middleware func(*Session, Packet) error

+ type Moddule interface

+ Group func() map[uint16]Handler

+ Init func(app *App)

+ type Packet interface

+ Body func() []byte

+ BodyLen func() uint16

+ OpCode func() uint16

+ Serialize func() []byte

+ var HeartPacket Packet = NewDefaultPacket(nil, 0)

+ func CretaePbPacket(opcode uint16, msg proto.Message) (Packet, error)

+ func Packing(r io.Reader) (Packet, error)

+ type Session struct

+ func NewSession(conn net.Conn, app *App) *Session

+ func (s *Session) Close()

+ func (s *Session) GetConn() net.Conn

+ func (s *Session) IsClosed() bool

+ func (s *Session) IsValid() bool

+ func (s *Session) Run()

+ func (s *Session) SetUserData(d interface{})

+ func (s *Session) UserData() interface{}

+ func (s *Session) UserID() int64

+ func (s *Session) Valid(userId int64)

+ func (s *Session) WritePacket(p Packet) (err error)

+ type SessionCallback interface

+ OnConnect func(*Session) bool

+ OnDisConnect func(*Session)

+ OnMessage func(*Session, Packet) bool

+ type SessionCreator func(net.Conn, *App) *Session