func ValidateHeartBeat()

in runtime/core/protocol/grpc/validator/validator.go [116:129]

• 14 lines of code
• 7 McCabe index (conditional complexity)

func ValidateHeartBeat(hb *pb.Heartbeat) error {
	if hb.ClientType == pb.Heartbeat_SUB && hb.ConsumerGroup == "" {
		return ErrHeartbeatNoConsumerGroup
	}
	if hb.ClientType == pb.Heartbeat_PUB && hb.ProducerGroup == "" {
		return ErrHeartbeatNoProducerGroup
	}
	for _, item := range hb.HeartbeatItems {
		if item.Topic == "" {
			return ErrHeartbeatNoTopic
		}
	}
	return nil
}