func()

in internal/actor/at_least_once_delivery_actor.go [33:58]

• 26 lines of code
• 10 McCabe index (conditional complexity)

func (a *atLeastOnceDeliveryRoutingActor) Receive(actorCtx actor.Context) {
	msg := actorCtx.Message()
	if wrappedMsg, ok := msg.(*actorcomm.SchedulerWrappedMsg); ok {
		msg = wrappedMsg.Msg
	}
	switch innerMsg := msg.(type) {
	case *schedulerx.WorkerReportJobInstanceStatusRequest:
		a.handleReportInstanceStatusEvent(innerMsg)
	case *schedulerx.WorkerBatchReportTaskStatuesRequest:
		a.handleBatchReportTaskStatues(innerMsg)
	case *schedulerx.ContainerBatchReportTaskStatuesRequest:
		a.handleContainerBatchStatus(actorCtx, innerMsg)
	case *schedulerx.MasterDestroyContainerPoolRequest:
		a.handleDestroyContainerPool(actorCtx, innerMsg)
	case *schedulerx.WorkerReportJobInstanceStatusResponse:
		logger.Infof("Receive WorkerReportJobInstanceStatusResponse, resp=%+v", innerMsg)
	case *schedulerx.WorkerBatchReportTaskStatuesResponse:
		logger.Infof("Receive WorkerBatchReportTaskStatuesResponse, resp=%+v", innerMsg)
	case *schedulerx.ContainerBatchReportTaskStatuesResponse:
		logger.Infof("Receive ContainerBatchReportTaskStatuesResponse, resp=%+v", innerMsg)
	case *schedulerx.MasterDestroyContainerPoolResponse:
		logger.Infof("Receive MasterDestroyContainerPoolResponse, resp=%+v", innerMsg)
	default:
		logger.Errorf("Receive unknown message in atLeastOnceDeliveryRoutingActor, msg=%+v", msg)
	}
}