mock_capture

Documentation

Overview

Package mock_capture is a generated GoMock package.

Index

• type MockCapture
  • func NewMockCapture(ctrl *gomock.Controller) *MockCapture
  • func (m *MockCapture) Close()
  • func (m *MockCapture) Drain() <-chan struct{}
  • func (m *MockCapture) EXPECT() *MockCaptureMockRecorder
  • func (m *MockCapture) GetEtcdClient() etcd.CDCEtcdClient
  • func (m *MockCapture) GetOwner() (owner.Owner, error)
  • func (m *MockCapture) GetOwnerCaptureInfo(ctx context.Context) (*model.CaptureInfo, error)
  • func (m *MockCapture) GetUpstreamInfo(arg0 context.Context, arg1 model.UpstreamID, arg2 string) (*model.UpstreamInfo, error)
  • func (m *MockCapture) GetUpstreamManager() (*upstream.Manager, error)
  • func (m *MockCapture) Info() (model.CaptureInfo, error)
  • func (m *MockCapture) IsOwner() bool
  • func (m *MockCapture) IsReady() bool
  • func (m *MockCapture) Liveness() model.Liveness
  • func (m *MockCapture) Run(ctx context.Context) error
  • func (m *MockCapture) StatusProvider() owner.StatusProvider
  • func (m *MockCapture) WriteDebugInfo(ctx context.Context, w io.Writer)
• type MockCaptureMockRecorder
  • func (mr *MockCaptureMockRecorder) Close() *gomock.Call
  • func (mr *MockCaptureMockRecorder) Drain() *gomock.Call
  • func (mr *MockCaptureMockRecorder) GetEtcdClient() *gomock.Call
  • func (mr *MockCaptureMockRecorder) GetOwner() *gomock.Call
  • func (mr *MockCaptureMockRecorder) GetOwnerCaptureInfo(ctx interface{}) *gomock.Call
  • func (mr *MockCaptureMockRecorder) GetUpstreamInfo(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockCaptureMockRecorder) GetUpstreamManager() *gomock.Call
  • func (mr *MockCaptureMockRecorder) Info() *gomock.Call
  • func (mr *MockCaptureMockRecorder) IsOwner() *gomock.Call
  • func (mr *MockCaptureMockRecorder) IsReady() *gomock.Call
  • func (mr *MockCaptureMockRecorder) Liveness() *gomock.Call
  • func (mr *MockCaptureMockRecorder) Run(ctx interface{}) *gomock.Call
  • func (mr *MockCaptureMockRecorder) StatusProvider() *gomock.Call
  • func (mr *MockCaptureMockRecorder) WriteDebugInfo(ctx, w interface{}) *gomock.Call

Types

type MockCapture

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

MockCapture is a mock of Capture interface.

func NewMockCapture

func NewMockCapture(ctrl *gomock.Controller) *MockCapture

NewMockCapture creates a new mock instance.

func (*MockCapture) Close

func (m *MockCapture) Close()

Close mocks base method.

func (*MockCapture) Drain

func (m *MockCapture) Drain() <-chan struct{}

Drain mocks base method.

func (*MockCapture) EXPECT

func (m *MockCapture) EXPECT() *MockCaptureMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCapture) GetEtcdClient

func (m *MockCapture) GetEtcdClient() etcd.CDCEtcdClient

GetEtcdClient mocks base method.

func (*MockCapture) GetOwner

func (m *MockCapture) GetOwner() (owner.Owner, error)

GetOwner mocks base method.

func (*MockCapture) GetOwnerCaptureInfo

func (m *MockCapture) GetOwnerCaptureInfo(ctx context.Context) (*model.CaptureInfo, error)

GetOwnerCaptureInfo mocks base method.

func (*MockCapture) GetUpstreamInfo

func (m *MockCapture) GetUpstreamInfo(arg0 context.Context, arg1 model.UpstreamID, arg2 string) (*model.UpstreamInfo, error)

