mongo

Documentation

Index

• type DataSession
  • func (d *DataSession) ActivateDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error
  • func (d *DataSession) ArchiveDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error
  • func (d *DataSession) ArchiveDeviceDataUsingHashesFromDataSet(ctx context.Context, dataSet *upload.Upload) error
  • func (d *DataSession) CreateDataSet(ctx context.Context, dataSet *upload.Upload) error
  • func (d *DataSession) CreateDataSetData(ctx context.Context, dataSet *upload.Upload, dataSetData []data.Datum) error
  • func (d *DataSession) DeleteDataSet(ctx context.Context, dataSet *upload.Upload) error
  • func (d *DataSession) DeleteDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error
  • func (d *DataSession) DeleteOtherDataSetData(ctx context.Context, dataSet *upload.Upload) error
  • func (d *DataSession) DestroyDataForUserByID(ctx context.Context, userID string) error
  • func (d *DataSession) DestroyDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error
  • func (d *DataSession) DestroyDeletedDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error
  • func (d *DataSession) GetDataSet(ctx context.Context, id string) (*data.DataSet, error)
  • func (d *DataSession) GetDataSetByID(ctx context.Context, dataSetID string) (*upload.Upload, error)
  • func (d *DataSession) GetDataSetsForUserByID(ctx context.Context, userID string, filter *storeDEPRECATED.Filter, ...) ([]*upload.Upload, error)
  • func (d *DataSession) ListUserDataSets(ctx context.Context, userID string, filter *data.DataSetFilter, ...) (data.DataSets, error)
  • func (d *DataSession) UnarchiveDeviceDataUsingHashesFromDataSet(ctx context.Context, dataSet *upload.Upload) error
  • func (d *DataSession) UpdateDataSet(ctx context.Context, id string, update *data.DataSetUpdate) (*upload.Upload, error)
• type Store
  • func NewStore(cfg *storeStructuredMongo.Config, lgr log.Logger) (*Store, error)
  • func (s *Store) NewDataSession() storeDEPRECATED.DataSession

Types

type DataSession

type DataSession struct {
	*storeStructuredMongo.Session
}

func (*DataSession) ActivateDataSetData

func (d *DataSession) ActivateDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error

func (*DataSession) ArchiveDataSetData

func (d *DataSession) ArchiveDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error

func (*DataSession) ArchiveDeviceDataUsingHashesFromDataSet

func (d *DataSession) ArchiveDeviceDataUsingHashesFromDataSet(ctx context.Context, dataSet *upload.Upload) error

func (*DataSession) CreateDataSet

func (d *DataSession) CreateDataSet(ctx context.Context, dataSet *upload.Upload) error

func (*DataSession) CreateDataSetData

func (d *DataSession) CreateDataSetData(ctx context.Context, dataSet *upload.Upload, dataSetData []data.Datum) error

func (*DataSession) DeleteDataSet

func (d *DataSession) DeleteDataSet(ctx context.Context, dataSet *upload.Upload) error

func (*DataSession) DeleteDataSetData

func (d *DataSession) DeleteDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error

func (*DataSession) DeleteOtherDataSetData

func (d *DataSession) DeleteOtherDataSetData(ctx context.Context, dataSet *upload.Upload) error

func (*DataSession) DestroyDataForUserByID

func (d *DataSession) DestroyDataForUserByID(ctx context.Context, userID string) error

func (*DataSession) DestroyDataSetData

func (d *DataSession) DestroyDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error

func (*DataSession) DestroyDeletedDataSetData

func (d *DataSession) DestroyDeletedDataSetData(ctx context.Context, dataSet *upload.Upload, selectors *data.Selectors) error

func (*DataSession) GetDataSet

func (d *DataSession) GetDataSet(ctx context.Context, id string) (*data.DataSet, error)

func (*DataSession) GetDataSetByID

func (d *DataSession) GetDataSetByID(ctx context.Context, dataSetID string) (*upload.Upload, error)

func (*DataSession) GetDataSetsForUserByID

func (d *DataSession) GetDataSetsForUserByID(ctx context.Context, userID string, filter *storeDEPRECATED.Filter, pagination *page.Pagination) ([]*upload.Upload, error)

func (*DataSession) ListUserDataSets

func (d *DataSession) ListUserDataSets(ctx context.Context, userID string, filter *data.DataSetFilter, pagination *page.Pagination) (data.DataSets, error)

func (*DataSession) UnarchiveDeviceDataUsingHashesFromDataSet

func (d *DataSession) UnarchiveDeviceDataUsingHashesFromDataSet(ctx context.Context, dataSet *upload.Upload) error

func (*DataSession) UpdateDataSet

func (d *DataSession) UpdateDataSet(ctx context.Context, id string, update *data.DataSetUpdate) (*upload.Upload, error)

type Store

type Store struct {
	*storeStructuredMongo.Store
}

func NewStore

func NewStore(cfg *storeStructuredMongo.Config, lgr log.Logger) (*Store, error)

func (*Store) NewDataSession

func (s *Store) NewDataSession() storeDEPRECATED.DataSession