copier

package
v1.38.0 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2026 License: BSD-3-Clause Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Copier 

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

Copier for shard replicas, can copy a shard replica from one node to another.

func New 

func New(clientFactory FileReplicationServiceClientFactory, remoteIndex types.RemoteIndex, nodeSelector cluster.NodeSelector,
	concurrentWorkers int, rootPath string, dbWrapper types.DbWrapper, nodeName string, logger logrus.FieldLogger,
) *Copier

New creates a new shard replica Copier.

func (*Copier) AddAsyncReplicationTargetNode 

func (c *Copier) AddAsyncReplicationTargetNode(ctx context.Context, targetNodeOverride additional.AsyncReplicationTargetNodeOverride, schemaVersion uint64) error

AddAsyncReplicationTargetNode adds a target node override for a shard.

func (*Copier) AsyncReplicationStatus 

func (c *Copier) AsyncReplicationStatus(ctx context.Context, srcNodeId, targetNodeId, collectionName, shardName string) (models.AsyncReplicationStatus, error)

AsyncReplicationStatus returns the async replication status for a shard. The first two return values are the number of objects propagated and the start diff time in unix milliseconds.

func (*Copier) CopyReplicaFiles 

func (c *Copier) CopyReplicaFiles(ctx context.Context, srcNodeId, collectionName, shardName string, schemaVersion uint64) error

CopyReplicaFiles copies a shard replica from the source node to this node.

func (*Copier) FinalizeChangeLog added in v1.38.0 

func (c *Copier) FinalizeChangeLog(ctx context.Context, srcNodeId, indexName, shardName, opID string) (uint64, error)

FinalizeChangeLog seals the source's change-capture log and returns its final LSN. The caller need not compare to lastAppliedLSN — the server closes the stream with io.EOF once its tailer drains through finalLSN.

func (*Copier) InitAsyncReplicationLocally 

func (c *Copier) InitAsyncReplicationLocally(ctx context.Context, collectionName, shardName string) error

func (*Copier) LoadLocalShard 

func (c *Copier) LoadLocalShard(ctx context.Context, collectionName, shardName string) error

func (*Copier) RemoveAsyncReplicationTargetNode 

func (c *Copier) RemoveAsyncReplicationTargetNode(ctx context.Context, targetNodeOverride additional.AsyncReplicationTargetNodeOverride) error

RemoveAsyncReplicationTargetNode removes a target node override for a shard.

func (*Copier) RevertAsyncReplicationLocally 

func (c *Copier) RevertAsyncReplicationLocally(ctx context.Context, collectionName, shardName string) error

func (*Copier) SnapshotChangeLogLSN added in v1.38.0 

func (c *Copier) SnapshotChangeLogLSN(ctx context.Context, srcNodeId, indexName, shardName, opID string) (uint64, error)

SnapshotChangeLogLSN returns the source's current change-log LSN without sealing it. The log stays writable; pair with a capped TailAndApply to drain a phase boundary without sealing.

func (*Copier) StartChangeCapture added in v1.38.0 

func (c *Copier) StartChangeCapture(ctx context.Context, srcNodeId, indexName, shardName, opID string, schemaVersion uint64) error

StartChangeCapture must be called before the source takes its file snapshot.

func (*Copier) StopChangeCapture added in v1.38.0 

func (c *Copier) StopChangeCapture(ctx context.Context, srcNodeId, indexName, shardName, opID string) error

StopChangeCapture deactivates the source log and removes its file. Safe to call on an unknown opID; the server treats it as a no-op.

func (*Copier) TailAndApply added in v1.38.0 

func (c *Copier) TailAndApply(ctx context.Context, srcNodeId, indexName, shardName, opID string, untilLSN uint64) (lastAppliedLSN uint64, err error)

TailAndApply streams the source log and replays each entry on the local shard. untilLSN is the inclusive upper bound on emitted LSNs; the stream closes when lastApplied reaches untilLSN or the source seals the log, whichever fires first. Pass a Snapshot LSN to drain a phase boundary (the log keeps accepting writes), or finalLSN after FinalizeChangeLog to drain the sealed tail. untilLSN=0 is a no-op for a quiet shard. Returns on io.EOF, ctx cancel, or fatal recv/apply error.

type FileChunkStream added in v1.32.0 

type FileChunkStream interface {
	Context() context.Context
	CloseSend() error
	Header() (metadata.MD, error)
	Trailer() metadata.MD
	RecvMsg(m interface{}) error
	SendMsg(interface{}) error
	Send(*protocol.GetFileRequest) error
	Recv() (*protocol.FileChunk, error)
}

Create non-generic wrapper interface so it can be generated with mockery

type FileMetadataStream added in v1.32.0 

type FileMetadataStream interface {
	Context() context.Context
	CloseSend() error
	Header() (metadata.MD, error)
	Trailer() metadata.MD
	RecvMsg(m interface{}) error
	SendMsg(interface{}) error
	Send(*protocol.GetFileMetadataRequest) error
	Recv() (*protocol.FileMetadata, error)
}

