MCPcopy
hub / github.com/cubefs/cubefs / ResponseDataNodeTask

Method ResponseDataNodeTask

sdk/master/api_node.go:112–114  ·  view source on GitHub ↗
(task *proto.AdminTask)

Source from the content-addressed store, hash-verified

110}
111
112func (api *NodeAPI) ResponseDataNodeTask(task *proto.AdminTask) (err error) {
113 return api.mc.request(newRequest(post, proto.GetDataNodeTaskResponse).Header(api.h).Body(task))
114}
115
116func (api *NodeAPI) DataNodeDecommission(nodeAddr string, count int, clientIDKey string, raftForce bool, weight int) (err error) {
117 request := newRequest(get, proto.DecommissionDataNode).Header(api.h).NoTimeout()

Callers 5

handleUpdateVerPacketMethod · 0.80
handleHeartbeatPacketMethod · 0.80
handleHeartbeatsMethod · 0.80

Calls 4

BodyMethod · 0.80
newRequestFunction · 0.70
requestMethod · 0.45
HeaderMethod · 0.45

Tested by

no test coverage detected