rpc

package
v3.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockPeer 

type MockPeer struct {
	mock.Mock
}

MockPeer is an autogenerated mock type for the Peer type

func NewMockPeer 

func NewMockPeer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockPeer

NewMockPeer creates a new instance of MockPeer. 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 (*MockPeer) Done 

func (_m *MockPeer) Done(c context.Context, workflowID string, state rpc.WorkflowState) error

Done provides a mock function with given fields: c, workflowID, state

func (*MockPeer) EXPECT 

func (_m *MockPeer) EXPECT() *MockPeer_Expecter

func (*MockPeer) EnqueueLog 

func (_m *MockPeer) EnqueueLog(logEntry *rpc.LogEntry)

EnqueueLog provides a mock function with given fields: logEntry

func (*MockPeer) Extend 

func (_m *MockPeer) Extend(c context.Context, workflowID string) error

Extend provides a mock function with given fields: c, workflowID

func (*MockPeer) Init 

func (_m *MockPeer) Init(c context.Context, workflowID string, state rpc.WorkflowState) error

Init provides a mock function with given fields: c, workflowID, state

func (*MockPeer) Next 

func (_m *MockPeer) Next(c context.Context, f rpc.Filter) (*rpc.Workflow, error)

Next provides a mock function with given fields: c, f

func (*MockPeer) RegisterAgent 

func (_m *MockPeer) RegisterAgent(ctx context.Context, info rpc.AgentInfo) (int64, error)

RegisterAgent provides a mock function with given fields: ctx, info

func (*MockPeer) ReportHealth 

func (_m *MockPeer) ReportHealth(c context.Context) error

ReportHealth provides a mock function with given fields: c

func (*MockPeer) UnregisterAgent 

func (_m *MockPeer) UnregisterAgent(ctx context.Context) error

UnregisterAgent provides a mock function with given fields: ctx

func (*MockPeer) Update 

func (_m *MockPeer) Update(c context.Context, workflowID string, state rpc.StepState) error

Update provides a mock function with given fields: c, workflowID, state

func (*MockPeer) Version 

func (_m *MockPeer) Version(c context.Context) (*rpc.Version, error)

Version provides a mock function with given fields: c

func (*MockPeer) Wait 

func (_m *MockPeer) Wait(c context.Context, workflowID string) error

Wait provides a mock function with given fields: c, workflowID

type MockPeer_Done_Call 

type MockPeer_Done_Call struct {
	*mock.Call
}

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

func (*MockPeer_Done_Call) Return 

func (_c *MockPeer_Done_Call) Return(_a0 error) *MockPeer_Done_Call

func (*MockPeer_Done_Call) Run 

func (_c *MockPeer_Done_Call) Run(run func(c context.Context, workflowID string, state rpc.WorkflowState)) *MockPeer_Done_Call

func (*MockPeer_Done_Call) RunAndReturn 

func (_c *MockPeer_Done_Call) RunAndReturn(run func(context.Context, string, rpc.WorkflowState) error) *MockPeer_Done_Call

type MockPeer_EnqueueLog_Call 

type MockPeer_EnqueueLog_Call struct {
	*mock.Call
}

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

func (*MockPeer_EnqueueLog_Call) Return 

func (_c *MockPeer_EnqueueLog_Call) Return() *MockPeer_EnqueueLog_Call

func (*MockPeer_EnqueueLog_Call) Run 

func (_c *MockPeer_EnqueueLog_Call) Run(run func(logEntry *rpc.LogEntry)) *MockPeer_EnqueueLog_Call

func (*MockPeer_EnqueueLog_Call) RunAndReturn 

func (_c *MockPeer_EnqueueLog_Call) RunAndReturn(run func(*rpc.LogEntry)) *MockPeer_EnqueueLog_Call

type MockPeer_Expecter 

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

func (*MockPeer_Expecter) Done 

func (_e *MockPeer_Expecter) Done(c interface{}, workflowID interface{}, state interface{}) *MockPeer_Done_Call

Done is a helper method to define mock.On call

  • c context.Context
  • workflowID string
  • state rpc.WorkflowState

func (*MockPeer_Expecter) EnqueueLog 

func (_e *MockPeer_Expecter) EnqueueLog(logEntry interface{}) *MockPeer_EnqueueLog_Call

