emittertest

package
v0.0.0-...-4cdfe95 Latest Latest
Warning

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

 Go to latest Published: May 14, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package emittertest provides testing utilities for cff emitters.

Package emittertest is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockEmitter 

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

MockEmitter is a mock of Emitter interface.

func NewMockEmitter 

func NewMockEmitter(ctrl *gomock.Controller) *MockEmitter

NewMockEmitter creates a new mock instance.

func (*MockEmitter) EXPECT 

func (m *MockEmitter) EXPECT() *MockEmitterMockRecorder

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

func (*MockEmitter) FlowInit 

func (m *MockEmitter) FlowInit(arg0 *cff.FlowInfo) cff.FlowEmitter

FlowInit mocks base method.

func (*MockEmitter) ParallelInit 

func (m *MockEmitter) ParallelInit(arg0 *cff.ParallelInfo) cff.ParallelEmitter

ParallelInit mocks base method.

func (*MockEmitter) SchedulerInit 

func (m *MockEmitter) SchedulerInit(arg0 *cff.SchedulerInfo) cff.SchedulerEmitter

SchedulerInit mocks base method.

func (*MockEmitter) TaskInit 

func (m *MockEmitter) TaskInit(arg0 *cff.TaskInfo, arg1 *cff.DirectiveInfo) cff.TaskEmitter

TaskInit mocks base method.

type MockEmitterMockRecorder 

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

MockEmitterMockRecorder is the mock recorder for MockEmitter.

func (*MockEmitterMockRecorder) FlowInit 

func (mr *MockEmitterMockRecorder) FlowInit(arg0 interface{}) *gomock.Call

FlowInit indicates an expected call of FlowInit.

func (*MockEmitterMockRecorder) ParallelInit 

func (mr *MockEmitterMockRecorder) ParallelInit(arg0 interface{}) *gomock.Call

ParallelInit indicates an expected call of ParallelInit.

func (*MockEmitterMockRecorder) SchedulerInit 

func (mr *MockEmitterMockRecorder) SchedulerInit(arg0 interface{}) *gomock.Call

SchedulerInit indicates an expected call of SchedulerInit.

func (*MockEmitterMockRecorder) TaskInit 

func (mr *MockEmitterMockRecorder) TaskInit(arg0, arg1 interface{}) *gomock.Call

TaskInit indicates an expected call of TaskInit.

type MockFlowEmitter 

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

MockFlowEmitter is a mock of FlowEmitter interface.

func NewMockFlowEmitter 

func NewMockFlowEmitter(ctrl *gomock.Controller) *MockFlowEmitter

NewMockFlowEmitter creates a new mock instance.

func (*MockFlowEmitter) EXPECT 

func (m *MockFlowEmitter) EXPECT() *MockFlowEmitterMockRecorder

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

func (*MockFlowEmitter) FlowDone 

func (m *MockFlowEmitter) FlowDone(arg0 context.Context, arg1 time.Duration)

FlowDone mocks base method.

func (*MockFlowEmitter) FlowError 

func (m *MockFlowEmitter) FlowError(arg0 context.Context, arg1 error)

FlowError mocks base method.

func (*MockFlowEmitter) FlowSuccess 

func (m *MockFlowEmitter) FlowSuccess(arg0 context.Context)

FlowSuccess mocks base method.

type MockFlowEmitterMockRecorder 

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

MockFlowEmitterMockRecorder is the mock recorder for MockFlowEmitter.

func (*MockFlowEmitterMockRecorder) FlowDone 

func (mr *MockFlowEmitterMockRecorder) FlowDone(arg0, arg1 interface{}) *gomock.Call

FlowDone indicates an expected call of FlowDone.

func (*MockFlowEmitterMockRecorder) FlowError 

func (mr *MockFlowEmitterMockRecorder) FlowError(arg0, arg1 interface{}) *gomock.Call

FlowError indicates an expected call of FlowError.

func (*MockFlowEmitterMockRecorder) FlowSuccess 

func (mr *MockFlowEmitterMockRecorder) FlowSuccess(arg0 interface{}) *gomock.Call

FlowSuccess indicates an expected call of FlowSuccess.

type MockParallelEmitter 

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

MockParallelEmitter is a mock of ParallelEmitter interface.

func NewMockParallelEmitter 

func NewMockParallelEmitter(ctrl *gomock.Controller) *MockParallelEmitter

NewMockParallelEmitter creates a new mock instance.

func (*MockParallelEmitter) EXPECT 

func (m *MockParallelEmitter) EXPECT() *MockParallelEmitterMockRecorder

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

func (*MockParallelEmitter) ParallelDone 

func (m *MockParallelEmitter) ParallelDone(arg0 context.Context, arg1 time.Duration)

ParallelDone mocks base method.

func (*MockParallelEmitter) ParallelError 

func (m *MockParallelEmitter) ParallelError(arg0 context.Context, arg1 error)

ParallelError mocks base method.

func (*MockParallelEmitter) ParallelSuccess 

func (m *MockParallelEmitter) ParallelSuccess(arg0 context.Context)

ParallelSuccess mocks base method.

type MockParallelEmitterMockRecorder 

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

MockParallelEmitterMockRecorder is the mock recorder for MockParallelEmitter.

func (*MockParallelEmitterMockRecorder) ParallelDone 

