func()

in pcap-fsnotify/internal/gcs/client_library_exporter.go [159:197]

• 34 lines of code
• 2 McCabe index (conditional complexity)

func (x *libraryExporter) dialContext(
	ctx context.Context,
	addr string,
) (net.Conn, error) {
	address := x.gcsRemoteAddr(&addr)

	data := map[string]any{
		"endpoint": addr,
		"address":  address,
		"bucket":   x.bucket,
	}

	if conn, err := x.connect(ctx, &address); err != nil {
		x.logger.LogEvent(
			zapcore.ErrorLevel,
			sf.Format("failed to connect to GCS: {0}", address),
			PCAP_EXPORT,
			data,
			err)
		return nil, err
	} else {
		remoteAddrStr := conn.RemoteAddr().String()

		info := map[string]any{
			"local":  conn.LocalAddr().String(),
			"remote": remoteAddrStr,
		}
		maps.Copy(info, data)

		x.logger.LogEvent(
			zapcore.InfoLevel,
			sf.Format("connected to GCS via: {0} => {1}", address, remoteAddrStr),
			PCAP_EXPORT,
			info,
			nil)

		return conn, nil
	}
}