Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

server

package

Go to main page

Versions in this module

v0

v0.5.0

Jun 13, 2024

Changes in this version

+ var ErrUnsupportedQueueType = errors.New("unsupported queue type")

+ func GetBuiltinRuntimeFactoryBuilder() ...

+ func GetBuiltinTubeFactoryBuilder() map[string]func(configMap common.ConfigMap) (contube.TubeFactory, error)

type Config

+ EnableTLS bool

+ FunctionStore string

+ Queue QueueConfig

+ RuntimeConfig map[string]common.ConfigMap

+ TLSCertFile string

+ TLSKeyFile string

+ TubeConfig map[string]common.ConfigMap

+ type FunctionStore interface

+ Load func() error

+ func NewFunctionStoreDisabled() FunctionStore

+ func NewFunctionStoreImpl(fm fs.FunctionManager, path string) (FunctionStore, error)

+ type FunctionStoreDisabled struct

+ func (f *FunctionStoreDisabled) Load() error

+ type FunctionStoreImpl struct

+ func (f *FunctionStoreImpl) Load() error

+ type QueueConfig struct

+ Config common.ConfigMap

+ Type string

type Server

+ FunctionStore FunctionStore

type ServerOption

+ func WithLogger(log *logr.Logger) ServerOption

+ func WithQueueConfig(config QueueConfig) ServerOption

+ func WithRuntimeFactoryBuilder(name string, ...) ServerOption

+ func WithRuntimeFactoryBuilders(...) ServerOption

+ func WithTubeFactoryBuilder(name string, ...) ServerOption

+ func WithTubeFactoryBuilders(...) ServerOption

v0.4.0

May 7, 2024

Changes in this version

+ var ErrUnsupportedStateStore = errors.New("unsupported state store")

+ var ErrUnsupportedTRuntimeType = errors.New("unsupported runtime type")

+ var ErrUnsupportedTubeType = errors.New("unsupported tube type")

+ func DefaultRuntimeLoader(c *FactoryConfig) (api.FunctionRuntimeFactory, error)

+ func DefaultStateStoreLoader(c *StateStoreConfig) (api.StateStore, error)

+ func DefaultTubeLoader(c *FactoryConfig) (contube.TubeFactory, error)

+ type Config struct

+ ListenAddr string

+ RuntimeFactory map[string]*FactoryConfig

+ StateStore *StateStoreConfig

+ TubeFactory map[string]*FactoryConfig

+ func LoadConfigFromFile(filePath string) (*Config, error)

+ type FactoryConfig struct

+ Config *common.ConfigMap

+ Ref *string

+ Type *string

+ type RuntimeLoaderType func(c *FactoryConfig) (api.FunctionRuntimeFactory, error)

type ServerOption

+ func WithConfig(config *Config) ServerOption

+ func WithRuntimeLoader(loader RuntimeLoaderType) ServerOption

+ func WithStateStoreLoader(loader func(c *StateStoreConfig) (api.StateStore, error)) ServerOption

+ func WithTubeLoader(loader TubeLoaderType) ServerOption

+ type StateStoreConfig struct

+ Config *common.ConfigMap

+ Type *string

+ type StateStoreLoaderType func(c *StateStoreConfig) (api.StateStore, error)

+ type TubeLoaderType func(c *FactoryConfig) (contube.TubeFactory, error)

v0.3.0

Mar 8, 2024

Changes in this version

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

+ func LoadConfigFromEnv() *common.Config

+ func LoadStandaloneConfigFromEnv() *common.Config

+ type Server struct

+ Manager *fs.FunctionManager

+ 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

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

+ func WithHttpListener(listener net.Listener) ServerOption

+ func WithHttpTubeFactory(factory *contube.HttpTubeFactory) ServerOption