server

package

v0.3.0 Latest Latest Go to latest Published: Mar 8, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

func ConstructFunction(function *restclient.Function) (*model.Function, error)

func LoadConfigFromEnv() *common.Config

func LoadStandaloneConfigFromEnv() *common.Config

type Server struct {
	Manager *fs.FunctionManager
	// contains filtered or unexported fields
}

func NewDefaultServer() (*Server, error)

func NewServer(opts ...ServerOption) (*Server, error)

func NewServerWithConfig(config *common.Config) (*Server, error)

func (s *Server) Close() error

func (s *Server) Run(context context.Context)

func (s *Server) WaitForReady(ctx context.Context) <-chan struct{}

type ServerOption interface {
	// contains filtered or unexported methods
}

func WithFunctionManager(opts ...fs.ManagerOption) ServerOption

WithFunctionManager sets the function Manager for the server.

func WithHttpListener(listener net.Listener) ServerOption

WithHttpListener sets the listener for the HTTP server. If not set, the server will listen on the Config.ListenAddr.

func WithHttpTubeFactory(factory *contube.HttpTubeFactory) ServerOption

WithHttpTubeFactory sets the factory for the HTTP tube. If not set, the server will use the default HTTP tube factory.