mock_manager

Documentation

Index

• type MockManagerClient
  • func NewMockManagerClient(t interface{ ... }) *MockManagerClient
  • func (_m *MockManagerClient) Assign(ctx context.Context, pchannel types.PChannelInfoAssigned) error
  • func (_m *MockManagerClient) Close()
  • func (_m *MockManagerClient) CollectAllStatus(ctx context.Context) (map[int64]*types.StreamingNodeStatus, error)
  • func (_m *MockManagerClient) EXPECT() *MockManagerClient_Expecter
  • func (_m *MockManagerClient) Remove(ctx context.Context, pchannel types.PChannelInfoAssigned) error
  • func (_m *MockManagerClient) WatchNodeChanged(ctx context.Context) (<-chan struct{}, error)
• type MockManagerClient_Assign_Call
  • func (_c *MockManagerClient_Assign_Call) Return(_a0 error) *MockManagerClient_Assign_Call
  • func (_c *MockManagerClient_Assign_Call) Run(run func(ctx context.Context, pchannel types.PChannelInfoAssigned)) *MockManagerClient_Assign_Call
  • func (_c *MockManagerClient_Assign_Call) RunAndReturn(run func(context.Context, types.PChannelInfoAssigned) error) *MockManagerClient_Assign_Call
• type MockManagerClient_Close_Call
  • func (_c *MockManagerClient_Close_Call) Return() *MockManagerClient_Close_Call
  • func (_c *MockManagerClient_Close_Call) Run(run func()) *MockManagerClient_Close_Call
  • func (_c *MockManagerClient_Close_Call) RunAndReturn(run func()) *MockManagerClient_Close_Call
• type MockManagerClient_CollectAllStatus_Call
  • func (_c *MockManagerClient_CollectAllStatus_Call) Return(_a0 map[int64]*types.StreamingNodeStatus, _a1 error) *MockManagerClient_CollectAllStatus_Call
  • func (_c *MockManagerClient_CollectAllStatus_Call) Run(run func(ctx context.Context)) *MockManagerClient_CollectAllStatus_Call
  • func (_c *MockManagerClient_CollectAllStatus_Call) RunAndReturn(run func(context.Context) (map[int64]*types.StreamingNodeStatus, error)) *MockManagerClient_CollectAllStatus_Call
• type MockManagerClient_Expecter
  • func (_e *MockManagerClient_Expecter) Assign(ctx interface{}, pchannel interface{}) *MockManagerClient_Assign_Call
  • func (_e *MockManagerClient_Expecter) Close() *MockManagerClient_Close_Call
  • func (_e *MockManagerClient_Expecter) CollectAllStatus(ctx interface{}) *MockManagerClient_CollectAllStatus_Call
  • func (_e *MockManagerClient_Expecter) Remove(ctx interface{}, pchannel interface{}) *MockManagerClient_Remove_Call
  • func (_e *MockManagerClient_Expecter) WatchNodeChanged(ctx interface{}) *MockManagerClient_WatchNodeChanged_Call
• type MockManagerClient_Remove_Call
  • func (_c *MockManagerClient_Remove_Call) Return(_a0 error) *MockManagerClient_Remove_Call
  • func (_c *MockManagerClient_Remove_Call) Run(run func(ctx context.Context, pchannel types.PChannelInfoAssigned)) *MockManagerClient_Remove_Call
  • func (_c *MockManagerClient_Remove_Call) RunAndReturn(run func(context.Context, types.PChannelInfoAssigned) error) *MockManagerClient_Remove_Call
• type MockManagerClient_WatchNodeChanged_Call
  • func (_c *MockManagerClient_WatchNodeChanged_Call) Return(_a0 <-chan struct{}, _a1 error) *MockManagerClient_WatchNodeChanged_Call
  • func (_c *MockManagerClient_WatchNodeChanged_Call) Run(run func(ctx context.Context)) *MockManagerClient_WatchNodeChanged_Call
  • func (_c *MockManagerClient_WatchNodeChanged_Call) RunAndReturn(run func(context.Context) (<-chan struct{}, error)) *MockManagerClient_WatchNodeChanged_Call

Types

type MockManagerClient

type MockManagerClient struct {
	mock.Mock
}

MockManagerClient is an autogenerated mock type for the ManagerClient type

func NewMockManagerClient

func NewMockManagerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockManagerClient

NewMockManagerClient creates a new instance of MockManagerClient. 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 (*MockManagerClient) Assign

func (_m *MockManagerClient) Assign(ctx context.Context, pchannel types.PChannelInfoAssigned) error

Assign provides a mock function with given fields: ctx, pchannel

func (*MockManagerClient) Close

func (_m *MockManagerClient) Close()

Close provides a mock function with given fields:

func (*MockManagerClient) CollectAllStatus

func (_m *MockManagerClient) CollectAllStatus(ctx context.Context) (map[int64]*types.StreamingNodeStatus, error)

CollectAllStatus provides a mock function with given fields: ctx

func (*MockManagerClient) EXPECT

func (_m *MockManagerClient) EXPECT() *MockManagerClient_Expecter

func (*MockManagerClient) Remove

func (_m *MockManagerClient) Remove(ctx context.Context, pchannel types.PChannelInfoAssigned) error

Remove provides a mock function with given fields: ctx, pchannel

func (*MockManagerClient) WatchNodeChanged

func (_m *MockManagerClient) WatchNodeChanged(ctx context.Context) (<-chan struct{}, error)

WatchNodeChanged provides a mock function with given fields: ctx

type MockManagerClient_Assign_Call

type MockManagerClient_Assign_Call struct {
	*mock.Call
}

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

func (*MockManagerClient_Assign_Call) Return

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

func (*MockManagerClient_Assign_Call) Run

func (_c *MockManagerClient_Assign_Call) Run(run func(ctx context.Context, pchannel types.PChannelInfoAssigned)) *MockManagerClient_Assign_Call

func (*MockManagerClient_Assign_Call) RunAndReturn

func (_c *MockManagerClient_Assign_Call) RunAndReturn(run func(context.Context, types.PChannelInfoAssigned) error) *MockManagerClient_Assign_Call

type MockManagerClient_Close_Call

type MockManagerClient_Close_Call struct {
	*mock.Call
}

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

func (*MockManagerClient_Close_Call) Return

func (_c *MockManagerClient_Close_Call) Return() *MockManagerClient_Close_Call

func (*MockManagerClient_Close_Call) Run

func (_c *MockManagerClient_Close_Call) Run(run func()) *MockManagerClient_Close_Call

func (*MockManagerClient_Close_Call) RunAndReturn

func (_c *MockManagerClient_Close_Call) RunAndReturn(run func()) *MockManagerClient_Close_Call

type MockManagerClient_CollectAllStatus_Call

type MockManagerClient_CollectAllStatus_Call struct {
	*mock.Call
}

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

func (*MockManagerClient_CollectAllStatus_Call) Return

func (_c *MockManagerClient_CollectAllStatus_Call) Return(_a0 map[int64]*types.StreamingNodeStatus, _a1 error) *MockManagerClient_CollectAllStatus_Call

func (*MockManagerClient_CollectAllStatus_Call) Run

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

func (*MockManagerClient_CollectAllStatus_Call) RunAndReturn

func (_c *MockManagerClient_CollectAllStatus_Call) RunAndReturn(run func(context.Context) (map[int64]*types.StreamingNodeStatus, error)) *MockManagerClient_CollectAllStatus_Call

type MockManagerClient_Expecter

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

func (*MockManagerClient_Expecter) Assign

func (_e *MockManagerClient_Expecter) Assign(ctx interface{}, pchannel interface{}) *MockManagerClient_Assign_Call

Assign is a helper method to define mock.On call

• ctx context.Context
• pchannel types.PChannelInfoAssigned

func (*MockManagerClient_Expecter) Close

func (_e *MockManagerClient_Expecter) Close() *MockManagerClient_Close_Call

Close is a helper method to define mock.On call

func (*MockManagerClient_Expecter) CollectAllStatus

func (_e *MockManagerClient_Expecter) CollectAllStatus(ctx interface{}) *MockManagerClient_CollectAllStatus_Call

CollectAllStatus is a helper method to define mock.On call

• ctx context.Context

func (*MockManagerClient_Expecter) Remove

func (_e *MockManagerClient_Expecter) Remove(ctx interface{}, pchannel interface{}) *MockManagerClient_Remove_Call

Remove is a helper method to define mock.On call

• ctx context.Context
• pchannel types.PChannelInfoAssigned

func (*MockManagerClient_Expecter) WatchNodeChanged

func (_e *MockManagerClient_Expecter) WatchNodeChanged(ctx interface{}) *MockManagerClient_WatchNodeChanged_Call

WatchNodeChanged is a helper method to define mock.On call

• ctx context.Context

type MockManagerClient_Remove_Call

type MockManagerClient_Remove_Call struct {
	*mock.Call
}

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

func (*MockManagerClient_Remove_Call) Return

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

func (*MockManagerClient_Remove_Call) Run

func (_c *MockManagerClient_Remove_Call) Run(run func(ctx context.Context, pchannel types.PChannelInfoAssigned)) *MockManagerClient_Remove_Call

func (*MockManagerClient_Remove_Call) RunAndReturn

func (_c *MockManagerClient_Remove_Call) RunAndReturn(run func(context.Context, types.PChannelInfoAssigned) error) *MockManagerClient_Remove_Call

type MockManagerClient_WatchNodeChanged_Call

type MockManagerClient_WatchNodeChanged_Call struct {
	*mock.Call
}

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

func (*MockManagerClient_WatchNodeChanged_Call) Return

func (_c *MockManagerClient_WatchNodeChanged_Call) Return(_a0 <-chan struct{}, _a1 error) *MockManagerClient_WatchNodeChanged_Call

func (*MockManagerClient_WatchNodeChanged_Call) Run

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

func (*MockManagerClient_WatchNodeChanged_Call) RunAndReturn

func (_c *MockManagerClient_WatchNodeChanged_Call) RunAndReturn(run func(context.Context) (<-chan struct{}, error)) *MockManagerClient_WatchNodeChanged_Call