1 files changed, 60 insertions, 0 deletions
diff --git a/weed/topology/data_node.go b/weed/topology/data_node.go
new file mode 100644
index 000000000..bea4729e2
--- /dev/null
+++ b/weed/topology/data_node.go
@@ -0,0 +1,60 @@
+package topology
+
+import (
+	_ "fmt"
+	"weed/storage"
+	"strconv"
+)
+
+type DataNode struct {
+	NodeImpl
+	volumes   map[storage.VolumeId]storage.VolumeInfo
+	Ip        string
+	Port      int
+	PublicUrl string
+	LastSeen  int64 // unix time in seconds
+	Dead      bool
+}
+
+func NewDataNode(id string) *DataNode {
+	s := &DataNode{}
+	s.id = NodeId(id)
+	s.nodeType = "DataNode"
+	s.volumes = make(map[storage.VolumeId]storage.VolumeInfo)
+	s.NodeImpl.value = s
+	return s
+}
+func (dn *DataNode) AddOrUpdateVolume(v storage.VolumeInfo) {
+	if _, ok := dn.volumes[v.Id]; !ok {
+		dn.volumes[v.Id] = v
+		dn.UpAdjustVolumeCountDelta(1)
+		dn.UpAdjustActiveVolumeCountDelta(1)
+		dn.UpAdjustMaxVolumeId(v.Id)
+	} else {
+		dn.volumes[v.Id] = v
+	}
+}
+func (dn *DataNode) GetTopology() *Topology {
+	p := dn.parent
+	for p.Parent() != nil {
+		p = p.Parent()
+	}
+	t := p.(*Topology)
+	return t
+}
+func (dn *DataNode) MatchLocation(ip string, port int) bool {
+	return dn.Ip == ip && dn.Port == port
+}
+func (dn *DataNode) Url() string {
+	return dn.Ip + ":" + strconv.Itoa(dn.Port)
+}
+
+func (dn *DataNode) ToMap() interface{} {
+	ret := make(map[string]interface{})
+	ret["Url"] = dn.Url()
+	ret["Volumes"] = dn.GetVolumeCount()
+	ret["Max"] = dn.GetMaxVolumeCount()
+	ret["Free"] = dn.FreeSpace()
+	ret["PublicUrl"] = dn.PublicUrl
+	return ret
+}