Create non-generic wrapper interface so it can be generated with mockery

type FileReplicationServiceClient added in v1.32.0 

type FileReplicationServiceClient protocol.FileReplicationServiceClient

type FileReplicationServiceClientFactory added in v1.32.0 

type FileReplicationServiceClientFactory func(ctx context.Context, address string) (FileReplicationServiceClient, error)

type MockFileChunkStream added in v1.32.0 

type MockFileChunkStream struct {
	mock.Mock
}

MockFileChunkStream is an autogenerated mock type for the FileChunkStream type

func NewMockFileChunkStream added in v1.32.0 

func NewMockFileChunkStream(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockFileChunkStream

NewMockFileChunkStream creates a new instance of MockFileChunkStream. 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 (*MockFileChunkStream) CloseSend added in v1.32.0 

func (_m *MockFileChunkStream) CloseSend() error

CloseSend provides a mock function with no fields

func (*MockFileChunkStream) Context added in v1.32.0 

func (_m *MockFileChunkStream) Context() context.Context

Context provides a mock function with no fields

func (*MockFileChunkStream) EXPECT added in v1.32.0 

func (_m *MockFileChunkStream) EXPECT() *MockFileChunkStream_Expecter

func (*MockFileChunkStream) Header added in v1.32.0 

func (_m *MockFileChunkStream) Header() (metadata.MD, error)

Header provides a mock function with no fields

func (*MockFileChunkStream) Recv added in v1.32.0 

func (_m *MockFileChunkStream) Recv() (*protocol.FileChunk, error)

Recv provides a mock function with no fields

func (*MockFileChunkStream) RecvMsg added in v1.32.0 

func (_m *MockFileChunkStream) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockFileChunkStream) Send added in v1.32.0 

func (_m *MockFileChunkStream) Send(_a0 *protocol.GetFileRequest) error

Send provides a mock function with given fields: _a0

func (*MockFileChunkStream) SendMsg added in v1.32.0 

func (_m *MockFileChunkStream) SendMsg(_a0 interface{}) error

SendMsg provides a mock function with given fields: _a0

func (*MockFileChunkStream) Trailer added in v1.32.0 

func (_m *MockFileChunkStream) Trailer() metadata.MD

Trailer provides a mock function with no fields

type MockFileChunkStream_CloseSend_Call added in v1.32.0 

type MockFileChunkStream_CloseSend_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_CloseSend_Call) Return added in v1.32.0 

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

func (*MockFileChunkStream_CloseSend_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_CloseSend_Call) Run(run func()) *MockFileChunkStream_CloseSend_Call

func (*MockFileChunkStream_CloseSend_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_CloseSend_Call) RunAndReturn(run func() error) *MockFileChunkStream_CloseSend_Call

type MockFileChunkStream_Context_Call added in v1.32.0 

type MockFileChunkStream_Context_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_Context_Call) Return added in v1.32.0 

func (_c *MockFileChunkStream_Context_Call) Return(_a0 context.Context) *MockFileChunkStream_Context_Call

func (*MockFileChunkStream_Context_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_Context_Call) Run(run func()) *MockFileChunkStream_Context_Call

func (*MockFileChunkStream_Context_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_Context_Call) RunAndReturn(run func() context.Context) *MockFileChunkStream_Context_Call

type MockFileChunkStream_Expecter added in v1.32.0 

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

func (*MockFileChunkStream_Expecter) CloseSend added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) CloseSend() *MockFileChunkStream_CloseSend_Call

CloseSend is a helper method to define mock.On call

func (*MockFileChunkStream_Expecter) Context added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) Context() *MockFileChunkStream_Context_Call

Context is a helper method to define mock.On call

func (*MockFileChunkStream_Expecter) Header added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) Header() *MockFileChunkStream_Header_Call

Header is a helper method to define mock.On call

func (*MockFileChunkStream_Expecter) Recv added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) Recv() *MockFileChunkStream_Recv_Call

Recv is a helper method to define mock.On call

func (*MockFileChunkStream_Expecter) RecvMsg added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) RecvMsg(m interface{}) *MockFileChunkStream_RecvMsg_Call

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockFileChunkStream_Expecter) Send added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) Send(_a0 interface{}) *MockFileChunkStream_Send_Call

Send is a helper method to define mock.On call

  • _a0 *protocol.GetFileRequest

func (*MockFileChunkStream_Expecter) SendMsg added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) SendMsg(_a0 interface{}) *MockFileChunkStream_SendMsg_Call

SendMsg is a helper method to define mock.On call

  • _a0 interface{}

func (*MockFileChunkStream_Expecter) Trailer added in v1.32.0 

func (_e *MockFileChunkStream_Expecter) Trailer() *MockFileChunkStream_Trailer_Call

