mocks

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 21, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockService 

type MockService struct {
	mock.Mock
}

MockService is an autogenerated mock type for the Service type

func NewMockService 

func NewMockService(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockService

NewMockService creates a new instance of MockService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockService) ConfigureExperiment 

func (_mock *MockService) ConfigureExperiment(ctx context.Context, config manager.ExperimentConfig) error

ConfigureExperiment provides a mock function for the type MockService

func (*MockService) CreateJob 

func (_mock *MockService) CreateJob(ctx context.Context, name string, tasks []task.Task, executionMode string) (string, []task.Task, error)

CreateJob provides a mock function for the type MockService

func (*MockService) CreateTask 

func (_mock *MockService) CreateTask(ctx context.Context, task1 task.Task) (task.Task, error)

CreateTask provides a mock function for the type MockService

func (*MockService) CreateWorkflow 

func (_mock *MockService) CreateWorkflow(ctx context.Context, tasks []task.Task) ([]task.Task, error)

CreateWorkflow provides a mock function for the type MockService

func (*MockService) DeleteProplet 

func (_mock *MockService) DeleteProplet(ctx context.Context, propletID string) error

DeleteProplet provides a mock function for the type MockService

func (*MockService) DeleteTask 

func (_mock *MockService) DeleteTask(ctx context.Context, taskID string) error

DeleteTask provides a mock function for the type MockService

func (*MockService) EXPECT 

func (_m *MockService) EXPECT() *MockService_Expecter

func (*MockService) GetFLTask 

func (_mock *MockService) GetFLTask(ctx context.Context, roundID string, propletID string) (manager.FLTask, error)

GetFLTask provides a mock function for the type MockService

func (*MockService) GetJob 

func (_mock *MockService) GetJob(ctx context.Context, jobID string) ([]task.Task, error)

GetJob provides a mock function for the type MockService

func (*MockService) GetParentResults 

func (_mock *MockService) GetParentResults(ctx context.Context, taskID string) (map[string]any, error)

GetParentResults provides a mock function for the type MockService

func (*MockService) GetProplet 

func (_mock *MockService) GetProplet(ctx context.Context, propletID string) (proplet.Proplet, error)

GetProplet provides a mock function for the type MockService

func (*MockService) GetPropletMetrics 

func (_mock *MockService) GetPropletMetrics(ctx context.Context, propletID string, offset uint64, limit uint64) (manager.PropletMetricsPage, error)

GetPropletMetrics provides a mock function for the type MockService

func (*MockService) GetRoundStatus 

func (_mock *MockService) GetRoundStatus(ctx context.Context, roundID string) (manager.RoundStatus, error)

GetRoundStatus provides a mock function for the type MockService

func (*MockService) GetTask 

func (_mock *MockService) GetTask(ctx context.Context, taskID string) (task.Task, error)

GetTask provides a mock function for the type MockService

func (*MockService) GetTaskMetrics 

func (_mock *MockService) GetTaskMetrics(ctx context.Context, taskID string, offset uint64, limit uint64) (manager.TaskMetricsPage, error)

GetTaskMetrics provides a mock function for the type MockService

func (*MockService) GetTaskResults 

func (_mock *MockService) GetTaskResults(ctx context.Context, taskID string) (any, error)

GetTaskResults provides a mock function for the type MockService

func (*MockService) ListJobs 

func (_mock *MockService) ListJobs(ctx context.Context, offset uint64, limit uint64) (manager.JobPage, error)

ListJobs provides a mock function for the type MockService

func (*MockService) ListProplets 

func (_mock *MockService) ListProplets(ctx context.Context, offset uint64, limit uint64) (proplet.PropletPage, error)

ListProplets provides a mock function for the type MockService

func (*MockService) ListTasks 

func (_mock *MockService) ListTasks(ctx context.Context, offset uint64, limit uint64) (task.TaskPage, error)

ListTasks provides a mock function for the type MockService

func (*MockService) PostFLUpdate 

func (_mock *MockService) PostFLUpdate(ctx context.Context, update manager.FLUpdate) error

PostFLUpdate provides a mock function for the type MockService

func (*MockService) PostFLUpdateCBOR 

func (_mock *MockService) PostFLUpdateCBOR(ctx context.Context, updateData []byte) error

PostFLUpdateCBOR provides a mock function for the type MockService

func (*MockService) RecoverInterruptedTasks 

func (_mock *MockService) RecoverInterruptedTasks(ctx context.Context) error

