Function Init

pkg/controller/init.go:34–76

(options *options.ControllerOptions)

)

func Init(options *options.ControllerOptions) (controller *Controller, err error) {
	controller = &Controller{
		runOptions:    options,
		FuncletClient: client.NewFuncletClient(options.FuncletClientOptions),
	}

	for {
		err := controller.initContainers()
		if err != nil {
			logs.Errorf("get container failed: %s", err.Error())
			time.Sleep(time.Second)
		} else {
			break
		}
	}

	controller.runtimeControl, err = rtctrl.NewRuntimeClient(options.RuntimeConfigOptions,
		options.DispatcherV2Options, controller.runtimeDispatcher)
	if err != nil {
		return nil, err
	}
	cacheConfig := function.DefaultCacheExpirationConfigs()
	cacheConfig[function.CacheTypeAlias] = options.AliasCacheOptions.CacheExpiration
	controller.dataStorer, err = function.NewDataStorer(options.RepositoryOptions, function.NewStorageCache(cacheConfig))
	insideRepositoryOptions := options.RepositoryOptions
	insideRepositoryOptions.Version = "inside-v1"
	controller.insideDataStorer, err = function.NewDataStorer(insideRepositoryOptions, function.NewStorageCache(cacheConfig))
	if options.HTTPEnhanced {
		if options.HttpTriggerRepositoryOptions.IsEmpty() {
			controller.httpTriggerDataStorer, err = function.NewDataStorer(insideRepositoryOptions, function.NewStorageCache(cacheConfig))
		} else {
			controller.httpTriggerDataStorer, err = function.NewDataStorer(options.HttpTriggerRepositoryOptions, function.NewStorageCache(cacheConfig))
		}
	}
	if err != nil {
		return nil, err
	}
	go controller.cronTask(options)
	if options.RecommendedOptions.Features.EnableMetrics {
		go controller.metricTask(options)
	}
	return
}

func (controller *Controller) initContainers() (err error) {
	// TODO: sync from funclet for more runtime information