usecase

Documentation

Index

• type FranchiseUseCase
  • func NewFranchiseUseCase(franchiseScrapper httprport.ScrapFranchiseRepository, ...) *FranchiseUseCase
  • func (fuc *FranchiseUseCase) Create(f dto.PendingFranchiseDTO) error
  • func (fuc *FranchiseUseCase) GetAll(in dto.ConsultFranchiseCriterialDTO) ([]dto.FlatDetailedFranchiseDTO, error)
  • func (fuc *FranchiseUseCase) Update(u dto.UpdateFranchiseDTO) (dto.UpdatedFranchiseDTO, error)
• type PendingFranchiseUseCase
  • func NewPendingFranchiseUseCase(newFranchizeRepository psql.PendingFranchiseRepository, ...) *PendingFranchiseUseCase
  • func (nfs *PendingFranchiseUseCase) Create(in dto.CreateNewFranchizeDTO) (dto.PendingFranchiseDTO, error)
• type ProcessFranchiseUseCase
  • func NewProcessFranchiseUseCase(serviceConn grpc.ClientConnInterface, ...) *ProcessFranchiseUseCase
  • func (pfuc *ProcessFranchiseUseCase) Subscribe(e event.Event) error

Types

type FranchiseUseCase

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

func NewFranchiseUseCase

func NewFranchiseUseCase(
	franchiseScrapper httprport.ScrapFranchiseRepository,
	countryRepository psqlrport.CountryRepository,
	cityRepository psqlrport.CityRepository,
	companyRepository psqlrport.CompanyRepository,
	locationRepository psqlrport.LocationRepository,
	franchiseRepository psqlrport.FranchiseRepository,
	detailedFranchiseRepository psqlrport.DetailedFranchiseRepository,
) *FranchiseUseCase

func (*FranchiseUseCase) Create

func (fuc *FranchiseUseCase) Create(f dto.PendingFranchiseDTO) error

func (*FranchiseUseCase) GetAll

func (fuc *FranchiseUseCase) GetAll(in dto.ConsultFranchiseCriterialDTO) ([]dto.FlatDetailedFranchiseDTO, error)

func (*FranchiseUseCase) Update

func (fuc *FranchiseUseCase) Update(u dto.UpdateFranchiseDTO) (dto.UpdatedFranchiseDTO, error)

type PendingFranchiseUseCase

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

func NewPendingFranchiseUseCase

func NewPendingFranchiseUseCase(newFranchizeRepository psql.PendingFranchiseRepository, franchiseCreationPublisher qport.Publisher) *PendingFranchiseUseCase

func (*PendingFranchiseUseCase) Create

func (nfs *PendingFranchiseUseCase) Create(in dto.CreateNewFranchizeDTO) (dto.PendingFranchiseDTO, error)

type ProcessFranchiseUseCase

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

func NewProcessFranchiseUseCase

func NewProcessFranchiseUseCase(serviceConn grpc.ClientConnInterface, pendingFranchiseRepository psqlrport.PendingFranchiseRepository) *ProcessFranchiseUseCase

func (*ProcessFranchiseUseCase) Subscribe

func (pfuc *ProcessFranchiseUseCase) Subscribe(e event.Event) error