activities

Documentation

Index

• type DB
  • func NewDB(conn *pgxpool.Pool, commonDB database.CommonDB) *DB
  • func (db *DB) DeleteObjectActivity(ctx context.Context, activityID umid.UMID) error
  • func (db *DB) GetObjectIDsByActivityID(ctx context.Context, activityID umid.UMID) ([]umid.UMID, error)
  • func (db *DB) UpsertObjectActivities(ctx context.Context, objectActivities []*entry.ObjectActivity) error
  • func (db *DB) UpsertObjectActivity(ctx context.Context, objectActivity *entry.ObjectActivity) 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) DeleteObjectActivity

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

func (*DB) GetObjectIDsByActivityID

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

func (*DB) UpsertObjectActivities

func (db *DB) UpsertObjectActivities(ctx context.Context, objectActivities []*entry.ObjectActivity) error

func (*DB) UpsertObjectActivity

func (db *DB) UpsertObjectActivity(ctx context.Context, objectActivity *entry.ObjectActivity) error