MCPcopy
hub / github.com/uptrace/uptrace / AddJob

Method AddJob

pkg/taskq/queue.go:138–138  ·  view source on GitHub ↗
(ctx context.Context, msg *Job)

Source from the content-addressed store, hash-verified

136
137 Len(ctx context.Context) (int, error)
138 AddJob(ctx context.Context, msg *Job) error
139 ReserveN(ctx context.Context, n int, waitTimeout time.Duration) ([]Job, error)
140 Release(ctx context.Context, msg *Job) error
141 Delete(ctx context.Context, msg *Job) error

Callers 15

Example_customRateLimitFunction · 0.95
Example_retryOnErrorFunction · 0.95
Example_messageDelayFunction · 0.95
Example_rateLimitFunction · 0.95
Example_onceFunction · 0.95
UpsertMetricsFunction · 0.65
ProcessMethod · 0.65
mainFunction · 0.65
TestConsumerFunction · 0.65
TestUnknownTaskFunction · 0.65
TestFallbackFunction · 0.65
TestDelayFunction · 0.65

Implementers 3

Queuepkg/taskq/pgq/queue.go
Queuepkg/taskq/redisq/queue.go
Queuepkg/taskq/memqueue/queue.go

Calls

no outgoing calls

Tested by 15

Example_customRateLimitFunction · 0.76
Example_retryOnErrorFunction · 0.76
Example_messageDelayFunction · 0.76
Example_rateLimitFunction · 0.76
Example_onceFunction · 0.76
TestConsumerFunction · 0.52
TestUnknownTaskFunction · 0.52
TestFallbackFunction · 0.52
TestDelayFunction · 0.52
TestRetryFunction · 0.52
TestNamedJobFunction · 0.52
TestCallOnceFunction · 0.52