server

Documentation

Index

• Variables
• func DefaultStateStoreLoader(c *StateStoreConfig) (api.StateStore, error)
• func GetBuiltinRuntimeFactoryBuilder() ...
• func GetBuiltinTubeFactoryBuilder() map[string]func(configMap common.ConfigMap) (contube.TubeFactory, error)
• type Config
  • func LoadConfigFromEnv() (*Config, error)
  • func LoadConfigFromFile(filePath string) (*Config, error)
• type FactoryConfig
• type FunctionStore
  • func NewFunctionStoreDisabled() FunctionStore
  • func NewFunctionStoreImpl(fm fs.FunctionManager, path string) (FunctionStore, error)
• type FunctionStoreDisabled
  • func (f *FunctionStoreDisabled) Load() error
• type FunctionStoreImpl
  • func (f *FunctionStoreImpl) Load() error
• type QueueConfig
• type RuntimeLoaderType
• type Server
  • func NewDefaultServer() (*Server, error)
  • func NewServer(opts ...ServerOption) (*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
  • func WithConfig(config *Config) ServerOption
  • func WithHttpListener(listener net.Listener) ServerOption
  • func WithHttpTubeFactory(factory *contube.HttpTubeFactory) ServerOption
  • func WithLogger(log *logr.Logger) ServerOption
  • func WithQueueConfig(config QueueConfig) ServerOption
  • func WithRuntimeFactoryBuilder(name string, ...) ServerOption
  • func WithRuntimeFactoryBuilders(...) ServerOption
  • func WithStateStoreLoader(loader func(c *StateStoreConfig) (api.StateStore, error)) ServerOption
  • func WithTubeFactoryBuilder(name string, ...) ServerOption
  • func WithTubeFactoryBuilders(...) ServerOption
• type StateStoreConfig
• type StateStoreLoaderType
• type TubeLoaderType

Variables

var (
	ErrUnsupportedStateStore = errors.New("unsupported state store")
	ErrUnsupportedQueueType  = errors.New("unsupported queue type")
)

Functions

func DefaultStateStoreLoader

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

func GetBuiltinRuntimeFactoryBuilder

func GetBuiltinRuntimeFactoryBuilder() map[string]func(configMap common.ConfigMap) (api.FunctionRuntimeFactory, error)

func GetBuiltinTubeFactoryBuilder

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

Types

type Config

type Config struct {
	// ListenAddr is the address that the function stream REST service will listen on.
	ListenAddr string `mapstructure:"listen-addr"`

	Queue QueueConfig `mapstructure:"queue"`

	TubeConfig map[string]common.ConfigMap `mapstructure:"tube-config"`

	RuntimeConfig map[string]common.ConfigMap `mapstructure:"runtime-config"`

	// StateStore is the configuration for the state store that the function stream server will use.
	// Optional
	StateStore *StateStoreConfig `mapstructure:"state-store"`

	// FunctionStore is the path to the function store
	FunctionStore string `mapstructure:"function-store"`

	EnableTLS   bool   `mapstructure:"enable-tls"`
	TLSCertFile string `mapstructure:"tls-cert-file"`
	TLSKeyFile  string `mapstructure:"tls-key-file"`
}

func LoadConfigFromEnv

func LoadConfigFromEnv() (*Config, error)

func LoadConfigFromFile

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

type FactoryConfig

type FactoryConfig struct {
	// Deprecate
	Ref    *string           `mapstructure:"ref"`
	Type   *string           `mapstructure:"type"`
	Config *common.ConfigMap `mapstructure:"config"`
}

type FunctionStore

type FunctionStore interface {
	Load() error
}

func NewFunctionStoreDisabled

func NewFunctionStoreDisabled() FunctionStore

func NewFunctionStoreImpl

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

type FunctionStoreDisabled

type FunctionStoreDisabled struct {
}

func (*FunctionStoreDisabled) Load

func (f *FunctionStoreDisabled) Load() error

type FunctionStoreImpl

type FunctionStoreImpl struct {
	// contains filtered or unexported fields
}

func (*FunctionStoreImpl) Load

func (f *FunctionStoreImpl) Load() error

type QueueConfig

type QueueConfig struct {
	Type   string           `mapstructure:"type"`
	Config common.ConfigMap `mapstructure:"config"`
}

type RuntimeLoaderType

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

type Server

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

func NewDefaultServer

func NewDefaultServer() (*Server, error)

func NewServer

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

func (*Server) Close

func (s *Server) Close() error

func (*Server) Run

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

func (*Server) WaitForReady

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

type ServerOption

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

func WithConfig

func WithConfig(config *Config) ServerOption

func WithHttpListener

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

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.

func WithLogger

func WithLogger(log *logr.Logger) ServerOption

func WithQueueConfig

func WithQueueConfig(config QueueConfig) ServerOption

func WithRuntimeFactoryBuilder

func WithRuntimeFactoryBuilder(
	name string,
	builder func(configMap common.ConfigMap) (api.FunctionRuntimeFactory, error),
) ServerOption

func WithRuntimeFactoryBuilders

func WithRuntimeFactoryBuilders(
	builder map[string]func(configMap common.ConfigMap) (api.FunctionRuntimeFactory, error),
) ServerOption

func WithStateStoreLoader

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

func WithTubeFactoryBuilder

func WithTubeFactoryBuilder(
	name string,
	builder func(configMap common.ConfigMap) (contube.TubeFactory, error),
) ServerOption

func WithTubeFactoryBuilders

func WithTubeFactoryBuilders(
	builder map[string]func(configMap common.ConfigMap,
	) (contube.TubeFactory, error)) ServerOption

type StateStoreConfig

type StateStoreConfig struct {
	Type   *string           `mapstructure:"type"`
	Config *common.ConfigMap `mapstructure:"config"`
}

type StateStoreLoaderType

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

type TubeLoaderType

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