Mega refactoring. Integration DI #3

components/boggart/bind.go

@@ -1,8 +1,6 @@
 package boggart
 
 import (
-	"context"
-
 	"github.com/kihamo/go-workers/event"
 )
 
@@ -40,11 +38,3 @@ type Bind interface{}
 type BindRunner interface {
 	Run() error
 }
-
-type BindHasReadinessProbe interface {
-	ReadinessProbe(context.Context) error
-}
-
-type BindHasLivenessProbe interface {
-	LivenessProbe(context.Context) error
-}

components/boggart/bind/broadlink/rm/bind.go

@@ -9,6 +9,7 @@ import (
 
 type Bind struct {
 	di.MQTTBind
+	di.ProbesBind
 
 	config *ConfigRM
 

components/boggart/bind/broadlink/sp3s/bind.go

@@ -12,6 +12,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 

components/boggart/bind/chromecast/bind.go

@@ -37,6 +37,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config *Config
 

components/boggart/bind/ds18b20/bind.go

@@ -8,6 +8,7 @@ import (
 type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 }

components/boggart/bind/esphome/mqtt/bind.go

@@ -11,6 +11,7 @@ import (
 type Bind struct {
 	di.MetaBind
 	di.MQTTBind
+	di.ProbesBind
 
 	config     *Config
 	components sync.Map

components/boggart/bind/esphome/native_api/bind.go

@@ -23,6 +23,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config   *Config
 	provider *api.Client

components/boggart/bind/fcm/bind.go

@@ -11,6 +11,7 @@ import (
 
 type Bind struct {
 	di.MQTTBind
+	di.ProbesBind
 
 	config    *Config
 	messaging *messaging.Client

components/boggart/bind/google_home/bind.go

@@ -9,6 +9,7 @@ type Bind struct {
 	di.MetaBind
 	di.WorkersBind
 	di.LoggerBind
+	di.ProbesBind
 
 	provider *home.Client
 }

components/boggart/bind/grafana/bind.go

@@ -8,6 +8,7 @@ import (
 type Bind struct {
 	di.MQTTBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config   *Config
 	provider *grafana.Client

components/boggart/bind/herospeed/bind.go

@@ -9,6 +9,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 	client *herospeed.Client

components/boggart/bind/hikvision/bind.go

@@ -29,6 +29,7 @@ type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
 	di.LoggerBind
+	di.ProbesBind
 
 	mutex sync.RWMutex
 

components/boggart/bind/hilink/bind.go

@@ -25,6 +25,7 @@ type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config                    *Config
 	client                    *hilink.Client

components/boggart/bind/homie/esp/bind.go

@@ -18,6 +18,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config     *Config
 	lastUpdate atomic.TimeNull

components/boggart/bind/integratorit/elektroset/bind.go

@@ -8,6 +8,7 @@ import (
 type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 	client *elektroset.Client

components/boggart/bind/integratorit/mosenergosbyt/bind.go

@@ -13,6 +13,7 @@ var services = map[string]string{
 type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 	client *mosenergosbyt.Client

components/boggart/bind/led_wifi/bind.go

@@ -11,6 +11,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 	bulb   *wifiled.Bulb

components/boggart/bind/lg_webos/bind.go

@@ -29,6 +29,7 @@ type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config *Config
 	mutex  sync.RWMutex

components/boggart/bind/mercury/v1/bind.go

@@ -8,6 +8,7 @@ import (
 type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config   *Config
 	provider *mercury.MercuryV1

components/boggart/bind/mercury/v3/bind.go

@@ -9,6 +9,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config   *Config
 	provider *mercury.MercuryV3

components/boggart/bind/mikrotik/bind.go

@@ -22,6 +22,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config            *Config
 	address           *url.URL

components/boggart/bind/nut/bind.go

@@ -13,6 +13,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config    *Config
 	mutex     sync.Mutex

components/boggart/bind/octoprint/bind.go

@@ -9,6 +9,7 @@ type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config   *Config
 	provider *octoprint.Client

components/boggart/bind/pulsar/bind.go

@@ -12,6 +12,7 @@ const (
 type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config   *Config
 	provider *pulsar.HeatMeter

components/boggart/bind/rkcm/bind.go

@@ -9,6 +9,7 @@ type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config *Config
 	client *rkcm.Client

components/boggart/bind/samsung_tizen/bind.go

@@ -11,6 +11,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 	mutex  sync.RWMutex

components/boggart/bind/serial/bind.go

@@ -11,6 +11,7 @@ type Bind struct {
 	status uint32 // 0 - default, 1 - started, 2 - failed
 
 	di.LoggerBind
+	di.ProbesBind
 
 	server serial_network.Server
 }

components/boggart/bind/softvideo/bind.go

@@ -10,6 +10,7 @@ import (
 type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config   *Config
 	provider *softvideo.Client

components/boggart/bind/telegram/bind.go

@@ -18,6 +18,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config *Config
 

components/boggart/bind/xiaomi/roborock/miio/bind.go

@@ -9,6 +9,7 @@ type Bind struct {
 	di.MetaBind
 	di.MQTTBind
 	di.WorkersBind
+	di.ProbesBind
 
 	config *Config
 	device *vacuum.Device

components/boggart/bind/xmeye/bind.go

@@ -16,6 +16,7 @@ type Bind struct {
 	di.MQTTBind
 	di.WorkersBind
 	di.LoggerBind
+	di.ProbesBind
 
 	config         *Config
 	alarmStreaming *xmeye.AlertStreaming