add payload for manifestwork

Signed-off-by: Wei Liu <liuweixa@redhat.com>
open-cluster-management-io · Aug 29, 2023 · 7351025 · 7351025
1 parent e598981
commit 7351025
Show file tree

Hide file tree

Showing 31 changed files with 1,631 additions and 69 deletions.
diff --git a/client/cloudevents/agentclient.go → cloudevents/generic/agentclient.go b/client/cloudevents/agentclient.go → cloudevents/generic/agentclient.go
@@ -1,4 +1,4 @@
-package cloudevents
+package generic
 
 import (
 	"context"
@@ -9,9 +9,9 @@ import (
 
 	"k8s.io/klog/v2"
 
-	"open-cluster-management.io/api/client/cloudevents/options"
-	"open-cluster-management.io/api/client/cloudevents/payload"
-	"open-cluster-management.io/api/client/cloudevents/types"
+	"open-cluster-management.io/api/cloudevents/generic/options"
+	"open-cluster-management.io/api/cloudevents/generic/payload"
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 // CloudEventAgentClient is a client for an agent to resync/send/receive its resources with cloud events.

diff --git a/client/cloudevents/agentclient_test.go → cloudevents/generic/agentclient_test.go b/client/cloudevents/agentclient_test.go → cloudevents/generic/agentclient_test.go
@@ -1,4 +1,4 @@
-package cloudevents
+package generic
 
 import (
 	"context"
@@ -10,11 +10,11 @@ import (
 	"github.com/google/uuid"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	apitypes "k8s.io/apimachinery/pkg/types"
+	kubetypes "k8s.io/apimachinery/pkg/types"
 
-	"open-cluster-management.io/api/client/cloudevents/options/fake"
-	"open-cluster-management.io/api/client/cloudevents/payload"
-	"open-cluster-management.io/api/client/cloudevents/types"
+	"open-cluster-management.io/api/cloudevents/generic/options/fake"
+	"open-cluster-management.io/api/cloudevents/generic/payload"
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 const testAgentName = "mock-agent"
@@ -44,8 +44,8 @@ func TestAgentResync(t *testing.T) {
 			name:        "has cached resources",
 			clusterName: "cluster2",
 			resources: []*mockResource{
-				{UID: apitypes.UID("test1"), ResourceVersion: "2"},
-				{UID: apitypes.UID("test2"), ResourceVersion: "3"},
+				{UID: kubetypes.UID("test1"), ResourceVersion: "2"},
+				{UID: kubetypes.UID("test2"), ResourceVersion: "3"},
 			},
 			eventType:     types.CloudEventsType{SubResource: types.SubResourceSpec},
 			expectedItems: 2,
@@ -99,7 +99,7 @@ func TestAgentPublish(t *testing.T) {
 			name:        "publish status",
 			clusterName: "cluster1",
 			resources: &mockResource{
-				UID:             apitypes.UID("1234"),
+				UID:             kubetypes.UID("1234"),
 				ResourceVersion: "2",
 				Status:          "test-status",
 				Namespace:       "cluster1",
@@ -132,7 +132,7 @@ func TestAgentPublish(t *testing.T) {
 				t.Errorf("unexpected error %v", err)
 			}
 
-			if c.resources.UID != apitypes.UID(fmt.Sprintf("%s", resourceID)) {
+			if c.resources.UID != kubetypes.UID(fmt.Sprintf("%s", resourceID)) {
 				t.Errorf("expected %s, but got %v", c.resources.UID, evt.Context)
 			}
 
@@ -217,8 +217,8 @@ func TestStatusResyncResponse(t *testing.T) {
 				return evt
 			}(),
 			resources: []*mockResource{
-				{UID: apitypes.UID("test1"), ResourceVersion: "2", Status: "test1"},
-				{UID: apitypes.UID("test2"), ResourceVersion: "3", Status: "test2"},
+				{UID: kubetypes.UID("test1"), ResourceVersion: "2", Status: "test1"},
+				{UID: kubetypes.UID("test2"), ResourceVersion: "3", Status: "test2"},
 			},
 			validate: func(pubEvents []cloudevents.Event) {
 				if len(pubEvents) != 2 {
@@ -251,9 +251,9 @@ func TestStatusResyncResponse(t *testing.T) {
 				return evt
 			}(),
 			resources: []*mockResource{
-				{UID: apitypes.UID("test0"), ResourceVersion: "2", Status: "test0"},
-				{UID: apitypes.UID("test1"), ResourceVersion: "2", Status: "test1"},
-				{UID: apitypes.UID("test2"), ResourceVersion: "3", Status: "test2-updated"},
+				{UID: kubetypes.UID("test0"), ResourceVersion: "2", Status: "test0"},
+				{UID: kubetypes.UID("test1"), ResourceVersion: "2", Status: "test1"},
+				{UID: kubetypes.UID("test2"), ResourceVersion: "3", Status: "test2-updated"},
 			},
 			validate: func(pubEvents []cloudevents.Event) {
 				if len(pubEvents) != 1 {
@@ -339,7 +339,7 @@ func TestReceiveResourceSpec(t *testing.T) {
 					Action:              "test_create_request",
 				}
 
-				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: apitypes.UID("test1"), ResourceVersion: "1"})
+				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: kubetypes.UID("test1"), ResourceVersion: "1"})
 				return *evt
 			}(),
 			validate: func(event types.ResourceAction, resource *mockResource) {
@@ -358,12 +358,12 @@ func TestReceiveResourceSpec(t *testing.T) {
 					Action:              "test_update_request",
 				}
 
-				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: apitypes.UID("test1"), ResourceVersion: "2"})
+				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: kubetypes.UID("test1"), ResourceVersion: "2"})
 				return *evt
 			}(),
 			resources: []*mockResource{
-				{UID: apitypes.UID("test1"), ResourceVersion: "1"},
-				{UID: apitypes.UID("test2"), ResourceVersion: "1"},
+				{UID: kubetypes.UID("test1"), ResourceVersion: "1"},
+				{UID: kubetypes.UID("test2"), ResourceVersion: "1"},
 			},
 			validate: func(event types.ResourceAction, resource *mockResource) {
 				if event != types.Modified {
@@ -387,12 +387,12 @@ func TestReceiveResourceSpec(t *testing.T) {
 					Action:              "test_delete_request",
 				}
 				now := metav1.Now()
-				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: apitypes.UID("test2"), ResourceVersion: "2", DeletionTimestamp: &now})
+				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: kubetypes.UID("test2"), ResourceVersion: "2", DeletionTimestamp: &now})
 				return *evt
 			}(),
 			resources: []*mockResource{
-				{UID: apitypes.UID("test1"), ResourceVersion: "1"},
-				{UID: apitypes.UID("test2"), ResourceVersion: "1"},
+				{UID: kubetypes.UID("test1"), ResourceVersion: "1"},
+				{UID: kubetypes.UID("test2"), ResourceVersion: "1"},
 			},
 			validate: func(event types.ResourceAction, resource *mockResource) {
 				if event != types.Deleted {
@@ -413,12 +413,12 @@ func TestReceiveResourceSpec(t *testing.T) {
 					Action:              "test_create_request",
 				}
 
-				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: apitypes.UID("test1"), ResourceVersion: "2"})
+				evt, _ := newMockResourceCodec().Encode(testAgentName, eventType, &mockResource{UID: kubetypes.UID("test1"), ResourceVersion: "2"})
 				return *evt
 			}(),
 			resources: []*mockResource{
-				{UID: apitypes.UID("test1"), ResourceVersion: "2"},
-				{UID: apitypes.UID("test2"), ResourceVersion: "1"},
+				{UID: kubetypes.UID("test1"), ResourceVersion: "2"},
+				{UID: kubetypes.UID("test2"), ResourceVersion: "1"},
 			},
 			validate: func(event types.ResourceAction, resource *mockResource) {
 				if len(event) != 0 {
@@ -454,15 +454,15 @@ func TestReceiveResourceSpec(t *testing.T) {
 }
 
 type mockResource struct {
-	UID               apitypes.UID `json:"uid"`
-	ResourceVersion   string       `json:"resourceVersion"`
-	DeletionTimestamp *metav1.Time `json:"deletionTimestamp,omitempty"`
+	UID               kubetypes.UID `json:"uid"`
+	ResourceVersion   string        `json:"resourceVersion"`
+	DeletionTimestamp *metav1.Time  `json:"deletionTimestamp,omitempty"`
 	Namespace         string
 	Spec              string `json:"spec"`
 	Status            string `json:"status"`
 }
 
-func (r *mockResource) GetUID() apitypes.UID {
+func (r *mockResource) GetUID() kubetypes.UID {
 	return r.UID
 }
 
@@ -532,7 +532,7 @@ func (c *mockResourceCodec) Decode(evt *cloudevents.Event) (*mockResource, error
 	}
 
 	res := &mockResource{
-		UID:             apitypes.UID(fmt.Sprintf("%s", resourceID)),
+		UID:             kubetypes.UID(fmt.Sprintf("%s", resourceID)),
 		ResourceVersion: fmt.Sprintf("%s", resourceVersion),
 		Status:          string(evt.Data()),
 	}

diff --git a/client/cloudevents/interface.go → cloudevents/generic/interface.go b/client/cloudevents/interface.go → cloudevents/generic/interface.go
@@ -1,14 +1,14 @@
-package cloudevents
+package generic
 
 import (
 	"context"
 
 	cloudevents "github.com/cloudevents/sdk-go/v2"
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	apitypes "k8s.io/apimachinery/pkg/types"
+	kubetypes "k8s.io/apimachinery/pkg/types"
 
-	"open-cluster-management.io/api/client/cloudevents/types"
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 // ResourceHandler handles the received resource object.
@@ -20,7 +20,7 @@ type StatusHashGetter[T ResourceObject] func(obj T) (string, error)
 type ResourceObject interface {
 	// GetUID returns the resource ID of this object. The resource ID represents the unique identifier for this object.
 	// The source should ensure its uniqueness and consistency.
-	GetUID() apitypes.UID
+	GetUID() kubetypes.UID
 
 	// GetResourceVersion returns the resource version of this object. The resource version is a required int64 sequence
 	// number property that must be incremented by the source whenever this resource changes.

diff --git a/...cloudevents/options/fake/sourceoptions.go → ...vents/generic/options/fake/fakeoptions.go b/...cloudevents/options/fake/sourceoptions.go → ...vents/generic/options/fake/fakeoptions.go
@@ -7,7 +7,8 @@ import (
 	cloudevents "github.com/cloudevents/sdk-go/v2"
 	"github.com/cloudevents/sdk-go/v2/event"
 	"github.com/cloudevents/sdk-go/v2/protocol"
-	"open-cluster-management.io/api/client/cloudevents/options"
+
+	"open-cluster-management.io/api/cloudevents/generic/options"
 )
 
 type CloudEventsFakeOptions struct {

diff --git a/.../cloudevents/options/mqtt/agentoptions.go → ...ents/generic/options/mqtt/agentoptions.go b/.../cloudevents/options/mqtt/agentoptions.go → ...ents/generic/options/mqtt/agentoptions.go
@@ -10,8 +10,8 @@ import (
 	cloudeventscontext "github.com/cloudevents/sdk-go/v2/context"
 	"github.com/eclipse/paho.golang/paho"
 
-	"open-cluster-management.io/api/client/cloudevents/options"
-	"open-cluster-management.io/api/client/cloudevents/types"
+	"open-cluster-management.io/api/cloudevents/generic/options"
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 type mqttAgentOptions struct {

diff --git a/...devents/options/mqtt/agentoptions_test.go → ...generic/options/mqtt/agentoptions_test.go b/...devents/options/mqtt/agentoptions_test.go → ...generic/options/mqtt/agentoptions_test.go
@@ -6,7 +6,8 @@ import (
 
 	cloudevents "github.com/cloudevents/sdk-go/v2"
 	cloudeventscontext "github.com/cloudevents/sdk-go/v2/context"
-	"open-cluster-management.io/api/client/cloudevents/types"
+
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 var mockEventDataType = types.CloudEventsDataType{

diff --git a/client/cloudevents/options/mqtt/options.go → cloudevents/generic/options/mqtt/options.go b/client/cloudevents/options/mqtt/options.go → cloudevents/generic/options/mqtt/options.go
diff --git a/...cloudevents/options/mqtt/sourceoptions.go → ...nts/generic/options/mqtt/sourceoptions.go b/...cloudevents/options/mqtt/sourceoptions.go → ...nts/generic/options/mqtt/sourceoptions.go
@@ -9,8 +9,9 @@ import (
 	cloudevents "github.com/cloudevents/sdk-go/v2"
 	cloudeventscontext "github.com/cloudevents/sdk-go/v2/context"
 	"github.com/eclipse/paho.golang/paho"
-	"open-cluster-management.io/api/client/cloudevents/options"
-	"open-cluster-management.io/api/client/cloudevents/types"
+
+	"open-cluster-management.io/api/cloudevents/generic/options"
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 type mqttSourceOptions struct {

diff --git a/...events/options/mqtt/sourceoptions_test.go → ...eneric/options/mqtt/sourceoptions_test.go b/...events/options/mqtt/sourceoptions_test.go → ...eneric/options/mqtt/sourceoptions_test.go
@@ -6,7 +6,8 @@ import (
 
 	cloudevents "github.com/cloudevents/sdk-go/v2"
 	cloudeventscontext "github.com/cloudevents/sdk-go/v2/context"
-	"open-cluster-management.io/api/client/cloudevents/types"
+
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 func TestSourceContext(t *testing.T) {

diff --git a/client/cloudevents/options/options.go → cloudevents/generic/options/options.go b/client/cloudevents/options/options.go → cloudevents/generic/options/options.go
diff --git a/client/cloudevents/payload/payload.go → cloudevents/generic/payload/payload.go b/client/cloudevents/payload/payload.go → cloudevents/generic/payload/payload.go
diff --git a/client/cloudevents/payload/payload_test.go → cloudevents/generic/payload/payload_test.go b/client/cloudevents/payload/payload_test.go → cloudevents/generic/payload/payload_test.go
diff --git a/client/cloudevents/sourceclient.go → cloudevents/generic/sourceclient.go b/client/cloudevents/sourceclient.go → cloudevents/generic/sourceclient.go
@@ -1,4 +1,4 @@
-package cloudevents
+package generic
 
 import (
 	"context"
@@ -10,9 +10,9 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/klog/v2"
 
-	"open-cluster-management.io/api/client/cloudevents/options"
-	"open-cluster-management.io/api/client/cloudevents/payload"
-	"open-cluster-management.io/api/client/cloudevents/types"
+	"open-cluster-management.io/api/cloudevents/generic/options"
+	"open-cluster-management.io/api/cloudevents/generic/payload"
+	"open-cluster-management.io/api/cloudevents/generic/types"
 )
 
 // CloudEventSourceClient is a client for a source to resync/send/receive its resources with cloud events.