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

Method Add

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

Add telemetry task identified by `id` at time t. Implementations must ensure that Add returns fast.

(ctx context.Context, id string, t time.Time, replace bool)

Source from the content-addressed store, hash-verified

37 // Add telemetry task identified by `id` at time t.
38 // Implementations must ensure that Add returns fast.
39 Add(ctx context.Context, id string, t time.Time, replace bool) error
40
41 // RegisterCallback registers a callback that is called when a task is popped.
42 // All callbacks should be registered before the dispatch of the tasks in the queue, otherwise they are proned to

Callers 15

TestGPSConversionFunction · 0.65
ParseFunction · 0.65
TestCacheKeyVaultFunction · 0.65
TestConcurrentTaskSetFunction · 0.65
CallbackWithIntervalFunction · 0.65
AddMethod · 0.65
shouldSendTelemetryFunction · 0.65
handleEventsMethod · 0.65
runTestSubscriptionsFunction · 0.65
SubscribeMethod · 0.65
relDurationFunction · 0.65

Implementers 2

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

Calls

no outgoing calls

Tested by 15

TestGPSConversionFunction · 0.52
TestCacheKeyVaultFunction · 0.52
TestConcurrentTaskSetFunction · 0.52
runTestSubscriptionsFunction · 0.52
TestBatchOperationsFunction · 0.52
fetchEntityRightsFunction · 0.52
requireAuthInfoFunction · 0.52
requireRightsFunction · 0.52
timeTravelFunction · 0.52
TestPbaFunction · 0.52
TestTaskBackoffResetFunction · 0.52