db

Documentation

Index

• Constants
• Variables
• type OrdersDataService
• type OrdersRepo
  • func NewOrdersRepo(lgr logger.Logger, db mongodb.MongoDatabase) (*OrdersRepo, error)
  • func (o *OrdersRepo) Create(ctx context.Context, po *data.Order) (string, error)
  • func (o *OrdersRepo) DeleteByID(ctx context.Context, id primitive.ObjectID) error
  • func (o *OrdersRepo) GetAll(ctx context.Context, offset, limit int64) (*[]data.Order, error)
  • func (o *OrdersRepo) GetByID(ctx context.Context, oID primitive.ObjectID) (*data.Order, error)
  • func (o *OrdersRepo) Update(ctx context.Context, po *data.Order) error

Constants

const (
	OrdersCollection = "purchaseOrders"
	DefaultPageSize  = 100
)

Variables

var (
	ErrInvalidInitialization = errors.New("invalid initialization")
	ErrInvalidPOIDCreate     = errors.New("order id should be empty")
	ErrInvalidPOIDUpdate     = errors.New("invalid order id")
	ErrUnexpectedUpdateOrder = errors.New("unexpected error occurred while updating order")
	ErrPOIDNotFound          = errors.New("purchase order doesn't exist with given id")
	ErrFailedToCreateOrder   = errors.New("failed to create order")
	ErrUnexpectedDeleteOrder = errors.New("unexpected error occurred while deleting order")
	ErrUnexpectedGetOrder    = errors.New("unexpected error occurred while fetching order")
	ErrInvalidID             = errors.New("failed to assert inserted ID as ObjectID")
)

Types

type OrdersDataService

type OrdersDataService interface {
	Create(ctx context.Context, purchaseOrder *data.Order) (string, error)
	Update(ctx context.Context, purchaseOrder *data.Order) error
	GetAll(ctx context.Context, offset, limit int64) (*[]data.Order, error)
	GetByID(ctx context.Context, id primitive.ObjectID) (*data.Order, error)
	DeleteByID(ctx context.Context, id primitive.ObjectID) error
}

OrdersDataService defines the interface for order data operations.

type OrdersRepo

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

OrdersRepo implements OrdersDataService using MongoDB.

func NewOrdersRepo

func NewOrdersRepo(lgr logger.Logger, db mongodb.MongoDatabase) (*OrdersRepo, error)

NewOrdersRepo creates a new OrdersRepo.

func (*OrdersRepo) Create

func (o *OrdersRepo) Create(ctx context.Context, po *data.Order) (string, error)

Create inserts a new order into the collection.

func (*OrdersRepo) DeleteByID

func (o *OrdersRepo) DeleteByID(ctx context.Context, id primitive.ObjectID) error

DeleteByID removes an order by its ObjectID.

func (*OrdersRepo) GetAll

func (o *OrdersRepo) GetAll(ctx context.Context, offset, limit int64) (*[]data.Order, error)

GetAll retrieves all orders up to the specified limit, starting at the given offset.

func (*OrdersRepo) GetByID

func (o *OrdersRepo) GetByID(ctx context.Context, oID primitive.ObjectID) (*data.Order, error)

GetByID retrieves an order by its ObjectID.

func (*OrdersRepo) Update

func (o *OrdersRepo) Update(ctx context.Context, po *data.Order) error

Update modifies an existing order.