datasource

Documentation

Index

• func ReplaceObjectIds(data interface{}) interface{}
• type Datasource
  • func New(config wst.M) *Datasource
  • func (ds *Datasource) Create(collectionName string, data *wst.M) (*mongo.Cursor, error)
  • func (ds *Datasource) DeleteById(collectionName string, id interface{}) int64
  • func (ds *Datasource) FindById(collectionName string, id interface{}, filter *wst.Filter, lookups *wst.A) *mongo.Cursor
  • func (ds *Datasource) FindMany(collectionName string, filter *wst.Filter, lookups *wst.A) *mongo.Cursor
  • func (ds *Datasource) Initialize() error
  • func (ds *Datasource) UpdateById(collectionName string, id interface{}, data *wst.M) *mongo.Cursor
• type OperationError
  • func NewError(code int, message string) *OperationError
  • func (e *OperationError) Error() string

Functions

func ReplaceObjectIds

func ReplaceObjectIds(data interface{}) interface{}

Types

type Datasource

type Datasource struct {
	Config wst.M
	Db     interface{}
}

func New

func New(config wst.M) *Datasource

func (*Datasource) Create

func (ds *Datasource) Create(collectionName string, data *wst.M) (*mongo.Cursor, error)

func (*Datasource) DeleteById

func (ds *Datasource) DeleteById(collectionName string, id interface{}) int64

func (*Datasource) FindById

func (ds *Datasource) FindById(collectionName string, id interface{}, filter *wst.Filter, lookups *wst.A) *mongo.Cursor

func (*Datasource) FindMany

func (ds *Datasource) FindMany(collectionName string, filter *wst.Filter, lookups *wst.A) *mongo.Cursor

func (*Datasource) Initialize

func (ds *Datasource) Initialize() error

func (*Datasource) UpdateById

func (ds *Datasource) UpdateById(collectionName string, id interface{}, data *wst.M) *mongo.Cursor

type OperationError

type OperationError struct {
	Code    int
	Message string
}

func NewError

func NewError(code int, message string) *OperationError

func (*OperationError) Error

func (e *OperationError) Error() string