package main

import (
	"app.yhyue.com/BP/servicerd/proto"
	"log"
)

/**
心跳服务
*/
type Heartbeat struct {
}

//
func (h *Heartbeat) PutStream(cliStr proto.HeartBeat_PutStreamServer) error {
	for {
		if tem, err := cliStr.Recv(); err == nil {
			log.Printf("心跳包-  %s--%s \n", tem.ServiceName, tem.ServiceAddr)
			UpdateServiceMetaTtl(tem.ServiceAddr)
		} else {
			log.Println("break, err :", err)
			break
		}
	}
	return nil
}