RecoverInterruptedTasks provides a mock function for the type MockService

func (*MockService) SelectProplet 

func (_mock *MockService) SelectProplet(ctx context.Context, task1 task.Task) (proplet.Proplet, error)

SelectProplet provides a mock function for the type MockService

func (*MockService) Shutdown 

func (_mock *MockService) Shutdown(ctx context.Context) error

Shutdown provides a mock function for the type MockService

func (*MockService) StartJob 

func (_mock *MockService) StartJob(ctx context.Context, jobID string) error

StartJob provides a mock function for the type MockService

func (*MockService) StartTask 

func (_mock *MockService) StartTask(ctx context.Context, taskID string) error

StartTask provides a mock function for the type MockService

func (*MockService) StopJob 

func (_mock *MockService) StopJob(ctx context.Context, jobID string) error

StopJob provides a mock function for the type MockService

func (*MockService) StopTask 

func (_mock *MockService) StopTask(ctx context.Context, taskID string) error

StopTask provides a mock function for the type MockService

func (*MockService) Subscribe 

func (_mock *MockService) Subscribe(ctx context.Context) error

Subscribe provides a mock function for the type MockService

func (*MockService) UpdateTask 

func (_mock *MockService) UpdateTask(ctx context.Context, task1 task.Task) (task.Task, error)

UpdateTask provides a mock function for the type MockService

type MockService_ConfigureExperiment_Call 

type MockService_ConfigureExperiment_Call struct {
	*mock.Call
}

MockService_ConfigureExperiment_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConfigureExperiment'

func (*MockService_ConfigureExperiment_Call) Return 

func (_c *MockService_ConfigureExperiment_Call) Return(err error) *MockService_ConfigureExperiment_Call

func (*MockService_ConfigureExperiment_Call) Run 

func (_c *MockService_ConfigureExperiment_Call) Run(run func(ctx context.Context, config manager.ExperimentConfig)) *MockService_ConfigureExperiment_Call

func (*MockService_ConfigureExperiment_Call) RunAndReturn 

func (_c *MockService_ConfigureExperiment_Call) RunAndReturn(run func(ctx context.Context, config manager.ExperimentConfig) error) *MockService_ConfigureExperiment_Call

type MockService_CreateJob_Call 

type MockService_CreateJob_Call struct {
	*mock.Call
}

MockService_CreateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJob'

func (*MockService_CreateJob_Call) Return 

func (_c *MockService_CreateJob_Call) Return(s string, tasks1 []task.Task, err error) *MockService_CreateJob_Call

func (*MockService_CreateJob_Call) Run 

func (_c *MockService_CreateJob_Call) Run(run func(ctx context.Context, name string, tasks []task.Task, executionMode string)) *MockService_CreateJob_Call

func (*MockService_CreateJob_Call) RunAndReturn 

func (_c *MockService_CreateJob_Call) RunAndReturn(run func(ctx context.Context, name string, tasks []task.Task, executionMode string) (string, []task.Task, error)) *MockService_CreateJob_Call

type MockService_CreateTask_Call 

type MockService_CreateTask_Call struct {
	*mock.Call
}

MockService_CreateTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTask'

func (*MockService_CreateTask_Call) Return 

func (_c *MockService_CreateTask_Call) Return(task11 task.Task, err error) *MockService_CreateTask_Call

func (*MockService_CreateTask_Call) Run 

func (_c *MockService_CreateTask_Call) Run(run func(ctx context.Context, task1 task.Task)) *MockService_CreateTask_Call

func (*MockService_CreateTask_Call) RunAndReturn 

func (_c *MockService_CreateTask_Call) RunAndReturn(run func(ctx context.Context, task1 task.Task) (task.Task, error)) *MockService_CreateTask_Call

type MockService_CreateWorkflow_Call 

type MockService_CreateWorkflow_Call struct {
	*mock.Call
}

MockService_CreateWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateWorkflow'

func (*MockService_CreateWorkflow_Call) Return 

func (_c *MockService_CreateWorkflow_Call) Return(tasks1 []task.Task, err error) *MockService_CreateWorkflow_Call

func (*MockService_CreateWorkflow_Call) Run 

func (_c *MockService_CreateWorkflow_Call) Run(run func(ctx context.Context, tasks []task.Task)) *MockService_CreateWorkflow_Call

func (*MockService_CreateWorkflow_Call) RunAndReturn 

func (_c *MockService_CreateWorkflow_Call) RunAndReturn(run func(ctx context.Context, tasks []task.Task) ([]task.Task, error)) *MockService_CreateWorkflow_Call

