scheduledTaskInfra

Documentation

Index

• type ScheduledTaskCmdRepo
  • func NewScheduledTaskCmdRepo(persistentDbSvc *internalDbInfra.PersistentDatabaseService) *ScheduledTaskCmdRepo
  • func (repo *ScheduledTaskCmdRepo) Create(createDto dto.CreateScheduledTask) error
  • func (repo *ScheduledTaskCmdRepo) Delete(id valueObject.ScheduledTaskId) error
  • func (repo *ScheduledTaskCmdRepo) Run(pendingTask entity.ScheduledTask) error
  • func (repo *ScheduledTaskCmdRepo) Update(updateDto dto.UpdateScheduledTask) error
• type ScheduledTaskQueryRepo
  • func NewScheduledTaskQueryRepo(persistentDbSvc *internalDbInfra.PersistentDatabaseService) *ScheduledTaskQueryRepo
  • func (repo *ScheduledTaskQueryRepo) Read(readDto dto.ReadScheduledTasksRequest) (responseDto dto.ReadScheduledTasksResponse, err error)

Types

type ScheduledTaskCmdRepo

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

func NewScheduledTaskCmdRepo

func NewScheduledTaskCmdRepo(
	persistentDbSvc *internalDbInfra.PersistentDatabaseService,
) *ScheduledTaskCmdRepo

func (*ScheduledTaskCmdRepo) Create

func (repo *ScheduledTaskCmdRepo) Create(
	createDto dto.CreateScheduledTask,
) error

func (*ScheduledTaskCmdRepo) Delete

func (repo *ScheduledTaskCmdRepo) Delete(id valueObject.ScheduledTaskId) error

func (*ScheduledTaskCmdRepo) Run

func (repo *ScheduledTaskCmdRepo) Run(
	pendingTask entity.ScheduledTask,
) error

func (*ScheduledTaskCmdRepo) Update

func (repo *ScheduledTaskCmdRepo) Update(
	updateDto dto.UpdateScheduledTask,
) error

type ScheduledTaskQueryRepo

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

func NewScheduledTaskQueryRepo

func NewScheduledTaskQueryRepo(
	persistentDbSvc *internalDbInfra.PersistentDatabaseService,
) *ScheduledTaskQueryRepo

func (*ScheduledTaskQueryRepo) Read

func (repo *ScheduledTaskQueryRepo) Read(
	readDto dto.ReadScheduledTasksRequest,
) (responseDto dto.ReadScheduledTasksResponse, err error)