mirror of https://github.com/k3s-io/k3s
480 lines
17 KiB
Go
480 lines
17 KiB
Go
|
/*
|
||
|
|
Copyright 2017 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 server
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
|
||
|
|
"github.com/sirupsen/logrus"
|
||
|
|
"golang.org/x/net/context"
|
||
|
|
runtime "k8s.io/kubernetes/pkg/kubelet/apis/cri/runtime/v1alpha2"
|
||
|
|
|
||
|
|
api "github.com/containerd/cri/pkg/api/v1"
|
||
|
|
ctrdutil "github.com/containerd/cri/pkg/containerd/util"
|
||
|
|
"github.com/containerd/cri/pkg/log"
|
||
|
|
)
|
||
|
|
|
||
|
|
// instrumentedService wraps service with containerd namespace and logs.
|
||
|
|
type instrumentedService struct {
|
||
|
|
c *criService
|
||
|
|
}
|
||
|
|
|
||
|
|
func newInstrumentedService(c *criService) grpcServices {
|
||
|
|
return &instrumentedService{c: c}
|
||
|
|
}
|
||
|
|
|
||
|
|
// checkInitialized returns error if the server is not fully initialized.
|
||
|
|
// GRPC service request handlers should return error before server is fully
|
||
|
|
// initialized.
|
||
|
|
// NOTE(random-liu): All following functions MUST check initialized at the beginning.
|
||
|
|
func (in *instrumentedService) checkInitialized() error {
|
||
|
|
if in.c.initialized.IsSet() {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
return errors.New("server is not initialized yet")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) RunPodSandbox(ctx context.Context, r *runtime.RunPodSandboxRequest) (res *runtime.RunPodSandboxResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("RunPodSandbox with config %+v", r.GetConfig())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("RunPodSandbox for %+v failed, error", r.GetConfig().GetMetadata())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("RunPodSandbox for %+v returns sandbox id %q", r.GetConfig().GetMetadata(), res.GetPodSandboxId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.RunPodSandbox(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ListPodSandbox(ctx context.Context, r *runtime.ListPodSandboxRequest) (res *runtime.ListPodSandboxResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("ListPodSandbox with filter %+v", r.GetFilter())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Error("ListPodSandbox failed")
|
||
|
|
} else {
|
||
|
|
log.Tracef("ListPodSandbox returns pod sandboxes %+v", res.GetItems())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ListPodSandbox(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) PodSandboxStatus(ctx context.Context, r *runtime.PodSandboxStatusRequest) (res *runtime.PodSandboxStatusResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("PodSandboxStatus for %q", r.GetPodSandboxId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("PodSandboxStatus for %q failed", r.GetPodSandboxId())
|
||
|
|
} else {
|
||
|
|
log.Tracef("PodSandboxStatus for %q returns status %+v", r.GetPodSandboxId(), res.GetStatus())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.PodSandboxStatus(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) StopPodSandbox(ctx context.Context, r *runtime.StopPodSandboxRequest) (_ *runtime.StopPodSandboxResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("StopPodSandbox for %q", r.GetPodSandboxId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("StopPodSandbox for %q failed", r.GetPodSandboxId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("StopPodSandbox for %q returns successfully", r.GetPodSandboxId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.StopPodSandbox(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) RemovePodSandbox(ctx context.Context, r *runtime.RemovePodSandboxRequest) (_ *runtime.RemovePodSandboxResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("RemovePodSandbox for %q", r.GetPodSandboxId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("RemovePodSandbox for %q failed", r.GetPodSandboxId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("RemovePodSandbox %q returns successfully", r.GetPodSandboxId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.RemovePodSandbox(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) PortForward(ctx context.Context, r *runtime.PortForwardRequest) (res *runtime.PortForwardResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("Portforward for %q port %v", r.GetPodSandboxId(), r.GetPort())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("Portforward for %q failed", r.GetPodSandboxId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("Portforward for %q returns URL %q", r.GetPodSandboxId(), res.GetUrl())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.PortForward(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) CreateContainer(ctx context.Context, r *runtime.CreateContainerRequest) (res *runtime.CreateContainerResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("CreateContainer within sandbox %q with container config %+v and sandbox config %+v",
|
||
|
|
r.GetPodSandboxId(), r.GetConfig(), r.GetSandboxConfig())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("CreateContainer within sandbox %q for %+v failed",
|
||
|
|
r.GetPodSandboxId(), r.GetConfig().GetMetadata())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("CreateContainer within sandbox %q for %+v returns container id %q",
|
||
|
|
r.GetPodSandboxId(), r.GetConfig().GetMetadata(), res.GetContainerId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.CreateContainer(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) StartContainer(ctx context.Context, r *runtime.StartContainerRequest) (_ *runtime.StartContainerResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("StartContainer for %q", r.GetContainerId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("StartContainer for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("StartContainer for %q returns successfully", r.GetContainerId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.StartContainer(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ListContainers(ctx context.Context, r *runtime.ListContainersRequest) (res *runtime.ListContainersResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("ListContainers with filter %+v", r.GetFilter())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("ListContainers with filter %+v failed", r.GetFilter())
|
||
|
|
} else {
|
||
|
|
log.Tracef("ListContainers with filter %+v returns containers %+v",
|
||
|
|
r.GetFilter(), res.GetContainers())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ListContainers(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ContainerStatus(ctx context.Context, r *runtime.ContainerStatusRequest) (res *runtime.ContainerStatusResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("ContainerStatus for %q", r.GetContainerId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("ContainerStatus for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
log.Tracef("ContainerStatus for %q returns status %+v", r.GetContainerId(), res.GetStatus())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ContainerStatus(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) StopContainer(ctx context.Context, r *runtime.StopContainerRequest) (res *runtime.StopContainerResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("StopContainer for %q with timeout %d (s)", r.GetContainerId(), r.GetTimeout())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("StopContainer for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("StopContainer for %q returns successfully", r.GetContainerId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.StopContainer(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) RemoveContainer(ctx context.Context, r *runtime.RemoveContainerRequest) (res *runtime.RemoveContainerResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("RemoveContainer for %q", r.GetContainerId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("RemoveContainer for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("RemoveContainer for %q returns successfully", r.GetContainerId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.RemoveContainer(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ExecSync(ctx context.Context, r *runtime.ExecSyncRequest) (res *runtime.ExecSyncResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("ExecSync for %q with command %+v and timeout %d (s)", r.GetContainerId(), r.GetCmd(), r.GetTimeout())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("ExecSync for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("ExecSync for %q returns with exit code %d", r.GetContainerId(), res.GetExitCode())
|
||
|
|
logrus.Debugf("ExecSync for %q outputs - stdout: %q, stderr: %q", r.GetContainerId(),
|
||
|
|
res.GetStdout(), res.GetStderr())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ExecSync(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) Exec(ctx context.Context, r *runtime.ExecRequest) (res *runtime.ExecResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("Exec for %q with command %+v, tty %v and stdin %v",
|
||
|
|
r.GetContainerId(), r.GetCmd(), r.GetTty(), r.GetStdin())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("Exec for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("Exec for %q returns URL %q", r.GetContainerId(), res.GetUrl())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.Exec(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) Attach(ctx context.Context, r *runtime.AttachRequest) (res *runtime.AttachResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("Attach for %q with tty %v and stdin %v", r.GetContainerId(), r.GetTty(), r.GetStdin())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("Attach for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("Attach for %q returns URL %q", r.GetContainerId(), res.Url)
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.Attach(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) UpdateContainerResources(ctx context.Context, r *runtime.UpdateContainerResourcesRequest) (res *runtime.UpdateContainerResourcesResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("UpdateContainerResources for %q with %+v", r.GetContainerId(), r.GetLinux())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("UpdateContainerResources for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("UpdateContainerResources for %q returns successfully", r.GetContainerId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.UpdateContainerResources(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) PullImage(ctx context.Context, r *runtime.PullImageRequest) (res *runtime.PullImageResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("PullImage %q", r.GetImage().GetImage())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("PullImage %q failed", r.GetImage().GetImage())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("PullImage %q returns image reference %q",
|
||
|
|
r.GetImage().GetImage(), res.GetImageRef())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.PullImage(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ListImages(ctx context.Context, r *runtime.ListImagesRequest) (res *runtime.ListImagesResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("ListImages with filter %+v", r.GetFilter())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("ListImages with filter %+v failed", r.GetFilter())
|
||
|
|
} else {
|
||
|
|
log.Tracef("ListImages with filter %+v returns image list %+v",
|
||
|
|
r.GetFilter(), res.GetImages())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ListImages(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ImageStatus(ctx context.Context, r *runtime.ImageStatusRequest) (res *runtime.ImageStatusResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("ImageStatus for %q", r.GetImage().GetImage())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("ImageStatus for %q failed", r.GetImage().GetImage())
|
||
|
|
} else {
|
||
|
|
log.Tracef("ImageStatus for %q returns image status %+v",
|
||
|
|
r.GetImage().GetImage(), res.GetImage())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ImageStatus(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) RemoveImage(ctx context.Context, r *runtime.RemoveImageRequest) (_ *runtime.RemoveImageResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Infof("RemoveImage %q", r.GetImage().GetImage())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("RemoveImage %q failed", r.GetImage().GetImage())
|
||
|
|
} else {
|
||
|
|
logrus.Infof("RemoveImage %q returns successfully", r.GetImage().GetImage())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.RemoveImage(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ImageFsInfo(ctx context.Context, r *runtime.ImageFsInfoRequest) (res *runtime.ImageFsInfoResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Debugf("ImageFsInfo")
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Error("ImageFsInfo failed")
|
||
|
|
} else {
|
||
|
|
logrus.Debugf("ImageFsInfo returns filesystem info %+v", res.ImageFilesystems)
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ImageFsInfo(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ContainerStats(ctx context.Context, r *runtime.ContainerStatsRequest) (res *runtime.ContainerStatsResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Debugf("ContainerStats for %q", r.GetContainerId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("ContainerStats for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Debugf("ContainerStats for %q returns stats %+v", r.GetContainerId(), res.GetStats())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ContainerStats(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ListContainerStats(ctx context.Context, r *runtime.ListContainerStatsRequest) (res *runtime.ListContainerStatsResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("ListContainerStats with filter %+v", r.GetFilter())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Error("ListContainerStats failed")
|
||
|
|
} else {
|
||
|
|
log.Tracef("ListContainerStats returns stats %+v", res.GetStats())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ListContainerStats(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) Status(ctx context.Context, r *runtime.StatusRequest) (res *runtime.StatusResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("Status")
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Error("Status failed")
|
||
|
|
} else {
|
||
|
|
log.Tracef("Status returns status %+v", res.GetStatus())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.Status(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) Version(ctx context.Context, r *runtime.VersionRequest) (res *runtime.VersionResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
log.Tracef("Version with client side version %q", r.GetVersion())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Error("Version failed")
|
||
|
|
} else {
|
||
|
|
log.Tracef("Version returns %+v", res)
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.Version(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) UpdateRuntimeConfig(ctx context.Context, r *runtime.UpdateRuntimeConfigRequest) (res *runtime.UpdateRuntimeConfigResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Debugf("UpdateRuntimeConfig with config %+v", r.GetRuntimeConfig())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Error("UpdateRuntimeConfig failed")
|
||
|
|
} else {
|
||
|
|
logrus.Debug("UpdateRuntimeConfig returns returns successfully")
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.UpdateRuntimeConfig(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) LoadImage(ctx context.Context, r *api.LoadImageRequest) (res *api.LoadImageResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Debugf("LoadImage from file %q", r.GetFilePath())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Error("LoadImage failed")
|
||
|
|
} else {
|
||
|
|
logrus.Debugf("LoadImage returns images %+v", res.GetImages())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.LoadImage(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|
||
|
|
|
||
|
|
func (in *instrumentedService) ReopenContainerLog(ctx context.Context, r *runtime.ReopenContainerLogRequest) (res *runtime.ReopenContainerLogResponse, err error) {
|
||
|
|
if err := in.checkInitialized(); err != nil {
|
||
|
|
return nil, err
|
||
|
|
}
|
||
|
|
logrus.Debugf("ReopenContainerLog for %q", r.GetContainerId())
|
||
|
|
defer func() {
|
||
|
|
if err != nil {
|
||
|
|
logrus.WithError(err).Errorf("ReopenContainerLog for %q failed", r.GetContainerId())
|
||
|
|
} else {
|
||
|
|
logrus.Debugf("ReopenContainerLog for %q returns successfully", r.GetContainerId())
|
||
|
|
}
|
||
|
|
}()
|
||
|
|
return in.c.ReopenContainerLog(ctrdutil.WithNamespace(ctx), r)
|
||
|
|
}
|