MCPcopy Create free account
hub / github.com/frain-dev/convoy / Write

Method Write

queue/queue.go:18–18  ·  view source on GitHub ↗
(ctx context.Context, taskName convoy.TaskName, queueName convoy.QueueName, job *Job)

Source from the content-addressed store, hash-verified

16// of the producer's; callers don't need to do anything special.
17type Queuer interface {
18 Write(ctx context.Context, taskName convoy.TaskName, queueName convoy.QueueName, job *Job) error
19 WriteWithoutTimeout(ctx context.Context, taskName convoy.TaskName, queueName convoy.QueueName, job *Job) error
20 Options() QueueOptions
21}

Callers 15

runMethod · 0.65
VerifyRequestMethod · 0.65
signPayloadMethod · 0.65
DecodeMsgPackFunction · 0.65
TestWriteMethod · 0.65
TestProcessEventCreatedFunction · 0.65
TestProcessBatchRetryFunction · 0.65
ProcessBatchRetryFunction · 0.65
ProcessEventDeliveryFunction · 0.65

Implementers 5

MockQueuermocks/queue.go
RedisQueuequeue/redis/client.go
testQueueinternal/dataplane/notifications_test.
recordingQueuerapi/public_integration_test.go

Calls

no outgoing calls