mocks

Apr 8, 2026

Changes in this version

+ type MockEventBusRuntime struct

+ func NewMockEventBusRuntime(ctrl *gomock.Controller) *MockEventBusRuntime

+ func (m *MockEventBusRuntime) Approve(arg0 context.Context, arg1 string, arg2 types.ApprovalStatus) error

+ func (m *MockEventBusRuntime) Close()

+ func (m *MockEventBusRuntime) EXPECT() *MockEventBusRuntimeMockRecorder

+ func (m *MockEventBusRuntime) Execute(arg0 context.Context, arg1 *runtime.ExecuteRequest) (*types.AgentResponse, error)

+ func (m *MockEventBusRuntime) ExecuteStream(arg0 context.Context, arg1 *runtime.ExecuteRequest) (chan *types.AgentEvent, error)

+ func (m *MockEventBusRuntime) GetEventBus() eventbus.EventBus

+ func (m *MockEventBusRuntime) SetEventBus(arg0 eventbus.EventBus)

+ type MockEventBusRuntimeMockRecorder struct

+ func (mr *MockEventBusRuntimeMockRecorder) Approve(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockEventBusRuntimeMockRecorder) Close() *gomock.Call

+ func (mr *MockEventBusRuntimeMockRecorder) Execute(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventBusRuntimeMockRecorder) ExecuteStream(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventBusRuntimeMockRecorder) GetEventBus() *gomock.Call

+ func (mr *MockEventBusRuntimeMockRecorder) SetEventBus(arg0 interface{}) *gomock.Call

+ type MockWorkerRuntime struct

+ func NewMockWorkerRuntime(ctrl *gomock.Controller) *MockWorkerRuntime

+ func (m *MockWorkerRuntime) Approve(arg0 context.Context, arg1 string, arg2 types.ApprovalStatus) error

+ func (m *MockWorkerRuntime) Close()

+ func (m *MockWorkerRuntime) EXPECT() *MockWorkerRuntimeMockRecorder

+ func (m *MockWorkerRuntime) Execute(arg0 context.Context, arg1 *runtime.ExecuteRequest) (*types.AgentResponse, error)

+ func (m *MockWorkerRuntime) ExecuteStream(arg0 context.Context, arg1 *runtime.ExecuteRequest) (chan *types.AgentEvent, error)

+ func (m *MockWorkerRuntime) Start(arg0 context.Context) error

+ func (m *MockWorkerRuntime) Stop()

+ type MockWorkerRuntimeMockRecorder struct

+ func (mr *MockWorkerRuntimeMockRecorder) Approve(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockWorkerRuntimeMockRecorder) Close() *gomock.Call

+ func (mr *MockWorkerRuntimeMockRecorder) Execute(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockWorkerRuntimeMockRecorder) ExecuteStream(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockWorkerRuntimeMockRecorder) Start(arg0 interface{}) *gomock.Call

+ func (mr *MockWorkerRuntimeMockRecorder) Stop() *gomock.Call

Apr 5, 2026

Changes in this version

+ type MockRuntime struct

+ func NewMockRuntime(ctrl *gomock.Controller) *MockRuntime

+ func (m *MockRuntime) Approve(arg0 context.Context, arg1 string, arg2 types.ApprovalStatus) error

+ func (m *MockRuntime) Close()

+ func (m *MockRuntime) EXPECT() *MockRuntimeMockRecorder

+ func (m *MockRuntime) Execute(arg0 context.Context, arg1 *runtime.ExecuteRequest) (*types.AgentResponse, error)

+ func (m *MockRuntime) ExecuteStream(arg0 context.Context, arg1 *runtime.ExecuteRequest) (chan *types.AgentEvent, error)

+ func (m *MockRuntime) GetEventBus() eventbus.EventBus

+ func (m *MockRuntime) SetEventBus(arg0 eventbus.EventBus)

+ func (m *MockRuntime) Start(arg0 context.Context) error

+ func (m *MockRuntime) Stop()

+ type MockRuntimeMockRecorder struct

+ func (mr *MockRuntimeMockRecorder) Approve(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockRuntimeMockRecorder) Close() *gomock.Call

+ func (mr *MockRuntimeMockRecorder) Execute(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRuntimeMockRecorder) ExecuteStream(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockRuntimeMockRecorder) GetEventBus() *gomock.Call

+ func (mr *MockRuntimeMockRecorder) SetEventBus(arg0 interface{}) *gomock.Call

+ func (mr *MockRuntimeMockRecorder) Start(arg0 interface{}) *gomock.Call

+ func (mr *MockRuntimeMockRecorder) Stop() *gomock.Call