Include AckEvent

Author: DylanTinianov

pkg/capabilities/triggers/mercury_trigger.go

@@ -37,6 +37,11 @@ type MercuryTriggerService struct {
 	metaOverride       datastreams.Metadata // usually empty, but set to a value in mock trigger
 }
 
+func (o *MercuryTriggerService) AckEvent(ctx context.Context, eventId string) error {
+	//TODO Use BaseTriggerCapability?
+	return nil
+}
+
 var _ capabilities.TriggerCapability = (*MercuryTriggerService)(nil)
 var _ services.Service = &MercuryTriggerService{}
 

pkg/capabilities/triggers/on_demand_trigger.go

@@ -72,6 +72,11 @@ func (o *OnDemand) SendEvent(ctx context.Context, wid string, event capabilities
 	return nil
 }
 
+func (o *OnDemand) AckEvent(ctx context.Context, eventId string) error {
+	//TODO Should this trigger type use BaseTriggerCapability?
+	return nil
+}
+
 func (o *OnDemand) RegisterTrigger(ctx context.Context, req capabilities.TriggerRegistrationRequest) (<-chan capabilities.TriggerResponse, error) {
 	wid := req.Metadata.WorkflowID
 	o.mu.Lock()