MCPcopy
hub / github.com/uptrace/uptrace / Options

Method Options

pkg/taskq/queue.go:134–134  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

132 fmt.Stringer
133 Name() string
134 Options() *QueueConfig
135 Consumer() QueueConsumer
136
137 Len(ctx context.Context) (int, error)

Callers 2

NewConsumerFunction · 0.65
HandleJobMethod · 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

no test coverage detected