Documentation
¶
Overview ¶
Package runnable provides background task runners with recover and keep-alive.
Index ¶
- func Run(ctx context.Context, name string, fn func(ctx context.Context))
- func StartSessionArtifactDeclared(ictx context.Context, eb eventbus.EventBus, db *gorm.DB)
- func StartSessionCompleted(ictx context.Context, service contract.SessionService, eb eventbus.EventBus)
- func StartSessionRunStarted(ictx context.Context, service contract.SessionService, eb eventbus.EventBus)
- func StartSessionTitleHandler(ctx context.Context, service contract.SessionService, eb eventbus.EventBus, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartSessionArtifactDeclared ¶
StartSessionArtifactDeclared 订阅实时产物声明并持久化。
func StartSessionCompleted ¶
func StartSessionCompleted(ictx context.Context, service contract.SessionService, eb eventbus.EventBus)
StartSessionCompleted subscribes to session completed events and dispatches to the service.
func StartSessionRunStarted ¶ added in v0.1.10
func StartSessionRunStarted(ictx context.Context, service contract.SessionService, eb eventbus.EventBus)
StartSessionRunStarted subscribes to run.started events and marks source user messages as processing.
func StartSessionTitleHandler ¶
func StartSessionTitleHandler(ctx context.Context, service contract.SessionService, eb eventbus.EventBus, db *gorm.DB)
StartSessionTitleHandler subscribes to session title update requests and dispatches to the service.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.