fix: return gRPC code "unavailable" if server is not initialized yet

Correct error code helps client to decide when it should retry request.

Signed-off-by: Konstantin Khlebnikov <koct9i@gmail.com>
This commit is contained in:
Konstantin Khlebnikov 2023-12-19 21:05:42 +01:00
parent 93e3a50420
commit c191935747

View File

@ -18,7 +18,6 @@ package instrument
import ( import (
"context" "context"
"errors"
"github.com/containerd/containerd/v2/errdefs" "github.com/containerd/containerd/v2/errdefs"
"github.com/containerd/containerd/v2/tracing" "github.com/containerd/containerd/v2/tracing"
@ -63,7 +62,7 @@ func (in *instrumentedService) checkInitialized() error {
if in.c.IsInitialized() { if in.c.IsInitialized() {
return nil return nil
} }
return errors.New("server is not initialized yet") return errdefs.ToGRPCf(errdefs.ErrUnavailable, "server is not initialized yet")
} }
func (in *instrumentedService) RunPodSandbox(ctx context.Context, r *runtime.RunPodSandboxRequest) (res *runtime.RunPodSandboxResponse, err error) { func (in *instrumentedService) RunPodSandbox(ctx context.Context, r *runtime.RunPodSandboxRequest) (res *runtime.RunPodSandboxResponse, err error) {