type MockService_DeleteProplet_Call 

type MockService_DeleteProplet_Call struct {
	*mock.Call
}

MockService_DeleteProplet_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteProplet'

func (*MockService_DeleteProplet_Call) Return 

func (_c *MockService_DeleteProplet_Call) Return(err error) *MockService_DeleteProplet_Call

func (*MockService_DeleteProplet_Call) Run 

func (_c *MockService_DeleteProplet_Call) Run(run func(ctx context.Context, propletID string)) *MockService_DeleteProplet_Call

func (*MockService_DeleteProplet_Call) RunAndReturn 

func (_c *MockService_DeleteProplet_Call) RunAndReturn(run func(ctx context.Context, propletID string) error) *MockService_DeleteProplet_Call

type MockService_DeleteTask_Call 

type MockService_DeleteTask_Call struct {
	*mock.Call
}

MockService_DeleteTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteTask'

func (*MockService_DeleteTask_Call) Return 

func (_c *MockService_DeleteTask_Call) Return(err error) *MockService_DeleteTask_Call

func (*MockService_DeleteTask_Call) Run 

func (_c *MockService_DeleteTask_Call) Run(run func(ctx context.Context, taskID string)) *MockService_DeleteTask_Call

func (*MockService_DeleteTask_Call) RunAndReturn 

func (_c *MockService_DeleteTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *MockService_DeleteTask_Call

type MockService_Expecter 

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

func (*MockService_Expecter) ConfigureExperiment 

func (_e *MockService_Expecter) ConfigureExperiment(ctx interface{}, config interface{}) *MockService_ConfigureExperiment_Call

ConfigureExperiment is a helper method to define mock.On call

  • ctx context.Context
  • config manager.ExperimentConfig

func (*MockService_Expecter) CreateJob 

func (_e *MockService_Expecter) CreateJob(ctx interface{}, name interface{}, tasks interface{}, executionMode interface{}) *MockService_CreateJob_Call

CreateJob is a helper method to define mock.On call

  • ctx context.Context
  • name string
  • tasks []task.Task
  • executionMode string

func (*MockService_Expecter) CreateTask 

func (_e *MockService_Expecter) CreateTask(ctx interface{}, task1 interface{}) *MockService_CreateTask_Call

CreateTask is a helper method to define mock.On call

  • ctx context.Context
  • task1 task.Task

func (*MockService_Expecter) CreateWorkflow 

func (_e *MockService_Expecter) CreateWorkflow(ctx interface{}, tasks interface{}) *MockService_CreateWorkflow_Call

CreateWorkflow is a helper method to define mock.On call

  • ctx context.Context
  • tasks []task.Task

func (*MockService_Expecter) DeleteProplet 

func (_e *MockService_Expecter) DeleteProplet(ctx interface{}, propletID interface{}) *MockService_DeleteProplet_Call

DeleteProplet is a helper method to define mock.On call

  • ctx context.Context
  • propletID string

func (*MockService_Expecter) DeleteTask 

func (_e *MockService_Expecter) DeleteTask(ctx interface{}, taskID interface{}) *MockService_DeleteTask_Call

DeleteTask is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*MockService_Expecter) GetFLTask 

func (_e *MockService_Expecter) GetFLTask(ctx interface{}, roundID interface{}, propletID interface{}) *MockService_GetFLTask_Call

GetFLTask is a helper method to define mock.On call

  • ctx context.Context
  • roundID string
  • propletID string

func (*MockService_Expecter) GetJob 

func (_e *MockService_Expecter) GetJob(ctx interface{}, jobID interface{}) *MockService_GetJob_Call

GetJob is a helper method to define mock.On call

  • ctx context.Context
  • jobID string

func (*MockService_Expecter) GetParentResults 

func (_e *MockService_Expecter) GetParentResults(ctx interface{}, taskID interface{}) *MockService_GetParentResults_Call

GetParentResults is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*MockService_Expecter) GetProplet 

func (_e *MockService_Expecter) GetProplet(ctx interface{}, propletID interface{}) *MockService_GetProplet_Call

GetProplet is a helper method to define mock.On call

  • ctx context.Context
  • propletID string

func (*MockService_Expecter) GetPropletMetrics 

func (_e *MockService_Expecter) GetPropletMetrics(ctx interface{}, propletID interface{}, offset interface{}, limit interface{}) *MockService_GetPropletMetrics_Call

