channel

Documentation

Index

• func NewOpRunner(channel string, pipelineParams *util.PipelineParams, releaseF releaseFunc, ...) *opRunner
• type ChannelManager
• type ChannelManagerImpl
  • func NewChannelManager(pipelineParams *util.PipelineParams, fgManager pipeline.FlowgraphManager) *ChannelManagerImpl
  • func (m *ChannelManagerImpl) Close()
  • func (m *ChannelManagerImpl) GetProgress(info *datapb.ChannelWatchInfo) *datapb.ChannelOperationProgressResponse
  • func (m *ChannelManagerImpl) Start()
  • func (m *ChannelManagerImpl) Submit(info *datapb.ChannelWatchInfo) error
• type MockChannelManager
  • func NewMockChannelManager(t interface{ ... }) *MockChannelManager
  • func (_m *MockChannelManager) Close()
  • func (_m *MockChannelManager) EXPECT() *MockChannelManager_Expecter
  • func (_m *MockChannelManager) GetProgress(info *datapb.ChannelWatchInfo) *datapb.ChannelOperationProgressResponse
  • func (_m *MockChannelManager) Start()
  • func (_m *MockChannelManager) Submit(info *datapb.ChannelWatchInfo) error
• type MockChannelManager_Close_Call
  • func (_c *MockChannelManager_Close_Call) Return() *MockChannelManager_Close_Call
  • func (_c *MockChannelManager_Close_Call) Run(run func()) *MockChannelManager_Close_Call
  • func (_c *MockChannelManager_Close_Call) RunAndReturn(run func()) *MockChannelManager_Close_Call
• type MockChannelManager_Expecter
  • func (_e *MockChannelManager_Expecter) Close() *MockChannelManager_Close_Call
  • func (_e *MockChannelManager_Expecter) GetProgress(info interface{}) *MockChannelManager_GetProgress_Call
  • func (_e *MockChannelManager_Expecter) Start() *MockChannelManager_Start_Call
  • func (_e *MockChannelManager_Expecter) Submit(info interface{}) *MockChannelManager_Submit_Call
• type MockChannelManager_GetProgress_Call
  • func (_c *MockChannelManager_GetProgress_Call) Return(_a0 *datapb.ChannelOperationProgressResponse) *MockChannelManager_GetProgress_Call
  • func (_c *MockChannelManager_GetProgress_Call) Run(run func(info *datapb.ChannelWatchInfo)) *MockChannelManager_GetProgress_Call
  • func (_c *MockChannelManager_GetProgress_Call) RunAndReturn(run func(*datapb.ChannelWatchInfo) *datapb.ChannelOperationProgressResponse) *MockChannelManager_GetProgress_Call
• type MockChannelManager_Start_Call
  • func (_c *MockChannelManager_Start_Call) Return() *MockChannelManager_Start_Call
  • func (_c *MockChannelManager_Start_Call) Run(run func()) *MockChannelManager_Start_Call
  • func (_c *MockChannelManager_Start_Call) RunAndReturn(run func()) *MockChannelManager_Start_Call
• type MockChannelManager_Submit_Call
  • func (_c *MockChannelManager_Submit_Call) Return(_a0 error) *MockChannelManager_Submit_Call
  • func (_c *MockChannelManager_Submit_Call) Run(run func(info *datapb.ChannelWatchInfo)) *MockChannelManager_Submit_Call
  • func (_c *MockChannelManager_Submit_Call) RunAndReturn(run func(*datapb.ChannelWatchInfo) error) *MockChannelManager_Submit_Call

Functions

func NewOpRunner

func NewOpRunner(channel string, pipelineParams *util.PipelineParams, releaseF releaseFunc, watchF watchFunc, resultCh chan *opState) *opRunner

Types

type ChannelManager

type ChannelManager interface {
	Submit(info *datapb.ChannelWatchInfo) error
	GetProgress(info *datapb.ChannelWatchInfo) *datapb.ChannelOperationProgressResponse
	Close()
	Start()
}

type ChannelManagerImpl

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

func NewChannelManager

func NewChannelManager(pipelineParams *util.PipelineParams, fgManager pipeline.FlowgraphManager) *ChannelManagerImpl

func (*ChannelManagerImpl) Close

func (m *ChannelManagerImpl) Close()

func (*ChannelManagerImpl) GetProgress

func (m *ChannelManagerImpl) GetProgress(info *datapb.ChannelWatchInfo) *datapb.ChannelOperationProgressResponse

func (*ChannelManagerImpl) Start

func (m *ChannelManagerImpl) Start()

func (*ChannelManagerImpl) Submit

