Documentation ¶
Index ¶
- type AgentMock
- type ConnectionMock
- type ContractMapperMock
- func (m *ContractMapperMock) MapDTOToCommon(d *dto.ContractDTO) *common.Contract
- func (m *ContractMapperMock) MapDTOToEntity(d *dto.ContractDTO) *entities.Contract
- func (m *ContractMapperMock) MapEntityToDTO(c *entities.Contract) *dto.ContractDTO
- func (m *ContractMapperMock) MapNewDTOToEntity(d *dto.NewContractDTO) *entities.Contract
- func (m *ContractMapperMock) MapNewWithIdDTOToEntity(d *dto.NewContractWithIdDTO) *entities.Contract
- type ContractRepoMock
- func (m *ContractRepoMock) Create(tx *gorm.DB, contract *entities.Contract) error
- func (m *ContractRepoMock) Find(tx *gorm.DB, id string) (*entities.Contract, error)
- func (m *ContractRepoMock) FindAll(tx *gorm.DB) ([]entities.Contract, error)
- func (m *ContractRepoMock) FindByTaskId(tx *gorm.DB, taskId string) (*entities.Contract, error)
- func (m *ContractRepoMock) Update(tx *gorm.DB, contract *entities.Contract) error
- type DeployerMock
- type EventBusMock
- type HTTPClientMock
- type TaskFinishTopicMock
- type TaskInputRequestTopicMock
- type TaskServiceMock
- func (m *TaskServiceMock) Create(task *dto.NewTaskDTO) (*dto.TaskDTO, error)
- func (m *TaskServiceMock) FindNotFinishedAndExpired() ([]*dto.TaskDTO, error)
- func (m *TaskServiceMock) FindNotFinishedAndHaveDeployedContract() ([]*dto.TaskDTO, error)
- func (m *TaskServiceMock) FindNotFinishedTasksThatDontHaveIncompletedTransactions() ([]*dto.TaskDTO, error)
- func (m *TaskServiceMock) FindNotFinishedThatHaveDeployedContractAndLimitedPendingTransactions(limit int) ([]*dto.TaskDTO, error)
- func (m *TaskServiceMock) Get(taskId string) (*dto.TaskDTO, error)
- func (m *TaskServiceMock) Update(task *dto.TaskDTO) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnectionMock ¶
func (*ConnectionMock) Clean ¶
func (m *ConnectionMock) Clean() error
func (*ConnectionMock) GetDB ¶
func (m *ConnectionMock) GetDB() *gorm.DB
func (*ConnectionMock) Migrate ¶
func (m *ConnectionMock) Migrate() error
type ContractMapperMock ¶
func (*ContractMapperMock) MapDTOToCommon ¶
func (m *ContractMapperMock) MapDTOToCommon(d *dto.ContractDTO) *common.Contract
func (*ContractMapperMock) MapDTOToEntity ¶
func (m *ContractMapperMock) MapDTOToEntity(d *dto.ContractDTO) *entities.Contract
func (*ContractMapperMock) MapEntityToDTO ¶
func (m *ContractMapperMock) MapEntityToDTO(c *entities.Contract) *dto.ContractDTO
func (*ContractMapperMock) MapNewDTOToEntity ¶
func (m *ContractMapperMock) MapNewDTOToEntity(d *dto.NewContractDTO) *entities.Contract
func (*ContractMapperMock) MapNewWithIdDTOToEntity ¶
func (m *ContractMapperMock) MapNewWithIdDTOToEntity(d *dto.NewContractWithIdDTO) *entities.Contract
type ContractRepoMock ¶
func (*ContractRepoMock) FindByTaskId ¶
type DeployerMock ¶
type EventBusMock ¶
func (*EventBusMock) Publish ¶
func (m *EventBusMock) Publish(topic string, args ...interface{})
func (*EventBusMock) Subscribe ¶
func (m *EventBusMock) Subscribe(topic string, fn interface{})
func (*EventBusMock) SubscribeOnce ¶
func (m *EventBusMock) SubscribeOnce(topic string, fn interface{})
func (*EventBusMock) Unsubscribe ¶
func (m *EventBusMock) Unsubscribe(topic string, fn interface{})
type HTTPClientMock ¶
type TaskFinishTopicMock ¶
func (*TaskFinishTopicMock) Publish ¶
func (m *TaskFinishTopicMock) Publish(e bus.TaskFinishEvent)
func (*TaskFinishTopicMock) Subscribe ¶
func (m *TaskFinishTopicMock) Subscribe(fn interface{})
func (*TaskFinishTopicMock) Unsubscribe ¶
func (m *TaskFinishTopicMock) Unsubscribe(fn interface{})
type TaskInputRequestTopicMock ¶
func (*TaskInputRequestTopicMock) Publish ¶
func (m *TaskInputRequestTopicMock) Publish(e bus.TaskInputRequestEvent)
func (*TaskInputRequestTopicMock) Subscribe ¶
func (m *TaskInputRequestTopicMock) Subscribe(fn interface{})
func (*TaskInputRequestTopicMock) Unsubscribe ¶
func (m *TaskInputRequestTopicMock) Unsubscribe(fn interface{})
type TaskServiceMock ¶
func (*TaskServiceMock) Create ¶
func (m *TaskServiceMock) Create(task *dto.NewTaskDTO) (*dto.TaskDTO, error)
func (*TaskServiceMock) FindNotFinishedAndExpired ¶
func (m *TaskServiceMock) FindNotFinishedAndExpired() ([]*dto.TaskDTO, error)
func (*TaskServiceMock) FindNotFinishedAndHaveDeployedContract ¶
func (m *TaskServiceMock) FindNotFinishedAndHaveDeployedContract() ([]*dto.TaskDTO, error)
func (*TaskServiceMock) FindNotFinishedTasksThatDontHaveIncompletedTransactions ¶
func (m *TaskServiceMock) FindNotFinishedTasksThatDontHaveIncompletedTransactions() ([]*dto.TaskDTO, error)
func (*TaskServiceMock) FindNotFinishedThatHaveDeployedContractAndLimitedPendingTransactions ¶
func (m *TaskServiceMock) FindNotFinishedThatHaveDeployedContractAndLimitedPendingTransactions(limit int) ([]*dto.TaskDTO, error)
Click to show internal directories.
Click to hide internal directories.