def METHOD_NAME(aggregator, instance):
    c = GnatsdStreamingCheck(CHECK_NAME, {}, [instance])
    c.check(instance)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.serverz.clients', 'nss-cluster_id', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.serverz.clients', 'nss-server_id', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.serverz.clients', 'nss-version', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.serverz.clients', 'nss-go', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.storez.total_msgs', 'nss-cluster_id', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.storez.total_msgs', 'nss-server_id', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.clientsz.total', 'nss-cluster_id', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.clientsz.total', 'nss-server_id', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.channelsz.total', 'nss-cluster_id', at_least=1)
    aggregator.assert_metric_has_tag_prefix('gnatsd.streaming.channelsz.total', 'nss-server_id', at_least=1)