Method AddTaskAsSuccess

internal/queues/message-queue.go:12–12 · view source on GitHub ↗

(message types.Process)

Source from the content-addressed store, hash-verified

10	AddTaskToQueue(message types.Process) error
11	AddTaskAsFailed(error error, message types.Process) error
12	AddTaskAsSuccess(message types.Process) error
13	AddTaskAsFinished(message types.Process) error
14	WaitingForFailedTask() (<-chan amqp.Delivery, error)
15	WaitingForSucceedTask() (<-chan amqp.Delivery, error)

addToQueueFunction · 0.65

queueinternal/queues/rabbitmq-queue.go

no outgoing calls

no test coverage detected