Versions in this module Expand all Collapse all v0 v0.1.3 May 15, 2024 Changes in this version + type MockManagerClient struct + func NewMockManagerClient(ctrl *gomock.Controller) *MockManagerClient + func (m *MockManagerClient) CreateModel(ctx context.Context, in *manager.CreateModelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + func (m *MockManagerClient) DeleteSeedPeer(ctx context.Context, in *manager.DeleteSeedPeerRequest, ...) (*emptypb.Empty, error) + func (m *MockManagerClient) EXPECT() *MockManagerClientMockRecorder + func (m *MockManagerClient) GetObjectStorage(ctx context.Context, in *manager.GetObjectStorageRequest, ...) (*manager.ObjectStorage, error) + func (m *MockManagerClient) GetScheduler(ctx context.Context, in *manager.GetSchedulerRequest, opts ...grpc.CallOption) (*manager.Scheduler, error) + func (m *MockManagerClient) GetSeedPeer(ctx context.Context, in *manager.GetSeedPeerRequest, opts ...grpc.CallOption) (*manager.SeedPeer, error) + func (m *MockManagerClient) KeepAlive(ctx context.Context, opts ...grpc.CallOption) (manager.Manager_KeepAliveClient, error) + func (m *MockManagerClient) ListApplications(ctx context.Context, in *manager.ListApplicationsRequest, ...) (*manager.ListApplicationsResponse, error) + func (m *MockManagerClient) ListBuckets(ctx context.Context, in *manager.ListBucketsRequest, opts ...grpc.CallOption) (*manager.ListBucketsResponse, error) + func (m *MockManagerClient) ListSchedulers(ctx context.Context, in *manager.ListSchedulersRequest, ...) (*manager.ListSchedulersResponse, error) + func (m *MockManagerClient) UpdateScheduler(ctx context.Context, in *manager.UpdateSchedulerRequest, ...) (*manager.Scheduler, error) + func (m *MockManagerClient) UpdateSeedPeer(ctx context.Context, in *manager.UpdateSeedPeerRequest, ...) (*manager.SeedPeer, error) + type MockManagerClientMockRecorder struct + func (mr *MockManagerClientMockRecorder) CreateModel(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) DeleteSeedPeer(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) GetObjectStorage(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) GetScheduler(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) GetSeedPeer(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) KeepAlive(ctx interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) ListApplications(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) ListBuckets(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) ListSchedulers(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) UpdateScheduler(ctx, in interface{}, opts ...interface{}) *gomock.Call + func (mr *MockManagerClientMockRecorder) UpdateSeedPeer(ctx, in interface{}, opts ...interface{}) *gomock.Call + type MockManagerServer struct + func NewMockManagerServer(ctrl *gomock.Controller) *MockManagerServer + func (m *MockManagerServer) CreateModel(arg0 context.Context, arg1 *manager.CreateModelRequest) (*emptypb.Empty, error) + func (m *MockManagerServer) DeleteSeedPeer(arg0 context.Context, arg1 *manager.DeleteSeedPeerRequest) (*emptypb.Empty, error) + func (m *MockManagerServer) EXPECT() *MockManagerServerMockRecorder + func (m *MockManagerServer) GetObjectStorage(arg0 context.Context, arg1 *manager.GetObjectStorageRequest) (*manager.ObjectStorage, error) + func (m *MockManagerServer) GetScheduler(arg0 context.Context, arg1 *manager.GetSchedulerRequest) (*manager.Scheduler, error) + func (m *MockManagerServer) GetSeedPeer(arg0 context.Context, arg1 *manager.GetSeedPeerRequest) (*manager.SeedPeer, error) + func (m *MockManagerServer) KeepAlive(arg0 manager.Manager_KeepAliveServer) error + func (m *MockManagerServer) ListApplications(arg0 context.Context, arg1 *manager.ListApplicationsRequest) (*manager.ListApplicationsResponse, error) + func (m *MockManagerServer) ListBuckets(arg0 context.Context, arg1 *manager.ListBucketsRequest) (*manager.ListBucketsResponse, error) + func (m *MockManagerServer) ListSchedulers(arg0 context.Context, arg1 *manager.ListSchedulersRequest) (*manager.ListSchedulersResponse, error) + func (m *MockManagerServer) UpdateScheduler(arg0 context.Context, arg1 *manager.UpdateSchedulerRequest) (*manager.Scheduler, error) + func (m *MockManagerServer) UpdateSeedPeer(arg0 context.Context, arg1 *manager.UpdateSeedPeerRequest) (*manager.SeedPeer, error) + type MockManagerServerMockRecorder struct + func (mr *MockManagerServerMockRecorder) CreateModel(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) DeleteSeedPeer(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) GetObjectStorage(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) GetScheduler(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) GetSeedPeer(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) KeepAlive(arg0 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) ListApplications(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) ListBuckets(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) ListSchedulers(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) UpdateScheduler(arg0, arg1 interface{}) *gomock.Call + func (mr *MockManagerServerMockRecorder) UpdateSeedPeer(arg0, arg1 interface{}) *gomock.Call + type MockManager_KeepAliveClient struct + func NewMockManager_KeepAliveClient(ctrl *gomock.Controller) *MockManager_KeepAliveClient + func (m *MockManager_KeepAliveClient) CloseAndRecv() (*emptypb.Empty, error) + func (m *MockManager_KeepAliveClient) CloseSend() error + func (m *MockManager_KeepAliveClient) Context() context.Context + func (m *MockManager_KeepAliveClient) EXPECT() *MockManager_KeepAliveClientMockRecorder + func (m *MockManager_KeepAliveClient) Header() (metadata.MD, error) + func (m *MockManager_KeepAliveClient) Send(arg0 *manager.KeepAliveRequest) error + func (m *MockManager_KeepAliveClient) Trailer() metadata.MD + func (m_2 *MockManager_KeepAliveClient) RecvMsg(m interface{}) error + func (m_2 *MockManager_KeepAliveClient) SendMsg(m interface{}) error + type MockManager_KeepAliveClientMockRecorder struct + func (mr *MockManager_KeepAliveClientMockRecorder) CloseAndRecv() *gomock.Call + func (mr *MockManager_KeepAliveClientMockRecorder) CloseSend() *gomock.Call + func (mr *MockManager_KeepAliveClientMockRecorder) Context() *gomock.Call + func (mr *MockManager_KeepAliveClientMockRecorder) Header() *gomock.Call + func (mr *MockManager_KeepAliveClientMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockManager_KeepAliveClientMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockManager_KeepAliveClientMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockManager_KeepAliveClientMockRecorder) Trailer() *gomock.Call + type MockManager_KeepAliveServer struct + func NewMockManager_KeepAliveServer(ctrl *gomock.Controller) *MockManager_KeepAliveServer + func (m *MockManager_KeepAliveServer) Context() context.Context + func (m *MockManager_KeepAliveServer) EXPECT() *MockManager_KeepAliveServerMockRecorder + func (m *MockManager_KeepAliveServer) Recv() (*manager.KeepAliveRequest, error) + func (m *MockManager_KeepAliveServer) SendAndClose(arg0 *emptypb.Empty) error + func (m *MockManager_KeepAliveServer) SendHeader(arg0 metadata.MD) error + func (m *MockManager_KeepAliveServer) SetHeader(arg0 metadata.MD) error + func (m *MockManager_KeepAliveServer) SetTrailer(arg0 metadata.MD) + func (m_2 *MockManager_KeepAliveServer) RecvMsg(m interface{}) error + func (m_2 *MockManager_KeepAliveServer) SendMsg(m interface{}) error + type MockManager_KeepAliveServerMockRecorder struct + func (mr *MockManager_KeepAliveServerMockRecorder) Context() *gomock.Call + func (mr *MockManager_KeepAliveServerMockRecorder) Recv() *gomock.Call + func (mr *MockManager_KeepAliveServerMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockManager_KeepAliveServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call + func (mr *MockManager_KeepAliveServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call + func (mr *MockManager_KeepAliveServerMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockManager_KeepAliveServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call + func (mr *MockManager_KeepAliveServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call + type MockUnsafeManagerServer struct + func NewMockUnsafeManagerServer(ctrl *gomock.Controller) *MockUnsafeManagerServer + func (m *MockUnsafeManagerServer) EXPECT() *MockUnsafeManagerServerMockRecorder + type MockUnsafeManagerServerMockRecorder struct
Go to main page