memactives

Documentation

Index

• Variables
• type Config
  • func (c *Config) CreateService() (*Service, error)
  • func (c *Config) Execute(us *usersystem.UserSystem) error
• type Service
  • func NewService() *Service
  • func (s *Service) Execute(us *usersystem.UserSystem) error
  • func (s *Service) MustConfig(st usersystem.SessionType) *activesessions.Config
  • func (s *Service) MustCreateSerialNumber() string
  • func (s *Service) MustGetActiveSessions(st usersystem.SessionType, uid string) []*activesessions.Active
  • func (s *Service) MustOnSessionActive(session *usersystem.Session)
  • func (s *Service) MustPurgeActiveSession(st usersystem.SessionType, uid string, serialnumber string)
  • func (s *Service) Start() error
  • func (s *Service) Stop() error
• type Store
  • func NewStore() *Store
  • func (s *Store) GetActiveSessions(uid string, from time.Time) map[string]*activesessions.Active
  • func (s *Store) OnSessionActive(session *usersystem.Session)
  • func (s *Store) PurgeActiveSession(uid string, serialnumber string)
• type StoreList
  • func NewStoreList() *StoreList
  • func (l *StoreList) GetActiveSessions(uid string) []*activesessions.Active
  • func (l *StoreList) OnSessionActive(session *usersystem.Session)
  • func (l *StoreList) PurgeActiveSession(uid string, serialnumber string)
  • func (l *StoreList) Start() error
  • func (l *StoreList) Stop() error
  • func (l *StoreList) Update()
• type UserData
  • func NewUserdata() *UserData
  • func (d *UserData) GetActiveSessions(from time.Time) map[string]*activesessions.Active
  • func (d *UserData) OnSessionActive(session *usersystem.Session)
  • func (d *UserData) PurgeActiveSession(serialnumber string)

Variables

var DirectiveFactory = func(loader func(v interface{}) error) (usersystem.Directive, error) {
	c := &Config{}
	err := loader(c)

	if err != nil {
		return nil, err
	}

	return c, nil
}

Types

type Config

type Config struct {
	Durations map[string]string
}

func (*Config) CreateService

func (c *Config) CreateService() (*Service, error)

func (*Config) Execute

func (c *Config) Execute(us *usersystem.UserSystem) error

type Service

type Service struct {
	Stores map[usersystem.SessionType]*StoreList
}

func NewService

func NewService() *Service

func (*Service) Execute

func (s *Service) Execute(us *usersystem.UserSystem) error

func (*Service) MustConfig

func (s *Service) MustConfig(st usersystem.SessionType) *activesessions.Config

func (*Service) MustCreateSerialNumber

func (s *Service) MustCreateSerialNumber() string

func (*Service) MustGetActiveSessions

func (s *Service) MustGetActiveSessions(st usersystem.SessionType, uid string) []*activesessions.Active

func (*Service) MustOnSessionActive

func (s *Service) MustOnSessionActive(session *usersystem.Session)

func (*Service) MustPurgeActiveSession

func (s *Service) MustPurgeActiveSession(st usersystem.SessionType, uid string, serialnumber string)

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error

type Store

type Store struct {
	CreatedTime time.Time
	Data        map[string]*UserData
}

func NewStore

func NewStore() *Store

func (*Store) GetActiveSessions

func (s *Store) GetActiveSessions(uid string, from time.Time) map[string]*activesessions.Active

func (*Store) OnSessionActive

func (s *Store) OnSessionActive(session *usersystem.Session)

func (*Store) PurgeActiveSession

func (s *Store) PurgeActiveSession(uid string, serialnumber string)

type StoreList

type StoreList struct {
	Ticker   *time.Ticker
	Duration time.Duration
	Locker   sync.RWMutex
	List     []*Store
}

func NewStoreList

func NewStoreList() *StoreList

func (*StoreList) GetActiveSessions

func (l *StoreList) GetActiveSessions(uid string) []*activesessions.Active

func (*StoreList) OnSessionActive

func (l *StoreList) OnSessionActive(session *usersystem.Session)

func (*StoreList) PurgeActiveSession

func (l *StoreList) PurgeActiveSession(uid string, serialnumber string)

func (*StoreList) Start

func (l *StoreList) Start() error

func (*StoreList) Stop

func (l *StoreList) Stop() error

func (*StoreList) Update

func (l *StoreList) Update()

type UserData

type UserData map[string]*activesessions.Active

func NewUserdata

func NewUserdata() *UserData

func (*UserData) GetActiveSessions

func (d *UserData) GetActiveSessions(from time.Time) map[string]*activesessions.Active

func (*UserData) OnSessionActive

func (d *UserData) OnSessionActive(session *usersystem.Session)

func (*UserData) PurgeActiveSession

func (d *UserData) PurgeActiveSession(serialnumber string)