mock

package

v2.7.6 Latest Latest Go to latest Published: Apr 12, 2024 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/influxdata/influxdb

Links

Open Source Insights

Documentation ¶

Overview ¶

Package mock contains mock implementations of different task interfaces.

Index ¶

type Executor
- func NewExecutor() *Executor
type TaskControlService
- func NewTaskControlService() *TaskControlService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Executor ¶

type Executor struct {
	ExecutedChan chan scheduler.ID
	// contains filtered or unexported fields
}

func NewExecutor ¶

func NewExecutor() *Executor

func (*Executor) Cancel ¶

func (e *Executor) Cancel(context.Context, platform.ID) error

func (*Executor) Execute ¶

func (e *Executor) Execute(ctx context.Context, id scheduler.ID, scheduledAt time.Time, runAt time.Time) error

func (*Executor) FailNextCallToExecute ¶

func (e *Executor) FailNextCallToExecute(err error)

FailNextCallToExecute causes the next call to e.Execute to unconditionally return err.

func (*Executor) ManualRun ¶

func (e *Executor) ManualRun(ctx context.Context, id platform.ID, runID platform.ID) (executor.Promise, error)

func (*Executor) ScheduleManualRun ¶ added in v2.5.0

func (e *Executor) ScheduleManualRun(ctx context.Context, id platform.ID, runID platform.ID) error

func (*Executor) Wait ¶

func (e *Executor) Wait()

type TaskControlService ¶

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

TaskControlService is a mock implementation of TaskControlService (used by NewScheduler).

func NewTaskControlService ¶

func NewTaskControlService() *TaskControlService

func (*TaskControlService) AddRunLog ¶

func (d *TaskControlService) AddRunLog(ctx context.Context, taskID, runID platform.ID, when time.Time, log string) error

AddRunLog adds a log line to the run.

func (*TaskControlService) CreateRun ¶

func (t *TaskControlService) CreateRun(_ context.Context, taskID platform.ID, scheduledFor time.Time, runAt time.Time) (*taskmodel.Run, error)

func (*TaskControlService) CreatedFor ¶

func (d *TaskControlService) CreatedFor(taskID platform.ID) []*taskmodel.Run

func (*TaskControlService) CurrentlyRunning ¶

func (t *TaskControlService) CurrentlyRunning(ctx context.Context, taskID platform.ID) ([]*taskmodel.Run, error)

func (*TaskControlService) FinishRun ¶

func (d *TaskControlService) FinishRun(_ context.Context, taskID, runID platform.ID) (*taskmodel.Run, error)

func (*TaskControlService) FinishedRun ¶

func (d *TaskControlService) FinishedRun(runID platform.ID) *taskmodel.Run

func (*TaskControlService) FinishedRuns ¶

func (d *TaskControlService) FinishedRuns() []*taskmodel.Run

func (*TaskControlService) ManualRuns ¶

func (t *TaskControlService) ManualRuns(ctx context.Context, taskID platform.ID) ([]*taskmodel.Run, error)

func (*TaskControlService) PollForNumberCreated ¶

func (d *TaskControlService) PollForNumberCreated(taskID platform.ID, count int) ([]*taskmodel.Run, error)

PollForNumberCreated blocks for a small amount of time waiting for exactly the given count of created and unfinished runs for the given task ID. If the expected number isn't found in time, it returns an error.

Because the scheduler and executor do a lot of state changes asynchronously, this is useful in test.

func (*TaskControlService) SetManualRuns ¶

func (d *TaskControlService) SetManualRuns(runs []*taskmodel.Run)

func (*TaskControlService) SetTask ¶

func (d *TaskControlService) SetTask(task *taskmodel.Task)

SetTask sets the task. SetTask must be called before CreateNextRun, for a given task ID.

func (*TaskControlService) StartManualRun ¶

func (t *TaskControlService) StartManualRun(_ context.Context, taskID, runID platform.ID) (*taskmodel.Run, error)

func (*TaskControlService) TotalRunsCreatedForTask ¶

func (d *TaskControlService) TotalRunsCreatedForTask(taskID platform.ID) int

TotalRunsCreatedForTask returns the number of runs created for taskID.

func (*TaskControlService) UpdateRunState ¶

func (d *TaskControlService) UpdateRunState(ctx context.Context, taskID, runID platform.ID, when time.Time, state taskmodel.RunStatus) error

UpdateRunState sets the run state at the respective time.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL