repository

Documentation

Index

• Constants
• func InitMongoDB(logger *logrus.Logger) *mongo.Database
• func TimeOutContext() (context.Context, context.CancelFunc)
• func TimeOutContextWithParent(parent context.Context) (context.Context, context.CancelFunc)
• type MongoRepository
  • func BuildMongoRepository(db *mongo.Database) *MongoRepository
  • func (m *MongoRepository) OrderRepository() OrderRepository
• type OrderRepo
  • func NewOrderRepo(db *mongo.Database, log *logrus.Logger) *OrderRepo
  • func (r *OrderRepo) Create(c context.Context, t *model.Order) (model.Order, error)
  • func (r *OrderRepo) FindAll() ([]model.Order, error)
  • func (r *OrderRepo) FindByID(id string) (model.Order, error)
• type OrderRepository
• type Repository

Constants

const (
	ErrMgoInvalidOID = "invalid ObjectId: %s"
	ErrMgoOpsFail    = "fail MongoOperation : %s"
)

Err

Functions

func InitMongoDB

func InitMongoDB(logger *logrus.Logger) *mongo.Database

func TimeOutContext

func TimeOutContext() (context.Context, context.CancelFunc)

TimeOutContext is a global context for mongodb connection access

func TimeOutContextWithParent

func TimeOutContextWithParent(parent context.Context) (context.Context, context.CancelFunc)

TimeOutContextWithParent is a global context for mongodb connection access with parent Context

Types

type MongoRepository

type MongoRepository struct {
	DB *mongo.Database
	// contains filtered or unexported fields
}

MongoRepository implementation of `service.Repository`

func BuildMongoRepository

func BuildMongoRepository(db *mongo.Database) *MongoRepository

func (*MongoRepository) OrderRepository

func (m *MongoRepository) OrderRepository() OrderRepository

type OrderRepo

type OrderRepo struct {
	// contains filtered or unexported fields
}

Order repository

func NewOrderRepo

func NewOrderRepo(db *mongo.Database, log *logrus.Logger) *OrderRepo

Instantiate new OrderRepo

func (*OrderRepo) Create

func (r *OrderRepo) Create(c context.Context, t *model.Order) (model.Order, error)

Create new Order

func (*OrderRepo) FindAll

func (r *OrderRepo) FindAll() ([]model.Order, error)

FindAll orders

func (*OrderRepo) FindByID

func (r *OrderRepo) FindByID(id string) (model.Order, error)

FindByID is finding order by its id

type OrderRepository

type OrderRepository interface {
	Create(c context.Context, t *model.Order) (model.Order, error)
	FindByID(id string) (model.Order, error)
	FindAll() ([]model.Order, error)
}

OrderRepository ...

type Repository

type Repository interface {
	OrderRepository() OrderRepository
}

Repository is base interface for any kind of Repository