feat: add plugin ping

Author: Mahanmmi

go.mod

@@ -15,7 +15,7 @@ require (
 	github.com/hashicorp/go-plugin v1.6.0
 	github.com/jackc/pgtype v1.14.4
 	github.com/nats-io/nats.go v1.36.0
-	github.com/opengovern/og-util v1.10.1
+	github.com/opengovern/og-util v1.11.0
 	github.com/opengovern/resilient-bridge v0.0.0-20241223164127-85ad8f42a67d
 	github.com/shurcooL/githubv4 v0.0.0-20240727222349-48295856cce7
 	github.com/spf13/cobra v1.8.1

go.sum

@@ -743,8 +743,8 @@ github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8
 github.com/opencontainers/go-digest v1.0.0/go.mod h1:0JzlMkj0TRzQZfJkVvzbP0HBR3IKzErnv2BNG4W4MAM=
 github.com/opencontainers/image-spec v1.1.0 h1:8SG7/vwALn54lVB/0yZ/MMwhFrPYtpEHQb2IpWsCzug=
 github.com/opencontainers/image-spec v1.1.0/go.mod h1:W4s4sFTMaBeK1BQLXbG4AdM2szdn85PY75RI83NrTrM=
-github.com/opengovern/og-util v1.10.1 h1:D51GVWKI1J1d9v50z6Eg4gG0Q79+aFLGrxe4ynJCAck=
-github.com/opengovern/og-util v1.10.1/go.mod h1:9uNpGalixRoQkUzPPBdT+JG1epg8FTRx/qmkfTyUZHE=
+github.com/opengovern/og-util v1.11.0 h1:Amct1bHXDF5TBnymstPUEWpWaC+Lji5dnJ8Mr6fkbMA=
+github.com/opengovern/og-util v1.11.0/go.mod h1:9uNpGalixRoQkUzPPBdT+JG1epg8FTRx/qmkfTyUZHE=
 github.com/opengovern/resilient-bridge v0.0.0-20241223164127-85ad8f42a67d h1:OnoG1Za89armxN1ZlEbr/eKvAdbRN6UGKXCFxee58s0=
 github.com/opengovern/resilient-bridge v0.0.0-20241223164127-85ad8f42a67d/go.mod h1:zEulaGgccj5tPXGiudGz17NRhXAk2HHh+GPj2VkjNq0=
 github.com/opensearch-project/opensearch-go/v2 v2.3.0 h1:nQIEMr+A92CkhHrZgUhcfsrZjibvB3APXf2a1VwCmMQ=

platform/integration.go

@@ -14,7 +14,7 @@ import (
 
 type Integration struct{}
 
-func (i *Integration) GetConfiguration() interfaces.IntegrationConfiguration {
+func (i *Integration) GetConfiguration() (interfaces.IntegrationConfiguration, error) {
 	return interfaces.IntegrationConfiguration{
 		NatsScheduledJobsTopic:   global.JobQueueTopic,
 		NatsManualJobsTopic:      global.JobQueueTopicManuals,
@@ -30,7 +30,7 @@ func (i *Integration) GetConfiguration() interfaces.IntegrationConfiguration {
 
 		DescriberDeploymentName: constants.DescriberDeploymentName,
 		DescriberRunCommand:     constants.DescriberRunCommand,
-	}
+	}, nil
 }
 
 func (i *Integration) HealthCheck(jsonData []byte, providerId string, labels map[string]string, annotations map[string]string) (bool, error) {
@@ -98,19 +98,19 @@ func (i *Integration) GetResourceTypesByLabels(labels map[string]string) (map[st
 	return resourceTypesMap, nil
 }
 
-func (i *Integration) GetResourceTypeFromTableName(tableName string) string {
+func (i *Integration) GetResourceTypeFromTableName(tableName string) (string, error) {
 	if v, ok := maps.TablesToResourceTypes[tableName]; ok {
-		return v
+		return v, nil
 	}
 
-	return ""
+	return "", nil
 }
 
-func (i *Integration) GetIntegrationType() integration.Type {
-	return constants.IntegrationName
+func (i *Integration) GetIntegrationType() (integration.Type, error) {
+	return constants.IntegrationName, nil
 }
 
-func (i *Integration) ListAllTables() map[string][]interfaces.CloudQLColumn {
+func (i *Integration) ListAllTables() (map[string][]interfaces.CloudQLColumn, error) {
 	plugin := global.Plugin()
 	tables := make(map[string][]interfaces.CloudQLColumn)
 	for tableKey, table := range plugin.TableMap {
@@ -121,5 +121,9 @@ func (i *Integration) ListAllTables() map[string][]interfaces.CloudQLColumn {
 		tables[tableKey] = columns
 	}
 
-	return tables
+	return tables, nil
+}
+
+func (i *Integration) Ping() error {
+	return nil
 }