func CreateDatanodeClient()

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
}