copier

package
v1.32.13 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2025 License: BSD-3-Clause Imports: 26 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) 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

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 interface {
	pbv1.FileReplicationServiceClient
	Close() error
}

func NewFileReplicationServiceClient added in v1.32.0 

func NewFileReplicationServiceClient(clientConn *grpc.ClientConn, authConfig cluster.AuthConfig) 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) Close added in v1.32.0 

func (_m *MockFileReplicationServiceClient) Close() error

Close provides a mock function with no fields

func (*MockFileReplicationServiceClient) EXPECT added in v1.32.0 

func (_m *MockFileReplicationServiceClient) EXPECT() *MockFileReplicationServiceClient_Expecter

func (*MockFileReplicationServiceClient) GetFile added in v1.32.0 

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

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

func (*MockFileReplicationServiceClient) GetFileMetadata added in v1.32.0 

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

GetFileMetadata provides a mock function with given fields: ctx, 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

type MockFileReplicationServiceClient_Close_Call added in v1.32.0 

type MockFileReplicationServiceClient_Close_Call struct {
	*mock.Call
}

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

func (*MockFileReplicationServiceClient_Close_Call) Return added in v1.32.0 

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

func (*MockFileReplicationServiceClient_Close_Call) Run added in v1.32.0 

func (_c *MockFileReplicationServiceClient_Close_Call) Run(run func()) *MockFileReplicationServiceClient_Close_Call

func (*MockFileReplicationServiceClient_Close_Call) RunAndReturn added in v1.32.0 

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

type MockFileReplicationServiceClient_Expecter added in v1.32.0 

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

func (*MockFileReplicationServiceClient_Expecter) Close added in v1.32.0 

func (_e *MockFileReplicationServiceClient_Expecter) Close() *MockFileReplicationServiceClient_Close_Call

Close is a helper method to define mock.On call

func (*MockFileReplicationServiceClient_Expecter) GetFile added in v1.32.0 

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

GetFile is a helper method to define mock.On call

  • ctx context.Context
  • opts ...grpc.CallOption

func (*MockFileReplicationServiceClient_Expecter) GetFileMetadata added in v1.32.0 

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

GetFileMetadata is a helper method to define mock.On call

  • ctx context.Context
  • 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

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 grpc.BidiStreamingClient[protocol.GetFileMetadataRequest, 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, 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, ...grpc.CallOption) (grpc.BidiStreamingClient[protocol.GetFileMetadataRequest, 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.BidiStreamingClient[protocol.GetFileRequest, 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, 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, ...grpc.CallOption) (grpc.BidiStreamingClient[protocol.GetFileRequest, 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

Source Files

View all Source files

Directories

Path Synopsis

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.