MCPcopy
hub / github.com/seaweedfs/seaweedfs / DetectionSender

Interface DetectionSender

weed/plugin/worker/worker.go:29–33  ·  view source on GitHub ↗

DetectionSender sends detection responses for one request.

Source from the content-addressed store, hash-verified

27
28// DetectionSender sends detection responses for one request.
29type DetectionSender interface {
30 SendProposals(*plugin_pb.DetectionProposals) error
31 SendComplete(*plugin_pb.DetectionComplete) error
32 SendActivity(*plugin_pb.ActivityEvent) error
33}
34
35// ExecutionSender sends execution progress/completion responses for one request.
36type ExecutionSender interface {

Callers 23

DetectMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65
sendEmptyDetectionMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65
DetectMethod · 0.65

Implementers 10

noopDetectionSenderweed/plugin/worker/testing_senders_tes
recordingDetectionSenderweed/plugin/worker/testing_senders_tes
detectionSenderweed/plugin/worker/worker.go
noopDetectionSenderweed/worker/tasks/erasure_coding/plugi
recordingDetectionSenderweed/worker/tasks/erasure_coding/plugi
noopDetectionSenderweed/worker/tasks/balance/plugin_handl
recordingDetectionSenderweed/worker/tasks/balance/plugin_handl
noopDetectionSenderweed/worker/tasks/vacuum/plugin_handle
recordingDetectionSenderweed/worker/tasks/vacuum/plugin_handle
recordingSenderweed/worker/tasks/s3_lifecycle/handler

Calls

no outgoing calls

Tested by

no test coverage detected