datasource

Documentation

Index

• func ReplaceObjectIds(data interface{}) interface{}
• type Datasource
  • func New(dsKey string, dsViper *viper.Viper, parentContext context.Context) *Datasource
  • func (ds *Datasource) Create(collectionName string, data *wst.M) (*wst.M, error)
  • func (ds *Datasource) DeleteById(collectionName string, id interface{}) int64
  • func (ds *Datasource) FindById(collectionName string, id interface{}, filter *wst.Filter, lookups *wst.A) (*wst.M, error)
  • func (ds *Datasource) FindMany(collectionName string, filter *wst.Filter, lookups *wst.A) (*wst.A, error)
  • func (ds *Datasource) Initialize() error
  • func (ds *Datasource) UpdateById(collectionName string, id interface{}, data *wst.M) (*wst.M, error)
• 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 {
	Name  string
	Db    interface{}
	Viper *viper.Viper

	Key     string
	Context context.Context
	// contains filtered or unexported fields
}

func New

func New(dsKey string, dsViper *viper.Viper, parentContext context.Context) *Datasource

func (*Datasource) Create

func (ds *Datasource) Create(collectionName string, data *wst.M) (*wst.M, 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) (*wst.M, error)

func (*Datasource) FindMany

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

func (*Datasource) Initialize

func (ds *Datasource) Initialize() error

func (*Datasource) UpdateById

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

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