Function WithConfig

server/server.go:211–239

(config *Config)

}

func WithConfig(config *Config) ServerOption {
	return serverOptionFunc(func(o *serverOptions) (*serverOptions, error) {
		ln, err := net.Listen("tcp", config.ListenAddr)
		if err != nil {
			return nil, err
		}
		o.httpListener = ln
		o.enableTls = config.EnableTLS
		if o.enableTls {
			if config.TLSCertFile == "" || config.TLSKeyFile == "" {
				return nil, fmt.Errorf("TLS certificate and key file must be provided")
			}
			o.tlsCertFile = config.TLSCertFile
			o.tlsKeyFile = config.TLSKeyFile
		}
		o.tubeConfig = config.TubeConfig
		o.queueConfig = config.Queue
		o.runtimeConfig = config.RuntimeConfig
		if config.StateStore != nil {
			stateStore, err := o.stateStoreLoader(config.StateStore)
			if err != nil {
				return nil, err
			}
			o.managerOpts = append(o.managerOpts, fs.WithStateStore(stateStore))
		}
		o.functionStore = config.FunctionStore
		return o, nil
	})
}

func NewServer(opts ...ServerOption) (*Server, error) {
	options := &serverOptions{}