storengine

package
v0.0.0-...-9fc6fd2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 17, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddDatadir 

func AddDatadir(dir model.DatadirSchema, session *r.Session) (model.DatadirSchema, error)

func AddDefaultUsersToStoreEngine 

func AddDefaultUsersToStoreEngine(t *testing.T, e UsersStoreEngine)

func CleanupUsersStoreEngine 

func CleanupUsersStoreEngine(e UsersStoreEngine)

func ToDatadirSchema 

func ToDatadirSchema(ddModel model.AddDatadirModel) model.DatadirSchema

Types

type AccessStoreEngine 

type AccessStoreEngine interface {
	AddAccessEntry(entry model.ProjectAccessSchema) (model.ProjectAccessSchema, error)
	DeleteAccess(projectID, userID string) error
	DeleteAllAccessForProject(projectID string) error
	GetProjectAccessEntries(projectID string) ([]model.ProjectAccessSchema, error)
	GetUserAccessEntries(userID string) ([]model.ProjectAccessSchema, error)
}

type AssociationsRethinkdb 

type AssociationsRethinkdb struct {
	Session *r.Session
}

func NewAssociationsRethinkdb 

func NewAssociationsRethinkdb(session *r.Session) *AssociationsRethinkdb

func (*AssociationsRethinkdb) AssociateSampleWithExperiment 

func (e *AssociationsRethinkdb) AssociateSampleWithExperiment(sampleID, experimentID string) error

func (*AssociationsRethinkdb) AssociateSampleWithFile 

func (e *AssociationsRethinkdb) AssociateSampleWithFile(sampleID, fileID string) error

func (*AssociationsRethinkdb) AssociateSampleWithProject 

func (e *AssociationsRethinkdb) AssociateSampleWithProject(sampleID, projectID string) error

type AssociationsStoreEngine 

type AssociationsStoreEngine interface {
	AssociateSampleWithProject(sampleID, projectID string) error
	AssociateSampleWithExperiment(sampleID, experimentID string) error
	AssociateSampleWithFile(sampleID, fileID string) error
}

type BackgroundProcessMemory 

type BackgroundProcessMemory struct {
	DB map[string]model.BackgroundProcessSchema
}

func NewBackgroundProcessMemory 

func NewBackgroundProcessMemory() *BackgroundProcessMemory

func NewBackgroundProcessMemoryWithDB 

func NewBackgroundProcessMemoryWithDB(db map[string]model.BackgroundProcessSchema) *BackgroundProcessMemory

func (*BackgroundProcessMemory) AddBackgroundProcess 

func (e *BackgroundProcessMemory) AddBackgroundProcess(bgp model.BackgroundProcessSchema) (model.BackgroundProcessSchema, error)

func (*BackgroundProcessMemory) DeleteBackgroundProcess 

func (e *BackgroundProcessMemory) DeleteBackgroundProcess(id string) error

func (*BackgroundProcessMemory) GetBackgroundProcess 

func (e *BackgroundProcessMemory) GetBackgroundProcess(id string) (model.BackgroundProcessSchema, error)

func (*BackgroundProcessMemory) GetListBackgroundProcess 

func (e *BackgroundProcessMemory) GetListBackgroundProcess(glbpg model.GetListBackgroundProcessModel) ([]model.BackgroundProcessSchema, error)

func (*BackgroundProcessMemory) SetFinishedBackgroundProcess 

func (e *BackgroundProcessMemory) SetFinishedBackgroundProcess(id string, done bool) error

func (*BackgroundProcessMemory) SetOkBackgroundProcess 

func (e *BackgroundProcessMemory) SetOkBackgroundProcess(id string, success bool) error

func (*BackgroundProcessMemory) UpdateStatusBackgroundProcess 

func (e *BackgroundProcessMemory) UpdateStatusBackgroundProcess(id string, status string, message string) error

type BackgroundProcessRethinkdb 

