feat: Adds support for new attributes for Trigger configuration (#6)

Author: maastha

appservices/event_triggers.go

@@ -210,4 +210,7 @@ type EventTriggerConfig struct {
 	ScheduleType             string      `json:"schedule_type,omitempty"`
 	Unordered                *bool       `json:"unordered,omitempty"`
 	ClusterName              string      `json:"clusterName,omitempty"`
+	TolerateResumeErrors     *bool       `json:"tolerate_resume_errors,omitempty"`
+	SkipCatchupEvents        *bool       `json:"skip_catchup_events,omitempty"`
+	MaximumThroughput        *bool       `json:"maximum_throughput,omitempty"`
 }

appservices/event_triggers_test.go

@@ -128,6 +128,9 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
 			Project:                  `{"updateDescription.updatedFields.FieldA": 1, "operationType": 1}`,
 			FullDocument:             pointy.Bool(false),
 			FullDocumentBeforeChange: pointy.Bool(false),
+			TolerateResumeErrors:     pointy.Bool(true),
+			SkipCatchupEvents:        pointy.Bool(true),
+			MaximumThroughput:        pointy.Bool(true),
 			Unordered:                pointy.Bool(false),
 		},
 		EventProcessors: map[string]interface{}{
@@ -159,6 +162,9 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
 				"full_document":               false,
 				"full_document_before_change": false,
 				"unordered":                   false,
+				"tolerate_resume_errors":      true,
+				"skip_catchup_events":         true,
+				"maximum_throughput":          true,
 			},
 			"event_processors": map[string]interface{}{
 				"AWS_EVENTBRIDGE": map[string]interface{}{
@@ -204,7 +210,10 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
 		  "project": {"updateDescription.updatedFields.FieldA": 1, "operationType": 1},
 		  "full_document": false,
 		  "full_document_before_change": false,
-		  "unordered": false
+		  "unordered": false,
+		  "tolerate_resume_errors": true,
+		  "skip_catchup_events": true,
+		  "maximum_throughput": true
 		 },
 		"event_processors": {
 		   "AWS_EVENTBRIDGE": {
@@ -248,6 +257,9 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
 			FullDocument:             pointy.Bool(false),
 			FullDocumentBeforeChange: pointy.Bool(false),
 			Unordered:                pointy.Bool(false),
+			TolerateResumeErrors:     pointy.Bool(true),
+			SkipCatchupEvents:        pointy.Bool(true),
+			MaximumThroughput:        pointy.Bool(true),
 			ClusterName:              "cluster name",
 		},
 		EventProcessors: map[string]interface{}{