EnqueueLog is a helper method to define mock.On call

  • logEntry *rpc.LogEntry

func (*MockPeer_Expecter) Extend 

func (_e *MockPeer_Expecter) Extend(c interface{}, workflowID interface{}) *MockPeer_Extend_Call

Extend is a helper method to define mock.On call

  • c context.Context
  • workflowID string

func (*MockPeer_Expecter) Init 

func (_e *MockPeer_Expecter) Init(c interface{}, workflowID interface{}, state interface{}) *MockPeer_Init_Call

Init is a helper method to define mock.On call

  • c context.Context
  • workflowID string
  • state rpc.WorkflowState

func (*MockPeer_Expecter) Next 

func (_e *MockPeer_Expecter) Next(c interface{}, f interface{}) *MockPeer_Next_Call

Next is a helper method to define mock.On call

  • c context.Context
  • f rpc.Filter

func (*MockPeer_Expecter) RegisterAgent 

func (_e *MockPeer_Expecter) RegisterAgent(ctx interface{}, info interface{}) *MockPeer_RegisterAgent_Call

RegisterAgent is a helper method to define mock.On call

  • ctx context.Context
  • info rpc.AgentInfo

func (*MockPeer_Expecter) ReportHealth 

func (_e *MockPeer_Expecter) ReportHealth(c interface{}) *MockPeer_ReportHealth_Call

ReportHealth is a helper method to define mock.On call

  • c context.Context

func (*MockPeer_Expecter) UnregisterAgent 

func (_e *MockPeer_Expecter) UnregisterAgent(ctx interface{}) *MockPeer_UnregisterAgent_Call

UnregisterAgent is a helper method to define mock.On call

  • ctx context.Context

func (*MockPeer_Expecter) Update 

func (_e *MockPeer_Expecter) Update(c interface{}, workflowID interface{}, state interface{}) *MockPeer_Update_Call

Update is a helper method to define mock.On call

  • c context.Context
  • workflowID string
  • state rpc.StepState

func (*MockPeer_Expecter) Version 

func (_e *MockPeer_Expecter) Version(c interface{}) *MockPeer_Version_Call

Version is a helper method to define mock.On call

  • c context.Context

func (*MockPeer_Expecter) Wait 

func (_e *MockPeer_Expecter) Wait(c interface{}, workflowID interface{}) *MockPeer_Wait_Call

Wait is a helper method to define mock.On call

  • c context.Context
  • workflowID string

type MockPeer_Extend_Call 

type MockPeer_Extend_Call struct {
	*mock.Call
}

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

func (*MockPeer_Extend_Call) Return 

func (_c *MockPeer_Extend_Call) Return(_a0 error) *MockPeer_Extend_Call

func (*MockPeer_Extend_Call) Run 

func (_c *MockPeer_Extend_Call) Run(run func(c context.Context, workflowID string)) *MockPeer_Extend_Call

func (*MockPeer_Extend_Call) RunAndReturn 

func (_c *MockPeer_Extend_Call) RunAndReturn(run func(context.Context, string) error) *MockPeer_Extend_Call

type MockPeer_Init_Call 

type MockPeer_Init_Call struct {
	*mock.Call
}

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

func (*MockPeer_Init_Call) Return 

func (_c *MockPeer_Init_Call) Return(_a0 error) *MockPeer_Init_Call

func (*MockPeer_Init_Call) Run 

func (_c *MockPeer_Init_Call) Run(run func(c context.Context, workflowID string, state rpc.WorkflowState)) *MockPeer_Init_Call

func (*MockPeer_Init_Call) RunAndReturn 

func (_c *MockPeer_Init_Call) RunAndReturn(run func(context.Context, string, rpc.WorkflowState) error) *MockPeer_Init_Call

type MockPeer_Next_Call 

type MockPeer_Next_Call struct {
	*mock.Call
}

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

func (*MockPeer_Next_Call) Return 

func (_c *MockPeer_Next_Call) Return(_a0 *rpc.Workflow, _a1 error) *MockPeer_Next_Call

func (*MockPeer_Next_Call) Run 

func (_c *MockPeer_Next_Call) Run(run func(c context.Context, f rpc.Filter)) *MockPeer_Next_Call

func (*MockPeer_Next_Call) RunAndReturn 

