mongorepo

Documentation

Index

• type Config
• type Repository
  • func New(cfg Config) *Repository
  • func (r *Repository) Connect(ctx context.Context) error
  • func (r *Repository) CreateFollow(ctx context.Context, req outbound.CreateFollowRequest) error
  • func (r *Repository) CreateOrder(ctx context.Context, req outbound.CreateOrderRequest) error
  • func (r *Repository) Disconnect(ctx context.Context) error
  • func (r *Repository) GetFollow(ctx context.Context, req outbound.GetFollowRequest) (domain.Follow, error)
  • func (r *Repository) GetOrder(ctx context.Context, req outbound.GetOrderRequest) (domain.Order, error)
  • func (r *Repository) UpdateFollow(ctx context.Context, req outbound.UpdateFollowRequest) error
  • func (r *Repository) UpdateOrder(ctx context.Context, req outbound.UpdateOrderRequest) error

Types

type Config

type Config struct {
	DBName string
	URI    string
}

type Repository

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

func New

func New(cfg Config) *Repository

func (*Repository) Connect

func (r *Repository) Connect(ctx context.Context) error

func (*Repository) CreateFollow

func (r *Repository) CreateFollow(ctx context.Context, req outbound.CreateFollowRequest) error

Follow

func (*Repository) CreateOrder

func (r *Repository) CreateOrder(ctx context.Context, req outbound.CreateOrderRequest) error

Order

func (*Repository) Disconnect

func (r *Repository) Disconnect(ctx context.Context) error

func (*Repository) GetFollow

func (r *Repository) GetFollow(ctx context.Context, req outbound.GetFollowRequest) (domain.Follow, error)

func (*Repository) GetOrder

func (r *Repository) GetOrder(ctx context.Context, req outbound.GetOrderRequest) (domain.Order, error)

func (*Repository) UpdateFollow

func (r *Repository) UpdateFollow(ctx context.Context, req outbound.UpdateFollowRequest) error

func (*Repository) UpdateOrder

func (r *Repository) UpdateOrder(ctx context.Context, req outbound.UpdateOrderRequest) error