mongodb

Documentation

Index

• type Handle
  • func NewMongoDBHandle(log ports.Logger, client *mongo.Client) *Handle
  • func (h *Handle) Begin(ctx context.Context, i ...interface{}) (models.Response, error)
  • func (h *Handle) Close() error
  • func (h *Handle) Configure(ctx context.Context, i ...interface{}) error
  • func (h *Handle) Create(ctx context.Context, params ...interface{}) (response models.Response, err error)
  • func (h *Handle) Delete(ctx context.Context, i ...interface{}) (models.Response, error)
  • func (h *Handle) Execute(ctx context.Context, i ...interface{}) (models.Response, error)
  • func (h *Handle) Query(ctx context.Context, params ...interface{}) (response models.Response, err error)
  • func (h *Handle) Rollback(ctx context.Context, i ...interface{}) (models.Response, error)
  • func (h *Handle) Update(ctx context.Context, params ...interface{}) (response models.Response, err error)

Types

type Handle

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

func NewMongoDBHandle

func NewMongoDBHandle(log ports.Logger, client *mongo.Client) *Handle

func (*Handle) Begin

func (h *Handle) Begin(ctx context.Context, i ...interface{}) (models.Response, error)

func (*Handle) Close

func (h *Handle) Close() error

func (*Handle) Configure

func (h *Handle) Configure(ctx context.Context, i ...interface{}) error

func (*Handle) Create

func (h *Handle) Create(ctx context.Context, params ...interface{}) (response models.Response, err error)

func (*Handle) Delete

func (h *Handle) Delete(ctx context.Context, i ...interface{}) (models.Response, error)

func (*Handle) Execute

func (h *Handle) Execute(ctx context.Context, i ...interface{}) (models.Response, error)

func (*Handle) Query

func (h *Handle) Query(ctx context.Context, params ...interface{}) (response models.Response, err error)

func (*Handle) Rollback

func (h *Handle) Rollback(ctx context.Context, i ...interface{}) (models.Response, error)

func (*Handle) Update

func (h *Handle) Update(ctx context.Context, params ...interface{}) (response models.Response, err error)