feat: autoscaling for MonoVertex

Signed-off-by: Derek Wang <[email protected]>

hack/generate-proto.sh

@@ -75,6 +75,8 @@ gen-protoc(){
 
 gen-protoc pkg/apis/proto/daemon/daemon.proto
 
+gen-protoc pkg/apis/proto/mvtxdaemon/mvtxdaemon.proto
+
 gen-protoc pkg/apis/proto/isb/message.proto
 
 gen-protoc pkg/apis/proto/wmb/wmb.proto

pkg/apis/numaflow/v1alpha1/mono_vertex_types.go

@@ -123,6 +123,14 @@ func (mv MonoVertex) GetDaemonDeploymentName() string {
 	return fmt.Sprintf("%s-mv-daemon", mv.Name)
 }
 
+func (mv MonoVertex) GetDaemonServiceURL() string {
+	return fmt.Sprintf("%s.%s.svc:%d", mv.GetDaemonServiceName(), mv.Namespace, MonoVertexDaemonServicePort)
+}
+
+func (mv MonoVertex) Scalable() bool {
+	return !mv.Spec.Scale.Disabled
+}
+
 func (mv MonoVertex) GetDaemonServiceObj() *corev1.Service {
 	labels := map[string]string{
 		KeyPartOf:         Project,
@@ -518,6 +526,18 @@ func (mvs *MonoVertexStatus) MarkPhaseRunning() {
 	mvs.MarkPhase(MonoVertexPhaseRunning, "", "")
 }
 
+// IsHealthy indicates whether the MonoVertex is in healthy status
+func (mvs *MonoVertexStatus) IsHealthy() bool {
+	switch mvs.Phase {
+	case MonoVertexPhaseFailed:
+		return false
+	case MonoVertexPhaseRunning:
+		return mvs.IsReady()
+	default:
+		return false
+	}
+}
+
 // +kubebuilder:object:root=true
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 type MonoVertexList struct {