GetPropletMetrics is a helper method to define mock.On call

  • ctx context.Context
  • propletID string
  • offset uint64
  • limit uint64

func (*MockService_Expecter) GetRoundStatus 

func (_e *MockService_Expecter) GetRoundStatus(ctx interface{}, roundID interface{}) *MockService_GetRoundStatus_Call

GetRoundStatus is a helper method to define mock.On call

  • ctx context.Context
  • roundID string

func (*MockService_Expecter) GetTask 

func (_e *MockService_Expecter) GetTask(ctx interface{}, taskID interface{}) *MockService_GetTask_Call

GetTask is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*MockService_Expecter) GetTaskMetrics 

func (_e *MockService_Expecter) GetTaskMetrics(ctx interface{}, taskID interface{}, offset interface{}, limit interface{}) *MockService_GetTaskMetrics_Call

GetTaskMetrics is a helper method to define mock.On call

  • ctx context.Context
  • taskID string
  • offset uint64
  • limit uint64

func (*MockService_Expecter) GetTaskResults 

func (_e *MockService_Expecter) GetTaskResults(ctx interface{}, taskID interface{}) *MockService_GetTaskResults_Call

GetTaskResults is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*MockService_Expecter) ListJobs 

func (_e *MockService_Expecter) ListJobs(ctx interface{}, offset interface{}, limit interface{}) *MockService_ListJobs_Call

ListJobs is a helper method to define mock.On call

  • ctx context.Context
  • offset uint64
  • limit uint64

func (*MockService_Expecter) ListProplets 

func (_e *MockService_Expecter) ListProplets(ctx interface{}, offset interface{}, limit interface{}) *MockService_ListProplets_Call

ListProplets is a helper method to define mock.On call

  • ctx context.Context
  • offset uint64
  • limit uint64

func (*MockService_Expecter) ListTasks 

func (_e *MockService_Expecter) ListTasks(ctx interface{}, offset interface{}, limit interface{}) *MockService_ListTasks_Call

ListTasks is a helper method to define mock.On call

  • ctx context.Context
  • offset uint64
  • limit uint64

func (*MockService_Expecter) PostFLUpdate 

func (_e *MockService_Expecter) PostFLUpdate(ctx interface{}, update interface{}) *MockService_PostFLUpdate_Call

PostFLUpdate is a helper method to define mock.On call

  • ctx context.Context
  • update manager.FLUpdate

func (*MockService_Expecter) PostFLUpdateCBOR 

func (_e *MockService_Expecter) PostFLUpdateCBOR(ctx interface{}, updateData interface{}) *MockService_PostFLUpdateCBOR_Call

PostFLUpdateCBOR is a helper method to define mock.On call

  • ctx context.Context
  • updateData []byte

func (*MockService_Expecter) RecoverInterruptedTasks 

func (_e *MockService_Expecter) RecoverInterruptedTasks(ctx interface{}) *MockService_RecoverInterruptedTasks_Call

RecoverInterruptedTasks is a helper method to define mock.On call

  • ctx context.Context

func (*MockService_Expecter) SelectProplet 

func (_e *MockService_Expecter) SelectProplet(ctx interface{}, task1 interface{}) *MockService_SelectProplet_Call

SelectProplet is a helper method to define mock.On call

  • ctx context.Context
  • task1 task.Task

func (*MockService_Expecter) Shutdown 

func (_e *MockService_Expecter) Shutdown(ctx interface{}) *MockService_Shutdown_Call

Shutdown is a helper method to define mock.On call

  • ctx context.Context

func (*MockService_Expecter) StartJob 

func (_e *MockService_Expecter) StartJob(ctx interface{}, jobID interface{}) *MockService_StartJob_Call

StartJob is a helper method to define mock.On call

  • ctx context.Context
  • jobID string

func (*MockService_Expecter) StartTask 

func (_e *MockService_Expecter) StartTask(ctx interface{}, taskID interface{}) *MockService_StartTask_Call

StartTask is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*MockService_Expecter) StopJob 

func (_e *MockService_Expecter) StopJob(ctx interface{}, jobID interface{}) *MockService_StopJob_Call

StopJob is a helper method to define mock.On call

  • ctx context.Context
  • jobID string

func (*MockService_Expecter) StopTask 

func (_e *MockService_Expecter) StopTask(ctx interface{}, taskID interface{}) *MockService_StopTask_Call

StopTask is a helper method to define mock.On call

  • ctx context.Context
  • taskID string

