mongodb

Documentation

Index

• Constants
• func ConvertToObjectID(id string) primitive.ObjectID
• func ErrorCheck(err error) error
• func GetStringID(id interface{}) string
• func IncrementVersion(version string) string
• type FileInfo
• type MongoService
  • func NewMongoService(uri string) (*MongoService, error)
  • func (db *MongoService) CreateDataset(userId string, dataset openapi.DatasetInfo) (string, error)
  • func (db *MongoService) CreateDesign(userId string, design openapi.Design) error
  • func (db *MongoService) CreateDesignCode(userId string, designId string, fileName string, fileVer string, ...) error
  • func (db *MongoService) CreateDesignSchema(userId string, designId string, ds openapi.DesignSchema) error
  • func (db *MongoService) CreateJob(userId string, jobSpec openapi.JobSpec) (openapi.JobStatus, error)
  • func (db *MongoService) CreateTasks(tasks []objects.Task, dirty bool) error
  • func (db *MongoService) DeleteJob(userId string, jobId string) error
  • func (db *MongoService) DeleteTasks(jobId string, dirty bool) error
  • func (db *MongoService) GetDatasetById(datasetId string) (openapi.DatasetInfo, error)
  • func (db *MongoService) GetDatasets(userId string, limit int32) ([]openapi.DatasetInfo, error)
  • func (db *MongoService) GetDesign(userId string, designId string) (openapi.Design, error)
  • func (db *MongoService) GetDesignCode(userId string, designId string, fileVer string) ([]byte, error)
  • func (db *MongoService) GetDesignSchema(userId string, designId string, version string) (openapi.DesignSchema, error)
  • func (db *MongoService) GetDesignSchemas(userId string, designId string) ([]openapi.DesignSchema, error)
  • func (db *MongoService) GetDesigns(userId string, limit int32) ([]openapi.DesignInfo, error)
  • func (db *MongoService) GetJob(userId string, jobId string) (openapi.JobSpec, error)
  • func (db *MongoService) GetJobById(jobId string) (openapi.JobSpec, error)
  • func (db *MongoService) GetJobStatus(userId string, jobId string) (openapi.JobStatus, error)
  • func (db *MongoService) GetJobs(userId string, limit int32) ([]openapi.JobStatus, error)
  • func (db *MongoService) GetLatestDesignCodeVersion(userId string, designId string) string
  • func (db *MongoService) GetTask(jobId string, agentId string, key string) (map[string][]byte, error)
  • func (db *MongoService) GetTasksInfo(userId string, jobId string, limit int32, inclKey bool) ([]openapi.TaskInfo, error)
  • func (db *MongoService) IsOneTaskInState(jobId string, state openapi.JobState) bool
  • func (db *MongoService) IsOneTaskInStateWithRole(jobId string, state openapi.JobState, role string) bool
  • func (db *MongoService) MonitorTasks(jobId string) (chan openapi.TaskInfo, chan error, context.CancelFunc, error)
  • func (db *MongoService) SetTaskDirtyFlag(jobId string, dirty bool) error
  • func (db *MongoService) UpdateDesignSchema(userId string, designId string, version string, ds openapi.DesignSchema) error
  • func (db *MongoService) UpdateJob(userId string, jobId string, jobSpec openapi.JobSpec) error
  • func (db *MongoService) UpdateJobStatus(userId string, jobId string, jobStatus openapi.JobStatus) error
  • func (db *MongoService) UpdateTaskStateByFilter(jobId string, newState openapi.JobState, userFilter map[string]interface{}) error
  • func (db *MongoService) UpdateTaskStatus(jobId string, agentId string, taskStatus openapi.TaskStatus) error

Constants

const (
	DatabaseName      = "flame"
	DatasetCollection = "t_dataset"
	DesignCollection  = "t_design"
	JobCollection     = "t_job"
	TaskCollection    = "t_task"
)

Functions

func ConvertToObjectID

func ConvertToObjectID(id string) primitive.ObjectID

Tutorial - https://www.mongodb.com/blog/post/quick-start-golang--mongodb--how-to-read-documents

Bson.M vs .D https://stackoverflow.com/questions/64281675/bson-d-vs-bson-m-for-find-queries

func ErrorCheck

func ErrorCheck(err error) error

func GetStringID

func GetStringID(id interface{}) string

func IncrementVersion

func IncrementVersion(version string) string

Types

type FileInfo

type FileInfo struct {
	ZipName string          `json:"zipname"`
	Version string          `json:"version"`
	DataSet []util.FileData `json:"dataset"`
}

type MongoService

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

func NewMongoService

func NewMongoService(uri string) (*MongoService, error)

func (*MongoService) CreateDataset

func (db *MongoService) CreateDataset(userId string, dataset openapi.DatasetInfo) (string, error)

CreateDataset creates a new dataset entry in the database

func (*MongoService) CreateDesign

func (db *MongoService) CreateDesign(userId string, design openapi.Design) error