type BackgroundProcessRethinkdb struct {
	Session *r.Session
}

func NewBackgroundProcessRethinkdb 

func NewBackgroundProcessRethinkdb(session *r.Session) *BackgroundProcessRethinkdb

func (*BackgroundProcessRethinkdb) AddBackgroundProcess 

func (e *BackgroundProcessRethinkdb) AddBackgroundProcess(bgp model.BackgroundProcessSchema) (model.BackgroundProcessSchema, error)

func (*BackgroundProcessRethinkdb) DeleteBackgroundProcess 

func (e *BackgroundProcessRethinkdb) DeleteBackgroundProcess(id string) error

func (*BackgroundProcessRethinkdb) GetBackgroundProcess 

func (e *BackgroundProcessRethinkdb) GetBackgroundProcess(id string) (model.BackgroundProcessSchema, error)

func (*BackgroundProcessRethinkdb) GetListBackgroundProcess 

func (e *BackgroundProcessRethinkdb) GetListBackgroundProcess(glbgp model.GetListBackgroundProcessModel) ([]model.BackgroundProcessSchema, error)

func (*BackgroundProcessRethinkdb) SetFinishedBackgroundProcess 

func (e *BackgroundProcessRethinkdb) SetFinishedBackgroundProcess(id string, done bool) error

func (*BackgroundProcessRethinkdb) SetOkBackgroundProcess 

func (e *BackgroundProcessRethinkdb) SetOkBackgroundProcess(id string, success bool) error

func (*BackgroundProcessRethinkdb) UpdateStatusBackgroundProcess 

func (e *BackgroundProcessRethinkdb) UpdateStatusBackgroundProcess(id string, status string, message string) error

type BackgroundProcessStoreEngine 

type BackgroundProcessStoreEngine interface {
	AddBackgroundProcess(bgp model.BackgroundProcessSchema) (model.BackgroundProcessSchema, error)
	GetListBackgroundProcess(glbpg model.GetListBackgroundProcessModel) ([]model.BackgroundProcessSchema, error)
	DeleteBackgroundProcess(id string) error
	GetBackgroundProcess(id string) (model.BackgroundProcessSchema, error)
	UpdateStatusBackgroundProcess(id string, status string, message string) error
	SetFinishedBackgroundProcess(id string, done bool) error
	SetOkBackgroundProcess(id string, success bool) error
}

type DatadirsMemory 

type DatadirsMemory struct {
	DB map[string]model.DatadirSchema
}

func NewDatadirsMemory 

func NewDatadirsMemory() *DatadirsMemory

func NewDatadirsMemoryWithDB 

func NewDatadirsMemoryWithDB(db map[string]model.DatadirSchema) *DatadirsMemory

func (*DatadirsMemory) AddDir 

func (e *DatadirsMemory) AddDir(dir model.DatadirSchema) (model.DatadirSchema, error)

func (*DatadirsMemory) GetDatadir 

func (e *DatadirsMemory) GetDatadir(id string) (model.DatadirSchema, error)

func (*DatadirsMemory) GetDatadirByPathInProject 

func (e *DatadirsMemory) GetDatadirByPathInProject(path, projectID string) (model.DatadirSchema, error)

func (*DatadirsMemory) GetDatadirForProject 

func (e *DatadirsMemory) GetDatadirForProject(projectID, userID, dirID string) (model.DatadirEntryModel, error)

func (*DatadirsMemory) GetDatadirsForProject 

func (e *DatadirsMemory) GetDatadirsForProject(projectID, userID string) ([]model.DatadirEntryModel, error)

func (*DatadirsMemory) GetFilesForDatadir 

func (e *DatadirsMemory) GetFilesForDatadir(projectID, userID, dirID string) ([]model.DatafileSimpleModel, error)

type DatadirsRethinkdb 

type DatadirsRethinkdb struct {
	Session *r.Session
}

func NewDatadirsRethinkdb 