func (mr *MockParallelEmitterMockRecorder) ParallelDone(arg0, arg1 interface{}) *gomock.Call

ParallelDone indicates an expected call of ParallelDone.

func (*MockParallelEmitterMockRecorder) ParallelError 

func (mr *MockParallelEmitterMockRecorder) ParallelError(arg0, arg1 interface{}) *gomock.Call

ParallelError indicates an expected call of ParallelError.

func (*MockParallelEmitterMockRecorder) ParallelSuccess 

func (mr *MockParallelEmitterMockRecorder) ParallelSuccess(arg0 interface{}) *gomock.Call

ParallelSuccess indicates an expected call of ParallelSuccess.

type MockSchedulerEmitter 

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

MockSchedulerEmitter is a mock of SchedulerEmitter interface.

func NewMockSchedulerEmitter 

func NewMockSchedulerEmitter(ctrl *gomock.Controller) *MockSchedulerEmitter

NewMockSchedulerEmitter creates a new mock instance.

func (*MockSchedulerEmitter) EXPECT 

func (m *MockSchedulerEmitter) EXPECT() *MockSchedulerEmitterMockRecorder

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

func (*MockSchedulerEmitter) EmitScheduler 

func (m *MockSchedulerEmitter) EmitScheduler(arg0 scheduler.State)

EmitScheduler mocks base method.

type MockSchedulerEmitterMockRecorder 

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

MockSchedulerEmitterMockRecorder is the mock recorder for MockSchedulerEmitter.

func (*MockSchedulerEmitterMockRecorder) EmitScheduler 

func (mr *MockSchedulerEmitterMockRecorder) EmitScheduler(arg0 interface{}) *gomock.Call

EmitScheduler indicates an expected call of EmitScheduler.

type MockTaskEmitter 

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

MockTaskEmitter is a mock of TaskEmitter interface.

func NewMockTaskEmitter 

func NewMockTaskEmitter(ctrl *gomock.Controller) *MockTaskEmitter

NewMockTaskEmitter creates a new mock instance.

func (*MockTaskEmitter) EXPECT 

func (m *MockTaskEmitter) EXPECT() *MockTaskEmitterMockRecorder

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

func (*MockTaskEmitter) TaskDone 

func (m *MockTaskEmitter) TaskDone(arg0 context.Context, arg1 time.Duration)

TaskDone mocks base method.

func (*MockTaskEmitter) TaskError 

func (m *MockTaskEmitter) TaskError(arg0 context.Context, arg1 error)

TaskError mocks base method.

func (*MockTaskEmitter) TaskErrorRecovered 

func (m *MockTaskEmitter) TaskErrorRecovered(arg0 context.Context, arg1 error)

TaskErrorRecovered mocks base method.

func (*MockTaskEmitter) TaskPanic 

func (m *MockTaskEmitter) TaskPanic(arg0 context.Context, arg1 interface{})

TaskPanic mocks base method.

func (*MockTaskEmitter) TaskPanicRecovered 

func (m *MockTaskEmitter) TaskPanicRecovered(arg0 context.Context, arg1 interface{})

TaskPanicRecovered mocks base method.

func (*MockTaskEmitter) TaskSkipped 

func (m *MockTaskEmitter) TaskSkipped(arg0 context.Context, arg1 error)

TaskSkipped mocks base method.

func (*MockTaskEmitter) TaskSuccess 

func (m *MockTaskEmitter) TaskSuccess(arg0 context.Context)

TaskSuccess mocks base method.

type MockTaskEmitterMockRecorder 

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

MockTaskEmitterMockRecorder is the mock recorder for MockTaskEmitter.

func (*MockTaskEmitterMockRecorder) TaskDone 

func (mr *MockTaskEmitterMockRecorder) TaskDone(arg0, arg1 interface{}) *gomock.Call

TaskDone indicates an expected call of TaskDone.

func (*MockTaskEmitterMockRecorder) TaskError 

func (mr *MockTaskEmitterMockRecorder) TaskError(arg0, arg1 interface{}) *gomock.Call

TaskError indicates an expected call of TaskError.

func (*MockTaskEmitterMockRecorder) TaskErrorRecovered 

func (mr *MockTaskEmitterMockRecorder) TaskErrorRecovered(arg0, arg1 interface{}) *gomock.Call

TaskErrorRecovered indicates an expected call of TaskErrorRecovered.

func (*MockTaskEmitterMockRecorder) TaskPanic 

func (mr *MockTaskEmitterMockRecorder) TaskPanic(arg0, arg1 interface{}) *gomock.Call

TaskPanic indicates an expected call of TaskPanic.

func (*MockTaskEmitterMockRecorder) TaskPanicRecovered 

func (mr *MockTaskEmitterMockRecorder) TaskPanicRecovered(arg0, arg1 interface{}) *gomock.Call

TaskPanicRecovered indicates an expected call of TaskPanicRecovered.

func (*MockTaskEmitterMockRecorder) TaskSkipped 

func (mr *MockTaskEmitterMockRecorder) TaskSkipped(arg0, arg1 interface{}) *gomock.Call

TaskSkipped indicates an expected call of TaskSkipped.

func (*MockTaskEmitterMockRecorder) TaskSuccess 

func (mr *MockTaskEmitterMockRecorder) TaskSuccess(arg0 interface{}) *gomock.Call

TaskSuccess indicates an expected call of TaskSuccess.

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.