Interface FunctionManager

fs/manager.go:54–62

}

type FunctionManager interface {
	StartFunction(f *model.Function) error
	DeleteFunction(namespace, name string) error
	ListFunctions() []string
	ProduceEvent(name string, event contube.Record) error
	ConsumeEvent(name string) (contube.Record, error)
	GetStateStore() api.StateStore
	Close() error
}

type functionManagerImpl struct {
	options       *managerOptions