sessionstore

Documentation

Index

• func Delete(APIKey string)
• func DeleteAllConnections()
• func DeleteAllForUser(userID string)
• func Init()
• func OnSessionDelete(handler func(*Session))
• func OnSessionUpdate(handler func(*Session))
• func PublicKey() *rsa.PublicKey
• func PublicKeyBytes() []byte
• type Conn
• type Session
  • func GetAll() []*Session
  • func GetByAPIKey(APIKey string) (s *Session, err error)
  • func GetByUserID(id interface{}) (s *Session, err error)
  • func New(user map[string]interface{}, sessionID string) *Session
  • func (s *Session) AddSubscription(connID, uri string, extra interface{})
  • func (s *Session) Delete()
  • func (s *Session) DeleteConnection(connID string)
  • func (s *Session) DeleteSubscription(connID, uri string)
  • func (s *Session) GetAPIKey() string
  • func (s *Session) GetUserID() interface{}
  • func (s *Session) Save()

Functions

func Delete

func Delete(APIKey string)

Delete removes session by the APIKey provided from store

func DeleteAllConnections

func DeleteAllConnections()

DeleteAllConnections deletes all connections from all sessions

func DeleteAllForUser

func DeleteAllForUser(userID string)

DeleteAllForUser removes all sessions for user from store

func Init

func Init()

Init is the entrypoint of sessionstore

func OnSessionDelete

func OnSessionDelete(handler func(*Session))

OnSessionDelete registers callback that will called when session deleted

func OnSessionUpdate

func OnSessionUpdate(handler func(*Session))

OnSessionUpdate registers callback that will called when session updated

func PublicKey

func PublicKey() *rsa.PublicKey

PublicKey returns *rsa.PublicKey

func PublicKeyBytes

func PublicKeyBytes() []byte

PublicKeyBytes returns PEM RSA Key as []byte

Types

type Conn

type Conn struct {
	ConnID        string                 `json:"connId"`
	Subscriptions map[string]interface{} `json:"subscriptions"`
}

Conn represents WAMP connection in session

type Session

type Session struct {
	APIKey      string      `json:"apiKey"`
	AccessToken string      `json:"access_token,omitempty"`
	UserID      interface{} `json:"userId"`
	Connections []*Conn     `json:"connections"`
	CreatedAt   time.Time   `json:"createdAt"`
	LastRequest time.Time   `json:"lastRequest"`
	TTL         time.Time   `json:"ttl"`
	V           int         `json:"__v"`
	sync.RWMutex
}

Session represents user session in Blank

func GetAll

func GetAll() []*Session

GetAll returns all stored sessions

func GetByAPIKey

func GetByAPIKey(APIKey string) (s *Session, err error)

GetByAPIKey returns point to Session or error if it is not exists.

func GetByUserID

func GetByUserID(id interface{}) (s *Session, err error)

GetByUserID returns point to Session or error if it is not exists.

func New

func New(user map[string]interface{}, sessionID string) *Session

New created new user session.

func (*Session) AddSubscription

func (s *Session) AddSubscription(connID, uri string, extra interface{})

AddSubscription adds subscription URI with provided params to user session

func (*Session) Delete

func (s *Session) Delete()

Delete removes Session from store

func (*Session) DeleteConnection

func (s *Session) DeleteConnection(connID string)

DeleteConnection deletes WAMP connection from user session

func (*Session) DeleteSubscription

func (s *Session) DeleteSubscription(connID, uri string)

DeleteSubscription deletes subscription from connection of user session

func (*Session) GetAPIKey

func (s *Session) GetAPIKey() string

GetAPIKey returns apiKey of session

func (*Session) GetUserID

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

GetUserID returns userID stored in session

func (*Session) Save

func (s *Session) Save()

Save saves session in store