Function addEntity

controller/mutators/etcd/common.go:26–51

(entityList pb.EntityList, name string)

)

func addEntity(entityList pb.EntityList, name string) (res pb.EntityList, incarnation int, exist bool) {
	nowTs := utils.Now().UnixNano()
	for _, entityName := range entityList.Entities {
		if name == entityName.Name {
			if !entityName.Tomstoned {
				exist = true
				return
			}
			entityName.Incarnation++
			incarnation = int(entityName.Incarnation)
			entityName.Tomstoned = false
			entityName.LastUpdatedAt = nowTs
			entityList.LastUpdatedAt = nowTs
			return entityList, incarnation, false
		}
	}

	entityList.Entities = append(entityList.Entities, &pb.EntityName{
		Name:          name,
		Tomstoned:     false,
		Incarnation:   0,
		LastUpdatedAt: nowTs,
	})
	entityList.LastUpdatedAt = nowTs
	return entityList, incarnation, false
}

func readValue(etcdStore kv.TxnStore, key string, out proto.Message) (version int, err error) {
	var value kv.Value