Versions in this module Expand all Collapse all v0 v0.1.3 May 15, 2024 Changes in this version + type MockSeederClient struct + func NewMockSeederClient(ctrl *gomock.Controller) *MockSeederClient + func (m *MockSeederClient) EXPECT() *MockSeederClientMockRecorder + func (m *MockSeederClient) GetPieceTasks(ctx context.Context, in *common.PieceTaskRequest, opts ...grpc.CallOption) (*common.PiecePacket, error) + func (m *MockSeederClient) ObtainSeeds(ctx context.Context, in *cdnsystem.SeedRequest, opts ...grpc.CallOption) (cdnsystem.Seeder_ObtainSeedsClient, error) + func (m *MockSeederClient) SyncPieceTasks(ctx context.Context, opts ...grpc.CallOption) (cdnsystem.Seeder_SyncPieceTasksClient, error) + type MockSeederClientMockRecorder struct + func (mr *MockSeederClientMockRecorder) GetPieceTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockSeederClientMockRecorder) ObtainSeeds(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockSeederClientMockRecorder) SyncPieceTasks(ctx interface{}, opts ...interface{}) *gomock.Call + type MockSeederServer struct + func NewMockSeederServer(ctrl *gomock.Controller) *MockSeederServer + func (m *MockSeederServer) EXPECT() *MockSeederServerMockRecorder + func (m *MockSeederServer) GetPieceTasks(arg0 context.Context, arg1 *common.PieceTaskRequest) (*common.PiecePacket, error) + func (m *MockSeederServer) ObtainSeeds(arg0 *cdnsystem.SeedRequest, arg1 cdnsystem.Seeder_ObtainSeedsServer) error + func (m *MockSeederServer) SyncPieceTasks(arg0 cdnsystem.Seeder_SyncPieceTasksServer) error + type MockSeederServerMockRecorder struct + func (mr *MockSeederServerMockRecorder) GetPieceTasks(arg0, arg1 interface{}) *gomock.Call + func (mr *MockSeederServerMockRecorder) ObtainSeeds(arg0, arg1 interface{}) *gomock.Call + func (mr *MockSeederServerMockRecorder) SyncPieceTasks(arg0 interface{}) *gomock.Call + type MockSeeder_ObtainSeedsClient struct + func NewMockSeeder_ObtainSeedsClient(ctrl *gomock.Controller) *MockSeeder_ObtainSeedsClient + func (m *MockSeeder_ObtainSeedsClient) CloseSend() error + func (m *MockSeeder_ObtainSeedsClient) Context() context.Context + func (m *MockSeeder_ObtainSeedsClient) EXPECT() *MockSeeder_ObtainSeedsClientMockRecorder + func (m *MockSeeder_ObtainSeedsClient) Header() (metadata.MD, error) + func (m *MockSeeder_ObtainSeedsClient) Recv() (*cdnsystem.PieceSeed, error) + func (m *MockSeeder_ObtainSeedsClient) Trailer() metadata.MD + func (m_2 *MockSeeder_ObtainSeedsClient) RecvMsg(m interface{}) error + func (m_2 *MockSeeder_ObtainSeedsClient) SendMsg(m interface{}) error + type MockSeeder_ObtainSeedsClientMockRecorder struct + func (mr *MockSeeder_ObtainSeedsClientMockRecorder) CloseSend() *gomock.Call + func (mr *MockSeeder_ObtainSeedsClientMockRecorder) Context() *gomock.Call + func (mr *MockSeeder_ObtainSeedsClientMockRecorder) Header() *gomock.Call + func (mr *MockSeeder_ObtainSeedsClientMockRecorder) Recv() *gomock.Call + func (mr *MockSeeder_ObtainSeedsClientMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_ObtainSeedsClientMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_ObtainSeedsClientMockRecorder) Trailer() *gomock.Call + type MockSeeder_ObtainSeedsServer struct + func NewMockSeeder_ObtainSeedsServer(ctrl *gomock.Controller) *MockSeeder_ObtainSeedsServer + func (m *MockSeeder_ObtainSeedsServer) Context() context.Context + func (m *MockSeeder_ObtainSeedsServer) EXPECT() *MockSeeder_ObtainSeedsServerMockRecorder + func (m *MockSeeder_ObtainSeedsServer) Send(arg0 *cdnsystem.PieceSeed) error + func (m *MockSeeder_ObtainSeedsServer) SendHeader(arg0 metadata.MD) error + func (m *MockSeeder_ObtainSeedsServer) SetHeader(arg0 metadata.MD) error + func (m *MockSeeder_ObtainSeedsServer) SetTrailer(arg0 metadata.MD) + func (m_2 *MockSeeder_ObtainSeedsServer) RecvMsg(m interface{}) error + func (m_2 *MockSeeder_ObtainSeedsServer) SendMsg(m interface{}) error + type MockSeeder_ObtainSeedsServerMockRecorder struct + func (mr *MockSeeder_ObtainSeedsServerMockRecorder) Context() *gomock.Call + func (mr *MockSeeder_ObtainSeedsServerMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_ObtainSeedsServerMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockSeeder_ObtainSeedsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call + func (mr *MockSeeder_ObtainSeedsServerMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_ObtainSeedsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call + func (mr *MockSeeder_ObtainSeedsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call + type MockSeeder_SyncPieceTasksClient struct + func NewMockSeeder_SyncPieceTasksClient(ctrl *gomock.Controller) *MockSeeder_SyncPieceTasksClient + func (m *MockSeeder_SyncPieceTasksClient) CloseSend() error + func (m *MockSeeder_SyncPieceTasksClient) Context() context.Context + func (m *MockSeeder_SyncPieceTasksClient) EXPECT() *MockSeeder_SyncPieceTasksClientMockRecorder + func (m *MockSeeder_SyncPieceTasksClient) Header() (metadata.MD, error) + func (m *MockSeeder_SyncPieceTasksClient) Recv() (*common.PiecePacket, error) + func (m *MockSeeder_SyncPieceTasksClient) Send(arg0 *common.PieceTaskRequest) error + func (m *MockSeeder_SyncPieceTasksClient) Trailer() metadata.MD + func (m_2 *MockSeeder_SyncPieceTasksClient) RecvMsg(m interface{}) error + func (m_2 *MockSeeder_SyncPieceTasksClient) SendMsg(m interface{}) error + type MockSeeder_SyncPieceTasksClientMockRecorder struct + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) CloseSend() *gomock.Call + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) Context() *gomock.Call + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) Header() *gomock.Call + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) Recv() *gomock.Call + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksClientMockRecorder) Trailer() *gomock.Call + type MockSeeder_SyncPieceTasksServer struct + func NewMockSeeder_SyncPieceTasksServer(ctrl *gomock.Controller) *MockSeeder_SyncPieceTasksServer + func (m *MockSeeder_SyncPieceTasksServer) Context() context.Context + func (m *MockSeeder_SyncPieceTasksServer) EXPECT() *MockSeeder_SyncPieceTasksServerMockRecorder + func (m *MockSeeder_SyncPieceTasksServer) Recv() (*common.PieceTaskRequest, error) + func (m *MockSeeder_SyncPieceTasksServer) Send(arg0 *common.PiecePacket) error + func (m *MockSeeder_SyncPieceTasksServer) SendHeader(arg0 metadata.MD) error + func (m *MockSeeder_SyncPieceTasksServer) SetHeader(arg0 metadata.MD) error + func (m *MockSeeder_SyncPieceTasksServer) SetTrailer(arg0 metadata.MD) + func (m_2 *MockSeeder_SyncPieceTasksServer) RecvMsg(m interface{}) error + func (m_2 *MockSeeder_SyncPieceTasksServer) SendMsg(m interface{}) error + type MockSeeder_SyncPieceTasksServerMockRecorder struct + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) Context() *gomock.Call + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) Recv() *gomock.Call + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call + func (mr *MockSeeder_SyncPieceTasksServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call + type MockUnsafeSeederServer struct + func NewMockUnsafeSeederServer(ctrl *gomock.Controller) *MockUnsafeSeederServer + func (m *MockUnsafeSeederServer) EXPECT() *MockUnsafeSeederServerMockRecorder + type MockUnsafeSeederServerMockRecorder struct