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))
• type Conn
• type Session
  • func GetAll() []*Session
  • func GetByAPIKey(APIKey string) (s *Session, err error)
  • func GetByUserID(id string) (s *Session, err error)
  • func New(userID string, tmp ...bool) *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() string
  • func (s *Session) Save(noLastRequestUpdate bool)

Functions

func Delete

func Delete(APIKey string)

Delete removes session by the APIKey provided from store

func DeleteAllConnections

func DeleteAllConnections()

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

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"`
	UserID      string    `json:"userId"`
	Connections []*Conn   `json:"connections"`
	LastRequest time.Time `json:"lastRequest"`
	V           int       `json:"__v"`

	sync.RWMutex
	// contains filtered or unexported fields
}

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 string) (s *Session, err error)

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

func New

func New(userID string, tmp ...bool) *Session

New created new user session. Optional bool param for creating session with 1 minute ttl

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() string

GetUserID returns userID stored in session

func (*Session) Save

func (s *Session) Save(noLastRequestUpdate bool)

Save saves session in store and update LastRequest prop in it.