Trailer is a helper method to define mock.On call

type MockFileChunkStream_Header_Call added in v1.32.0 

type MockFileChunkStream_Header_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_Header_Call) Return added in v1.32.0 

func (_c *MockFileChunkStream_Header_Call) Return(_a0 metadata.MD, _a1 error) *MockFileChunkStream_Header_Call

func (*MockFileChunkStream_Header_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_Header_Call) Run(run func()) *MockFileChunkStream_Header_Call

func (*MockFileChunkStream_Header_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_Header_Call) RunAndReturn(run func() (metadata.MD, error)) *MockFileChunkStream_Header_Call

type MockFileChunkStream_RecvMsg_Call added in v1.32.0 

type MockFileChunkStream_RecvMsg_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_RecvMsg_Call) Return added in v1.32.0 

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

func (*MockFileChunkStream_RecvMsg_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_RecvMsg_Call) Run(run func(m interface{})) *MockFileChunkStream_RecvMsg_Call

func (*MockFileChunkStream_RecvMsg_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_RecvMsg_Call) RunAndReturn(run func(interface{}) error) *MockFileChunkStream_RecvMsg_Call

type MockFileChunkStream_Recv_Call added in v1.32.0 

type MockFileChunkStream_Recv_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_Recv_Call) Return added in v1.32.0 

func (_c *MockFileChunkStream_Recv_Call) Return(_a0 *protocol.FileChunk, _a1 error) *MockFileChunkStream_Recv_Call

func (*MockFileChunkStream_Recv_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_Recv_Call) Run(run func()) *MockFileChunkStream_Recv_Call

func (*MockFileChunkStream_Recv_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_Recv_Call) RunAndReturn(run func() (*protocol.FileChunk, error)) *MockFileChunkStream_Recv_Call

type MockFileChunkStream_SendMsg_Call added in v1.32.0 

type MockFileChunkStream_SendMsg_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_SendMsg_Call) Return added in v1.32.0 

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

func (*MockFileChunkStream_SendMsg_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_SendMsg_Call) Run(run func(_a0 interface{})) *MockFileChunkStream_SendMsg_Call

func (*MockFileChunkStream_SendMsg_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_SendMsg_Call) RunAndReturn(run func(interface{}) error) *MockFileChunkStream_SendMsg_Call

type MockFileChunkStream_Send_Call added in v1.32.0 

type MockFileChunkStream_Send_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_Send_Call) Return added in v1.32.0 

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

func (*MockFileChunkStream_Send_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_Send_Call) Run(run func(_a0 *protocol.GetFileRequest)) *MockFileChunkStream_Send_Call

func (*MockFileChunkStream_Send_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_Send_Call) RunAndReturn(run func(*protocol.GetFileRequest) error) *MockFileChunkStream_Send_Call

type MockFileChunkStream_Trailer_Call added in v1.32.0 

type MockFileChunkStream_Trailer_Call struct {
	*mock.Call
}

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

func (*MockFileChunkStream_Trailer_Call) Return added in v1.32.0 

func (_c *MockFileChunkStream_Trailer_Call) Return(_a0 metadata.MD) *MockFileChunkStream_Trailer_Call

func (*MockFileChunkStream_Trailer_Call) Run added in v1.32.0 

func (_c *MockFileChunkStream_Trailer_Call) Run(run func()) *MockFileChunkStream_Trailer_Call

func (*MockFileChunkStream_Trailer_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileChunkStream_Trailer_Call) RunAndReturn(run func() metadata.MD) *MockFileChunkStream_Trailer_Call

type MockFileMetadataStream added in v1.32.0 

type MockFileMetadataStream struct {
	mock.Mock
}

MockFileMetadataStream is an autogenerated mock type for the FileMetadataStream type

func NewMockFileMetadataStream added in v1.32.0 

func NewMockFileMetadataStream(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockFileMetadataStream

NewMockFileMetadataStream creates a new instance of MockFileMetadataStream. 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 (*MockFileMetadataStream) CloseSend added in v1.32.0 

func (_m *MockFileMetadataStream) CloseSend() error

CloseSend provides a mock function with no fields

func (*MockFileMetadataStream) Context added in v1.32.0 

func (_m *MockFileMetadataStream) Context() context.Context

Context provides a mock function with no fields

func (*MockFileMetadataStream) EXPECT added in v1.32.0 

func (_m *MockFileMetadataStream) EXPECT() *MockFileMetadataStream_Expecter

func (*MockFileMetadataStream) Header added in v1.32.0 

func (_m *MockFileMetadataStream) Header() (metadata.MD, error)

Header provides a mock function with no fields

func (*MockFileMetadataStream) Recv added in v1.32.0 

func (_m *MockFileMetadataStream) Recv() (*protocol.FileMetadata, error)

Recv provides a mock function with no fields

func (*MockFileMetadataStream) RecvMsg added in v1.32.0 

func (_m *MockFileMetadataStream) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*MockFileMetadataStream) Send added in v1.32.0 

