Versions in this module Expand all Collapse all v0 v0.6.2 Jan 25, 2024 v0.6.1 Jan 25, 2024 Changes in this version + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *MockClient + func (m *MockClient) Close() error + func (m *MockClient) Conn() *grpc.ClientConn + func (m *MockClient) ContainerService() containers.Store + func (m *MockClient) Containers(arg0 context.Context, arg1 ...string) ([]containerd.Container, error) + func (m *MockClient) ContentStore() content.Store + func (m *MockClient) DiffService() containerd.DiffService + func (m *MockClient) EXPECT() *MockClientMockRecorder + func (m *MockClient) EventService() containerd.EventService + func (m *MockClient) Fetch(arg0 context.Context, arg1 string, arg2 ...containerd.RemoteOpt) (images.Image, error) + func (m *MockClient) GetImage(arg0 context.Context, arg1 string) (containerd.Image, error) + func (m *MockClient) GetLabel(arg0 context.Context, arg1 string) (string, error) + func (m *MockClient) GetSnapshotterSupportedPlatforms(arg0 context.Context, arg1 string) (platforms.MatchComparer, error) + func (m *MockClient) HealthService() grpc_health_v1.HealthClient + func (m *MockClient) ImageService() images.Store + func (m *MockClient) IntrospectionService() introspection.Service + func (m *MockClient) IsServing(arg0 context.Context) (bool, error) + func (m *MockClient) LeasesService() leases.Manager + func (m *MockClient) ListImages(arg0 context.Context, arg1 ...string) ([]containerd.Image, error) + func (m *MockClient) LoadContainer(arg0 context.Context, arg1 string) (containerd.Container, error) + func (m *MockClient) NamespaceService() namespaces.Store + func (m *MockClient) NewContainer(arg0 context.Context, arg1 string, arg2 ...containerd.NewContainerOpts) (containerd.Container, error) + func (m *MockClient) Pull(arg0 context.Context, arg1 string, arg2 ...containerd.RemoteOpt) (containerd.Image, error) + func (m *MockClient) Push(arg0 context.Context, arg1 string, arg2 v1.Descriptor, ...) error + func (m *MockClient) Reconnect() error + func (m *MockClient) Restore(arg0 context.Context, arg1 string, arg2 containerd.Image, ...) (containerd.Container, error) + func (m *MockClient) Runtime() string + func (m *MockClient) Server(arg0 context.Context) (containerd.ServerInfo, error) + func (m *MockClient) SnapshotService(arg0 string) snapshots.Snapshotter + func (m *MockClient) Subscribe(arg0 context.Context, arg1 ...string) (<-chan *events.Envelope, <-chan error) + func (m *MockClient) TaskService() tasks.TasksClient + func (m *MockClient) Version(arg0 context.Context) (containerd.Version, error) + func (m *MockClient) VersionService() version.VersionClient + type MockClientMockRecorder struct + func (mr *MockClientMockRecorder) Close() *gomock.Call + func (mr *MockClientMockRecorder) Conn() *gomock.Call + func (mr *MockClientMockRecorder) ContainerService() *gomock.Call + func (mr *MockClientMockRecorder) Containers(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) ContentStore() *gomock.Call + func (mr *MockClientMockRecorder) DiffService() *gomock.Call + func (mr *MockClientMockRecorder) EventService() *gomock.Call + func (mr *MockClientMockRecorder) Fetch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetImage(arg0, arg1 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetLabel(arg0, arg1 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) GetSnapshotterSupportedPlatforms(arg0, arg1 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) HealthService() *gomock.Call + func (mr *MockClientMockRecorder) ImageService() *gomock.Call + func (mr *MockClientMockRecorder) IntrospectionService() *gomock.Call + func (mr *MockClientMockRecorder) IsServing(arg0 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) LeasesService() *gomock.Call + func (mr *MockClientMockRecorder) ListImages(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) LoadContainer(arg0, arg1 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) NamespaceService() *gomock.Call + func (mr *MockClientMockRecorder) NewContainer(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Pull(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Push(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Reconnect() *gomock.Call + func (mr *MockClientMockRecorder) Restore(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Runtime() *gomock.Call + func (mr *MockClientMockRecorder) Server(arg0 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) SnapshotService(arg0 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) Subscribe(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockClientMockRecorder) TaskService() *gomock.Call + func (mr *MockClientMockRecorder) Version(arg0 interface{}) *gomock.Call + func (mr *MockClientMockRecorder) VersionService() *gomock.Call + type MockEventService struct + func NewMockEventService(ctrl *gomock.Controller) *MockEventService + func (m *MockEventService) EXPECT() *MockEventServiceMockRecorder + func (m *MockEventService) Publish(arg0 context.Context, arg1 string, arg2 interface{}) error + func (m *MockEventService) Subscribe(arg0 context.Context) (<-chan *ports.EventEnvelope, <-chan error) + func (m *MockEventService) SubscribeTopic(arg0 context.Context, arg1 string) (<-chan *ports.EventEnvelope, <-chan error) + func (m *MockEventService) SubscribeTopics(arg0 context.Context, arg1 []string) (<-chan *ports.EventEnvelope, <-chan error) + type MockEventServiceMockRecorder struct + func (mr *MockEventServiceMockRecorder) Publish(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockEventServiceMockRecorder) Subscribe(arg0 interface{}) *gomock.Call + func (mr *MockEventServiceMockRecorder) SubscribeTopic(arg0, arg1 interface{}) *gomock.Call + func (mr *MockEventServiceMockRecorder) SubscribeTopics(arg0, arg1 interface{}) *gomock.Call + type MockIDService struct + func NewMockIDService(ctrl *gomock.Controller) *MockIDService + func (m *MockIDService) EXPECT() *MockIDServiceMockRecorder + func (m *MockIDService) GenerateRandom() (string, error) + type MockIDServiceMockRecorder struct + func (mr *MockIDServiceMockRecorder) GenerateRandom() *gomock.Call + type MockImage struct + func NewMockImage(ctrl *gomock.Controller) *MockImage + func (m *MockImage) Config(arg0 context.Context) (v1.Descriptor, error) + func (m *MockImage) ContentStore() content.Store + func (m *MockImage) EXPECT() *MockImageMockRecorder + func (m *MockImage) IsUnpacked(arg0 context.Context, arg1 string) (bool, error) + func (m *MockImage) Labels() map[string]string + func (m *MockImage) Metadata() images.Image + func (m *MockImage) Name() string + func (m *MockImage) Platform() platforms.MatchComparer + func (m *MockImage) RootFS(arg0 context.Context) ([]digest.Digest, error) + func (m *MockImage) Size(arg0 context.Context) (int64, error) + func (m *MockImage) Spec(arg0 context.Context) (v1.Image, error) + func (m *MockImage) Target() v1.Descriptor + func (m *MockImage) Unpack(arg0 context.Context, arg1 string, arg2 ...containerd.UnpackOpt) error + func (m *MockImage) Usage(arg0 context.Context, arg1 ...containerd.UsageOpt) (int64, error) + type MockImageMockRecorder struct + func (mr *MockImageMockRecorder) Config(arg0 interface{}) *gomock.Call + func (mr *MockImageMockRecorder) ContentStore() *gomock.Call + func (mr *MockImageMockRecorder) IsUnpacked(arg0, arg1 interface{}) *gomock.Call + func (mr *MockImageMockRecorder) Labels() *gomock.Call + func (mr *MockImageMockRecorder) Metadata() *gomock.Call + func (mr *MockImageMockRecorder) Name() *gomock.Call + func (mr *MockImageMockRecorder) Platform() *gomock.Call + func (mr *MockImageMockRecorder) RootFS(arg0 interface{}) *gomock.Call + func (mr *MockImageMockRecorder) Size(arg0 interface{}) *gomock.Call + func (mr *MockImageMockRecorder) Spec(arg0 interface{}) *gomock.Call + func (mr *MockImageMockRecorder) Target() *gomock.Call + func (mr *MockImageMockRecorder) Unpack(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockImageMockRecorder) Usage(arg0 interface{}, arg1 ...interface{}) *gomock.Call + type MockImageService struct + func NewMockImageService(ctrl *gomock.Controller) *MockImageService + func (m *MockImageService) EXPECT() *MockImageServiceMockRecorder + func (m *MockImageService) Exists(arg0 context.Context, arg1 *ports.ImageSpec) (bool, error) + func (m *MockImageService) IsMounted(arg0 context.Context, arg1 *ports.ImageMountSpec) (bool, error) + func (m *MockImageService) Pull(arg0 context.Context, arg1 *ports.ImageSpec) error + func (m *MockImageService) PullAndMount(arg0 context.Context, arg1 *ports.ImageMountSpec) ([]models.Mount, error) + type MockImageServiceMockRecorder struct + func (mr *MockImageServiceMockRecorder) Exists(arg0, arg1 interface{}) *gomock.Call + func (mr *MockImageServiceMockRecorder) IsMounted(arg0, arg1 interface{}) *gomock.Call + func (mr *MockImageServiceMockRecorder) Pull(arg0, arg1 interface{}) *gomock.Call + func (mr *MockImageServiceMockRecorder) PullAndMount(arg0, arg1 interface{}) *gomock.Call + type MockManager struct + func NewMockManager(ctrl *gomock.Controller) *MockManager + func (m *MockManager) AddResource(arg0 context.Context, arg1 leases.Lease, arg2 leases.Resource) error + func (m *MockManager) Create(arg0 context.Context, arg1 ...leases.Opt) (leases.Lease, error) + func (m *MockManager) Delete(arg0 context.Context, arg1 leases.Lease, arg2 ...leases.DeleteOpt) error + func (m *MockManager) DeleteResource(arg0 context.Context, arg1 leases.Lease, arg2 leases.Resource) error + func (m *MockManager) EXPECT() *MockManagerMockRecorder + func (m *MockManager) List(arg0 context.Context, arg1 ...string) ([]leases.Lease, error) + func (m *MockManager) ListResources(arg0 context.Context, arg1 leases.Lease) ([]leases.Resource, error) + type MockManagerMockRecorder struct + func (mr *MockManagerMockRecorder) AddResource(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) Create(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) DeleteResource(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) List(arg0 interface{}, arg1 ...interface{}) *gomock.Call + func (mr *MockManagerMockRecorder) ListResources(arg0, arg1 interface{}) *gomock.Call + type MockMicroVMCommandUseCases struct + func NewMockMicroVMCommandUseCases(ctrl *gomock.Controller) *MockMicroVMCommandUseCases + func (m *MockMicroVMCommandUseCases) CreateMicroVM(arg0 context.Context, arg1 *models.MicroVM) (*models.MicroVM, error) + func (m *MockMicroVMCommandUseCases) DeleteMicroVM(arg0 context.Context, arg1 string) error + func (m *MockMicroVMCommandUseCases) EXPECT() *MockMicroVMCommandUseCasesMockRecorder + type MockMicroVMCommandUseCasesMockRecorder struct + func (mr *MockMicroVMCommandUseCasesMockRecorder) CreateMicroVM(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMCommandUseCasesMockRecorder) DeleteMicroVM(arg0, arg1 interface{}) *gomock.Call + type MockMicroVMQueryUseCases struct + func NewMockMicroVMQueryUseCases(ctrl *gomock.Controller) *MockMicroVMQueryUseCases + func (m *MockMicroVMQueryUseCases) EXPECT() *MockMicroVMQueryUseCasesMockRecorder + func (m *MockMicroVMQueryUseCases) GetAllMicroVM(arg0 context.Context, arg1 models.ListMicroVMQuery) ([]*models.MicroVM, error) + func (m *MockMicroVMQueryUseCases) GetMicroVM(arg0 context.Context, arg1 string) (*models.MicroVM, error) + type MockMicroVMQueryUseCasesMockRecorder struct + func (mr *MockMicroVMQueryUseCasesMockRecorder) GetAllMicroVM(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMQueryUseCasesMockRecorder) GetMicroVM(arg0, arg1 interface{}) *gomock.Call + type MockMicroVMRepository struct + func NewMockMicroVMRepository(ctrl *gomock.Controller) *MockMicroVMRepository + func (m *MockMicroVMRepository) Delete(arg0 context.Context, arg1 *models.MicroVM) error + func (m *MockMicroVMRepository) EXPECT() *MockMicroVMRepositoryMockRecorder + func (m *MockMicroVMRepository) Exists(arg0 context.Context, arg1 models.VMID) (bool, error) + func (m *MockMicroVMRepository) Get(arg0 context.Context, arg1 ports.RepositoryGetOptions) (*models.MicroVM, error) + func (m *MockMicroVMRepository) GetAll(arg0 context.Context, arg1 models.ListMicroVMQuery) ([]*models.MicroVM, error) + func (m *MockMicroVMRepository) ReleaseLease(arg0 context.Context, arg1 *models.MicroVM) error + func (m *MockMicroVMRepository) Save(arg0 context.Context, arg1 *models.MicroVM) (*models.MicroVM, error) + type MockMicroVMRepositoryMockRecorder struct + func (mr *MockMicroVMRepositoryMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMRepositoryMockRecorder) Exists(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMRepositoryMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMRepositoryMockRecorder) GetAll(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMRepositoryMockRecorder) ReleaseLease(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMRepositoryMockRecorder) Save(arg0, arg1 interface{}) *gomock.Call + type MockMicroVMService struct + func NewMockMicroVMService(ctrl *gomock.Controller) *MockMicroVMService + func (m *MockMicroVMService) Capabilities() models.Capabilities + func (m *MockMicroVMService) Create(arg0 context.Context, arg1 *models.MicroVM) error + func (m *MockMicroVMService) Delete(arg0 context.Context, arg1 string) error + func (m *MockMicroVMService) EXPECT() *MockMicroVMServiceMockRecorder + func (m *MockMicroVMService) Metrics(arg0 context.Context, arg1 models.VMID) (ports.MachineMetrics, error) + func (m *MockMicroVMService) Start(arg0 context.Context, arg1 *models.MicroVM) error + func (m *MockMicroVMService) State(arg0 context.Context, arg1 string) (ports.MicroVMState, error) + type MockMicroVMServiceMockRecorder struct + func (mr *MockMicroVMServiceMockRecorder) Capabilities() *gomock.Call + func (mr *MockMicroVMServiceMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMServiceMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMServiceMockRecorder) Metrics(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMServiceMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call + func (mr *MockMicroVMServiceMockRecorder) State(arg0, arg1 interface{}) *gomock.Call + type MockNetworkService struct + func NewMockNetworkService(ctrl *gomock.Controller) *MockNetworkService + func (m *MockNetworkService) EXPECT() *MockNetworkServiceMockRecorder + func (m *MockNetworkService) IfaceCreate(arg0 context.Context, arg1 ports.IfaceCreateInput) (*ports.IfaceDetails, error) + func (m *MockNetworkService) IfaceDelete(arg0 context.Context, arg1 ports.DeleteIfaceInput) error + func (m *MockNetworkService) IfaceDetails(arg0 context.Context, arg1 string) (*ports.IfaceDetails, error) + func (m *MockNetworkService) IfaceExists(arg0 context.Context, arg1 string) (bool, error) + type MockNetworkServiceMockRecorder struct + func (mr *MockNetworkServiceMockRecorder) IfaceCreate(arg0, arg1 interface{}) *gomock.Call + func (mr *MockNetworkServiceMockRecorder) IfaceDelete(arg0, arg1 interface{}) *gomock.Call + func (mr *MockNetworkServiceMockRecorder) IfaceDetails(arg0, arg1 interface{}) *gomock.Call + func (mr *MockNetworkServiceMockRecorder) IfaceExists(arg0, arg1 interface{}) *gomock.Call + type MockReconcileMicroVMsUseCase struct + func NewMockReconcileMicroVMsUseCase(ctrl *gomock.Controller) *MockReconcileMicroVMsUseCase + func (m *MockReconcileMicroVMsUseCase) EXPECT() *MockReconcileMicroVMsUseCaseMockRecorder + func (m *MockReconcileMicroVMsUseCase) ReconcileMicroVM(arg0 context.Context, arg1 models.VMID) error + type MockReconcileMicroVMsUseCaseMockRecorder struct + func (mr *MockReconcileMicroVMsUseCaseMockRecorder) ReconcileMicroVM(arg0, arg1 interface{}) *gomock.Call + type MockSnapshotter struct + func NewMockSnapshotter(ctrl *gomock.Controller) *MockSnapshotter + func (m *MockSnapshotter) Close() error + func (m *MockSnapshotter) Commit(arg0 context.Context, arg1, arg2 string, arg3 ...snapshots.Opt) error + func (m *MockSnapshotter) EXPECT() *MockSnapshotterMockRecorder + func (m *MockSnapshotter) Mounts(arg0 context.Context, arg1 string) ([]mount.Mount, error) + func (m *MockSnapshotter) Prepare(arg0 context.Context, arg1, arg2 string, arg3 ...snapshots.Opt) ([]mount.Mount, error) + func (m *MockSnapshotter) Remove(arg0 context.Context, arg1 string) error + func (m *MockSnapshotter) Stat(arg0 context.Context, arg1 string) (snapshots.Info, error) + func (m *MockSnapshotter) Update(arg0 context.Context, arg1 snapshots.Info, arg2 ...string) (snapshots.Info, error) + func (m *MockSnapshotter) Usage(arg0 context.Context, arg1 string) (snapshots.Usage, error) + func (m *MockSnapshotter) View(arg0 context.Context, arg1, arg2 string, arg3 ...snapshots.Opt) ([]mount.Mount, error) + func (m *MockSnapshotter) Walk(arg0 context.Context, arg1 snapshots.WalkFunc, arg2 ...string) error + type MockSnapshotterMockRecorder struct + func (mr *MockSnapshotterMockRecorder) Close() *gomock.Call + func (mr *MockSnapshotterMockRecorder) Commit(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) Mounts(arg0, arg1 interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) Prepare(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) Remove(arg0, arg1 interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) Stat(arg0, arg1 interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) Update(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) Usage(arg0, arg1 interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) View(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call + func (mr *MockSnapshotterMockRecorder) Walk(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Go to main page