diff --git a/appservices/event_triggers.go b/appservices/event_triggers.go index f4c2081..86b5081 100644 --- a/appservices/event_triggers.go +++ b/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"` } diff --git a/appservices/event_triggers_test.go b/appservices/event_triggers_test.go index 1b0f3b5..8cb29d2 100644 --- a/appservices/event_triggers_test.go +++ b/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{}{