From d3099dc275b3b395335e00ca13b3ec0b1dbc36bf Mon Sep 17 00:00:00 2001
From: napnap75 <thomas@nappez.com>
Date: Sun, 11 Jun 2023 15:46:33 +0200
Subject: [PATCH] Corrected error following new docker client version

---
 docker2mqtt/docker2mqtt.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/docker2mqtt/docker2mqtt.go b/docker2mqtt/docker2mqtt.go
index 8fe1472..8232f0c 100644
--- a/docker2mqtt/docker2mqtt.go
+++ b/docker2mqtt/docker2mqtt.go
@@ -8,14 +8,17 @@ import (
 	"os/signal"
 	"time"
 	"github.com/docker/docker/api/types"
+	"github.com/docker/docker/api/types/container"
 	"github.com/docker/docker/client"
 	"github.com/eclipse/paho.mqtt.golang"
 )
 
 func restartHandler(client mqtt.Client, msg mqtt.Message, dockerClient *client.Client, dockerContext context.Context) {
 	fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
-	var timeout = 30*time.Second
-	err := dockerClient.ContainerRestart(dockerContext, string(msg.Payload()), &timeout)
+	var timeout = int(30*time.Second)
+	var options container.StopOptions
+	options.Timeout = &timeout
+	err := dockerClient.ContainerRestart(dockerContext, string(msg.Payload()), options)
 	if err != nil {
 		fmt.Fprintf(os.Stderr, "Unable to restart container %s: %v\n", msg.Payload(), err)
 	} else {