Function NewServer

server/server.go:241–333

(opts ...ServerOption)

}

func NewServer(opts ...ServerOption) (*Server, error) {
	options := &serverOptions{}
	options.tubeFactoryBuilders = make(map[string]func(configMap common.ConfigMap) (contube.TubeFactory, error))
	options.tubeConfig = make(map[string]common.ConfigMap)
	options.runtimeFactoryBuilders = make(map[string]func(configMap common.ConfigMap) (api.FunctionRuntimeFactory, error))
	options.runtimeConfig = make(map[string]common.ConfigMap)
	options.stateStoreLoader = DefaultStateStoreLoader
	for _, o := range opts {
		if o == nil {
			continue
		}
		_, err := o.apply(options)
		if err != nil {
			return nil, err
		}
	}
	var log *common.Logger
	if options.log == nil {
		log = common.NewDefaultLogger()
	} else {
		log = common.NewLogger(options.log)
	}
	if options.httpTubeFact == nil {
		options.httpTubeFact = contube.NewHttpTubeFactory(context.Background())
		log.Info("Using the default HTTP tube factory")
	}
	options.managerOpts = []fs.ManagerOption{
		fs.WithTubeFactory("http", options.httpTubeFact),
	}

	options.managerOpts = append(options.managerOpts, fs.WithLogger(log.Logger))

	// Config Tube Factory
	if tubeFactories, err := setupFactories(options.tubeFactoryBuilders, options.tubeConfig); err == nil {
		for name, f := range tubeFactories {
			options.managerOpts = append(options.managerOpts, fs.WithTubeFactory(name, f))
		}
	} else {
		return nil, err
	}

	// Config Runtime Factory
	if runtimeFactories, err := setupFactories(options.runtimeFactoryBuilders, options.runtimeConfig); err == nil {
		for name, f := range runtimeFactories {
			options.managerOpts = append(options.managerOpts, fs.WithRuntimeFactory(name, f))
		}
	} else {
		return nil, err
	}

	// Config Queue Factory
	if options.queueConfig.Type != "" {
		queueFactoryBuilder, ok := options.tubeFactoryBuilders[options.queueConfig.Type]
		if !ok {
			return nil, fmt.Errorf("%w, queueType: %s", ErrUnsupportedQueueType, options.queueConfig.Type)
		}
		queueFactory, err := queueFactoryBuilder(options.queueConfig.Config)
		if err != nil {