db

func Count(collection string, filter bson.D) (error, int64)

func DeleteMany(collection string, filter bson.D) error

func DeleteOne(collection string, filter bson.D) error

func FindMany(collection string, filter bson.D) ([]interface{}, error)

func FindManyResults(collection string, filter bson.D) ([]internaltypes.Result, error)

func FindOne(collection string, filter bson.D, doc interface{}) error

func FindOneWorkflow(collection string, filter bson.D, doc internaltypes.Workflow) error

func Init()

func InsertMany(collection string, docs []interface{}) error

func InsertOne(collection string, doc interface{}) error

func ReplaceOne(collection string, filter interface{}, replacement interface{}) error

func UpdateByID(collection string, id string, update interface{}) error

func UpdateMany(collection string, filter bson.D, update bson.D) error

func UpdateOne(collection string, filter bson.D, update interface{}) error

func WebSocket(ws *websocket.Conn)