From 7d66579b53d831a1b543f9ad20239d1fced303ab Mon Sep 17 00:00:00 2001 From: Alessandro Pagnin Date: Fri, 13 Dec 2024 17:46:37 +0100 Subject: [PATCH] feat: add ConsumerInactiveThreshold to NatsStreamConfiguration (#1014) --- v2/pkg/engine/datasource/pubsub_datasource/pubsub_nats.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/v2/pkg/engine/datasource/pubsub_datasource/pubsub_nats.go b/v2/pkg/engine/datasource/pubsub_datasource/pubsub_nats.go index b6b5e5049..2f1eff224 100644 --- a/v2/pkg/engine/datasource/pubsub_datasource/pubsub_nats.go +++ b/v2/pkg/engine/datasource/pubsub_datasource/pubsub_nats.go @@ -13,8 +13,9 @@ import ( ) type NatsStreamConfiguration struct { - Consumer string `json:"consumer"` - StreamName string `json:"streamName"` + Consumer string `json:"consumer"` + ConsumerInactiveThreshold int32 `json:"consumerInactiveThreshold"` + StreamName string `json:"streamName"` } type NatsEventConfiguration struct {