Add event timeout to protos

Author: DylanTinianov

pkg/capabilities/capabilities.go

@@ -552,6 +552,7 @@ func MustNewRemoteCapabilityInfo(
 const (
 	DefaultRegistrationRefresh       = 30 * time.Second
 	DefaultRegistrationExpiry        = 2 * time.Minute
+	DefaultEventTimeout              = 2 * time.Minute // TODO: determine best value
 	DefaultMessageExpiry             = 2 * time.Minute
 	DefaultBatchSize                 = 100
 	DefaultBatchCollectionPeriod     = 100 * time.Millisecond
@@ -562,6 +563,7 @@ const (
 type RemoteTriggerConfig struct {
 	RegistrationRefresh     time.Duration
 	RegistrationExpiry      time.Duration
+	EventTimeout            time.Duration
 	MinResponsesToAggregate uint32
 	MessageExpiry           time.Duration
 	MaxBatchSize            uint32
@@ -595,6 +597,9 @@ func (c *RemoteTriggerConfig) ApplyDefaults() {
 	if c.RegistrationExpiry == 0 {
 		c.RegistrationExpiry = DefaultRegistrationExpiry
 	}
+	if c.EventTimeout == 0 {
+		c.EventTimeout = DefaultEventTimeout
+	}
 	if c.MessageExpiry == 0 {
 		c.MessageExpiry = DefaultMessageExpiry
 	}

pkg/capabilities/pb/registry.pb.go

@@ -10,10 +10,11 @@ import "google/protobuf/duration.proto";
 message RemoteTriggerConfig {
   google.protobuf.Duration registrationRefresh = 1;
   google.protobuf.Duration registrationExpiry = 2;
-  uint32 minResponsesToAggregate = 3;
-  google.protobuf.Duration messageExpiry = 4;
-  uint32 maxBatchSize = 5;
-  google.protobuf.Duration batchCollectionPeriod = 6;
+  google.protobuf.Duration eventTimeout =3;
+  uint32 minResponsesToAggregate = 4;
+  google.protobuf.Duration messageExpiry = 5;
+  uint32 maxBatchSize = 6;
+  google.protobuf.Duration batchCollectionPeriod = 7;
 }
 
 // deprecated - v1 only

pkg/capabilities/pb/registry.proto

@@ -187,6 +187,7 @@ func decodeRemoteTriggerConfig(prtc *capabilitiespb.RemoteTriggerConfig) *capabi
 	remoteTriggerConfig := &capabilities.RemoteTriggerConfig{}
 	remoteTriggerConfig.RegistrationRefresh = prtc.RegistrationRefresh.AsDuration()
 	remoteTriggerConfig.RegistrationExpiry = prtc.RegistrationExpiry.AsDuration()
+	remoteTriggerConfig.EventTimeout = prtc.EventTimeout.AsDuration()
 	remoteTriggerConfig.MinResponsesToAggregate = prtc.MinResponsesToAggregate
 	remoteTriggerConfig.MessageExpiry = prtc.MessageExpiry.AsDuration()
 	remoteTriggerConfig.MaxBatchSize = prtc.MaxBatchSize