func (_m *MockFileMetadataStream) Send(_a0 *protocol.GetFileMetadataRequest) error

Send provides a mock function with given fields: _a0

func (*MockFileMetadataStream) SendMsg added in v1.32.0 

func (_m *MockFileMetadataStream) SendMsg(_a0 interface{}) error

SendMsg provides a mock function with given fields: _a0

func (*MockFileMetadataStream) Trailer added in v1.32.0 

func (_m *MockFileMetadataStream) Trailer() metadata.MD

Trailer provides a mock function with no fields

type MockFileMetadataStream_CloseSend_Call added in v1.32.0 

type MockFileMetadataStream_CloseSend_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_CloseSend_Call) Return added in v1.32.0 

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

func (*MockFileMetadataStream_CloseSend_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_CloseSend_Call) Run(run func()) *MockFileMetadataStream_CloseSend_Call

func (*MockFileMetadataStream_CloseSend_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_CloseSend_Call) RunAndReturn(run func() error) *MockFileMetadataStream_CloseSend_Call

type MockFileMetadataStream_Context_Call added in v1.32.0 

type MockFileMetadataStream_Context_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_Context_Call) Return added in v1.32.0 

func (_c *MockFileMetadataStream_Context_Call) Return(_a0 context.Context) *MockFileMetadataStream_Context_Call

func (*MockFileMetadataStream_Context_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_Context_Call) Run(run func()) *MockFileMetadataStream_Context_Call

func (*MockFileMetadataStream_Context_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_Context_Call) RunAndReturn(run func() context.Context) *MockFileMetadataStream_Context_Call

type MockFileMetadataStream_Expecter added in v1.32.0 

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

func (*MockFileMetadataStream_Expecter) CloseSend added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) CloseSend() *MockFileMetadataStream_CloseSend_Call

CloseSend is a helper method to define mock.On call

func (*MockFileMetadataStream_Expecter) Context added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) Context() *MockFileMetadataStream_Context_Call

Context is a helper method to define mock.On call

func (*MockFileMetadataStream_Expecter) Header added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) Header() *MockFileMetadataStream_Header_Call

Header is a helper method to define mock.On call

func (*MockFileMetadataStream_Expecter) Recv added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) Recv() *MockFileMetadataStream_Recv_Call

Recv is a helper method to define mock.On call

func (*MockFileMetadataStream_Expecter) RecvMsg added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) RecvMsg(m interface{}) *MockFileMetadataStream_RecvMsg_Call

RecvMsg is a helper method to define mock.On call

  • m interface{}

func (*MockFileMetadataStream_Expecter) Send added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) Send(_a0 interface{}) *MockFileMetadataStream_Send_Call

Send is a helper method to define mock.On call

  • _a0 *protocol.GetFileMetadataRequest

func (*MockFileMetadataStream_Expecter) SendMsg added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) SendMsg(_a0 interface{}) *MockFileMetadataStream_SendMsg_Call

SendMsg is a helper method to define mock.On call

  • _a0 interface{}

func (*MockFileMetadataStream_Expecter) Trailer added in v1.32.0 

func (_e *MockFileMetadataStream_Expecter) Trailer() *MockFileMetadataStream_Trailer_Call

Trailer is a helper method to define mock.On call

type MockFileMetadataStream_Header_Call added in v1.32.0 

type MockFileMetadataStream_Header_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_Header_Call) Return added in v1.32.0 

func (_c *MockFileMetadataStream_Header_Call) Return(_a0 metadata.MD, _a1 error) *MockFileMetadataStream_Header_Call

func (*MockFileMetadataStream_Header_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_Header_Call) Run(run func()) *MockFileMetadataStream_Header_Call

func (*MockFileMetadataStream_Header_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_Header_Call) RunAndReturn(run func() (metadata.MD, error)) *MockFileMetadataStream_Header_Call

type MockFileMetadataStream_RecvMsg_Call added in v1.32.0 

type MockFileMetadataStream_RecvMsg_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_RecvMsg_Call) Return added in v1.32.0 

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

func (*MockFileMetadataStream_RecvMsg_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_RecvMsg_Call) Run(run func(m interface{})) *MockFileMetadataStream_RecvMsg_Call

func (*MockFileMetadataStream_RecvMsg_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_RecvMsg_Call) RunAndReturn(run func(interface{}) error) *MockFileMetadataStream_RecvMsg_Call

type MockFileMetadataStream_Recv_Call added in v1.32.0 

type MockFileMetadataStream_Recv_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_Recv_Call) Return added in v1.32.0 

func (_c *MockFileMetadataStream_Recv_Call) Return(_a0 *protocol.FileMetadata, _a1 error) *MockFileMetadataStream_Recv_Call

