server

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

	// TubeFactory is the list of tube factories that the function stream server will use.
	TubeFactory map[string]*FactoryConfig `mapstructure:"tube_factory"`

	// RuntimeFactory is the list of runtime factories that the function stream server will use.
	RuntimeFactory map[string]*FactoryConfig `mapstructure:"runtime_factory"`

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

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

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

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

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

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

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

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