func (*MockService_Expecter) Subscribe 

func (_e *MockService_Expecter) Subscribe(ctx interface{}) *MockService_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • ctx context.Context

func (*MockService_Expecter) UpdateTask 

func (_e *MockService_Expecter) UpdateTask(ctx interface{}, task1 interface{}) *MockService_UpdateTask_Call

UpdateTask is a helper method to define mock.On call

  • ctx context.Context
  • task1 task.Task

type MockService_GetFLTask_Call 

type MockService_GetFLTask_Call struct {
	*mock.Call
}

MockService_GetFLTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetFLTask'

func (*MockService_GetFLTask_Call) Return 

func (_c *MockService_GetFLTask_Call) Return(fLTask manager.FLTask, err error) *MockService_GetFLTask_Call

func (*MockService_GetFLTask_Call) Run 

func (_c *MockService_GetFLTask_Call) Run(run func(ctx context.Context, roundID string, propletID string)) *MockService_GetFLTask_Call

func (*MockService_GetFLTask_Call) RunAndReturn 

func (_c *MockService_GetFLTask_Call) RunAndReturn(run func(ctx context.Context, roundID string, propletID string) (manager.FLTask, error)) *MockService_GetFLTask_Call

type MockService_GetJob_Call 

type MockService_GetJob_Call struct {
	*mock.Call
}

MockService_GetJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJob'

func (*MockService_GetJob_Call) Return 

func (_c *MockService_GetJob_Call) Return(tasks []task.Task, err error) *MockService_GetJob_Call

func (*MockService_GetJob_Call) Run 

func (_c *MockService_GetJob_Call) Run(run func(ctx context.Context, jobID string)) *MockService_GetJob_Call

func (*MockService_GetJob_Call) RunAndReturn 

func (_c *MockService_GetJob_Call) RunAndReturn(run func(ctx context.Context, jobID string) ([]task.Task, error)) *MockService_GetJob_Call

type MockService_GetParentResults_Call 

type MockService_GetParentResults_Call struct {
	*mock.Call
}

MockService_GetParentResults_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetParentResults'

func (*MockService_GetParentResults_Call) Return 

func (_c *MockService_GetParentResults_Call) Return(stringToV map[string]any, err error) *MockService_GetParentResults_Call

func (*MockService_GetParentResults_Call) Run 

func (_c *MockService_GetParentResults_Call) Run(run func(ctx context.Context, taskID string)) *MockService_GetParentResults_Call

func (*MockService_GetParentResults_Call) RunAndReturn 

func (_c *MockService_GetParentResults_Call) RunAndReturn(run func(ctx context.Context, taskID string) (map[string]any, error)) *MockService_GetParentResults_Call

type MockService_GetPropletMetrics_Call 

type MockService_GetPropletMetrics_Call struct {
	*mock.Call
}

MockService_GetPropletMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPropletMetrics'

func (*MockService_GetPropletMetrics_Call) Return 

func (_c *MockService_GetPropletMetrics_Call) Return(propletMetricsPage manager.PropletMetricsPage, err error) *MockService_GetPropletMetrics_Call

func (*MockService_GetPropletMetrics_Call) Run 

func (_c *MockService_GetPropletMetrics_Call) Run(run func(ctx context.Context, propletID string, offset uint64, limit uint64)) *MockService_GetPropletMetrics_Call

func (*MockService_GetPropletMetrics_Call) RunAndReturn 

func (_c *MockService_GetPropletMetrics_Call) RunAndReturn(run func(ctx context.Context, propletID string, offset uint64, limit uint64) (manager.PropletMetricsPage, error)) *MockService_GetPropletMetrics_Call

type MockService_GetProplet_Call 

type MockService_GetProplet_Call struct {
	*mock.Call
}

MockService_GetProplet_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetProplet'

func (*MockService_GetProplet_Call) Return 

func (_c *MockService_GetProplet_Call) Return(proplet1 proplet.Proplet, err error) *MockService_GetProplet_Call

func (*MockService_GetProplet_Call) Run 

func (_c *MockService_GetProplet_Call) Run(run func(ctx context.Context, propletID string)) *MockService_GetProplet_Call

func (*MockService_GetProplet_Call) RunAndReturn 

func (_c *MockService_GetProplet_Call) RunAndReturn(run func(ctx context.Context, propletID string) (proplet.Proplet, error)) *MockService_GetProplet_Call

type MockService_GetRoundStatus_Call 

type MockService_GetRoundStatus_Call struct {
	*mock.Call
}

