server

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"`
}

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

type FunctionStore interface {
	Load() error
}

type FunctionStoreDisabled struct {
}

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

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

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

type Server struct {
	Manager       fs.FunctionManager
	FunctionStore FunctionStore
	// 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)