db

Documentation

Index

• 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)

Functions

func Count

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

func DeleteMany

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

func DeleteOne

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

func FindMany

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

func FindManyResults

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

func FindOne

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

func FindOneWorkflow

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

func Init

func Init()

func InsertMany

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

func InsertOne

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

func ReplaceOne

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

func UpdateByID

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

func UpdateMany

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

func UpdateOne

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

func WebSocket

func WebSocket(ws *websocket.Conn)