Expand description
Implementation of grpc service for flow node
Structs§
- Flow
Service - wrapping flow node manager to avoid orphan rule with Arc<…>
- Flownode
Builder FlownodeInstanceBuilder- Flownode
Instance - The flownode server instance.
- Flownode
Server - Flownode
Server 🔒Inner - FlownodeServerInner is the inner state of FlownodeServer, this struct mostly useful for construct/start and stop the flow node server
- Flownode
Service Builder - Useful in distributed mode
- Frontend
Invoker - Basically a tiny frontend that communicates with datanode, different from
FrontendClientwhich connect to a real frontend instead, this is used for flow’s streaming engine. And is for simple query.
Constants§
Functions§
- get_
all_ 🔒flow_ ids - get all flow ids in this flownode
- get_
flow_ auth_ options