func NewDatadirsRethinkdb(session *r.Session) *DatadirsRethinkdb

func (*DatadirsRethinkdb) AddDir 

func (e *DatadirsRethinkdb) AddDir(dir model.DatadirSchema) (model.DatadirSchema, error)

func (*DatadirsRethinkdb) GetDatadir 

func (e *DatadirsRethinkdb) GetDatadir(id string) (model.DatadirSchema, error)

func (*DatadirsRethinkdb) GetDatadirByPathInProject 

func (e *DatadirsRethinkdb) GetDatadirByPathInProject(path, projectID string) (model.DatadirSchema, error)

func (*DatadirsRethinkdb) GetDatadirForProject 

func (e *DatadirsRethinkdb) GetDatadirForProject(projectID, userID, dirID string) (model.DatadirEntryModel, error)

func (*DatadirsRethinkdb) GetDatadirsForProject 

func (e *DatadirsRethinkdb) GetDatadirsForProject(projectID, userID string) ([]model.DatadirEntryModel, error)

func (*DatadirsRethinkdb) GetFilesForDatadir 

func (e *DatadirsRethinkdb) GetFilesForDatadir(projectID, userID, dirID string) ([]model.DatafileSimpleModel, error)

type DatadirsStoreEngine 

type DatadirsStoreEngine interface {
	GetFilesForDatadir(projectID, userID, dirID string) ([]model.DatafileSimpleModel, error)
	GetDatadirForProject(projectID, userID, dirID string) (model.DatadirEntryModel, error)
	GetDatadirsForProject(projectID, userID string) ([]model.DatadirEntryModel, error)
	//
	AddDir(dir model.DatadirSchema) (model.DatadirSchema, error)
	GetDatadirByPathInProject(path, projectID string) (model.DatadirSchema, error)
	GetDatadir(id string) (model.DatadirSchema, error)
}

type DatafileSchemaInMemory 

type DatafileSchemaInMemory struct {
	DataFile  model.DatafileSchema
	DatadirID string
}

type DatafilesMemory 

type DatafilesMemory struct {
	DB map[string]DatafileSchemaInMemory
}

func NewDatafilesMemory 

func NewDatafilesMemory() *DatafilesMemory

func NewDatafilesMemoryWithDB 

func NewDatafilesMemoryWithDB(db map[string]DatafileSchemaInMemory) *DatafilesMemory

func (*DatafilesMemory) AddFile 

func (e *DatafilesMemory) AddFile(file model.DatafileSchema, projectID, datadirID string) (model.DatafileSchema, error)

func (*DatafilesMemory) GetFile 

func (e *DatafilesMemory) GetFile(id string) (model.DatafileSchema, error)

func (*DatafilesMemory) GetFileInDir 

func (e *DatafilesMemory) GetFileInDir(name string, dirID string) (model.DatafileSchema, error)

func (*DatafilesMemory) GetFileWithChecksum 

func (e *DatafilesMemory) GetFileWithChecksum(checksum string) (model.DatafileSchema, error)

func (*DatafilesMemory) UpdateFileCurrentFlag 

func (e *DatafilesMemory) UpdateFileCurrentFlag(id string, current bool) error

type DatafilesRethinkdb 

type DatafilesRethinkdb struct {
	Session *r.Session
}

func NewDatafilesRethinkdb 

func NewDatafilesRethinkdb(session *r.Session) *DatafilesRethinkdb

func (*DatafilesRethinkdb) AddFile 

func (e *DatafilesRethinkdb) AddFile(file model.DatafileSchema, projectID, datadirID string) (model.DatafileSchema, error)

func (*DatafilesRethinkdb) GetFile 

func (e *DatafilesRethinkdb) GetFile(id string) (model.DatafileSchema, error)

func (*DatafilesRethinkdb) GetFileInDir 

func (e *DatafilesRethinkdb) GetFileInDir(name string, dirID string) (model.DatafileSchema, error)

