activities

Documentation

Index

• type DB
  • func NewDB(conn *pgxpool.Pool, commonDB database.CommonDB) *DB
  • func (db *DB) GetActivities(ctx context.Context) ([]*entry.Activity, error)
  • func (db *DB) GetActivitiesByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.Activity, error)
  • func (db *DB) GetActivitiesByUserID(ctx context.Context, userID umid.UMID) ([]*entry.Activity, error)
  • func (db *DB) GetActivityByID(ctx context.Context, activityID umid.UMID) (*entry.Activity, error)
  • func (db *DB) GetActivityIDsByParentID(ctx context.Context, parentID umid.UMID) ([]umid.UMID, error)
  • func (db *DB) RemoveActivitiesByIDs(ctx context.Context, activityIDs []umid.UMID) error
  • func (db *DB) RemoveActivityByID(ctx context.Context, activityID umid.UMID) error
  • func (db *DB) UpdateActivityCreatedAt(ctx context.Context, activityID umid.UMID, createdAt time.Time) error
  • func (db *DB) UpdateActivityData(ctx context.Context, activityID umid.UMID, options *entry.ActivityData) error
  • func (db *DB) UpdateActivityObjectID(ctx context.Context, activityID umid.UMID, objectID *umid.UMID) error
  • func (db *DB) UpdateActivityType(ctx context.Context, activityID umid.UMID, activityType *entry.ActivityType) error
  • func (db *DB) UpdateActivityUserID(ctx context.Context, activityID umid.UMID, userID *umid.UMID) error
  • func (db *DB) UpsertActivities(ctx context.Context, activities []*entry.Activity) error
  • func (db *DB) UpsertActivity(ctx context.Context, activity *entry.Activity) error

Types

type DB

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

func NewDB

func NewDB(conn *pgxpool.Pool, commonDB database.CommonDB) *DB

func (*DB) GetActivities

func (db *DB) GetActivities(ctx context.Context) ([]*entry.Activity, error)

func (*DB) GetActivitiesByObjectID

func (db *DB) GetActivitiesByObjectID(ctx context.Context, objectID umid.UMID) ([]*entry.Activity, error)

func (*DB) GetActivitiesByUserID

func (db *DB) GetActivitiesByUserID(ctx context.Context, userID umid.UMID) ([]*entry.Activity, error)

func (*DB) GetActivityByID

func (db *DB) GetActivityByID(ctx context.Context, activityID umid.UMID) (*entry.Activity, error)

func (*DB) GetActivityIDsByParentID

func (db *DB) GetActivityIDsByParentID(ctx context.Context, parentID umid.UMID) ([]umid.UMID, error)

func (*DB) RemoveActivitiesByIDs

func (db *DB) RemoveActivitiesByIDs(ctx context.Context, activityIDs []umid.UMID) error

func (*DB) RemoveActivityByID

func (db *DB) RemoveActivityByID(ctx context.Context, activityID umid.UMID) error

func (*DB) UpdateActivityCreatedAt

func (db *DB) UpdateActivityCreatedAt(ctx context.Context, activityID umid.UMID, createdAt time.Time) error

func (*DB) UpdateActivityData

func (db *DB) UpdateActivityData(ctx context.Context, activityID umid.UMID, options *entry.ActivityData) error

func (*DB) UpdateActivityObjectID

func (db *DB) UpdateActivityObjectID(ctx context.Context, activityID umid.UMID, objectID *umid.UMID) error

func (*DB) UpdateActivityType

func (db *DB) UpdateActivityType(ctx context.Context, activityID umid.UMID, activityType *entry.ActivityType) error

func (*DB) UpdateActivityUserID

func (db *DB) UpdateActivityUserID(ctx context.Context, activityID umid.UMID, userID *umid.UMID) error

func (*DB) UpsertActivities

func (db *DB) UpsertActivities(ctx context.Context, activities []*entry.Activity) error

func (*DB) UpsertActivity

func (db *DB) UpsertActivity(ctx context.Context, activity *entry.Activity) error