func (*MockFileMetadataStream_Recv_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_Recv_Call) Run(run func()) *MockFileMetadataStream_Recv_Call

func (*MockFileMetadataStream_Recv_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_Recv_Call) RunAndReturn(run func() (*protocol.FileMetadata, error)) *MockFileMetadataStream_Recv_Call

type MockFileMetadataStream_SendMsg_Call added in v1.32.0 

type MockFileMetadataStream_SendMsg_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_SendMsg_Call) Return added in v1.32.0 

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

func (*MockFileMetadataStream_SendMsg_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_SendMsg_Call) Run(run func(_a0 interface{})) *MockFileMetadataStream_SendMsg_Call

func (*MockFileMetadataStream_SendMsg_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_SendMsg_Call) RunAndReturn(run func(interface{}) error) *MockFileMetadataStream_SendMsg_Call

type MockFileMetadataStream_Send_Call added in v1.32.0 

type MockFileMetadataStream_Send_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_Send_Call) Return added in v1.32.0 

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

func (*MockFileMetadataStream_Send_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_Send_Call) Run(run func(_a0 *protocol.GetFileMetadataRequest)) *MockFileMetadataStream_Send_Call

func (*MockFileMetadataStream_Send_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_Send_Call) RunAndReturn(run func(*protocol.GetFileMetadataRequest) error) *MockFileMetadataStream_Send_Call

type MockFileMetadataStream_Trailer_Call added in v1.32.0 

type MockFileMetadataStream_Trailer_Call struct {
	*mock.Call
}

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

func (*MockFileMetadataStream_Trailer_Call) Return added in v1.32.0 

func (_c *MockFileMetadataStream_Trailer_Call) Return(_a0 metadata.MD) *MockFileMetadataStream_Trailer_Call

func (*MockFileMetadataStream_Trailer_Call) Run added in v1.32.0 

func (_c *MockFileMetadataStream_Trailer_Call) Run(run func()) *MockFileMetadataStream_Trailer_Call

func (*MockFileMetadataStream_Trailer_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileMetadataStream_Trailer_Call) RunAndReturn(run func() metadata.MD) *MockFileMetadataStream_Trailer_Call

type MockFileReplicationServiceClient added in v1.32.0 

type MockFileReplicationServiceClient struct {
	mock.Mock
}

MockFileReplicationServiceClient is an autogenerated mock type for the FileReplicationServiceClient type

func NewMockFileReplicationServiceClient added in v1.32.0 

func NewMockFileReplicationServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockFileReplicationServiceClient

NewMockFileReplicationServiceClient creates a new instance of MockFileReplicationServiceClient. 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 (*MockFileReplicationServiceClient) EXPECT added in v1.32.0 

func (_m *MockFileReplicationServiceClient) EXPECT() *MockFileReplicationServiceClient_Expecter

func (*MockFileReplicationServiceClient) FinalizeChangeLog added in v1.38.0 

func (_m *MockFileReplicationServiceClient) FinalizeChangeLog(ctx context.Context, in *protocol.FinalizeChangeLogRequest, opts ...grpc.CallOption) (*protocol.FinalizeChangeLogResponse, error)

FinalizeChangeLog provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) GetChangeLog added in v1.38.0 

func (_m *MockFileReplicationServiceClient) GetChangeLog(ctx context.Context, in *protocol.GetChangeLogRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[protocol.ChangeLogStreamEntry], error)

GetChangeLog provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) GetFile added in v1.32.0 

func (_m *MockFileReplicationServiceClient) GetFile(ctx context.Context, in *protocol.GetFileRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[protocol.FileChunk], error)

GetFile provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) GetFileMetadata added in v1.32.0 

func (_m *MockFileReplicationServiceClient) GetFileMetadata(ctx context.Context, in *protocol.GetFileMetadataRequest, opts ...grpc.CallOption) (*protocol.FileMetadata, error)

GetFileMetadata provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) ListFiles added in v1.32.0 

func (_m *MockFileReplicationServiceClient) ListFiles(ctx context.Context, in *protocol.ListFilesRequest, opts ...grpc.CallOption) (*protocol.ListFilesResponse, error)

ListFiles provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) PauseFileActivity added in v1.32.0 

func (_m *MockFileReplicationServiceClient) PauseFileActivity(ctx context.Context, in *protocol.PauseFileActivityRequest, opts ...grpc.CallOption) (*protocol.PauseFileActivityResponse, error)

PauseFileActivity provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) ResumeFileActivity added in v1.32.0 

func (_m *MockFileReplicationServiceClient) ResumeFileActivity(ctx context.Context, in *protocol.ResumeFileActivityRequest, opts ...grpc.CallOption) (*protocol.ResumeFileActivityResponse, error)

ResumeFileActivity provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) SnapshotChangeLogLSN added in v1.38.0 

