feat: support plugin apply skip no change

Signed-off-by: zwtop <wang.zhan@smartx.com>

Author: zwtop

Makefile

@@ -1,7 +1,7 @@
 .PHONY: test docker-test
 
 test:
-	go test ./... --race --coverprofile coverage.out
+	go test --gcflags=all=-l ./... --race --coverprofile coverage.out
 
 docker-test:
 	$(eval WORKDIR := /go/src/github.com/everoute/container)

client/clienttest/runtime.go

@@ -118,12 +118,12 @@ func (r *runtime) ListContainers(ctx context.Context) ([]*model.Container, error
 	return containers, nil
 }
 
-func (r *runtime) GetContainerStatus(ctx context.Context, containerID string) (containerd.Status, error) {
+func (r *runtime) GetContainerStatus(ctx context.Context, containerID string) (client.ContainerStatus, error) {
 	_, ok := r.containers[containerID]
 	if !ok {
-		return containerd.Status{}, fmt.Errorf("container %s not found", containerID)
+		return client.ContainerStatus{}, fmt.Errorf("container %s not found", containerID)
 	}
-	return containerd.Status{Status: containerd.Running}, nil
+	return client.ContainerStatus{Status: containerd.Status{Status: containerd.Running}}, nil
 }
 
 func (r *runtime) ExecCommand(ctx context.Context, containerID string, commands []string) (*containerd.ExitStatus, error) {

client/interface.go

@@ -21,6 +21,7 @@ import (
 	"io"
 
 	"github.com/containerd/containerd"
+	"github.com/containerd/containerd/containers"
 	"github.com/containerd/containerd/images"
 	"github.com/containerd/containerd/platforms"
 
@@ -69,6 +70,11 @@ type ImageManager interface {
 	GetImage(ctx context.Context, ref string) (*images.Image, bool, error)
 }
 
+type ContainerStatus struct {
+	containerd.Status
+	containers.Container
+}
+
 // ContainerManager contains methods to manipulate containers managed by a
 // container runtime. The methods are thread-safe.
 type ContainerManager interface {
@@ -85,7 +91,7 @@ type ContainerManager interface {
 	ListContainers(ctx context.Context) ([]*model.Container, error)
 
 	// GetContainerStatus return the container status
-	GetContainerStatus(ctx context.Context, containerID string) (containerd.Status, error)
+	GetContainerStatus(ctx context.Context, containerID string) (ContainerStatus, error)
 
 	// ExecCommand exec giving commands and return result
 	ExecCommand(ctx context.Context, containerID string, commands []string) (*containerd.ExitStatus, error)

client/runtime.go

@@ -334,20 +334,28 @@ func (r *runtime) RemoveNamespace(ctx context.Context) error {
 	return ignoreNotFoundError(err)
 }
 
-func (r *runtime) GetContainerStatus(ctx context.Context, containerID string) (containerd.Status, error) {
+func (r *runtime) GetContainerStatus(ctx context.Context, containerID string) (ContainerStatus, error) {
 	ctx = namespaces.WithNamespace(ctx, r.namespace)
 
 	c, err := r.client.LoadContainer(ctx, containerID)
 	if err != nil {
-		return containerd.Status{}, fmt.Errorf("load container: %w", err)
+		return ContainerStatus{}, fmt.Errorf("load container: %w", err)
 	}
 
 	task, err := c.Task(ctx, nil)
 	if err != nil {
-		return containerd.Status{}, fmt.Errorf("load task: %w", err)
+		return ContainerStatus{}, fmt.Errorf("load task: %w", err)
 	}
 
-	return task.Status(ctx)
+	status, err := task.Status(ctx)
+	if err != nil {
+		return ContainerStatus{}, fmt.Errorf("get task status: %w", err)
+	}
+
+	return ContainerStatus{
+		Status:    status,
+		Container: lo.Must(c.Info(ctx, containerd.WithoutRefreshedMetadata)),
+	}, nil
 }
 
 func (r *runtime) ExecCommand(ctx context.Context, containerID string, commands []string) (*containerd.ExitStatus, error) {

go.mod

@@ -21,6 +21,7 @@ require (
 	github.com/samber/lo v1.39.0
 	go.uber.org/goleak v1.1.12
 	google.golang.org/grpc v1.50.1
+	gopkg.in/yaml.v3 v3.0.1
 	k8s.io/apimachinery v0.22.5
 	k8s.io/klog/v2 v2.30.0
 )

go.sum

@@ -1081,6 +1081,7 @@ gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C
 gopkg.in/yaml.v3 v3.0.0-20200615113413-eeeca48fe776/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gotest.tools v2.2.0+incompatible h1:VsBPFP1AI068pPrMxtb/S8Zkgf9xEmTLJjfM+P5UIEo=
 gotest.tools v2.2.0+incompatible/go.mod h1:DsYFclhRJ6vuDpmuTbkuFWG+y2sxOXAzmJt81HFBacw=
 gotest.tools/v3 v3.0.2/go.mod h1:3SzNCllyD9/Y+b5r9JIKQ474KzkZyqLqEfYqMsX94Bk=

plugin/context.go

@@ -0,0 +1,43 @@
+/*
+Copyright 2025 The Everoute 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 plugin
+
+import (
+	"context"
+
+	"github.com/samber/lo"
+)
+
+type ContextKey string
+
+const (
+	ContextSkipNoChange ContextKey = "skip-no-change"
+)
+
+func SetSkipNoChange(ctx context.Context, skip bool) context.Context {
+	return context.WithValue(ctx, ContextSkipNoChange, skip)
+}
+
+func GetSkipNoChange(ctx context.Context) bool {
+	v := ctx.Value(ContextSkipNoChange)
+	skip, ok := v.(bool)
+	return lo.If(ok, skip).Else(false)
+}
+
+func WithSkipNoChange(ctx context.Context) context.Context {
+	return SetSkipNoChange(ctx, true)
+}

plugin/context_test.go

@@ -0,0 +1,37 @@
+/*
+Copyright 2025 The Everoute 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 plugin_test
+
+import (
+	"context"
+	"testing"
+
+	. "github.com/onsi/gomega"
+
+	"github.com/everoute/container/plugin"
+)
+
+func TestContextSkipNoChange(t *testing.T) {
+	RegisterTestingT(t)
+
+	ctx := context.Background()
+	Expect(plugin.GetSkipNoChange(ctx)).Should(BeFalse())
+	ctx = plugin.WithSkipNoChange(ctx)
+	Expect(plugin.GetSkipNoChange(ctx)).Should(BeTrue())
+	ctx = plugin.SetSkipNoChange(ctx, false)
+	Expect(plugin.GetSkipNoChange(ctx)).Should(BeFalse())
+}