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) FindMany(collectionName string, 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 MonoDBDatasourceOptions
• type OperationError
  • func NewError(code int, message string) *OperationError
  • func (e *OperationError) Error() string
• type Options

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
	Options *Options
	// 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) FindMany

func (ds *Datasource) FindMany(collectionName string, 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 MonoDBDatasourceOptions

type MonoDBDatasourceOptions struct {
	Registry *bsoncodec.Registry
	Monitor  *event.CommandMonitor
}

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

type Options

type Options struct {
	MongoDB *MonoDBDatasourceOptions
}