func (_c *MockPeer_Next_Call) RunAndReturn(run func(context.Context, rpc.Filter) (*rpc.Workflow, error)) *MockPeer_Next_Call

type MockPeer_RegisterAgent_Call 

type MockPeer_RegisterAgent_Call struct {
	*mock.Call
}

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

func (*MockPeer_RegisterAgent_Call) Return 

func (_c *MockPeer_RegisterAgent_Call) Return(_a0 int64, _a1 error) *MockPeer_RegisterAgent_Call

func (*MockPeer_RegisterAgent_Call) Run 

func (_c *MockPeer_RegisterAgent_Call) Run(run func(ctx context.Context, info rpc.AgentInfo)) *MockPeer_RegisterAgent_Call

func (*MockPeer_RegisterAgent_Call) RunAndReturn 

func (_c *MockPeer_RegisterAgent_Call) RunAndReturn(run func(context.Context, rpc.AgentInfo) (int64, error)) *MockPeer_RegisterAgent_Call

type MockPeer_ReportHealth_Call 

type MockPeer_ReportHealth_Call struct {
	*mock.Call
}

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

func (*MockPeer_ReportHealth_Call) Return 

func (_c *MockPeer_ReportHealth_Call) Return(_a0 error) *MockPeer_ReportHealth_Call

func (*MockPeer_ReportHealth_Call) Run 

func (_c *MockPeer_ReportHealth_Call) Run(run func(c context.Context)) *MockPeer_ReportHealth_Call

func (*MockPeer_ReportHealth_Call) RunAndReturn 

func (_c *MockPeer_ReportHealth_Call) RunAndReturn(run func(context.Context) error) *MockPeer_ReportHealth_Call

type MockPeer_UnregisterAgent_Call 

type MockPeer_UnregisterAgent_Call struct {
	*mock.Call
}

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

func (*MockPeer_UnregisterAgent_Call) Return 

func (_c *MockPeer_UnregisterAgent_Call) Return(_a0 error) *MockPeer_UnregisterAgent_Call

func (*MockPeer_UnregisterAgent_Call) Run 

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

func (*MockPeer_UnregisterAgent_Call) RunAndReturn 

func (_c *MockPeer_UnregisterAgent_Call) RunAndReturn(run func(context.Context) error) *MockPeer_UnregisterAgent_Call

type MockPeer_Update_Call 

type MockPeer_Update_Call struct {
	*mock.Call
}

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

func (*MockPeer_Update_Call) Return 

func (_c *MockPeer_Update_Call) Return(_a0 error) *MockPeer_Update_Call

func (*MockPeer_Update_Call) Run 

func (_c *MockPeer_Update_Call) Run(run func(c context.Context, workflowID string, state rpc.StepState)) *MockPeer_Update_Call

func (*MockPeer_Update_Call) RunAndReturn 

func (_c *MockPeer_Update_Call) RunAndReturn(run func(context.Context, string, rpc.StepState) error) *MockPeer_Update_Call

type MockPeer_Version_Call 

type MockPeer_Version_Call struct {
	*mock.Call
}

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

func (*MockPeer_Version_Call) Return 

func (_c *MockPeer_Version_Call) Return(_a0 *rpc.Version, _a1 error) *MockPeer_Version_Call

func (*MockPeer_Version_Call) Run 

func (_c *MockPeer_Version_Call) Run(run func(c context.Context)) *MockPeer_Version_Call

func (*MockPeer_Version_Call) RunAndReturn 

func (_c *MockPeer_Version_Call) RunAndReturn(run func(context.Context) (*rpc.Version, error)) *MockPeer_Version_Call

type MockPeer_Wait_Call 

type MockPeer_Wait_Call struct {
	*mock.Call
}

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

func (*MockPeer_Wait_Call) Return 

func (_c *MockPeer_Wait_Call) Return(_a0 error) *MockPeer_Wait_Call

func (*MockPeer_Wait_Call) Run 

func (_c *MockPeer_Wait_Call) Run(run func(c context.Context, workflowID string)) *MockPeer_Wait_Call

func (*MockPeer_Wait_Call) RunAndReturn 

func (_c *MockPeer_Wait_Call) RunAndReturn(run func(context.Context, string) error) *MockPeer_Wait_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.