func (_m *MockFileReplicationServiceClient) SnapshotChangeLogLSN(ctx context.Context, in *protocol.SnapshotChangeLogLSNRequest, opts ...grpc.CallOption) (*protocol.SnapshotChangeLogLSNResponse, error)

SnapshotChangeLogLSN provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) StartChangeCapture added in v1.38.0 

func (_m *MockFileReplicationServiceClient) StartChangeCapture(ctx context.Context, in *protocol.StartChangeCaptureRequest, opts ...grpc.CallOption) (*protocol.StartChangeCaptureResponse, error)

StartChangeCapture provides a mock function with given fields: ctx, in, opts

func (*MockFileReplicationServiceClient) StopChangeCapture added in v1.38.0 

func (_m *MockFileReplicationServiceClient) StopChangeCapture(ctx context.Context, in *protocol.StopChangeCaptureRequest, opts ...grpc.CallOption) (*protocol.StopChangeCaptureResponse, error)

StopChangeCapture provides a mock function with given fields: ctx, in, opts

type MockFileReplicationServiceClient_Expecter added in v1.32.0 

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

func (*MockFileReplicationServiceClient_Expecter) FinalizeChangeLog added in v1.38.0 

func (_e *MockFileReplicationServiceClient_Expecter) FinalizeChangeLog(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_FinalizeChangeLog_Call

FinalizeChangeLog is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.FinalizeChangeLogRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) GetChangeLog added in v1.38.0 

func (_e *MockFileReplicationServiceClient_Expecter) GetChangeLog(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_GetChangeLog_Call

GetChangeLog is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.GetChangeLogRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) GetFile added in v1.32.0 

func (_e *MockFileReplicationServiceClient_Expecter) GetFile(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_GetFile_Call

GetFile is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.GetFileRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) GetFileMetadata added in v1.32.0 

func (_e *MockFileReplicationServiceClient_Expecter) GetFileMetadata(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_GetFileMetadata_Call

GetFileMetadata is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.GetFileMetadataRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) ListFiles added in v1.32.0 

func (_e *MockFileReplicationServiceClient_Expecter) ListFiles(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_ListFiles_Call

ListFiles is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.ListFilesRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) PauseFileActivity added in v1.32.0 

func (_e *MockFileReplicationServiceClient_Expecter) PauseFileActivity(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_PauseFileActivity_Call

PauseFileActivity is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.PauseFileActivityRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) ResumeFileActivity added in v1.32.0 

func (_e *MockFileReplicationServiceClient_Expecter) ResumeFileActivity(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_ResumeFileActivity_Call

ResumeFileActivity is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.ResumeFileActivityRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) SnapshotChangeLogLSN added in v1.38.0 

func (_e *MockFileReplicationServiceClient_Expecter) SnapshotChangeLogLSN(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call

SnapshotChangeLogLSN is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.SnapshotChangeLogLSNRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) StartChangeCapture added in v1.38.0 

func (_e *MockFileReplicationServiceClient_Expecter) StartChangeCapture(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_StartChangeCapture_Call

StartChangeCapture is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.StartChangeCaptureRequest
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) StopChangeCapture added in v1.38.0 

func (_e *MockFileReplicationServiceClient_Expecter) StopChangeCapture(ctx interface{}, in interface{}, opts ...interface{}) *MockFileReplicationServiceClient_StopChangeCapture_Call

StopChangeCapture is a helper method to define mock.On call

  • ctx context.Context
  • in *protocol.StopChangeCaptureRequest
  • opts ...grpc.CallOption

type MockFileReplicationServiceClient_FinalizeChangeLog_Call added in v1.38.0 

type MockFileReplicationServiceClient_FinalizeChangeLog_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_FinalizeChangeLog_Call) Return added in v1.38.0 

func (_c *MockFileReplicationServiceClient_FinalizeChangeLog_Call) Return(_a0 *protocol.FinalizeChangeLogResponse, _a1 error) *MockFileReplicationServiceClient_FinalizeChangeLog_Call

func (*MockFileReplicationServiceClient_FinalizeChangeLog_Call) Run added in v1.38.0 

