// A countingDialer dials connections and counts the number that remain reachable.
type countingDialer struct {
	dialer      net.Dialer
	mu          sync.Mutex
	total, live int64
}

func (d *countingDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
	conn, err := d.dialer.DialContext(ctx, network, address)
	if err != nil {
		return nil, err
	}

	counted := new(countedConn)

String id=52
	data="net.(*sysDialer).dialSerial"
String id=53
	data="net.(*sysDialer).dialParallel"
String id=54
	data="net.(*Dialer).DialContext"
String id=55
	data="net.(*Dialer).Dial"
String id=56
	data="net.Dial"
String id=57
	data="runtime.chansend1"
String id=58
	data="/usr/local/google/home/mknyszek/work/go-1/src/runtime/chan.go"
String id=59

function setup-fluentd {
  local -r dst_dir="$1"
  local -r fluentd_gcp_yaml="${dst_dir}/fluentd-gcp/fluentd-gcp-ds.yaml"
  local -r fluentd_gcp_scaler_yaml="${dst_dir}/fluentd-gcp/scaler-deployment.yaml"
  # Ingest logs against new resources like "k8s_container" and "k8s_node" if
  # LOGGING_STACKDRIVER_RESOURCE_TYPES is "new".
  # Ingest logs against old resources like "gke_container" and "gce_instance" if