MCPcopy Create free account
hub / github.com/TheThingsNetwork/lorawan-stack / Dispatch

Method Dispatch

pkg/telemetry/exporter/task_queue.go:47–47  ·  view source on GitHub ↗

Dispatch the tasks in the queue.

(ctx context.Context, consumerID string)

Source from the content-addressed store, hash-verified

45
46 // Dispatch the tasks in the queue.
47 Dispatch(ctx context.Context, consumerID string) error
48
49 // Pop pops the most recent task in the schedule, for which timestamp is in range [0, time.Now()], the value of
50 // the queue goes through the registered callback and determines which one should be called.

Callers 2

DispatchMethod · 0.65
DispatchTaskFunction · 0.65

Implementers 2

mockTaskQueuepkg/telemetry/exporter/task_queue_test
RedisTaskQueuepkg/telemetry/exporter/task_queue.go

Calls

no outgoing calls

Tested by

no test coverage detected