in api/datanode/datanode.go [89:101]
func CreateDatanodeClient(pipeline *hdds.Pipeline) (*DatanodeClient, error) {
dnClient := &DatanodeClient{
ctx: context.Background(),
pipelineId: pipeline.Id,
datanodes: pipeline.Members,
memberIndex: -1,
}
err := dnClient.connectToNext()
if err != nil {
return nil, err
}
return dnClient, nil
}