MCPcopy
hub / github.com/seaweedfs/seaweedfs / sendEmptyDetection

Method sendEmptyDetection

weed/worker/tasks/iceberg/handler.go:631–644  ·  view source on GitHub ↗
(sender pluginworker.DetectionSender)

Source from the content-addressed store, hash-verified

629}
630
631func (h *Handler) sendEmptyDetection(sender pluginworker.DetectionSender) error {
632 if err := sender.SendProposals(&plugin_pb.DetectionProposals{
633 JobType: jobType,
634 Proposals: []*plugin_pb.JobProposal{},
635 HasMore: false,
636 }); err != nil {
637 return err
638 }
639 return sender.SendComplete(&plugin_pb.DetectionComplete{
640 JobType: jobType,
641 Success: true,
642 TotalProposals: 0,
643 })
644}
645
646// dialFiler connects to a filer at the given gRPC address. The address must
647// already be a dialable host:grpcPort: Detect resolves it from

Callers 1

DetectMethod · 0.95

Calls 2

SendProposalsMethod · 0.65
SendCompleteMethod · 0.65

Tested by

no test coverage detected