Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tracker

package

Go to main page

Versions in this module

v0

v0.9.3

Oct 24, 2024

v0.9.2

Oct 9, 2024

v0.9.1

Jun 11, 2024

Changes in this version

+ const BaseSubject

+ const StreamName

+ const UsersUpdate

+ type ITracker interface

+ GetAllActiveUsers func() ([]*livemap.UserMarker, error)

+ GetUserById func(id int32) (*livemap.UserMarker, bool)

+ GetUsersByJob func(job string) (*xsync.MapOf[int32, *livemap.UserMarker], bool)

+ IsUserOnDuty func(userId int32) bool

+ Subscribe func() chan *livemap.UsersUpdateEvent

+ Unsubscribe func(c chan *livemap.UsersUpdateEvent)

+ func New(p Params) (ITracker, error)

+ func NewForTests(p TestParams) ITracker

+ type Manager struct

+ func NewManager(p ManagerParams) (*Manager, error)

+ type ManagerParams struct

+ AppConfig appconfig.IConfig

+ Config *config.Config

+ DB *sql.DB

+ Enricher *mstlystcdata.Enricher

+ JS *events.JSWrapper

+ LC fx.Lifecycle

+ Logger *zap.Logger

+ Postals postals.Postals

+ State *state.State

+ TP *tracesdk.TracerProvider

+ type Params struct

+ JS *events.JSWrapper

+ LC fx.Lifecycle

+ Logger *zap.Logger

+ TP *tracesdk.TracerProvider

+ type TestParams struct

+ LC fx.Lifecycle

+ type TestTracker struct

+ func (s *TestTracker) GetAllActiveUsers() ([]*livemap.UserMarker, error)

+ func (s *TestTracker) GetUserById(id int32) (*livemap.UserMarker, bool)

+ func (s *TestTracker) GetUserByJobAndID(job string, userId int32) (*livemap.UserMarker, bool)

+ func (s *TestTracker) GetUsersByJob(job string) (*xsync.MapOf[int32, *livemap.UserMarker], bool)

+ func (s *TestTracker) IsUserOnDuty(userId int32) bool

+ func (s *TestTracker) Subscribe() chan *livemap.UsersUpdateEvent

+ func (s *TestTracker) Unsubscribe(c chan *livemap.UsersUpdateEvent)

+ type Tracker struct

+ func (s *Tracker) GetAllActiveUsers() ([]*livemap.UserMarker, error)

+ func (s *Tracker) GetUserById(id int32) (*livemap.UserMarker, bool)

+ func (s *Tracker) GetUsersByJob(job string) (*xsync.MapOf[int32, *livemap.UserMarker], bool)

+ func (s *Tracker) IsUserOnDuty(userId int32) bool

+ func (s *Tracker) Subscribe() chan *livemap.UsersUpdateEvent

+ func (s *Tracker) Unsubscribe(c chan *livemap.UsersUpdateEvent)