CreateDesign create a new design entry in the database

func (*MongoService) CreateDesignCode

func (db *MongoService) CreateDesignCode(userId string, designId string, fileName string, fileVer string, fileData *os.File) error

func (*MongoService) CreateDesignSchema

func (db *MongoService) CreateDesignSchema(userId string, designId string, ds openapi.DesignSchema) error

CreateDesignSchema adds schema design to the design template information

func (*MongoService) CreateJob

func (db *MongoService) CreateJob(userId string, jobSpec openapi.JobSpec) (openapi.JobStatus, error)

CreateJob creates a new job specification and returns JobStatus

func (*MongoService) CreateTasks

func (db *MongoService) CreateTasks(tasks []objects.Task, dirty bool) error

CreateTasks creates task records in task db collection

func (*MongoService) DeleteJob

func (db *MongoService) DeleteJob(userId string, jobId string) error

func (*MongoService) DeleteTasks

func (db *MongoService) DeleteTasks(jobId string, dirty bool) error

func (*MongoService) GetDatasetById

func (db *MongoService) GetDatasetById(datasetId string) (openapi.DatasetInfo, error)

func (*MongoService) GetDatasets

func (db *MongoService) GetDatasets(userId string, limit int32) ([]openapi.DatasetInfo, error)

func (*MongoService) GetDesign

func (db *MongoService) GetDesign(userId string, designId string) (openapi.Design, error)

GetDesign returns the details about the given design id

func (*MongoService) GetDesignCode

func (db *MongoService) GetDesignCode(userId string, designId string, fileVer string) ([]byte, error)

func (*MongoService) GetDesignSchema

func (db *MongoService) GetDesignSchema(userId string, designId string, version string) (openapi.DesignSchema, error)

func (*MongoService) GetDesignSchemas

func (db *MongoService) GetDesignSchemas(userId string, designId string) ([]openapi.DesignSchema, error)

func (*MongoService) GetDesigns

func (db *MongoService) GetDesigns(userId string, limit int32) ([]openapi.DesignInfo, error)

GetDesigns get a lists of all the designs created by the user TODO: update the method to implement a limit next based cursor

func (*MongoService) GetJob

func (db *MongoService) GetJob(userId string, jobId string) (openapi.JobSpec, error)

func (*MongoService) GetJobById

func (db *MongoService) GetJobById(jobId string) (openapi.JobSpec, error)

func (*MongoService) GetJobStatus

func (db *MongoService) GetJobStatus(userId string, jobId string) (openapi.JobStatus, error)

func (*MongoService) GetJobs

func (db *MongoService) GetJobs(userId string, limit int32) ([]openapi.JobStatus, error)

func (*MongoService) GetLatestDesignCodeVersion

func (db *MongoService) GetLatestDesignCodeVersion(userId string, designId string) string

func (*MongoService) GetTask

func (db *MongoService) GetTask(jobId string, agentId string, key string) (map[string][]byte, error)

func (*MongoService) GetTasksInfo

func (db *MongoService) GetTasksInfo(userId string, jobId string, limit int32, inclKey bool) ([]openapi.TaskInfo, error)

func (*MongoService) IsOneTaskInState

func (db *MongoService) IsOneTaskInState(jobId string, state openapi.JobState) bool

IsOneTaskInState returns true if the state of at least one task is set to the given state. Otherwise, it returns false.

func (*MongoService) IsOneTaskInStateWithRole

func (db *MongoService) IsOneTaskInStateWithRole(jobId string, state openapi.JobState, role string) bool

func (*MongoService) MonitorTasks

func (db *MongoService) MonitorTasks(jobId string) (chan openapi.TaskInfo, chan error, context.CancelFunc, error)

MonitorTasks creates and returns a watcher to monitor state changes of tasks in a job

func (*MongoService) SetTaskDirtyFlag

func (db *MongoService) SetTaskDirtyFlag(jobId string, dirty bool) error

func (*MongoService) UpdateDesignSchema

func (db *MongoService) UpdateDesignSchema(userId string, designId string, version string, ds openapi.DesignSchema) error

func (*MongoService) UpdateJob

func (db *MongoService) UpdateJob(userId string, jobId string, jobSpec openapi.JobSpec) error

func (*MongoService) UpdateJobStatus

func (db *MongoService) UpdateJobStatus(userId string, jobId string, jobStatus openapi.JobStatus) error

UpdateJobStatus update Job's status

func (*MongoService) UpdateTaskStateByFilter

func (db *MongoService) UpdateTaskStateByFilter(jobId string, newState openapi.JobState, userFilter map[string]interface{}) error

UpdateTaskStateByFilter updates the status of tasks on a particular state in a job. The function should be only called by a system; hence, this function shouldn't become open to user API

func (*MongoService) UpdateTaskStatus

func (db *MongoService) UpdateTaskStatus(jobId string, agentId string, taskStatus openapi.TaskStatus) error