session

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (p *Manager) Len() (n int)
  • func (p *Manager) Load(token []byte) (session *Session, ok bool)
  • func (p *Manager) Pop() (session *Session)
  • func (p *Manager) Push(session *Session)
  • func (p *Manager) Remove(token []byte) (session *Session, ok bool)
• type Session
  • func NewSession(deadline time.Time, sk socket.ServerSocket) *Session
  • func (p *Session) Close() error
  • func (p *Session) IsDead() (dead bool)
  • func (p *Session) Socket() socket.ServerSocket
  • func (p *Session) String() string
  • func (p *Session) Token() (token []byte)

Types

type Manager

type Manager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Manager is used to manage RSocket session when resume is enabled.

func NewManager

func NewManager() *Manager

NewManager returns a new blank session manager.

func (*Manager) Len

func (p *Manager) Len() (n int)

Len returns size of session in current manager.

func (*Manager) Load

func (p *Manager) Load(token []byte) (session *Session, ok bool)

Load returns session with custom token.

func (*Manager) Pop

func (p *Manager) Pop() (session *Session)

Pop pop earliest session.

func (*Manager) Push

func (p *Manager) Push(session *Session)

Push push a new session.

func (*Manager) Remove

func (p *Manager) Remove(token []byte) (session *Session, ok bool)

Remove remove a session with custom token.

type Session

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

Session represents a lifecycle of a RSocket server socket.

func NewSession

func NewSession(deadline time.Time, sk socket.ServerSocket) *Session

NewSession returns a new session.

func (*Session) Close

func (p *Session) Close() error

Close close current session.

func (*Session) IsDead

func (p *Session) IsDead() (dead bool)

IsDead returns true if current session is dead.

func (*Session) Socket

func (p *Session) Socket() socket.ServerSocket

Socket returns RSocket server socket in current session.

func (*Session) String

func (p *Session) String() string

func (*Session) Token

func (p *Session) Token() (token []byte)

Token returns token of session.