diff --git a/pkg/kubelet/container/kuberuntime.go b/pkg/kubelet/api/services.go similarity index 99% rename from pkg/kubelet/container/kuberuntime.go rename to pkg/kubelet/api/services.go index 1e031681718..715c53e4f4a 100644 --- a/pkg/kubelet/container/kuberuntime.go +++ b/pkg/kubelet/api/services.go @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and limitations under the License. */ -package container +package api import ( "io" diff --git a/pkg/kubelet/api/testing/fake_image_service.go b/pkg/kubelet/api/testing/fake_image_service.go new file mode 100644 index 00000000000..d5a138f7295 --- /dev/null +++ b/pkg/kubelet/api/testing/fake_image_service.go @@ -0,0 +1,47 @@ +/* +Copyright 2016 The Kubernetes Authors. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package testing + +import ( + "fmt" + + internalApi "k8s.io/kubernetes/pkg/kubelet/api" + runtimeApi "k8s.io/kubernetes/pkg/kubelet/api/v1alpha1/runtime" +) + +type fakeImageService struct { +} + +func NewFakeImageService() internalApi.ImageManagerService { + return &fakeImageService{} +} + +func (r *fakeImageService) ListImages(filter *runtimeApi.ImageFilter) ([]*runtimeApi.Image, error) { + return nil, fmt.Errorf("not implemented") +} + +func (r *fakeImageService) ImageStatus(image *runtimeApi.ImageSpec) (*runtimeApi.Image, error) { + return nil, fmt.Errorf("not implemented") +} + +func (r *fakeImageService) PullImage(image *runtimeApi.ImageSpec, auth *runtimeApi.AuthConfig) error { + return fmt.Errorf("not implemented") +} + +func (r *fakeImageService) RemoveImage(image *runtimeApi.ImageSpec) error { + return fmt.Errorf("not implemented") +} diff --git a/pkg/kubelet/api/testing/fake_runtime_service.go b/pkg/kubelet/api/testing/fake_runtime_service.go new file mode 100644 index 00000000000..7d76468e6d5 --- /dev/null +++ b/pkg/kubelet/api/testing/fake_runtime_service.go @@ -0,0 +1,84 @@ +/* +Copyright 2016 The Kubernetes Authors. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package testing + +import ( + "fmt" + "io" + + internalApi "k8s.io/kubernetes/pkg/kubelet/api" + runtimeApi "k8s.io/kubernetes/pkg/kubelet/api/v1alpha1/runtime" +) + +type fakeRuntimeService struct { +} + +func NewFakeRuntimeService() internalApi.RuntimeService { + return &fakeRuntimeService{} +} + +func (r *fakeRuntimeService) Version(apiVersion string) (*runtimeApi.VersionResponse, error) { + return nil, fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) CreatePodSandbox(config *runtimeApi.PodSandboxConfig) (string, error) { + return "", fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) StopPodSandbox(podSandboxID string) error { + return fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) DeletePodSandbox(podSandboxID string) error { + return fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) PodSandboxStatus(podSandboxID string) (*runtimeApi.PodSandboxStatus, error) { + return nil, fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) ListPodSandbox(filter *runtimeApi.PodSandboxFilter) ([]*runtimeApi.PodSandbox, error) { + return nil, fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) CreateContainer(podSandboxID string, config *runtimeApi.ContainerConfig, sandboxConfig *runtimeApi.PodSandboxConfig) (string, error) { + return "", fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) StartContainer(rawContainerID string) error { + return fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) StopContainer(rawContainerID string, timeout int64) error { + return fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) RemoveContainer(rawContainerID string) error { + return fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) ListContainers(filter *runtimeApi.ContainerFilter) ([]*runtimeApi.Container, error) { + return nil, fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) ContainerStatus(rawContainerID string) (*runtimeApi.ContainerStatus, error) { + return nil, fmt.Errorf("not implemented") +} + +func (r *fakeRuntimeService) Exec(rawContainerID string, cmd []string, tty bool, stdin io.Reader, stdout, stderr io.WriteCloser) error { + return fmt.Errorf("not implemented") +} diff --git a/pkg/kubelet/dockershim/docker_service.go b/pkg/kubelet/dockershim/docker_service.go index 2371560654b..e499158eacd 100644 --- a/pkg/kubelet/dockershim/docker_service.go +++ b/pkg/kubelet/dockershim/docker_service.go @@ -21,6 +21,7 @@ import ( "io" "k8s.io/kubernetes/pkg/api" + internalApi "k8s.io/kubernetes/pkg/kubelet/api" runtimeApi "k8s.io/kubernetes/pkg/kubelet/api/v1alpha1/runtime" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" "k8s.io/kubernetes/pkg/kubelet/dockertools" @@ -48,8 +49,8 @@ func NewDockerSevice(client dockertools.DockerInterface) DockerLegacyService { // RuntimeService and ImageService interfaces, while including legacy methods // for backward compatibility. type DockerLegacyService interface { - kubecontainer.RuntimeService - kubecontainer.ImageManagerService + internalApi.RuntimeService + internalApi.ImageManagerService // Supporting legacy methods for docker. GetContainerLogs(pod *api.Pod, containerID kubecontainer.ContainerID, logOptions *api.PodLogOptions, stdout, stderr io.Writer) (err error)