diff --git a/tests/certification/go.sum b/tests/certification/go.sum index 084876035f..7ef70a2259 100644 --- a/tests/certification/go.sum +++ b/tests/certification/go.sum @@ -35,7 +35,7 @@ cloud.google.com/go/datastore v1.1.0/go.mod h1:umbIZjpQpHh4hmRpGhH4tLFup+FVzqBi1 cloud.google.com/go/firestore v1.1.0/go.mod h1:ulACoGHTpvq5r8rxGJ4ddJZBZqakUQqClKRT5SZwBmk= cloud.google.com/go/iam v1.0.0 h1:hlQJMovyJJwYjZcTohUH4o1L8Z8kYz+E+W/zktiLCBc= cloud.google.com/go/iam v1.0.0/go.mod h1:ikbQ4f1r91wTmBmmOtBCOtuEOei6taatNXytzB7Cxew= -cloud.google.com/go/kms v1.10.0 h1:Imrtp8792uqNP9bdfPrjtUkjjqOMBcAJ2bdFaAnLhnk= +cloud.google.com/go/kms v1.10.1 h1:7hm1bRqGCA1GBRQUrp831TwJ9TWhP+tvLuP497CQS2g= cloud.google.com/go/longrunning v0.4.1 h1:v+yFJOfKC3yZdY6ZUI933pIYdhyhV8S3NpWrXWmg7jM= cloud.google.com/go/pubsub v1.0.1/go.mod h1:R0Gpsv3s54REJCy4fxDixWD93lHJMoZTyQ2kNxGRt3I= cloud.google.com/go/pubsub v1.1.0/go.mod h1:EwwdRX2sKPjnvnqCa270oGRyludottCI76h+R3AArQw= diff --git a/workflows/requests.go b/workflows/requests.go index 04b084ff18..02b7f6db3d 100644 --- a/workflows/requests.go +++ b/workflows/requests.go @@ -34,3 +34,8 @@ type PauseRequest struct { type ResumeRequest struct { InstanceID string `json:"instanceID"` } + +// PurgeRequest is the object describing a Purge request. +type PurgeRequest struct { + InstanceID string `json:"instanceID"` +} diff --git a/workflows/temporal/temporal.go b/workflows/temporal/temporal.go index abcc66c49c..0b528c04c0 100644 --- a/workflows/temporal/temporal.go +++ b/workflows/temporal/temporal.go @@ -149,6 +149,11 @@ func (c *TemporalWF) RaiseEvent(ctx context.Context, req *workflows.RaiseEventRe return c.client.SignalWorkflow(ctx, req.InstanceID, "", req.EventName, decodedEventData) } +func (c *TemporalWF) Purge(ctx context.Context, req *workflows.PurgeRequest) error { + // Unimplemented + return nil +} + func (c *TemporalWF) Close() { c.client.Close() } diff --git a/workflows/workflow.go b/workflows/workflow.go index 5d45a9f7fc..1dee2ba398 100644 --- a/workflows/workflow.go +++ b/workflows/workflow.go @@ -27,6 +27,7 @@ type Workflow interface { Terminate(ctx context.Context, req *TerminateRequest) error Get(ctx context.Context, req *GetRequest) (*StateResponse, error) RaiseEvent(ctx context.Context, req *RaiseEventRequest) error + Purge(ctx context.Context, req *PurgeRequest) error Pause(ctx context.Context, req *PauseRequest) error Resume(ctx context.Context, req *ResumeRequest) error GetComponentMetadata() map[string]string