add default role tag

zhangzengfei

2023-05-15 2863a050be2530afc452e48aae8b4be9b3965ebd

add default role tag

 agent.go

@@ -51,6 +51,7 @@
    NodeID              string         `json:"nodeID"`
    NodeAddress         string         `json:"nodeAddress"`
    IsAlive             int            `json:"isAlive"`
    Role                string         `json:"role"`
}

// Create create serf agent with config
@@ -177,6 +178,7 @@
        nodeID,
        nodeAddress,
        isAlive,
        mb.Tags["role"],
    })

    // replace node address
@@ -406,6 +408,7 @@
        node.NodeAddress = mb.Addr.String() + ":" + strconv.Itoa(int(mb.Port))
        node.IsAlive = int(mb.Status)
        node.ClusterID = mb.Tags[tagKeyClusterID]
        node.Role = mb.Tags["role"]

        nodes = append(nodes, node)
    }

 config.go

@@ -163,7 +163,7 @@
    serfConf.MemberlistConfig.BindPort = bindPort
    serfConf.NodeName = c.NodeName

    serfConf.Tags = map[string]string{TagKeyRPCPort: strconv.Itoa(c.RPCPort)}
    serfConf.Tags = map[string]string{TagKeyRPCPort: strconv.Itoa(c.RPCPort), "role": "slave"}

    if c.ClusterID != "" {
        serfConf.Tags[tagKeyClusterID] = c.ClusterID