Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockDfdaemonDownloadClient
- func (m *MockDfdaemonDownloadClient) DeleteCacheTask(ctx context.Context, in *dfdaemon.DeleteCacheTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadClient) DeleteHost(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadClient) DeleteTask(ctx context.Context, in *dfdaemon.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadClient) DownloadCacheTask(ctx context.Context, in *dfdaemon.DownloadCacheTaskRequest, ...) (dfdaemon.DfdaemonDownload_DownloadCacheTaskClient, error)
- func (m *MockDfdaemonDownloadClient) DownloadPersistentCacheTask(ctx context.Context, in *dfdaemon.DownloadPersistentCacheTaskRequest, ...) (dfdaemon.DfdaemonDownload_DownloadPersistentCacheTaskClient, error)
- func (m *MockDfdaemonDownloadClient) DownloadPersistentTask(ctx context.Context, in *dfdaemon.DownloadPersistentTaskRequest, ...) (dfdaemon.DfdaemonDownload_DownloadPersistentTaskClient, error)
- func (m *MockDfdaemonDownloadClient) DownloadTask(ctx context.Context, in *dfdaemon.DownloadTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonDownload_DownloadTaskClient, error)
- func (m *MockDfdaemonDownloadClient) EXPECT() *MockDfdaemonDownloadClientMockRecorder
- func (m *MockDfdaemonDownloadClient) ListTaskEntries(ctx context.Context, in *dfdaemon.ListTaskEntriesRequest, ...) (*dfdaemon.ListTaskEntriesResponse, error)
- func (m *MockDfdaemonDownloadClient) StatCacheTask(ctx context.Context, in *dfdaemon.StatCacheTaskRequest, ...) (*common.CacheTask, error)
- func (m *MockDfdaemonDownloadClient) StatLocalTask(ctx context.Context, in *dfdaemon.StatLocalTaskRequest, ...) (*dfdaemon.StatLocalTaskResponse, error)
- func (m *MockDfdaemonDownloadClient) StatPersistentCacheTask(ctx context.Context, in *dfdaemon.StatPersistentCacheTaskRequest, ...) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonDownloadClient) StatTask(ctx context.Context, in *dfdaemon.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)
- func (m *MockDfdaemonDownloadClient) UploadPersistentCacheTask(ctx context.Context, in *dfdaemon.UploadPersistentCacheTaskRequest, ...) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonDownloadClient) UploadPersistentTask(ctx context.Context, in *dfdaemon.UploadPersistentTaskRequest, ...) (*common.PersistentTask, error)
- type MockDfdaemonDownloadClientMockRecorder
- func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteHost(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadPersistentTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) ListTaskEntries(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) StatCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) StatLocalTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) StatPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) UploadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) UploadPersistentTask(ctx, in any, opts ...any) *gomock.Call
- type MockDfdaemonDownloadServer
- func (m *MockDfdaemonDownloadServer) DeleteCacheTask(arg0 context.Context, arg1 *dfdaemon.DeleteCacheTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadServer) DeleteHost(arg0 context.Context, arg1 *emptypb.Empty) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadServer) DeleteTask(arg0 context.Context, arg1 *dfdaemon.DeleteTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadServer) DownloadCacheTask(arg0 *dfdaemon.DownloadCacheTaskRequest, ...) error
- func (m *MockDfdaemonDownloadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, ...) error
- func (m *MockDfdaemonDownloadServer) DownloadPersistentTask(arg0 *dfdaemon.DownloadPersistentTaskRequest, ...) error
- func (m *MockDfdaemonDownloadServer) DownloadTask(arg0 *dfdaemon.DownloadTaskRequest, ...) error
- func (m *MockDfdaemonDownloadServer) EXPECT() *MockDfdaemonDownloadServerMockRecorder
- func (m *MockDfdaemonDownloadServer) ListTaskEntries(arg0 context.Context, arg1 *dfdaemon.ListTaskEntriesRequest) (*dfdaemon.ListTaskEntriesResponse, error)
- func (m *MockDfdaemonDownloadServer) StatCacheTask(arg0 context.Context, arg1 *dfdaemon.StatCacheTaskRequest) (*common.CacheTask, error)
- func (m *MockDfdaemonDownloadServer) StatLocalTask(arg0 context.Context, arg1 *dfdaemon.StatLocalTaskRequest) (*dfdaemon.StatLocalTaskResponse, error)
- func (m *MockDfdaemonDownloadServer) StatPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonDownloadServer) StatTask(arg0 context.Context, arg1 *dfdaemon.StatTaskRequest) (*common.Task, error)
- func (m *MockDfdaemonDownloadServer) UploadPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.UploadPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonDownloadServer) UploadPersistentTask(arg0 context.Context, arg1 *dfdaemon.UploadPersistentTaskRequest) (*common.PersistentTask, error)
- type MockDfdaemonDownloadServerMockRecorder
- func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteHost(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadPersistentTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) ListTaskEntries(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) StatCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) StatLocalTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) StatPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) UploadPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) UploadPersistentTask(arg0, arg1 any) *gomock.Call
- type MockDfdaemonDownload_DownloadCacheTaskClient
- func (m *MockDfdaemonDownload_DownloadCacheTaskClient) CloseSend() error
- func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadCacheTaskClient) EXPECT() *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder
- func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Recv() (*dfdaemon.DownloadCacheTaskResponse, error)
- func (m_2 *MockDfdaemonDownload_DownloadCacheTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonDownload_DownloadCacheTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Trailer() metadata.MD
- type MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder
- func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonDownload_DownloadCacheTaskServer
- func (m *MockDfdaemonDownload_DownloadCacheTaskServer) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadCacheTaskServer) EXPECT() *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder
- func (m_2 *MockDfdaemonDownload_DownloadCacheTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadCacheTaskServer) Send(arg0 *dfdaemon.DownloadCacheTaskResponse) error
- func (m *MockDfdaemonDownload_DownloadCacheTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonDownload_DownloadCacheTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadCacheTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonDownload_DownloadCacheTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder
- func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonDownload_DownloadPersistentCacheTaskClient
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) CloseSend() error
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) EXPECT() *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Recv() (*dfdaemon.DownloadPersistentCacheTaskResponse, error)
- func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Trailer() metadata.MD
- type MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonDownload_DownloadPersistentCacheTaskServer
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) EXPECT() *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder
- func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) Send(arg0 *dfdaemon.DownloadPersistentCacheTaskResponse) error
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonDownload_DownloadPersistentTaskClient
- func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) CloseSend() error
- func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) EXPECT() *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder
- func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Recv() (*dfdaemon.DownloadPersistentTaskResponse, error)
- func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Trailer() metadata.MD
- type MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonDownload_DownloadPersistentTaskServer
- func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) EXPECT() *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder
- func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) Send(arg0 *dfdaemon.DownloadPersistentTaskResponse) error
- func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonDownload_DownloadTaskClient
- func (m *MockDfdaemonDownload_DownloadTaskClient) CloseSend() error
- func (m *MockDfdaemonDownload_DownloadTaskClient) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadTaskClient) EXPECT() *MockDfdaemonDownload_DownloadTaskClientMockRecorder
- func (m *MockDfdaemonDownload_DownloadTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonDownload_DownloadTaskClient) Recv() (*dfdaemon.DownloadTaskResponse, error)
- func (m_2 *MockDfdaemonDownload_DownloadTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonDownload_DownloadTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadTaskClient) Trailer() metadata.MD
- type MockDfdaemonDownload_DownloadTaskClientMockRecorder
- func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonDownload_DownloadTaskServer
- func (m *MockDfdaemonDownload_DownloadTaskServer) Context() context.Context
- func (m *MockDfdaemonDownload_DownloadTaskServer) EXPECT() *MockDfdaemonDownload_DownloadTaskServerMockRecorder
- func (m_2 *MockDfdaemonDownload_DownloadTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadTaskServer) Send(arg0 *dfdaemon.DownloadTaskResponse) error
- func (m *MockDfdaemonDownload_DownloadTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonDownload_DownloadTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonDownload_DownloadTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonDownload_DownloadTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonDownload_DownloadTaskServerMockRecorder
- func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUploadClient
- func (m *MockDfdaemonUploadClient) DeleteCacheTask(ctx context.Context, in *dfdaemon.DeleteCacheTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadClient) DeletePersistentCacheTask(ctx context.Context, in *dfdaemon.DeletePersistentCacheTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadClient) DeletePersistentTask(ctx context.Context, in *dfdaemon.DeletePersistentTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadClient) DeleteTask(ctx context.Context, in *dfdaemon.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadClient) DownloadCachePiece(ctx context.Context, in *dfdaemon.DownloadCachePieceRequest, ...) (*dfdaemon.DownloadCachePieceResponse, error)
- func (m *MockDfdaemonUploadClient) DownloadCacheTask(ctx context.Context, in *dfdaemon.DownloadCacheTaskRequest, ...) (dfdaemon.DfdaemonUpload_DownloadCacheTaskClient, error)
- func (m *MockDfdaemonUploadClient) DownloadPersistentCacheTask(ctx context.Context, in *dfdaemon.DownloadPersistentCacheTaskRequest, ...) (dfdaemon.DfdaemonUpload_DownloadPersistentCacheTaskClient, error)
- func (m *MockDfdaemonUploadClient) DownloadPersistentTask(ctx context.Context, in *dfdaemon.DownloadPersistentTaskRequest, ...) (dfdaemon.DfdaemonUpload_DownloadPersistentTaskClient, error)
- func (m *MockDfdaemonUploadClient) DownloadTask(ctx context.Context, in *dfdaemon.DownloadTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_DownloadTaskClient, error)
- func (m *MockDfdaemonUploadClient) EXPECT() *MockDfdaemonUploadClientMockRecorder
- func (m *MockDfdaemonUploadClient) ExchangeIBVerbsQueuePairEndpoint(ctx context.Context, in *dfdaemon.ExchangeIBVerbsQueuePairEndpointRequest, ...) (*dfdaemon.ExchangeIBVerbsQueuePairEndpointResponse, error)
- func (m *MockDfdaemonUploadClient) ListTaskEntries(ctx context.Context, in *dfdaemon.ListTaskEntriesRequest, ...) (*dfdaemon.ListTaskEntriesResponse, error)
- func (m *MockDfdaemonUploadClient) StatCacheTask(ctx context.Context, in *dfdaemon.StatCacheTaskRequest, ...) (*common.CacheTask, error)
- func (m *MockDfdaemonUploadClient) StatLocalTask(ctx context.Context, in *dfdaemon.StatLocalTaskRequest, ...) (*dfdaemon.StatLocalTaskResponse, error)
- func (m *MockDfdaemonUploadClient) StatPersistentCacheTask(ctx context.Context, in *dfdaemon.StatPersistentCacheTaskRequest, ...) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonUploadClient) StatPersistentTask(ctx context.Context, in *dfdaemon.StatPersistentTaskRequest, ...) (*common.PersistentTask, error)
- func (m *MockDfdaemonUploadClient) StatTask(ctx context.Context, in *dfdaemon.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)
- func (m *MockDfdaemonUploadClient) SyncCachePieces(ctx context.Context, in *dfdaemon.SyncCachePiecesRequest, ...) (dfdaemon.DfdaemonUpload_SyncCachePiecesClient, error)
- func (m *MockDfdaemonUploadClient) SyncHost(ctx context.Context, in *dfdaemon.SyncHostRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncHostClient, error)
- func (m *MockDfdaemonUploadClient) SyncPersistentCachePieces(ctx context.Context, in *dfdaemon.SyncPersistentCachePiecesRequest, ...) (dfdaemon.DfdaemonUpload_SyncPersistentCachePiecesClient, error)
- func (m *MockDfdaemonUploadClient) SyncPersistentPieces(ctx context.Context, in *dfdaemon.SyncPersistentPiecesRequest, ...) (dfdaemon.DfdaemonUpload_SyncPersistentPiecesClient, error)
- func (m *MockDfdaemonUploadClient) SyncPieces(ctx context.Context, in *dfdaemon.SyncPiecesRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncPiecesClient, error)
- func (m *MockDfdaemonUploadClient) UpdatePersistentCacheTask(ctx context.Context, in *dfdaemon.UpdatePersistentCacheTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadClient) UpdatePersistentTask(ctx context.Context, in *dfdaemon.UpdatePersistentTaskRequest, ...) (*emptypb.Empty, error)
- type MockDfdaemonUploadClientMockRecorder
- func (mr *MockDfdaemonUploadClientMockRecorder) DeleteCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DeletePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DeletePersistentTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadCachePiece(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadPersistentTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) ExchangeIBVerbsQueuePairEndpoint(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) ListTaskEntries(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) StatCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) StatLocalTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) StatPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) StatPersistentTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) SyncCachePieces(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) SyncHost(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) SyncPersistentCachePieces(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) SyncPersistentPieces(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) SyncPieces(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) UpdatePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) UpdatePersistentTask(ctx, in any, opts ...any) *gomock.Call
- type MockDfdaemonUploadServer
- func (m *MockDfdaemonUploadServer) DeleteCacheTask(arg0 context.Context, arg1 *dfdaemon.DeleteCacheTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadServer) DeletePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadServer) DeletePersistentTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadServer) DeleteTask(arg0 context.Context, arg1 *dfdaemon.DeleteTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadServer) DownloadCachePiece(arg0 context.Context, arg1 *dfdaemon.DownloadCachePieceRequest) (*dfdaemon.DownloadCachePieceResponse, error)
- func (m *MockDfdaemonUploadServer) DownloadCacheTask(arg0 *dfdaemon.DownloadCacheTaskRequest, ...) error
- func (m *MockDfdaemonUploadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, ...) error
- func (m *MockDfdaemonUploadServer) DownloadPersistentTask(arg0 *dfdaemon.DownloadPersistentTaskRequest, ...) error
- func (m *MockDfdaemonUploadServer) DownloadTask(arg0 *dfdaemon.DownloadTaskRequest, ...) error
- func (m *MockDfdaemonUploadServer) EXPECT() *MockDfdaemonUploadServerMockRecorder
- func (m *MockDfdaemonUploadServer) ExchangeIBVerbsQueuePairEndpoint(arg0 context.Context, arg1 *dfdaemon.ExchangeIBVerbsQueuePairEndpointRequest) (*dfdaemon.ExchangeIBVerbsQueuePairEndpointResponse, error)
- func (m *MockDfdaemonUploadServer) ListTaskEntries(arg0 context.Context, arg1 *dfdaemon.ListTaskEntriesRequest) (*dfdaemon.ListTaskEntriesResponse, error)
- func (m *MockDfdaemonUploadServer) StatCacheTask(arg0 context.Context, arg1 *dfdaemon.StatCacheTaskRequest) (*common.CacheTask, error)
- func (m *MockDfdaemonUploadServer) StatLocalTask(arg0 context.Context, arg1 *dfdaemon.StatLocalTaskRequest) (*dfdaemon.StatLocalTaskResponse, error)
- func (m *MockDfdaemonUploadServer) StatPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonUploadServer) StatPersistentTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentTaskRequest) (*common.PersistentTask, error)
- func (m *MockDfdaemonUploadServer) StatTask(arg0 context.Context, arg1 *dfdaemon.StatTaskRequest) (*common.Task, error)
- func (m *MockDfdaemonUploadServer) SyncCachePieces(arg0 *dfdaemon.SyncCachePiecesRequest, ...) error
- func (m *MockDfdaemonUploadServer) SyncHost(arg0 *dfdaemon.SyncHostRequest, arg1 dfdaemon.DfdaemonUpload_SyncHostServer) error
- func (m *MockDfdaemonUploadServer) SyncPersistentCachePieces(arg0 *dfdaemon.SyncPersistentCachePiecesRequest, ...) error
- func (m *MockDfdaemonUploadServer) SyncPersistentPieces(arg0 *dfdaemon.SyncPersistentPiecesRequest, ...) error
- func (m *MockDfdaemonUploadServer) SyncPieces(arg0 *dfdaemon.SyncPiecesRequest, ...) error
- func (m *MockDfdaemonUploadServer) UpdatePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.UpdatePersistentCacheTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadServer) UpdatePersistentTask(arg0 context.Context, arg1 *dfdaemon.UpdatePersistentTaskRequest) (*emptypb.Empty, error)
- type MockDfdaemonUploadServerMockRecorder
- func (mr *MockDfdaemonUploadServerMockRecorder) DeleteCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DeletePersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DeletePersistentTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadCachePiece(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPersistentTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) ExchangeIBVerbsQueuePairEndpoint(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) ListTaskEntries(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) StatCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) StatLocalTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) StatPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) StatPersistentTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) SyncCachePieces(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) SyncHost(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) SyncPersistentCachePieces(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) SyncPersistentPieces(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) SyncPieces(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) UpdatePersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) UpdatePersistentTask(arg0, arg1 any) *gomock.Call
- type MockDfdaemonUpload_DownloadCacheTaskClient
- func (m *MockDfdaemonUpload_DownloadCacheTaskClient) CloseSend() error
- func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadCacheTaskClient) EXPECT() *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder
- func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Recv() (*dfdaemon.DownloadCacheTaskResponse, error)
- func (m_2 *MockDfdaemonUpload_DownloadCacheTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_DownloadCacheTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Trailer() metadata.MD
- type MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder
- func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_DownloadCacheTaskServer
- func (m *MockDfdaemonUpload_DownloadCacheTaskServer) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadCacheTaskServer) EXPECT() *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder
- func (m_2 *MockDfdaemonUpload_DownloadCacheTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadCacheTaskServer) Send(arg0 *dfdaemon.DownloadCacheTaskResponse) error
- func (m *MockDfdaemonUpload_DownloadCacheTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_DownloadCacheTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadCacheTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_DownloadCacheTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder
- func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_DownloadPersistentCacheTaskClient
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) CloseSend() error
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) EXPECT() *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Recv() (*dfdaemon.DownloadPersistentCacheTaskResponse, error)
- func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Trailer() metadata.MD
- type MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_DownloadPersistentCacheTaskServer
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) EXPECT() *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder
- func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) Send(arg0 *dfdaemon.DownloadPersistentCacheTaskResponse) error
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_DownloadPersistentTaskClient
- func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) CloseSend() error
- func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) EXPECT() *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder
- func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Recv() (*dfdaemon.DownloadPersistentTaskResponse, error)
- func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Trailer() metadata.MD
- type MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_DownloadPersistentTaskServer
- func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) EXPECT() *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder
- func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) Send(arg0 *dfdaemon.DownloadPersistentTaskResponse) error
- func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_DownloadTaskClient
- func (m *MockDfdaemonUpload_DownloadTaskClient) CloseSend() error
- func (m *MockDfdaemonUpload_DownloadTaskClient) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadTaskClient) EXPECT() *MockDfdaemonUpload_DownloadTaskClientMockRecorder
- func (m *MockDfdaemonUpload_DownloadTaskClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_DownloadTaskClient) Recv() (*dfdaemon.DownloadTaskResponse, error)
- func (m_2 *MockDfdaemonUpload_DownloadTaskClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_DownloadTaskClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadTaskClient) Trailer() metadata.MD
- type MockDfdaemonUpload_DownloadTaskClientMockRecorder
- func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_DownloadTaskServer
- func (m *MockDfdaemonUpload_DownloadTaskServer) Context() context.Context
- func (m *MockDfdaemonUpload_DownloadTaskServer) EXPECT() *MockDfdaemonUpload_DownloadTaskServerMockRecorder
- func (m_2 *MockDfdaemonUpload_DownloadTaskServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadTaskServer) Send(arg0 *dfdaemon.DownloadTaskResponse) error
- func (m *MockDfdaemonUpload_DownloadTaskServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_DownloadTaskServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_DownloadTaskServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_DownloadTaskServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_DownloadTaskServerMockRecorder
- func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_SyncCachePiecesClient
- func (m *MockDfdaemonUpload_SyncCachePiecesClient) CloseSend() error
- func (m *MockDfdaemonUpload_SyncCachePiecesClient) Context() context.Context
- func (m *MockDfdaemonUpload_SyncCachePiecesClient) EXPECT() *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder
- func (m *MockDfdaemonUpload_SyncCachePiecesClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_SyncCachePiecesClient) Recv() (*dfdaemon.SyncCachePiecesResponse, error)
- func (m_2 *MockDfdaemonUpload_SyncCachePiecesClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_SyncCachePiecesClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncCachePiecesClient) Trailer() metadata.MD
- type MockDfdaemonUpload_SyncCachePiecesClientMockRecorder
- func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_SyncCachePiecesServer
- func (m *MockDfdaemonUpload_SyncCachePiecesServer) Context() context.Context
- func (m *MockDfdaemonUpload_SyncCachePiecesServer) EXPECT() *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder
- func (m_2 *MockDfdaemonUpload_SyncCachePiecesServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_SyncCachePiecesServer) Send(arg0 *dfdaemon.SyncCachePiecesResponse) error
- func (m *MockDfdaemonUpload_SyncCachePiecesServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_SyncCachePiecesServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncCachePiecesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_SyncCachePiecesServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_SyncCachePiecesServerMockRecorder
- func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_SyncHostClient
- func (m *MockDfdaemonUpload_SyncHostClient) CloseSend() error
- func (m *MockDfdaemonUpload_SyncHostClient) Context() context.Context
- func (m *MockDfdaemonUpload_SyncHostClient) EXPECT() *MockDfdaemonUpload_SyncHostClientMockRecorder
- func (m *MockDfdaemonUpload_SyncHostClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_SyncHostClient) Recv() (*common.Host, error)
- func (m_2 *MockDfdaemonUpload_SyncHostClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_SyncHostClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncHostClient) Trailer() metadata.MD
- type MockDfdaemonUpload_SyncHostClientMockRecorder
- func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_SyncHostServer
- func (m *MockDfdaemonUpload_SyncHostServer) Context() context.Context
- func (m *MockDfdaemonUpload_SyncHostServer) EXPECT() *MockDfdaemonUpload_SyncHostServerMockRecorder
- func (m_2 *MockDfdaemonUpload_SyncHostServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_SyncHostServer) Send(arg0 *common.Host) error
- func (m *MockDfdaemonUpload_SyncHostServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_SyncHostServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncHostServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_SyncHostServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_SyncHostServerMockRecorder
- func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_SyncPersistentCachePiecesClient
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) CloseSend() error
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Context() context.Context
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) EXPECT() *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Recv() (*dfdaemon.SyncPersistentCachePiecesResponse, error)
- func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Trailer() metadata.MD
- type MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_SyncPersistentCachePiecesServer
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) Context() context.Context
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) EXPECT() *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder
- func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) Send(arg0 *dfdaemon.SyncPersistentCachePiecesResponse) error
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_SyncPersistentPiecesClient
- func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) CloseSend() error
- func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Context() context.Context
- func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) EXPECT() *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder
- func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Recv() (*dfdaemon.SyncPersistentPiecesResponse, error)
- func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Trailer() metadata.MD
- type MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_SyncPersistentPiecesServer
- func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) Context() context.Context
- func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) EXPECT() *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder
- func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) Send(arg0 *dfdaemon.SyncPersistentPiecesResponse) error
- func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockDfdaemonUpload_SyncPiecesClient
- func (m *MockDfdaemonUpload_SyncPiecesClient) CloseSend() error
- func (m *MockDfdaemonUpload_SyncPiecesClient) Context() context.Context
- func (m *MockDfdaemonUpload_SyncPiecesClient) EXPECT() *MockDfdaemonUpload_SyncPiecesClientMockRecorder
- func (m *MockDfdaemonUpload_SyncPiecesClient) Header() (metadata.MD, error)
- func (m *MockDfdaemonUpload_SyncPiecesClient) Recv() (*dfdaemon.SyncPiecesResponse, error)
- func (m_2 *MockDfdaemonUpload_SyncPiecesClient) RecvMsg(m any) error
- func (m_2 *MockDfdaemonUpload_SyncPiecesClient) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPiecesClient) Trailer() metadata.MD
- type MockDfdaemonUpload_SyncPiecesClientMockRecorder
- func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Header() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Trailer() *gomock.Call
- type MockDfdaemonUpload_SyncPiecesServer
- func (m *MockDfdaemonUpload_SyncPiecesServer) Context() context.Context
- func (m *MockDfdaemonUpload_SyncPiecesServer) EXPECT() *MockDfdaemonUpload_SyncPiecesServerMockRecorder
- func (m_2 *MockDfdaemonUpload_SyncPiecesServer) RecvMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPiecesServer) Send(arg0 *dfdaemon.SyncPiecesResponse) error
- func (m *MockDfdaemonUpload_SyncPiecesServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockDfdaemonUpload_SyncPiecesServer) SendMsg(m any) error
- func (m *MockDfdaemonUpload_SyncPiecesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDfdaemonUpload_SyncPiecesServer) SetTrailer(arg0 metadata.MD)
- type MockDfdaemonUpload_SyncPiecesServerMockRecorder
- func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) Context() *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) Send(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SendMsg(m any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
- func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
- type MockUnsafeDfdaemonDownloadServer
- type MockUnsafeDfdaemonDownloadServerMockRecorder
- type MockUnsafeDfdaemonUploadServer
- type MockUnsafeDfdaemonUploadServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockDfdaemonDownloadClient ¶ added in v2.0.63
type MockDfdaemonDownloadClient struct {
// contains filtered or unexported fields
}
MockDfdaemonDownloadClient is a mock of DfdaemonDownloadClient interface.
func NewMockDfdaemonDownloadClient ¶ added in v2.0.63
func NewMockDfdaemonDownloadClient(ctrl *gomock.Controller) *MockDfdaemonDownloadClient
NewMockDfdaemonDownloadClient creates a new mock instance.
func (*MockDfdaemonDownloadClient) DeleteCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonDownloadClient) DeleteCacheTask(ctx context.Context, in *dfdaemon.DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteCacheTask mocks base method.
func (*MockDfdaemonDownloadClient) DeleteHost ¶ added in v2.0.120
func (m *MockDfdaemonDownloadClient) DeleteHost(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteHost mocks base method.
func (*MockDfdaemonDownloadClient) DeleteTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadClient) DeleteTask(ctx context.Context, in *dfdaemon.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteTask mocks base method.
func (*MockDfdaemonDownloadClient) DownloadCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonDownloadClient) DownloadCacheTask(ctx context.Context, in *dfdaemon.DownloadCacheTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonDownload_DownloadCacheTaskClient, error)
DownloadCacheTask mocks base method.
func (*MockDfdaemonDownloadClient) DownloadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadClient) DownloadPersistentCacheTask(ctx context.Context, in *dfdaemon.DownloadPersistentCacheTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonDownload_DownloadPersistentCacheTaskClient, error)
DownloadPersistentCacheTask mocks base method.
func (*MockDfdaemonDownloadClient) DownloadPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonDownloadClient) DownloadPersistentTask(ctx context.Context, in *dfdaemon.DownloadPersistentTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonDownload_DownloadPersistentTaskClient, error)
DownloadPersistentTask mocks base method.
func (*MockDfdaemonDownloadClient) DownloadTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadClient) DownloadTask(ctx context.Context, in *dfdaemon.DownloadTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonDownload_DownloadTaskClient, error)
DownloadTask mocks base method.
func (*MockDfdaemonDownloadClient) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonDownloadClient) EXPECT() *MockDfdaemonDownloadClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownloadClient) ListTaskEntries ¶ added in v2.1.41
func (m *MockDfdaemonDownloadClient) ListTaskEntries(ctx context.Context, in *dfdaemon.ListTaskEntriesRequest, opts ...grpc.CallOption) (*dfdaemon.ListTaskEntriesResponse, error)
ListTaskEntries mocks base method.
func (*MockDfdaemonDownloadClient) StatCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonDownloadClient) StatCacheTask(ctx context.Context, in *dfdaemon.StatCacheTaskRequest, opts ...grpc.CallOption) (*common.CacheTask, error)
StatCacheTask mocks base method.
func (*MockDfdaemonDownloadClient) StatLocalTask ¶ added in v2.1.97
func (m *MockDfdaemonDownloadClient) StatLocalTask(ctx context.Context, in *dfdaemon.StatLocalTaskRequest, opts ...grpc.CallOption) (*dfdaemon.StatLocalTaskResponse, error)
StatLocalTask mocks base method.
func (*MockDfdaemonDownloadClient) StatPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadClient) StatPersistentCacheTask(ctx context.Context, in *dfdaemon.StatPersistentCacheTaskRequest, opts ...grpc.CallOption) (*common.PersistentCacheTask, error)
StatPersistentCacheTask mocks base method.
func (*MockDfdaemonDownloadClient) StatTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadClient) StatTask(ctx context.Context, in *dfdaemon.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)
StatTask mocks base method.
func (*MockDfdaemonDownloadClient) UploadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadClient) UploadPersistentCacheTask(ctx context.Context, in *dfdaemon.UploadPersistentCacheTaskRequest, opts ...grpc.CallOption) (*common.PersistentCacheTask, error)
UploadPersistentCacheTask mocks base method.
func (*MockDfdaemonDownloadClient) UploadPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonDownloadClient) UploadPersistentTask(ctx context.Context, in *dfdaemon.UploadPersistentTaskRequest, opts ...grpc.CallOption) (*common.PersistentTask, error)
UploadPersistentTask mocks base method.
type MockDfdaemonDownloadClientMockRecorder ¶ added in v2.0.63
type MockDfdaemonDownloadClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownloadClientMockRecorder is the mock recorder for MockDfdaemonDownloadClient.
func (*MockDfdaemonDownloadClientMockRecorder) DeleteCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteCacheTask(ctx, in any, opts ...any) *gomock.Call
DeleteCacheTask indicates an expected call of DeleteCacheTask.
func (*MockDfdaemonDownloadClientMockRecorder) DeleteHost ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteHost(ctx, in any, opts ...any) *gomock.Call
DeleteHost indicates an expected call of DeleteHost.
func (*MockDfdaemonDownloadClientMockRecorder) DeleteTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
DeleteTask indicates an expected call of DeleteTask.
func (*MockDfdaemonDownloadClientMockRecorder) DownloadCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadCacheTask(ctx, in any, opts ...any) *gomock.Call
DownloadCacheTask indicates an expected call of DownloadCacheTask.
func (*MockDfdaemonDownloadClientMockRecorder) DownloadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
DownloadPersistentCacheTask indicates an expected call of DownloadPersistentCacheTask.
func (*MockDfdaemonDownloadClientMockRecorder) DownloadPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadPersistentTask(ctx, in any, opts ...any) *gomock.Call
DownloadPersistentTask indicates an expected call of DownloadPersistentTask.
func (*MockDfdaemonDownloadClientMockRecorder) DownloadTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadTask(ctx, in any, opts ...any) *gomock.Call
DownloadTask indicates an expected call of DownloadTask.
func (*MockDfdaemonDownloadClientMockRecorder) ListTaskEntries ¶ added in v2.1.41
func (mr *MockDfdaemonDownloadClientMockRecorder) ListTaskEntries(ctx, in any, opts ...any) *gomock.Call
ListTaskEntries indicates an expected call of ListTaskEntries.
func (*MockDfdaemonDownloadClientMockRecorder) StatCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadClientMockRecorder) StatCacheTask(ctx, in any, opts ...any) *gomock.Call
StatCacheTask indicates an expected call of StatCacheTask.
func (*MockDfdaemonDownloadClientMockRecorder) StatLocalTask ¶ added in v2.1.97
func (mr *MockDfdaemonDownloadClientMockRecorder) StatLocalTask(ctx, in any, opts ...any) *gomock.Call
StatLocalTask indicates an expected call of StatLocalTask.
func (*MockDfdaemonDownloadClientMockRecorder) StatPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadClientMockRecorder) StatPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
StatPersistentCacheTask indicates an expected call of StatPersistentCacheTask.
func (*MockDfdaemonDownloadClientMockRecorder) StatTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockDfdaemonDownloadClientMockRecorder) UploadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadClientMockRecorder) UploadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
UploadPersistentCacheTask indicates an expected call of UploadPersistentCacheTask.
func (*MockDfdaemonDownloadClientMockRecorder) UploadPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonDownloadClientMockRecorder) UploadPersistentTask(ctx, in any, opts ...any) *gomock.Call
UploadPersistentTask indicates an expected call of UploadPersistentTask.
type MockDfdaemonDownloadServer ¶ added in v2.0.63
type MockDfdaemonDownloadServer struct {
// contains filtered or unexported fields
}
MockDfdaemonDownloadServer is a mock of DfdaemonDownloadServer interface.
func NewMockDfdaemonDownloadServer ¶ added in v2.0.63
func NewMockDfdaemonDownloadServer(ctrl *gomock.Controller) *MockDfdaemonDownloadServer
NewMockDfdaemonDownloadServer creates a new mock instance.
func (*MockDfdaemonDownloadServer) DeleteCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonDownloadServer) DeleteCacheTask(arg0 context.Context, arg1 *dfdaemon.DeleteCacheTaskRequest) (*emptypb.Empty, error)
DeleteCacheTask mocks base method.
func (*MockDfdaemonDownloadServer) DeleteHost ¶ added in v2.0.120
func (m *MockDfdaemonDownloadServer) DeleteHost(arg0 context.Context, arg1 *emptypb.Empty) (*emptypb.Empty, error)
DeleteHost mocks base method.
func (*MockDfdaemonDownloadServer) DeleteTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadServer) DeleteTask(arg0 context.Context, arg1 *dfdaemon.DeleteTaskRequest) (*emptypb.Empty, error)
DeleteTask mocks base method.
func (*MockDfdaemonDownloadServer) DownloadCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonDownloadServer) DownloadCacheTask(arg0 *dfdaemon.DownloadCacheTaskRequest, arg1 dfdaemon.DfdaemonDownload_DownloadCacheTaskServer) error
DownloadCacheTask mocks base method.
func (*MockDfdaemonDownloadServer) DownloadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, arg1 dfdaemon.DfdaemonDownload_DownloadPersistentCacheTaskServer) error
DownloadPersistentCacheTask mocks base method.
func (*MockDfdaemonDownloadServer) DownloadPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonDownloadServer) DownloadPersistentTask(arg0 *dfdaemon.DownloadPersistentTaskRequest, arg1 dfdaemon.DfdaemonDownload_DownloadPersistentTaskServer) error
DownloadPersistentTask mocks base method.
func (*MockDfdaemonDownloadServer) DownloadTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadServer) DownloadTask(arg0 *dfdaemon.DownloadTaskRequest, arg1 dfdaemon.DfdaemonDownload_DownloadTaskServer) error
DownloadTask mocks base method.
func (*MockDfdaemonDownloadServer) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonDownloadServer) EXPECT() *MockDfdaemonDownloadServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownloadServer) ListTaskEntries ¶ added in v2.1.41
func (m *MockDfdaemonDownloadServer) ListTaskEntries(arg0 context.Context, arg1 *dfdaemon.ListTaskEntriesRequest) (*dfdaemon.ListTaskEntriesResponse, error)
ListTaskEntries mocks base method.
func (*MockDfdaemonDownloadServer) StatCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonDownloadServer) StatCacheTask(arg0 context.Context, arg1 *dfdaemon.StatCacheTaskRequest) (*common.CacheTask, error)
StatCacheTask mocks base method.
func (*MockDfdaemonDownloadServer) StatLocalTask ¶ added in v2.1.97
func (m *MockDfdaemonDownloadServer) StatLocalTask(arg0 context.Context, arg1 *dfdaemon.StatLocalTaskRequest) (*dfdaemon.StatLocalTaskResponse, error)
StatLocalTask mocks base method.
func (*MockDfdaemonDownloadServer) StatPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadServer) StatPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)
StatPersistentCacheTask mocks base method.
func (*MockDfdaemonDownloadServer) StatTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadServer) StatTask(arg0 context.Context, arg1 *dfdaemon.StatTaskRequest) (*common.Task, error)
StatTask mocks base method.
func (*MockDfdaemonDownloadServer) UploadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadServer) UploadPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.UploadPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)
UploadPersistentCacheTask mocks base method.
func (*MockDfdaemonDownloadServer) UploadPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonDownloadServer) UploadPersistentTask(arg0 context.Context, arg1 *dfdaemon.UploadPersistentTaskRequest) (*common.PersistentTask, error)
UploadPersistentTask mocks base method.
type MockDfdaemonDownloadServerMockRecorder ¶ added in v2.0.63
type MockDfdaemonDownloadServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownloadServerMockRecorder is the mock recorder for MockDfdaemonDownloadServer.
func (*MockDfdaemonDownloadServerMockRecorder) DeleteCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteCacheTask(arg0, arg1 any) *gomock.Call
DeleteCacheTask indicates an expected call of DeleteCacheTask.
func (*MockDfdaemonDownloadServerMockRecorder) DeleteHost ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteHost(arg0, arg1 any) *gomock.Call
DeleteHost indicates an expected call of DeleteHost.
func (*MockDfdaemonDownloadServerMockRecorder) DeleteTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
DeleteTask indicates an expected call of DeleteTask.
func (*MockDfdaemonDownloadServerMockRecorder) DownloadCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadCacheTask(arg0, arg1 any) *gomock.Call
DownloadCacheTask indicates an expected call of DownloadCacheTask.
func (*MockDfdaemonDownloadServerMockRecorder) DownloadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
DownloadPersistentCacheTask indicates an expected call of DownloadPersistentCacheTask.
func (*MockDfdaemonDownloadServerMockRecorder) DownloadPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadPersistentTask(arg0, arg1 any) *gomock.Call
DownloadPersistentTask indicates an expected call of DownloadPersistentTask.
func (*MockDfdaemonDownloadServerMockRecorder) DownloadTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadTask(arg0, arg1 any) *gomock.Call
DownloadTask indicates an expected call of DownloadTask.
func (*MockDfdaemonDownloadServerMockRecorder) ListTaskEntries ¶ added in v2.1.41
func (mr *MockDfdaemonDownloadServerMockRecorder) ListTaskEntries(arg0, arg1 any) *gomock.Call
ListTaskEntries indicates an expected call of ListTaskEntries.
func (*MockDfdaemonDownloadServerMockRecorder) StatCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadServerMockRecorder) StatCacheTask(arg0, arg1 any) *gomock.Call
StatCacheTask indicates an expected call of StatCacheTask.
func (*MockDfdaemonDownloadServerMockRecorder) StatLocalTask ¶ added in v2.1.97
func (mr *MockDfdaemonDownloadServerMockRecorder) StatLocalTask(arg0, arg1 any) *gomock.Call
StatLocalTask indicates an expected call of StatLocalTask.
func (*MockDfdaemonDownloadServerMockRecorder) StatPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadServerMockRecorder) StatPersistentCacheTask(arg0, arg1 any) *gomock.Call
StatPersistentCacheTask indicates an expected call of StatPersistentCacheTask.
func (*MockDfdaemonDownloadServerMockRecorder) StatTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockDfdaemonDownloadServerMockRecorder) UploadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadServerMockRecorder) UploadPersistentCacheTask(arg0, arg1 any) *gomock.Call
UploadPersistentCacheTask indicates an expected call of UploadPersistentCacheTask.
func (*MockDfdaemonDownloadServerMockRecorder) UploadPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonDownloadServerMockRecorder) UploadPersistentTask(arg0, arg1 any) *gomock.Call
UploadPersistentTask indicates an expected call of UploadPersistentTask.
type MockDfdaemonDownload_DownloadCacheTaskClient ¶ added in v2.0.120
type MockDfdaemonDownload_DownloadCacheTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadCacheTaskClient is a mock of DfdaemonDownload_DownloadCacheTaskClient interface.
func NewMockDfdaemonDownload_DownloadCacheTaskClient ¶ added in v2.0.120
func NewMockDfdaemonDownload_DownloadCacheTaskClient(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadCacheTaskClient
NewMockDfdaemonDownload_DownloadCacheTaskClient creates a new mock instance.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) CloseSend ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) Context ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) EXPECT ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskClient) EXPECT() *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) Header ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) Recv ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Recv() (*dfdaemon.DownloadCacheTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) RecvMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonDownload_DownloadCacheTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) SendMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonDownload_DownloadCacheTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskClient) Trailer ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder ¶ added in v2.0.120
type MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadCacheTaskClient.
func (*MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) CloseSend ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Context ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Header ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Recv ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) RecvMsg ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) SendMsg ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Trailer ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonDownload_DownloadCacheTaskServer ¶ added in v2.0.120
type MockDfdaemonDownload_DownloadCacheTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadCacheTaskServer is a mock of DfdaemonDownload_DownloadCacheTaskServer interface.
func NewMockDfdaemonDownload_DownloadCacheTaskServer ¶ added in v2.0.120
func NewMockDfdaemonDownload_DownloadCacheTaskServer(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadCacheTaskServer
NewMockDfdaemonDownload_DownloadCacheTaskServer creates a new mock instance.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) Context ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) EXPECT ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskServer) EXPECT() *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) RecvMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonDownload_DownloadCacheTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) Send ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskServer) Send(arg0 *dfdaemon.DownloadCacheTaskResponse) error
Send mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) SendHeader ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) SendMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonDownload_DownloadCacheTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) SetHeader ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonDownload_DownloadCacheTaskServer) SetTrailer ¶ added in v2.0.120
func (m *MockDfdaemonDownload_DownloadCacheTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder ¶ added in v2.0.120
type MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadCacheTaskServer.
func (*MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) Context ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) RecvMsg ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) Send ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SendHeader ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SendMsg ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SetHeader ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SetTrailer ¶ added in v2.0.120
func (mr *MockDfdaemonDownload_DownloadCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonDownload_DownloadPersistentCacheTaskClient ¶ added in v2.0.162
type MockDfdaemonDownload_DownloadPersistentCacheTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentCacheTaskClient is a mock of DfdaemonDownload_DownloadPersistentCacheTaskClient interface.
func NewMockDfdaemonDownload_DownloadPersistentCacheTaskClient ¶ added in v2.0.162
func NewMockDfdaemonDownload_DownloadPersistentCacheTaskClient(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadPersistentCacheTaskClient
NewMockDfdaemonDownload_DownloadPersistentCacheTaskClient creates a new mock instance.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) CloseSend ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Context ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) EXPECT ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) EXPECT() *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Header ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Recv ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Recv() (*dfdaemon.DownloadPersistentCacheTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) RecvMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) SendMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Trailer ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder ¶ added in v2.0.162
type MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadPersistentCacheTaskClient.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) CloseSend ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Context ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Header ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Recv ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) RecvMsg ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) SendMsg ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Trailer ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonDownload_DownloadPersistentCacheTaskServer ¶ added in v2.0.162
type MockDfdaemonDownload_DownloadPersistentCacheTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentCacheTaskServer is a mock of DfdaemonDownload_DownloadPersistentCacheTaskServer interface.
func NewMockDfdaemonDownload_DownloadPersistentCacheTaskServer ¶ added in v2.0.162
func NewMockDfdaemonDownload_DownloadPersistentCacheTaskServer(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadPersistentCacheTaskServer
NewMockDfdaemonDownload_DownloadPersistentCacheTaskServer creates a new mock instance.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) Context ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) EXPECT ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) EXPECT() *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) RecvMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) Send ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) Send(arg0 *dfdaemon.DownloadPersistentCacheTaskResponse) error
Send mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SendHeader ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SendMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SetHeader ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SetTrailer ¶ added in v2.0.162
func (m *MockDfdaemonDownload_DownloadPersistentCacheTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder ¶ added in v2.0.162
type MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadPersistentCacheTaskServer.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) Context ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) RecvMsg ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) Send ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SendHeader ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SendMsg ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SetHeader ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SetTrailer ¶ added in v2.0.162
func (mr *MockDfdaemonDownload_DownloadPersistentCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonDownload_DownloadPersistentTaskClient ¶ added in v2.1.86
type MockDfdaemonDownload_DownloadPersistentTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentTaskClient is a mock of DfdaemonDownload_DownloadPersistentTaskClient interface.
func NewMockDfdaemonDownload_DownloadPersistentTaskClient ¶ added in v2.1.86
func NewMockDfdaemonDownload_DownloadPersistentTaskClient(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadPersistentTaskClient
NewMockDfdaemonDownload_DownloadPersistentTaskClient creates a new mock instance.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) CloseSend ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) Context ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) EXPECT ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) EXPECT() *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) Header ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) Recv ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Recv() (*dfdaemon.DownloadPersistentTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) RecvMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) SendMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskClient) Trailer ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder ¶ added in v2.1.86
type MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadPersistentTaskClient.
func (*MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) CloseSend ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Context ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Header ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Recv ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) RecvMsg ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) SendMsg ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Trailer ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonDownload_DownloadPersistentTaskServer ¶ added in v2.1.86
type MockDfdaemonDownload_DownloadPersistentTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentTaskServer is a mock of DfdaemonDownload_DownloadPersistentTaskServer interface.
func NewMockDfdaemonDownload_DownloadPersistentTaskServer ¶ added in v2.1.86
func NewMockDfdaemonDownload_DownloadPersistentTaskServer(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadPersistentTaskServer
NewMockDfdaemonDownload_DownloadPersistentTaskServer creates a new mock instance.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) Context ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) EXPECT ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) EXPECT() *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) RecvMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) Send ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) Send(arg0 *dfdaemon.DownloadPersistentTaskResponse) error
Send mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) SendHeader ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) SendMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonDownload_DownloadPersistentTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) SetHeader ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonDownload_DownloadPersistentTaskServer) SetTrailer ¶ added in v2.1.86
func (m *MockDfdaemonDownload_DownloadPersistentTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder ¶ added in v2.1.86
type MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadPersistentTaskServer.
func (*MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) Context ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) RecvMsg ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) Send ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SendHeader ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SendMsg ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SetHeader ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SetTrailer ¶ added in v2.1.86
func (mr *MockDfdaemonDownload_DownloadPersistentTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonDownload_DownloadTaskClient ¶ added in v2.0.63
type MockDfdaemonDownload_DownloadTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadTaskClient is a mock of DfdaemonDownload_DownloadTaskClient interface.
func NewMockDfdaemonDownload_DownloadTaskClient ¶ added in v2.0.63
func NewMockDfdaemonDownload_DownloadTaskClient(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadTaskClient
NewMockDfdaemonDownload_DownloadTaskClient creates a new mock instance.
func (*MockDfdaemonDownload_DownloadTaskClient) CloseSend ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonDownload_DownloadTaskClient) Context ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadTaskClient) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskClient) EXPECT() *MockDfdaemonDownload_DownloadTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadTaskClient) Header ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonDownload_DownloadTaskClient) Recv ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskClient) Recv() (*dfdaemon.DownloadTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonDownload_DownloadTaskClient) RecvMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonDownload_DownloadTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadTaskClient) SendMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonDownload_DownloadTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadTaskClient) Trailer ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonDownload_DownloadTaskClientMockRecorder ¶ added in v2.0.63
type MockDfdaemonDownload_DownloadTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadTaskClientMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadTaskClient.
func (*MockDfdaemonDownload_DownloadTaskClientMockRecorder) CloseSend ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonDownload_DownloadTaskClientMockRecorder) Context ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadTaskClientMockRecorder) Header ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonDownload_DownloadTaskClientMockRecorder) Recv ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonDownload_DownloadTaskClientMockRecorder) RecvMsg ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadTaskClientMockRecorder) SendMsg ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadTaskClientMockRecorder) Trailer ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonDownload_DownloadTaskServer ¶ added in v2.0.63
type MockDfdaemonDownload_DownloadTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadTaskServer is a mock of DfdaemonDownload_DownloadTaskServer interface.
func NewMockDfdaemonDownload_DownloadTaskServer ¶ added in v2.0.63
func NewMockDfdaemonDownload_DownloadTaskServer(ctrl *gomock.Controller) *MockDfdaemonDownload_DownloadTaskServer
NewMockDfdaemonDownload_DownloadTaskServer creates a new mock instance.
func (*MockDfdaemonDownload_DownloadTaskServer) Context ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonDownload_DownloadTaskServer) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskServer) EXPECT() *MockDfdaemonDownload_DownloadTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonDownload_DownloadTaskServer) RecvMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonDownload_DownloadTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonDownload_DownloadTaskServer) Send ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskServer) Send(arg0 *dfdaemon.DownloadTaskResponse) error
Send mocks base method.
func (*MockDfdaemonDownload_DownloadTaskServer) SendHeader ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonDownload_DownloadTaskServer) SendMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonDownload_DownloadTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonDownload_DownloadTaskServer) SetHeader ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonDownload_DownloadTaskServer) SetTrailer ¶ added in v2.0.63
func (m *MockDfdaemonDownload_DownloadTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonDownload_DownloadTaskServerMockRecorder ¶ added in v2.0.63
type MockDfdaemonDownload_DownloadTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonDownload_DownloadTaskServerMockRecorder is the mock recorder for MockDfdaemonDownload_DownloadTaskServer.
func (*MockDfdaemonDownload_DownloadTaskServerMockRecorder) Context ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonDownload_DownloadTaskServerMockRecorder) RecvMsg ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonDownload_DownloadTaskServerMockRecorder) Send ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonDownload_DownloadTaskServerMockRecorder) SendHeader ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonDownload_DownloadTaskServerMockRecorder) SendMsg ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonDownload_DownloadTaskServerMockRecorder) SetHeader ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonDownload_DownloadTaskServerMockRecorder) SetTrailer ¶ added in v2.0.63
func (mr *MockDfdaemonDownload_DownloadTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUploadClient ¶ added in v2.0.63
type MockDfdaemonUploadClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUploadClient is a mock of DfdaemonUploadClient interface.
func NewMockDfdaemonUploadClient ¶ added in v2.0.63
func NewMockDfdaemonUploadClient(ctrl *gomock.Controller) *MockDfdaemonUploadClient
NewMockDfdaemonUploadClient creates a new mock instance.
func (*MockDfdaemonUploadClient) DeleteCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonUploadClient) DeleteCacheTask(ctx context.Context, in *dfdaemon.DeleteCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteCacheTask mocks base method.
func (*MockDfdaemonUploadClient) DeletePersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonUploadClient) DeletePersistentCacheTask(ctx context.Context, in *dfdaemon.DeletePersistentCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeletePersistentCacheTask mocks base method.
func (*MockDfdaemonUploadClient) DeletePersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadClient) DeletePersistentTask(ctx context.Context, in *dfdaemon.DeletePersistentTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeletePersistentTask mocks base method.
func (*MockDfdaemonUploadClient) DeleteTask ¶ added in v2.0.148
func (m *MockDfdaemonUploadClient) DeleteTask(ctx context.Context, in *dfdaemon.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteTask mocks base method.
func (*MockDfdaemonUploadClient) DownloadCachePiece ¶ added in v2.1.50
func (m *MockDfdaemonUploadClient) DownloadCachePiece(ctx context.Context, in *dfdaemon.DownloadCachePieceRequest, opts ...grpc.CallOption) (*dfdaemon.DownloadCachePieceResponse, error)
DownloadCachePiece mocks base method.
func (*MockDfdaemonUploadClient) DownloadCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonUploadClient) DownloadCacheTask(ctx context.Context, in *dfdaemon.DownloadCacheTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_DownloadCacheTaskClient, error)
DownloadCacheTask mocks base method.
func (*MockDfdaemonUploadClient) DownloadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonUploadClient) DownloadPersistentCacheTask(ctx context.Context, in *dfdaemon.DownloadPersistentCacheTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_DownloadPersistentCacheTaskClient, error)
DownloadPersistentCacheTask mocks base method.
func (*MockDfdaemonUploadClient) DownloadPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadClient) DownloadPersistentTask(ctx context.Context, in *dfdaemon.DownloadPersistentTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_DownloadPersistentTaskClient, error)
DownloadPersistentTask mocks base method.
func (*MockDfdaemonUploadClient) DownloadTask ¶ added in v2.0.64
func (m *MockDfdaemonUploadClient) DownloadTask(ctx context.Context, in *dfdaemon.DownloadTaskRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_DownloadTaskClient, error)
DownloadTask mocks base method.
func (*MockDfdaemonUploadClient) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonUploadClient) EXPECT() *MockDfdaemonUploadClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUploadClient) ExchangeIBVerbsQueuePairEndpoint ¶ added in v2.1.35
func (m *MockDfdaemonUploadClient) ExchangeIBVerbsQueuePairEndpoint(ctx context.Context, in *dfdaemon.ExchangeIBVerbsQueuePairEndpointRequest, opts ...grpc.CallOption) (*dfdaemon.ExchangeIBVerbsQueuePairEndpointResponse, error)
ExchangeIBVerbsQueuePairEndpoint mocks base method.
func (*MockDfdaemonUploadClient) ListTaskEntries ¶ added in v2.1.72
func (m *MockDfdaemonUploadClient) ListTaskEntries(ctx context.Context, in *dfdaemon.ListTaskEntriesRequest, opts ...grpc.CallOption) (*dfdaemon.ListTaskEntriesResponse, error)
ListTaskEntries mocks base method.
func (*MockDfdaemonUploadClient) StatCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonUploadClient) StatCacheTask(ctx context.Context, in *dfdaemon.StatCacheTaskRequest, opts ...grpc.CallOption) (*common.CacheTask, error)
StatCacheTask mocks base method.
func (*MockDfdaemonUploadClient) StatLocalTask ¶ added in v2.1.97
func (m *MockDfdaemonUploadClient) StatLocalTask(ctx context.Context, in *dfdaemon.StatLocalTaskRequest, opts ...grpc.CallOption) (*dfdaemon.StatLocalTaskResponse, error)
StatLocalTask mocks base method.
func (*MockDfdaemonUploadClient) StatPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonUploadClient) StatPersistentCacheTask(ctx context.Context, in *dfdaemon.StatPersistentCacheTaskRequest, opts ...grpc.CallOption) (*common.PersistentCacheTask, error)
StatPersistentCacheTask mocks base method.
func (*MockDfdaemonUploadClient) StatPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadClient) StatPersistentTask(ctx context.Context, in *dfdaemon.StatPersistentTaskRequest, opts ...grpc.CallOption) (*common.PersistentTask, error)
StatPersistentTask mocks base method.
func (*MockDfdaemonUploadClient) StatTask ¶ added in v2.0.148
func (m *MockDfdaemonUploadClient) StatTask(ctx context.Context, in *dfdaemon.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)
StatTask mocks base method.
func (*MockDfdaemonUploadClient) SyncCachePieces ¶ added in v2.1.50
func (m *MockDfdaemonUploadClient) SyncCachePieces(ctx context.Context, in *dfdaemon.SyncCachePiecesRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncCachePiecesClient, error)
SyncCachePieces mocks base method.
func (*MockDfdaemonUploadClient) SyncHost ¶ added in v2.1.2
func (m *MockDfdaemonUploadClient) SyncHost(ctx context.Context, in *dfdaemon.SyncHostRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncHostClient, error)
SyncHost mocks base method.
func (*MockDfdaemonUploadClient) SyncPersistentCachePieces ¶ added in v2.1.13
func (m *MockDfdaemonUploadClient) SyncPersistentCachePieces(ctx context.Context, in *dfdaemon.SyncPersistentCachePiecesRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncPersistentCachePiecesClient, error)
SyncPersistentCachePieces mocks base method.
func (*MockDfdaemonUploadClient) SyncPersistentPieces ¶ added in v2.1.86
func (m *MockDfdaemonUploadClient) SyncPersistentPieces(ctx context.Context, in *dfdaemon.SyncPersistentPiecesRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncPersistentPiecesClient, error)
SyncPersistentPieces mocks base method.
func (*MockDfdaemonUploadClient) SyncPieces ¶ added in v2.0.63
func (m *MockDfdaemonUploadClient) SyncPieces(ctx context.Context, in *dfdaemon.SyncPiecesRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncPiecesClient, error)
SyncPieces mocks base method.
func (*MockDfdaemonUploadClient) UpdatePersistentCacheTask ¶ added in v2.1.14
func (m *MockDfdaemonUploadClient) UpdatePersistentCacheTask(ctx context.Context, in *dfdaemon.UpdatePersistentCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
UpdatePersistentCacheTask mocks base method.
func (*MockDfdaemonUploadClient) UpdatePersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadClient) UpdatePersistentTask(ctx context.Context, in *dfdaemon.UpdatePersistentTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
UpdatePersistentTask mocks base method.
type MockDfdaemonUploadClientMockRecorder ¶ added in v2.0.63
type MockDfdaemonUploadClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUploadClientMockRecorder is the mock recorder for MockDfdaemonUploadClient.
func (*MockDfdaemonUploadClientMockRecorder) DeleteCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonUploadClientMockRecorder) DeleteCacheTask(ctx, in any, opts ...any) *gomock.Call
DeleteCacheTask indicates an expected call of DeleteCacheTask.
func (*MockDfdaemonUploadClientMockRecorder) DeletePersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadClientMockRecorder) DeletePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
DeletePersistentCacheTask indicates an expected call of DeletePersistentCacheTask.
func (*MockDfdaemonUploadClientMockRecorder) DeletePersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadClientMockRecorder) DeletePersistentTask(ctx, in any, opts ...any) *gomock.Call
DeletePersistentTask indicates an expected call of DeletePersistentTask.
func (*MockDfdaemonUploadClientMockRecorder) DeleteTask ¶ added in v2.0.148
func (mr *MockDfdaemonUploadClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
DeleteTask indicates an expected call of DeleteTask.
func (*MockDfdaemonUploadClientMockRecorder) DownloadCachePiece ¶ added in v2.1.50
func (mr *MockDfdaemonUploadClientMockRecorder) DownloadCachePiece(ctx, in any, opts ...any) *gomock.Call
DownloadCachePiece indicates an expected call of DownloadCachePiece.
func (*MockDfdaemonUploadClientMockRecorder) DownloadCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonUploadClientMockRecorder) DownloadCacheTask(ctx, in any, opts ...any) *gomock.Call
DownloadCacheTask indicates an expected call of DownloadCacheTask.
func (*MockDfdaemonUploadClientMockRecorder) DownloadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadClientMockRecorder) DownloadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
DownloadPersistentCacheTask indicates an expected call of DownloadPersistentCacheTask.
func (*MockDfdaemonUploadClientMockRecorder) DownloadPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadClientMockRecorder) DownloadPersistentTask(ctx, in any, opts ...any) *gomock.Call
DownloadPersistentTask indicates an expected call of DownloadPersistentTask.
func (*MockDfdaemonUploadClientMockRecorder) DownloadTask ¶ added in v2.0.64
func (mr *MockDfdaemonUploadClientMockRecorder) DownloadTask(ctx, in any, opts ...any) *gomock.Call
DownloadTask indicates an expected call of DownloadTask.
func (*MockDfdaemonUploadClientMockRecorder) ExchangeIBVerbsQueuePairEndpoint ¶ added in v2.1.35
func (mr *MockDfdaemonUploadClientMockRecorder) ExchangeIBVerbsQueuePairEndpoint(ctx, in any, opts ...any) *gomock.Call
ExchangeIBVerbsQueuePairEndpoint indicates an expected call of ExchangeIBVerbsQueuePairEndpoint.
func (*MockDfdaemonUploadClientMockRecorder) ListTaskEntries ¶ added in v2.1.72
func (mr *MockDfdaemonUploadClientMockRecorder) ListTaskEntries(ctx, in any, opts ...any) *gomock.Call
ListTaskEntries indicates an expected call of ListTaskEntries.
func (*MockDfdaemonUploadClientMockRecorder) StatCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonUploadClientMockRecorder) StatCacheTask(ctx, in any, opts ...any) *gomock.Call
StatCacheTask indicates an expected call of StatCacheTask.
func (*MockDfdaemonUploadClientMockRecorder) StatLocalTask ¶ added in v2.1.97
func (mr *MockDfdaemonUploadClientMockRecorder) StatLocalTask(ctx, in any, opts ...any) *gomock.Call
StatLocalTask indicates an expected call of StatLocalTask.
func (*MockDfdaemonUploadClientMockRecorder) StatPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadClientMockRecorder) StatPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
StatPersistentCacheTask indicates an expected call of StatPersistentCacheTask.
func (*MockDfdaemonUploadClientMockRecorder) StatPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadClientMockRecorder) StatPersistentTask(ctx, in any, opts ...any) *gomock.Call
StatPersistentTask indicates an expected call of StatPersistentTask.
func (*MockDfdaemonUploadClientMockRecorder) StatTask ¶ added in v2.0.148
func (mr *MockDfdaemonUploadClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockDfdaemonUploadClientMockRecorder) SyncCachePieces ¶ added in v2.1.50
func (mr *MockDfdaemonUploadClientMockRecorder) SyncCachePieces(ctx, in any, opts ...any) *gomock.Call
SyncCachePieces indicates an expected call of SyncCachePieces.
func (*MockDfdaemonUploadClientMockRecorder) SyncHost ¶ added in v2.1.2
func (mr *MockDfdaemonUploadClientMockRecorder) SyncHost(ctx, in any, opts ...any) *gomock.Call
SyncHost indicates an expected call of SyncHost.
func (*MockDfdaemonUploadClientMockRecorder) SyncPersistentCachePieces ¶ added in v2.1.13
func (mr *MockDfdaemonUploadClientMockRecorder) SyncPersistentCachePieces(ctx, in any, opts ...any) *gomock.Call
SyncPersistentCachePieces indicates an expected call of SyncPersistentCachePieces.
func (*MockDfdaemonUploadClientMockRecorder) SyncPersistentPieces ¶ added in v2.1.86
func (mr *MockDfdaemonUploadClientMockRecorder) SyncPersistentPieces(ctx, in any, opts ...any) *gomock.Call
SyncPersistentPieces indicates an expected call of SyncPersistentPieces.
func (*MockDfdaemonUploadClientMockRecorder) SyncPieces ¶ added in v2.0.63
func (mr *MockDfdaemonUploadClientMockRecorder) SyncPieces(ctx, in any, opts ...any) *gomock.Call
SyncPieces indicates an expected call of SyncPieces.
func (*MockDfdaemonUploadClientMockRecorder) UpdatePersistentCacheTask ¶ added in v2.1.14
func (mr *MockDfdaemonUploadClientMockRecorder) UpdatePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
UpdatePersistentCacheTask indicates an expected call of UpdatePersistentCacheTask.
func (*MockDfdaemonUploadClientMockRecorder) UpdatePersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadClientMockRecorder) UpdatePersistentTask(ctx, in any, opts ...any) *gomock.Call
UpdatePersistentTask indicates an expected call of UpdatePersistentTask.
type MockDfdaemonUploadServer ¶ added in v2.0.63
type MockDfdaemonUploadServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUploadServer is a mock of DfdaemonUploadServer interface.
func NewMockDfdaemonUploadServer ¶ added in v2.0.63
func NewMockDfdaemonUploadServer(ctrl *gomock.Controller) *MockDfdaemonUploadServer
NewMockDfdaemonUploadServer creates a new mock instance.
func (*MockDfdaemonUploadServer) DeleteCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonUploadServer) DeleteCacheTask(arg0 context.Context, arg1 *dfdaemon.DeleteCacheTaskRequest) (*emptypb.Empty, error)
DeleteCacheTask mocks base method.
func (*MockDfdaemonUploadServer) DeletePersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonUploadServer) DeletePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
DeletePersistentCacheTask mocks base method.
func (*MockDfdaemonUploadServer) DeletePersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadServer) DeletePersistentTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentTaskRequest) (*emptypb.Empty, error)
DeletePersistentTask mocks base method.
func (*MockDfdaemonUploadServer) DeleteTask ¶ added in v2.0.148
func (m *MockDfdaemonUploadServer) DeleteTask(arg0 context.Context, arg1 *dfdaemon.DeleteTaskRequest) (*emptypb.Empty, error)
DeleteTask mocks base method.
func (*MockDfdaemonUploadServer) DownloadCachePiece ¶ added in v2.1.50
func (m *MockDfdaemonUploadServer) DownloadCachePiece(arg0 context.Context, arg1 *dfdaemon.DownloadCachePieceRequest) (*dfdaemon.DownloadCachePieceResponse, error)
DownloadCachePiece mocks base method.
func (*MockDfdaemonUploadServer) DownloadCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonUploadServer) DownloadCacheTask(arg0 *dfdaemon.DownloadCacheTaskRequest, arg1 dfdaemon.DfdaemonUpload_DownloadCacheTaskServer) error
DownloadCacheTask mocks base method.
func (*MockDfdaemonUploadServer) DownloadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonUploadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, arg1 dfdaemon.DfdaemonUpload_DownloadPersistentCacheTaskServer) error
DownloadPersistentCacheTask mocks base method.
func (*MockDfdaemonUploadServer) DownloadPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadServer) DownloadPersistentTask(arg0 *dfdaemon.DownloadPersistentTaskRequest, arg1 dfdaemon.DfdaemonUpload_DownloadPersistentTaskServer) error
DownloadPersistentTask mocks base method.
func (*MockDfdaemonUploadServer) DownloadTask ¶ added in v2.0.64
func (m *MockDfdaemonUploadServer) DownloadTask(arg0 *dfdaemon.DownloadTaskRequest, arg1 dfdaemon.DfdaemonUpload_DownloadTaskServer) error
DownloadTask mocks base method.
func (*MockDfdaemonUploadServer) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonUploadServer) EXPECT() *MockDfdaemonUploadServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUploadServer) ExchangeIBVerbsQueuePairEndpoint ¶ added in v2.1.35
func (m *MockDfdaemonUploadServer) ExchangeIBVerbsQueuePairEndpoint(arg0 context.Context, arg1 *dfdaemon.ExchangeIBVerbsQueuePairEndpointRequest) (*dfdaemon.ExchangeIBVerbsQueuePairEndpointResponse, error)
ExchangeIBVerbsQueuePairEndpoint mocks base method.
func (*MockDfdaemonUploadServer) ListTaskEntries ¶ added in v2.1.72
func (m *MockDfdaemonUploadServer) ListTaskEntries(arg0 context.Context, arg1 *dfdaemon.ListTaskEntriesRequest) (*dfdaemon.ListTaskEntriesResponse, error)
ListTaskEntries mocks base method.
func (*MockDfdaemonUploadServer) StatCacheTask ¶ added in v2.0.120
func (m *MockDfdaemonUploadServer) StatCacheTask(arg0 context.Context, arg1 *dfdaemon.StatCacheTaskRequest) (*common.CacheTask, error)
StatCacheTask mocks base method.
func (*MockDfdaemonUploadServer) StatLocalTask ¶ added in v2.1.97
func (m *MockDfdaemonUploadServer) StatLocalTask(arg0 context.Context, arg1 *dfdaemon.StatLocalTaskRequest) (*dfdaemon.StatLocalTaskResponse, error)
StatLocalTask mocks base method.
func (*MockDfdaemonUploadServer) StatPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonUploadServer) StatPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)
StatPersistentCacheTask mocks base method.
func (*MockDfdaemonUploadServer) StatPersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadServer) StatPersistentTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentTaskRequest) (*common.PersistentTask, error)
StatPersistentTask mocks base method.
func (*MockDfdaemonUploadServer) StatTask ¶ added in v2.0.148
func (m *MockDfdaemonUploadServer) StatTask(arg0 context.Context, arg1 *dfdaemon.StatTaskRequest) (*common.Task, error)
StatTask mocks base method.
func (*MockDfdaemonUploadServer) SyncCachePieces ¶ added in v2.1.50
func (m *MockDfdaemonUploadServer) SyncCachePieces(arg0 *dfdaemon.SyncCachePiecesRequest, arg1 dfdaemon.DfdaemonUpload_SyncCachePiecesServer) error
SyncCachePieces mocks base method.
func (*MockDfdaemonUploadServer) SyncHost ¶ added in v2.1.2
func (m *MockDfdaemonUploadServer) SyncHost(arg0 *dfdaemon.SyncHostRequest, arg1 dfdaemon.DfdaemonUpload_SyncHostServer) error
SyncHost mocks base method.
func (*MockDfdaemonUploadServer) SyncPersistentCachePieces ¶ added in v2.1.13
func (m *MockDfdaemonUploadServer) SyncPersistentCachePieces(arg0 *dfdaemon.SyncPersistentCachePiecesRequest, arg1 dfdaemon.DfdaemonUpload_SyncPersistentCachePiecesServer) error
SyncPersistentCachePieces mocks base method.
func (*MockDfdaemonUploadServer) SyncPersistentPieces ¶ added in v2.1.86
func (m *MockDfdaemonUploadServer) SyncPersistentPieces(arg0 *dfdaemon.SyncPersistentPiecesRequest, arg1 dfdaemon.DfdaemonUpload_SyncPersistentPiecesServer) error
SyncPersistentPieces mocks base method.
func (*MockDfdaemonUploadServer) SyncPieces ¶ added in v2.0.63
func (m *MockDfdaemonUploadServer) SyncPieces(arg0 *dfdaemon.SyncPiecesRequest, arg1 dfdaemon.DfdaemonUpload_SyncPiecesServer) error
SyncPieces mocks base method.
func (*MockDfdaemonUploadServer) UpdatePersistentCacheTask ¶ added in v2.1.14
func (m *MockDfdaemonUploadServer) UpdatePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.UpdatePersistentCacheTaskRequest) (*emptypb.Empty, error)
UpdatePersistentCacheTask mocks base method.
func (*MockDfdaemonUploadServer) UpdatePersistentTask ¶ added in v2.1.86
func (m *MockDfdaemonUploadServer) UpdatePersistentTask(arg0 context.Context, arg1 *dfdaemon.UpdatePersistentTaskRequest) (*emptypb.Empty, error)
UpdatePersistentTask mocks base method.
type MockDfdaemonUploadServerMockRecorder ¶ added in v2.0.63
type MockDfdaemonUploadServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUploadServerMockRecorder is the mock recorder for MockDfdaemonUploadServer.
func (*MockDfdaemonUploadServerMockRecorder) DeleteCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonUploadServerMockRecorder) DeleteCacheTask(arg0, arg1 any) *gomock.Call
DeleteCacheTask indicates an expected call of DeleteCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) DeletePersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadServerMockRecorder) DeletePersistentCacheTask(arg0, arg1 any) *gomock.Call
DeletePersistentCacheTask indicates an expected call of DeletePersistentCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) DeletePersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadServerMockRecorder) DeletePersistentTask(arg0, arg1 any) *gomock.Call
DeletePersistentTask indicates an expected call of DeletePersistentTask.
func (*MockDfdaemonUploadServerMockRecorder) DeleteTask ¶ added in v2.0.148
func (mr *MockDfdaemonUploadServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
DeleteTask indicates an expected call of DeleteTask.
func (*MockDfdaemonUploadServerMockRecorder) DownloadCachePiece ¶ added in v2.1.50
func (mr *MockDfdaemonUploadServerMockRecorder) DownloadCachePiece(arg0, arg1 any) *gomock.Call
DownloadCachePiece indicates an expected call of DownloadCachePiece.
func (*MockDfdaemonUploadServerMockRecorder) DownloadCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonUploadServerMockRecorder) DownloadCacheTask(arg0, arg1 any) *gomock.Call
DownloadCacheTask indicates an expected call of DownloadCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) DownloadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
DownloadPersistentCacheTask indicates an expected call of DownloadPersistentCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) DownloadPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPersistentTask(arg0, arg1 any) *gomock.Call
DownloadPersistentTask indicates an expected call of DownloadPersistentTask.
func (*MockDfdaemonUploadServerMockRecorder) DownloadTask ¶ added in v2.0.64
func (mr *MockDfdaemonUploadServerMockRecorder) DownloadTask(arg0, arg1 any) *gomock.Call
DownloadTask indicates an expected call of DownloadTask.
func (*MockDfdaemonUploadServerMockRecorder) ExchangeIBVerbsQueuePairEndpoint ¶ added in v2.1.35
func (mr *MockDfdaemonUploadServerMockRecorder) ExchangeIBVerbsQueuePairEndpoint(arg0, arg1 any) *gomock.Call
ExchangeIBVerbsQueuePairEndpoint indicates an expected call of ExchangeIBVerbsQueuePairEndpoint.
func (*MockDfdaemonUploadServerMockRecorder) ListTaskEntries ¶ added in v2.1.72
func (mr *MockDfdaemonUploadServerMockRecorder) ListTaskEntries(arg0, arg1 any) *gomock.Call
ListTaskEntries indicates an expected call of ListTaskEntries.
func (*MockDfdaemonUploadServerMockRecorder) StatCacheTask ¶ added in v2.0.120
func (mr *MockDfdaemonUploadServerMockRecorder) StatCacheTask(arg0, arg1 any) *gomock.Call
StatCacheTask indicates an expected call of StatCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) StatLocalTask ¶ added in v2.1.97
func (mr *MockDfdaemonUploadServerMockRecorder) StatLocalTask(arg0, arg1 any) *gomock.Call
StatLocalTask indicates an expected call of StatLocalTask.
func (*MockDfdaemonUploadServerMockRecorder) StatPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadServerMockRecorder) StatPersistentCacheTask(arg0, arg1 any) *gomock.Call
StatPersistentCacheTask indicates an expected call of StatPersistentCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) StatPersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadServerMockRecorder) StatPersistentTask(arg0, arg1 any) *gomock.Call
StatPersistentTask indicates an expected call of StatPersistentTask.
func (*MockDfdaemonUploadServerMockRecorder) StatTask ¶ added in v2.0.148
func (mr *MockDfdaemonUploadServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
StatTask indicates an expected call of StatTask.
func (*MockDfdaemonUploadServerMockRecorder) SyncCachePieces ¶ added in v2.1.50
func (mr *MockDfdaemonUploadServerMockRecorder) SyncCachePieces(arg0, arg1 any) *gomock.Call
SyncCachePieces indicates an expected call of SyncCachePieces.
func (*MockDfdaemonUploadServerMockRecorder) SyncHost ¶ added in v2.1.2
func (mr *MockDfdaemonUploadServerMockRecorder) SyncHost(arg0, arg1 any) *gomock.Call
SyncHost indicates an expected call of SyncHost.
func (*MockDfdaemonUploadServerMockRecorder) SyncPersistentCachePieces ¶ added in v2.1.13
func (mr *MockDfdaemonUploadServerMockRecorder) SyncPersistentCachePieces(arg0, arg1 any) *gomock.Call
SyncPersistentCachePieces indicates an expected call of SyncPersistentCachePieces.
func (*MockDfdaemonUploadServerMockRecorder) SyncPersistentPieces ¶ added in v2.1.86
func (mr *MockDfdaemonUploadServerMockRecorder) SyncPersistentPieces(arg0, arg1 any) *gomock.Call
SyncPersistentPieces indicates an expected call of SyncPersistentPieces.
func (*MockDfdaemonUploadServerMockRecorder) SyncPieces ¶ added in v2.0.63
func (mr *MockDfdaemonUploadServerMockRecorder) SyncPieces(arg0, arg1 any) *gomock.Call
SyncPieces indicates an expected call of SyncPieces.
func (*MockDfdaemonUploadServerMockRecorder) UpdatePersistentCacheTask ¶ added in v2.1.14
func (mr *MockDfdaemonUploadServerMockRecorder) UpdatePersistentCacheTask(arg0, arg1 any) *gomock.Call
UpdatePersistentCacheTask indicates an expected call of UpdatePersistentCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) UpdatePersistentTask ¶ added in v2.1.86
func (mr *MockDfdaemonUploadServerMockRecorder) UpdatePersistentTask(arg0, arg1 any) *gomock.Call
UpdatePersistentTask indicates an expected call of UpdatePersistentTask.
type MockDfdaemonUpload_DownloadCacheTaskClient ¶ added in v2.0.120
type MockDfdaemonUpload_DownloadCacheTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadCacheTaskClient is a mock of DfdaemonUpload_DownloadCacheTaskClient interface.
func NewMockDfdaemonUpload_DownloadCacheTaskClient ¶ added in v2.0.120
func NewMockDfdaemonUpload_DownloadCacheTaskClient(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadCacheTaskClient
NewMockDfdaemonUpload_DownloadCacheTaskClient creates a new mock instance.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) CloseSend ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) Context ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) EXPECT ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskClient) EXPECT() *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) Header ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) Recv ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Recv() (*dfdaemon.DownloadCacheTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) RecvMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonUpload_DownloadCacheTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) SendMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonUpload_DownloadCacheTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskClient) Trailer ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder ¶ added in v2.0.120
type MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadCacheTaskClient.
func (*MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) CloseSend ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Context ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Header ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Recv ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) RecvMsg ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) SendMsg ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Trailer ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_DownloadCacheTaskServer ¶ added in v2.0.120
type MockDfdaemonUpload_DownloadCacheTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadCacheTaskServer is a mock of DfdaemonUpload_DownloadCacheTaskServer interface.
func NewMockDfdaemonUpload_DownloadCacheTaskServer ¶ added in v2.0.120
func NewMockDfdaemonUpload_DownloadCacheTaskServer(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadCacheTaskServer
NewMockDfdaemonUpload_DownloadCacheTaskServer creates a new mock instance.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) Context ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) EXPECT ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskServer) EXPECT() *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) RecvMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonUpload_DownloadCacheTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) Send ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskServer) Send(arg0 *dfdaemon.DownloadCacheTaskResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) SendHeader ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) SendMsg ¶ added in v2.0.120
func (m_2 *MockDfdaemonUpload_DownloadCacheTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) SetHeader ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_DownloadCacheTaskServer) SetTrailer ¶ added in v2.0.120
func (m *MockDfdaemonUpload_DownloadCacheTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder ¶ added in v2.0.120
type MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadCacheTaskServer.
func (*MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) Context ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) RecvMsg ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) Send ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SendHeader ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SendMsg ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SetHeader ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SetTrailer ¶ added in v2.0.120
func (mr *MockDfdaemonUpload_DownloadCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_DownloadPersistentCacheTaskClient ¶ added in v2.0.162
type MockDfdaemonUpload_DownloadPersistentCacheTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentCacheTaskClient is a mock of DfdaemonUpload_DownloadPersistentCacheTaskClient interface.
func NewMockDfdaemonUpload_DownloadPersistentCacheTaskClient ¶ added in v2.0.162
func NewMockDfdaemonUpload_DownloadPersistentCacheTaskClient(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadPersistentCacheTaskClient
NewMockDfdaemonUpload_DownloadPersistentCacheTaskClient creates a new mock instance.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) CloseSend ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Context ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) EXPECT ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) EXPECT() *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Header ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Recv ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Recv() (*dfdaemon.DownloadPersistentCacheTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) RecvMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) SendMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Trailer ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder ¶ added in v2.0.162
type MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadPersistentCacheTaskClient.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) CloseSend ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Context ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Header ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Recv ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) RecvMsg ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) SendMsg ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Trailer ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_DownloadPersistentCacheTaskServer ¶ added in v2.0.162
type MockDfdaemonUpload_DownloadPersistentCacheTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentCacheTaskServer is a mock of DfdaemonUpload_DownloadPersistentCacheTaskServer interface.
func NewMockDfdaemonUpload_DownloadPersistentCacheTaskServer ¶ added in v2.0.162
func NewMockDfdaemonUpload_DownloadPersistentCacheTaskServer(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadPersistentCacheTaskServer
NewMockDfdaemonUpload_DownloadPersistentCacheTaskServer creates a new mock instance.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) Context ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) EXPECT ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) EXPECT() *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) RecvMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) Send ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) Send(arg0 *dfdaemon.DownloadPersistentCacheTaskResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SendHeader ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SendMsg ¶ added in v2.0.162
func (m_2 *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SetHeader ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SetTrailer ¶ added in v2.0.162
func (m *MockDfdaemonUpload_DownloadPersistentCacheTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder ¶ added in v2.0.162
type MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadPersistentCacheTaskServer.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) Context ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) RecvMsg ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) Send ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SendHeader ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SendMsg ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SetHeader ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SetTrailer ¶ added in v2.0.162
func (mr *MockDfdaemonUpload_DownloadPersistentCacheTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_DownloadPersistentTaskClient ¶ added in v2.1.86
type MockDfdaemonUpload_DownloadPersistentTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentTaskClient is a mock of DfdaemonUpload_DownloadPersistentTaskClient interface.
func NewMockDfdaemonUpload_DownloadPersistentTaskClient ¶ added in v2.1.86
func NewMockDfdaemonUpload_DownloadPersistentTaskClient(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadPersistentTaskClient
NewMockDfdaemonUpload_DownloadPersistentTaskClient creates a new mock instance.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) CloseSend ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) Context ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) EXPECT ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) EXPECT() *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) Header ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) Recv ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Recv() (*dfdaemon.DownloadPersistentTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) RecvMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) SendMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskClient) Trailer ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder ¶ added in v2.1.86
type MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadPersistentTaskClient.
func (*MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) CloseSend ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Context ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Header ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Recv ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) RecvMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) SendMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Trailer ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_DownloadPersistentTaskServer ¶ added in v2.1.86
type MockDfdaemonUpload_DownloadPersistentTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentTaskServer is a mock of DfdaemonUpload_DownloadPersistentTaskServer interface.
func NewMockDfdaemonUpload_DownloadPersistentTaskServer ¶ added in v2.1.86
func NewMockDfdaemonUpload_DownloadPersistentTaskServer(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadPersistentTaskServer
NewMockDfdaemonUpload_DownloadPersistentTaskServer creates a new mock instance.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) Context ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) EXPECT ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) EXPECT() *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) RecvMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) Send ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) Send(arg0 *dfdaemon.DownloadPersistentTaskResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) SendHeader ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) SendMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_DownloadPersistentTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) SetHeader ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_DownloadPersistentTaskServer) SetTrailer ¶ added in v2.1.86
func (m *MockDfdaemonUpload_DownloadPersistentTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder ¶ added in v2.1.86
type MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadPersistentTaskServer.
func (*MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) Context ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) RecvMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) Send ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SendHeader ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SendMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SetHeader ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SetTrailer ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_DownloadPersistentTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_DownloadTaskClient ¶ added in v2.0.64
type MockDfdaemonUpload_DownloadTaskClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadTaskClient is a mock of DfdaemonUpload_DownloadTaskClient interface.
func NewMockDfdaemonUpload_DownloadTaskClient ¶ added in v2.0.64
func NewMockDfdaemonUpload_DownloadTaskClient(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadTaskClient
NewMockDfdaemonUpload_DownloadTaskClient creates a new mock instance.
func (*MockDfdaemonUpload_DownloadTaskClient) CloseSend ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_DownloadTaskClient) Context ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadTaskClient) EXPECT ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskClient) EXPECT() *MockDfdaemonUpload_DownloadTaskClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadTaskClient) Header ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_DownloadTaskClient) Recv ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskClient) Recv() (*dfdaemon.DownloadTaskResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_DownloadTaskClient) RecvMsg ¶ added in v2.0.64
func (m_2 *MockDfdaemonUpload_DownloadTaskClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadTaskClient) SendMsg ¶ added in v2.0.64
func (m_2 *MockDfdaemonUpload_DownloadTaskClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadTaskClient) Trailer ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_DownloadTaskClientMockRecorder ¶ added in v2.0.64
type MockDfdaemonUpload_DownloadTaskClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadTaskClientMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadTaskClient.
func (*MockDfdaemonUpload_DownloadTaskClientMockRecorder) CloseSend ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_DownloadTaskClientMockRecorder) Context ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadTaskClientMockRecorder) Header ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_DownloadTaskClientMockRecorder) Recv ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_DownloadTaskClientMockRecorder) RecvMsg ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadTaskClientMockRecorder) SendMsg ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadTaskClientMockRecorder) Trailer ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_DownloadTaskServer ¶ added in v2.0.64
type MockDfdaemonUpload_DownloadTaskServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadTaskServer is a mock of DfdaemonUpload_DownloadTaskServer interface.
func NewMockDfdaemonUpload_DownloadTaskServer ¶ added in v2.0.64
func NewMockDfdaemonUpload_DownloadTaskServer(ctrl *gomock.Controller) *MockDfdaemonUpload_DownloadTaskServer
NewMockDfdaemonUpload_DownloadTaskServer creates a new mock instance.
func (*MockDfdaemonUpload_DownloadTaskServer) Context ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_DownloadTaskServer) EXPECT ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskServer) EXPECT() *MockDfdaemonUpload_DownloadTaskServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_DownloadTaskServer) RecvMsg ¶ added in v2.0.64
func (m_2 *MockDfdaemonUpload_DownloadTaskServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_DownloadTaskServer) Send ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskServer) Send(arg0 *dfdaemon.DownloadTaskResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_DownloadTaskServer) SendHeader ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_DownloadTaskServer) SendMsg ¶ added in v2.0.64
func (m_2 *MockDfdaemonUpload_DownloadTaskServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_DownloadTaskServer) SetHeader ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_DownloadTaskServer) SetTrailer ¶ added in v2.0.64
func (m *MockDfdaemonUpload_DownloadTaskServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_DownloadTaskServerMockRecorder ¶ added in v2.0.64
type MockDfdaemonUpload_DownloadTaskServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_DownloadTaskServerMockRecorder is the mock recorder for MockDfdaemonUpload_DownloadTaskServer.
func (*MockDfdaemonUpload_DownloadTaskServerMockRecorder) Context ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_DownloadTaskServerMockRecorder) RecvMsg ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_DownloadTaskServerMockRecorder) Send ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_DownloadTaskServerMockRecorder) SendHeader ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_DownloadTaskServerMockRecorder) SendMsg ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_DownloadTaskServerMockRecorder) SetHeader ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_DownloadTaskServerMockRecorder) SetTrailer ¶ added in v2.0.64
func (mr *MockDfdaemonUpload_DownloadTaskServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_SyncCachePiecesClient ¶ added in v2.1.50
type MockDfdaemonUpload_SyncCachePiecesClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncCachePiecesClient is a mock of DfdaemonUpload_SyncCachePiecesClient interface.
func NewMockDfdaemonUpload_SyncCachePiecesClient ¶ added in v2.1.50
func NewMockDfdaemonUpload_SyncCachePiecesClient(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncCachePiecesClient
NewMockDfdaemonUpload_SyncCachePiecesClient creates a new mock instance.
func (*MockDfdaemonUpload_SyncCachePiecesClient) CloseSend ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesClient) Context ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesClient) EXPECT ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesClient) EXPECT() *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncCachePiecesClient) Header ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesClient) Recv ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesClient) Recv() (*dfdaemon.SyncCachePiecesResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesClient) RecvMsg ¶ added in v2.1.50
func (m_2 *MockDfdaemonUpload_SyncCachePiecesClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesClient) SendMsg ¶ added in v2.1.50
func (m_2 *MockDfdaemonUpload_SyncCachePiecesClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesClient) Trailer ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_SyncCachePiecesClientMockRecorder ¶ added in v2.1.50
type MockDfdaemonUpload_SyncCachePiecesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncCachePiecesClientMockRecorder is the mock recorder for MockDfdaemonUpload_SyncCachePiecesClient.
func (*MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) CloseSend ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Context ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Header ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Recv ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) RecvMsg ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) SendMsg ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Trailer ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_SyncCachePiecesServer ¶ added in v2.1.50
type MockDfdaemonUpload_SyncCachePiecesServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncCachePiecesServer is a mock of DfdaemonUpload_SyncCachePiecesServer interface.
func NewMockDfdaemonUpload_SyncCachePiecesServer ¶ added in v2.1.50
func NewMockDfdaemonUpload_SyncCachePiecesServer(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncCachePiecesServer
NewMockDfdaemonUpload_SyncCachePiecesServer creates a new mock instance.
func (*MockDfdaemonUpload_SyncCachePiecesServer) Context ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesServer) EXPECT ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesServer) EXPECT() *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncCachePiecesServer) RecvMsg ¶ added in v2.1.50
func (m_2 *MockDfdaemonUpload_SyncCachePiecesServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesServer) Send ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesServer) Send(arg0 *dfdaemon.SyncCachePiecesResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesServer) SendHeader ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesServer) SendMsg ¶ added in v2.1.50
func (m_2 *MockDfdaemonUpload_SyncCachePiecesServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesServer) SetHeader ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_SyncCachePiecesServer) SetTrailer ¶ added in v2.1.50
func (m *MockDfdaemonUpload_SyncCachePiecesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_SyncCachePiecesServerMockRecorder ¶ added in v2.1.50
type MockDfdaemonUpload_SyncCachePiecesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncCachePiecesServerMockRecorder is the mock recorder for MockDfdaemonUpload_SyncCachePiecesServer.
func (*MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) Context ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) RecvMsg ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) Send ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SendHeader ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SendMsg ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SetHeader ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SetTrailer ¶ added in v2.1.50
func (mr *MockDfdaemonUpload_SyncCachePiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_SyncHostClient ¶ added in v2.1.2
type MockDfdaemonUpload_SyncHostClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncHostClient is a mock of DfdaemonUpload_SyncHostClient interface.
func NewMockDfdaemonUpload_SyncHostClient ¶ added in v2.1.2
func NewMockDfdaemonUpload_SyncHostClient(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncHostClient
NewMockDfdaemonUpload_SyncHostClient creates a new mock instance.
func (*MockDfdaemonUpload_SyncHostClient) CloseSend ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_SyncHostClient) Context ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncHostClient) EXPECT ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostClient) EXPECT() *MockDfdaemonUpload_SyncHostClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncHostClient) Header ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_SyncHostClient) Recv ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostClient) Recv() (*common.Host, error)
Recv mocks base method.
func (*MockDfdaemonUpload_SyncHostClient) RecvMsg ¶ added in v2.1.2
func (m_2 *MockDfdaemonUpload_SyncHostClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncHostClient) SendMsg ¶ added in v2.1.2
func (m_2 *MockDfdaemonUpload_SyncHostClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncHostClient) Trailer ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_SyncHostClientMockRecorder ¶ added in v2.1.2
type MockDfdaemonUpload_SyncHostClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncHostClientMockRecorder is the mock recorder for MockDfdaemonUpload_SyncHostClient.
func (*MockDfdaemonUpload_SyncHostClientMockRecorder) CloseSend ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_SyncHostClientMockRecorder) Context ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncHostClientMockRecorder) Header ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_SyncHostClientMockRecorder) Recv ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_SyncHostClientMockRecorder) RecvMsg ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncHostClientMockRecorder) SendMsg ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncHostClientMockRecorder) Trailer ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_SyncHostServer ¶ added in v2.1.2
type MockDfdaemonUpload_SyncHostServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncHostServer is a mock of DfdaemonUpload_SyncHostServer interface.
func NewMockDfdaemonUpload_SyncHostServer ¶ added in v2.1.2
func NewMockDfdaemonUpload_SyncHostServer(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncHostServer
NewMockDfdaemonUpload_SyncHostServer creates a new mock instance.
func (*MockDfdaemonUpload_SyncHostServer) Context ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncHostServer) EXPECT ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostServer) EXPECT() *MockDfdaemonUpload_SyncHostServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncHostServer) RecvMsg ¶ added in v2.1.2
func (m_2 *MockDfdaemonUpload_SyncHostServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncHostServer) Send ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostServer) Send(arg0 *common.Host) error
Send mocks base method.
func (*MockDfdaemonUpload_SyncHostServer) SendHeader ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_SyncHostServer) SendMsg ¶ added in v2.1.2
func (m_2 *MockDfdaemonUpload_SyncHostServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncHostServer) SetHeader ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_SyncHostServer) SetTrailer ¶ added in v2.1.2
func (m *MockDfdaemonUpload_SyncHostServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_SyncHostServerMockRecorder ¶ added in v2.1.2
type MockDfdaemonUpload_SyncHostServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncHostServerMockRecorder is the mock recorder for MockDfdaemonUpload_SyncHostServer.
func (*MockDfdaemonUpload_SyncHostServerMockRecorder) Context ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncHostServerMockRecorder) RecvMsg ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncHostServerMockRecorder) Send ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_SyncHostServerMockRecorder) SendHeader ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_SyncHostServerMockRecorder) SendMsg ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncHostServerMockRecorder) SetHeader ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_SyncHostServerMockRecorder) SetTrailer ¶ added in v2.1.2
func (mr *MockDfdaemonUpload_SyncHostServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_SyncPersistentCachePiecesClient ¶ added in v2.1.13
type MockDfdaemonUpload_SyncPersistentCachePiecesClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentCachePiecesClient is a mock of DfdaemonUpload_SyncPersistentCachePiecesClient interface.
func NewMockDfdaemonUpload_SyncPersistentCachePiecesClient ¶ added in v2.1.13
func NewMockDfdaemonUpload_SyncPersistentCachePiecesClient(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncPersistentCachePiecesClient
NewMockDfdaemonUpload_SyncPersistentCachePiecesClient creates a new mock instance.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) CloseSend ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) Context ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) EXPECT ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) EXPECT() *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) Header ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) Recv ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Recv() (*dfdaemon.SyncPersistentCachePiecesResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) RecvMsg ¶ added in v2.1.13
func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) SendMsg ¶ added in v2.1.13
func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClient) Trailer ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder ¶ added in v2.1.13
type MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder is the mock recorder for MockDfdaemonUpload_SyncPersistentCachePiecesClient.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) CloseSend ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Context ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Header ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Recv ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) RecvMsg ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) SendMsg ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Trailer ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_SyncPersistentCachePiecesServer ¶ added in v2.1.13
type MockDfdaemonUpload_SyncPersistentCachePiecesServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentCachePiecesServer is a mock of DfdaemonUpload_SyncPersistentCachePiecesServer interface.
func NewMockDfdaemonUpload_SyncPersistentCachePiecesServer ¶ added in v2.1.13
func NewMockDfdaemonUpload_SyncPersistentCachePiecesServer(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncPersistentCachePiecesServer
NewMockDfdaemonUpload_SyncPersistentCachePiecesServer creates a new mock instance.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) Context ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) EXPECT ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) EXPECT() *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) RecvMsg ¶ added in v2.1.13
func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) Send ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) Send(arg0 *dfdaemon.SyncPersistentCachePiecesResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) SendHeader ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) SendMsg ¶ added in v2.1.13
func (m_2 *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) SetHeader ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServer) SetTrailer ¶ added in v2.1.13
func (m *MockDfdaemonUpload_SyncPersistentCachePiecesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder ¶ added in v2.1.13
type MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder is the mock recorder for MockDfdaemonUpload_SyncPersistentCachePiecesServer.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) Context ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) RecvMsg ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) Send ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SendHeader ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SendMsg ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SetHeader ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SetTrailer ¶ added in v2.1.13
func (mr *MockDfdaemonUpload_SyncPersistentCachePiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_SyncPersistentPiecesClient ¶ added in v2.1.86
type MockDfdaemonUpload_SyncPersistentPiecesClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentPiecesClient is a mock of DfdaemonUpload_SyncPersistentPiecesClient interface.
func NewMockDfdaemonUpload_SyncPersistentPiecesClient ¶ added in v2.1.86
func NewMockDfdaemonUpload_SyncPersistentPiecesClient(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncPersistentPiecesClient
NewMockDfdaemonUpload_SyncPersistentPiecesClient creates a new mock instance.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) CloseSend ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) Context ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) EXPECT ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) EXPECT() *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) Header ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) Recv ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Recv() (*dfdaemon.SyncPersistentPiecesResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) RecvMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) SendMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesClient) Trailer ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder ¶ added in v2.1.86
type MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder is the mock recorder for MockDfdaemonUpload_SyncPersistentPiecesClient.
func (*MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) CloseSend ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Context ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Header ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Recv ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) RecvMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) SendMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Trailer ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_SyncPersistentPiecesServer ¶ added in v2.1.86
type MockDfdaemonUpload_SyncPersistentPiecesServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentPiecesServer is a mock of DfdaemonUpload_SyncPersistentPiecesServer interface.
func NewMockDfdaemonUpload_SyncPersistentPiecesServer ¶ added in v2.1.86
func NewMockDfdaemonUpload_SyncPersistentPiecesServer(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncPersistentPiecesServer
NewMockDfdaemonUpload_SyncPersistentPiecesServer creates a new mock instance.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) Context ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) EXPECT ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) EXPECT() *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) RecvMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) Send ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) Send(arg0 *dfdaemon.SyncPersistentPiecesResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) SendHeader ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) SendMsg ¶ added in v2.1.86
func (m_2 *MockDfdaemonUpload_SyncPersistentPiecesServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) SetHeader ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_SyncPersistentPiecesServer) SetTrailer ¶ added in v2.1.86
func (m *MockDfdaemonUpload_SyncPersistentPiecesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder ¶ added in v2.1.86
type MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder is the mock recorder for MockDfdaemonUpload_SyncPersistentPiecesServer.
func (*MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) Context ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) RecvMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) Send ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SendHeader ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SendMsg ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SetHeader ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SetTrailer ¶ added in v2.1.86
func (mr *MockDfdaemonUpload_SyncPersistentPiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockDfdaemonUpload_SyncPiecesClient ¶ added in v2.0.63
type MockDfdaemonUpload_SyncPiecesClient struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPiecesClient is a mock of DfdaemonUpload_SyncPiecesClient interface.
func NewMockDfdaemonUpload_SyncPiecesClient ¶ added in v2.0.63
func NewMockDfdaemonUpload_SyncPiecesClient(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncPiecesClient
NewMockDfdaemonUpload_SyncPiecesClient creates a new mock instance.
func (*MockDfdaemonUpload_SyncPiecesClient) CloseSend ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesClient) CloseSend() error
CloseSend mocks base method.
func (*MockDfdaemonUpload_SyncPiecesClient) Context ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesClient) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncPiecesClient) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesClient) EXPECT() *MockDfdaemonUpload_SyncPiecesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncPiecesClient) Header ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDfdaemonUpload_SyncPiecesClient) Recv ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesClient) Recv() (*dfdaemon.SyncPiecesResponse, error)
Recv mocks base method.
func (*MockDfdaemonUpload_SyncPiecesClient) RecvMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonUpload_SyncPiecesClient) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncPiecesClient) SendMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonUpload_SyncPiecesClient) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncPiecesClient) Trailer ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDfdaemonUpload_SyncPiecesClientMockRecorder ¶ added in v2.0.63
type MockDfdaemonUpload_SyncPiecesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPiecesClientMockRecorder is the mock recorder for MockDfdaemonUpload_SyncPiecesClient.
func (*MockDfdaemonUpload_SyncPiecesClientMockRecorder) CloseSend ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDfdaemonUpload_SyncPiecesClientMockRecorder) Context ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncPiecesClientMockRecorder) Header ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDfdaemonUpload_SyncPiecesClientMockRecorder) Recv ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDfdaemonUpload_SyncPiecesClientMockRecorder) RecvMsg ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncPiecesClientMockRecorder) SendMsg ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncPiecesClientMockRecorder) Trailer ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDfdaemonUpload_SyncPiecesServer ¶ added in v2.0.63
type MockDfdaemonUpload_SyncPiecesServer struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPiecesServer is a mock of DfdaemonUpload_SyncPiecesServer interface.
func NewMockDfdaemonUpload_SyncPiecesServer ¶ added in v2.0.63
func NewMockDfdaemonUpload_SyncPiecesServer(ctrl *gomock.Controller) *MockDfdaemonUpload_SyncPiecesServer
NewMockDfdaemonUpload_SyncPiecesServer creates a new mock instance.
func (*MockDfdaemonUpload_SyncPiecesServer) Context ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesServer) Context() context.Context
Context mocks base method.
func (*MockDfdaemonUpload_SyncPiecesServer) EXPECT ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesServer) EXPECT() *MockDfdaemonUpload_SyncPiecesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDfdaemonUpload_SyncPiecesServer) RecvMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonUpload_SyncPiecesServer) RecvMsg(m any) error
RecvMsg mocks base method.
func (*MockDfdaemonUpload_SyncPiecesServer) Send ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesServer) Send(arg0 *dfdaemon.SyncPiecesResponse) error
Send mocks base method.
func (*MockDfdaemonUpload_SyncPiecesServer) SendHeader ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDfdaemonUpload_SyncPiecesServer) SendMsg ¶ added in v2.0.63
func (m_2 *MockDfdaemonUpload_SyncPiecesServer) SendMsg(m any) error
SendMsg mocks base method.
func (*MockDfdaemonUpload_SyncPiecesServer) SetHeader ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDfdaemonUpload_SyncPiecesServer) SetTrailer ¶ added in v2.0.63
func (m *MockDfdaemonUpload_SyncPiecesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDfdaemonUpload_SyncPiecesServerMockRecorder ¶ added in v2.0.63
type MockDfdaemonUpload_SyncPiecesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUpload_SyncPiecesServerMockRecorder is the mock recorder for MockDfdaemonUpload_SyncPiecesServer.
func (*MockDfdaemonUpload_SyncPiecesServerMockRecorder) Context ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDfdaemonUpload_SyncPiecesServerMockRecorder) RecvMsg ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) RecvMsg(m any) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDfdaemonUpload_SyncPiecesServerMockRecorder) Send ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) Send(arg0 any) *gomock.Call
Send indicates an expected call of Send.
func (*MockDfdaemonUpload_SyncPiecesServerMockRecorder) SendHeader ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SendHeader(arg0 any) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDfdaemonUpload_SyncPiecesServerMockRecorder) SendMsg ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SendMsg(m any) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDfdaemonUpload_SyncPiecesServerMockRecorder) SetHeader ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SetHeader(arg0 any) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDfdaemonUpload_SyncPiecesServerMockRecorder) SetTrailer ¶ added in v2.0.63
func (mr *MockDfdaemonUpload_SyncPiecesServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockUnsafeDfdaemonDownloadServer ¶ added in v2.0.63
type MockUnsafeDfdaemonDownloadServer struct {
// contains filtered or unexported fields
}
MockUnsafeDfdaemonDownloadServer is a mock of UnsafeDfdaemonDownloadServer interface.
func NewMockUnsafeDfdaemonDownloadServer ¶ added in v2.0.63
func NewMockUnsafeDfdaemonDownloadServer(ctrl *gomock.Controller) *MockUnsafeDfdaemonDownloadServer
NewMockUnsafeDfdaemonDownloadServer creates a new mock instance.
func (*MockUnsafeDfdaemonDownloadServer) EXPECT ¶ added in v2.0.63
func (m *MockUnsafeDfdaemonDownloadServer) EXPECT() *MockUnsafeDfdaemonDownloadServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeDfdaemonDownloadServerMockRecorder ¶ added in v2.0.63
type MockUnsafeDfdaemonDownloadServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeDfdaemonDownloadServerMockRecorder is the mock recorder for MockUnsafeDfdaemonDownloadServer.
type MockUnsafeDfdaemonUploadServer ¶ added in v2.0.63
type MockUnsafeDfdaemonUploadServer struct {
// contains filtered or unexported fields
}
MockUnsafeDfdaemonUploadServer is a mock of UnsafeDfdaemonUploadServer interface.
func NewMockUnsafeDfdaemonUploadServer ¶ added in v2.0.63
func NewMockUnsafeDfdaemonUploadServer(ctrl *gomock.Controller) *MockUnsafeDfdaemonUploadServer
NewMockUnsafeDfdaemonUploadServer creates a new mock instance.
func (*MockUnsafeDfdaemonUploadServer) EXPECT ¶ added in v2.0.63
func (m *MockUnsafeDfdaemonUploadServer) EXPECT() *MockUnsafeDfdaemonUploadServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockUnsafeDfdaemonUploadServerMockRecorder ¶ added in v2.0.63
type MockUnsafeDfdaemonUploadServerMockRecorder struct {
// contains filtered or unexported fields
}
MockUnsafeDfdaemonUploadServerMockRecorder is the mock recorder for MockUnsafeDfdaemonUploadServer.