Documentation
¶
Index ¶
- type Driver
- type Driver_Expecter
- type Driver_Start_Call
- type Driver_Stop_Call
- type Manager
- func (_mock *Manager) ChangeOutputBufferCapacity(ctx context.Context, sessionName string, newCap int64, blocking bool) error
- func (_m *Manager) EXPECT() *Manager_Expecter
- func (_mock *Manager) HandleChangeOutputBufferCapacity(sessionName string, newCap int64, ...) error
- func (_mock *Manager) HandleSessionIPCProcessError(sessionName string, sessionErr error)
- func (_mock *Manager) HandleSessionIdleNotify(sessionName string)
- func (_mock *Manager) HandleStartSession(sessionName string, onComplete func(ctx context.Context, err error)) error
- func (_mock *Manager) HandleStopAllSessions(onComplete func(ctx context.Context, err error)) error
- func (_mock *Manager) HandleStopSession(sessionName string, onComplete func(ctx context.Context, err error)) error
- func (_mock *Manager) Start(ctx context.Context) error
- func (_mock *Manager) StartSession(ctx context.Context, sessionName string, blocking bool) error
- func (_mock *Manager) Stop(ctx context.Context) error
- func (_mock *Manager) StopAllSessions(ctx context.Context, blocking bool) error
- func (_mock *Manager) StopSession(ctx context.Context, sessionName string, blocking bool) error
- type Manager_ChangeOutputBufferCapacity_Call
- func (_c *Manager_ChangeOutputBufferCapacity_Call) Return(err error) *Manager_ChangeOutputBufferCapacity_Call
- func (_c *Manager_ChangeOutputBufferCapacity_Call) Run(run func(ctx context.Context, sessionName string, newCap int64, blocking bool)) *Manager_ChangeOutputBufferCapacity_Call
- func (_c *Manager_ChangeOutputBufferCapacity_Call) RunAndReturn(...) *Manager_ChangeOutputBufferCapacity_Call
- type Manager_Expecter
- func (_e *Manager_Expecter) ChangeOutputBufferCapacity(ctx interface{}, sessionName interface{}, newCap interface{}, ...) *Manager_ChangeOutputBufferCapacity_Call
- func (_e *Manager_Expecter) HandleChangeOutputBufferCapacity(sessionName interface{}, newCap interface{}, onComplete interface{}) *Manager_HandleChangeOutputBufferCapacity_Call
- func (_e *Manager_Expecter) HandleSessionIPCProcessError(sessionName interface{}, sessionErr interface{}) *Manager_HandleSessionIPCProcessError_Call
- func (_e *Manager_Expecter) HandleSessionIdleNotify(sessionName interface{}) *Manager_HandleSessionIdleNotify_Call
- func (_e *Manager_Expecter) HandleStartSession(sessionName interface{}, onComplete interface{}) *Manager_HandleStartSession_Call
- func (_e *Manager_Expecter) HandleStopAllSessions(onComplete interface{}) *Manager_HandleStopAllSessions_Call
- func (_e *Manager_Expecter) HandleStopSession(sessionName interface{}, onComplete interface{}) *Manager_HandleStopSession_Call
- func (_e *Manager_Expecter) Start(ctx interface{}) *Manager_Start_Call
- func (_e *Manager_Expecter) StartSession(ctx interface{}, sessionName interface{}, blocking interface{}) *Manager_StartSession_Call
- func (_e *Manager_Expecter) Stop(ctx interface{}) *Manager_Stop_Call
- func (_e *Manager_Expecter) StopAllSessions(ctx interface{}, blocking interface{}) *Manager_StopAllSessions_Call
- func (_e *Manager_Expecter) StopSession(ctx interface{}, sessionName interface{}, blocking interface{}) *Manager_StopSession_Call
- type Manager_HandleChangeOutputBufferCapacity_Call
- func (_c *Manager_HandleChangeOutputBufferCapacity_Call) Return(err error) *Manager_HandleChangeOutputBufferCapacity_Call
- func (_c *Manager_HandleChangeOutputBufferCapacity_Call) Run(run func(sessionName string, newCap int64, ...)) *Manager_HandleChangeOutputBufferCapacity_Call
- func (_c *Manager_HandleChangeOutputBufferCapacity_Call) RunAndReturn(run func(sessionName string, newCap int64, ...) error) *Manager_HandleChangeOutputBufferCapacity_Call
- type Manager_HandleSessionIPCProcessError_Call
- func (_c *Manager_HandleSessionIPCProcessError_Call) Return() *Manager_HandleSessionIPCProcessError_Call
- func (_c *Manager_HandleSessionIPCProcessError_Call) Run(run func(sessionName string, sessionErr error)) *Manager_HandleSessionIPCProcessError_Call
- func (_c *Manager_HandleSessionIPCProcessError_Call) RunAndReturn(run func(sessionName string, sessionErr error)) *Manager_HandleSessionIPCProcessError_Call
- type Manager_HandleSessionIdleNotify_Call
- func (_c *Manager_HandleSessionIdleNotify_Call) Return() *Manager_HandleSessionIdleNotify_Call
- func (_c *Manager_HandleSessionIdleNotify_Call) Run(run func(sessionName string)) *Manager_HandleSessionIdleNotify_Call
- func (_c *Manager_HandleSessionIdleNotify_Call) RunAndReturn(run func(sessionName string)) *Manager_HandleSessionIdleNotify_Call
- type Manager_HandleStartSession_Call
- func (_c *Manager_HandleStartSession_Call) Return(err error) *Manager_HandleStartSession_Call
- func (_c *Manager_HandleStartSession_Call) Run(run func(sessionName string, onComplete func(ctx context.Context, err error))) *Manager_HandleStartSession_Call
- func (_c *Manager_HandleStartSession_Call) RunAndReturn(...) *Manager_HandleStartSession_Call
- type Manager_HandleStopAllSessions_Call
- func (_c *Manager_HandleStopAllSessions_Call) Return(err error) *Manager_HandleStopAllSessions_Call
- func (_c *Manager_HandleStopAllSessions_Call) Run(run func(onComplete func(ctx context.Context, err error))) *Manager_HandleStopAllSessions_Call
- func (_c *Manager_HandleStopAllSessions_Call) RunAndReturn(run func(onComplete func(ctx context.Context, err error)) error) *Manager_HandleStopAllSessions_Call
- type Manager_HandleStopSession_Call
- func (_c *Manager_HandleStopSession_Call) Return(err error) *Manager_HandleStopSession_Call
- func (_c *Manager_HandleStopSession_Call) Run(run func(sessionName string, onComplete func(ctx context.Context, err error))) *Manager_HandleStopSession_Call
- func (_c *Manager_HandleStopSession_Call) RunAndReturn(...) *Manager_HandleStopSession_Call
- type Manager_StartSession_Call
- func (_c *Manager_StartSession_Call) Return(err error) *Manager_StartSession_Call
- func (_c *Manager_StartSession_Call) Run(run func(ctx context.Context, sessionName string, blocking bool)) *Manager_StartSession_Call
- func (_c *Manager_StartSession_Call) RunAndReturn(run func(ctx context.Context, sessionName string, blocking bool) error) *Manager_StartSession_Call
- type Manager_Start_Call
- type Manager_StopAllSessions_Call
- func (_c *Manager_StopAllSessions_Call) Return(err error) *Manager_StopAllSessions_Call
- func (_c *Manager_StopAllSessions_Call) Run(run func(ctx context.Context, blocking bool)) *Manager_StopAllSessions_Call
- func (_c *Manager_StopAllSessions_Call) RunAndReturn(run func(ctx context.Context, blocking bool) error) *Manager_StopAllSessions_Call
- type Manager_StopSession_Call
- func (_c *Manager_StopSession_Call) Return(err error) *Manager_StopSession_Call
- func (_c *Manager_StopSession_Call) Run(run func(ctx context.Context, sessionName string, blocking bool)) *Manager_StopSession_Call
- func (_c *Manager_StopSession_Call) RunAndReturn(run func(ctx context.Context, sessionName string, blocking bool) error) *Manager_StopSession_Call
- type Manager_Stop_Call
- type Runner
- func (_m *Runner) EXPECT() *Runner_Expecter
- func (_mock *Runner) HandleIPCRequestMessage(newMessage models.IPCMessageEnvelope) error
- func (_mock *Runner) HandleStartSession(onComplete func(ctx context.Context, err error)) error
- func (_mock *Runner) HandleStopSession(onComplete func(ctx context.Context, err error)) error
- func (_mock *Runner) HandleSubmitCommands(commands []models.SessionInputCommand, ...) error
- func (_mock *Runner) Start(ctx context.Context) error
- func (_mock *Runner) StartSession(ctx context.Context, blocking bool) error
- func (_mock *Runner) Stop(ctx context.Context) error
- func (_mock *Runner) StopSession(ctx context.Context, blocking bool) error
- func (_mock *Runner) SubmitCommands(ctx context.Context, commands []models.SessionInputCommand) error
- type Runner_Expecter
- func (_e *Runner_Expecter) HandleIPCRequestMessage(newMessage interface{}) *Runner_HandleIPCRequestMessage_Call
- func (_e *Runner_Expecter) HandleStartSession(onComplete interface{}) *Runner_HandleStartSession_Call
- func (_e *Runner_Expecter) HandleStopSession(onComplete interface{}) *Runner_HandleStopSession_Call
- func (_e *Runner_Expecter) HandleSubmitCommands(commands interface{}, onComplete interface{}) *Runner_HandleSubmitCommands_Call
- func (_e *Runner_Expecter) Start(ctx interface{}) *Runner_Start_Call
- func (_e *Runner_Expecter) StartSession(ctx interface{}, blocking interface{}) *Runner_StartSession_Call
- func (_e *Runner_Expecter) Stop(ctx interface{}) *Runner_Stop_Call
- func (_e *Runner_Expecter) StopSession(ctx interface{}, blocking interface{}) *Runner_StopSession_Call
- func (_e *Runner_Expecter) SubmitCommands(ctx interface{}, commands interface{}) *Runner_SubmitCommands_Call
- type Runner_HandleIPCRequestMessage_Call
- func (_c *Runner_HandleIPCRequestMessage_Call) Return(err error) *Runner_HandleIPCRequestMessage_Call
- func (_c *Runner_HandleIPCRequestMessage_Call) Run(run func(newMessage models.IPCMessageEnvelope)) *Runner_HandleIPCRequestMessage_Call
- func (_c *Runner_HandleIPCRequestMessage_Call) RunAndReturn(run func(newMessage models.IPCMessageEnvelope) error) *Runner_HandleIPCRequestMessage_Call
- type Runner_HandleStartSession_Call
- func (_c *Runner_HandleStartSession_Call) Return(err error) *Runner_HandleStartSession_Call
- func (_c *Runner_HandleStartSession_Call) Run(run func(onComplete func(ctx context.Context, err error))) *Runner_HandleStartSession_Call
- func (_c *Runner_HandleStartSession_Call) RunAndReturn(run func(onComplete func(ctx context.Context, err error)) error) *Runner_HandleStartSession_Call
- type Runner_HandleStopSession_Call
- func (_c *Runner_HandleStopSession_Call) Return(err error) *Runner_HandleStopSession_Call
- func (_c *Runner_HandleStopSession_Call) Run(run func(onComplete func(ctx context.Context, err error))) *Runner_HandleStopSession_Call
- func (_c *Runner_HandleStopSession_Call) RunAndReturn(run func(onComplete func(ctx context.Context, err error)) error) *Runner_HandleStopSession_Call
- type Runner_HandleSubmitCommands_Call
- func (_c *Runner_HandleSubmitCommands_Call) Return(err error) *Runner_HandleSubmitCommands_Call
- func (_c *Runner_HandleSubmitCommands_Call) Run(run func(commands []models.SessionInputCommand, ...)) *Runner_HandleSubmitCommands_Call
- func (_c *Runner_HandleSubmitCommands_Call) RunAndReturn(run func(commands []models.SessionInputCommand, ...) error) *Runner_HandleSubmitCommands_Call
- type Runner_StartSession_Call
- func (_c *Runner_StartSession_Call) Return(err error) *Runner_StartSession_Call
- func (_c *Runner_StartSession_Call) Run(run func(ctx context.Context, blocking bool)) *Runner_StartSession_Call
- func (_c *Runner_StartSession_Call) RunAndReturn(run func(ctx context.Context, blocking bool) error) *Runner_StartSession_Call
- type Runner_Start_Call
- type Runner_StopSession_Call
- func (_c *Runner_StopSession_Call) Return(err error) *Runner_StopSession_Call
- func (_c *Runner_StopSession_Call) Run(run func(ctx context.Context, blocking bool)) *Runner_StopSession_Call
- func (_c *Runner_StopSession_Call) RunAndReturn(run func(ctx context.Context, blocking bool) error) *Runner_StopSession_Call
- type Runner_Stop_Call
- type Runner_SubmitCommands_Call
- func (_c *Runner_SubmitCommands_Call) Return(err error) *Runner_SubmitCommands_Call
- func (_c *Runner_SubmitCommands_Call) Run(run func(ctx context.Context, commands []models.SessionInputCommand)) *Runner_SubmitCommands_Call
- func (_c *Runner_SubmitCommands_Call) RunAndReturn(run func(ctx context.Context, commands []models.SessionInputCommand) error) *Runner_SubmitCommands_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Driver ¶
Driver is an autogenerated mock type for the Driver type
func NewDriver ¶
NewDriver creates a new instance of Driver. 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 (*Driver) EXPECT ¶
func (_m *Driver) EXPECT() *Driver_Expecter
type Driver_Expecter ¶
type Driver_Expecter struct {
// contains filtered or unexported fields
}
func (*Driver_Expecter) Start ¶
func (_e *Driver_Expecter) Start(parentCtx interface{}) *Driver_Start_Call
Start is a helper method to define mock.On call
- parentCtx context.Context
func (*Driver_Expecter) Stop ¶
func (_e *Driver_Expecter) Stop(ctx interface{}) *Driver_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
type Driver_Start_Call ¶
Driver_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Driver_Start_Call) Return ¶
func (_c *Driver_Start_Call) Return(err error) *Driver_Start_Call
func (*Driver_Start_Call) Run ¶
func (_c *Driver_Start_Call) Run(run func(parentCtx context.Context)) *Driver_Start_Call
func (*Driver_Start_Call) RunAndReturn ¶
func (_c *Driver_Start_Call) RunAndReturn(run func(parentCtx context.Context) error) *Driver_Start_Call
type Driver_Stop_Call ¶
Driver_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Driver_Stop_Call) Return ¶
func (_c *Driver_Stop_Call) Return(err error) *Driver_Stop_Call
func (*Driver_Stop_Call) Run ¶
func (_c *Driver_Stop_Call) Run(run func(ctx context.Context)) *Driver_Stop_Call
func (*Driver_Stop_Call) RunAndReturn ¶
func (_c *Driver_Stop_Call) RunAndReturn(run func(ctx context.Context) error) *Driver_Stop_Call
type Manager ¶
Manager is an autogenerated mock type for the Manager type
func NewManager ¶
NewManager creates a new instance of Manager. 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 (*Manager) ChangeOutputBufferCapacity ¶
func (_mock *Manager) ChangeOutputBufferCapacity(ctx context.Context, sessionName string, newCap int64, blocking bool) error
ChangeOutputBufferCapacity provides a mock function for the type Manager
func (*Manager) EXPECT ¶
func (_m *Manager) EXPECT() *Manager_Expecter
func (*Manager) HandleChangeOutputBufferCapacity ¶
func (_mock *Manager) HandleChangeOutputBufferCapacity(sessionName string, newCap int64, onComplete func(ctx context.Context, err error)) error
HandleChangeOutputBufferCapacity provides a mock function for the type Manager
func (*Manager) HandleSessionIPCProcessError ¶
HandleSessionIPCProcessError provides a mock function for the type Manager
func (*Manager) HandleSessionIdleNotify ¶
HandleSessionIdleNotify provides a mock function for the type Manager
func (*Manager) HandleStartSession ¶
func (_mock *Manager) HandleStartSession(sessionName string, onComplete func(ctx context.Context, err error)) error
HandleStartSession provides a mock function for the type Manager
func (*Manager) HandleStopAllSessions ¶
HandleStopAllSessions provides a mock function for the type Manager
func (*Manager) HandleStopSession ¶
func (_mock *Manager) HandleStopSession(sessionName string, onComplete func(ctx context.Context, err error)) error
HandleStopSession provides a mock function for the type Manager
func (*Manager) StartSession ¶
StartSession provides a mock function for the type Manager
func (*Manager) StopAllSessions ¶
StopAllSessions provides a mock function for the type Manager
type Manager_ChangeOutputBufferCapacity_Call ¶
Manager_ChangeOutputBufferCapacity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ChangeOutputBufferCapacity'
func (*Manager_ChangeOutputBufferCapacity_Call) Return ¶
func (_c *Manager_ChangeOutputBufferCapacity_Call) Return(err error) *Manager_ChangeOutputBufferCapacity_Call
func (*Manager_ChangeOutputBufferCapacity_Call) Run ¶
func (_c *Manager_ChangeOutputBufferCapacity_Call) Run(run func(ctx context.Context, sessionName string, newCap int64, blocking bool)) *Manager_ChangeOutputBufferCapacity_Call
func (*Manager_ChangeOutputBufferCapacity_Call) RunAndReturn ¶
func (_c *Manager_ChangeOutputBufferCapacity_Call) RunAndReturn(run func(ctx context.Context, sessionName string, newCap int64, blocking bool) error) *Manager_ChangeOutputBufferCapacity_Call
type Manager_Expecter ¶
type Manager_Expecter struct {
// contains filtered or unexported fields
}
func (*Manager_Expecter) ChangeOutputBufferCapacity ¶
func (_e *Manager_Expecter) ChangeOutputBufferCapacity(ctx interface{}, sessionName interface{}, newCap interface{}, blocking interface{}) *Manager_ChangeOutputBufferCapacity_Call
ChangeOutputBufferCapacity is a helper method to define mock.On call
- ctx context.Context
- sessionName string
- newCap int64
- blocking bool
func (*Manager_Expecter) HandleChangeOutputBufferCapacity ¶
func (_e *Manager_Expecter) HandleChangeOutputBufferCapacity(sessionName interface{}, newCap interface{}, onComplete interface{}) *Manager_HandleChangeOutputBufferCapacity_Call
HandleChangeOutputBufferCapacity is a helper method to define mock.On call
- sessionName string
- newCap int64
- onComplete func(ctx context.Context, err error)
func (*Manager_Expecter) HandleSessionIPCProcessError ¶
func (_e *Manager_Expecter) HandleSessionIPCProcessError(sessionName interface{}, sessionErr interface{}) *Manager_HandleSessionIPCProcessError_Call
HandleSessionIPCProcessError is a helper method to define mock.On call
- sessionName string
- sessionErr error
func (*Manager_Expecter) HandleSessionIdleNotify ¶
func (_e *Manager_Expecter) HandleSessionIdleNotify(sessionName interface{}) *Manager_HandleSessionIdleNotify_Call
HandleSessionIdleNotify is a helper method to define mock.On call
- sessionName string
func (*Manager_Expecter) HandleStartSession ¶
func (_e *Manager_Expecter) HandleStartSession(sessionName interface{}, onComplete interface{}) *Manager_HandleStartSession_Call
HandleStartSession is a helper method to define mock.On call
- sessionName string
- onComplete func(ctx context.Context, err error)
func (*Manager_Expecter) HandleStopAllSessions ¶
func (_e *Manager_Expecter) HandleStopAllSessions(onComplete interface{}) *Manager_HandleStopAllSessions_Call
HandleStopAllSessions is a helper method to define mock.On call
- onComplete func(ctx context.Context, err error)
func (*Manager_Expecter) HandleStopSession ¶
func (_e *Manager_Expecter) HandleStopSession(sessionName interface{}, onComplete interface{}) *Manager_HandleStopSession_Call
HandleStopSession is a helper method to define mock.On call
- sessionName string
- onComplete func(ctx context.Context, err error)
func (*Manager_Expecter) Start ¶
func (_e *Manager_Expecter) Start(ctx interface{}) *Manager_Start_Call
Start is a helper method to define mock.On call
- ctx context.Context
func (*Manager_Expecter) StartSession ¶
func (_e *Manager_Expecter) StartSession(ctx interface{}, sessionName interface{}, blocking interface{}) *Manager_StartSession_Call
StartSession is a helper method to define mock.On call
- ctx context.Context
- sessionName string
- blocking bool
func (*Manager_Expecter) Stop ¶
func (_e *Manager_Expecter) Stop(ctx interface{}) *Manager_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
func (*Manager_Expecter) StopAllSessions ¶
func (_e *Manager_Expecter) StopAllSessions(ctx interface{}, blocking interface{}) *Manager_StopAllSessions_Call
StopAllSessions is a helper method to define mock.On call
- ctx context.Context
- blocking bool
func (*Manager_Expecter) StopSession ¶
func (_e *Manager_Expecter) StopSession(ctx interface{}, sessionName interface{}, blocking interface{}) *Manager_StopSession_Call
StopSession is a helper method to define mock.On call
- ctx context.Context
- sessionName string
- blocking bool
type Manager_HandleChangeOutputBufferCapacity_Call ¶
Manager_HandleChangeOutputBufferCapacity_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleChangeOutputBufferCapacity'
func (*Manager_HandleChangeOutputBufferCapacity_Call) Return ¶
func (_c *Manager_HandleChangeOutputBufferCapacity_Call) Return(err error) *Manager_HandleChangeOutputBufferCapacity_Call
func (*Manager_HandleChangeOutputBufferCapacity_Call) Run ¶
func (_c *Manager_HandleChangeOutputBufferCapacity_Call) Run(run func(sessionName string, newCap int64, onComplete func(ctx context.Context, err error))) *Manager_HandleChangeOutputBufferCapacity_Call
func (*Manager_HandleChangeOutputBufferCapacity_Call) RunAndReturn ¶
func (_c *Manager_HandleChangeOutputBufferCapacity_Call) RunAndReturn(run func(sessionName string, newCap int64, onComplete func(ctx context.Context, err error)) error) *Manager_HandleChangeOutputBufferCapacity_Call
type Manager_HandleSessionIPCProcessError_Call ¶
Manager_HandleSessionIPCProcessError_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleSessionIPCProcessError'
func (*Manager_HandleSessionIPCProcessError_Call) Return ¶
func (_c *Manager_HandleSessionIPCProcessError_Call) Return() *Manager_HandleSessionIPCProcessError_Call
func (*Manager_HandleSessionIPCProcessError_Call) Run ¶
func (_c *Manager_HandleSessionIPCProcessError_Call) Run(run func(sessionName string, sessionErr error)) *Manager_HandleSessionIPCProcessError_Call
func (*Manager_HandleSessionIPCProcessError_Call) RunAndReturn ¶
func (_c *Manager_HandleSessionIPCProcessError_Call) RunAndReturn(run func(sessionName string, sessionErr error)) *Manager_HandleSessionIPCProcessError_Call
type Manager_HandleSessionIdleNotify_Call ¶
Manager_HandleSessionIdleNotify_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleSessionIdleNotify'
func (*Manager_HandleSessionIdleNotify_Call) Return ¶
func (_c *Manager_HandleSessionIdleNotify_Call) Return() *Manager_HandleSessionIdleNotify_Call
func (*Manager_HandleSessionIdleNotify_Call) Run ¶
func (_c *Manager_HandleSessionIdleNotify_Call) Run(run func(sessionName string)) *Manager_HandleSessionIdleNotify_Call
func (*Manager_HandleSessionIdleNotify_Call) RunAndReturn ¶
func (_c *Manager_HandleSessionIdleNotify_Call) RunAndReturn(run func(sessionName string)) *Manager_HandleSessionIdleNotify_Call
type Manager_HandleStartSession_Call ¶
Manager_HandleStartSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleStartSession'
func (*Manager_HandleStartSession_Call) Return ¶
func (_c *Manager_HandleStartSession_Call) Return(err error) *Manager_HandleStartSession_Call
func (*Manager_HandleStartSession_Call) Run ¶
func (_c *Manager_HandleStartSession_Call) Run(run func(sessionName string, onComplete func(ctx context.Context, err error))) *Manager_HandleStartSession_Call
func (*Manager_HandleStartSession_Call) RunAndReturn ¶
func (_c *Manager_HandleStartSession_Call) RunAndReturn(run func(sessionName string, onComplete func(ctx context.Context, err error)) error) *Manager_HandleStartSession_Call
type Manager_HandleStopAllSessions_Call ¶
Manager_HandleStopAllSessions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleStopAllSessions'
func (*Manager_HandleStopAllSessions_Call) Return ¶
func (_c *Manager_HandleStopAllSessions_Call) Return(err error) *Manager_HandleStopAllSessions_Call
func (*Manager_HandleStopAllSessions_Call) Run ¶
func (_c *Manager_HandleStopAllSessions_Call) Run(run func(onComplete func(ctx context.Context, err error))) *Manager_HandleStopAllSessions_Call
func (*Manager_HandleStopAllSessions_Call) RunAndReturn ¶
func (_c *Manager_HandleStopAllSessions_Call) RunAndReturn(run func(onComplete func(ctx context.Context, err error)) error) *Manager_HandleStopAllSessions_Call
type Manager_HandleStopSession_Call ¶
Manager_HandleStopSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleStopSession'
func (*Manager_HandleStopSession_Call) Return ¶
func (_c *Manager_HandleStopSession_Call) Return(err error) *Manager_HandleStopSession_Call
func (*Manager_HandleStopSession_Call) Run ¶
func (_c *Manager_HandleStopSession_Call) Run(run func(sessionName string, onComplete func(ctx context.Context, err error))) *Manager_HandleStopSession_Call
func (*Manager_HandleStopSession_Call) RunAndReturn ¶
func (_c *Manager_HandleStopSession_Call) RunAndReturn(run func(sessionName string, onComplete func(ctx context.Context, err error)) error) *Manager_HandleStopSession_Call
type Manager_StartSession_Call ¶
Manager_StartSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartSession'
func (*Manager_StartSession_Call) Return ¶
func (_c *Manager_StartSession_Call) Return(err error) *Manager_StartSession_Call
func (*Manager_StartSession_Call) Run ¶
func (_c *Manager_StartSession_Call) Run(run func(ctx context.Context, sessionName string, blocking bool)) *Manager_StartSession_Call
func (*Manager_StartSession_Call) RunAndReturn ¶
func (_c *Manager_StartSession_Call) RunAndReturn(run func(ctx context.Context, sessionName string, blocking bool) error) *Manager_StartSession_Call
type Manager_Start_Call ¶
Manager_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Manager_Start_Call) Return ¶
func (_c *Manager_Start_Call) Return(err error) *Manager_Start_Call
func (*Manager_Start_Call) Run ¶
func (_c *Manager_Start_Call) Run(run func(ctx context.Context)) *Manager_Start_Call
func (*Manager_Start_Call) RunAndReturn ¶
func (_c *Manager_Start_Call) RunAndReturn(run func(ctx context.Context) error) *Manager_Start_Call
type Manager_StopAllSessions_Call ¶
Manager_StopAllSessions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopAllSessions'
func (*Manager_StopAllSessions_Call) Return ¶
func (_c *Manager_StopAllSessions_Call) Return(err error) *Manager_StopAllSessions_Call
func (*Manager_StopAllSessions_Call) Run ¶
func (_c *Manager_StopAllSessions_Call) Run(run func(ctx context.Context, blocking bool)) *Manager_StopAllSessions_Call
func (*Manager_StopAllSessions_Call) RunAndReturn ¶
func (_c *Manager_StopAllSessions_Call) RunAndReturn(run func(ctx context.Context, blocking bool) error) *Manager_StopAllSessions_Call
type Manager_StopSession_Call ¶
Manager_StopSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopSession'
func (*Manager_StopSession_Call) Return ¶
func (_c *Manager_StopSession_Call) Return(err error) *Manager_StopSession_Call
func (*Manager_StopSession_Call) Run ¶
func (_c *Manager_StopSession_Call) Run(run func(ctx context.Context, sessionName string, blocking bool)) *Manager_StopSession_Call
func (*Manager_StopSession_Call) RunAndReturn ¶
func (_c *Manager_StopSession_Call) RunAndReturn(run func(ctx context.Context, sessionName string, blocking bool) error) *Manager_StopSession_Call
type Manager_Stop_Call ¶
Manager_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Manager_Stop_Call) Return ¶
func (_c *Manager_Stop_Call) Return(err error) *Manager_Stop_Call
func (*Manager_Stop_Call) Run ¶
func (_c *Manager_Stop_Call) Run(run func(ctx context.Context)) *Manager_Stop_Call
func (*Manager_Stop_Call) RunAndReturn ¶
func (_c *Manager_Stop_Call) RunAndReturn(run func(ctx context.Context) error) *Manager_Stop_Call
type Runner ¶
Runner is an autogenerated mock type for the Runner type
func NewRunner ¶
NewRunner creates a new instance of Runner. 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 (*Runner) EXPECT ¶
func (_m *Runner) EXPECT() *Runner_Expecter
func (*Runner) HandleIPCRequestMessage ¶
func (_mock *Runner) HandleIPCRequestMessage(newMessage models.IPCMessageEnvelope) error
HandleIPCRequestMessage provides a mock function for the type Runner
func (*Runner) HandleStartSession ¶
HandleStartSession provides a mock function for the type Runner
func (*Runner) HandleStopSession ¶
HandleStopSession provides a mock function for the type Runner
func (*Runner) HandleSubmitCommands ¶
func (_mock *Runner) HandleSubmitCommands(commands []models.SessionInputCommand, onComplete func(ctx context.Context, err error)) error
HandleSubmitCommands provides a mock function for the type Runner
func (*Runner) StartSession ¶
StartSession provides a mock function for the type Runner
func (*Runner) StopSession ¶
StopSession provides a mock function for the type Runner
func (*Runner) SubmitCommands ¶
func (_mock *Runner) SubmitCommands(ctx context.Context, commands []models.SessionInputCommand) error
SubmitCommands provides a mock function for the type Runner
type Runner_Expecter ¶
type Runner_Expecter struct {
// contains filtered or unexported fields
}
func (*Runner_Expecter) HandleIPCRequestMessage ¶
func (_e *Runner_Expecter) HandleIPCRequestMessage(newMessage interface{}) *Runner_HandleIPCRequestMessage_Call
HandleIPCRequestMessage is a helper method to define mock.On call
- newMessage models.IPCMessageEnvelope
func (*Runner_Expecter) HandleStartSession ¶
func (_e *Runner_Expecter) HandleStartSession(onComplete interface{}) *Runner_HandleStartSession_Call
HandleStartSession is a helper method to define mock.On call
- onComplete func(ctx context.Context, err error)
func (*Runner_Expecter) HandleStopSession ¶
func (_e *Runner_Expecter) HandleStopSession(onComplete interface{}) *Runner_HandleStopSession_Call
HandleStopSession is a helper method to define mock.On call
- onComplete func(ctx context.Context, err error)
func (*Runner_Expecter) HandleSubmitCommands ¶
func (_e *Runner_Expecter) HandleSubmitCommands(commands interface{}, onComplete interface{}) *Runner_HandleSubmitCommands_Call
HandleSubmitCommands is a helper method to define mock.On call
- commands []models.SessionInputCommand
- onComplete func(ctx context.Context, err error)
func (*Runner_Expecter) Start ¶
func (_e *Runner_Expecter) Start(ctx interface{}) *Runner_Start_Call
Start is a helper method to define mock.On call
- ctx context.Context
func (*Runner_Expecter) StartSession ¶
func (_e *Runner_Expecter) StartSession(ctx interface{}, blocking interface{}) *Runner_StartSession_Call
StartSession is a helper method to define mock.On call
- ctx context.Context
- blocking bool
func (*Runner_Expecter) Stop ¶
func (_e *Runner_Expecter) Stop(ctx interface{}) *Runner_Stop_Call
Stop is a helper method to define mock.On call
- ctx context.Context
func (*Runner_Expecter) StopSession ¶
func (_e *Runner_Expecter) StopSession(ctx interface{}, blocking interface{}) *Runner_StopSession_Call
StopSession is a helper method to define mock.On call
- ctx context.Context
- blocking bool
func (*Runner_Expecter) SubmitCommands ¶
func (_e *Runner_Expecter) SubmitCommands(ctx interface{}, commands interface{}) *Runner_SubmitCommands_Call
SubmitCommands is a helper method to define mock.On call
- ctx context.Context
- commands []models.SessionInputCommand
type Runner_HandleIPCRequestMessage_Call ¶
Runner_HandleIPCRequestMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleIPCRequestMessage'
func (*Runner_HandleIPCRequestMessage_Call) Return ¶
func (_c *Runner_HandleIPCRequestMessage_Call) Return(err error) *Runner_HandleIPCRequestMessage_Call
func (*Runner_HandleIPCRequestMessage_Call) Run ¶
func (_c *Runner_HandleIPCRequestMessage_Call) Run(run func(newMessage models.IPCMessageEnvelope)) *Runner_HandleIPCRequestMessage_Call
func (*Runner_HandleIPCRequestMessage_Call) RunAndReturn ¶
func (_c *Runner_HandleIPCRequestMessage_Call) RunAndReturn(run func(newMessage models.IPCMessageEnvelope) error) *Runner_HandleIPCRequestMessage_Call
type Runner_HandleStartSession_Call ¶
Runner_HandleStartSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleStartSession'
func (*Runner_HandleStartSession_Call) Return ¶
func (_c *Runner_HandleStartSession_Call) Return(err error) *Runner_HandleStartSession_Call
func (*Runner_HandleStartSession_Call) Run ¶
func (_c *Runner_HandleStartSession_Call) Run(run func(onComplete func(ctx context.Context, err error))) *Runner_HandleStartSession_Call
func (*Runner_HandleStartSession_Call) RunAndReturn ¶
func (_c *Runner_HandleStartSession_Call) RunAndReturn(run func(onComplete func(ctx context.Context, err error)) error) *Runner_HandleStartSession_Call
type Runner_HandleStopSession_Call ¶
Runner_HandleStopSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleStopSession'
func (*Runner_HandleStopSession_Call) Return ¶
func (_c *Runner_HandleStopSession_Call) Return(err error) *Runner_HandleStopSession_Call
func (*Runner_HandleStopSession_Call) Run ¶
func (_c *Runner_HandleStopSession_Call) Run(run func(onComplete func(ctx context.Context, err error))) *Runner_HandleStopSession_Call
func (*Runner_HandleStopSession_Call) RunAndReturn ¶
func (_c *Runner_HandleStopSession_Call) RunAndReturn(run func(onComplete func(ctx context.Context, err error)) error) *Runner_HandleStopSession_Call
type Runner_HandleSubmitCommands_Call ¶
Runner_HandleSubmitCommands_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HandleSubmitCommands'
func (*Runner_HandleSubmitCommands_Call) Return ¶
func (_c *Runner_HandleSubmitCommands_Call) Return(err error) *Runner_HandleSubmitCommands_Call
func (*Runner_HandleSubmitCommands_Call) Run ¶
func (_c *Runner_HandleSubmitCommands_Call) Run(run func(commands []models.SessionInputCommand, onComplete func(ctx context.Context, err error))) *Runner_HandleSubmitCommands_Call
func (*Runner_HandleSubmitCommands_Call) RunAndReturn ¶
func (_c *Runner_HandleSubmitCommands_Call) RunAndReturn(run func(commands []models.SessionInputCommand, onComplete func(ctx context.Context, err error)) error) *Runner_HandleSubmitCommands_Call
type Runner_StartSession_Call ¶
Runner_StartSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StartSession'
func (*Runner_StartSession_Call) Return ¶
func (_c *Runner_StartSession_Call) Return(err error) *Runner_StartSession_Call
func (*Runner_StartSession_Call) Run ¶
func (_c *Runner_StartSession_Call) Run(run func(ctx context.Context, blocking bool)) *Runner_StartSession_Call
func (*Runner_StartSession_Call) RunAndReturn ¶
func (_c *Runner_StartSession_Call) RunAndReturn(run func(ctx context.Context, blocking bool) error) *Runner_StartSession_Call
type Runner_Start_Call ¶
Runner_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'
func (*Runner_Start_Call) Return ¶
func (_c *Runner_Start_Call) Return(err error) *Runner_Start_Call
func (*Runner_Start_Call) Run ¶
func (_c *Runner_Start_Call) Run(run func(ctx context.Context)) *Runner_Start_Call
func (*Runner_Start_Call) RunAndReturn ¶
func (_c *Runner_Start_Call) RunAndReturn(run func(ctx context.Context) error) *Runner_Start_Call
type Runner_StopSession_Call ¶
Runner_StopSession_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StopSession'
func (*Runner_StopSession_Call) Return ¶
func (_c *Runner_StopSession_Call) Return(err error) *Runner_StopSession_Call
func (*Runner_StopSession_Call) Run ¶
func (_c *Runner_StopSession_Call) Run(run func(ctx context.Context, blocking bool)) *Runner_StopSession_Call
func (*Runner_StopSession_Call) RunAndReturn ¶
func (_c *Runner_StopSession_Call) RunAndReturn(run func(ctx context.Context, blocking bool) error) *Runner_StopSession_Call
type Runner_Stop_Call ¶
Runner_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'
func (*Runner_Stop_Call) Return ¶
func (_c *Runner_Stop_Call) Return(err error) *Runner_Stop_Call
func (*Runner_Stop_Call) Run ¶
func (_c *Runner_Stop_Call) Run(run func(ctx context.Context)) *Runner_Stop_Call
func (*Runner_Stop_Call) RunAndReturn ¶
func (_c *Runner_Stop_Call) RunAndReturn(run func(ctx context.Context) error) *Runner_Stop_Call
type Runner_SubmitCommands_Call ¶
Runner_SubmitCommands_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubmitCommands'
func (*Runner_SubmitCommands_Call) Return ¶
func (_c *Runner_SubmitCommands_Call) Return(err error) *Runner_SubmitCommands_Call
func (*Runner_SubmitCommands_Call) Run ¶
func (_c *Runner_SubmitCommands_Call) Run(run func(ctx context.Context, commands []models.SessionInputCommand)) *Runner_SubmitCommands_Call
func (*Runner_SubmitCommands_Call) RunAndReturn ¶
func (_c *Runner_SubmitCommands_Call) RunAndReturn(run func(ctx context.Context, commands []models.SessionInputCommand) error) *Runner_SubmitCommands_Call