state

Documentation

Index

• Variables
• func JobIdKey(job string, id uint64) string
• type Params
• type State
  • func New(p Params) (*State, error)
  • func (s *State) CreateDispatch(ctx context.Context, job string, id uint64, dsp *centrum.Dispatch) error
  • func (s *State) DeleteDispatch(ctx context.Context, job string, id uint64) error
  • func (s *State) DeleteUnit(ctx context.Context, job string, id uint64) error
  • func (s *State) DispatchesStore() *store.Store[centrum.Dispatch, *centrum.Dispatch]
  • func (s *State) FilterDispatches(ctx context.Context, job string, statuses []centrum.StatusDispatch, ...) []*centrum.Dispatch
  • func (s *State) FilterUnits(ctx context.Context, job string, statuses []centrum.StatusUnit, ...) []*centrum.Unit
  • func (s *State) GetDispatch(ctx context.Context, job string, id uint64) (*centrum.Dispatch, error)
  • func (s *State) GetDispatchLocations(job string) *coords.Coords[*centrum.Dispatch]
  • func (s *State) GetDisponents(ctx context.Context, job string) ([]*users.UserShort, error)
  • func (s *State) GetSettings(ctx context.Context, job string) *centrum.Settings
  • func (s *State) GetUnit(ctx context.Context, job string, id uint64) (*centrum.Unit, error)
  • func (s *State) GetUserUnitID(ctx context.Context, userId int32) (uint64, bool)
  • func (s *State) ListDispatches(ctx context.Context, job string) ([]*centrum.Dispatch, bool)
  • func (s *State) ListSettings(ctx context.Context) []*centrum.Settings
  • func (s *State) ListUnits(ctx context.Context, job string) ([]*centrum.Unit, bool)
  • func (s *State) SetUnitForUser(ctx context.Context, job string, userId int32, unitId uint64) error
  • func (s *State) UnitsStore() *store.Store[centrum.Unit, *centrum.Unit]
  • func (s *State) UnsetUnitIDForUser(ctx context.Context, userId int32) error
  • func (s *State) UpdateDispatch(ctx context.Context, job string, id uint64, dsp *centrum.Dispatch) error
  • func (s *State) UpdateDispatchStatus(ctx context.Context, job string, id uint64, status *centrum.DispatchStatus) error
  • func (s *State) UpdateDispatchUnits(ctx context.Context, job string, id uint64, ...) error
  • func (s *State) UpdateDisponents(ctx context.Context, job string, disponents []*users.UserShort) error
  • func (s *State) UpdateSettings(ctx context.Context, job string, in *centrum.Settings) error
  • func (s *State) UpdateUnit(ctx context.Context, job string, id uint64, unit *centrum.Unit) error
  • func (s *State) UpdateUnitStatus(ctx context.Context, job string, id uint64, status *centrum.UnitStatus) error
  • func (s *State) UpdateUnitUsers(ctx context.Context, job string, id uint64, users []*centrum.UnitAssignment) error

Variables

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

Functions

func JobIdKey

func JobIdKey(job string, id uint64) string

Types

type Params

type Params struct {
	fx.In

	LC fx.Lifecycle

	Logger    *zap.Logger
	JS        *events.JSWrapper
	AppConfig appconfig.IConfig
}

type State

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

func New

func New(p Params) (*State, error)

func (*State) CreateDispatch

func (s *State) CreateDispatch(ctx context.Context, job string, id uint64, dsp *centrum.Dispatch) error

func (*State) DeleteDispatch

func (s *State) DeleteDispatch(ctx context.Context, job string, id uint64) error

func (*State) DeleteUnit

func (s *State) DeleteUnit(ctx context.Context, job string, id uint64) error

func (*State) DispatchesStore

func (s *State) DispatchesStore() *store.Store[centrum.Dispatch, *centrum.Dispatch]

func (*State) FilterDispatches

func (s *State) FilterDispatches(ctx context.Context, job string, statuses []centrum.StatusDispatch, notStatuses []centrum.StatusDispatch) []*centrum.Dispatch

func (*State) FilterUnits

func (s *State) FilterUnits(ctx context.Context, job string, statuses []centrum.StatusUnit, notStatuses []centrum.StatusUnit, filterFn func(unit *centrum.Unit) bool) []*centrum.Unit

func (*State) GetDispatch

func (s *State) GetDispatch(ctx context.Context, job string, id uint64) (*centrum.Dispatch, error)

func (*State) GetDispatchLocations

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

func (*State) GetDisponents

func (s *State) GetDisponents(ctx context.Context, job string) ([]*users.UserShort, error)

func (*State) GetSettings

func (s *State) GetSettings(ctx context.Context, job string) *centrum.Settings

func (*State) GetUnit

func (s *State) GetUnit(ctx context.Context, job string, id uint64) (*centrum.Unit, error)

func (*State) GetUserUnitID

func (s *State) GetUserUnitID(ctx context.Context, userId int32) (uint64, bool)

func (*State) ListDispatches

func (s *State) ListDispatches(ctx context.Context, job string) ([]*centrum.Dispatch, bool)

func (*State) ListSettings

func (s *State) ListSettings(ctx context.Context) []*centrum.Settings

func (*State) ListUnits

func (s *State) ListUnits(ctx context.Context, job string) ([]*centrum.Unit, bool)

func (*State) SetUnitForUser

func (s *State) SetUnitForUser(ctx context.Context, job string, userId int32, unitId uint64) error

func (*State) UnitsStore

func (s *State) UnitsStore() *store.Store[centrum.Unit, *centrum.Unit]

func (*State) UnsetUnitIDForUser

func (s *State) UnsetUnitIDForUser(ctx context.Context, userId int32) error

func (*State) UpdateDispatch

func (s *State) UpdateDispatch(ctx context.Context, job string, id uint64, dsp *centrum.Dispatch) error

func (*State) UpdateDispatchStatus

func (s *State) UpdateDispatchStatus(ctx context.Context, job string, id uint64, status *centrum.DispatchStatus) error

func (*State) UpdateDispatchUnits

func (s *State) UpdateDispatchUnits(ctx context.Context, job string, id uint64, units []*centrum.DispatchAssignment) error

func (*State) UpdateDisponents

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

func (*State) UpdateSettings

func (s *State) UpdateSettings(ctx context.Context, job string, in *centrum.Settings) error

func (*State) UpdateUnit

func (s *State) UpdateUnit(ctx context.Context, job string, id uint64, unit *centrum.Unit) error

func (*State) UpdateUnitStatus

func (s *State) UpdateUnitStatus(ctx context.Context, job string, id uint64, status *centrum.UnitStatus) error

func (*State) UpdateUnitUsers

func (s *State) UpdateUnitUsers(ctx context.Context, job string, id uint64, users []*centrum.UnitAssignment) error