fetchContainerLog static method

Future<void> fetchContainerLog(Client cloudApiClient, { required void writeln(String), required String projectId, required DateTime? before, required DateTime? after, required int limit, required bool inUtc, })

Implementation

static Future<void> fetchContainerLog(
  final Client cloudApiClient, {
  required final void Function(String) writeln,
  required final String projectId,
  required final DateTime? before,
  required final DateTime? after,
  required final int limit,
  required final bool inUtc,
}) async {
  final timezoneName = inUtc
      ? 'UTC'
      : 'local (${DateTime.now().timeZoneName})';
  writeln(
    'Fetching logs from ${after?.toTzString(inUtc) ?? 'oldest'} '
    'to ${before?.toTzString(inUtc) ?? 'newest'}. Display time zone: $timezoneName.',
  );

  final Stream<LogRecord> recordStream;
  if (before == null && after == null) {
    recordStream = cloudApiClient.logs.fetchRecentRecords(
      cloudCapsuleId: projectId,
      limit: limit,
    );
  } else {
    recordStream = cloudApiClient.logs.fetchRecords(
      cloudCapsuleId: projectId,
      beforeTime: before,
      afterTime: after,
      limit: limit,
    );
  }

  await _outputLogStream(writeln, recordStream, limit: limit, inUtc: inUtc);
}