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

Method Enqueue

pkg/runtime/message_queue.go:28–28  ·  view source on GitHub ↗

Enqueue adds a message to the queue. Returns false if the queue is full or the context is cancelled.

(ctx context.Context, msg QueuedMessage)

Source from the content-addressed store, hash-verified

26 // Enqueue adds a message to the queue. Returns false if the queue is
27 // full or the context is cancelled.
28 Enqueue(ctx context.Context, msg QueuedMessage) bool
29 // Dequeue removes and returns the next message from the queue.
30 // Returns the message and true, or a zero value and false if the
31 // queue is empty. Must not block.

Callers 2

SteerMethod · 0.65
FollowUpMethod · 0.65

Implementers 1

inMemoryMessageQueuepkg/runtime/message_queue.go

Calls

no outgoing calls

Tested by

no test coverage detected