dao

Documentation

Overview

Package dao is a generated GoMock package.

Package dao is a generated GoMock package.

Index

• func ConvertTime(rawTime sql.RawBytes) (time.Time, error)
• type MockTaskDao
  • func NewMockTaskDao(ctrl *gomock.Controller) *MockTaskDao
  • func (m *MockTaskDao) EXPECT() *MockTaskDaoMockRecorder
  • func (m *MockTaskDao) GetTaskById(id *string, tx *sql.Tx) (*model.TaskDTO, error)
  • func (m *MockTaskDao) GetTasksByIds(ids *[]string, tx *sql.Tx) (*[]*model.TaskDTO, error)
  • func (m *MockTaskDao) SaveTask(task *model.TaskDTO, tx *sql.Tx) error
• type MockTaskDaoMockRecorder
  • func (mr *MockTaskDaoMockRecorder) GetTaskById(id, tx interface{}) *gomock.Call
  • func (mr *MockTaskDaoMockRecorder) GetTasksByIds(ids, tx interface{}) *gomock.Call
  • func (mr *MockTaskDaoMockRecorder) SaveTask(task, tx interface{}) *gomock.Call
• type MockTaskHistoryDao
  • func NewMockTaskHistoryDao(ctrl *gomock.Controller) *MockTaskHistoryDao
  • func (m *MockTaskHistoryDao) EXPECT() *MockTaskHistoryDaoMockRecorder
  • func (m *MockTaskHistoryDao) GetTaskById(id *string, tx *sql.Tx) (*model.TaskHistoryDTO, error)
  • func (m *MockTaskHistoryDao) GetTaskHistory(id *string, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)
  • func (m *MockTaskHistoryDao) GetTasksByStatus(status *data.TaskStatus, offset, limit *int, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)
  • func (m *MockTaskHistoryDao) SaveTaskEntry(entry *model.TaskHistoryDTO, tx *sql.Tx) error
• type MockTaskHistoryDaoMockRecorder
  • func (mr *MockTaskHistoryDaoMockRecorder) GetTaskById(id, tx interface{}) *gomock.Call
  • func (mr *MockTaskHistoryDaoMockRecorder) GetTaskHistory(id, tx interface{}) *gomock.Call
  • func (mr *MockTaskHistoryDaoMockRecorder) GetTasksByStatus(status, offset, limit, tx interface{}) *gomock.Call
  • func (mr *MockTaskHistoryDaoMockRecorder) SaveTaskEntry(entry, tx interface{}) *gomock.Call
• type TaskDao
• type TaskDaoImpl
  • func NewTaskDao() *TaskDaoImpl
  • func (dao *TaskDaoImpl) GetTaskById(id *string, tx *sql.Tx) (*model.TaskDTO, error)
  • func (dao *TaskDaoImpl) GetTasksByIds(ids *[]string, tx *sql.Tx) (*[]*model.TaskDTO, error)
  • func (dao *TaskDaoImpl) SaveTask(task *model.TaskDTO, tx *sql.Tx) error
• type TaskHistoryDao
• type TaskHistoryDaoImpl
  • func NewTaskHistoryDao() *TaskHistoryDaoImpl
  • func (dao *TaskHistoryDaoImpl) GetTaskById(id *string, tx *sql.Tx) (*model.TaskHistoryDTO, error)
  • func (dao *TaskHistoryDaoImpl) GetTaskHistory(id *string, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)
  • func (dao *TaskHistoryDaoImpl) GetTasksByStatus(status *data.TaskStatus, offset *int, limit *int, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)
  • func (dao *TaskHistoryDaoImpl) SaveTaskEntry(entry *model.TaskHistoryDTO, tx *sql.Tx) error

Functions

func ConvertTime

func ConvertTime(rawTime sql.RawBytes) (time.Time, error)

Types

type MockTaskDao

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

MockTaskDao is a mock of TaskDao interface.

func NewMockTaskDao

func NewMockTaskDao(ctrl *gomock.Controller) *MockTaskDao

NewMockTaskDao creates a new mock instance.

func (*MockTaskDao) EXPECT

func (m *MockTaskDao) EXPECT() *MockTaskDaoMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTaskDao) GetTaskById

func (m *MockTaskDao) GetTaskById(id *string, tx *sql.Tx) (*model.TaskDTO, error)

GetTaskById mocks base method.

func (*MockTaskDao) GetTasksByIds

func (m *MockTaskDao) GetTasksByIds(ids *[]string, tx *sql.Tx) (*[]*model.TaskDTO, error)

GetTasksByIds mocks base method.

func (*MockTaskDao) SaveTask

func (m *MockTaskDao) SaveTask(task *model.TaskDTO, tx *sql.Tx) error

SaveTask mocks base method.

type MockTaskDaoMockRecorder

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

MockTaskDaoMockRecorder is the mock recorder for MockTaskDao.

func (*MockTaskDaoMockRecorder) GetTaskById

func (mr *MockTaskDaoMockRecorder) GetTaskById(id, tx interface{}) *gomock.Call

GetTaskById indicates an expected call of GetTaskById.

func (*MockTaskDaoMockRecorder) GetTasksByIds

func (mr *MockTaskDaoMockRecorder) GetTasksByIds(ids, tx interface{}) *gomock.Call

