@@ -45,7 +45,6 @@ import (
45
45
46
46
v1 "k8s.io/api/core/v1"
47
47
runtimeapi "k8s.io/cri-api/pkg/apis/runtime/v1"
48
- runtimeapi_alpha "k8s.io/cri-api/v1alpha2/pkg/apis/runtime/v1alpha2"
49
48
)
50
49
51
50
const (
@@ -74,12 +73,6 @@ const (
74
73
defaultCgroupDriver = "cgroupfs"
75
74
)
76
75
77
- // v1AlphaCRIService provides the interface necessary for cri.v1alpha2
78
- type v1AlphaCRIService interface {
79
- runtimeapi_alpha.RuntimeServiceServer
80
- runtimeapi_alpha.ImageServiceServer
81
- }
82
-
83
76
// CRIService includes all methods necessary for a CRI backend.
84
77
type CRIService interface {
85
78
runtimeapi.RuntimeServiceServer
@@ -288,17 +281,6 @@ type dockerService struct {
288
281
cleanupInfosLock sync.RWMutex
289
282
}
290
283
291
- type dockerServiceAlpha struct {
292
- ds DockerService
293
-
294
- // This handles unimplemented methods unless cri-dockerd overrides them
295
- runtimeapi_alpha.UnimplementedRuntimeServiceServer
296
- }
297
-
298
- func NewDockerServiceAlpha (ds DockerService ) v1AlphaCRIService {
299
- return & dockerServiceAlpha {ds : ds }
300
- }
301
-
302
284
// Version returns the runtime name, runtime version and runtime API version
303
285
func (ds * dockerService ) Version (
304
286
_ context.Context ,
@@ -316,22 +298,6 @@ func (ds *dockerService) Version(
316
298
}, nil
317
299
}
318
300
319
- func (ds * dockerService ) AlphaVersion (
320
- _ context.Context ,
321
- r * runtimeapi.VersionRequest ,
322
- ) (* runtimeapi_alpha.VersionResponse , error ) {
323
- v , err := ds .getDockerVersion ()
324
- if err != nil {
325
- return nil , err
326
- }
327
- return & runtimeapi_alpha.VersionResponse {
328
- Version : kubeAPIVersion ,
329
- RuntimeName : dockerRuntimeName ,
330
- RuntimeVersion : v .Version ,
331
- RuntimeApiVersion : config .CRIVersionAlpha ,
332
- }, nil
333
- }
334
-
335
301
// getDockerVersion gets the version information from docker.
336
302
func (ds * dockerService ) getDockerVersion () (* dockertypes.Version , error ) {
337
303
res , err := ds .systemInfoCache .Memoize ("docker_version" , systemInfoCacheMinTTL , func () (interface {}, error ) {
0 commit comments