Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Index ¶
- type MockManagerClient
- func (m *MockManagerClient) CreateModel(ctx context.Context, in *v1.CreateModelRequest, opts ...grpc.CallOption) (*v1.Model, error)
- func (m *MockManagerClient) CreateModelVersion(ctx context.Context, in *v1.CreateModelVersionRequest, opts ...grpc.CallOption) (*v1.ModelVersion, error)
- func (m *MockManagerClient) DeleteModel(ctx context.Context, in *v1.DeleteModelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockManagerClient) DeleteModelVersion(ctx context.Context, in *v1.DeleteModelVersionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
- func (m *MockManagerClient) EXPECT() *MockManagerClientMockRecorder
- func (m *MockManagerClient) GetModel(ctx context.Context, in *v1.GetModelRequest, opts ...grpc.CallOption) (*v1.Model, error)
- func (m *MockManagerClient) GetModelVersion(ctx context.Context, in *v1.GetModelVersionRequest, opts ...grpc.CallOption) (*v1.ModelVersion, error)
- func (m *MockManagerClient) GetObjectStorage(ctx context.Context, in *v1.GetObjectStorageRequest, opts ...grpc.CallOption) (*v1.ObjectStorage, error)
- func (m *MockManagerClient) GetScheduler(ctx context.Context, in *v1.GetSchedulerRequest, opts ...grpc.CallOption) (*v1.Scheduler, error)
- func (m *MockManagerClient) GetSeedPeer(ctx context.Context, in *v1.GetSeedPeerRequest, opts ...grpc.CallOption) (*v1.SeedPeer, error)
- func (m *MockManagerClient) KeepAlive(ctx context.Context, opts ...grpc.CallOption) (v1.Manager_KeepAliveClient, error)
- func (m *MockManagerClient) ListApplications(ctx context.Context, in *v1.ListApplicationsRequest, opts ...grpc.CallOption) (*v1.ListApplicationsResponse, error)
- func (m *MockManagerClient) ListBuckets(ctx context.Context, in *v1.ListBucketsRequest, opts ...grpc.CallOption) (*v1.ListBucketsResponse, error)
- func (m *MockManagerClient) ListModelVersions(ctx context.Context, in *v1.ListModelVersionsRequest, opts ...grpc.CallOption) (*v1.ListModelVersionsResponse, error)
- func (m *MockManagerClient) ListModels(ctx context.Context, in *v1.ListModelsRequest, opts ...grpc.CallOption) (*v1.ListModelsResponse, error)
- func (m *MockManagerClient) ListSchedulers(ctx context.Context, in *v1.ListSchedulersRequest, opts ...grpc.CallOption) (*v1.ListSchedulersResponse, error)
- func (m *MockManagerClient) UpdateModel(ctx context.Context, in *v1.UpdateModelRequest, opts ...grpc.CallOption) (*v1.Model, error)
- func (m *MockManagerClient) UpdateModelVersion(ctx context.Context, in *v1.UpdateModelVersionRequest, opts ...grpc.CallOption) (*v1.ModelVersion, error)
- func (m *MockManagerClient) UpdateScheduler(ctx context.Context, in *v1.UpdateSchedulerRequest, opts ...grpc.CallOption) (*v1.Scheduler, error)
- func (m *MockManagerClient) UpdateSeedPeer(ctx context.Context, in *v1.UpdateSeedPeerRequest, opts ...grpc.CallOption) (*v1.SeedPeer, error)
- type MockManagerClientMockRecorder
- func (mr *MockManagerClientMockRecorder) CreateModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) CreateModelVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) DeleteModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) DeleteModelVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) GetModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) GetModelVersion(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) ListModelVersions(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) ListModels(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) ListSchedulers(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) UpdateModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockManagerClientMockRecorder) UpdateModelVersion(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
- func (m *MockManagerServer) CreateModel(arg0 context.Context, arg1 *v1.CreateModelRequest) (*v1.Model, error)
- func (m *MockManagerServer) CreateModelVersion(arg0 context.Context, arg1 *v1.CreateModelVersionRequest) (*v1.ModelVersion, error)
- func (m *MockManagerServer) DeleteModel(arg0 context.Context, arg1 *v1.DeleteModelRequest) (*emptypb.Empty, error)
- func (m *MockManagerServer) DeleteModelVersion(arg0 context.Context, arg1 *v1.DeleteModelVersionRequest) (*emptypb.Empty, error)
- func (m *MockManagerServer) EXPECT() *MockManagerServerMockRecorder
- func (m *MockManagerServer) GetModel(arg0 context.Context, arg1 *v1.GetModelRequest) (*v1.Model, error)
- func (m *MockManagerServer) GetModelVersion(arg0 context.Context, arg1 *v1.GetModelVersionRequest) (*v1.ModelVersion, error)
- func (m *MockManagerServer) GetObjectStorage(arg0 context.Context, arg1 *v1.GetObjectStorageRequest) (*v1.ObjectStorage, error)
- func (m *MockManagerServer) GetScheduler(arg0 context.Context, arg1 *v1.GetSchedulerRequest) (*v1.Scheduler, error)
- func (m *MockManagerServer) GetSeedPeer(arg0 context.Context, arg1 *v1.GetSeedPeerRequest) (*v1.SeedPeer, error)
- func (m *MockManagerServer) KeepAlive(arg0 v1.Manager_KeepAliveServer) error
- func (m *MockManagerServer) ListApplications(arg0 context.Context, arg1 *v1.ListApplicationsRequest) (*v1.ListApplicationsResponse, error)
- func (m *MockManagerServer) ListBuckets(arg0 context.Context, arg1 *v1.ListBucketsRequest) (*v1.ListBucketsResponse, error)
- func (m *MockManagerServer) ListModelVersions(arg0 context.Context, arg1 *v1.ListModelVersionsRequest) (*v1.ListModelVersionsResponse, error)
- func (m *MockManagerServer) ListModels(arg0 context.Context, arg1 *v1.ListModelsRequest) (*v1.ListModelsResponse, error)
- func (m *MockManagerServer) ListSchedulers(arg0 context.Context, arg1 *v1.ListSchedulersRequest) (*v1.ListSchedulersResponse, error)
- func (m *MockManagerServer) UpdateModel(arg0 context.Context, arg1 *v1.UpdateModelRequest) (*v1.Model, error)
- func (m *MockManagerServer) UpdateModelVersion(arg0 context.Context, arg1 *v1.UpdateModelVersionRequest) (*v1.ModelVersion, error)
- func (m *MockManagerServer) UpdateScheduler(arg0 context.Context, arg1 *v1.UpdateSchedulerRequest) (*v1.Scheduler, error)
- func (m *MockManagerServer) UpdateSeedPeer(arg0 context.Context, arg1 *v1.UpdateSeedPeerRequest) (*v1.SeedPeer, error)
- type MockManagerServerMockRecorder
- func (mr *MockManagerServerMockRecorder) CreateModel(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) CreateModelVersion(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) DeleteModel(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) DeleteModelVersion(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) GetModel(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) GetModelVersion(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) ListModelVersions(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) ListModels(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) ListSchedulers(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) UpdateModel(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockManagerServerMockRecorder) UpdateModelVersion(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
- 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_2 *MockManager_KeepAliveClient) RecvMsg(m interface{}) error
- func (m *MockManager_KeepAliveClient) Send(arg0 *v1.KeepAliveRequest) error
- func (m_2 *MockManager_KeepAliveClient) SendMsg(m interface{}) error
- func (m *MockManager_KeepAliveClient) Trailer() metadata.MD
- type MockManager_KeepAliveClientMockRecorder
- 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
- func (m *MockManager_KeepAliveServer) Context() context.Context
- func (m *MockManager_KeepAliveServer) EXPECT() *MockManager_KeepAliveServerMockRecorder
- func (m *MockManager_KeepAliveServer) Recv() (*v1.KeepAliveRequest, error)
- func (m_2 *MockManager_KeepAliveServer) RecvMsg(m interface{}) error
- func (m *MockManager_KeepAliveServer) SendAndClose(arg0 *emptypb.Empty) error
- func (m *MockManager_KeepAliveServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockManager_KeepAliveServer) SendMsg(m interface{}) error
- func (m *MockManager_KeepAliveServer) SetHeader(arg0 metadata.MD) error
- func (m *MockManager_KeepAliveServer) SetTrailer(arg0 metadata.MD)
- type MockManager_KeepAliveServerMockRecorder
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockManagerClient ¶
type MockManagerClient struct {
// contains filtered or unexported fields
}
MockManagerClient is a mock of ManagerClient interface.
func NewMockManagerClient ¶
func NewMockManagerClient(ctrl *gomock.Controller) *MockManagerClient
NewMockManagerClient creates a new mock instance.
func (*MockManagerClient) CreateModel ¶ added in v1.0.4
func (m *MockManagerClient) CreateModel(ctx context.Context, in *v1.CreateModelRequest, opts ...grpc.CallOption) (*v1.Model, error)
CreateModel mocks base method.
func (*MockManagerClient) CreateModelVersion ¶ added in v1.0.4
func (m *MockManagerClient) CreateModelVersion(ctx context.Context, in *v1.CreateModelVersionRequest, opts ...grpc.CallOption) (*v1.ModelVersion, error)
CreateModelVersion mocks base method.
func (*MockManagerClient) DeleteModel ¶ added in v1.0.4
func (m *MockManagerClient) DeleteModel(ctx context.Context, in *v1.DeleteModelRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteModel mocks base method.
func (*MockManagerClient) DeleteModelVersion ¶ added in v1.0.4
func (m *MockManagerClient) DeleteModelVersion(ctx context.Context, in *v1.DeleteModelVersionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
DeleteModelVersion mocks base method.
func (*MockManagerClient) EXPECT ¶
func (m *MockManagerClient) EXPECT() *MockManagerClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManagerClient) GetModel ¶ added in v1.0.4
func (m *MockManagerClient) GetModel(ctx context.Context, in *v1.GetModelRequest, opts ...grpc.CallOption) (*v1.Model, error)
GetModel mocks base method.
func (*MockManagerClient) GetModelVersion ¶ added in v1.0.4
func (m *MockManagerClient) GetModelVersion(ctx context.Context, in *v1.GetModelVersionRequest, opts ...grpc.CallOption) (*v1.ModelVersion, error)
GetModelVersion mocks base method.
func (*MockManagerClient) GetObjectStorage ¶
func (m *MockManagerClient) GetObjectStorage(ctx context.Context, in *v1.GetObjectStorageRequest, opts ...grpc.CallOption) (*v1.ObjectStorage, error)
GetObjectStorage mocks base method.
func (*MockManagerClient) GetScheduler ¶
func (m *MockManagerClient) GetScheduler(ctx context.Context, in *v1.GetSchedulerRequest, opts ...grpc.CallOption) (*v1.Scheduler, error)
GetScheduler mocks base method.
func (*MockManagerClient) GetSeedPeer ¶
func (m *MockManagerClient) GetSeedPeer(ctx context.Context, in *v1.GetSeedPeerRequest, opts ...grpc.CallOption) (*v1.SeedPeer, error)
GetSeedPeer mocks base method.
func (*MockManagerClient) KeepAlive ¶
func (m *MockManagerClient) KeepAlive(ctx context.Context, opts ...grpc.CallOption) (v1.Manager_KeepAliveClient, error)
KeepAlive mocks base method.
func (*MockManagerClient) ListApplications ¶ added in v1.3.1
func (m *MockManagerClient) ListApplications(ctx context.Context, in *v1.ListApplicationsRequest, opts ...grpc.CallOption) (*v1.ListApplicationsResponse, error)
ListApplications mocks base method.
func (*MockManagerClient) ListBuckets ¶
func (m *MockManagerClient) ListBuckets(ctx context.Context, in *v1.ListBucketsRequest, opts ...grpc.CallOption) (*v1.ListBucketsResponse, error)
ListBuckets mocks base method.
func (*MockManagerClient) ListModelVersions ¶ added in v1.0.4
func (m *MockManagerClient) ListModelVersions(ctx context.Context, in *v1.ListModelVersionsRequest, opts ...grpc.CallOption) (*v1.ListModelVersionsResponse, error)
ListModelVersions mocks base method.
func (*MockManagerClient) ListModels ¶ added in v1.0.4
func (m *MockManagerClient) ListModels(ctx context.Context, in *v1.ListModelsRequest, opts ...grpc.CallOption) (*v1.ListModelsResponse, error)
ListModels mocks base method.
func (*MockManagerClient) ListSchedulers ¶
func (m *MockManagerClient) ListSchedulers(ctx context.Context, in *v1.ListSchedulersRequest, opts ...grpc.CallOption) (*v1.ListSchedulersResponse, error)
ListSchedulers mocks base method.
func (*MockManagerClient) UpdateModel ¶ added in v1.0.4
func (m *MockManagerClient) UpdateModel(ctx context.Context, in *v1.UpdateModelRequest, opts ...grpc.CallOption) (*v1.Model, error)
UpdateModel mocks base method.
func (*MockManagerClient) UpdateModelVersion ¶ added in v1.0.4
func (m *MockManagerClient) UpdateModelVersion(ctx context.Context, in *v1.UpdateModelVersionRequest, opts ...grpc.CallOption) (*v1.ModelVersion, error)
UpdateModelVersion mocks base method.
func (*MockManagerClient) UpdateScheduler ¶
func (m *MockManagerClient) UpdateScheduler(ctx context.Context, in *v1.UpdateSchedulerRequest, opts ...grpc.CallOption) (*v1.Scheduler, error)
UpdateScheduler mocks base method.
func (*MockManagerClient) UpdateSeedPeer ¶
func (m *MockManagerClient) UpdateSeedPeer(ctx context.Context, in *v1.UpdateSeedPeerRequest, opts ...grpc.CallOption) (*v1.SeedPeer, error)
UpdateSeedPeer mocks base method.
type MockManagerClientMockRecorder ¶
type MockManagerClientMockRecorder struct {
// contains filtered or unexported fields
}
MockManagerClientMockRecorder is the mock recorder for MockManagerClient.
func (*MockManagerClientMockRecorder) CreateModel ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) CreateModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
CreateModel indicates an expected call of CreateModel.
func (*MockManagerClientMockRecorder) CreateModelVersion ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) CreateModelVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call
CreateModelVersion indicates an expected call of CreateModelVersion.
func (*MockManagerClientMockRecorder) DeleteModel ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) DeleteModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteModel indicates an expected call of DeleteModel.
func (*MockManagerClientMockRecorder) DeleteModelVersion ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) DeleteModelVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call
DeleteModelVersion indicates an expected call of DeleteModelVersion.
func (*MockManagerClientMockRecorder) GetModel ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) GetModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetModel indicates an expected call of GetModel.
func (*MockManagerClientMockRecorder) GetModelVersion ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) GetModelVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetModelVersion indicates an expected call of GetModelVersion.
func (*MockManagerClientMockRecorder) GetObjectStorage ¶
func (mr *MockManagerClientMockRecorder) GetObjectStorage(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetObjectStorage indicates an expected call of GetObjectStorage.
func (*MockManagerClientMockRecorder) GetScheduler ¶
func (mr *MockManagerClientMockRecorder) GetScheduler(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetScheduler indicates an expected call of GetScheduler.
func (*MockManagerClientMockRecorder) GetSeedPeer ¶
func (mr *MockManagerClientMockRecorder) GetSeedPeer(ctx, in interface{}, opts ...interface{}) *gomock.Call
GetSeedPeer indicates an expected call of GetSeedPeer.
func (*MockManagerClientMockRecorder) KeepAlive ¶
func (mr *MockManagerClientMockRecorder) KeepAlive(ctx interface{}, opts ...interface{}) *gomock.Call
KeepAlive indicates an expected call of KeepAlive.
func (*MockManagerClientMockRecorder) ListApplications ¶ added in v1.3.1
func (mr *MockManagerClientMockRecorder) ListApplications(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListApplications indicates an expected call of ListApplications.
func (*MockManagerClientMockRecorder) ListBuckets ¶
func (mr *MockManagerClientMockRecorder) ListBuckets(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListBuckets indicates an expected call of ListBuckets.
func (*MockManagerClientMockRecorder) ListModelVersions ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) ListModelVersions(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListModelVersions indicates an expected call of ListModelVersions.
func (*MockManagerClientMockRecorder) ListModels ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) ListModels(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListModels indicates an expected call of ListModels.
func (*MockManagerClientMockRecorder) ListSchedulers ¶
func (mr *MockManagerClientMockRecorder) ListSchedulers(ctx, in interface{}, opts ...interface{}) *gomock.Call
ListSchedulers indicates an expected call of ListSchedulers.
func (*MockManagerClientMockRecorder) UpdateModel ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) UpdateModel(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateModel indicates an expected call of UpdateModel.
func (*MockManagerClientMockRecorder) UpdateModelVersion ¶ added in v1.0.4
func (mr *MockManagerClientMockRecorder) UpdateModelVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateModelVersion indicates an expected call of UpdateModelVersion.
func (*MockManagerClientMockRecorder) UpdateScheduler ¶
func (mr *MockManagerClientMockRecorder) UpdateScheduler(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateScheduler indicates an expected call of UpdateScheduler.
func (*MockManagerClientMockRecorder) UpdateSeedPeer ¶
func (mr *MockManagerClientMockRecorder) UpdateSeedPeer(ctx, in interface{}, opts ...interface{}) *gomock.Call
UpdateSeedPeer indicates an expected call of UpdateSeedPeer.
type MockManagerServer ¶
type MockManagerServer struct {
// contains filtered or unexported fields
}
MockManagerServer is a mock of ManagerServer interface.
func NewMockManagerServer ¶
func NewMockManagerServer(ctrl *gomock.Controller) *MockManagerServer
NewMockManagerServer creates a new mock instance.
func (*MockManagerServer) CreateModel ¶ added in v1.0.4
func (m *MockManagerServer) CreateModel(arg0 context.Context, arg1 *v1.CreateModelRequest) (*v1.Model, error)
CreateModel mocks base method.
func (*MockManagerServer) CreateModelVersion ¶ added in v1.0.4
func (m *MockManagerServer) CreateModelVersion(arg0 context.Context, arg1 *v1.CreateModelVersionRequest) (*v1.ModelVersion, error)
CreateModelVersion mocks base method.
func (*MockManagerServer) DeleteModel ¶ added in v1.0.4
func (m *MockManagerServer) DeleteModel(arg0 context.Context, arg1 *v1.DeleteModelRequest) (*emptypb.Empty, error)
DeleteModel mocks base method.
func (*MockManagerServer) DeleteModelVersion ¶ added in v1.0.4
func (m *MockManagerServer) DeleteModelVersion(arg0 context.Context, arg1 *v1.DeleteModelVersionRequest) (*emptypb.Empty, error)
DeleteModelVersion mocks base method.
func (*MockManagerServer) EXPECT ¶
func (m *MockManagerServer) EXPECT() *MockManagerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManagerServer) GetModel ¶ added in v1.0.4
func (m *MockManagerServer) GetModel(arg0 context.Context, arg1 *v1.GetModelRequest) (*v1.Model, error)
GetModel mocks base method.
func (*MockManagerServer) GetModelVersion ¶ added in v1.0.4
func (m *MockManagerServer) GetModelVersion(arg0 context.Context, arg1 *v1.GetModelVersionRequest) (*v1.ModelVersion, error)
GetModelVersion mocks base method.
func (*MockManagerServer) GetObjectStorage ¶
func (m *MockManagerServer) GetObjectStorage(arg0 context.Context, arg1 *v1.GetObjectStorageRequest) (*v1.ObjectStorage, error)
GetObjectStorage mocks base method.
func (*MockManagerServer) GetScheduler ¶
func (m *MockManagerServer) GetScheduler(arg0 context.Context, arg1 *v1.GetSchedulerRequest) (*v1.Scheduler, error)
GetScheduler mocks base method.
func (*MockManagerServer) GetSeedPeer ¶
func (m *MockManagerServer) GetSeedPeer(arg0 context.Context, arg1 *v1.GetSeedPeerRequest) (*v1.SeedPeer, error)
GetSeedPeer mocks base method.
func (*MockManagerServer) KeepAlive ¶
func (m *MockManagerServer) KeepAlive(arg0 v1.Manager_KeepAliveServer) error
KeepAlive mocks base method.
func (*MockManagerServer) ListApplications ¶ added in v1.3.1
func (m *MockManagerServer) ListApplications(arg0 context.Context, arg1 *v1.ListApplicationsRequest) (*v1.ListApplicationsResponse, error)
ListApplications mocks base method.
func (*MockManagerServer) ListBuckets ¶
func (m *MockManagerServer) ListBuckets(arg0 context.Context, arg1 *v1.ListBucketsRequest) (*v1.ListBucketsResponse, error)
ListBuckets mocks base method.
func (*MockManagerServer) ListModelVersions ¶ added in v1.0.4
func (m *MockManagerServer) ListModelVersions(arg0 context.Context, arg1 *v1.ListModelVersionsRequest) (*v1.ListModelVersionsResponse, error)
ListModelVersions mocks base method.
func (*MockManagerServer) ListModels ¶ added in v1.0.4
func (m *MockManagerServer) ListModels(arg0 context.Context, arg1 *v1.ListModelsRequest) (*v1.ListModelsResponse, error)
ListModels mocks base method.
func (*MockManagerServer) ListSchedulers ¶
func (m *MockManagerServer) ListSchedulers(arg0 context.Context, arg1 *v1.ListSchedulersRequest) (*v1.ListSchedulersResponse, error)
ListSchedulers mocks base method.
func (*MockManagerServer) UpdateModel ¶ added in v1.0.4
func (m *MockManagerServer) UpdateModel(arg0 context.Context, arg1 *v1.UpdateModelRequest) (*v1.Model, error)
UpdateModel mocks base method.
func (*MockManagerServer) UpdateModelVersion ¶ added in v1.0.4
func (m *MockManagerServer) UpdateModelVersion(arg0 context.Context, arg1 *v1.UpdateModelVersionRequest) (*v1.ModelVersion, error)
UpdateModelVersion mocks base method.
func (*MockManagerServer) UpdateScheduler ¶
func (m *MockManagerServer) UpdateScheduler(arg0 context.Context, arg1 *v1.UpdateSchedulerRequest) (*v1.Scheduler, error)
UpdateScheduler mocks base method.
func (*MockManagerServer) UpdateSeedPeer ¶
func (m *MockManagerServer) UpdateSeedPeer(arg0 context.Context, arg1 *v1.UpdateSeedPeerRequest) (*v1.SeedPeer, error)
UpdateSeedPeer mocks base method.
type MockManagerServerMockRecorder ¶
type MockManagerServerMockRecorder struct {
// contains filtered or unexported fields
}
MockManagerServerMockRecorder is the mock recorder for MockManagerServer.
func (*MockManagerServerMockRecorder) CreateModel ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) CreateModel(arg0, arg1 interface{}) *gomock.Call
CreateModel indicates an expected call of CreateModel.
func (*MockManagerServerMockRecorder) CreateModelVersion ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) CreateModelVersion(arg0, arg1 interface{}) *gomock.Call
CreateModelVersion indicates an expected call of CreateModelVersion.
func (*MockManagerServerMockRecorder) DeleteModel ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) DeleteModel(arg0, arg1 interface{}) *gomock.Call
DeleteModel indicates an expected call of DeleteModel.
func (*MockManagerServerMockRecorder) DeleteModelVersion ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) DeleteModelVersion(arg0, arg1 interface{}) *gomock.Call
DeleteModelVersion indicates an expected call of DeleteModelVersion.
func (*MockManagerServerMockRecorder) GetModel ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) GetModel(arg0, arg1 interface{}) *gomock.Call
GetModel indicates an expected call of GetModel.
func (*MockManagerServerMockRecorder) GetModelVersion ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) GetModelVersion(arg0, arg1 interface{}) *gomock.Call
GetModelVersion indicates an expected call of GetModelVersion.
func (*MockManagerServerMockRecorder) GetObjectStorage ¶
func (mr *MockManagerServerMockRecorder) GetObjectStorage(arg0, arg1 interface{}) *gomock.Call
GetObjectStorage indicates an expected call of GetObjectStorage.
func (*MockManagerServerMockRecorder) GetScheduler ¶
func (mr *MockManagerServerMockRecorder) GetScheduler(arg0, arg1 interface{}) *gomock.Call
GetScheduler indicates an expected call of GetScheduler.
func (*MockManagerServerMockRecorder) GetSeedPeer ¶
func (mr *MockManagerServerMockRecorder) GetSeedPeer(arg0, arg1 interface{}) *gomock.Call
GetSeedPeer indicates an expected call of GetSeedPeer.
func (*MockManagerServerMockRecorder) KeepAlive ¶
func (mr *MockManagerServerMockRecorder) KeepAlive(arg0 interface{}) *gomock.Call
KeepAlive indicates an expected call of KeepAlive.
func (*MockManagerServerMockRecorder) ListApplications ¶ added in v1.3.1
func (mr *MockManagerServerMockRecorder) ListApplications(arg0, arg1 interface{}) *gomock.Call
ListApplications indicates an expected call of ListApplications.
func (*MockManagerServerMockRecorder) ListBuckets ¶
func (mr *MockManagerServerMockRecorder) ListBuckets(arg0, arg1 interface{}) *gomock.Call
ListBuckets indicates an expected call of ListBuckets.
func (*MockManagerServerMockRecorder) ListModelVersions ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) ListModelVersions(arg0, arg1 interface{}) *gomock.Call
ListModelVersions indicates an expected call of ListModelVersions.
func (*MockManagerServerMockRecorder) ListModels ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) ListModels(arg0, arg1 interface{}) *gomock.Call
ListModels indicates an expected call of ListModels.
func (*MockManagerServerMockRecorder) ListSchedulers ¶
func (mr *MockManagerServerMockRecorder) ListSchedulers(arg0, arg1 interface{}) *gomock.Call
ListSchedulers indicates an expected call of ListSchedulers.
func (*MockManagerServerMockRecorder) UpdateModel ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) UpdateModel(arg0, arg1 interface{}) *gomock.Call
UpdateModel indicates an expected call of UpdateModel.
func (*MockManagerServerMockRecorder) UpdateModelVersion ¶ added in v1.0.4
func (mr *MockManagerServerMockRecorder) UpdateModelVersion(arg0, arg1 interface{}) *gomock.Call
UpdateModelVersion indicates an expected call of UpdateModelVersion.
func (*MockManagerServerMockRecorder) UpdateScheduler ¶
func (mr *MockManagerServerMockRecorder) UpdateScheduler(arg0, arg1 interface{}) *gomock.Call
UpdateScheduler indicates an expected call of UpdateScheduler.
func (*MockManagerServerMockRecorder) UpdateSeedPeer ¶
func (mr *MockManagerServerMockRecorder) UpdateSeedPeer(arg0, arg1 interface{}) *gomock.Call
UpdateSeedPeer indicates an expected call of UpdateSeedPeer.
type MockManager_KeepAliveClient ¶
type MockManager_KeepAliveClient struct {
// contains filtered or unexported fields
}
MockManager_KeepAliveClient is a mock of Manager_KeepAliveClient interface.
func NewMockManager_KeepAliveClient ¶
func NewMockManager_KeepAliveClient(ctrl *gomock.Controller) *MockManager_KeepAliveClient
NewMockManager_KeepAliveClient creates a new mock instance.
func (*MockManager_KeepAliveClient) CloseAndRecv ¶
func (m *MockManager_KeepAliveClient) CloseAndRecv() (*emptypb.Empty, error)
CloseAndRecv mocks base method.
func (*MockManager_KeepAliveClient) CloseSend ¶
func (m *MockManager_KeepAliveClient) CloseSend() error
CloseSend mocks base method.
func (*MockManager_KeepAliveClient) Context ¶
func (m *MockManager_KeepAliveClient) Context() context.Context
Context mocks base method.
func (*MockManager_KeepAliveClient) EXPECT ¶
func (m *MockManager_KeepAliveClient) EXPECT() *MockManager_KeepAliveClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManager_KeepAliveClient) Header ¶
func (m *MockManager_KeepAliveClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockManager_KeepAliveClient) RecvMsg ¶
func (m_2 *MockManager_KeepAliveClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockManager_KeepAliveClient) Send ¶
func (m *MockManager_KeepAliveClient) Send(arg0 *v1.KeepAliveRequest) error
Send mocks base method.
func (*MockManager_KeepAliveClient) SendMsg ¶
func (m_2 *MockManager_KeepAliveClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockManager_KeepAliveClient) Trailer ¶
func (m *MockManager_KeepAliveClient) Trailer() metadata.MD
Trailer mocks base method.
type MockManager_KeepAliveClientMockRecorder ¶
type MockManager_KeepAliveClientMockRecorder struct {
// contains filtered or unexported fields
}
MockManager_KeepAliveClientMockRecorder is the mock recorder for MockManager_KeepAliveClient.
func (*MockManager_KeepAliveClientMockRecorder) CloseAndRecv ¶
func (mr *MockManager_KeepAliveClientMockRecorder) CloseAndRecv() *gomock.Call
CloseAndRecv indicates an expected call of CloseAndRecv.
func (*MockManager_KeepAliveClientMockRecorder) CloseSend ¶
func (mr *MockManager_KeepAliveClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockManager_KeepAliveClientMockRecorder) Context ¶
func (mr *MockManager_KeepAliveClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockManager_KeepAliveClientMockRecorder) Header ¶
func (mr *MockManager_KeepAliveClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockManager_KeepAliveClientMockRecorder) RecvMsg ¶
func (mr *MockManager_KeepAliveClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockManager_KeepAliveClientMockRecorder) Send ¶
func (mr *MockManager_KeepAliveClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockManager_KeepAliveClientMockRecorder) SendMsg ¶
func (mr *MockManager_KeepAliveClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockManager_KeepAliveClientMockRecorder) Trailer ¶
func (mr *MockManager_KeepAliveClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockManager_KeepAliveServer ¶
type MockManager_KeepAliveServer struct {
// contains filtered or unexported fields
}
MockManager_KeepAliveServer is a mock of Manager_KeepAliveServer interface.
func NewMockManager_KeepAliveServer ¶
func NewMockManager_KeepAliveServer(ctrl *gomock.Controller) *MockManager_KeepAliveServer
NewMockManager_KeepAliveServer creates a new mock instance.
func (*MockManager_KeepAliveServer) Context ¶
func (m *MockManager_KeepAliveServer) Context() context.Context
Context mocks base method.
func (*MockManager_KeepAliveServer) EXPECT ¶
func (m *MockManager_KeepAliveServer) EXPECT() *MockManager_KeepAliveServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManager_KeepAliveServer) Recv ¶
func (m *MockManager_KeepAliveServer) Recv() (*v1.KeepAliveRequest, error)
Recv mocks base method.
func (*MockManager_KeepAliveServer) RecvMsg ¶
func (m_2 *MockManager_KeepAliveServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockManager_KeepAliveServer) SendAndClose ¶
func (m *MockManager_KeepAliveServer) SendAndClose(arg0 *emptypb.Empty) error
SendAndClose mocks base method.
func (*MockManager_KeepAliveServer) SendHeader ¶
func (m *MockManager_KeepAliveServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockManager_KeepAliveServer) SendMsg ¶
func (m_2 *MockManager_KeepAliveServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockManager_KeepAliveServer) SetHeader ¶
func (m *MockManager_KeepAliveServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockManager_KeepAliveServer) SetTrailer ¶
func (m *MockManager_KeepAliveServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockManager_KeepAliveServerMockRecorder ¶
type MockManager_KeepAliveServerMockRecorder struct {
// contains filtered or unexported fields
}
MockManager_KeepAliveServerMockRecorder is the mock recorder for MockManager_KeepAliveServer.
func (*MockManager_KeepAliveServerMockRecorder) Context ¶
func (mr *MockManager_KeepAliveServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockManager_KeepAliveServerMockRecorder) Recv ¶
func (mr *MockManager_KeepAliveServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockManager_KeepAliveServerMockRecorder) RecvMsg ¶
func (mr *MockManager_KeepAliveServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockManager_KeepAliveServerMockRecorder) SendAndClose ¶
func (mr *MockManager_KeepAliveServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call
SendAndClose indicates an expected call of SendAndClose.
func (*MockManager_KeepAliveServerMockRecorder) SendHeader ¶
func (mr *MockManager_KeepAliveServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockManager_KeepAliveServerMockRecorder) SendMsg ¶
func (mr *MockManager_KeepAliveServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockManager_KeepAliveServerMockRecorder) SetHeader ¶
func (mr *MockManager_KeepAliveServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockManager_KeepAliveServerMockRecorder) SetTrailer ¶
func (mr *MockManager_KeepAliveServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.