tracker

type ITracker interface {
	GetUsersByJob(job string) (*xsync.MapOf[int32, *livemap.UserMarker], bool)
	GetUserById(id int32) (*livemap.UserMarker, bool)
	GetAllActiveUsers() ([]*livemap.UserMarker, error)
	IsUserOnDuty(userId int32) bool

	Subscribe() chan *livemap.UsersUpdateEvent
	Unsubscribe(c chan *livemap.UsersUpdateEvent)
}

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

type ManagerParams struct {
	fx.In

	LC fx.Lifecycle

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

type Params struct {
	fx.In

	LC fx.Lifecycle

	Logger *zap.Logger
	JS     nats.JetStreamContext
}

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

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