Method ConsumeEvent

fs/manager.go:59–59

(name string)

	ListFunctions() []string
	ProduceEvent(name string, event contube.Record) error
	ConsumeEvent(name string) (contube.Record, error)
	GetStateStore() api.StateStore
	Close() error
}