session

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (sm *Manager) Delete(id int64)
  • func (sm *Manager) Get(id int64) *Session
  • func (sm *Manager) Run(ctx context.Context, wc ikio.WriteCloser, ...) bool
  • func (sm *Manager) Set(id int64, s *Session)
  • func (sm *Manager) Size() int64
• type Session
  • func NewSession(c *ikio.ServerChannel) *Session
  • func (s *Session) Conn() *ikio.ServerChannel
  • func (s *Session) Info() interface{}
  • func (s *Session) LastHeartbeat() int64
  • func (s *Session) SetInfo(info interface{})
  • func (s *Session) UpdateInfo(cb func(info interface{}))
  • func (s *Session) UpdateLastHeartbeat(t int64)

Types

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) Delete

func (sm *Manager) Delete(id int64)

func (*Manager) Get

func (sm *Manager) Get(id int64) *Session

func (*Manager) Run

func (sm *Manager) Run(ctx context.Context, wc ikio.WriteCloser, cb func(ctx context.Context, s *Session)) bool

func (*Manager) Set

func (sm *Manager) Set(id int64, s *Session)

func (*Manager) Size

func (sm *Manager) Size() int64

type Session

type Session struct {
	ConnID int64
	// contains filtered or unexported fields
}

func NewSession

func NewSession(c *ikio.ServerChannel) *Session

func (*Session) Conn

func (s *Session) Conn() *ikio.ServerChannel

func (*Session) Info

func (s *Session) Info() interface{}

func (*Session) LastHeartbeat

func (s *Session) LastHeartbeat() int64

func (*Session) SetInfo

func (s *Session) SetInfo(info interface{})

func (*Session) UpdateInfo

func (s *Session) UpdateInfo(cb func(info interface{}))

func (*Session) UpdateLastHeartbeat

func (s *Session) UpdateLastHeartbeat(t int64)