MCPcopy Create free account
hub / github.com/docker/docker-agent / forwardEvents

Method forwardEvents

pkg/tools/builtin/rag/rag.go:112–124  ·  view source on GitHub ↗

forwardEvents reads events from the RAG manager and forwards them via the callback.

(ctx context.Context)

Source from the content-addressed store, hash-verified

110
111// forwardEvents reads events from the RAG manager and forwards them via the callback.
112func (t *ToolSet) forwardEvents(ctx context.Context) {
113 for {
114 select {
115 case <-ctx.Done():
116 return
117 case event, ok := <-t.manager.Events():
118 if !ok {
119 return
120 }
121 t.eventCallback(event)
122 }
123 }
124}
125
126func (t *ToolSet) Instructions() string {
127 if t.manager != nil {

Callers 1

StartMethod · 0.95

Implementers 15

StartableToolSetpkg/tools/startable.go
fakeToolSetpkg/tools/named_test.go
stubDescriberpkg/tools/startable_test.go
stubToolSetpkg/tools/startable_test.go
flappyToolSetpkg/tools/startable_test.go
listFlappyToolSetpkg/tools/startable_test.go
reportingToolSetpkg/tools/startable_test.go
reportingStartOnlyToolSetpkg/tools/startable_test.go
recoveryFailingToolSetpkg/tools/startable_test.go
codeModeToolpkg/tools/codemode/codemode.go
testToolSetpkg/tools/codemode/codemode_test.go
Toolsetpkg/tools/a2a/a2a.go

Calls 1

EventsMethod · 0.80

Tested by

no test coverage detected