func (m *ChannelManagerImpl) Submit(info *datapb.ChannelWatchInfo) error

type MockChannelManager

type MockChannelManager struct {
	mock.Mock
}

MockChannelManager is an autogenerated mock type for the ChannelManager type

func NewMockChannelManager

func NewMockChannelManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockChannelManager

NewMockChannelManager creates a new instance of MockChannelManager. 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 (*MockChannelManager) Close

func (_m *MockChannelManager) Close()

Close provides a mock function with given fields:

func (*MockChannelManager) EXPECT

func (_m *MockChannelManager) EXPECT() *MockChannelManager_Expecter

func (*MockChannelManager) GetProgress

func (_m *MockChannelManager) GetProgress(info *datapb.ChannelWatchInfo) *datapb.ChannelOperationProgressResponse

GetProgress provides a mock function with given fields: info

func (*MockChannelManager) Start

func (_m *MockChannelManager) Start()

Start provides a mock function with given fields:

func (*MockChannelManager) Submit

func (_m *MockChannelManager) Submit(info *datapb.ChannelWatchInfo) error

Submit provides a mock function with given fields: info

type MockChannelManager_Close_Call

type MockChannelManager_Close_Call struct {
	*mock.Call
}

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

func (*MockChannelManager_Close_Call) Return

func (_c *MockChannelManager_Close_Call) Return() *MockChannelManager_Close_Call

func (*MockChannelManager_Close_Call) Run

func (_c *MockChannelManager_Close_Call) Run(run func()) *MockChannelManager_Close_Call

func (*MockChannelManager_Close_Call) RunAndReturn

func (_c *MockChannelManager_Close_Call) RunAndReturn(run func()) *MockChannelManager_Close_Call

type MockChannelManager_Expecter

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

func (*MockChannelManager_Expecter) Close

func (_e *MockChannelManager_Expecter) Close() *MockChannelManager_Close_Call

Close is a helper method to define mock.On call

func (*MockChannelManager_Expecter) GetProgress

func (_e *MockChannelManager_Expecter) GetProgress(info interface{}) *MockChannelManager_GetProgress_Call

GetProgress is a helper method to define mock.On call

• info *datapb.ChannelWatchInfo

func (*MockChannelManager_Expecter) Start

func (_e *MockChannelManager_Expecter) Start() *MockChannelManager_Start_Call

Start is a helper method to define mock.On call

func (*MockChannelManager_Expecter) Submit

func (_e *MockChannelManager_Expecter) Submit(info interface{}) *MockChannelManager_Submit_Call

Submit is a helper method to define mock.On call

• info *datapb.ChannelWatchInfo

type MockChannelManager_GetProgress_Call

type MockChannelManager_GetProgress_Call struct {
	*mock.Call
}

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

func (*MockChannelManager_GetProgress_Call) Return

func (_c *MockChannelManager_GetProgress_Call) Return(_a0 *datapb.ChannelOperationProgressResponse) *MockChannelManager_GetProgress_Call

func (*MockChannelManager_GetProgress_Call) Run

func (_c *MockChannelManager_GetProgress_Call) Run(run func(info *datapb.ChannelWatchInfo)) *MockChannelManager_GetProgress_Call

func (*MockChannelManager_GetProgress_Call) RunAndReturn

func (_c *MockChannelManager_GetProgress_Call) RunAndReturn(run func(*datapb.ChannelWatchInfo) *datapb.ChannelOperationProgressResponse) *MockChannelManager_GetProgress_Call

type MockChannelManager_Start_Call

type MockChannelManager_Start_Call struct {
	*mock.Call
}

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

func (*MockChannelManager_Start_Call) Return

func (_c *MockChannelManager_Start_Call) Return() *MockChannelManager_Start_Call

func (*MockChannelManager_Start_Call) Run

func (_c *MockChannelManager_Start_Call) Run(run func()) *MockChannelManager_Start_Call

func (*MockChannelManager_Start_Call) RunAndReturn

func (_c *MockChannelManager_Start_Call) RunAndReturn(run func()) *MockChannelManager_Start_Call

type MockChannelManager_Submit_Call

type MockChannelManager_Submit_Call struct {
	*mock.Call
}

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

func (*MockChannelManager_Submit_Call) Return

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

func (*MockChannelManager_Submit_Call) Run

func (_c *MockChannelManager_Submit_Call) Run(run func(info *datapb.ChannelWatchInfo)) *MockChannelManager_Submit_Call

func (*MockChannelManager_Submit_Call) RunAndReturn

func (_c *MockChannelManager_Submit_Call) RunAndReturn(run func(*datapb.ChannelWatchInfo) error) *MockChannelManager_Submit_Call