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

Method FollowUp

pkg/runtime/runtime.go:1791–1796  ·  view source on GitHub ↗

FollowUp enqueues a message to be processed after the current agent turn finishes. Unlike Steer, follow-ups are popped one at a time and each gets a full undivided agent turn.

(ctx context.Context, msg QueuedMessage)

Source from the content-addressed store, hash-verified

1789// finishes. Unlike Steer, follow-ups are popped one at a time and each gets
1790// a full undivided agent turn.
1791func (r *LocalRuntime) FollowUp(ctx context.Context, msg QueuedMessage) error {
1792 if !r.followUpQueue.Enqueue(ctx, msg) {
1793 return errors.New("follow-up queue full")
1794 }
1795 return nil
1796}
1797
1798func (r *LocalRuntime) QueueStatus() QueueStatus {
1799 status := QueueStatus{}

Callers 1

Calls 2

EnqueueMethod · 0.65
NewMethod · 0.45

Tested by 1