func (*DatafilesRethinkdb) GetFileWithChecksum 

func (e *DatafilesRethinkdb) GetFileWithChecksum(checksum string) (model.DatafileSchema, error)

func (*DatafilesRethinkdb) UpdateFileCurrentFlag 

func (e *DatafilesRethinkdb) UpdateFileCurrentFlag(id string, current bool) error

type DatafilesStoreEngine 

type DatafilesStoreEngine interface {
	AddFile(file model.DatafileSchema, projectID, datadirID string) (model.DatafileSchema, error)
	GetFile(id string) (model.DatafileSchema, error)
	GetFileWithChecksum(checksum string) (model.DatafileSchema, error)
	GetFileInDir(name string, dirID string) (model.DatafileSchema, error)
	UpdateFileCurrentFlag(fileID string, current bool) error
}

type DatasetsMemory 

type DatasetsMemory struct {
	DB map[string]model.DatasetSchema
}

func NewDatasetsMemory 

func NewDatasetsMemory() *DatasetsMemory

func NewDatasetsMemoryWithDB 

func NewDatasetsMemoryWithDB(db map[string]model.DatasetSchema) *DatasetsMemory

func (*DatasetsMemory) GetDatadirsForDataset 

func (e *DatasetsMemory) GetDatadirsForDataset(datasetID string) ([]model.DatadirEntryModel, error)

func (*DatasetsMemory) GetDataset 

func (e *DatasetsMemory) GetDataset(datasetID string) (model.DatasetSchema, error)

func (*DatasetsMemory) SetDatasetZipfile 

func (e *DatasetsMemory) SetDatasetZipfile(datasetID string, size int64, name string) error

type DatasetsRethinkdb 

type DatasetsRethinkdb struct {
	Session *r.Session
}

func NewDatasetsRethinkdb 

func NewDatasetsRethinkdb(session *r.Session) *DatasetsRethinkdb

func (*DatasetsRethinkdb) GetDatadirsForDataset 

func (e *DatasetsRethinkdb) GetDatadirsForDataset(datasetID string) ([]model.DatadirEntryModel, error)

func (*DatasetsRethinkdb) GetDataset 

func (e *DatasetsRethinkdb) GetDataset(datasetID string) (model.DatasetSchema, error)

func (*DatasetsRethinkdb) SetDatasetZipfile 

func (e *DatasetsRethinkdb) SetDatasetZipfile(datasetID string, size int64, name string) error

type DatasetsStoreEngine 

type DatasetsStoreEngine interface {
	GetDatadirsForDataset(datasetID string) ([]model.DatadirEntryModel, error)
	GetDataset(datasetID string) (model.DatasetSchema, error)
	SetDatasetZipfile(datasetID string, size int64, name string) error
}

type ExperimentsMemory 

type ExperimentsMemory struct {
	DB map[string]model.ExperimentSchema
}

func NewExperimentsMemory 

func NewExperimentsMemory() *ExperimentsMemory

func NewExperimentsMemoryWithDB 

func NewExperimentsMemoryWithDB(db map[string]model.ExperimentSchema) *ExperimentsMemory

func (*ExperimentsMemory) GetExperimentOverviewsForProject 

func (e *ExperimentsMemory) GetExperimentOverviewsForProject(projectID string) ([]model.ExperimentOverviewModel, error)

type ExperimentsRethinkdb 

type ExperimentsRethinkdb struct {
	Session *r.Session
}

func NewExperimentsRethinkdb 

func NewExperimentsRethinkdb(session *r.Session) *ExperimentsRethinkdb

func (*ExperimentsRethinkdb) GetExperimentOverviewsForProject 

func (e *ExperimentsRethinkdb) GetExperimentOverviewsForProject(projectID string) ([]model.ExperimentOverviewModel, error)

type ExperimentsStoreEngine 

type ExperimentsStoreEngine interface {
	GetExperimentOverviewsForProject(projectID string) ([]model.ExperimentOverviewModel, error)
}