MockService_GetRoundStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRoundStatus'

func (*MockService_GetRoundStatus_Call) Return 

func (_c *MockService_GetRoundStatus_Call) Return(roundStatus manager.RoundStatus, err error) *MockService_GetRoundStatus_Call

func (*MockService_GetRoundStatus_Call) Run 

func (_c *MockService_GetRoundStatus_Call) Run(run func(ctx context.Context, roundID string)) *MockService_GetRoundStatus_Call

func (*MockService_GetRoundStatus_Call) RunAndReturn 

func (_c *MockService_GetRoundStatus_Call) RunAndReturn(run func(ctx context.Context, roundID string) (manager.RoundStatus, error)) *MockService_GetRoundStatus_Call

type MockService_GetTaskMetrics_Call 

type MockService_GetTaskMetrics_Call struct {
	*mock.Call
}

MockService_GetTaskMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskMetrics'

func (*MockService_GetTaskMetrics_Call) Return 

func (_c *MockService_GetTaskMetrics_Call) Return(taskMetricsPage manager.TaskMetricsPage, err error) *MockService_GetTaskMetrics_Call

func (*MockService_GetTaskMetrics_Call) Run 

func (_c *MockService_GetTaskMetrics_Call) Run(run func(ctx context.Context, taskID string, offset uint64, limit uint64)) *MockService_GetTaskMetrics_Call

func (*MockService_GetTaskMetrics_Call) RunAndReturn 

func (_c *MockService_GetTaskMetrics_Call) RunAndReturn(run func(ctx context.Context, taskID string, offset uint64, limit uint64) (manager.TaskMetricsPage, error)) *MockService_GetTaskMetrics_Call

type MockService_GetTaskResults_Call 

type MockService_GetTaskResults_Call struct {
	*mock.Call
}

MockService_GetTaskResults_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTaskResults'

func (*MockService_GetTaskResults_Call) Return 

func (_c *MockService_GetTaskResults_Call) Return(v any, err error) *MockService_GetTaskResults_Call

func (*MockService_GetTaskResults_Call) Run 

func (_c *MockService_GetTaskResults_Call) Run(run func(ctx context.Context, taskID string)) *MockService_GetTaskResults_Call

func (*MockService_GetTaskResults_Call) RunAndReturn 

func (_c *MockService_GetTaskResults_Call) RunAndReturn(run func(ctx context.Context, taskID string) (any, error)) *MockService_GetTaskResults_Call

type MockService_GetTask_Call 

type MockService_GetTask_Call struct {
	*mock.Call
}

MockService_GetTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTask'

func (*MockService_GetTask_Call) Return 

func (_c *MockService_GetTask_Call) Return(task1 task.Task, err error) *MockService_GetTask_Call

func (*MockService_GetTask_Call) Run 

func (_c *MockService_GetTask_Call) Run(run func(ctx context.Context, taskID string)) *MockService_GetTask_Call

func (*MockService_GetTask_Call) RunAndReturn 

func (_c *MockService_GetTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) (task.Task, error)) *MockService_GetTask_Call

type MockService_ListJobs_Call 

type MockService_ListJobs_Call struct {
	*mock.Call
}

MockService_ListJobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListJobs'

func (*MockService_ListJobs_Call) Return 

func (_c *MockService_ListJobs_Call) Return(jobPage manager.JobPage, err error) *MockService_ListJobs_Call

func (*MockService_ListJobs_Call) Run 

func (_c *MockService_ListJobs_Call) Run(run func(ctx context.Context, offset uint64, limit uint64)) *MockService_ListJobs_Call

func (*MockService_ListJobs_Call) RunAndReturn 

func (_c *MockService_ListJobs_Call) RunAndReturn(run func(ctx context.Context, offset uint64, limit uint64) (manager.JobPage, error)) *MockService_ListJobs_Call

type MockService_ListProplets_Call 

type MockService_ListProplets_Call struct {
	*mock.Call
}

MockService_ListProplets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListProplets'

func (*MockService_ListProplets_Call) Return 

func (_c *MockService_ListProplets_Call) Return(propletPage proplet.PropletPage, err error) *MockService_ListProplets_Call

func (*MockService_ListProplets_Call) Run 

func (_c *MockService_ListProplets_Call) Run(run func(ctx context.Context, offset uint64, limit uint64)) *MockService_ListProplets_Call

func (*MockService_ListProplets_Call) RunAndReturn 

