github/containerd
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Set grpc code for unimplemented cri-api methods

Browse Source 
Signed-off-by: ruiwen-zhao <ruiwen@google.com>
This commit is contained in:
ruiwen-zhao 2022-09-22 05:37:30 +00:00
parent 1ff8df57a5
commit c6f571fc7d
4 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/cri/sbserver/container_checkpoint.go
View File

@ -18,11 +18,12 @@ package sbserver
import (
"context"
"errors"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
runtime "k8s.io/cri-api/pkg/apis/runtime/v1"
)
func (c *criService) CheckpointContainer(ctx context.Context, r *runtime.CheckpointContainerRequest) (res *runtime.CheckpointContainerResponse, err error) {
return nil, errors.New("not implemented")
return nil, status.Errorf(codes.Unimplemented, "method CheckpointContainer not implemented")
}

6
pkg/cri/sbserver/container_events.go
View File

@ -17,11 +17,11 @@
package sbserver
import (
"errors"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
runtime "k8s.io/cri-api/pkg/apis/runtime/v1"
)
func (c *criService) GetContainerEvents(r *runtime.GetEventsRequest, s runtime.RuntimeService_GetContainerEventsServer) error {
return errors.New("not implemented")
return status.Errorf(codes.Unimplemented, "method GetContainerEvents not implemented")
}

5
pkg/cri/server/container_checkpoint.go
View File

@ -18,11 +18,12 @@ package server
import (
"context"
"errors"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
runtime "k8s.io/cri-api/pkg/apis/runtime/v1"
)
func (c *criService) CheckpointContainer(ctx context.Context, r *runtime.CheckpointContainerRequest) (res *runtime.CheckpointContainerResponse, err error) {
return nil, errors.New("not implemented")
return nil, status.Errorf(codes.Unimplemented, "method CheckpointContainer not implemented")
}

6
pkg/cri/server/container_events.go
View File

@ -17,11 +17,11 @@
package server
import (
"errors"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
runtime "k8s.io/cri-api/pkg/apis/runtime/v1"
)
func (c *criService) GetContainerEvents(r *runtime.GetEventsRequest, s runtime.RuntimeService_GetContainerEventsServer) error {
return errors.New("not implemented")
return status.Errorf(codes.Unimplemented, "method GetContainerEvents not implemented")
}