GetTasksByIds indicates an expected call of GetTasksByIds.

func (*MockTaskDaoMockRecorder) SaveTask

func (mr *MockTaskDaoMockRecorder) SaveTask(task, tx interface{}) *gomock.Call

SaveTask indicates an expected call of SaveTask.

type MockTaskHistoryDao

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

MockTaskHistoryDao is a mock of TaskHistoryDao interface.

func NewMockTaskHistoryDao

func NewMockTaskHistoryDao(ctrl *gomock.Controller) *MockTaskHistoryDao

NewMockTaskHistoryDao creates a new mock instance.

func (*MockTaskHistoryDao) EXPECT

func (m *MockTaskHistoryDao) EXPECT() *MockTaskHistoryDaoMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTaskHistoryDao) GetTaskById

func (m *MockTaskHistoryDao) GetTaskById(id *string, tx *sql.Tx) (*model.TaskHistoryDTO, error)

GetTaskById mocks base method.

func (*MockTaskHistoryDao) GetTaskHistory

func (m *MockTaskHistoryDao) GetTaskHistory(id *string, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)

GetTaskHistory mocks base method.

func (*MockTaskHistoryDao) GetTasksByStatus

func (m *MockTaskHistoryDao) GetTasksByStatus(status *data.TaskStatus, offset, limit *int, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)

GetTasksByStatus mocks base method.

func (*MockTaskHistoryDao) SaveTaskEntry

func (m *MockTaskHistoryDao) SaveTaskEntry(entry *model.TaskHistoryDTO, tx *sql.Tx) error

SaveTaskEntry mocks base method.

type MockTaskHistoryDaoMockRecorder

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

MockTaskHistoryDaoMockRecorder is the mock recorder for MockTaskHistoryDao.

func (*MockTaskHistoryDaoMockRecorder) GetTaskById

func (mr *MockTaskHistoryDaoMockRecorder) GetTaskById(id, tx interface{}) *gomock.Call

GetTaskById indicates an expected call of GetTaskById.

func (*MockTaskHistoryDaoMockRecorder) GetTaskHistory

func (mr *MockTaskHistoryDaoMockRecorder) GetTaskHistory(id, tx interface{}) *gomock.Call

GetTaskHistory indicates an expected call of GetTaskHistory.

func (*MockTaskHistoryDaoMockRecorder) GetTasksByStatus

func (mr *MockTaskHistoryDaoMockRecorder) GetTasksByStatus(status, offset, limit, tx interface{}) *gomock.Call

GetTasksByStatus indicates an expected call of GetTasksByStatus.

func (*MockTaskHistoryDaoMockRecorder) SaveTaskEntry

func (mr *MockTaskHistoryDaoMockRecorder) SaveTaskEntry(entry, tx interface{}) *gomock.Call

SaveTaskEntry indicates an expected call of SaveTaskEntry.

type TaskDao

type TaskDao interface {
	SaveTask(task *model.TaskDTO, tx *sql.Tx) error

	GetTaskById(id *string, tx *sql.Tx) (*model.TaskDTO, error)

	GetTasksByIds(ids *[]string, tx *sql.Tx) (*[]*model.TaskDTO, error)
}

type TaskDaoImpl

type TaskDaoImpl struct {
}

func NewTaskDao

func NewTaskDao() *TaskDaoImpl

func (*TaskDaoImpl) GetTaskById

func (dao *TaskDaoImpl) GetTaskById(id *string, tx *sql.Tx) (*model.TaskDTO, error)

func (*TaskDaoImpl) GetTasksByIds

func (dao *TaskDaoImpl) GetTasksByIds(ids *[]string, tx *sql.Tx) (*[]*model.TaskDTO, error)

func (*TaskDaoImpl) SaveTask

func (dao *TaskDaoImpl) SaveTask(task *model.TaskDTO, tx *sql.Tx) error

type TaskHistoryDao

type TaskHistoryDao interface {
	SaveTaskEntry(entry *model.TaskHistoryDTO, tx *sql.Tx) error

	GetTaskById(id *string, tx *sql.Tx) (*model.TaskHistoryDTO, error)
	GetTasksByStatus(status *data.TaskStatus, offset *int, limit *int, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)
	GetTaskHistory(id *string, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)
}

type TaskHistoryDaoImpl

type TaskHistoryDaoImpl struct {
}

func NewTaskHistoryDao

func NewTaskHistoryDao() *TaskHistoryDaoImpl

func (*TaskHistoryDaoImpl) GetTaskById

func (dao *TaskHistoryDaoImpl) GetTaskById(id *string, tx *sql.Tx) (*model.TaskHistoryDTO, error)

get latest status

func (*TaskHistoryDaoImpl) GetTaskHistory

func (dao *TaskHistoryDaoImpl) GetTaskHistory(id *string, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)

func (*TaskHistoryDaoImpl) GetTasksByStatus

func (dao *TaskHistoryDaoImpl) GetTasksByStatus(status *data.TaskStatus,
	offset *int, limit *int, tx *sql.Tx) (*[]*model.TaskHistoryDTO, error)

func (*TaskHistoryDaoImpl) SaveTaskEntry

func (dao *TaskHistoryDaoImpl) SaveTaskEntry(entry *model.TaskHistoryDTO, tx *sql.Tx) error