MCPcopy
hub / github.com/cortexlabs/cortex / SendMessage

Method SendMessage

pkg/async-gateway/queue.go:27–27  ·  view source on GitHub ↗
(message string, uniqueID string)

Source from the content-addressed store, hash-verified

25// Queue is an interface to abstract communication with event queues
26type Queue interface {
27 SendMessage(message string, uniqueID string) error
28}
29
30type sqs struct {

Callers 8

EnqueueMethod · 0.65
TestSQSDequeuer_ReceiveMessageFunction · 0.65
TestSQSDequeuer_StartMessageRenewerFunction · 0.65
TestSQSDequeuerTerminationOnEmptyQueueFunction · 0.65
TestSQSDequeuer_Start_HandlerErrorFunction · 0.65
onJobCompleteMethod · 0.65
CreateWorkloadMethod · 0.65
SendMessageMethod · 0.65

Implementers 1

sqspkg/async-gateway/queue.go

Calls

no outgoing calls

Tested by 4

TestSQSDequeuer_ReceiveMessageFunction · 0.52
TestSQSDequeuer_StartMessageRenewerFunction · 0.52
TestSQSDequeuerTerminationOnEmptyQueueFunction · 0.52
TestSQSDequeuer_Start_HandlerErrorFunction · 0.52