type FileLoadsMemory 

type FileLoadsMemory struct {
	DB map[string]model.FileLoadSchema
}

func NewFileLoadsMemory 

func NewFileLoadsMemory() *FileLoadsMemory

func NewFileLoadsMemoryWithDB 

func NewFileLoadsMemoryWithDB(db map[string]model.FileLoadSchema) *FileLoadsMemory

func (*FileLoadsMemory) AddFileLoad 

func (e *FileLoadsMemory) AddFileLoad(fload model.FileLoadSchema) (model.FileLoadSchema, error)

func (*FileLoadsMemory) DeleteFileLoad 

func (e *FileLoadsMemory) DeleteFileLoad(floadID string) error

func (*FileLoadsMemory) GetAllFileLoads 

func (e *FileLoadsMemory) GetAllFileLoads() ([]model.FileLoadSchema, error)

func (*FileLoadsMemory) GetFileLoad 

func (e *FileLoadsMemory) GetFileLoad(floadID string) (model.FileLoadSchema, error)

func (*FileLoadsMemory) MarkAllNotLoading 

func (e *FileLoadsMemory) MarkAllNotLoading() error

func (*FileLoadsMemory) UpdateLoading 

func (e *FileLoadsMemory) UpdateLoading(id string, loading bool) error

type FileLoadsRethinkdb 

type FileLoadsRethinkdb struct {
	Session *r.Session
}

func NewFileLoadsRethinkdb 

func NewFileLoadsRethinkdb(session *r.Session) *FileLoadsRethinkdb

func (*FileLoadsRethinkdb) AddFileLoad 

func (e *FileLoadsRethinkdb) AddFileLoad(upload model.FileLoadSchema) (model.FileLoadSchema, error)

func (*FileLoadsRethinkdb) DeleteFileLoad 

func (e *FileLoadsRethinkdb) DeleteFileLoad(id string) error

func (*FileLoadsRethinkdb) GetAllFileLoads 

func (e *FileLoadsRethinkdb) GetAllFileLoads() ([]model.FileLoadSchema, error)

func (*FileLoadsRethinkdb) GetFileLoad 

func (e *FileLoadsRethinkdb) GetFileLoad(uploadID string) (model.FileLoadSchema, error)

func (*FileLoadsRethinkdb) MarkAllNotLoading 

func (e *FileLoadsRethinkdb) MarkAllNotLoading() error

func (*FileLoadsRethinkdb) UpdateLoading 

func (e *FileLoadsRethinkdb) UpdateLoading(id string, loading bool) error

type FileLoadsStoreEngine 

type FileLoadsStoreEngine interface {
	AddFileLoad(fileLoad model.FileLoadSchema) (model.FileLoadSchema, error)
	DeleteFileLoad(id string) error
	GetFileLoad(id string) (model.FileLoadSchema, error)
	GetAllFileLoads() ([]model.FileLoadSchema, error)
	MarkAllNotLoading() error
	UpdateLoading(id string, loading bool) error
}

type GlobusUploadsMemory 

type GlobusUploadsMemory struct {
	DB map[string]model.GlobusUploadSchema
}

func NewGlobusUploadsMemory 

func NewGlobusUploadsMemory() *GlobusUploadsMemory

func NewGlobusUploadsMemoryWithDB 

func NewGlobusUploadsMemoryWithDB(db map[string]model.GlobusUploadSchema) *GlobusUploadsMemory

func (*GlobusUploadsMemory) AddGlobusUpload 

func (e *GlobusUploadsMemory) AddGlobusUpload(upload model.GlobusUploadSchema) (model.GlobusUploadSchema, error)

func (*GlobusUploadsMemory) DeleteGlobusUpload 

func (e *GlobusUploadsMemory) DeleteGlobusUpload(id string) error

func (*GlobusUploadsMemory) GetAllGlobusUploads 

