mongo

Documentation

Index

• type DataSession
  • func (d *DataSession) ActivateDatasetData(ctx context.Context, dataset *upload.Upload) 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) DeleteOtherDatasetData(ctx context.Context, dataset *upload.Upload) error
  • func (d *DataSession) DestroyDataForUserByID(ctx context.Context, userID string) 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) 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 New(cfg *mongo.Config, lgr log.Logger) (*Store, error)
  • func (s *Store) NewDataSession() storeDEPRECATED.DataSession

Types

type DataSession

type DataSession struct {
	*mongo.Session
}

func (*DataSession) ActivateDatasetData

func (d *DataSession) ActivateDatasetData(ctx context.Context, dataset *upload.Upload) 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) 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) 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) 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 {
	*mongo.Store
}

func New

func New(cfg *mongo.Config, lgr log.Logger) (*Store, error)

func (*Store) NewDataSession

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