manager

Documentation

Index

• Constants
• Variables
• type Manager
  • func New(p Params) *Manager
  • func (s *Manager) AddDispatchStatus(ctx context.Context, tx qrm.DB, status *dispatch.DispatchStatus) error
  • func (s *Manager) CheckIfBotNeeded(job string) bool
  • func (s *Manager) CheckIfUserIsDisponent(job string, userId int32) bool
  • func (s *Manager) CheckIfUserIsPartOfDispatch(userInfo *userinfo.UserInfo, dsp *dispatch.Dispatch, disponentOkay bool) bool
  • func (s *Manager) CheckIfUserPartOfUnit(job string, userId int32, unit *dispatch.Unit, disponentOkay bool) bool
  • func (s *Manager) CreateDispatch(ctx context.Context, d *dispatch.Dispatch) (*dispatch.Dispatch, error)
  • func (s *Manager) DeleteDispatch(ctx context.Context, job string, id uint64) error
  • func (s *Manager) DispatchAssignmentExpirationTime() time.Time
  • func (s *Manager) DisponentSignOn(ctx context.Context, job string, userId int32, signon bool) error
  • func (s *Manager) GetUnitStatusFromDB(ctx context.Context, job string, id uint64) (*dispatch.UnitStatus, error)
  • func (s *Manager) LoadDispatchAssignments(ctx context.Context, job string, dispatchId uint64) ([]*dispatch.DispatchAssignment, error)
  • func (s *Manager) LoadDispatches(ctx context.Context, id uint64) error
  • func (s *Manager) LoadDisponents(ctx context.Context, job string) error
  • func (s *Manager) LoadSettings(ctx context.Context, job string) error
  • func (s *Manager) LoadUnitIDForUserID(ctx context.Context, userId int32) (uint64, error)
  • func (s *Manager) LoadUnits(ctx context.Context, id uint64) error
  • func (s *Manager) ResolveUserById(ctx context.Context, u int32) (*users.User, error)
  • func (s *Manager) UpdateDispatch(ctx context.Context, userInfo *userinfo.UserInfo, dsp *dispatch.Dispatch) error
  • func (s *Manager) UpdateDispatchAssignments(ctx context.Context, job string, userId *int32, dsp *dispatch.Dispatch, ...) error
  • func (s *Manager) UpdateDispatchStatus(ctx context.Context, job string, dsp *dispatch.Dispatch, ...) error
  • func (s *Manager) UpdateUnitAssignments(ctx context.Context, userInfo *userinfo.UserInfo, unit *dispatch.Unit, ...) error
  • func (s *Manager) UpdateUnitStatus(ctx context.Context, job string, unit *dispatch.Unit, in *dispatch.UnitStatus) error
• type Params

Constants

const DispatchExpirationTime = 31 * time.Second

const (
	MaxCancelledDispatchesPerRun = 3
)

Variables

var Module = fx.Module("centrum_manager", fx.Provide(
	New,
))

Types

type Manager

type Manager struct {
	*state.State
	// contains filtered or unexported fields
}

func New

func New(p Params) *Manager

func (*Manager) AddDispatchStatus

func (s *Manager) AddDispatchStatus(ctx context.Context, tx qrm.DB, status *dispatch.DispatchStatus) error

func (*Manager) CheckIfBotNeeded

func (s *Manager) CheckIfBotNeeded(job string) bool

func (*Manager) CheckIfUserIsDisponent

func (s *Manager) CheckIfUserIsDisponent(job string, userId int32) bool

func (*Manager) CheckIfUserIsPartOfDispatch

func (s *Manager) CheckIfUserIsPartOfDispatch(userInfo *userinfo.UserInfo, dsp *dispatch.Dispatch, disponentOkay bool) bool

func (*Manager) CheckIfUserPartOfUnit

func (s *Manager) CheckIfUserPartOfUnit(job string, userId int32, unit *dispatch.Unit, disponentOkay bool) bool

func (*Manager) CreateDispatch

func (s *Manager) CreateDispatch(ctx context.Context, d *dispatch.Dispatch) (*dispatch.Dispatch, error)

func (*Manager) DeleteDispatch

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

func (*Manager) DispatchAssignmentExpirationTime

func (s *Manager) DispatchAssignmentExpirationTime() time.Time

func (*Manager) DisponentSignOn

func (s *Manager) DisponentSignOn(ctx context.Context, job string, userId int32, signon bool) error

func (*Manager) GetUnitStatusFromDB

func (s *Manager) GetUnitStatusFromDB(ctx context.Context, job string, id uint64) (*dispatch.UnitStatus, error)

func (*Manager) LoadDispatchAssignments

func (s *Manager) LoadDispatchAssignments(ctx context.Context, job string, dispatchId uint64) ([]*dispatch.DispatchAssignment, error)

func (*Manager) LoadDispatches

func (s *Manager) LoadDispatches(ctx context.Context, id uint64) error

func (*Manager) LoadDisponents

func (s *Manager) LoadDisponents(ctx context.Context, job string) error

func (*Manager) LoadSettings

func (s *Manager) LoadSettings(ctx context.Context, job string) error

func (*Manager) LoadUnitIDForUserID

func (s *Manager) LoadUnitIDForUserID(ctx context.Context, userId int32) (uint64, error)

func (*Manager) LoadUnits

func (s *Manager) LoadUnits(ctx context.Context, id uint64) error

func (*Manager) ResolveUserById

func (s *Manager) ResolveUserById(ctx context.Context, u int32) (*users.User, error)

func (*Manager) UpdateDispatch

func (s *Manager) UpdateDispatch(ctx context.Context, userInfo *userinfo.UserInfo, dsp *dispatch.Dispatch) error

func (*Manager) UpdateDispatchAssignments

func (s *Manager) UpdateDispatchAssignments(ctx context.Context, job string, userId *int32, dsp *dispatch.Dispatch, toAdd []uint64, toRemove []uint64, expiresAt time.Time) error

func (*Manager) UpdateDispatchStatus

func (s *Manager) UpdateDispatchStatus(ctx context.Context, job string, dsp *dispatch.Dispatch, in *dispatch.DispatchStatus) error

func (*Manager) UpdateUnitAssignments

func (s *Manager) UpdateUnitAssignments(ctx context.Context, userInfo *userinfo.UserInfo, unit *dispatch.Unit, toAdd []int32, toRemove []int32) error

func (*Manager) UpdateUnitStatus

func (s *Manager) UpdateUnitStatus(ctx context.Context, job string, unit *dispatch.Unit, in *dispatch.UnitStatus) error

type Params

type Params struct {
	fx.In

	LC fx.Lifecycle

	Logger   *zap.Logger
	TP       *tracesdk.TracerProvider
	DB       *sql.DB
	Events   *events.Eventus
	Enricher *mstlystcdata.Enricher
	Postals  *postals.Postals
	Tracker  *tracker.Tracker
	Config   *config.Config

	State *state.State
}