func (e *GlobusUploadsMemory) GetAllGlobusUploads() ([]model.GlobusUploadSchema, error)

func (*GlobusUploadsMemory) GetAllGlobusUploadsForUser 

func (e *GlobusUploadsMemory) GetAllGlobusUploadsForUser(user string) ([]model.GlobusUploadSchema, error)

func (*GlobusUploadsMemory) GetGlobusUpload 

func (e *GlobusUploadsMemory) GetGlobusUpload(id string) (model.GlobusUploadSchema, error)

type GlobusUploadsRethinkdb 

type GlobusUploadsRethinkdb struct {
	Session *r.Session
}

func NewGlobusUploadsRethinkdb 

func NewGlobusUploadsRethinkdb(session *r.Session) *GlobusUploadsRethinkdb

func (*GlobusUploadsRethinkdb) AddGlobusUpload 

func (e *GlobusUploadsRethinkdb) AddGlobusUpload(upload model.GlobusUploadSchema) (model.GlobusUploadSchema, error)

func (*GlobusUploadsRethinkdb) DeleteGlobusUpload 

func (e *GlobusUploadsRethinkdb) DeleteGlobusUpload(id string) error

func (*GlobusUploadsRethinkdb) GetAllGlobusUploads 

func (e *GlobusUploadsRethinkdb) GetAllGlobusUploads() ([]model.GlobusUploadSchema, error)

func (*GlobusUploadsRethinkdb) GetAllGlobusUploadsForUser 

func (e *GlobusUploadsRethinkdb) GetAllGlobusUploadsForUser(user string) ([]model.GlobusUploadSchema, error)

func (*GlobusUploadsRethinkdb) GetGlobusUpload 

func (e *GlobusUploadsRethinkdb) GetGlobusUpload(id string) (model.GlobusUploadSchema, error)

type GlobusUploadsStoreEngine 

type GlobusUploadsStoreEngine interface {
	AddGlobusUpload(upload model.GlobusUploadSchema) (model.GlobusUploadSchema, error)
	DeleteGlobusUpload(id string) error
	GetGlobusUpload(id string) (model.GlobusUploadSchema, error)
	GetAllGlobusUploads() ([]model.GlobusUploadSchema, error)
	GetAllGlobusUploadsForUser(user string) ([]model.GlobusUploadSchema, error)
}

type ProcessesRethinkdb 

type ProcessesRethinkdb struct {
	Session *r.Session
}

func NewProcessesRethinkdb 

func NewProcessesRethinkdb(session *r.Session) *ProcessesRethinkdb

func (*ProcessesRethinkdb) AddProcess 

func (e *ProcessesRethinkdb) AddProcess(process model.ProcessSchema) (model.ProcessSchema, error)

func (*ProcessesRethinkdb) GetProcess 

func (e *ProcessesRethinkdb) GetProcess(processID string) (model.ProcessExtendedModel, error)

type ProcessesStoreEngine 

type ProcessesStoreEngine interface {
	AddProcess(process model.ProcessSchema) (model.ProcessSchema, error)
	GetProcess(processID string) (model.ProjectExtendedModel, error)
}

type ProjectAccessRethinkdb 

type ProjectAccessRethinkdb struct {
	Session *r.Session
}

func NewProjectAccessRethinkdb 

func NewProjectAccessRethinkdb(session *r.Session) *ProjectAccessRethinkdb

func (*ProjectAccessRethinkdb) AddAccessEntry 

func (e *ProjectAccessRethinkdb) AddAccessEntry(entry model.ProjectAccessSchema) (model.ProjectAccessSchema, error)

func (*ProjectAccessRethinkdb) DeleteAccess 

func (e *ProjectAccessRethinkdb) DeleteAccess(projectID, userID string) error

func (*ProjectAccessRethinkdb) DeleteAllAccessForProject 

func (e *ProjectAccessRethinkdb) DeleteAllAccessForProject(projectID string) error

