README ¶ mongorepo It's project is a extension repository for dolphin, using mongodb to persist task status Expand ▾ Collapse ▴ Documentation ¶ Index ¶ type MongoRepo func NewMongoRepo(connStr string, dbName string, cltName string) MongoRepo func (m MongoRepo) GetAll() ([]task.TaskStatus, error) func (m MongoRepo) InsertOrUpdate(ts task.TaskStatus) error func (m MongoRepo) RemoveLegacy(newTs map[string]*task.EtlTask) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type MongoRepo ¶ type MongoRepo struct { // contains filtered or unexported fields } func NewMongoRepo ¶ func NewMongoRepo(connStr string, dbName string, cltName string) MongoRepo func (MongoRepo) GetAll ¶ func (m MongoRepo) GetAll() ([]task.TaskStatus, error) func (MongoRepo) InsertOrUpdate ¶ func (m MongoRepo) InsertOrUpdate(ts task.TaskStatus) error func (MongoRepo) RemoveLegacy ¶ func (m MongoRepo) RemoveLegacy(newTs map[string]*task.EtlTask) error Source Files ¶ View all Source files mongorepo.go Click to show internal directories. Click to hide internal directories.