datasource

Documentation

Index

• Variables
• func ReplaceObjectIds(data interface{}) interface{}
• type Datasource
  • func New(dsKey string, dsViper *viper.Viper, parentContext context.Context) *Datasource
  • func (ds *Datasource) Count(collectionName string, lookups *wst.A) (int64, error)
  • 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 MongoDBDatasourceOptions
• type OperationError
  • func NewError(code int, message string) *OperationError
  • func (e *OperationError) Error() string
• type Options

Variables

var (
	RegexDaysAgo        = regexp.MustCompile(`^\$(\d+)dago$`)
	RegexWeeksAgo       = regexp.MustCompile(`^\$(\d+)wago$`)
	RegexMonthsAgo      = regexp.MustCompile(`^\$(\d+)mago$`)
	RegexYearsAgo       = regexp.MustCompile(`^\$(\d+)yago$`)
	RegexSecondsAgo     = regexp.MustCompile(`^\$(\d+)Sago$`)
	RegexMinutesAgo     = regexp.MustCompile(`^\$(\d+)Mago$`)
	RegexHoursAgo       = regexp.MustCompile(`^\$(\d+)Hago$`)
	RegexDaysFromNow    = regexp.MustCompile(`^\$(\d+)dfromnow$`)
	RegexWeeksFromNow   = regexp.MustCompile(`^\$(\d+)wfromnow$`)
	RegexMonthsFromNow  = regexp.MustCompile(`^\$(\d+)mfromnow$`)
	RegexYearsFromNow   = regexp.MustCompile(`^\$(\d+)yfromnow$`)
	RegexSecondsFromNow = regexp.MustCompile(`^\$(\d+)Sfromnow$`)
	RegexMinutesFromNow = regexp.MustCompile(`^\$(\d+)Mfromnow$`)
	RegexHoursFromNow   = regexp.MustCompile(`^\$(\d+)Hfromnow$`)
)

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

func (ds *Datasource) Count(collectionName string, lookups *wst.A) (int64, error)

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 MongoDBDatasourceOptions

type MongoDBDatasourceOptions struct {
	Registry     *bsoncodec.Registry
	Monitor      *event.CommandMonitor
	Timeout      int
	RetryOnError bool
}

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 *MongoDBDatasourceOptions
}