Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockDfdaemonDownloadClient
- func (m *MockDfdaemonDownloadClient) DeleteHost(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadClient) DeletePersistentCacheTask(ctx context.Context, in *dfdaemon.DeletePersistentCacheTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadClient) DeleteTask(ctx context.Context, in *dfdaemon.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadClient) DownloadPersistentCacheTask(ctx context.Context, in *dfdaemon.DownloadPersistentCacheTaskRequest, ...) (dfdaemon.DfdaemonDownload_DownloadPersistentCacheTaskClient, 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) 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) UploadTask(ctx context.Context, in *dfdaemon.UploadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- type MockDfdaemonDownloadClientMockRecorder
- func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteHost(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DeletePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonDownloadClientMockRecorder) DownloadTask(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) UploadTask(ctx, in any, opts ...any) *gomock.Call
- type MockDfdaemonDownloadServer
- func (m *MockDfdaemonDownloadServer) DeleteHost(arg0 context.Context, arg1 *emptypb.Empty) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadServer) DeletePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadServer) DeleteTask(arg0 context.Context, arg1 *dfdaemon.DeleteTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonDownloadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, ...) error
- func (m *MockDfdaemonDownloadServer) DownloadTask(arg0 *dfdaemon.DownloadTaskRequest, ...) error
- func (m *MockDfdaemonDownloadServer) EXPECT() *MockDfdaemonDownloadServerMockRecorder
- 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) UploadTask(arg0 context.Context, arg1 *dfdaemon.UploadTaskRequest) (*emptypb.Empty, error)
- type MockDfdaemonDownloadServerMockRecorder
- func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteHost(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DeletePersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadTask(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) UploadTask(arg0, arg1 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_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) DeletePersistentCacheTask(ctx context.Context, in *dfdaemon.DeletePersistentCacheTaskRequest, ...) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadClient) DeleteTask(ctx context.Context, in *dfdaemon.DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadClient) DownloadPersistentCacheTask(ctx context.Context, in *dfdaemon.DownloadPersistentCacheTaskRequest, ...) (dfdaemon.DfdaemonUpload_DownloadPersistentCacheTaskClient, error)
- func (m *MockDfdaemonUploadClient) DownloadPiece(ctx context.Context, in *dfdaemon.DownloadPieceRequest, ...) (*dfdaemon.DownloadPieceResponse, 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) StatPersistentCacheTask(ctx context.Context, in *dfdaemon.StatPersistentCacheTaskRequest, ...) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonUploadClient) StatTask(ctx context.Context, in *dfdaemon.StatTaskRequest, opts ...grpc.CallOption) (*common.Task, error)
- func (m *MockDfdaemonUploadClient) SyncPieces(ctx context.Context, in *dfdaemon.SyncPiecesRequest, opts ...grpc.CallOption) (dfdaemon.DfdaemonUpload_SyncPiecesClient, error)
- type MockDfdaemonUploadClientMockRecorder
- func (mr *MockDfdaemonUploadClientMockRecorder) DeletePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DeleteTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadPiece(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) DownloadTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) StatPersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) StatTask(ctx, in any, opts ...any) *gomock.Call
- func (mr *MockDfdaemonUploadClientMockRecorder) SyncPieces(ctx, in any, opts ...any) *gomock.Call
- type MockDfdaemonUploadServer
- func (m *MockDfdaemonUploadServer) DeletePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadServer) DeleteTask(arg0 context.Context, arg1 *dfdaemon.DeleteTaskRequest) (*emptypb.Empty, error)
- func (m *MockDfdaemonUploadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, ...) error
- func (m *MockDfdaemonUploadServer) DownloadPiece(arg0 context.Context, arg1 *dfdaemon.DownloadPieceRequest) (*dfdaemon.DownloadPieceResponse, error)
- func (m *MockDfdaemonUploadServer) DownloadTask(arg0 *dfdaemon.DownloadTaskRequest, ...) error
- func (m *MockDfdaemonUploadServer) EXPECT() *MockDfdaemonUploadServerMockRecorder
- func (m *MockDfdaemonUploadServer) StatPersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.StatPersistentCacheTaskRequest) (*common.PersistentCacheTask, error)
- func (m *MockDfdaemonUploadServer) StatTask(arg0 context.Context, arg1 *dfdaemon.StatTaskRequest) (*common.Task, error)
- func (m *MockDfdaemonUploadServer) SyncPieces(arg0 *dfdaemon.SyncPiecesRequest, ...) error
- type MockDfdaemonUploadServerMockRecorder
- func (mr *MockDfdaemonUploadServerMockRecorder) DeletePersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DeleteTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPiece(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) DownloadTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) StatPersistentCacheTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) StatTask(arg0, arg1 any) *gomock.Call
- func (mr *MockDfdaemonUploadServerMockRecorder) SyncPieces(arg0, arg1 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_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_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) 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) DeletePersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadClient) DeletePersistentCacheTask(ctx context.Context, in *dfdaemon.DeletePersistentCacheTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeletePersistentCacheTask 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) 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) 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) 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) UploadTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadClient) UploadTask(ctx context.Context, in *dfdaemon.UploadTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
UploadTask 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) 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) DeletePersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadClientMockRecorder) DeletePersistentCacheTask(ctx, in any, opts ...any) *gomock.Call
DeletePersistentCacheTask indicates an expected call of DeletePersistentCacheTask.
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) 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) 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) 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) UploadTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadClientMockRecorder) UploadTask(ctx, in any, opts ...any) *gomock.Call
UploadTask indicates an expected call of UploadTask.
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) 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) DeletePersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadServer) DeletePersistentCacheTask(arg0 context.Context, arg1 *dfdaemon.DeletePersistentCacheTaskRequest) (*emptypb.Empty, error)
DeletePersistentCacheTask 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) DownloadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonDownloadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, arg1 dfdaemon.DfdaemonDownload_DownloadPersistentCacheTaskServer) error
DownloadPersistentCacheTask 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) 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) UploadTask ¶ added in v2.0.63
func (m *MockDfdaemonDownloadServer) UploadTask(arg0 context.Context, arg1 *dfdaemon.UploadTaskRequest) (*emptypb.Empty, error)
UploadTask 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) DeleteHost ¶ added in v2.0.120
func (mr *MockDfdaemonDownloadServerMockRecorder) DeleteHost(arg0, arg1 any) *gomock.Call
DeleteHost indicates an expected call of DeleteHost.
func (*MockDfdaemonDownloadServerMockRecorder) DeletePersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadServerMockRecorder) DeletePersistentCacheTask(arg0, arg1 any) *gomock.Call
DeletePersistentCacheTask indicates an expected call of DeletePersistentCacheTask.
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) DownloadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonDownloadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
DownloadPersistentCacheTask indicates an expected call of DownloadPersistentCacheTask.
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) 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) UploadTask ¶ added in v2.0.63
func (mr *MockDfdaemonDownloadServerMockRecorder) UploadTask(arg0, arg1 any) *gomock.Call
UploadTask indicates an expected call of UploadTask.
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_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) 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) 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) 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) DownloadPiece ¶ added in v2.0.63
func (m *MockDfdaemonUploadClient) DownloadPiece(ctx context.Context, in *dfdaemon.DownloadPieceRequest, opts ...grpc.CallOption) (*dfdaemon.DownloadPieceResponse, error)
DownloadPiece 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) 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) 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) 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.
type MockDfdaemonUploadClientMockRecorder ¶ added in v2.0.63
type MockDfdaemonUploadClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDfdaemonUploadClientMockRecorder is the mock recorder for MockDfdaemonUploadClient.
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) 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) 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) DownloadPiece ¶ added in v2.0.63
func (mr *MockDfdaemonUploadClientMockRecorder) DownloadPiece(ctx, in any, opts ...any) *gomock.Call
DownloadPiece indicates an expected call of DownloadPiece.
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) 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) 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) SyncPieces ¶ added in v2.0.63
func (mr *MockDfdaemonUploadClientMockRecorder) SyncPieces(ctx, in any, opts ...any) *gomock.Call
SyncPieces indicates an expected call of SyncPieces.
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) 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) 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) DownloadPersistentCacheTask ¶ added in v2.0.162
func (m *MockDfdaemonUploadServer) DownloadPersistentCacheTask(arg0 *dfdaemon.DownloadPersistentCacheTaskRequest, arg1 dfdaemon.DfdaemonUpload_DownloadPersistentCacheTaskServer) error
DownloadPersistentCacheTask mocks base method.
func (*MockDfdaemonUploadServer) DownloadPiece ¶ added in v2.0.63
func (m *MockDfdaemonUploadServer) DownloadPiece(arg0 context.Context, arg1 *dfdaemon.DownloadPieceRequest) (*dfdaemon.DownloadPieceResponse, error)
DownloadPiece 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) 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) 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) SyncPieces ¶ added in v2.0.63
func (m *MockDfdaemonUploadServer) SyncPieces(arg0 *dfdaemon.SyncPiecesRequest, arg1 dfdaemon.DfdaemonUpload_SyncPiecesServer) error
SyncPieces 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) DeletePersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadServerMockRecorder) DeletePersistentCacheTask(arg0, arg1 any) *gomock.Call
DeletePersistentCacheTask indicates an expected call of DeletePersistentCacheTask.
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) DownloadPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPersistentCacheTask(arg0, arg1 any) *gomock.Call
DownloadPersistentCacheTask indicates an expected call of DownloadPersistentCacheTask.
func (*MockDfdaemonUploadServerMockRecorder) DownloadPiece ¶ added in v2.0.63
func (mr *MockDfdaemonUploadServerMockRecorder) DownloadPiece(arg0, arg1 any) *gomock.Call
DownloadPiece indicates an expected call of DownloadPiece.
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) StatPersistentCacheTask ¶ added in v2.0.162
func (mr *MockDfdaemonUploadServerMockRecorder) StatPersistentCacheTask(arg0, arg1 any) *gomock.Call
StatPersistentCacheTask indicates an expected call of StatPersistentCacheTask.
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) SyncPieces ¶ added in v2.0.63
func (mr *MockDfdaemonUploadServerMockRecorder) SyncPieces(arg0, arg1 any) *gomock.Call
SyncPieces indicates an expected call of SyncPieces.
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_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_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.