repository

Documentation

Index

• Constants
• Variables
• type CRUDImpl
  • func NewCRUDImpl(db datasource.IDataSource, redis datasource.ICacheDataSource, ...) *CRUDImpl
  • func (r *CRUDImpl) Create(ctx context.Context, e domain.IEntity) (domain.IEntity, error)
  • func (r *CRUDImpl) CreateTx(ctx context.Context, e domain.IEntity, tx domain.ITransactionEvent) (domain.IEntity, error)
  • func (r *CRUDImpl) Delete(ctx context.Context, e domain.IEntity) (domain.IEntity, error)
  • func (r *CRUDImpl) DeleteTx(ctx context.Context, e domain.IEntity, tx domain.ITransactionEvent) (domain.IEntity, error)
  • func (r *CRUDImpl) GetAll(ctx context.Context, sq *domain.SearchQuery, e domain.IEntity) (*domain.List, error)
  • func (r *CRUDImpl) GetByID(ctx context.Context, e domain.IEntity) (domain.IEntity, error)
  • func (r *CRUDImpl) Update(ctx context.Context, e domain.IEntity) (domain.IEntity, error)
  • func (r *CRUDImpl) UpdateTx(ctx context.Context, e domain.IEntity, tx domain.ITransactionEvent) (domain.IEntity, error)
  • func (r *CRUDImpl) UpdateWithFields(ctx context.Context, e domain.IEntity, keys []string) (domain.IEntity, error)
  • func (r *CRUDImpl) UpdateWithFieldsTx(ctx context.Context, e domain.IEntity, keys []string, ...) (domain.IEntity, error)
• type TransactionRunRepoImpl
  • func NewTransactionRunRepoImpl(tr datasource.ITransactionRun) *TransactionRunRepoImpl
  • func (r *TransactionRunRepoImpl) RunTransaction(ctx context.Context, f domain.TransactionEventFunc) error

Constants

const (
	ErrorCodeDatasource = domainerrors.ErrorCodeInfraRepo + domainerrors.ErrorCodeInfraRepoCRUD + iota
	ErrorCodeRepoTransform
	ErrorCodeRepoBackToDomain
	ErrorCodeRepoCast
	ErrorCodeRepoCreate
	ErrorCodeRepoDelete
	ErrorCodeRepoUpdate
	ErrorCodeRepoUpdateWithFields
	ErrorCodeRepoGet
	ErrorCodeRepoGetAll
	ErrorCodeRepoSet
	ErrorCodeRepoCreateTx
	ErrorCodeRepoDeleteTx
	ErrorCodeRepoUpdateTx
	ErrorCodeRepoUpdateWithFieldsTx
	ErrorCodeRepoParseMap
)

Variables

var (
	ErrCastTypeFailed = errors.New("repo transform failed")
)

Types

type CRUDImpl

type CRUDImpl struct {
	DB        datasource.IDataSource
	Redis     datasource.ICacheDataSource
	Cache     datasource.ICacheDataSource
	DTOEntity dto.IRepoEntity
}

CRUDImpl -.

func NewCRUDImpl

func NewCRUDImpl(db datasource.IDataSource, redis datasource.ICacheDataSource, cache datasource.ICacheDataSource, data dto.IRepoEntity) *CRUDImpl

NewCRUDImpl -.

func (*CRUDImpl) Create

func (r *CRUDImpl) Create(ctx context.Context, e domain.IEntity) (domain.IEntity, error)

Create -.

func (*CRUDImpl) CreateTx

func (r *CRUDImpl) CreateTx(ctx context.Context, e domain.IEntity, tx domain.ITransactionEvent) (domain.IEntity, error)

CreateTx -.

func (*CRUDImpl) Delete

func (r *CRUDImpl) Delete(ctx context.Context, e domain.IEntity) (domain.IEntity, error)

Delete -.

func (*CRUDImpl) DeleteTx

func (r *CRUDImpl) DeleteTx(ctx context.Context, e domain.IEntity, tx domain.ITransactionEvent) (domain.IEntity, error)

DeleteTx -.

func (*CRUDImpl) GetAll

func (r *CRUDImpl) GetAll(ctx context.Context, sq *domain.SearchQuery, e domain.IEntity) (*domain.List, error)

GetAll -.

func (*CRUDImpl) GetByID

func (r *CRUDImpl) GetByID(ctx context.Context, e domain.IEntity) (domain.IEntity, error)

GetByID -.

func (*CRUDImpl) Update

func (r *CRUDImpl) Update(ctx context.Context, e domain.IEntity) (domain.IEntity, error)

Update -.

func (*CRUDImpl) UpdateTx

func (r *CRUDImpl) UpdateTx(ctx context.Context, e domain.IEntity, tx domain.ITransactionEvent) (domain.IEntity, error)

func (*CRUDImpl) UpdateWithFields

func (r *CRUDImpl) UpdateWithFields(ctx context.Context, e domain.IEntity, keys []string) (domain.IEntity, error)

func (*CRUDImpl) UpdateWithFieldsTx

func (r *CRUDImpl) UpdateWithFieldsTx(ctx context.Context, e domain.IEntity, keys []string, tx domain.ITransactionEvent) (domain.IEntity, error)

type TransactionRunRepoImpl

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

func NewTransactionRunRepoImpl

func NewTransactionRunRepoImpl(tr datasource.ITransactionRun) *TransactionRunRepoImpl

NewTransactionRunRepoImpl -.

func (*TransactionRunRepoImpl) RunTransaction

func (r *TransactionRunRepoImpl) RunTransaction(ctx context.Context, f domain.TransactionEventFunc) error

RunTransaction -.