mongo

Documentation

Index

• type Repository
  • func New(ctx context.Context, uri, dbName string) (*Repository, error)
  • func (r *Repository) ListCustomers(ctx context.Context, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)
  • func (r *Repository) LockCustomer(ctx context.Context, id string) (func(), error)
  • func (r *Repository) LookupCustomerById(ctx context.Context, id string) (*customerv1.Customer, []*customerv1.ImportState, error)
  • func (r *Repository) LookupCustomerByMail(ctx context.Context, mail string, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)
  • func (r *Repository) LookupCustomerByName(ctx context.Context, name string, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)
  • func (r *Repository) LookupCustomerByPhone(ctx context.Context, phone string, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)
  • func (r *Repository) LookupCustomerByRef(ctx context.Context, importer, ref string) (*customerv1.Customer, []*customerv1.ImportState, error)
  • func (r *Repository) SearchQueries(ctx context.Context, queries []*customerv1.CustomerQuery, ...) ([]*customerv1.CustomerResponse, int, error)
  • func (r *Repository) StoreCustomer(ctx context.Context, customer *customerv1.Customer, ...) error

Types

type Repository

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

func New

func New(ctx context.Context, uri, dbName string) (*Repository, error)

func (*Repository) ListCustomers

func (r *Repository) ListCustomers(ctx context.Context, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)

func (*Repository) LockCustomer

func (r *Repository) LockCustomer(ctx context.Context, id string) (func(), error)

func (*Repository) LookupCustomerById

func (r *Repository) LookupCustomerById(ctx context.Context, id string) (*customerv1.Customer, []*customerv1.ImportState, error)

func (*Repository) LookupCustomerByMail

func (r *Repository) LookupCustomerByMail(ctx context.Context, mail string, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)

func (*Repository) LookupCustomerByName

func (r *Repository) LookupCustomerByName(ctx context.Context, name string, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)

func (*Repository) LookupCustomerByPhone

func (r *Repository) LookupCustomerByPhone(ctx context.Context, phone string, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)

func (*Repository) LookupCustomerByRef

func (r *Repository) LookupCustomerByRef(ctx context.Context, importer, ref string) (*customerv1.Customer, []*customerv1.ImportState, error)

func (*Repository) SearchQueries

func (r *Repository) SearchQueries(ctx context.Context, queries []*customerv1.CustomerQuery, p *commonv1.Pagination) ([]*customerv1.CustomerResponse, int, error)

func (*Repository) StoreCustomer

func (r *Repository) StoreCustomer(ctx context.Context, customer *customerv1.Customer, states []*customerv1.ImportState) error