func (*ProjectAccessRethinkdb) GetProjectAccess 

func (e *ProjectAccessRethinkdb) GetProjectAccess(projectID string) (model.ProjectAccessModel, error)

func (*ProjectAccessRethinkdb) GetProjectAccessEntries 

func (e *ProjectAccessRethinkdb) GetProjectAccessEntries(projectID string) ([]model.ProjectAccessSchema, error)

func (*ProjectAccessRethinkdb) GetUserAccessEntries 

func (e *ProjectAccessRethinkdb) GetUserAccessEntries(userID string) ([]model.ProjectAccessSchema, error)

type ProjectsMemory 

type ProjectsMemory struct {
	DB map[string]model.ProjectSchema
}

func NewProjectsMemory 

func NewProjectsMemory() *ProjectsMemory

func NewProjectsMemoryWithDB 

func NewProjectsMemoryWithDB(db map[string]model.ProjectSchema) *ProjectsMemory

func (*ProjectsMemory) AddProject 

func (e *ProjectsMemory) AddProject(project model.ProjectSchema) (model.ProjectSchema, error)

func (*ProjectsMemory) DeleteProject 

func (e *ProjectsMemory) DeleteProject(id string) error

func (*ProjectsMemory) GetProjectSimple 

func (e *ProjectsMemory) GetProjectSimple(id string) (model.ProjectSimpleModel, error)

func (*ProjectsMemory) GetProjectUsers 

func (e *ProjectsMemory) GetProjectUsers(id string) ([]model.UserSchema, error)

type ProjectsRethinkdb 

type ProjectsRethinkdb struct {
	Session *r.Session
}

func NewProjectsRethinkdb 

func NewProjectsRethinkdb(session *r.Session) *ProjectsRethinkdb

func (*ProjectsRethinkdb) AddProject 

func (e *ProjectsRethinkdb) AddProject(project model.ProjectSchema) (model.ProjectSchema, error)

func (*ProjectsRethinkdb) DeleteProject 

func (e *ProjectsRethinkdb) DeleteProject(id string) error

func (*ProjectsRethinkdb) GetProjectSimple 

func (e *ProjectsRethinkdb) GetProjectSimple(id string) (model.ProjectSimpleModel, error)

func (*ProjectsRethinkdb) GetProjectUsers 

func (e *ProjectsRethinkdb) GetProjectUsers(id string) ([]model.UserSchema, error)

type ProjectsStoreEngine 

type ProjectsStoreEngine interface {
	GetProjectSimple(id string) (model.ProjectSimpleModel, error)
	AddProject(project model.ProjectSchema) (model.ProjectSchema, error)
	DeleteProject(id string) error
	GetProjectUsers(id string) ([]model.UserSchema, error)
}

type SamplesRethinkdb 

type SamplesRethinkdb struct {
	Session *r.Session
}

func NewSamplesRethinkdb 

func NewSamplesRethinkdb(session *r.Session) *SamplesRethinkdb

func (*SamplesRethinkdb) AddSample 

func (e *SamplesRethinkdb) AddSample(sample model.SampleSchema) (model.SampleSchema, error)

func (*SamplesRethinkdb) DeleteSample 

func (e *SamplesRethinkdb) DeleteSample(sampleID string) error

func (*SamplesRethinkdb) GetSample 

func (e *SamplesRethinkdb) GetSample(sampleID string) (model.SampleSchema, error)

func (*SamplesRethinkdb) ModifySampleName 

func (e *SamplesRethinkdb) ModifySampleName(sampleID, name string, updatedAt time.Time) error

type SamplesStoreEngine 

type SamplesStoreEngine interface {
	AddSample(sample model.SampleSchema) (model.SampleSchema, error)
	DeleteSample(sampleID string) error
	GetSample(sampleID string) (model.SampleSchema, error)
	ModifySampleName(sampleID, name string, updatedAt time.Time) error
}

