You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
1.**Choose your base class** based on your service requirements
46
-
2.**Implement the required methods** for message handling and lifecycle management
47
-
3.**Register specifications** (for FlowProcessor) or set up consumers/producers (for AsyncProcessor)
48
-
4.**Add command-line arguments** for configuration
49
-
5.**Create an entry point** for your service
55
+
1.**Choose your base class** based on your service requirements:
56
+
-**Service Base Classes**: For standard patterns (LLM, embeddings, storage, etc.)
57
+
-**FlowProcessor**: For custom flow-aware services
58
+
-**AsyncProcessor**: For global services outside the flow system
59
+
60
+
2.**Implement the required methods**:
61
+
- Service Base Classes: One core method (e.g., `generate_content`, `invoke_tool`)
62
+
- FlowProcessor: Message handlers and specifications
63
+
- AsyncProcessor: Consumers, producers, and lifecycle management
64
+
65
+
3.**Configure your service**:
66
+
- Add command-line arguments for configuration
67
+
- Set up any required dependencies
68
+
- Configure concurrency if supported
69
+
70
+
4.**Create an entry point** for your service
50
71
51
-
Both base classes handle the underlying infrastructure including Pulsar messaging, configuration management, metrics collection, and error handling, allowing you to focus on your service's core logic.
72
+
All base classes handle the underlying infrastructure including Pulsar messaging, configuration management, metrics collection, and error handling, allowing you to focus on your service's core logic.
0 commit comments