state

Documentation

Index

• Variables
• type State
  • func New(cfg *config.Config) *State
  • func (s *State) ClearUnitLock(unitId uint64)
  • func (s *State) DeleteDispatch(job string, id uint64)
  • func (s *State) DeleteUnit(job string, id uint64)
  • func (s *State) FilterDispatches(job string, statuses []dispatch.StatusDispatch, ...) []*dispatch.Dispatch
  • func (s *State) FilterUnits(job string, statuses []dispatch.StatusUnit, notStatuses []dispatch.StatusUnit) []*dispatch.Unit
  • func (s *State) GetDispatch(job string, id uint64) (*dispatch.Dispatch, bool)
  • func (s *State) GetDispatchLocations(job string) *coords.Coords[*dispatch.Dispatch]
  • func (s *State) GetDispatchesJobs() []string
  • func (s *State) GetDispatchesMap(job string) *xsync.MapOf[uint64, *dispatch.Dispatch]
  • func (s *State) GetDisponents(job string) []*users.UserShort
  • func (s *State) GetSettings(job string) *dispatch.Settings
  • func (s *State) GetUnit(job string, id uint64) (*dispatch.Unit, bool)
  • func (s *State) GetUnitIDForUserID(userId int32) (uint64, bool)
  • func (s *State) GetUnitLock(unitId uint64) *sync.Mutex
  • func (s *State) GetUnitsJobs() []string
  • func (s *State) GetUnitsMap(job string) *xsync.MapOf[uint64, *dispatch.Unit]
  • func (s *State) GetUserUnitID(userId int32) (uint64, bool)
  • func (s *State) ListDispatches(job string) []*dispatch.Dispatch
  • func (s *State) ListSettings() []*dispatch.Settings
  • func (s *State) ListUnits(job string) ([]*dispatch.Unit, bool)
  • func (s *State) SetUnitForUser(userId int32, unitId uint64)
  • func (s *State) UnsetUnitIDForUser(userId int32)
  • func (s *State) UpdateDispatch(job string, dispatchId uint64, dsp *dispatch.Dispatch) error
  • func (s *State) UpdateDisponents(job string, disponents []*users.UserShort)
  • func (s *State) UpdateSettings(job string, in *dispatch.Settings) error
  • func (s *State) UpdateUnit(job string, unitId uint64, unit *dispatch.Unit) error

Variables

var StateModule = fx.Module("centrum_state", fx.Provide(
	New,
))

Types

type State

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

func New

func New(cfg *config.Config) *State

func (*State) ClearUnitLock

func (s *State) ClearUnitLock(unitId uint64)

func (*State) DeleteDispatch

func (s *State) DeleteDispatch(job string, id uint64)

func (*State) DeleteUnit

func (s *State) DeleteUnit(job string, id uint64)

func (*State) FilterDispatches

func (s *State) FilterDispatches(job string, statuses []dispatch.StatusDispatch, notStatuses []dispatch.StatusDispatch) []*dispatch.Dispatch

func (*State) FilterUnits

func (s *State) FilterUnits(job string, statuses []dispatch.StatusUnit, notStatuses []dispatch.StatusUnit) []*dispatch.Unit

func (*State) GetDispatch

func (s *State) GetDispatch(job string, id uint64) (*dispatch.Dispatch, bool)

func (*State) GetDispatchLocations

func (s *State) GetDispatchLocations(job string) *coords.Coords[*dispatch.Dispatch]

func (*State) GetDispatchesJobs

func (s *State) GetDispatchesJobs() []string

func (*State) GetDispatchesMap

func (s *State) GetDispatchesMap(job string) *xsync.MapOf[uint64, *dispatch.Dispatch]

func (*State) GetDisponents

func (s *State) GetDisponents(job string) []*users.UserShort

func (*State) GetSettings

func (s *State) GetSettings(job string) *dispatch.Settings

func (*State) GetUnit

func (s *State) GetUnit(job string, id uint64) (*dispatch.Unit, bool)

func (*State) GetUnitIDForUserID

func (s *State) GetUnitIDForUserID(userId int32) (uint64, bool)

func (*State) GetUnitLock

func (s *State) GetUnitLock(unitId uint64) *sync.Mutex

func (*State) GetUnitsJobs

func (s *State) GetUnitsJobs() []string

func (*State) GetUnitsMap

func (s *State) GetUnitsMap(job string) *xsync.MapOf[uint64, *dispatch.Unit]

func (*State) GetUserUnitID

func (s *State) GetUserUnitID(userId int32) (uint64, bool)

func (*State) ListDispatches

func (s *State) ListDispatches(job string) []*dispatch.Dispatch

func (*State) ListSettings

func (s *State) ListSettings() []*dispatch.Settings

func (*State) ListUnits

func (s *State) ListUnits(job string) ([]*dispatch.Unit, bool)

func (*State) SetUnitForUser

func (s *State) SetUnitForUser(userId int32, unitId uint64)

func (*State) UnsetUnitIDForUser

func (s *State) UnsetUnitIDForUser(userId int32)

func (*State) UpdateDispatch

func (s *State) UpdateDispatch(job string, dispatchId uint64, dsp *dispatch.Dispatch) error

func (*State) UpdateDisponents

func (s *State) UpdateDisponents(job string, disponents []*users.UserShort)

func (*State) UpdateSettings

func (s *State) UpdateSettings(job string, in *dispatch.Settings) error

func (*State) UpdateUnit

func (s *State) UpdateUnit(job string, unitId uint64, unit *dispatch.Unit) error