type UsersMemory 

type UsersMemory struct {
	DB map[string]model.UserSchema
}

func NewUsersMemory 

func NewUsersMemory() *UsersMemory

func NewUsersMemoryWithDB 

func NewUsersMemoryWithDB(db map[string]model.UserSchema) *UsersMemory

func (*UsersMemory) AddUser 

func (e *UsersMemory) AddUser(user model.UserSchema) (model.UserSchema, error)

func (*UsersMemory) GetUserByAPIKey 

func (e *UsersMemory) GetUserByAPIKey(apikey string) (model.UserSchema, error)

func (*UsersMemory) GetUserByID 

func (e *UsersMemory) GetUserByID(id string) (model.UserSchema, error)

func (*UsersMemory) UpdateUserAPIKey 

func (e *UsersMemory) UpdateUserAPIKey(id, apikey string, updatedAt time.Time) (model.UserSchema, error)

func (*UsersMemory) UpdateUserFullname 

func (e *UsersMemory) UpdateUserFullname(id, fullname string, updatedAt time.Time) (model.UserSchema, error)

func (*UsersMemory) UpdateUserGlobusUser 

func (e *UsersMemory) UpdateUserGlobusUser(id, globusUser string) error

func (*UsersMemory) UpdateUserPassword 

func (e *UsersMemory) UpdateUserPassword(id, password string, updatedAt time.Time) (model.UserSchema, error)

type UsersRethinkdb 

type UsersRethinkdb struct {
	Session *r.Session
}

func NewUsersRethinkdb 

func NewUsersRethinkdb(session *r.Session) *UsersRethinkdb

func (*UsersRethinkdb) AddUser 

func (e *UsersRethinkdb) AddUser(user model.UserSchema) (model.UserSchema, error)

func (*UsersRethinkdb) GetUserByAPIKey 

func (e *UsersRethinkdb) GetUserByAPIKey(apikey string) (model.UserSchema, error)

func (*UsersRethinkdb) GetUserByID 

func (e *UsersRethinkdb) GetUserByID(id string) (model.UserSchema, error)

func (*UsersRethinkdb) UpdateUserAPIKey 

func (e *UsersRethinkdb) UpdateUserAPIKey(id, apikey string, updatedAt time.Time) (model.UserSchema, error)

func (*UsersRethinkdb) UpdateUserFullname 

func (e *UsersRethinkdb) UpdateUserFullname(id, fullname string, updatedAt time.Time) (model.UserSchema, error)

func (*UsersRethinkdb) UpdateUserGlobusUser 

func (e *UsersRethinkdb) UpdateUserGlobusUser(id, globusUser string) error

func (*UsersRethinkdb) UpdateUserPassword 

func (e *UsersRethinkdb) UpdateUserPassword(id, password string, updatedAt time.Time) (model.UserSchema, error)

type UsersSQL 

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

func (*UsersSQL) AddUser 

func (e *UsersSQL) AddUser(user model.UserSchema) (model.UserSchema, error)

func (*UsersSQL) GetUserByAPIKey 

func (e *UsersSQL) GetUserByAPIKey(apikey string) (model.UserSchema, error)

func (*UsersSQL) GetUserByID 

func (e *UsersSQL) GetUserByID(id string) (model.UserSchema, error)

type UsersStoreEngine 

type UsersStoreEngine interface {
	AddUser(user model.UserSchema) (model.UserSchema, error)
	GetUserByID(id string) (model.UserSchema, error)
	GetUserByAPIKey(apikey string) (model.UserSchema, error)
	UpdateUserFullname(id, fullname string, updatedAt time.Time) (model.UserSchema, error)
	UpdateUserPassword(id, password string, updatedAt time.Time) (model.UserSchema, error)
	UpdateUserAPIKey(id, apikey string, updatedAt time.Time) (model.UserSchema, error)
	UpdateUserGlobusUser(id string, globusUser string) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.