feat(core): add pods details to firehose output (#103)

Author: rohilsurana

core/core.go

@@ -4,7 +4,8 @@ package core
 //go:generate mockery --name=ModuleService -r --case underscore --with-expecter --structname ModuleService  --filename=module_service.go --output=./mocks
 
 import (
-	"context"
+	context "context"
+	"encoding/json"
 	"time"
 
 	"go.uber.org/zap"
@@ -26,7 +27,8 @@ type Service struct {
 type ModuleService interface {
 	PlanAction(ctx context.Context, res module.ExpandedResource, act module.ActionRequest) (*module.Plan, error)
 	SyncState(ctx context.Context, res module.ExpandedResource) (*resource.State, error)
-	StreamLogs(ctx context.Context, spec module.ExpandedResource, filter map[string]string) (<-chan module.LogChunk, error)
+	StreamLogs(ctx context.Context, res module.ExpandedResource, filter map[string]string) (<-chan module.LogChunk, error)
+	GetOutput(ctx context.Context, res module.ExpandedResource) (json.RawMessage, error)
 }
 
 type AsyncWorker interface {

core/mocks/driver.go

@@ -26,6 +26,10 @@ type Driver interface {
 	// Sync can return state in resource.StatusDeleted to indicate resource
 	// should be removed from the Entropy storage.
 	Sync(ctx context.Context, res ExpandedResource) (*resource.State, error)
+
+	// Output returns the current external state of the resource
+	// Output should not have any side effects on any external resource
+	Output(ctx context.Context, res ExpandedResource) (json.RawMessage, error)
 }
 
 // Plan represents the changes to be staged and later synced by module.
@@ -38,7 +42,7 @@ type Plan struct {
 type Loggable interface {
 	Driver
 
-	Log(ctx context.Context, spec ExpandedResource, filter map[string]string) (<-chan LogChunk, error)
+	Log(ctx context.Context, res ExpandedResource, filter map[string]string) (<-chan LogChunk, error)
 }
 
 // ExpandedResource represents the context for Plan() or Sync() invocations.

core/mocks/loggable_module.go

@@ -79,8 +79,8 @@ func (desc Descriptor) validateDependencies(dependencies map[string]ResolvedDepe
 	return nil
 }
 
-func (desc Descriptor) validateActionReq(spec ExpandedResource, req ActionRequest) error {
-	kind := spec.Resource.Kind
+func (desc Descriptor) validateActionReq(res ExpandedResource, req ActionRequest) error {
+	kind := res.Resource.Kind
 
 	actDesc := desc.findAction(req.Name)
 	if actDesc == nil {