tracker

Documentation

Index

• Constants
• type Event
• type Params
• type Tracker
  • func New(p Params) *Tracker
  • func (s *Tracker) GenerateRandomDispatchMarker()
  • func (s *Tracker) GenerateRandomUserMarker()
  • func (s *Tracker) GetUserById(id int32) (*livemap.UserMarker, bool)
  • func (s *Tracker) GetUserByJobAndID(job string, userId int32) (*livemap.UserMarker, bool)
  • func (s *Tracker) GetUsers(job string) (*xsync.MapOf[int32, *livemap.UserMarker], bool)
  • func (s *Tracker) IsUserOnDuty(job string, userId int32) bool
  • func (s *Tracker) Subscribe() chan *Event
  • func (s *Tracker) Unsubscribe(c chan *Event)
• type UserInfo

Constants

const (
	MaxDispatchMarkerLimit = 120
)

Types

type Event

type Event struct {
	Added   []*UserInfo
	Removed []*UserInfo
	Current []*UserInfo
}

type Params

type Params struct {
	fx.In

	LC fx.Lifecycle

	Logger   *zap.Logger
	TP       *tracesdk.TracerProvider
	DB       *sql.DB
	Enricher *mstlystcdata.Enricher
	Postals  *postals.Postals
	Config   *config.Config
	State    *state.State
}

type Tracker

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

func New

func New(p Params) *Tracker

func (*Tracker) GenerateRandomDispatchMarker

func (s *Tracker) GenerateRandomDispatchMarker()

func (*Tracker) GenerateRandomUserMarker

func (s *Tracker) GenerateRandomUserMarker()

func (*Tracker) GetUserById

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

func (*Tracker) GetUserByJobAndID

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

func (*Tracker) GetUsers

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

func (*Tracker) IsUserOnDuty

func (s *Tracker) IsUserOnDuty(job string, userId int32) bool

func (*Tracker) Subscribe

func (s *Tracker) Subscribe() chan *Event

func (*Tracker) Unsubscribe

func (s *Tracker) Unsubscribe(c chan *Event)

type UserInfo

type UserInfo struct {
	Job    string
	UserID int32
	Time   time.Time
}