test

Documentation

Index

• type GenericTask
• type TaskStatus
• type TestTask
  • func CreateTestTask(te *TestTaskExecutor) *TestTask
  • func (task *TestTask) GetTaskID() string
  • func (task *TestTask) RunTask(t *testing.T) error
  • func (task *TestTask) WithTaskTime(d time.Duration) *TestTask
• type TestTaskExecutor
  • func NewTaskExecutor(t *testing.T) *TestTaskExecutor
  • func (te *TestTaskExecutor) AllExecutionTimeStamps(taskID string) []time.Time
  • func (te *TestTaskExecutor) AssertAllTasksExecutedAtleastOnce() bool
  • func (te *TestTaskExecutor) AssertAllTasksExecutedExactlyOnce() bool
  • func (te *TestTaskExecutor) CheckTaskExecutionCount(expected int) bool
  • func (te *TestTaskExecutor) Execute(t interface{}) error
  • func (te *TestTaskExecutor) GetExecutionCount(taskID string) int
  • func (te *TestTaskExecutor) GetTaskCreatedAt(taskID string) time.Time
  • func (te *TestTaskExecutor) GetTaskExecutedAt(taskID string) time.Time
  • func (te *TestTaskExecutor) GetTaskExecutionCount() int64
  • func (te *TestTaskExecutor) InitTask(taskID string)
  • func (te *TestTaskExecutor) PrintStatus()
  • func (te *TestTaskExecutor) TaskCount() int

Types

type GenericTask

type GenericTask interface {
	GetTaskID() string
	RunTask(t *testing.T) error
}

type TaskStatus

type TaskStatus struct {
	TimesCalled int
	CreatedAt   time.Time
	ExecutedAt  []time.Time
}

type TestTask

type TestTask struct {
	TaskTime time.Duration
	TaskID   string
}

func CreateTestTask

func CreateTestTask(te *TestTaskExecutor) *TestTask

func (*TestTask) GetTaskID

func (task *TestTask) GetTaskID() string

func (*TestTask) RunTask

func (task *TestTask) RunTask(t *testing.T) error

func (*TestTask) WithTaskTime

func (task *TestTask) WithTaskTime(d time.Duration) *TestTask

type TestTaskExecutor

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

func NewTaskExecutor

func NewTaskExecutor(t *testing.T) *TestTaskExecutor

func (*TestTaskExecutor) AllExecutionTimeStamps

func (te *TestTaskExecutor) AllExecutionTimeStamps(taskID string) []time.Time

func (*TestTaskExecutor) AssertAllTasksExecutedAtleastOnce

func (te *TestTaskExecutor) AssertAllTasksExecutedAtleastOnce() bool

func (*TestTaskExecutor) AssertAllTasksExecutedExactlyOnce

func (te *TestTaskExecutor) AssertAllTasksExecutedExactlyOnce() bool

func (*TestTaskExecutor) CheckTaskExecutionCount

func (te *TestTaskExecutor) CheckTaskExecutionCount(expected int) bool

func (*TestTaskExecutor) Execute

func (te *TestTaskExecutor) Execute(t interface{}) error

func (*TestTaskExecutor) GetExecutionCount

func (te *TestTaskExecutor) GetExecutionCount(taskID string) int

func (*TestTaskExecutor) GetTaskCreatedAt

func (te *TestTaskExecutor) GetTaskCreatedAt(taskID string) time.Time

func (*TestTaskExecutor) GetTaskExecutedAt

func (te *TestTaskExecutor) GetTaskExecutedAt(taskID string) time.Time

func (*TestTaskExecutor) GetTaskExecutionCount

func (te *TestTaskExecutor) GetTaskExecutionCount() int64

func (*TestTaskExecutor) InitTask

func (te *TestTaskExecutor) InitTask(taskID string)

func (*TestTaskExecutor) PrintStatus

func (te *TestTaskExecutor) PrintStatus()

func (*TestTaskExecutor) TaskCount

func (te *TestTaskExecutor) TaskCount() int