connector

Documentation

Index

• type Agent
• type ChannelRemote
  • func NewChannelRemote(conn Connector) *ChannelRemote
  • func (c *ChannelRemote) Broadcast(ctx context.Context, args *rpc.ArgsGroup, reply *rpc.ReplyGroup) error
  • func (c *ChannelRemote) PushMessageByGroup(ctx context.Context, args *rpc.ArgsGroup, reply *rpc.ReplyGroup) error
• type Connection
• type Connector
• type SessionMap
  • func (s *SessionMap) AddSession(a Agent)
  • func (s *SessionMap) DelSession(a Agent)
  • func (s *SessionMap) GetAgent(sessionId int64) (Agent, error)
  • func (s *SessionMap) GetSessionCount() int32
  • func (s *SessionMap) Range(f func(k, v interface{}) bool)
• type SessionRemote
  • func NewSessionRemote(c Connector) *SessionRemote
  • func (s *SessionRemote) Bind(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error
  • func (s *SessionRemote) GetSessionCount(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error
  • func (s *SessionRemote) KickBySid(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error
  • func (s *SessionRemote) Push(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error
  • func (s *SessionRemote) UnBind(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error
• type TimeJob
• type Timers
  • func NewTimer() *Timers
  • func (t *Timers) AfterFunc(d time.Duration, cb func()) *timer.Timer
  • func (t *Timers) ClearTimeout(handler *timer.Timer)
  • func (t *Timers) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron
  • func (t *Timers) RunTimer(closeSig chan bool)

Types

type Agent

type Agent interface {
	Write(data *[]byte)
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	Close()
	UserData() interface{}
	SetUserData(data interface{})
	GetSession() *rpc.Session
	PushMessage(uint32, []byte)
	KickMessage(string)
}

type ChannelRemote

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

func NewChannelRemote

func NewChannelRemote(conn Connector) *ChannelRemote

func (*ChannelRemote) Broadcast

func (c *ChannelRemote) Broadcast(ctx context.Context, args *rpc.ArgsGroup, reply *rpc.ReplyGroup) error

Broadcast to all the client connectd with current frontend server.

func (*ChannelRemote) PushMessageByGroup

func (c *ChannelRemote) PushMessageByGroup(ctx context.Context, args *rpc.ArgsGroup, reply *rpc.ReplyGroup) error

Push message to client by uids.

type Connection

type Connection interface {
	OnDisconnect(session *rpc.Session)
}

type Connector

type Connector interface {
	GetSessionMap() *SessionMap
}

type SessionMap

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

goroutine safe

func (*SessionMap) AddSession

func (s *SessionMap) AddSession(a Agent)

func (*SessionMap) DelSession

func (s *SessionMap) DelSession(a Agent)

func (*SessionMap) GetAgent

func (s *SessionMap) GetAgent(sessionId int64) (Agent, error)

func (*SessionMap) GetSessionCount

func (s *SessionMap) GetSessionCount() int32

func (*SessionMap) Range

func (s *SessionMap) Range(f func(k, v interface{}) bool)

type SessionRemote

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

func NewSessionRemote

func NewSessionRemote(c Connector) *SessionRemote

func (*SessionRemote) Bind

func (s *SessionRemote) Bind(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error

func (*SessionRemote) GetSessionCount

func (s *SessionRemote) GetSessionCount(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error

func (*SessionRemote) KickBySid

func (s *SessionRemote) KickBySid(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error

func (*SessionRemote) Push

func (s *SessionRemote) Push(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error

func (*SessionRemote) UnBind

func (s *SessionRemote) UnBind(ctx context.Context, args *rpc.Args, reply *rpc.Reply) error

type TimeJob

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

type Timers

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

func NewTimer

func NewTimer() *Timers

func (*Timers) AfterFunc

func (t *Timers) AfterFunc(d time.Duration, cb func()) *timer.Timer

func (*Timers) ClearTimeout

func (t *Timers) ClearTimeout(handler *timer.Timer)

func (*Timers) CronFunc

func (t *Timers) CronFunc(cronExpr *timer.CronExpr, cb func()) *timer.Cron

func (*Timers) RunTimer

func (t *Timers) RunTimer(closeSig chan bool)