Method initContainers

pkg/controller/init.go:78–111

()

}

func (controller *Controller) initContainers() (err error) {
	// TODO: sync from funclet for more runtime information
	nodeInfo, err := controller.FuncletClient.NodeInfo(&api.FuncletClientListNodeInput{RequestID: id.GetRequestID()})
	if err != nil {
		return err
	}
	params := &rtctrl.RuntimeManagerParameters{
		MaxRuntimeIdle:        controller.runOptions.MaxRuntimeIdle,
		MaxRunnerDefunct:      controller.runOptions.MaxRunnerDefunct,
		MaxRunnerResetTimeout: controller.runOptions.MaxRunnerResetTimeout,
	}
	controller.runtimeDispatcher = rtctrl.NewRuntimeManager(nodeInfo, params)

	res, err := controller.FuncletClient.List(&api.FuncletClientListContainersInput{RequestID: id.GetRequestID()})
	if err != nil {
		return err
	}
	allContainers := *res
	logs.Infof("get container %+v", allContainers)

	for _, container := range allContainers {
		// set default runtime concurrent mode from service option
		params := &rtctrl.NewRuntimeParameters{
			RuntimeID:               container.ContainerID,
			ConcurrentMode:          controller.runOptions.ConcurrentMode,
			StreamMode:              container.WithStreamMode,
			WaitRuntimeAliveTimeout: controller.runOptions.RuntimeConfigOptions.WaitRuntimeAliveTimeout,
			IsFrozen:                container.IsFrozen,
			Resource:                container.Resource,
		}
		controller.runtimeDispatcher.NewRuntime(params)
	}
	return nil
}