[New Scheduler] Implement FunctionPullingContainerProxy (#5113)

* Implement FunctionPullingContainerProxy

* Fix type mismatch error

* Fix cannot find Jsonwriter or JsonFormat type

* Fix Unit companion object is not allowed in source

* Add missing resourceTags and imagePullSecret

* Make test case more stable

* Remove unnecessary feature

Author: ningyougang

common/scala/src/main/scala/org/apache/openwhisk/common/TransactionId.scala

@@ -238,6 +238,7 @@ object TransactionId {
   val invokerHealthManager = TransactionId(systemPrefix + "invokerHealthManager") // Invoker startup/shutdown or GC activity
   def invokerHealthActivation = TransactionId(systemPrefix + "invokerHealthActivation") // Invoker health activation
   val invokerWarmup = TransactionId(systemPrefix + "invokerWarmup") // Invoker warmup thread that makes stem-cell containers
+  val invokerColdstart = TransactionId(systemPrefix + "invokerColdstart") //Invoker cold start thread
   val invokerNanny = TransactionId(systemPrefix + "invokerNanny") // Invoker nanny thread
   val dispatcher = TransactionId(systemPrefix + "dispatcher") // Kafka message dispatcher
   val loadbalancer = TransactionId(systemPrefix + "loadbalancer") // Loadbalancer thread

core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/v2/ActivationClientProxy.scala

@@ -18,6 +18,8 @@
 package org.apache.openwhisk.core.containerpool.v2
 
 import akka.actor.ActorRef
+import org.apache.openwhisk.core.connector.ActivationMessage
+import org.apache.openwhisk.core.entity.{DocRevision, FullyQualifiedEntityName}
 import org.apache.openwhisk.core.scheduler.SchedulerEndpoints
 
 // Event send by the actor
@@ -28,6 +30,14 @@ case object CloseClientProxy
 // Event received by the actor
 case object StartClient
 case class RequestActivation(lastDuration: Option[Long] = None, newScheduler: Option[SchedulerEndpoints] = None)
+case class RescheduleActivation(invocationNamespace: String,
+                                fqn: FullyQualifiedEntityName,
+                                rev: DocRevision,
+                                msg: ActivationMessage)
+
+case object RetryRequestActivation
+case object ContainerWarmed
+case object StopClientProxy
 
 // TODO, use grpc to fetch activation from memoryQueue
 class ActivationClientProxy {}