func (_c *MockService_ListProplets_Call) RunAndReturn(run func(ctx context.Context, offset uint64, limit uint64) (proplet.PropletPage, error)) *MockService_ListProplets_Call

type MockService_ListTasks_Call 

type MockService_ListTasks_Call struct {
	*mock.Call
}

MockService_ListTasks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListTasks'

func (*MockService_ListTasks_Call) Return 

func (_c *MockService_ListTasks_Call) Return(taskPage task.TaskPage, err error) *MockService_ListTasks_Call

func (*MockService_ListTasks_Call) Run 

func (_c *MockService_ListTasks_Call) Run(run func(ctx context.Context, offset uint64, limit uint64)) *MockService_ListTasks_Call

func (*MockService_ListTasks_Call) RunAndReturn 

func (_c *MockService_ListTasks_Call) RunAndReturn(run func(ctx context.Context, offset uint64, limit uint64) (task.TaskPage, error)) *MockService_ListTasks_Call

type MockService_PostFLUpdateCBOR_Call 

type MockService_PostFLUpdateCBOR_Call struct {
	*mock.Call
}

MockService_PostFLUpdateCBOR_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PostFLUpdateCBOR'

func (*MockService_PostFLUpdateCBOR_Call) Return 

func (_c *MockService_PostFLUpdateCBOR_Call) Return(err error) *MockService_PostFLUpdateCBOR_Call

func (*MockService_PostFLUpdateCBOR_Call) Run 

func (_c *MockService_PostFLUpdateCBOR_Call) Run(run func(ctx context.Context, updateData []byte)) *MockService_PostFLUpdateCBOR_Call

func (*MockService_PostFLUpdateCBOR_Call) RunAndReturn 

func (_c *MockService_PostFLUpdateCBOR_Call) RunAndReturn(run func(ctx context.Context, updateData []byte) error) *MockService_PostFLUpdateCBOR_Call

type MockService_PostFLUpdate_Call 

type MockService_PostFLUpdate_Call struct {
	*mock.Call
}

MockService_PostFLUpdate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PostFLUpdate'

func (*MockService_PostFLUpdate_Call) Return 

func (_c *MockService_PostFLUpdate_Call) Return(err error) *MockService_PostFLUpdate_Call

func (*MockService_PostFLUpdate_Call) Run 

func (_c *MockService_PostFLUpdate_Call) Run(run func(ctx context.Context, update manager.FLUpdate)) *MockService_PostFLUpdate_Call

func (*MockService_PostFLUpdate_Call) RunAndReturn 

func (_c *MockService_PostFLUpdate_Call) RunAndReturn(run func(ctx context.Context, update manager.FLUpdate) error) *MockService_PostFLUpdate_Call

type MockService_RecoverInterruptedTasks_Call 

type MockService_RecoverInterruptedTasks_Call struct {
	*mock.Call
}

MockService_RecoverInterruptedTasks_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecoverInterruptedTasks'

func (*MockService_RecoverInterruptedTasks_Call) Return 

func (_c *MockService_RecoverInterruptedTasks_Call) Return(err error) *MockService_RecoverInterruptedTasks_Call

func (*MockService_RecoverInterruptedTasks_Call) Run 

func (_c *MockService_RecoverInterruptedTasks_Call) Run(run func(ctx context.Context)) *MockService_RecoverInterruptedTasks_Call

func (*MockService_RecoverInterruptedTasks_Call) RunAndReturn 

func (_c *MockService_RecoverInterruptedTasks_Call) RunAndReturn(run func(ctx context.Context) error) *MockService_RecoverInterruptedTasks_Call

type MockService_SelectProplet_Call 

type MockService_SelectProplet_Call struct {
	*mock.Call
}

MockService_SelectProplet_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SelectProplet'

func (*MockService_SelectProplet_Call) Return 

func (_c *MockService_SelectProplet_Call) Return(proplet1 proplet.Proplet, err error) *MockService_SelectProplet_Call

func (*MockService_SelectProplet_Call) Run 

func (_c *MockService_SelectProplet_Call) Run(run func(ctx context.Context, task1 task.Task)) *MockService_SelectProplet_Call

func (*MockService_SelectProplet_Call) RunAndReturn 

func (_c *MockService_SelectProplet_Call) RunAndReturn(run func(ctx context.Context, task1 task.Task) (proplet.Proplet, error)) *MockService_SelectProplet_Call

type MockService_Shutdown_Call 

type MockService_Shutdown_Call struct {
	*mock.Call
}

