wip

pkg/capabilities/capabilities.go

@@ -350,6 +350,8 @@ type RemoteTargetConfig struct {
 
 type RemoteExecutableConfig struct {
 	RequestHashExcludedAttributes []string
+	RegistrationRefresh           time.Duration
+	RegistrationExpiry            time.Duration
 }
 
 // NOTE: consider splitting this config into values stored in Registry (KS-118)
@@ -375,6 +377,18 @@ func (c *RemoteTriggerConfig) ApplyDefaults() {
 	}
 }
 
+func (c *RemoteExecutableConfig) ApplyDefaults() {
+	if c == nil {
+		return
+	}
+	if c.RegistrationRefresh == 0 {
+		c.RegistrationRefresh = DefaultRegistrationRefresh
+	}
+	if c.RegistrationExpiry == 0 {
+		c.RegistrationExpiry = DefaultRegistrationExpiry
+	}
+}
+
 type CapabilityConfiguration struct {
 	DefaultConfig          *values.Map
 	RemoteTriggerConfig    *RemoteTriggerConfig

pkg/capabilities/pb/registry.proto

@@ -28,6 +28,8 @@ message RemoteExecutableConfig {
   // when calculating the hash of the request.  This is useful for excluding attributes that are not deterministic to ensure
   // that the hash of logically identical requests is consistent.
   repeated string requestHashExcludedAttributes = 1;
+  google.protobuf.Duration registrationRefresh = 2;
+  google.protobuf.Duration registrationExpiry = 3;
 }
 
 message CapabilityConfig {

pkg/loop/internal/core/services/capability/capabilities_registry.go

@@ -115,6 +115,8 @@ func (cr *capabilitiesRegistryClient) ConfigForCapability(ctx context.Context, c
 		prtc := res.CapabilityConfig.GetRemoteExecutableConfig()
 		remoteExecutableConfig = &capabilities.RemoteExecutableConfig{}
 		remoteExecutableConfig.RequestHashExcludedAttributes = prtc.RequestHashExcludedAttributes
+		remoteExecutableConfig.RegistrationRefresh = prtc.RegistrationRefresh.AsDuration()
+		remoteExecutableConfig.RegistrationExpiry = prtc.RegistrationExpiry.AsDuration()
 	}
 
 	return capabilities.CapabilityConfiguration{
@@ -352,6 +354,16 @@ func (c *capabilitiesRegistryServer) ConfigForCapability(ctx context.Context, re
 		}
 	}
 
+	if cc.RemoteExecutableConfig != nil {
+		ccp.RemoteConfig = &capabilitiespb.CapabilityConfig_RemoteExecutableConfig{
+			RemoteExecutableConfig: &capabilitiespb.RemoteExecutableConfig{
+				RequestHashExcludedAttributes: cc.RemoteExecutableConfig.RequestHashExcludedAttributes,
+				RegistrationRefresh:           durationpb.New(cc.RemoteExecutableConfig.RegistrationRefresh),
+				RegistrationExpiry:            durationpb.New(cc.RemoteExecutableConfig.RegistrationExpiry),
+			},
+		}
+	}
+
 	return &pb.ConfigForCapabilityReply{
 		CapabilityConfig: ccp,
 	}, nil