func (_c *MockFileReplicationServiceClient_FinalizeChangeLog_Call) Run(run func(ctx context.Context, in *protocol.FinalizeChangeLogRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_FinalizeChangeLog_Call

func (*MockFileReplicationServiceClient_FinalizeChangeLog_Call) RunAndReturn added in v1.38.0 

func (_c *MockFileReplicationServiceClient_FinalizeChangeLog_Call) RunAndReturn(run func(context.Context, *protocol.FinalizeChangeLogRequest, ...grpc.CallOption) (*protocol.FinalizeChangeLogResponse, error)) *MockFileReplicationServiceClient_FinalizeChangeLog_Call

type MockFileReplicationServiceClient_GetChangeLog_Call added in v1.38.0 

type MockFileReplicationServiceClient_GetChangeLog_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_GetChangeLog_Call) Return added in v1.38.0 

func (_c *MockFileReplicationServiceClient_GetChangeLog_Call) Return(_a0 grpc.ServerStreamingClient[protocol.ChangeLogStreamEntry], _a1 error) *MockFileReplicationServiceClient_GetChangeLog_Call

func (*MockFileReplicationServiceClient_GetChangeLog_Call) Run added in v1.38.0 

func (_c *MockFileReplicationServiceClient_GetChangeLog_Call) Run(run func(ctx context.Context, in *protocol.GetChangeLogRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_GetChangeLog_Call

func (*MockFileReplicationServiceClient_GetChangeLog_Call) RunAndReturn added in v1.38.0 

func (_c *MockFileReplicationServiceClient_GetChangeLog_Call) RunAndReturn(run func(context.Context, *protocol.GetChangeLogRequest, ...grpc.CallOption) (grpc.ServerStreamingClient[protocol.ChangeLogStreamEntry], error)) *MockFileReplicationServiceClient_GetChangeLog_Call

type MockFileReplicationServiceClient_GetFileMetadata_Call added in v1.32.0 

type MockFileReplicationServiceClient_GetFileMetadata_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_GetFileMetadata_Call) Return added in v1.32.0 

func (_c *MockFileReplicationServiceClient_GetFileMetadata_Call) Return(_a0 *protocol.FileMetadata, _a1 error) *MockFileReplicationServiceClient_GetFileMetadata_Call

func (*MockFileReplicationServiceClient_GetFileMetadata_Call) Run added in v1.32.0 

func (_c *MockFileReplicationServiceClient_GetFileMetadata_Call) Run(run func(ctx context.Context, in *protocol.GetFileMetadataRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_GetFileMetadata_Call

func (*MockFileReplicationServiceClient_GetFileMetadata_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileReplicationServiceClient_GetFileMetadata_Call) RunAndReturn(run func(context.Context, *protocol.GetFileMetadataRequest, ...grpc.CallOption) (*protocol.FileMetadata, error)) *MockFileReplicationServiceClient_GetFileMetadata_Call

type MockFileReplicationServiceClient_GetFile_Call added in v1.32.0 

type MockFileReplicationServiceClient_GetFile_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_GetFile_Call) Return added in v1.32.0 

func (_c *MockFileReplicationServiceClient_GetFile_Call) Return(_a0 grpc.ServerStreamingClient[protocol.FileChunk], _a1 error) *MockFileReplicationServiceClient_GetFile_Call

func (*MockFileReplicationServiceClient_GetFile_Call) Run added in v1.32.0 

func (_c *MockFileReplicationServiceClient_GetFile_Call) Run(run func(ctx context.Context, in *protocol.GetFileRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_GetFile_Call

func (*MockFileReplicationServiceClient_GetFile_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileReplicationServiceClient_GetFile_Call) RunAndReturn(run func(context.Context, *protocol.GetFileRequest, ...grpc.CallOption) (grpc.ServerStreamingClient[protocol.FileChunk], error)) *MockFileReplicationServiceClient_GetFile_Call

type MockFileReplicationServiceClient_ListFiles_Call added in v1.32.0 

type MockFileReplicationServiceClient_ListFiles_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_ListFiles_Call) Return added in v1.32.0 

func (_c *MockFileReplicationServiceClient_ListFiles_Call) Return(_a0 *protocol.ListFilesResponse, _a1 error) *MockFileReplicationServiceClient_ListFiles_Call

func (*MockFileReplicationServiceClient_ListFiles_Call) Run added in v1.32.0 

func (_c *MockFileReplicationServiceClient_ListFiles_Call) Run(run func(ctx context.Context, in *protocol.ListFilesRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_ListFiles_Call

func (*MockFileReplicationServiceClient_ListFiles_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileReplicationServiceClient_ListFiles_Call) RunAndReturn(run func(context.Context, *protocol.ListFilesRequest, ...grpc.CallOption) (*protocol.ListFilesResponse, error)) *MockFileReplicationServiceClient_ListFiles_Call

type MockFileReplicationServiceClient_PauseFileActivity_Call added in v1.32.0 

type MockFileReplicationServiceClient_PauseFileActivity_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_PauseFileActivity_Call) Return added in v1.32.0 

func (_c *MockFileReplicationServiceClient_PauseFileActivity_Call) Return(_a0 *protocol.PauseFileActivityResponse, _a1 error) *MockFileReplicationServiceClient_PauseFileActivity_Call

func (*MockFileReplicationServiceClient_PauseFileActivity_Call) Run added in v1.32.0 

func (_c *MockFileReplicationServiceClient_PauseFileActivity_Call) Run(run func(ctx context.Context, in *protocol.PauseFileActivityRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_PauseFileActivity_Call

func (*MockFileReplicationServiceClient_PauseFileActivity_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileReplicationServiceClient_PauseFileActivity_Call) RunAndReturn(run func(context.Context, *protocol.PauseFileActivityRequest, ...grpc.CallOption) (*protocol.PauseFileActivityResponse, error)) *MockFileReplicationServiceClient_PauseFileActivity_Call

type MockFileReplicationServiceClient_ResumeFileActivity_Call added in v1.32.0 

type MockFileReplicationServiceClient_ResumeFileActivity_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_ResumeFileActivity_Call) Return added in v1.32.0 

func (_c *MockFileReplicationServiceClient_ResumeFileActivity_Call) Return(_a0 *protocol.ResumeFileActivityResponse, _a1 error) *MockFileReplicationServiceClient_ResumeFileActivity_Call

func (*MockFileReplicationServiceClient_ResumeFileActivity_Call) Run added in v1.32.0 

func (_c *MockFileReplicationServiceClient_ResumeFileActivity_Call) Run(run func(ctx context.Context, in *protocol.ResumeFileActivityRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_ResumeFileActivity_Call

func (*MockFileReplicationServiceClient_ResumeFileActivity_Call) RunAndReturn added in v1.32.0 

func (_c *MockFileReplicationServiceClient_ResumeFileActivity_Call) RunAndReturn(run func(context.Context, *protocol.ResumeFileActivityRequest, ...grpc.CallOption) (*protocol.ResumeFileActivityResponse, error)) *MockFileReplicationServiceClient_ResumeFileActivity_Call

type MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call added in v1.38.0 

type MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call) Return added in v1.38.0 

func (_c *MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call) Return(_a0 *protocol.SnapshotChangeLogLSNResponse, _a1 error) *MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call

func (*MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call) Run added in v1.38.0 

func (_c *MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call) Run(run func(ctx context.Context, in *protocol.SnapshotChangeLogLSNRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call

func (*MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call) RunAndReturn added in v1.38.0 

func (_c *MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call) RunAndReturn(run func(context.Context, *protocol.SnapshotChangeLogLSNRequest, ...grpc.CallOption) (*protocol.SnapshotChangeLogLSNResponse, error)) *MockFileReplicationServiceClient_SnapshotChangeLogLSN_Call

type MockFileReplicationServiceClient_StartChangeCapture_Call added in v1.38.0 

type MockFileReplicationServiceClient_StartChangeCapture_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_StartChangeCapture_Call) Return added in v1.38.0 

func (_c *MockFileReplicationServiceClient_StartChangeCapture_Call) Return(_a0 *protocol.StartChangeCaptureResponse, _a1 error) *MockFileReplicationServiceClient_StartChangeCapture_Call

func (*MockFileReplicationServiceClient_StartChangeCapture_Call) Run added in v1.38.0 

func (_c *MockFileReplicationServiceClient_StartChangeCapture_Call) Run(run func(ctx context.Context, in *protocol.StartChangeCaptureRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_StartChangeCapture_Call

func (*MockFileReplicationServiceClient_StartChangeCapture_Call) RunAndReturn added in v1.38.0 

func (_c *MockFileReplicationServiceClient_StartChangeCapture_Call) RunAndReturn(run func(context.Context, *protocol.StartChangeCaptureRequest, ...grpc.CallOption) (*protocol.StartChangeCaptureResponse, error)) *MockFileReplicationServiceClient_StartChangeCapture_Call

type MockFileReplicationServiceClient_StopChangeCapture_Call added in v1.38.0 

type MockFileReplicationServiceClient_StopChangeCapture_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_StopChangeCapture_Call) Return added in v1.38.0 

func (_c *MockFileReplicationServiceClient_StopChangeCapture_Call) Return(_a0 *protocol.StopChangeCaptureResponse, _a1 error) *MockFileReplicationServiceClient_StopChangeCapture_Call

func (*MockFileReplicationServiceClient_StopChangeCapture_Call) Run added in v1.38.0 

func (_c *MockFileReplicationServiceClient_StopChangeCapture_Call) Run(run func(ctx context.Context, in *protocol.StopChangeCaptureRequest, opts ...grpc.CallOption)) *MockFileReplicationServiceClient_StopChangeCapture_Call

func (*MockFileReplicationServiceClient_StopChangeCapture_Call) RunAndReturn added in v1.38.0 

func (_c *MockFileReplicationServiceClient_StopChangeCapture_Call) RunAndReturn(run func(context.Context, *protocol.StopChangeCaptureRequest, ...grpc.CallOption) (*protocol.StopChangeCaptureResponse, error)) *MockFileReplicationServiceClient_StopChangeCapture_Call

Source Files

View all Source files

Directories

Path Synopsis
internal
changelogdrain
Package changelogdrain pulls ChangeLogStreamEntry messages from a gRPC server-streaming client, batches them, and flushes via a caller-supplied apply func.
 Package changelogdrain pulls ChangeLogStreamEntry messages from a gRPC server-streaming client, batches them, and flushes via a caller-supplied apply func.

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.