MockService_Shutdown_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Shutdown'

func (*MockService_Shutdown_Call) Return 

func (_c *MockService_Shutdown_Call) Return(err error) *MockService_Shutdown_Call

func (*MockService_Shutdown_Call) Run 

func (_c *MockService_Shutdown_Call) Run(run func(ctx context.Context)) *MockService_Shutdown_Call

func (*MockService_Shutdown_Call) RunAndReturn 

func (_c *MockService_Shutdown_Call) RunAndReturn(run func(ctx context.Context) error) *MockService_Shutdown_Call

type MockService_StartJob_Call 

type MockService_StartJob_Call struct {
	*mock.Call
}

MockService_StartJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartJob'

func (*MockService_StartJob_Call) Return 

func (_c *MockService_StartJob_Call) Return(err error) *MockService_StartJob_Call

func (*MockService_StartJob_Call) Run 

func (_c *MockService_StartJob_Call) Run(run func(ctx context.Context, jobID string)) *MockService_StartJob_Call

func (*MockService_StartJob_Call) RunAndReturn 

func (_c *MockService_StartJob_Call) RunAndReturn(run func(ctx context.Context, jobID string) error) *MockService_StartJob_Call

type MockService_StartTask_Call 

type MockService_StartTask_Call struct {
	*mock.Call
}

MockService_StartTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartTask'

func (*MockService_StartTask_Call) Return 

func (_c *MockService_StartTask_Call) Return(err error) *MockService_StartTask_Call

func (*MockService_StartTask_Call) Run 

func (_c *MockService_StartTask_Call) Run(run func(ctx context.Context, taskID string)) *MockService_StartTask_Call

func (*MockService_StartTask_Call) RunAndReturn 

func (_c *MockService_StartTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *MockService_StartTask_Call

type MockService_StopJob_Call 

type MockService_StopJob_Call struct {
	*mock.Call
}

MockService_StopJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopJob'

func (*MockService_StopJob_Call) Return 

func (_c *MockService_StopJob_Call) Return(err error) *MockService_StopJob_Call

func (*MockService_StopJob_Call) Run 

func (_c *MockService_StopJob_Call) Run(run func(ctx context.Context, jobID string)) *MockService_StopJob_Call

func (*MockService_StopJob_Call) RunAndReturn 

func (_c *MockService_StopJob_Call) RunAndReturn(run func(ctx context.Context, jobID string) error) *MockService_StopJob_Call

type MockService_StopTask_Call 

type MockService_StopTask_Call struct {
	*mock.Call
}

MockService_StopTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopTask'

func (*MockService_StopTask_Call) Return 

func (_c *MockService_StopTask_Call) Return(err error) *MockService_StopTask_Call

func (*MockService_StopTask_Call) Run 

func (_c *MockService_StopTask_Call) Run(run func(ctx context.Context, taskID string)) *MockService_StopTask_Call

func (*MockService_StopTask_Call) RunAndReturn 

func (_c *MockService_StopTask_Call) RunAndReturn(run func(ctx context.Context, taskID string) error) *MockService_StopTask_Call

type MockService_Subscribe_Call 

type MockService_Subscribe_Call struct {
	*mock.Call
}

MockService_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'

func (*MockService_Subscribe_Call) Return 

func (_c *MockService_Subscribe_Call) Return(err error) *MockService_Subscribe_Call

func (*MockService_Subscribe_Call) Run 

func (_c *MockService_Subscribe_Call) Run(run func(ctx context.Context)) *MockService_Subscribe_Call

func (*MockService_Subscribe_Call) RunAndReturn 

func (_c *MockService_Subscribe_Call) RunAndReturn(run func(ctx context.Context) error) *MockService_Subscribe_Call

type MockService_UpdateTask_Call 

type MockService_UpdateTask_Call struct {
	*mock.Call
}

MockService_UpdateTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateTask'

func (*MockService_UpdateTask_Call) Return 

func (_c *MockService_UpdateTask_Call) Return(task11 task.Task, err error) *MockService_UpdateTask_Call

func (*MockService_UpdateTask_Call) Run 

func (_c *MockService_UpdateTask_Call) Run(run func(ctx context.Context, task1 task.Task)) *MockService_UpdateTask_Call

func (*MockService_UpdateTask_Call) RunAndReturn 

func (_c *MockService_UpdateTask_Call) RunAndReturn(run func(ctx context.Context, task1 task.Task) (task.Task, error)) *MockService_UpdateTask_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.