GetUpstreamInfo mocks base method.

func (*MockCapture) GetUpstreamManager

func (m *MockCapture) GetUpstreamManager() (*upstream.Manager, error)

GetUpstreamManager mocks base method.

func (*MockCapture) Info

func (m *MockCapture) Info() (model.CaptureInfo, error)

Info mocks base method.

func (*MockCapture) IsOwner

func (m *MockCapture) IsOwner() bool

IsOwner mocks base method.

func (*MockCapture) IsReady

func (m *MockCapture) IsReady() bool

IsReady mocks base method.

func (*MockCapture) Liveness

func (m *MockCapture) Liveness() model.Liveness

Liveness mocks base method.

func (*MockCapture) Run

func (m *MockCapture) Run(ctx context.Context) error

Run mocks base method.

func (*MockCapture) StatusProvider

func (m *MockCapture) StatusProvider() owner.StatusProvider

StatusProvider mocks base method.

func (*MockCapture) WriteDebugInfo

func (m *MockCapture) WriteDebugInfo(ctx context.Context, w io.Writer)

WriteDebugInfo mocks base method.

type MockCaptureMockRecorder

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

MockCaptureMockRecorder is the mock recorder for MockCapture.

func (*MockCaptureMockRecorder) Close

func (mr *MockCaptureMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockCaptureMockRecorder) Drain

func (mr *MockCaptureMockRecorder) Drain() *gomock.Call

Drain indicates an expected call of Drain.

func (*MockCaptureMockRecorder) GetEtcdClient

func (mr *MockCaptureMockRecorder) GetEtcdClient() *gomock.Call

GetEtcdClient indicates an expected call of GetEtcdClient.

func (*MockCaptureMockRecorder) GetOwner

func (mr *MockCaptureMockRecorder) GetOwner() *gomock.Call

GetOwner indicates an expected call of GetOwner.

func (*MockCaptureMockRecorder) GetOwnerCaptureInfo

func (mr *MockCaptureMockRecorder) GetOwnerCaptureInfo(ctx interface{}) *gomock.Call

GetOwnerCaptureInfo indicates an expected call of GetOwnerCaptureInfo.

func (*MockCaptureMockRecorder) GetUpstreamInfo

func (mr *MockCaptureMockRecorder) GetUpstreamInfo(arg0, arg1, arg2 interface{}) *gomock.Call

GetUpstreamInfo indicates an expected call of GetUpstreamInfo.

func (*MockCaptureMockRecorder) GetUpstreamManager

func (mr *MockCaptureMockRecorder) GetUpstreamManager() *gomock.Call

GetUpstreamManager indicates an expected call of GetUpstreamManager.

func (*MockCaptureMockRecorder) Info

func (mr *MockCaptureMockRecorder) Info() *gomock.Call

Info indicates an expected call of Info.

func (*MockCaptureMockRecorder) IsOwner

func (mr *MockCaptureMockRecorder) IsOwner() *gomock.Call

IsOwner indicates an expected call of IsOwner.

func (*MockCaptureMockRecorder) IsReady

func (mr *MockCaptureMockRecorder) IsReady() *gomock.Call

IsReady indicates an expected call of IsReady.

func (*MockCaptureMockRecorder) Liveness

func (mr *MockCaptureMockRecorder) Liveness() *gomock.Call

Liveness indicates an expected call of Liveness.

func (*MockCaptureMockRecorder) Run

func (mr *MockCaptureMockRecorder) Run(ctx interface{}) *gomock.Call

Run indicates an expected call of Run.

func (*MockCaptureMockRecorder) StatusProvider

func (mr *MockCaptureMockRecorder) StatusProvider() *gomock.Call

StatusProvider indicates an expected call of StatusProvider.

func (*MockCaptureMockRecorder) WriteDebugInfo

func (mr *MockCaptureMockRecorder) WriteDebugInfo(ctx, w interface{}) *gomock.Call

WriteDebugInfo indicates an expected call of WriteDebugInfo.