DockerClientExtensions

DockerClientExtensions.cs

using System;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using Docker.DotNet;
using Docker.DotNet.Models;

public static class DockerClientExtensions
{
    public static async Task WaitForLogMessage(this DockerClient client, string containerId, string pattern, TimeSpan readDelay)
    {
        var buffer = new byte[1024];
        for (int i = 0; i < 120; i++)
        {
            var stream = await client.Containers.GetContainerLogsAsync(containerId, new ContainerLogsParameters { ShowStdout = true, ShowStderr = true });
            var count = await stream.ReadAsync(buffer);
            var logs = System.Text.Encoding.UTF8.GetString(buffer, 0, count);
            if (count > 0 && Regex.IsMatch(logs, pattern))
                break;
            await Task.Delay(readDelay);
        }
    }
}