activities

Documentation

Index

• type Activities
  • func NewActivities(db database.DB) *Activities
  • func (a *Activities) AddActivities(activities []universe.Activity, updateDB bool) error
  • func (a *Activities) AddActivity(activity universe.Activity, updateDB bool) error
  • func (a *Activities) CreateActivity(activityID umid.UMID) (universe.Activity, error)
  • func (a *Activities) GetActivities() map[umid.UMID]universe.Activity
  • func (a *Activities) GetActivitiesByUserID(userID umid.UMID) map[umid.UMID]universe.Activity
  • func (a *Activities) GetActivity(activityID umid.UMID) (universe.Activity, bool)
  • func (a *Activities) GetPaginatedActivities(startIndex int, pageSize int) ([]universe.Activity, int)
  • func (a *Activities) GetPaginatedActivitiesByObjectID(objectID *umid.UMID, startIndex int, pageSize int) ([]universe.Activity, int)
  • func (a *Activities) Initialize(ctx types.NodeContext) error
  • func (a *Activities) Inject(activity universe.Activity) error
  • func (a *Activities) Load() error
  • func (a *Activities) Modify(activity universe.Activity, modifyFn modify.Fn[entry.ActivityData]) error
  • func (a *Activities) NotifyProcessor(activity universe.Activity, updateType posbus.ActivityUpdateType, ...) error
  • func (a *Activities) Remove(activity universe.Activity) error
  • func (a *Activities) RemoveActivities(activities2d []universe.Activity, updateDB bool) (bool, error)
  • func (a *Activities) RemoveActivity(activity universe.Activity, updateDB bool) (bool, error)
  • func (a *Activities) Save() error

Types

type Activities

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

func NewActivities

func NewActivities(db database.DB) *Activities

func (*Activities) AddActivities

func (a *Activities) AddActivities(activities []universe.Activity, updateDB bool) error

func (*Activities) AddActivity

func (a *Activities) AddActivity(activity universe.Activity, updateDB bool) error

func (*Activities) CreateActivity

func (a *Activities) CreateActivity(activityID umid.UMID) (universe.Activity, error)

func (*Activities) GetActivities

func (a *Activities) GetActivities() map[umid.UMID]universe.Activity

func (*Activities) GetActivitiesByUserID

func (a *Activities) GetActivitiesByUserID(userID umid.UMID) map[umid.UMID]universe.Activity

func (*Activities) GetActivity

func (a *Activities) GetActivity(activityID umid.UMID) (universe.Activity, bool)

func (*Activities) GetPaginatedActivities

func (a *Activities) GetPaginatedActivities(startIndex int, pageSize int) ([]universe.Activity, int)

func (*Activities) GetPaginatedActivitiesByObjectID

func (a *Activities) GetPaginatedActivitiesByObjectID(objectID *umid.UMID, startIndex int, pageSize int) ([]universe.Activity, int)

func (*Activities) Initialize

func (a *Activities) Initialize(ctx types.NodeContext) error

func (*Activities) Inject

func (a *Activities) Inject(activity universe.Activity) error

func (*Activities) Load

func (a *Activities) Load() error

func (*Activities) Modify

func (a *Activities) Modify(activity universe.Activity, modifyFn modify.Fn[entry.ActivityData]) error

func (*Activities) NotifyProcessor

func (a *Activities) NotifyProcessor(activity universe.Activity, updateType posbus.ActivityUpdateType, objectIDs []umid.UMID) error

func (*Activities) Remove

func (a *Activities) Remove(activity universe.Activity) error

func (*Activities) RemoveActivities

func (a *Activities) RemoveActivities(activities2d []universe.Activity, updateDB bool) (bool, error)

func (*Activities) RemoveActivity

func (a *Activities) RemoveActivity(activity universe.Activity, updateDB bool) (bool, error)

func (*Activities) Save

func (a *Activities) Save() error