From a84c006368ba5a2e43596d4da6245e843314c5c0 Mon Sep 17 00:00:00 2001
From: Brent Baude <bbaude@redhat.com>
Date: Sun, 29 Mar 2020 18:07:05 -0500
Subject: podmanv2 enable healthcheck run

run healthcheck with podmanv2

Signed-off-by: Brent Baude <bbaude@redhat.com>
---
 pkg/domain/entities/engine_container.go |  4 ++++
 pkg/domain/entities/healthcheck.go      |  3 +++
 pkg/domain/infra/abi/healthcheck.go     | 26 ++++++++++++++++++++++++++
 pkg/domain/infra/tunnel/healthcheck.go  | 13 +++++++++++++
 4 files changed, 46 insertions(+)
 create mode 100644 pkg/domain/entities/healthcheck.go
 create mode 100644 pkg/domain/infra/abi/healthcheck.go
 create mode 100644 pkg/domain/infra/tunnel/healthcheck.go

(limited to 'pkg')

diff --git a/pkg/domain/entities/engine_container.go b/pkg/domain/entities/engine_container.go
index 28be8b225..2ab566238 100644
--- a/pkg/domain/entities/engine_container.go
+++ b/pkg/domain/entities/engine_container.go
@@ -2,6 +2,8 @@ package entities
 
 import (
 	"context"
+
+	"github.com/containers/libpod/libpod/define"
 )
 
 type ContainerEngine interface {
@@ -31,4 +33,6 @@ type ContainerEngine interface {
 	VolumeRm(ctx context.Context, namesOrIds []string, opts VolumeRmOptions) ([]*VolumeRmReport, error)
 	VolumePrune(ctx context.Context, opts VolumePruneOptions) ([]*VolumePruneReport, error)
 	VolumeList(ctx context.Context, opts VolumeListOptions) ([]*VolumeListReport, error)
+
+	HealthCheckRun(ctx context.Context, nameOrId string, options HealthCheckOptions) (*define.HealthCheckResults, error)
 }
diff --git a/pkg/domain/entities/healthcheck.go b/pkg/domain/entities/healthcheck.go
new file mode 100644
index 000000000..a880805f9
--- /dev/null
+++ b/pkg/domain/entities/healthcheck.go
@@ -0,0 +1,3 @@
+package entities
+
+type HealthCheckOptions struct{}
diff --git a/pkg/domain/infra/abi/healthcheck.go b/pkg/domain/infra/abi/healthcheck.go
new file mode 100644
index 000000000..699483243
--- /dev/null
+++ b/pkg/domain/infra/abi/healthcheck.go
@@ -0,0 +1,26 @@
+// +build ABISupport
+
+package abi
+
+import (
+	"context"
+
+	"github.com/containers/libpod/libpod"
+	"github.com/containers/libpod/libpod/define"
+	"github.com/containers/libpod/pkg/domain/entities"
+)
+
+func (ic *ContainerEngine) HealthCheckRun(ctx context.Context, nameOrId string, options entities.HealthCheckOptions) (*define.HealthCheckResults, error) {
+	status, err := ic.Libpod.HealthCheck(nameOrId)
+	if err != nil {
+		return nil, err
+	}
+	hcStatus := "unhealthy"
+	if status == libpod.HealthCheckSuccess {
+		hcStatus = "healthy"
+	}
+	report := define.HealthCheckResults{
+		Status: hcStatus,
+	}
+	return &report, nil
+}
diff --git a/pkg/domain/infra/tunnel/healthcheck.go b/pkg/domain/infra/tunnel/healthcheck.go
new file mode 100644
index 000000000..e589489b3
--- /dev/null
+++ b/pkg/domain/infra/tunnel/healthcheck.go
@@ -0,0 +1,13 @@
+package tunnel
+
+import (
+	"context"
+
+	"github.com/containers/libpod/libpod/define"
+	"github.com/containers/libpod/pkg/bindings/containers"
+	"github.com/containers/libpod/pkg/domain/entities"
+)
+
+func (ic *ContainerEngine) HealthCheckRun(ctx context.Context, nameOrId string, options entities.HealthCheckOptions) (*define.HealthCheckResults, error) {
+	return containers.RunHealthCheck(ic.ClientCxt, nameOrId)
+}
-- 
cgit v1.2.3-54-g00ecf