refactor(dp-server): simplify by removing dataplane_callbacks

api/generic/insights.go

@@ -26,6 +26,7 @@ func GetSubscription[S Subscription, T interface{ GetSubscriptions() []S }](t T,
 type Insight interface {
 	proto.Message
 	IsOnline() bool
+	// GetLastSubscription returns that last subscription or nil if there are no subscriptions
 	GetLastSubscription() Subscription
 	GetSubscription(id string) Subscription
 	AllSubscriptions() []Subscription

pkg/core/resources/apis/mesh/proxy_type.go

@@ -15,6 +15,20 @@ func ProxyTypeFromResourceType(t core_model.ResourceType) (mesh_proto.ProxyType,
 		return mesh_proto.IngressProxyType, nil
 	case ZoneEgressType:
 		return mesh_proto.EgressProxyType, nil
+	default:
+		return "", errors.Errorf("%s does not have a corresponding proxy type", t)
+	}
+}
+
+func ResourceTypeDescriptorFromProxyType(proxyType mesh_proto.ProxyType) (core_model.ResourceTypeDescriptor, error) {
+	switch proxyType {
+	case mesh_proto.DataplaneProxyType:
+		return DataplaneResourceTypeDescriptor, nil
+	case mesh_proto.IngressProxyType:
+		return ZoneIngressResourceTypeDescriptor, nil
+	case mesh_proto.EgressProxyType:
+		return ZoneEgressResourceTypeDescriptor, nil
+	default:
+		return core_model.ResourceTypeDescriptor{}, errors.Errorf("%s does not have a corresponding resource type", proxyType)
 	}
-	return "", errors.Errorf("%s does not have a corresponding proxy type", t)
 }

pkg/core/resources/model/resource.go

@@ -253,28 +253,28 @@ func (d ResourceTypeDescriptor) HasInsights() bool {
 
 func (d ResourceTypeDescriptor) NewInsight() Resource {
 	if !d.HasInsights() {
-		panic("No insight type precondition broken")
+		panic(fmt.Sprintf("No insight for type %s precondition broken", d.Name))
 	}
 	return newObject(d.Insight)
 }
 
 func (d ResourceTypeDescriptor) NewInsightList() ResourceList {
 	if !d.HasInsights() {
-		panic("No insight type precondition broken")
+		panic(fmt.Sprintf("No insight for type %s precondition broken", d.Name))
 	}
 	return d.Insight.Descriptor().NewList()
 }
 
 func (d ResourceTypeDescriptor) NewOverview() Resource {
 	if !d.HasInsights() {
-		panic("No insight type precondition broken")
+		panic(fmt.Sprintf("No insight for type %s precondition broken", d.Name))
 	}
 	return newObject(d.Overview)
 }
 
 func (d ResourceTypeDescriptor) NewOverviewList() ResourceList {
 	if !d.HasInsights() {
-		panic("No insight type precondition broken")
+		panic(fmt.Sprintf("No insight for type %s precondition broken", d.Name))
 	}
 	return d.Overview.Descriptor().NewList()
 }

pkg/util/xds/v3/watchdog_callbacks.go

@@ -14,6 +14,12 @@ type Watchdog interface {
 	Start(ctx context.Context)
 }
 
+type WatchdogFunc func(ctx context.Context)
+
+func (f WatchdogFunc) Start(ctx context.Context) {
+	f(ctx)
+}
+
 type NewNodeWatchdogFunc func(ctx context.Context, node *envoy_core.Node, streamId int64) (Watchdog, error)
 
 func NewWatchdogCallbacks(newNodeWatchdog NewNodeWatchdogFunc) envoy_xds.Callbacks {