repository

Documentation

Index

• type Entity
• type MotionNoSQLRepository
  • func NewSummaryStockRepository(ctx context.Context, mongoConnection *mongo.Client) *MotionNoSQLRepository[nosqlDomain.SummaryStock]
  • func NewWatchListRepository(ctx context.Context, mongoConnection *mongo.Client) *MotionNoSQLRepository[nosqlDomain.WatchList]
  • func (m *MotionNoSQLRepository[T]) DeleteById(i interface{}) error
  • func (m *MotionNoSQLRepository[T]) ExistByField(s string, i interface{}) bool
  • func (m *MotionNoSQLRepository[T]) FindAll(limit, page int) ([]T, error)
  • func (m *MotionNoSQLRepository[T]) FindByField(s string, i interface{}) (T, error)
  • func (m *MotionNoSQLRepository[T]) FindById(i interface{}) (T, error)
  • func (m *MotionNoSQLRepository[T]) GetCollection() *mongo.Collection
  • func (m *MotionNoSQLRepository[T]) Save(t T) (T, error)
• type MotionRepository
• type MotionSQLRepository
  • func NewOrderRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Order]
  • func NewProfileRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Profile]
  • func NewRoleRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Role]
  • func NewSessionRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Session]
  • func NewTransactionRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Transaction]
  • func NewUserRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.MotionUser]
  • func (m *MotionSQLRepository[T]) CreateNativeSQLQuery(query string, respType interface{}, vargs ...interface{}) (interface{}, error)
  • func (m *MotionSQLRepository[T]) DeleteById(s interface{}) error
  • func (m *MotionSQLRepository[T]) ExistByField(field string, fieldvalue interface{}) bool
  • func (m *MotionSQLRepository[T]) FindAll(limit, page int) ([]T, error)
  • func (m *MotionSQLRepository[T]) FindByField(field string, fieldValue interface{}) (T, error)
  • func (m *MotionSQLRepository[T]) FindById(s interface{}) (T, error)
  • func (m *MotionSQLRepository[T]) FindWithPreloads(preloads string, s interface{}) (T, error)
  • func (m *MotionSQLRepository[T]) Save(structValue T) (T, error)

Types

type Entity

type Entity interface {
	GetId() interface{}
}

type MotionNoSQLRepository

type MotionNoSQLRepository[T Entity] struct {
	// contains filtered or unexported fields
}

func NewSummaryStockRepository

func NewSummaryStockRepository(ctx context.Context, mongoConnection *mongo.Client) *MotionNoSQLRepository[nosqlDomain.SummaryStock]

func NewWatchListRepository

func NewWatchListRepository(ctx context.Context, mongoConnection *mongo.Client) *MotionNoSQLRepository[nosqlDomain.WatchList]

func (*MotionNoSQLRepository[T]) DeleteById

func (m *MotionNoSQLRepository[T]) DeleteById(i interface{}) error

func (*MotionNoSQLRepository[T]) ExistByField

func (m *MotionNoSQLRepository[T]) ExistByField(s string, i interface{}) bool

func (*MotionNoSQLRepository[T]) FindAll

func (m *MotionNoSQLRepository[T]) FindAll(limit, page int) ([]T, error)

func (*MotionNoSQLRepository[T]) FindByField

func (m *MotionNoSQLRepository[T]) FindByField(s string, i interface{}) (T, error)

func (*MotionNoSQLRepository[T]) FindById

func (m *MotionNoSQLRepository[T]) FindById(i interface{}) (T, error)

func (*MotionNoSQLRepository[T]) GetCollection

func (m *MotionNoSQLRepository[T]) GetCollection() *mongo.Collection

func (*MotionNoSQLRepository[T]) Save

func (m *MotionNoSQLRepository[T]) Save(t T) (T, error)

type MotionRepository

type MotionRepository[T Entity] interface {
	FindById(interface{}) (T, error)
	FindByField(string, interface{}) (T, error)
	ExistByField(string, interface{}) bool
	FindAll(int, int) ([]T, error)
	DeleteById(interface{}) error
	Save(T) (T, error)
	FindWithPreloads(preloads string, s interface{}) (T, error)
}

type MotionSQLRepository

type MotionSQLRepository[T Entity] struct {
	// contains filtered or unexported fields
}

func NewOrderRepository

func NewOrderRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Order]

func NewProfileRepository

func NewProfileRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Profile]

func NewRoleRepository

func NewRoleRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Role]

func NewSessionRepository

func NewSessionRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Session]

func NewTransactionRepository

func NewTransactionRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.Transaction]

func NewUserRepository

func NewUserRepository(conn *gorm.DB) *MotionSQLRepository[sqlDomain.MotionUser]

func (*MotionSQLRepository[T]) CreateNativeSQLQuery

func (m *MotionSQLRepository[T]) CreateNativeSQLQuery(query string, respType interface{}, vargs ...interface{}) (interface{}, error)

func (*MotionSQLRepository[T]) DeleteById

func (m *MotionSQLRepository[T]) DeleteById(s interface{}) error

func (*MotionSQLRepository[T]) ExistByField

func (m *MotionSQLRepository[T]) ExistByField(field string, fieldvalue interface{}) bool

func (*MotionSQLRepository[T]) FindAll

func (m *MotionSQLRepository[T]) FindAll(limit, page int) ([]T, error)

func (*MotionSQLRepository[T]) FindByField

func (m *MotionSQLRepository[T]) FindByField(field string, fieldValue interface{}) (T, error)

func (*MotionSQLRepository[T]) FindById

func (m *MotionSQLRepository[T]) FindById(s interface{}) (T, error)

func (*MotionSQLRepository[T]) FindWithPreloads

func (m *MotionSQLRepository[T]) FindWithPreloads(preloads string, s interface{}) (T, error)

func (*MotionSQLRepository[T]) Save

func (m *MotionSQLRepository[T]) Save(structValue T) (T, error)