const { NewTelemetryClient, Exporters, TelemetryType } = require('@vtex/diagnostics');

async function main() {
  // Initialize the central telemetry client
  const telemetryClient = await NewTelemetryClient(
    'my-client',
    'my-service'
  );

  // Create an exporter for traces
  const tracesConfig = Exporters.CreateTracesExporterConfig({
    endpoint: 'localhost:4317',
    protocol: 'grpc'
  });
  const tracesExporter = Exporters.CreateExporter(tracesConfig, 'otlp');

  // Initialize traces client
  const tracesClient = await telemetryClient.newTracesClient({
    exporter: tracesExporter,
    setGlobalProvider: true
  });

  // Start tracing
  const span = tracesClient.startSpan('my-operation');
  
  try {
    // Your business logic here
    span.setAttributes({ 'my.attribute': 'value' });
    
    // Record an event
    span.addEvent('processing-started');
    
    // Create a child span for a sub-operation
    const childSpan = tracesClient.startSpan('sub-operation');
    // ... more logic
    childSpan.end();
  } catch (error) {
    span.recordError(error);
    throw error;
  } finally {
    span.end();
  }

  // Graceful shutdown
  await tracesClient.shutdown();
}

main().catch(console.error);

const { NewTelemetryClient, Exporters, TelemetryType } = require('@vtex/diagnostics');

async function setupMetrics() {
  const telemetryClient = await NewTelemetryClient('metrics-client', 'my-service');
  
  const metricsConfig = Exporters.CreateMetricsExporterConfig({
    endpoint: 'localhost:4317'
  });
  const metricsExporter = Exporters.CreateExporter(metricsConfig, 'otlp');
  
  const metricsClient = await telemetryClient.newMetricsClient({
    exporter: metricsExporter
  });

  // Create a counter
  const requestCounter = metricsClient.counter('http_requests_total', [
    { description: 'Total HTTP requests processed' },
    { unit: '1' }
  ]);

  // Create a histogram with custom buckets
  const responseTimeHistogram = metricsClient.histogram('response_time_seconds', [
    { description: 'HTTP response time' },
    { unit: 's' },
    { buckets: [0.01, 0.05, 0.1, 0.5, 1, 5] }
  ]);

  return { metricsClient, requestCounter, responseTimeHistogram };
}

const { NewTelemetryClient, Exporters, TelemetryType } = require('@vtex/diagnostics');

async function setupLogging() {
  const telemetryClient = await NewTelemetryClient('logs-client', 'my-service');
  
  const logsConfig = Exporters.CreateLogsExporterConfig({
    endpoint: 'localhost:4317'
  });
  const logsExporter = Exporters.CreateExporter(logsConfig, 'otlp');
  
  const logsClient = await telemetryClient.newLogsClient({
    exporter: logsExporter
  });

  // Log different levels
  logsClient.info('Application started', { version: '1.0.0' });
  logsClient.warn('Resource usage high', { cpu: 0.85 });
  
  try {
    // Some operation that might fail
    throw new Error('Database connection failed');
  } catch (err) {
    logsClient.error('Operation failed', { error: err.message });
  }

  return logsClient;
}